01
const apiEnvSchema = z.object({
02
  APP_ENV: z.enum(['development', 'test', 'production']),
03
  ADMIN_ORIGIN: z.string().url(),
04
  WEB_ORIGIN: z.string().url(),
05
  JWT_ACCESS_SECRET: z.string().min(16),
06
  JWT_REFRESH_SECRET: z.string().min(16),
07
  ACCESS_TOKEN_TTL_SEC: z.coerce.number().int().positive(),
08
  REFRESH_TOKEN_TTL_SEC: z.coerce.number().int().positive(),
09
  DEEPSEEK_API_KEY: z.string().min(1).optional(),
10
  DEEPSEEK_BASE_URL: z.string().url().optional(),
11
  DEEPSEEK_MODEL: z.string().min(1).optional(),
12
})

01
export function getApiEnv(bindings: ApiBindings): ApiEnv {
02
  return apiEnvSchema.parse({
03
    APP_ENV: bindings.APP_ENV,
04
    ADMIN_ORIGIN: bindings.ADMIN_ORIGIN,
05
    WEB_ORIGIN: bindings.WEB_ORIGIN,
06
    JWT_ACCESS_SECRET: bindings.JWT_ACCESS_SECRET,
07
    JWT_REFRESH_SECRET: bindings.JWT_REFRESH_SECRET,
08
    ACCESS_TOKEN_TTL_SEC: bindings.ACCESS_TOKEN_TTL_SEC,
09
    REFRESH_TOKEN_TTL_SEC: bindings.REFRESH_TOKEN_TTL_SEC,
10
    DEEPSEEK_API_KEY: bindings.DEEPSEEK_API_KEY,
11
    DEEPSEEK_BASE_URL: bindings.DEEPSEEK_BASE_URL,
12
    DEEPSEEK_MODEL: bindings.DEEPSEEK_MODEL,
13
  })
14
}

1
{
2
  id: string
3
  role: 'user' | 'assistant'
4
  parts: Array<UIMessagePart>
5
}

1
const InboxChatPartSchema = z.object({
2
  type: z.string().min(1),
3
}).passthrough()
4

5
export const InboxChatMessageSchema = z.object({
6
  id: z.string().optional(),
7
  role: z.enum(['user', 'assistant']),
8
  parts: z.array(InboxChatPartSchema).min(1).max(50),
9
})

1
export const InboxChatRequestSchema = z.object({
2
  messages: z.array(InboxChatMessageSchema).min(1).max(20),
3
  mail: z.object({
4
    subject: z.string().min(1).max(200),
5
    sender: z.string().min(1).max(120),
6
    senderEmail: z.string().email(),
7
    teaser: z.string().min(1).max(2000),
8
  }),
9
})

1
.route('/rpc/chat/inbox', inboxChatRoute)

01
inboxChatRoute.post(
02
  '/',
03
  zValidator(
04
    'json',
05
    InboxChatRequestSchema,
06
    buildValidationErrorHandler('Invalid chat payload'),
07
  ),
08
  async (c) => {
09
    // handler
10
  },
11
)

1
function extractText(message: { parts: Array<{ type: string; text?: unknown }> }) {
2
  return message.parts
3
    .filter((part) => part.type === 'text' && typeof part.text === 'string')
4
    .map((part) => part.text)
5
    .join('\n')
6
    .trim()
7
}

1
const model = new ChatOpenAI({
2
  apiKey: env.DEEPSEEK_API_KEY,
3
  model: env.DEEPSEEK_MODEL ?? 'deepseek-chat',
4
  configuration: {
5
    baseURL: env.DEEPSEEK_BASE_URL ?? 'https://api.deepseek.com/v1',
6
  },
7
})

1
if (!env.DEEPSEEK_API_KEY) {
2
  throw new AppError(
3
    BizCode.SYSTEM_INTERNAL_ERROR,
4
    'DeepSeek API key is not configured',
5
    500,
6
  )
7
}

01
const messages: BaseMessage[] = [
02
  new SystemMessage([
03
    '你是 AI Agent Web 控制台里的聊天助手。',
04
    '请基于当前聊天上下文，用简洁、自然的中文回答用户。',
05
    '如果用户要求起草回复，请直接给出可发送的回复内容。',
06
  ].join('\n')),
07
  new HumanMessage([
08
    `聊天主题：${payload.mail.subject}`,
09
    `发送方：${payload.mail.sender} <${payload.mail.senderEmail}>`,
10
    `聊天摘要：${payload.mail.teaser}`,
11
  ].join('\n')),
12
]

01
for (const message of payload.messages) {
02
  const text = extractText(message)
03

04
  if (!text) {
05
    continue
06
  }
07

08
  messages.push(
09
    message.role === 'user'
10
      ? new HumanMessage(text)
11
      : new AIMessage(text),
12
  )
13
}

1
const stream = await model.stream(messages)

01
const textStream = new ReadableStream<Uint8Array>({
02
  async start(controller) {
03
    const encoder = new TextEncoder()
04

05
    try {
06
      for await (const chunk of stream) {
07
        const content = typeof chunk.content === 'string'
08
          ? chunk.content
09
          : chunk.content.map((part) => {
10
            if (typeof part === 'string') {
11
              return part
12
            }
13

14
            if ('text' in part && typeof part.text === 'string') {
15
              return part.text
16
            }
17

18
            return ''
19
          }).join('')
20

21
        if (content) {
22
          controller.enqueue(encoder.encode(content))
23
        }
24
      }
25

26
      controller.close()
27
    } catch (error) {
28
      controller.error(error)
29
    }
30
  },
31
})

1
return new Response(textStream, {
2
  headers: {
3
    'content-type': 'text/plain; charset=utf-8',
4
    'cache-control': 'no-cache',
5
  },
6
})

1
const { messages, sendMessage, status, error, stop } = useChat({
2
  transport,
3
  messages: initialMessages,
4
})

1
const transport = useMemo(
2
  () => new TextStreamChatTransport<UIMessage>({
3
    api: `${getWebClientEnv().NEXT_PUBLIC_API_BASE_URL}/rpc/chat/inbox`,
4
    body: {
5
      mail,
6
    },
7
  }),
8
  [mail],
9
)

1
new TextStreamChatTransport({
2
  api: `${NEXT_PUBLIC_API_BASE_URL}/rpc/chat/inbox`,
3
})

1
const InboxChatPartSchema = z.object({
2
  type: z.string().min(1),
3
}).passthrough()

1
.filter((part) => part.type === 'text' && typeof part.text === 'string')