feat(http): support external trasnport component

Author: Matrix-X

src/kernel/accessToken.go

@@ -358,24 +358,27 @@ func (accessToken *AccessToken) OverrideGetMiddlewareOfLog() {
 	accessToken.GetMiddlewareOfLog = func(logger contract2.LoggerInterface) contract3.RequestMiddleware {
 		return func(handle contract3.RequestHandle) contract3.RequestHandle {
 			return func(request *http.Request) (response *http.Response, err error) {
-				logger := logger.WithContext(request.Context())
-
-				// 此处请求前后日志根据 log 配置中的 level 判断是否打印
-				request2.LogRequest(logger, request)
-
+				defer func() {
+					config := (accessToken.App).GetConfig()
+					debug := config.GetBool("http_debug", false)
+					if debug {
+						logger := logger.WithContext(request.Context())
+						// 此处请求前后日志根据 log 配置中的 level 判断是否打印
+						request2.LogRequest(logger, request)
+						if response != nil {
+							response2.LogResponse(logger, response)
+						}
+					}
+				}()
 				response, err = handle(request)
 				if err != nil {
 					return response, err
 				}
-
-				response2.LogResponse(logger, response)
-
 				return
 			}
 		}
 	}
 }
-
 func (accessToken *AccessToken) OverrideGetEndpoint() {
 	accessToken.GetEndpoint = func() (string, error) {
 		if accessToken.EndpointToGetToken == "" {

src/kernel/baseClient.go

@@ -448,17 +448,22 @@ func (client *BaseClient) OverrideGetMiddlewareOfLog() {
 	client.GetMiddlewareOfLog = func(logger contract2.LoggerInterface) contract.RequestMiddleware {
 		return func(handle contract.RequestHandle) contract.RequestHandle {
 			return func(request *http.Request) (response *http.Response, err error) {
-				logger = logger.WithContext(request.Context())
-
-				// 此处请求前后日志根据 log 配置中的 level 判断是否打印
-				request2.LogRequest(logger, request)
-
+				config := (*client.App).GetConfig()
+				defer func() {
+					debug := config.GetBool("http_debug", false)
+					if debug {
+						logger := logger.WithContext(request.Context())
+						// 此处请求前后日志根据 log 配置中的 level 判断是否打印
+						request2.LogRequest(logger, request)
+						if response != nil {
+							response2.LogResponse(logger, response)
+						}
+					}
+				}()
 				response, err = handle(request)
 				if err != nil {
 					return response, err
 				}
-				response2.LogResponse(logger, response)
-
 				return
 			}
 		}

src/kernel/request/request.go

@@ -34,5 +34,5 @@ func LogRequest(logger contract2.LoggerInterface, request *http.Request) {
 		output.Write(body)
 	}
 
-	logger.Info(output.String())
+	logger.Debug(output.String())
 }

src/kernel/response/response.go

@@ -13,5 +13,5 @@ func LogResponse(logger contract2.LoggerInterface, response *http.Response) {
 	output.Write([]byte("response content:"))
 	dumpRes, _ := httputil.DumpResponse(response, true)
 	output.Write(dumpRes)
-	logger.Info(output.String())
+	logger.Debug(output.String())
 }