fix log

main.go

@@ -937,46 +937,52 @@ func main() {
 
 		slogfiber.AddCustomAttributes(c, slog.String(TaskIdAtrr, taskId))
 
+		queryBaseAttributes := []slog.Attr{}
+		queryBaseAttributes = append(queryBaseAttributes, slog.String(TaskIdAtrr, taskId))
+
 		reqHeaders := c.GetReqHeaders()
 
+		// if taskHeaders, ok := reqHeaders[TaskIdAtrr]; ok {
+		// 	if taskHeaders == nil || len(taskHeaders) == 0 {
+
+		// 		return ApiErrorF(c, fmt.Sprintf(fmt.Sprintf("Please provide http header %s  value, right now the value is %v.", TaskIdAtrr, taskHeaders)), queryBaseAttributes)
+		// 	}
+		// } else {
+
+		// 	return ApiErrorF(c, fmt.Sprintf("Please provide http header %s .", TaskIdAtrr), queryBaseAttributes)
+		// }
+
 		if RequestIdHeaders, ok := reqHeaders[RequestId]; ok {
 			if RequestIdHeaders == nil || len(RequestIdHeaders) == 0 {
-				return ApiErrorF(c, fmt.Sprintf("Please provide http header %s  value, right now the value is %v.", RequestId, RequestIdHeaders), baseAttributes)
+				return ApiErrorF(c, fmt.Sprintf(fmt.Sprintf("Please provide http header %s  value, right now the value is %v.", RequestId, RequestIdHeaders)), queryBaseAttributes)
 			}
 		} else {
-
-			return ApiErrorF(c, fmt.Sprintf("Please provide http header %s .", RequestId), attributes)
+			return ApiErrorF(c, fmt.Sprintf("Please provide http header %s .", RequestId), queryBaseAttributes)
 		}
 
 		slogfiber.AddCustomAttributes(c, slog.String(RequestId, reqHeaders[RequestId][0]))
 
-		baseAttributes := []slog.Attr{}
-		baseAttributes = append(baseAttributes, slog.String(TaskIdAtrr, taskId))
-
-		newAttributes := append(baseAttributes, slog.String("c.Path()", c.Path()), slog.String("c.Route().Path", c.Route().Path))
+		// baseAttributes := []slog.Attr{}
+		// baseAttributes = append(baseAttributes, slog.String(TaskIdAtrr, taskId))
 
+		newAttributes := append(queryBaseAttributes, slog.String("c.Path()", c.Path()), slog.String("c.Route().Path", c.Route().Path))
 		slog.LogAttrs(c.UserContext(), slog.LevelInfo, "http api query task", newAttributes...)
 
 		if len(taskId) == 0 {
-			return ApiErrorF(c, fmt.Sprintf("%s must provide task id param for route %s ; e.g. http://127.0.0.1/query/v1/e45b5ebc-c71e-4ab8-b10f-d1202e7fb16e ", c.Path(), c.Route().Path), attributes)
+			return ApiErrorF(c, fmt.Sprintf("%s must provide task id param for route %s ; e.g. http://127.0.0.1/query/v1/e45b5ebc-c71e-4ab8-b10f-d1202e7fb16e ", c.Path(), c.Route().Path), newAttributes)
 		}
 
 		if res, ok := getAsyncRes(taskId); ok {
 
-			// baseAttributes := []slog.Attr{}
-			// baseAttributes = append(baseAttributes, slog.String(TaskIdAtrr, taskId))
-			newAttributes := append(baseAttributes, slog.Int("resAsPb.TaskResultCode", int(res.TaskResultCode)))
-			// slog.String("TaskResultHeader", string(res.TaskResultHeader)), slog.String("TaskResultBody", string(res.TaskResultBody)))
+			newAttributes := append(queryBaseAttributes, slog.Int("resAsPb.TaskResultCode", int(res.TaskResultCode)))
 			newAttributes = append(newAttributes, slog.String("TaskResultHeader", string(res.TaskResultHeader)))
 
 			if isBase64(res.TaskResultBody) {
 				newAttributes = append(newAttributes, slog.Int("TaskResultBody as Base64", len(res.TaskResultBody)))
 			} else {
-				newAttributes = append(newAttributes, slog.String("TaskResultBody", string(res.TaskResultBody)))
+				newAttributes = append(newAttributes, slog.String("TaskResultBody is not Base64", string(res.TaskResultBody)))
 			}
 
-			//if len(res.TaskResultBody) >
-
 			slog.LogAttrs(c.UserContext(), slog.LevelInfo, "getAsyncRes", newAttributes...)
 
 			return syncOrAsyncReturn(c, res, taskId, baseAttributes)