beyhan/opantoantro
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: enhance error logging in Anthropic and OpenAI handlers with client IP information

Browse Source
This commit is contained in:
Beyhan Ogur
2026-05-11 20:54:09 +03:00
parent 74b9cb517a
commit 80c75ec40f
2 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
handlers/anthropic.go
+5 -5
View File
@@ -174,8 +174,8 @@ func AnthropicHandler(cfg *config.Config, db *gorm.DB) fiber.Handler {
} }
if err != nil { if err != nil {
logger.Warn("│ ❌ UPSTREAM ERROR: %v", err) logger.Warn("│ ❌ UPSTREAM ERROR [IP: %s]: %v", c.IP(), err)
logger.Warn("└─ [ANTHROPIC] <<< 502 (%dms)", latency) logger.Warn("└─ [ANTHROPIC] <<< 502 (%dms) | IP: %s", latency, c.IP())
return c.Status(fiber.StatusBadGateway).JSON(fiber.Map{ return c.Status(fiber.StatusBadGateway).JSON(fiber.Map{
"error": fmt.Sprintf("upstream error: %v", err), "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") c.Set("Content-Type", "application/json")
return c.Status(result.StatusCode).Send(antBody) 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) logger.Info("└─ [ANTHROPIC] <<< %d (passthrough, %dms)", result.StatusCode, latency)
@@ -287,14 +287,14 @@ func handleStreaming(
client := &http.Client{} client := &http.Client{}
resp, err := client.Do(req) resp, err := client.Do(req)
if err != nil { 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") return c.Status(fiber.StatusBadGateway).SendString("upstream error")
} }
defer resp.Body.Close() defer resp.Body.Close()
if resp.StatusCode != 200 { if resp.StatusCode != 200 {
body, _ := io.ReadAll(resp.Body) 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) return c.Status(resp.StatusCode).Send(body)
} }
handlers/openai.go
+2 -2
View File
@@ -86,8 +86,8 @@ func OpenAIHandler(cfg *config.Config, db *gorm.DB) fiber.Handler {
} }
if err != nil { if err != nil {
logger.Warn("│ ❌ UPSTREAM ERROR: %v", err) logger.Warn("│ ❌ UPSTREAM ERROR [IP: %s]: %v", c.IP(), err)
logger.Warn("└─ [OPENAI] <<< 502 (%dms)", latency) logger.Warn("└─ [OPENAI] <<< 502 (%dms) | IP: %s", latency, c.IP())
return c.Status(fiber.StatusBadGateway).JSON(fiber.Map{ return c.Status(fiber.StatusBadGateway).JSON(fiber.Map{
"error": fmt.Sprintf("upstream error: %v", err), "error": fmt.Sprintf("upstream error: %v", err),
}) })