import logger from "@egg/logger"

import initAppConfig from "./constant/config"
import { manageBotReq } from "./routes/bot"
import { manageMessageReq } from "./routes/message"
import { manageMicroAppReq } from "./routes/microApp"
import { manageModelProxyReq } from "./routes/modelProxy"
import { manageSheetReq } from "./routes/sheet"
import { initSchedule } from "./schedule"
import genContext from "./utils/genContext"

initSchedule()

await initAppConfig()

const bunServer = Bun.serve({
  fetch: async (req, server) => {
    // 设置超时时间
    server.timeout(req, 30)
    // 生成上下文
    const ctx = await genContext(req)
    const { path, genResp, logger } = ctx
    // 非健康检查由打印必要信息
    if (
      path.exact("/bot") ||
      path.exact("/message") ||
      path.exact("/sheet") ||
      path.startsWith("/micro_app")
    ) {
      // 使用结构化日志，适合JSON模式
      logger.info("收到请求", {
        method: req.method,
        url: req.url,
      })
      logger.debug("请求体内容", {
        body: ctx.text,
      })
    }
    // 逻辑处理
    try {
      // 机器人
      if (path.exact("/bot")) return await manageBotReq(ctx)
      // 消息代理发送
      if (path.exact("/message")) return await manageMessageReq(ctx)
      // 表格代理操作
      if (path.exact("/sheet")) return await manageSheetReq(ctx)
      // 小程序
      if (path.startsWith("/micro_app")) return await manageMicroAppReq(ctx)
      // 转发到模型代理服务
      if (path.startsWith("/v1")) return manageModelProxyReq(ctx)
      // 健康检查
      if (path.full("/health")) return genResp.healthCheck()
      // 错误模拟
      if (path.startsWith("/mock/400")) return genResp.badRequest("模拟错误400")
      if (path.startsWith("/mock/403")) return genResp.forbidden("模拟错误403")
      if (path.startsWith("/mock/404")) return genResp.notFound("模拟错误404")
      if (path.startsWith("/mock/500"))
        return genResp.serverError("模拟错误500")

      // 其他
      return genResp.healthCheck("hello, there is egg, glade to serve you!")
    } catch (error: any) {
      // 错误处理
      logger.error("服务器错误", {
        message: error.message,
        stack: error.stack,
      })
      return genResp.serverError(error.message || "server error")
    }
  },
  port: 3000,
})

// 使用结构化日志记录服务启动信息
logger.info("服务器启动", {
  hostname: bunServer.hostname,
  port: bunServer.port,
})