Function handleNonStream

tools/model-gateway/server.mjs:226–248

(body, res, config)

}

async function handleNonStream(body, res, config) {
  const upstreamBody = anthropicToOpenAI(body, false, config)
  const upstreamResponse = await fetch(
    joinUrl(config.upstreamBaseUrl, config.upstreamChatPath),
    {
      method: 'POST',
      headers: buildUpstreamHeaders(config),
      body: JSON.stringify(upstreamBody),
    },
  )

  const text = await upstreamResponse.text()
  if (!upstreamResponse.ok) {
    res.statusCode = upstreamResponse.status
    res.setHeader('content-type', 'application/json')
    res.end(text)
    return
  }

  const payload = JSON.parse(text)
  const anthropicMessage = openAINonStreamToAnthropic(body, payload)
  writeJson(res, 200, anthropicMessage)
}

async function handleStream(body, res, config) {
  const upstreamBody = anthropicToOpenAI(body, true, config)