feat: arastirma modulleri odeme ve operasyonlari tamamla

src/app/api/ads/import-apify/route.ts

@@ -0,0 +1,97 @@
+import { NextResponse } from "next/server";
+import { z } from "zod";
+import { currentUser } from "@/lib/auth/current-user";
+import { importApifyAds, runApifyActor } from "@/lib/apify";
+import { prisma } from "@/lib/db";
+import { planFromUser } from "@/lib/plans";
+import { checkAndConsumeQuota, refundQuota } from "@/lib/quota";
+import { hizSiniriAsimi } from "@/lib/rate-limit";
+
+const schema = z.object({
+  searchTerm: z.string().trim().min(2).max(100),
+  maxResults: z.coerce.number().int().refine((value) => [10, 25, 50, 100].includes(value))
+});
+
+function planResultLimit(planCode: string | undefined, isAdmin: boolean) {
+  if (isAdmin || planCode === "PREMIUM") return 100;
+  if (planCode === "STANDARD") return 50;
+  if (planCode === "BASIC") return 25;
+  return 0;
+}
+
+export async function POST(request: Request) {
+  const limited = hizSiniriAsimi(request, "arama");
+  if (limited) return limited;
+
+  const user = await currentUser();
+  if (!user) return NextResponse.json({ error: "UNAUTHORIZED" }, { status: 401 });
+  const parsed = schema.safeParse(await request.json().catch(() => null));
+  if (!parsed.success) return NextResponse.json({ error: "INVALID_INPUT" }, { status: 400 });
+
+  const plan = planFromUser(user as never);
+  const isAdmin = user.role === "ADMIN";
+  const resultLimit = planResultLimit(plan?.code, isAdmin);
+  if (resultLimit === 0) return NextResponse.json({ error: "UPGRADE_REQUIRED" }, { status: 403 });
+  if (parsed.data.maxResults > resultLimit) {
+    return NextResponse.json({ error: "PLAN_LIMIT_EXCEEDED", maxResults: resultLimit }, { status: 403 });
+  }
+
+  let dailyReserved = false;
+  let creditsReserved = false;
+  if (!isAdmin) {
+    const daily = await checkAndConsumeQuota({ userId: user.id, plan, metric: "ads_search_daily" });
+    if (!daily.allowed) return NextResponse.json({ error: "DAILY_QUOTA_EXCEEDED", usage: daily }, { status: 403 });
+    dailyReserved = true;
+
+    const credits = await checkAndConsumeQuota({ userId: user.id, plan, metric: "api_credits_monthly", amount: parsed.data.maxResults });
+    if (!credits.allowed) {
+      await refundQuota({ userId: user.id, metric: "ads_search_daily" });
+      return NextResponse.json({ error: "API_CREDITS_EXCEEDED", usage: credits }, { status: 403 });
+    }
+    creditsReserved = true;
+  }
+
+  const job = await prisma.ingestJob.create({
+    data: {
+      source: "apify",
+      type: "meta-ads-library",
+      status: "RUNNING",
+      startedAt: new Date(),
+      metadata: { userId: user.id, searchTerm: parsed.data.searchTerm, maxResults: parsed.data.maxResults }
+    }
+  });
+
+  try {
+    const records = await runApifyActor({
+      searchTerms: [parsed.data.searchTerm],
+      country: "ALL",
+      adActiveStatus: "ACTIVE",
+      mediaType: "ALL",
+      maxResults: parsed.data.maxResults,
+      maxCostUsd: Math.max(0.1, Math.ceil(parsed.data.maxResults * 0.004 * 10) / 10),
+      scrapeAdDetails: true,
+      includeAboutPage: false
+    });
+    const result = await importApifyAds(records);
+    if (creditsReserved && records.length < parsed.data.maxResults) {
+      await refundQuota({ userId: user.id, metric: "api_credits_monthly", amount: parsed.data.maxResults - records.length });
+    }
+    await prisma.ingestJob.update({
+      where: { id: job.id },
+      data: {
+        status: "COMPLETED",
+        finishedAt: new Date(),
+        recordsImported: result.imported,
+        recordsFailed: result.failed,
+        metadata: { userId: user.id, searchTerm: parsed.data.searchTerm, maxResults: parsed.data.maxResults, received: records.length }
+      }
+    });
+    return NextResponse.json({ ok: true, ...result, received: records.length });
+  } catch (error) {
+    if (dailyReserved) await refundQuota({ userId: user.id, metric: "ads_search_daily" });
+    if (creditsReserved) await refundQuota({ userId: user.id, metric: "api_credits_monthly", amount: parsed.data.maxResults });
+    const code = error instanceof Error && /^APIFY_[A-Z0-9_]+$/.test(error.message) ? error.message : "APIFY_INGEST_FAILED";
+    await prisma.ingestJob.update({ where: { id: job.id }, data: { status: "FAILED", finishedAt: new Date(), errorMessage: code } });
+    return NextResponse.json({ error: code }, { status: code === "APIFY_NOT_CONFIGURED" ? 503 : 502 });
+  }
+}