-
- )}
+ {q && masked.length === 0 && “{q}” için sonuç bulunamadı
-Yeni reklamların içe aktarılması için yöneticinizle iletişime geçin.
-Start now — Unlock winners
}
diff --git a/src/app/dashboard/brand-tracker/page.tsx b/src/app/dashboard/brand-tracker/page.tsx
index 25a9365..10a5544 100644
--- a/src/app/dashboard/brand-tracker/page.tsx
+++ b/src/app/dashboard/brand-tracker/page.tsx
@@ -15,7 +15,7 @@ export default async function BrandTrackerPage({ searchParams }: { searchParams:
{ niche: { contains: query, mode: "insensitive" } }
]
} : {};
- const [brands, tracked] = await Promise.all([
+ const [brands, tracked, alerts] = await Promise.all([
prisma.brandPage.findMany({
where,
include: {
@@ -25,7 +25,8 @@ export default async function BrandTrackerPage({ searchParams }: { searchParams:
orderBy: { ads: { _count: "desc" } },
take: 40
}),
- prisma.trackedBrand.findMany({ where: { userId: user.id } })
+ prisma.trackedBrand.findMany({ where: { userId: user.id } }),
+ prisma.brandAlert.findMany({ where: { userId: user.id }, include: { trackedBrand: { include: { brandPage: true } } }, orderBy: { createdAt: "desc" }, take: 20 })
]);
const trackedByBrand = new Map(tracked.map((item) => [item.brandPageId, item.id]));
const limit = getFeatureLimit(planFromUser(user as any), "followed_brands");
@@ -40,6 +41,7 @@ export default async function BrandTrackerPage({ searchParams }: { searchParams:
+ {alerts.length > 0 && Yeni reklam uyarıları
{alerts.map((alert) => )}
{alert.trackedBrand.brandPage.name}
{alert.createdAt.toLocaleDateString("tr-TR")}{alert.title}
{brands.map((brand) => {
const activeAds = brand.ads.filter((ad) => ad.status === "ACTIVE").length;
diff --git a/src/app/dashboard/layout.tsx b/src/app/dashboard/layout.tsx
index 05580c0..12d1004 100644
--- a/src/app/dashboard/layout.tsx
+++ b/src/app/dashboard/layout.tsx
@@ -1,5 +1,6 @@
import Link from "next/link";
import { requireUser } from "@/lib/auth/current-user";
+import { DashboardMobileNav } from "@/components/dashboard-mobile-nav";
const nav = [
["Ads", "/dashboard/ads"],
@@ -20,6 +21,7 @@ export default async function DashboardLayout({ children }: { children: React.Re
WinningHunter.AI
+
- {user.role === "ADMIN" ? Admin : Upgrade}
+ {user.role !== "ADMIN" && Upgrade}
> }) {
- await requireUser();
+ const user = await requireUser();
const q = (await searchParams).q?.trim();
const where: Prisma.AdWhereInput = q ? { OR: [{ headline: { contains: q, mode: "insensitive" } }, { primaryText: { contains: q, mode: "insensitive" } }, { brandPage: { name: { contains: q, mode: "insensitive" } } }] } : {};
- const ads = await prisma.ad.findMany({ where, include: { brandPage: true, creatives: { take: 1 } }, orderBy: [{ daysRunning: "desc" }, { updatedAt: "desc" }], take: 18 });
+ const [ads, analyses] = await Promise.all([
+ prisma.ad.findMany({ where, include: { brandPage: true, creatives: { take: 1 } }, orderBy: [{ daysRunning: "desc" }, { updatedAt: "desc" }], take: 18 }),
+ prisma.aiAnalysis.findMany({ where: { userId: user.id }, orderBy: { createdAt: "desc" }, take: 5 })
+ ]);
return (
-
+
-
);
diff --git a/src/components/checkout-button.tsx b/src/components/checkout-button.tsx
new file mode 100644
index 0000000..b55995a
--- /dev/null
+++ b/src/components/checkout-button.tsx
@@ -0,0 +1,18 @@
+"use client";
+import { useState } from "react";
+
+export function CheckoutButton({ planCode }: { planCode: "BASIC" | "STANDARD" | "PREMIUM" }) {
+ const [busy, setBusy] = useState(false);
+ const [error, setError] = useState("");
+ async function checkout() {
+ setBusy(true); setError("");
+ try {
+ const response = await fetch("/api/billing/checkout", { method: "POST", headers: { "content-type": "application/json" }, body: JSON.stringify({ planCode, interval: "monthly" }) });
+ const data = await response.json().catch(() => ({}));
+ if (response.status === 401) { window.location.href = "/login?next=/pricing"; return; }
+ if (!response.ok || !data.url) throw new Error(data.error || "CHECKOUT_FAILED");
+ window.location.href = data.url;
+ } catch (caught) { setError(caught instanceof Error ? caught.message : "Ödeme başlatılamadı."); setBusy(false); }
+ }
+ return <>{error && (null);
+ const [message, setMessage] = useState("");
+ const [error, setError] = useState(false);
+
+ async function addStore(event: FormEvent) {
+ event.preventDefault();
+ setBusy("add"); setMessage("");
+ try {
+ const response = await fetch("/api/tracked-stores", {
+ method: "POST",
+ headers: { "content-type": "application/json" },
+ body: JSON.stringify({ domain })
+ });
+ const data = await response.json().catch(() => ({}));
+ if (!response.ok) throw new Error(data.error || "STORE_TRACKER_FAILED");
+ setDomain(""); setError(false); setMessage("Mağaza takip listesine eklendi."); router.refresh();
+ } catch (caught) {
+ setError(true); setMessage(caught instanceof Error ? caught.message : "Mağaza eklenemedi.");
+ } finally { setBusy(null); }
+ }
+
+ async function removeStore(id: string) {
+ setBusy(id); setMessage("");
+ try {
+ const response = await fetch(`/api/tracked-stores/${id}`, { method: "DELETE" });
+ const data = await response.json().catch(() => ({}));
+ if (!response.ok) throw new Error(data.error || "STORE_TRACKER_FAILED");
+ setError(false); setMessage("Mağaza takip listesinden çıkarıldı."); router.refresh();
+ } catch (caught) {
+ setError(true); setMessage(caught instanceof Error ? caught.message : "Mağaza çıkarılamadı.");
+ } finally { setBusy(null); }
+ }
+
+ return (
+ ;
+const API_BASE = "https://api.apify.com/v2";
+const DEFAULT_ACTOR = "toolzerhub~tiktok-shop-products-scraper";
+
+function text(row: Row, ...keys: string[]) {
+ for (const key of keys) {
+ const value = row[key];
+ if (typeof value === "string" && value.trim()) return value.trim();
+ }
+ return null;
+}
+
+function number(row: Row, ...keys: string[]) {
+ for (const key of keys) {
+ const value = row[key];
+ const parsed = typeof value === "number" ? value : typeof value === "string" ? Number(value.replace(/[^0-9.-]/g, "")) : NaN;
+ if (Number.isFinite(parsed)) return parsed;
+ }
+ return null;
+}
+
+function nested(row: Row, key: string) {
+ const value = row[key];
+ return value && typeof value === "object" && !Array.isArray(value) ? value as Row : {};
+}
+
+function safeUrl(value: string | null) {
+ if (!value) return null;
+ try {
+ const url = new URL(value);
+ return ["https:", "http:"].includes(url.protocol) ? url.toString() : null;
+ } catch { return null; }
+}
+
+export async function runTikTokShopActor(input: { query: string; region: string; maxResults: number }) {
+ const token = process.env.APIFY_TOKEN?.trim();
+ if (!token) throw new Error("APIFY_NOT_CONFIGURED");
+ const actor = (process.env.APIFY_TIKTOK_ACTOR_ID?.trim() || DEFAULT_ACTOR).replace("/", "~");
+ if (!/^[a-zA-Z0-9_-]+~[a-zA-Z0-9_-]+$/.test(actor)) throw new Error("APIFY_TIKTOK_ACTOR_INVALID");
+ const params = new URLSearchParams({ clean: "true", timeout: "180", maxItems: String(input.maxResults), maxTotalChargeUsd: String(Math.max(0.1, input.maxResults * 0.01)) });
+ const controller = new AbortController();
+ const timer = setTimeout(() => controller.abort(), 210_000);
+ try {
+ const response = await fetch(`${API_BASE}/actors/${actor}/run-sync-get-dataset-items?${params}`, {
+ method: "POST",
+ headers: { authorization: `Bearer ${token}`, "content-type": "application/json", accept: "application/json" },
+ body: JSON.stringify({ search_word: input.query, region: input.region, maxItems: input.maxResults, enrichProductDetails: false }),
+ signal: controller.signal,
+ cache: "no-store"
+ });
+ if (!response.ok) throw new Error(`APIFY_TIKTOK_HTTP_${response.status}`);
+ const payload: unknown = await response.json();
+ if (!Array.isArray(payload)) throw new Error("APIFY_TIKTOK_INVALID_RESPONSE");
+ return payload.filter((item): item is Row => Boolean(item) && typeof item === "object" && !Array.isArray(item));
+ } catch (error) {
+ if (error instanceof Error && error.name === "AbortError") throw new Error("APIFY_TIKTOK_TIMEOUT");
+ throw error;
+ } finally { clearTimeout(timer); }
+}
+
+export async function importTikTokProducts(rows: Row[], region: string) {
+ let imported = 0;
+ let failed = 0;
+ for (const row of rows) {
+ const product = nested(row, "product");
+ const shop = { ...nested(row, "shop"), ...nested(row, "seller") };
+ const externalId = text(row, "productId", "product_id", "id") || text(product, "productId", "product_id", "id");
+ const title = text(row, "title", "productTitle", "name") || text(product, "title", "name");
+ if (!externalId || !title) { failed += 1; continue; }
+ try {
+ await prisma.tikTokProduct.upsert({
+ where: { externalId },
+ create: {
+ externalId, title, description: text(row, "description") || text(product, "description"),
+ productUrl: safeUrl(text(row, "productUrl", "url") || text(product, "productUrl", "url")),
+ imageUrl: safeUrl(text(row, "image", "imageUrl", "thumbnail") || text(product, "image", "imageUrl", "thumbnail")),
+ shopName: text(row, "shopName", "sellerName") || text(shop, "shopName", "sellerName", "name"),
+ shopExternalId: text(row, "sellerId", "shopId") || text(shop, "sellerId", "shopId", "id"),
+ region: text(row, "region", "country") || region, currency: text(row, "currency") || text(product, "currency"),
+ price: number(row, "price", "salePrice") ?? number(product, "price", "salePrice"),
+ originalPrice: number(row, "originalPrice", "listPrice") ?? number(product, "originalPrice", "listPrice"),
+ soldCount: Math.round(number(row, "soldCount", "sales", "unitsSold") ?? number(product, "soldCount", "sales", "unitsSold") ?? 0),
+ rating: number(row, "rating", "ratingScore") ?? number(product, "rating", "ratingScore"),
+ reviewCount: Math.round(number(row, "reviewCount", "reviews") ?? number(product, "reviewCount", "reviews") ?? 0),
+ category: text(row, "category", "categoryName") || text(product, "category", "categoryName"), raw: row as Prisma.InputJsonValue
+ },
+ update: {
+ title, productUrl: safeUrl(text(row, "productUrl", "url") || text(product, "productUrl", "url")),
+ imageUrl: safeUrl(text(row, "image", "imageUrl", "thumbnail") || text(product, "image", "imageUrl", "thumbnail")),
+ shopName: text(row, "shopName", "sellerName") || text(shop, "shopName", "sellerName", "name"),
+ price: number(row, "price", "salePrice") ?? number(product, "price", "salePrice"),
+ soldCount: Math.round(number(row, "soldCount", "sales", "unitsSold") ?? number(product, "soldCount", "sales", "unitsSold") ?? 0),
+ rating: number(row, "rating", "ratingScore") ?? number(product, "rating", "ratingScore"), lastSeenAt: new Date(), raw: row as Prisma.InputJsonValue
+ }
+ });
+ imported += 1;
+ } catch { failed += 1; }
+ }
+ return { imported, failed };
+}
diff --git a/src/lib/openai-analysis.ts b/src/lib/openai-analysis.ts
new file mode 100644
index 0000000..fe4fa0c
--- /dev/null
+++ b/src/lib/openai-analysis.ts
@@ -0,0 +1,67 @@
+type AdSignal = { headline: string | null; primaryText: string | null; mediaType: string; daysRunning: number | null; status: string; brand: string | null };
+
+export type CreativeAnalysis = { summary: string; insights: Array<{ title: string; action: string; confidence: number }> };
+
+export async function analyzeCreatives(query: string | undefined, ads: AdSignal[]): Promise {
+ const apiKey = process.env.OPENAI_API_KEY?.trim();
+ if (!apiKey) throw new Error("OPENAI_NOT_CONFIGURED");
+ const model = process.env.OPENAI_MODEL?.trim() || "gpt-5.6-luna";
+ const controller = new AbortController();
+ const timer = setTimeout(() => controller.abort(), 45_000);
+ try {
+ const response = await fetch("https://api.openai.com/v1/responses", {
+ method: "POST",
+ headers: { authorization: `Bearer ${apiKey}`, "content-type": "application/json" },
+ body: JSON.stringify({
+ model,
+ input: [
+ { role: "system", content: [{ type: "input_text", text: "Sen bir reklam kreatif stratejistisin. Sadece verilen sinyallere dayan. Türkçe, kısa, somut A/B test önerileri üret. Veri yoksa uydurma." }] },
+ { role: "user", content: [{ type: "input_text", text: JSON.stringify({ query: query || null, ads }) }] }
+ ],
+ text: {
+ format: {
+ type: "json_schema",
+ name: "creative_analysis",
+ strict: true,
+ schema: {
+ type: "object",
+ additionalProperties: false,
+ properties: {
+ summary: { type: "string" },
+ insights: {
+ type: "array",
+ minItems: 1,
+ maxItems: 6,
+ items: {
+ type: "object",
+ additionalProperties: false,
+ properties: {
+ title: { type: "string" },
+ action: { type: "string" },
+ confidence: { type: "number", minimum: 0, maximum: 1 }
+ },
+ required: ["title", "action", "confidence"]
+ }
+ }
+ },
+ required: ["summary", "insights"]
+ }
+ }
+ },
+ max_output_tokens: 1200
+ }),
+ signal: controller.signal,
+ cache: "no-store"
+ });
+ if (!response.ok) throw new Error(`OPENAI_HTTP_${response.status}`);
+ const payload = await response.json() as { output_text?: string; output?: Array<{ content?: Array<{ type?: string; text?: string }> }> };
+ const outputText = payload.output_text || payload.output?.flatMap((item) => item.content || []).find((item) => item.type === "output_text")?.text;
+ if (!outputText) throw new Error("OPENAI_INVALID_RESPONSE");
+ const parsed = JSON.parse(outputText) as CreativeAnalysis;
+ if (!parsed.summary || !Array.isArray(parsed.insights)) throw new Error("OPENAI_INVALID_RESPONSE");
+ return { ...parsed, model };
+ } catch (error) {
+ if (error instanceof Error && error.name === "AbortError") throw new Error("OPENAI_TIMEOUT");
+ throw error;
+ } finally { clearTimeout(timer); }
+}
diff --git a/src/lib/quota.ts b/src/lib/quota.ts
index ad641ec..9d40bed 100644
--- a/src/lib/quota.ts
+++ b/src/lib/quota.ts
@@ -102,11 +102,25 @@ export async function checkAndConsumeQuota(params: {
};
}
- const updated = await prisma.usageCounter.update({
- where: { id: counter.id },
+ // Koşullu artış, eşzamanlı iki isteğin aynı kalan kotayı tüketmesini önler.
+ const claimed = await prisma.usageCounter.updateMany({
+ where: { id: counter.id, used: { lte: limit - amount } },
data: { used: { increment: amount }, limit, resetAt }
});
+ if (claimed.count === 0) {
+ const latest = await prisma.usageCounter.findUniqueOrThrow({ where: { id: counter.id } });
+ return {
+ allowed: false,
+ used: latest.used,
+ limit,
+ remaining: Math.max(0, limit - latest.used),
+ resetAt: latest.resetAt
+ };
+ }
+
+ const updated = await prisma.usageCounter.findUniqueOrThrow({ where: { id: counter.id } });
+
return {
allowed: true,
used: updated.used,
@@ -115,3 +129,18 @@ export async function checkAndConsumeQuota(params: {
resetAt: updated.resetAt
};
}
+
+export async function refundQuota(params: { userId: string; metric: string; amount?: number }) {
+ const amount = Math.max(0, params.amount ?? 1);
+ if (amount === 0) return;
+ const period = periodForMetric(params.metric);
+ const periodKey = keyForPeriod(period);
+ const counter = await prisma.usageCounter.findUnique({
+ where: { userId_metric_periodKey: { userId: params.userId, metric: params.metric, periodKey } }
+ });
+ if (!counter) return;
+ await prisma.usageCounter.update({
+ where: { id: counter.id },
+ data: { used: Math.max(0, counter.used - amount) }
+ });
+}
diff --git a/src/lib/stripe.ts b/src/lib/stripe.ts
new file mode 100644
index 0000000..b266410
--- /dev/null
+++ b/src/lib/stripe.ts
@@ -0,0 +1,14 @@
+import Stripe from "stripe";
+
+export function stripeClient() {
+ const key = process.env.STRIPE_SECRET_KEY?.trim();
+ if (!key) throw new Error("STRIPE_NOT_CONFIGURED");
+ return new Stripe(key, { maxNetworkRetries: 2, timeout: 20_000 });
+}
+
+export function stripePriceFor(planCode: string, interval: "monthly" | "yearly") {
+ const key = `STRIPE_PRICE_${planCode}_${interval}`.toUpperCase();
+ const price = process.env[key]?.trim();
+ if (!price || !/^price_[a-zA-Z0-9]+$/.test(price)) throw new Error("STRIPE_PRICE_NOT_CONFIGURED");
+ return price;
+}
diff --git a/src/lib/trend-snapshots.ts b/src/lib/trend-snapshots.ts
new file mode 100644
index 0000000..24f0a0a
--- /dev/null
+++ b/src/lib/trend-snapshots.ts
@@ -0,0 +1,49 @@
+import { Prisma } from "@prisma/client";
+import { prisma } from "@/lib/db";
+
+function startOfUtcDay() {
+ const now = new Date();
+ return new Date(Date.UTC(now.getUTCFullYear(), now.getUTCMonth(), now.getUTCDate()));
+}
+
+export async function captureTrendSnapshot() {
+ const [ads, stores, tiktok] = await Promise.all([
+ prisma.ad.findMany({ select: { niche: true, mediaType: true, countries: true, status: true, daysRunning: true, firstSeenAt: true } }),
+ prisma.store.aggregate({ _count: true, _avg: { monthlyVisitGrowth: true, monthlyVisits: true } }),
+ prisma.tikTokProduct.aggregate({ _count: true, _sum: { soldCount: true }, _avg: { rating: true, price: true } })
+ ]);
+ const count = (values: string[]) => Object.fromEntries([...values.reduce((map, value) => map.set(value || "Bilinmiyor", (map.get(value || "Bilinmiyor") || 0) + 1), new Map()).entries()].sort((a, b) => b[1] - a[1]).slice(0, 20));
+ const metrics = {
+ ads: { total: ads.length, active: ads.filter((ad) => ad.status === "ACTIVE").length, longRunners: ads.filter((ad) => (ad.daysRunning || 0) >= 30).length, new14d: ads.filter((ad) => ad.firstSeenAt && Date.now() - ad.firstSeenAt.getTime() <= 14 * 86_400_000).length },
+ niches: count(ads.map((ad) => ad.niche || "Bilinmiyor")), media: count(ads.map((ad) => ad.mediaType)), countries: count(ads.flatMap((ad) => ad.countries)),
+ stores: { total: stores._count, avgGrowth: stores._avg.monthlyVisitGrowth, avgVisits: stores._avg.monthlyVisits },
+ tiktok: { total: tiktok._count, sold: tiktok._sum.soldCount, avgRating: tiktok._avg.rating, avgPrice: tiktok._avg.price }
+ };
+ return prisma.trendSnapshot.upsert({ where: { date: startOfUtcDay() }, create: { date: startOfUtcDay(), metrics: metrics as Prisma.InputJsonValue }, update: { metrics: metrics as Prisma.InputJsonValue } });
+}
+
+async function sendAlertEmail(email: string, title: string, brand: string) {
+ const key = process.env.RESEND_API_KEY?.trim();
+ const from = process.env.ALERT_FROM_EMAIL?.trim();
+ if (!key || !from) return false;
+ const response = await fetch("https://api.resend.com/emails", { method: "POST", headers: { authorization: `Bearer ${key}`, "content-type": "application/json" }, body: JSON.stringify({ from, to: [email], subject: `${brand}: yeni reklam`, html: `
{user.name || user.email}
{user.subscription?.plan.name}
diff --git a/src/app/dashboard/magic-ai/page.tsx b/src/app/dashboard/magic-ai/page.tsx
index af0f547..b15ad3f 100644
--- a/src/app/dashboard/magic-ai/page.tsx
+++ b/src/app/dashboard/magic-ai/page.tsx
@@ -3,6 +3,7 @@ import { prisma } from "@/lib/db";
import { requireUser } from "@/lib/auth/current-user";
import { Card } from "@/components/ui/card";
import { AdCreativeMedia } from "@/components/ad-creative-media";
+import { MagicAiRunner } from "@/components/magic-ai-runner";
function sentence(value?: string | null) {
return value?.split(/[.!?\n]/).map((item) => item.trim()).find(Boolean) || "Metin kancası bulunamadı";
@@ -17,15 +18,19 @@ function recommendation(ad: { daysRunning: number | null; mediaType: string; pri
}
export default async function MagicAIPage({ searchParams }: { searchParams: PromiseMagic AI
Kreatif dayanıklılığı, formatı ve reklam metnini analiz ederek uygulanabilir test önerileri üretir.
{analyses.map((analysis) =>
}
{analysis.query || "Genel kreatif analizi"}
{analysis.model}{analysis.summary}
{(analysis.insights as Array<{title:string;action:string;confidence:number}>).map((item, index) =>
{item.title}
)}{item.action}
Creative Intelligence
{ads.length} reklamdan aksiyon planı
Öneriler canlı reklam süresi ve mevcut kreatif sinyallerinden hesaplanır.
{ads.map((ad) => { const insight = recommendation(ad); return
-
-
);
diff --git a/src/app/dashboard/tiktok-shop/page.tsx b/src/app/dashboard/tiktok-shop/page.tsx
index 8305dc8..d3d7829 100644
--- a/src/app/dashboard/tiktok-shop/page.tsx
+++ b/src/app/dashboard/tiktok-shop/page.tsx
@@ -1,42 +1,46 @@
import { Prisma } from "@prisma/client";
import { prisma } from "@/lib/db";
import { requireUser } from "@/lib/auth/current-user";
+import { planFromUser } from "@/lib/plans";
import { Card } from "@/components/ui/card";
+import { TikTokShopImport } from "@/components/tiktok-shop-import";
-function opportunityScore(product: { isBestSeller: boolean; price: number | null; store: { monthlyVisitGrowth: number | null; monthlyVisits: number | null } }) {
- const growth = Math.max(0, product.store.monthlyVisitGrowth || 0);
- const traffic = Math.min(25, Math.log10(Math.max(1, product.store.monthlyVisits || 1)) * 4);
+function opportunityScore(product: { soldCount: number | null; rating: number | null; reviewCount: number | null; price: number | null }) {
+ const sales = Math.min(45, Math.log10(Math.max(1, product.soldCount || 1)) * 10);
+ const reviews = Math.min(15, Math.log10(Math.max(1, product.reviewCount || 1)) * 4);
+ const rating = Math.min(20, Math.max(0, (product.rating || 0) * 4));
const priceFit = product.price && product.price >= 15 && product.price <= 80 ? 20 : 8;
- return Math.min(99, Math.round(20 + growth + traffic + priceFit + (product.isBestSeller ? 15 : 0)));
+ return Math.min(99, Math.round(sales + reviews + rating + priceFit));
}
export default async function TikTokShopPage({ searchParams }: { searchParams: Promise> }) {
- await requireUser();
+ const user = await requireUser();
+ const plan = planFromUser(user as never);
+ const planLimit = user.role === "ADMIN" || plan?.code === "PREMIUM" ? 50 : plan?.code === "STANDARD" ? 25 : plan?.code === "BASIC" ? 10 : 0;
const resolved = await searchParams;
const q = resolved.q?.trim();
- const country = resolved.country?.trim();
- const where: Prisma.StoreProductWhereInput = {
- store: { pixels: { some: { type: { contains: "TikTok", mode: "insensitive" } } }, ...(country ? { country } : {}) },
- ...(q ? { OR: [{ title: { contains: q, mode: "insensitive" } }, { store: { name: { contains: q, mode: "insensitive" } } }] } : {})
+ const region = resolved.region?.trim();
+ const where: Prisma.TikTokProductWhereInput = {
+ ...(region ? { region } : {}),
+ ...(q ? { OR: [{ title: { contains: q, mode: "insensitive" } }, { shopName: { contains: q, mode: "insensitive" } }, { category: { contains: q, mode: "insensitive" } }] } : {})
};
- const products = await prisma.storeProduct.findMany({ where, include: { store: true }, take: 60 });
+ const products = await prisma.tikTokProduct.findMany({ where, orderBy: [{ soldCount: "desc" }, { lastSeenAt: "desc" }], take: 60 });
const ranked = products.map((product) => ({ ...product, score: opportunityScore(product) })).sort((a, b) => b.score - a.score);
- const countries = [...new Set(products.map((product) => product.store.country).filter(Boolean))] as string[];
-
- return (
- sum + ad.countries.length, 0)} />
);
}
diff --git a/src/app/login/page.tsx b/src/app/login/page.tsx
index 533bcf8..211af80 100644
--- a/src/app/login/page.tsx
+++ b/src/app/login/page.tsx
@@ -27,24 +27,7 @@ export default function LoginPage() {
body: JSON.stringify({ email, password })
});
if (!res.ok) {
- setError("Giriş başarısız. Demo hesap için aşağıdaki butonu kullanabilir veya bilgileri elle girebilirsiniz (demo@winninghunter.local / demo1234).");
- return;
- }
- location.href = "/dashboard/ads";
- }
-
- async function loginAsDemo(e: React.MouseEvent) {
- e.preventDefault();
- setError("");
- const demoEmail = "demo@winninghunter.local";
- const demoPassword = "demo1234";
- const res = await fetch("/api/auth/login", {
- method: "POST",
- headers: { "content-type": "application/json" },
- body: JSON.stringify({ email: demoEmail, password: demoPassword })
- });
- if (!res.ok) {
- setError("Demo girişi başarısız. Demo veritabanı kurulmamış olabilir.");
+ setError("E-posta veya şifre hatalı.");
return;
}
location.href = "/dashboard/ads";
@@ -54,7 +37,7 @@ export default function LoginPage() {
{ad.headline || "Başlıksız reklam"}
{ad.brandPage?.name || "Bilinmeyen marka"} · {ad.mediaType} · {ad.daysRunning || "—"} gün
Kanca
{sentence(ad.primaryText)}
{insight.text}
Store Tracker
Plan limitine göre rakip Shopify mağazalarını watchlist’e ekle.
- {tracked.map((t) =>
+ {t.store.name}
{t.store.domain} · {t.store.products.map((p) => p.title).join(", ")} · €{t.store.estRevenue30dMax?.toLocaleString()} est.
)}
- {!tracked.length && Free planda tracker kapalıdır. Admin demo hesabında örnek takip bulunur.
}
-
-
-
-
- );
+ const regions = [...new Set(products.map((product) => product.region).filter(Boolean))] as string[];
+ return TikTok Shop
TikTok Pixel bulunan mağazalardaki ürünleri büyüme, trafik, fiyat ve bestseller sinyalleriyle sırala.
Ürün sinyali
{ranked.length}
TikTok Pixel mağazası
{new Set(ranked.map((item) => item.storeId)).size}
Ortalama fırsat skoru
{ranked.length ? Math.round(ranked.reduce((sum, item) => sum + item.score, 0) / ranked.length) : 0}
{ranked.map((product) =>
- {product.imageUrl ? 
: {product.score}
-
- )}{!ranked.length && TikTok Pixel sinyalli ürün bulunamadı. }
- Ürün görseli yok
}
- {product.title}
{product.store.name} · {product.store.country}
{product.price ? `${product.price} ${product.currency || product.store.currency || ""}` : "—"}
Fiyat
Fiyat
{product.store.monthlyVisitGrowth || 0}%
Büyüme
Büyüme
{product.isBestSeller ? "Evet" : "Hayır"}
Bestseller
Bestseller
+
+
;
}
diff --git a/src/app/dashboard/trends/page.tsx b/src/app/dashboard/trends/page.tsx
index 4311f67..6784fcd 100644
--- a/src/app/dashboard/trends/page.tsx
+++ b/src/app/dashboard/trends/page.tsx
@@ -14,9 +14,10 @@ function Bars({ rows, total }: { rows: [string, number][]; total: number }) {
export default async function TrendsPage() {
await requireUser();
- const [ads, stores] = await Promise.all([
+ const [ads, stores, history] = await Promise.all([
prisma.ad.findMany({ select: { niche: true, mediaType: true, countries: true, status: true, daysRunning: true, firstSeenAt: true }, orderBy: { updatedAt: "desc" }, take: 500 }),
- prisma.store.findMany({ select: { niche: true, monthlyVisitGrowth: true, name: true, country: true }, orderBy: { monthlyVisitGrowth: "desc" }, take: 20 })
+ prisma.store.findMany({ select: { niche: true, monthlyVisitGrowth: true, name: true, country: true }, orderBy: { monthlyVisitGrowth: "desc" }, take: 20 }),
+ prisma.trendSnapshot.findMany({ orderBy: { date: "desc" }, take: 14 })
]);
const active = ads.filter((ad) => ad.status === "ACTIVE");
const longRunners = ads.filter((ad) => (ad.daysRunning || 0) >= 30);
@@ -31,6 +32,7 @@ export default async function TrendsPage() {
TikTok Shop
Apify üzerinden canlı ürün, satış, fiyat, mağaza ve değerlendirme sinyalleri.
Canlı ürün
{ranked.length}
Mağaza
{new Set(ranked.map((item) => item.shopExternalId || item.shopName)).size}
Toplam satış sinyali
{ranked.reduce((sum, item) => sum + (item.soldCount || 0), 0).toLocaleString("tr-TR")}
{ranked.map((product) =>
+ {product.imageUrl ? : {product.score}
+
+ {product.productUrl && TikTok’ta aç →}
+ )}{!ranked.length && Yukarıdan bir ürün aratıp canlı veriyi getirin. }
+ Ürün görseli yok
}
+ {product.title}
{product.shopName || "Mağaza bilinmiyor"} · {product.region}
{product.price ? `${product.price} ${product.currency || ""}` : "—"}
Fiyat
Fiyat
{(product.soldCount || 0).toLocaleString("tr-TR")}
Satış
Satış
{product.rating || "—"}
Puan
Puan
İzlenen reklam
{ads.length}
Aktif reklam
{active.length}
30+ gün yaşayan
{longRunners.length}
Son 14 gün
{newAds.length}
Niche dağılımı
Medya formatı
Ülke sinyali
Hızlı büyüyen mağazalar
Aylık ziyaret büyümesine göre
{stores.slice(0, 8).map((store) => )}
{store.name}
{store.niche || "Niche yok"} · {store.country || "—"}
+{store.monthlyVisitGrowth || 0}%
14 günlük geçmiş
Günlük otomasyonla kaydedilen reklam ve TikTok Shop sinyalleri
{history.map((snapshot) => { const metrics = snapshot.metrics as any; return
{snapshot.date.toLocaleDateString("tr-TR")}
; })}{!history.length && {metrics.ads?.active || 0} aktif reklam
{metrics.tiktok?.total || 0} TikTok ürün
İlk günlük snapshot henüz oluşmadı.
}Apify · Yalnızca yöneticiler
+Apify · Plan limiti: {planLimit || "erişim yok"} reklam · Kullanılan kayıt kadar API kredisi
{message &&{message}
}{error}
}; +} diff --git a/src/components/dashboard-mobile-nav.tsx b/src/components/dashboard-mobile-nav.tsx new file mode 100644 index 0000000..bbe282f --- /dev/null +++ b/src/components/dashboard-mobile-nav.tsx @@ -0,0 +1,16 @@ +"use client"; +import Link from "next/link"; +import { usePathname } from "next/navigation"; +import { useState } from "react"; + +const items = [ + ["Ads", "/dashboard/ads"], ["Stores", "/dashboard/stores"], ["Store Tracker", "/dashboard/store-tracker"], + ["Saved Ads", "/dashboard/saved-ads"], ["TikTok Shop", "/dashboard/tiktok-shop"], ["Magic AI", "/dashboard/magic-ai"], + ["Trends", "/dashboard/trends"], ["Brand Tracker", "/dashboard/brand-tracker"], ["Account", "/dashboard/account"] +]; + +export function DashboardMobileNav({ isAdmin }: { isAdmin: boolean }) { + const [open, setOpen] = useState(false); + const pathname = usePathname(); + return{open && }
;
+}
diff --git a/src/components/magic-ai-runner.tsx b/src/components/magic-ai-runner.tsx
new file mode 100644
index 0000000..87a83d2
--- /dev/null
+++ b/src/components/magic-ai-runner.tsx
@@ -0,0 +1,21 @@
+"use client";
+import { useState } from "react";
+import { useRouter } from "next/navigation";
+
+export function MagicAiRunner() {
+ const router = useRouter();
+ const [query, setQuery] = useState("");
+ const [busy, setBusy] = useState(false);
+ const [message, setMessage] = useState("");
+ async function analyze() {
+ setBusy(true); setMessage("");
+ try {
+ const response = await fetch("/api/magic-ai/analyze", { method: "POST", headers: { "content-type": "application/json" }, body: JSON.stringify({ query: query.trim() || undefined }) });
+ const data = await response.json().catch(() => ({}));
+ if (!response.ok) throw new Error(data.error || "AI_ANALYSIS_FAILED");
+ setMessage("Yeni AI analizi kaydedildi."); router.refresh();
+ } catch (error) { setMessage(error instanceof Error ? error.message : "Analiz başarısız."); }
+ finally { setBusy(false); }
+ }
+ return setQuery(e.target.value)} placeholder="Ürün, marka veya reklam metni" className="min-w-0 flex-1 rounded-2xl border border-slate-200 px-4 py-3" />{message &&
;
+}
diff --git a/src/components/store-tracker-manager.tsx b/src/components/store-tracker-manager.tsx
new file mode 100644
index 0000000..27b0e69
--- /dev/null
+++ b/src/components/store-tracker-manager.tsx
@@ -0,0 +1,67 @@
+"use client";
+
+import { FormEvent, useState } from "react";
+import { useRouter } from "next/navigation";
+
+type TrackedStoreItem = {
+ id: string;
+ store: {
+ id: string;
+ name: string;
+ domain: string;
+ estRevenue30dMax: number | null;
+ products: { title: string }[];
+ };
+};
+
+export function StoreTrackerManager({ tracked, limit }: { tracked: TrackedStoreItem[]; limit: number | null }) {
+ const router = useRouter();
+ const [domain, setDomain] = useState("");
+ const [busy, setBusy] = useState{message}
}
+
+
+ );
+}
diff --git a/src/components/tiktok-shop-import.tsx b/src/components/tiktok-shop-import.tsx
new file mode 100644
index 0000000..f771175
--- /dev/null
+++ b/src/components/tiktok-shop-import.tsx
@@ -0,0 +1,29 @@
+"use client";
+import { useState } from "react";
+import { useRouter } from "next/navigation";
+
+export function TikTokShopImport({ planLimit }: { planLimit: number }) {
+ const router = useRouter();
+ const [query, setQuery] = useState("");
+ const [region, setRegion] = useState("US");
+ const [count, setCount] = useState(Math.min(10, planLimit || 10));
+ const [busy, setBusy] = useState(false);
+ const [message, setMessage] = useState("");
+ async function run() {
+ setBusy(true); setMessage("");
+ try {
+ const response = await fetch("/api/tiktok-shop/import", { method: "POST", headers: { "content-type": "application/json" }, body: JSON.stringify({ query, region, maxResults: count }) });
+ const data = await response.json().catch(() => ({}));
+ if (!response.ok) throw new Error(data.error || "TIKTOK_IMPORT_FAILED");
+ setMessage(`${data.imported} ürün güncellendi.`); router.refresh();
+ } catch (error) { setMessage(error instanceof Error ? error.message : "İçe aktarma başarısız."); }
+ finally { setBusy(false); }
+ }
+ return Yalnızca WinningHunter veritabanında bulunan domainler eklenebilir.{tracked.length} / {limit === null ? "∞" : limit}
+ {message && {message}
}
+
+ {tracked.map((item) => )}
+ {!tracked.length &&
+ Henüz takip edilen mağaza yok.
}
+
+ setQuery(e.target.value)} placeholder="TikTok Shop ürününü canlı ara" className="rounded-2xl border border-slate-200 px-4 py-3" />
+
+
+
+ {message &&
;
+}
diff --git a/src/lib/apify-tiktok.ts b/src/lib/apify-tiktok.ts
new file mode 100644
index 0000000..0c7d000
--- /dev/null
+++ b/src/lib/apify-tiktok.ts
@@ -0,0 +1,103 @@
+import { Prisma } from "@prisma/client";
+import { prisma } from "@/lib/db";
+
+type Row = Record{message}
} +${brand} için yeni reklam bulundu.
${title}
` }) }); + return response.ok; +} + +export async function createBrandAlerts() { + const tracked = await prisma.trackedBrand.findMany({ include: { user: { select: { email: true } }, brandPage: { include: { ads: { orderBy: { createdAt: "desc" }, take: 20 } } } } }); + let created = 0; + for (const item of tracked) { + for (const ad of item.brandPage.ads) { + if (ad.createdAt < item.createdAt && (!ad.firstSeenAt || ad.firstSeenAt < item.createdAt)) continue; + const title = ad.headline || ad.primaryText?.slice(0, 100) || "Yeni kreatif"; + const unique = { userId: item.userId, trackedBrandId: item.id, adId: ad.id, type: "NEW_AD" }; + if (await prisma.brandAlert.findUnique({ where: { userId_trackedBrandId_adId_type: unique } })) continue; + await prisma.brandAlert.create({ data: { ...unique, title, details: { brand: item.brandPage.name, mediaType: ad.mediaType } } }); + await prisma.notification.create({ data: { userId: item.userId, type: "BRAND_NEW_AD", title: `${item.brandPage.name}: yeni reklam`, body: title, link: "/dashboard/brand-tracker" } }); + await sendAlertEmail(item.user.email, title, item.brandPage.name).catch(() => false); + created += 1; + } + } + return created; +} diff --git a/tests/core.test.ts b/tests/core.test.ts new file mode 100644 index 0000000..d051b16 --- /dev/null +++ b/tests/core.test.ts @@ -0,0 +1,51 @@ +import assert from "node:assert/strict"; +import test from "node:test"; +import { MediaType } from "@prisma/client"; +import { normalizeApifyAd } from "../src/lib/apify"; +import { getFeatureLimit } from "../src/lib/plans"; +import { istemciIp, hizSiniriAsimi } from "../src/lib/rate-limit"; +import { stripePriceFor } from "../src/lib/stripe"; + +test("Apify reklamı metin, medya ve ülke alanlarıyla normalize edilir", () => { + const ad = normalizeApifyAd({ + adArchiveID: "123", + pageID: "page-1", + pageName: "Berber İstanbul", + adText: "Yeni stilini keşfet", + videoUrl: "https://cdn.example.com/ad.mp4", + countries: ["TR"], + adStatus: "ACTIVE" + }); + assert.ok(ad); + assert.equal(ad.externalAdId, "123"); + assert.equal(ad.mediaType, MediaType.VIDEO); + assert.deepEqual(ad.countries, ["TR"]); +}); + +test("plan feature limiti metrik adına göre çözülür", () => { + const plan = { features: { adsSearchDaily: 100, apiCreditsMonthly: 500 } } as never; + assert.equal(getFeatureLimit(plan, "ads_search_daily"), 100); + assert.equal(getFeatureLimit(plan, "api_credits_monthly"), 500); + assert.equal(getFeatureLimit(plan, "unknown"), 0); +}); + +test("istemci IP'sinde güvenilir son proxy adresi kullanılır", () => { + const request = new Request("https://example.com", { headers: { "x-forwarded-for": "198.51.100.1, 10.0.0.2" } }); + assert.equal(istemciIp(request), "10.0.0.2"); +}); + +test("giriş hız sınırı on birinci isteği engeller", () => { + const request = new Request("https://example.com", { headers: { "x-real-ip": `test-${Date.now()}` } }); + for (let i = 0; i < 10; i += 1) assert.equal(hizSiniriAsimi(request, "giris"), null); + assert.equal(hizSiniriAsimi(request, "giris")?.status, 429); +}); + +test("Stripe fiyat kimliği env allowlist'inden okunur", () => { + const previous = process.env.STRIPE_PRICE_BASIC_MONTHLY; + process.env.STRIPE_PRICE_BASIC_MONTHLY = "price_test123"; + assert.equal(stripePriceFor("BASIC", "monthly"), "price_test123"); + process.env.STRIPE_PRICE_BASIC_MONTHLY = "invalid"; + assert.throws(() => stripePriceFor("BASIC", "monthly"), /STRIPE_PRICE_NOT_CONFIGURED/); + if (previous === undefined) delete process.env.STRIPE_PRICE_BASIC_MONTHLY; + else process.env.STRIPE_PRICE_BASIC_MONTHLY = previous; +});