给你的 Curve 主题添加一个 DeepSeek 代理

// api/deepseek.ts
export const config = { runtime: 'edge' }

function withCors(init: ResponseInit = {}) {
  return {
    ...init,
    headers: {
      'Access-Control-Allow-Origin': '*',
      'Access-Control-Allow-Headers': 'Content-Type, Authorization',
      'Access-Control-Allow-Methods': 'POST, GET, OPTIONS',
      ...(init.headers || {}),
    },
  }
}
const json = (data: any, status = 200) =>
  new Response(JSON.stringify(data), withCors({
    status,
    headers: { 'Content-Type': 'application/json; charset=utf-8' },
  }))

export default async function handler(req: Request) {
  if (req.method === 'OPTIONS') return new Response(null, withCors({ status: 204 }))
  if (req.method === 'GET') return json({ ok: true, hint: 'POST /api/deepseek with JSON body. Supports stream true/false.' })
  if (req.method !== 'POST') return json({ error: 'Method Not Allowed' }, 405)

  const apiKey = process.env.DEEPSEEK_API_KEY
  if (!apiKey) return json({ error: 'Missing DEEPSEEK_API_KEY' }, 500)

  let body: any
  try { body = await req.json() } catch { return json({ error: 'Invalid JSON body' }, 400) }

  const { model='deepseek-chat', messages, stream=true, temperature, top_p, frequency_penalty, presence_penalty, max_tokens } = body ?? {}
  if (!Array.isArray(messages)) return json({ error: '`messages` must be an array' }, 400)

  const payload: Record<string, any> = { model, messages, stream }
  if (temperature !== undefined) payload.temperature = temperature
  if (top_p !== undefined) payload.top_p = top_p
  if (frequency_penalty !== undefined) payload.frequency_penalty = frequency_penalty
  if (presence_penalty !== undefined) payload.presence_penalty = presence_penalty
  if (max_tokens !== undefined) payload.max_tokens = max_tokens

  const upstream = await fetch('https://api.deepseek.com/chat/completions', {
    method: 'POST',
    headers: { 'Content-Type': 'application/json', Authorization: `Bearer ${apiKey}` },
    body: JSON.stringify(payload),
  })

  if (!upstream.ok) {
    const text = await upstream.text().catch(() => '')
    return new Response(text || 'Upstream error', withCors({
      status: upstream.status,
      headers: { 'Content-Type': upstream.headers.get('content-type') || 'text/plain; charset=utf-8' },
    }))
  }

  if (stream) {
    return new Response(upstream.body, withCors({
      status: 200,
      headers: {
        'Content-Type': 'text/event-stream; charset=utf-8',
        'Cache-Control': 'no-cache, no-transform',
        'Connection': 'keep-alive',
      },
    }))
  } else {
    const text = await upstream.text()
    return new Response(text, withCors({
      status: 200,
      headers: { 'Content-Type': 'application/json; charset=utf-8' },
    }))
  }
}