diff --git a/handlers/anthropic.go b/handlers/anthropic.go index 3e0876c..b6863f1 100644 --- a/handlers/anthropic.go +++ b/handlers/anthropic.go @@ -174,8 +174,8 @@ func AnthropicHandler(cfg *config.Config, db *gorm.DB) fiber.Handler { } if err != nil { - logger.Warn("│ ❌ UPSTREAM ERROR: %v", err) - logger.Warn("└─ [ANTHROPIC] <<< 502 (%dms)", latency) + logger.Warn("│ ❌ UPSTREAM ERROR [IP: %s]: %v", c.IP(), err) + logger.Warn("└─ [ANTHROPIC] <<< 502 (%dms) | IP: %s", latency, c.IP()) return c.Status(fiber.StatusBadGateway).JSON(fiber.Map{ "error": fmt.Sprintf("upstream error: %v", err), }) @@ -197,7 +197,7 @@ func AnthropicHandler(cfg *config.Config, db *gorm.DB) fiber.Handler { c.Set("Content-Type", "application/json") return c.Status(result.StatusCode).Send(antBody) } - logger.Warn("│ ⚠️ RESPONSE TRANSFORM FAILED: %v (forwarding raw)", terr) + logger.Warn("│ ⚠️ RESPONSE TRANSFORM FAILED [IP: %s]: %v (forwarding raw)", c.IP(), terr) } logger.Info("└─ [ANTHROPIC] <<< %d (passthrough, %dms)", result.StatusCode, latency) @@ -287,14 +287,14 @@ func handleStreaming( client := &http.Client{} resp, err := client.Do(req) if err != nil { - logger.Warn("[ANTHROPIC] Stream error: %v", err) + logger.Warn("[ANTHROPIC] Stream error [IP: %s]: %v", c.IP(), err) return c.Status(fiber.StatusBadGateway).SendString("upstream error") } defer resp.Body.Close() if resp.StatusCode != 200 { body, _ := io.ReadAll(resp.Body) - logger.Warn("[ANTHROPIC] Stream upstream %d: %s", resp.StatusCode, string(body)) + logger.Warn("[ANTHROPIC] Stream upstream %d [IP: %s]: %s", resp.StatusCode, c.IP(), string(body)) return c.Status(resp.StatusCode).Send(body) } diff --git a/handlers/openai.go b/handlers/openai.go index 2fd9dea..3f2dfec 100644 --- a/handlers/openai.go +++ b/handlers/openai.go @@ -86,8 +86,8 @@ func OpenAIHandler(cfg *config.Config, db *gorm.DB) fiber.Handler { } if err != nil { - logger.Warn("│ ❌ UPSTREAM ERROR: %v", err) - logger.Warn("└─ [OPENAI] <<< 502 (%dms)", latency) + logger.Warn("│ ❌ UPSTREAM ERROR [IP: %s]: %v", c.IP(), err) + logger.Warn("└─ [OPENAI] <<< 502 (%dms) | IP: %s", latency, c.IP()) return c.Status(fiber.StatusBadGateway).JSON(fiber.Map{ "error": fmt.Sprintf("upstream error: %v", err), })