Function createCanopyWaveRequest

web/src/llm-api/canopywave.ts:88–127

(params: {
  body: ChatCompletionRequestBody
  originalModel: string
  fetch: typeof globalThis.fetch
})

}

function createCanopyWaveRequest(params: {
  body: ChatCompletionRequestBody
  originalModel: string
  fetch: typeof globalThis.fetch
}) {
  const { body, originalModel, fetch } = params
  const providerBody = isKimiModel(originalModel)
    ? addKimiToolCompatibilityFields(body)
    : body
  const canopywaveBody: Record<string, unknown> = {
    ...providerBody,
    model: getCanopyWaveModelId(originalModel),
  }

  // Strip OpenRouter-specific / internal fields
  delete canopywaveBody.provider
  delete canopywaveBody.transforms
  delete canopywaveBody.codebuff_metadata
  delete canopywaveBody.usage

  // For streaming, request usage in the final chunk
  if (canopywaveBody.stream) {
    canopywaveBody.stream_options = { include_usage: true }
  }

  if (!env.CANOPYWAVE_API_KEY) {
    throw new Error('CANOPYWAVE_API_KEY is not configured')
  }

  return fetch(`${CANOPYWAVE_BASE_URL}/chat/completions`, {
    method: 'POST',
    headers: {
      Authorization: `Bearer ${env.CANOPYWAVE_API_KEY}`,
      'Content-Type': 'application/json',
    },
    body: JSON.stringify(canopywaveBody),
    // @ts-expect-error - dispatcher is a valid undici option not in fetch types
    dispatcher: canopywaveAgent,
  })
}

function extractUsageAndCost(usage: Record<string, unknown> | undefined | null, model: string): UsageData {
  if (!usage) return { inputTokens: 0, outputTokens: 0, cacheReadInputTokens: 0, reasoningTokens: 0, cost: 0 }