Function startGatewayServer

tools/model-gateway/server.mjs:129–224

(overrides = {})

}

export async function startGatewayServer(overrides = {}) {
  const config = resolveGatewayConfig(overrides)
  if (!config.upstreamBaseUrl) {
    throw new Error('OPENAI_COMPAT_BASE_URL is required')
  }

  const server = http.createServer(async (req, res) => {
    try {
      const requestUrl = new URL(req.url || '/', `http://${config.host}:${config.port}`)
      const pathname = requestUrl.pathname

      if (req.method === 'GET' && pathname === '/health') {
        writeJson(res, 200, {
          ok: true,
          upstreamBaseUrl: config.upstreamBaseUrl,
          upstreamChatPath: config.upstreamChatPath,
        })
        return
      }

      if (req.method === 'POST' && pathname === '/v1/messages') {
        const body = await readJson(req)

        // ── Passthrough API key from request headers ──
        if (!config.upstreamApiKey) {
          const incomingKey = req.headers['x-api-key'] || ''
          if (incomingKey && incomingKey !== 'dummy' && incomingKey !== 'unused') {
            config = { ...config, upstreamApiKey: incomingKey }
          }
        }

        // ── Soul + Memory injection (can be disabled via CLAW_ENABLE_SOUL=0) ──
        const soulEnabled = process.env.CLAW_ENABLE_SOUL !== '0'
        const soulPrefix = soulEnabled ? loadSoulPrefix(config) : ''
        const memPrefix = soulEnabled ? loadMemoryPrefix(config) : ''
        const injected = [soulPrefix, memPrefix].filter(Boolean).join('\n\n')
        if (injected) {
          const existing = typeof body.system === 'string' ? body.system : ''
          body.system = injected + (existing ? '\n\n' + existing : '')
        }

        if (config.textMode === 'anthropic') {
          await handleAnthropicPassthrough(body, res, config)
          return
        }
        if (config.textMode === 'gemini') {
          if (body.stream) {
            await handleGeminiStream(body, res, config)
          } else {
            await handleGeminiNonStream(body, res, config)
          }
          return
        }
        if (body.stream) {
          await handleStream(body, res, config)
        } else {
          await handleNonStream(body, res, config)
        }