|
|
@ -81,14 +81,14 @@ func NewTransport(debug bool) *retry.Transport {
|
|
|
|
func (t *LoggingTransport) RoundTrip(req *http.Request) (resp *http.Response, err error) {
|
|
|
|
func (t *LoggingTransport) RoundTrip(req *http.Request) (resp *http.Response, err error) {
|
|
|
|
id := atomic.AddUint64(&requestCount, 1) - 1
|
|
|
|
id := atomic.AddUint64(&requestCount, 1) - 1
|
|
|
|
|
|
|
|
|
|
|
|
slog.Debug("Request", "id", id, "url", req.URL, "method", req.Method, "header", logHeader(req.Header))
|
|
|
|
slog.Debug(req.Method, "id", id, "url", req.URL, "header", logHeader(req.Header))
|
|
|
|
resp, err = t.RoundTripper.RoundTrip(req)
|
|
|
|
resp, err = t.RoundTripper.RoundTrip(req)
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|
slog.Debug("Response", "id", id, "error", err)
|
|
|
|
slog.Debug("Response"[:len(req.Method)], "id", id, "error", err)
|
|
|
|
} else if resp != nil {
|
|
|
|
} else if resp != nil {
|
|
|
|
slog.Debug("Response", "id", id, "status", resp.Status, "header", logHeader(resp.Header), "body", logResponseBody(resp))
|
|
|
|
slog.Debug("Response"[:len(req.Method)], "id", id, "status", resp.Status, "header", logHeader(resp.Header), "body", logResponseBody(resp))
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
slog.Debug("Response", "id", id, "response", "nil")
|
|
|
|
slog.Debug("Response"[:len(req.Method)], "id", id, "response", "nil")
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
return resp, err
|
|
|
|
return resp, err
|
|
|
|