Skip to content

Commit 008f990

Browse files
fixed request and response function to send logs to AI (Azure#495)
1 parent c2665f3 commit 008f990

File tree

1 file changed

+28
-0
lines changed

1 file changed

+28
-0
lines changed

cns/logger/log.go

Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -117,10 +117,38 @@ func Errorf(format string, args ...interface{}) {
117117

118118
func Request(tag string, request interface{}, err error) {
119119
Log.logger.Request(tag, request, err)
120+
121+
if Log.th == nil || Log.DisableTraceLogging {
122+
return
123+
}
124+
125+
var msg string
126+
if err == nil {
127+
msg = fmt.Sprintf("[%s] Received %T %+v.", tag, request, request)
128+
} else {
129+
msg = fmt.Sprintf("[%s] Failed to decode %T %+v %s.", tag, request, request, err.Error())
130+
}
131+
132+
sendTraceInternal(msg)
120133
}
121134

122135
func Response(tag string, response interface{}, returnCode int, returnStr string, err error) {
123136
Log.logger.Response(tag, response, returnCode, returnStr, err)
137+
138+
if Log.th == nil || Log.DisableTraceLogging {
139+
return
140+
}
141+
142+
var msg string
143+
if err == nil && returnCode == 0 {
144+
msg = fmt.Sprintf("[%s] Sent %T %+v.", tag, response, response)
145+
} else if err != nil {
146+
msg = fmt.Sprintf("[%s] Code:%s, %+v %s.", tag, returnStr, response, err.Error())
147+
} else {
148+
msg = fmt.Sprintf("[%s] Code:%s, %+v.", tag, returnStr, response)
149+
}
150+
151+
sendTraceInternal(msg)
124152
}
125153

126154
// Send AI telemetry metric

0 commit comments

Comments
 (0)