feat: Add request/response logging and remove config manager

Author: ericc-ch

src/lib/config.ts

@@ -0,0 +1,89 @@
+import consola from "consola"
+import fs from "node:fs/promises"
+import path from "pathe"
+
+export interface LoggerOptions {
+  enabled: boolean
+  filePath?: string
+}
+
+export const logger = {
+  options: {
+    enabled: false,
+    filePath: undefined,
+  } as LoggerOptions,
+
+  async initialize(filePath?: string): Promise<void> {
+    if (!filePath) {
+      this.options.enabled = false
+      return
+    }
+
+    try {
+      // Ensure the directory exists
+      await fs.mkdir(path.dirname(filePath), { recursive: true })
+
+      // Initialize the log file with a header
+      const timestamp = new Date().toISOString()
+      await fs.writeFile(
+        filePath,
+        `# API Request/Response Log\n# Started: ${timestamp}\n\n`,
+        { flag: "w" },
+      )
+
+      this.options.enabled = true
+      this.options.filePath = filePath
+      consola.success(`Request logging enabled to: ${filePath}`)
+    } catch (error) {
+      consola.error(`Failed to initialize log file`, error)
+      this.options.enabled = false
+    }
+  },
+
+  async logRequest(
+    endpoint: string,
+    method: string,
+    payload: unknown,
+  ): Promise<void> {
+    if (!this.options.enabled || !this.options.filePath) return
+
+    const timestamp = new Date().toISOString()
+    const logEntry = [
+      `## Request - ${timestamp}`,
+      `Endpoint: ${endpoint}`,
+      `Method: ${method}`,
+      `Payload:`,
+      `\`\`\`json`,
+      JSON.stringify(payload, null, 2),
+      `\`\`\``,
+      `\n`,
+    ].join("\n")
+
+    try {
+      await fs.appendFile(this.options.filePath, logEntry)
+    } catch (error) {
+      consola.error(`Failed to write to log file`, error)
+    }
+  },
+
+  async logResponse(endpoint: string, response: unknown): Promise<void> {
+    if (!this.options.enabled || !this.options.filePath) return
+
+    const timestamp = new Date().toISOString()
+    const logEntry = [
+      `## Response - ${timestamp}`,
+      `Endpoint: ${endpoint}`,
+      `Response:`,
+      `\`\`\`json`,
+      JSON.stringify(response, null, 2),
+      `\`\`\``,
+      `\n`,
+    ].join("\n")
+
+    try {
+      await fs.appendFile(this.options.filePath, logEntry)
+    } catch (error) {
+      consola.error(`Failed to write to log file`, error)
+    }
+  },
+}

src/lib/logger.ts

@@ -1,15 +1,11 @@
 import consola from "consola"
 import { getPort } from "get-port-please"
 
-import { configManager } from "./config"
-
 export async function initializePort(requestedPort?: number): Promise<number> {
-  const config = configManager.getConfig()
-
   const port = await getPort({
     name: "copilot-api",
-    port: requestedPort ?? config.PORT,
-    portRange: config.PORT_RANGE,
+    port: requestedPort,
+    portRange: [4142, 4200],
     random: false,
   })
 
@@ -19,7 +15,5 @@ export async function initializePort(requestedPort?: number): Promise<number> {
     )
   }
 
-  configManager.setConfig({ PORT: port })
-
   return port
 }

src/lib/port.ts

@@ -5,6 +5,7 @@ import consola from "consola"
 import { serve, type ServerHandler } from "srvx"
 
 import { initializeApp } from "./lib/initialization"
+import { logger } from "./lib/logger"
 import { initializePort } from "./lib/port"
 import { server } from "./server"
 
@@ -22,6 +23,10 @@ const main = defineCommand({
       default: false,
       description: "Enable verbose logging",
     },
+    logFile: {
+      type: "string",
+      description: "File to log request/response details",
+    },
   },
   async run({ args }) {
     if (args.verbose) {
@@ -33,6 +38,8 @@ const main = defineCommand({
 
     const port = await initializePort(portInt)
 
+    await logger.initialize(args.logFile)
+
     await initializeApp()
 
     const serverUrl = `http://localhost:${port}`

src/main.ts

@@ -4,15 +4,26 @@ import { streamSSE, type SSEMessage } from "hono/streaming"
 
 import type { ChatCompletionsPayload } from "~/services/copilot/chat-completions/types"
 
+import { logger } from "~/lib/logger"
 import { chatCompletions } from "~/services/copilot/chat-completions/service"
 import { chatCompletionsStream } from "~/services/copilot/chat-completions/service-streaming"
 
 export async function handlerStreaming(c: Context) {
   const payload = await c.req.json<ChatCompletionsPayload>()
 
+  // Log the request
+  await logger.logRequest("/chat/completions", "POST", payload)
+
   if (payload.stream) {
     const response = await chatCompletionsStream(payload)
 
+    // For streaming responses, we'll log the initial response setup
+    await logger.logResponse("/chat/completions", {
+      type: "stream",
+      timestamp: new Date().toISOString(),
+      model: payload.model,
+    })
+
     return streamSSE(c, async (stream) => {
       for await (const chunk of response) {
         await stream.writeSSE(chunk as SSEMessage)
@@ -21,5 +32,9 @@ export async function handlerStreaming(c: Context) {
   }
 
   const response = await chatCompletions(payload)
+
+  // Log the non-streaming response
+  await logger.logResponse("/chat/completions", response)
+
   return c.json(response)
 }