route.ts 1.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243
  1. import { streamText } from "ai";
  2. import { gateway } from "@ai-sdk/gateway";
  3. import { headers } from "next/headers";
  4. import { generateSystemPrompt, generateUserPrompt } from "@/lib/ai-prompt";
  5. import { minuteRateLimit, dailyRateLimit } from "@/lib/rate-limit";
  6. export async function POST(req: Request) {
  7. const headersList = await headers();
  8. const ip = headersList.get("x-forwarded-for")?.split(",")[0] ?? "anonymous";
  9. const [minuteResult, dailyResult] = await Promise.all([
  10. minuteRateLimit.limit(ip),
  11. dailyRateLimit.limit(ip),
  12. ]);
  13. if (!minuteResult.success || !dailyResult.success) {
  14. const isMinuteLimit = !minuteResult.success;
  15. return new Response(
  16. JSON.stringify({
  17. error: "Rate limit exceeded",
  18. message: isMinuteLimit
  19. ? "Too many requests. Please wait a moment before trying again."
  20. : "Daily limit reached. Please try again tomorrow.",
  21. }),
  22. {
  23. status: 429,
  24. headers: { "Content-Type": "application/json" },
  25. },
  26. );
  27. }
  28. const { prompt, spec, previousPrompts } = await req.json();
  29. const result = streamText({
  30. model: gateway(
  31. process.env.AI_GATEWAY_MODEL || "anthropic/claude-sonnet-4-6",
  32. ),
  33. system: generateSystemPrompt(),
  34. prompt: generateUserPrompt(prompt, spec, previousPrompts),
  35. });
  36. return result.toTextStreamResponse();
  37. }