fiber http log

main.go

@@ -915,10 +915,10 @@ func main() {
 	//app := fiber.New()
 	//app.Use(slogfiber.NewWithConfig(slog.Default(), cfg))
 
-	app.Use(slogfiber.New(slog.Default()))
+	//app.Use(slogfiber.New(slog.Default()))
 	//app.Use(recover.New())
 
-	//app.Use(slogfiber.New(slog.Default()))
+	app.Use(slogfiber.New(slog.Default()))
 	app.Use(recover.New())
 
 	apiGroup := app.Group("/api")
@@ -928,16 +928,34 @@ func main() {
 	apiGroupV1.Post("/*", ApiOrJWT)
 
 	jwtGroupV1 := jwtGroup.Group("/v1")
+	//jwtGroupV1.Post("/*", slogfiber.New(slog.Default()), ApiOrJWT)
+
 	jwtGroupV1.Post("/*", ApiOrJWT)
 
 	//curl -X GET http://127.0.0.1:4000/api/jobs?id=e45b5ebc-c71e-4ab8-b10f-d1202e7fb16e
 
+	//slogfiber.NewWithConfig(slog.Default(), cfg)
+
 	queryGroup := app.Group("/query")
 	queryGroupV1 := queryGroup.Group("/v1")
 	queryGroupV1.Get("/:taskId", func(c *fiber.Ctx) error {
 
 		taskId := c.Params("taskId")
 
+		slogfiber.AddCustomAttributes(c, slog.String(TaskIdAtrr, taskId))
+
+		reqHeaders := c.GetReqHeaders()
+
+		if RequestIdHeaders, ok := reqHeaders[RequestId]; ok {
+			if RequestIdHeaders == nil || len(RequestIdHeaders) == 0 {
+				return c.SendString(fmt.Sprintf("Please provide http header %s  value, right now the value is %v.", RequestId, RequestIdHeaders))
+			}
+		} else {
+			return c.SendString(fmt.Sprintf("Please provide http header %s .", RequestId))
+		}
+
+		slogfiber.AddCustomAttributes(c, slog.String(RequestId, reqHeaders[RequestId][0]))
+
 		baseAttributes := []slog.Attr{}
 		baseAttributes = append(baseAttributes, slog.String(TaskIdAtrr, taskId))
 
@@ -992,6 +1010,8 @@ func main() {
 			return c.SendString(fmt.Sprintf("callback Unmarshal error %v", err.Error()))
 		}
 
+		slogfiber.AddCustomAttributes(c, slog.String(TaskIdAtrr, resbody.TaskId))
+
 		baseAttributes := []slog.Attr{}
 		baseAttributes = append(baseAttributes, slog.String(TaskIdAtrr, resbody.TaskId))
 
@@ -1046,6 +1066,8 @@ func ApiOrJWT(c *fiber.Ctx) error {
 		return c.SendString(fmt.Sprintf("Please provide http header %s .", TaskIdAtrr))
 	}
 
+	slogfiber.AddCustomAttributes(c, slog.String(TaskIdAtrr, reqHeaders[TaskIdAtrr][0]))
+
 	if RequestIdHeaders, ok := reqHeaders[RequestId]; ok {
 		if RequestIdHeaders == nil || len(RequestIdHeaders) == 0 {
 			return c.SendString(fmt.Sprintf("Please provide http header %s  value, right now the value is %v.", RequestId, RequestIdHeaders))
@@ -1054,6 +1076,8 @@ func ApiOrJWT(c *fiber.Ctx) error {
 		return c.SendString(fmt.Sprintf("Please provide http header %s .", RequestId))
 	}
 
+	slogfiber.AddCustomAttributes(c, slog.String(RequestId, reqHeaders[RequestId][0]))
+
 	//slogfiber.AddCustomAttributes(c, slog.String(TaskIdAtrr, reqHeaders[TaskIdAtrr][0]))
 
 	baseAttributes := []slog.Attr{}