+ Your CrawlProof ad money across both sides — what you earn as a publisher and what
+ you spend as an advertiser. Last {RANGE} days. Download a PDF report for your
+ accountant or team.
+
+
+
+
+
+ = 0} danger={t.netCents < 0} />
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ {/* Publisher earnings */}
+
Earnings by site
+ {model.slots.length === 0 ? (
+
+ No monetized sites yet.{" "}
+
+ Monetize a site
+
+ .
+
+ ) : (
+
+
+
+
+
Site
+
Status
+
Impr.
+
Clicks
+
CTR
+
Earned
+
+
+
+ {model.slots.map((s) => (
+
+
{s.name}
+
+ {s.status}
+
+
{s.impressions.toLocaleString()}
+
{s.clicks.toLocaleString()}
+
{ctr(s.clicks, s.impressions)}
+
+ {dollars(s.earnedCents)}
+
+
+ ))}
+
+
+
+ )}
+
+ {/* Advertiser spend */}
+
Spend by campaign
+ {model.campaigns.length === 0 ? (
+
+ No ad campaigns yet.{" "}
+
+ Create an ad
+
+ .
+
+
+ Earnings & reports
+
Monetize a site
diff --git a/app/(app)/ads/slots/page.tsx b/app/(app)/ads/slots/page.tsx
index febdb2a5..62fe1523 100644
--- a/app/(app)/ads/slots/page.tsx
+++ b/app/(app)/ads/slots/page.tsx
@@ -95,14 +95,19 @@ export default async function SlotsPage() {
← Ad campaigns
-
+
Monetize your site
- {/* Always-visible way to add a site to monetize — a site is a project,
- so this starts the project-creation flow. Previously the only link
- to it was hidden inside the empty state. */}
-
- Monetize a new site
-
+
+
+ Earnings & reports
+
+ {/* Always-visible way to add a site to monetize — a site is a project,
+ so this starts the project-creation flow. Previously the only link
+ to it was hidden inside the empty state. */}
+
+ Monetize a new site
+
+
Each site you monetize is a CrawlProof project. Add a site to
diff --git a/app/api/ads/earnings/pdf/route.ts b/app/api/ads/earnings/pdf/route.ts
new file mode 100644
index 00000000..1ac7d7c4
--- /dev/null
+++ b/app/api/ads/earnings/pdf/route.ts
@@ -0,0 +1,50 @@
+// PDF earnings/spend report for the logged-in account. Runs the same
+// RLS-scoped queries as /ads/earnings, renders a self-contained HTML report,
+// and hands it to the worker's Playwright /pdf endpoint (html branch).
+
+import { NextResponse } from "next/server";
+import { createClient } from "@/lib/supabase/server";
+import { env } from "@/lib/env";
+import { loadEarnings } from "@/lib/ads/earnings-data";
+import { buildEarningsReportHtml } from "@/lib/ads/earnings-report";
+
+export const runtime = "nodejs";
+
+export async function GET(req: Request) {
+ const supabase = await createClient();
+ const {
+ data: { user },
+ } = await supabase.auth.getUser();
+ if (!user) return NextResponse.json({ error: "Not authenticated" }, { status: 401 });
+
+ if (!env.workerUrl) {
+ return NextResponse.json({ error: "Worker not configured" }, { status: 500 });
+ }
+
+ const daysParam = Number(new URL(req.url).searchParams.get("days"));
+ const days = Number.isFinite(daysParam) && daysParam >= 1 && daysParam <= 365 ? Math.floor(daysParam) : 30;
+
+ const model = await loadEarnings(supabase, user.id, days);
+ const html = buildEarningsReportHtml({
+ model,
+ account: user.email ?? user.id,
+ generatedAt: new Date().toISOString(),
+ });
+
+ const workerRes = await fetch(`${env.workerUrl}/pdf`, {
+ method: "POST",
+ headers: { "content-type": "application/json", "x-worker-secret": env.workerSecret },
+ body: JSON.stringify({ html }),
+ });
+ if (!workerRes.ok) {
+ return NextResponse.json({ error: "PDF render failed" }, { status: 502 });
+ }
+ const buf = await workerRes.arrayBuffer();
+ const stamp = new Date().toISOString().slice(0, 10);
+ return new NextResponse(buf, {
+ headers: {
+ "content-type": "application/pdf",
+ "content-disposition": `attachment; filename="crawlproof-earnings-${stamp}.pdf"`,
+ },
+ });
+}
diff --git a/components/ads/earnings-pdf-button.tsx b/components/ads/earnings-pdf-button.tsx
new file mode 100644
index 00000000..1a53c80f
--- /dev/null
+++ b/components/ads/earnings-pdf-button.tsx
@@ -0,0 +1,19 @@
+"use client";
+
+import { useState } from "react";
+
+export function EarningsPdfButton({ days = 30 }: { days?: number }) {
+ const [busy, setBusy] = useState(false);
+ return (
+ {
+ setBusy(true);
+ setTimeout(() => setBusy(false), 4000);
+ }}
+ >
+ {busy ? "Preparing PDF…" : "Download PDF report"}
+
+ );
+}
diff --git a/components/ads/money-trend.tsx b/components/ads/money-trend.tsx
new file mode 100644
index 00000000..abd4b93e
--- /dev/null
+++ b/components/ads/money-trend.tsx
@@ -0,0 +1,100 @@
+"use client";
+
+import {
+ CartesianGrid,
+ Legend,
+ Line,
+ LineChart,
+ ResponsiveContainer,
+ Tooltip,
+ XAxis,
+ YAxis,
+} from "recharts";
+import type { MoneyDailyPoint } from "@/lib/ads/earnings-data";
+
+// Spend vs. earnings over time, in dollars. Mirrors the styling of
+// CampaignTrend but plots money on a single $ axis. Loaded via next/dynamic
+// (ssr:false) so recharts stays out of the server bundle.
+export function MoneyTrend({ data }: { data: MoneyDailyPoint[] }) {
+ const total = data.reduce((s, p) => s + p.spentCents + p.earnedCents, 0);
+ if (total === 0) {
+ return (
+
+
+
+ `;
+}
diff --git a/lib/ads/series.ts b/lib/ads/series.ts
index 075228fa..1c5c34c3 100644
--- a/lib/ads/series.ts
+++ b/lib/ads/series.ts
@@ -8,6 +8,13 @@ export type CampaignDailyPoint = {
spentCents: number;
};
+export type SlotDailyPoint = {
+ /** UTC calendar day, YYYY-MM-DD */
+ date: string;
+ clicks: number;
+ earnedCents: number;
+};
+
function dayKey(iso: string): string {
return iso.slice(0, 10);
}
@@ -80,3 +87,70 @@ export async function getCampaignDailySeries(
return result;
}
+
+type SlotSeriesRow = {
+ slot_id: string;
+ day: string; // YYYY-MM-DD (UTC)
+ clicks: number | string;
+ earned_cents: number | string;
+};
+
+/**
+ * Per-slot daily clicks / publisher earnings for the last `days`.
+ * Server-side aggregate via the ad_slot_daily_series RPC (security_invoker →
+ * RLS scopes to the caller's own slots). Same 1000-row-cap rationale as
+ * getCampaignDailySeries. See migration 20260717150000_ad_slot_daily_series_rpc.sql.
+ */
+export async function getSlotDailySeries(
+ supabase: SupabaseClient,
+ slotIds: string[],
+ days = 30,
+): Promise> {
+ const axis = dayAxis(days);
+ const result = new Map();
+ const emptyFor = () => axis.map((date) => ({ date, clicks: 0, earnedCents: 0 }));
+ for (const id of slotIds) result.set(id, emptyFor());
+ if (slotIds.length === 0) return result;
+
+ const index = new Map>();
+ for (const id of slotIds) {
+ const byDay = new Map();
+ for (const p of result.get(id)!) byDay.set(p.date, p);
+ index.set(id, byDay);
+ }
+
+ const { data, error } = await supabase.rpc("ad_slot_daily_series", { days });
+ if (error) return result;
+
+ for (const row of (data as SlotSeriesRow[]) ?? []) {
+ const point = index.get(row.slot_id)?.get(dayKey(row.day));
+ if (point) {
+ point.clicks += Number(row.clicks) || 0;
+ point.earnedCents += Number(row.earned_cents) || 0;
+ }
+ }
+
+ return result;
+}
+
+/** Merge campaign spend series + slot earnings series into one account-wide
+ * daily spend/earn axis (zero-filled, oldest first). */
+export function mergeMoneySeries(
+ campaign: Map,
+ slot: Map,
+ days = 30,
+): { date: string; spentCents: number; earnedCents: number }[] {
+ const byDate = new Map();
+ for (const date of dayAxis(days)) byDate.set(date, { date, spentCents: 0, earnedCents: 0 });
+ for (const points of campaign.values())
+ for (const p of points) {
+ const d = byDate.get(p.date);
+ if (d) d.spentCents += p.spentCents;
+ }
+ for (const points of slot.values())
+ for (const p of points) {
+ const d = byDate.get(p.date);
+ if (d) d.earnedCents += p.earnedCents;
+ }
+ return [...byDate.values()];
+}
diff --git a/supabase/migrations/20260717150000_ad_slot_daily_series_rpc.sql b/supabase/migrations/20260717150000_ad_slot_daily_series_rpc.sql
new file mode 100644
index 00000000..be8615bb
--- /dev/null
+++ b/supabase/migrations/20260717150000_ad_slot_daily_series_rpc.sql
@@ -0,0 +1,49 @@
+-- Ad network: per-slot daily PUBLISHER EARNINGS as a server-side aggregate.
+--
+-- Mirror of ad_campaign_daily_series (advertiser spend) for the publisher side,
+-- powering the /ads/earnings page's earnings-over-time chart and PDF report.
+-- Same rationale: bucketing raw ad_clicks in JS would hit PostgREST's 1000-row
+-- cap once a slot is busy, so aggregate in Postgres (at most slots * days rows).
+--
+-- security_invoker: RLS on ad_slots/ad_clicks applies to the caller, and we
+-- additionally scope to slots they OWN so nothing leaks across accounts.
+-- Earnings come from ad_clicks.publisher_earn_cents (floor rate), matching the
+-- ad_slot_stats view and the publisher_accrual ledger.
+--
+-- Days are UTC calendar days to match dayAxis() in lib/ads/series.ts.
+-- Apply via psql over the pooler / MCP (prod migration history diverged).
+
+create or replace function public.ad_slot_daily_series(days integer default 30)
+returns table (
+ slot_id uuid,
+ day date,
+ clicks bigint,
+ earned_cents bigint
+)
+language sql
+stable
+security invoker
+set search_path = public
+as $$
+ with bounds as (
+ select greatest(coalesce(days, 30), 1) as n
+ ),
+ since as (
+ select ((now() at time zone 'UTC')::date - (n - 1))::timestamptz as from_ts
+ from bounds
+ ),
+ owned as (
+ select id from public.ad_slots where owner_id = auth.uid()
+ )
+ select cl.slot_id,
+ (cl.ts at time zone 'UTC')::date as day,
+ count(*)::bigint as clicks,
+ coalesce(sum(cl.publisher_earn_cents), 0)::bigint as earned_cents
+ from public.ad_clicks cl
+ where cl.valid
+ and cl.slot_id in (select id from owned)
+ and cl.ts >= (select from_ts from since)
+ group by 1, 2;
+$$;
+
+grant execute on function public.ad_slot_daily_series(integer) to authenticated, service_role;
diff --git a/worker/index.ts b/worker/index.ts
index b8a287cc..8b6f0f12 100644
--- a/worker/index.ts
+++ b/worker/index.ts
@@ -831,12 +831,17 @@ const server = http.createServer(async (req, res) => {
const payload = JSON.parse(body || "{}") as {
token?: string;
markdown?: string;
+ html?: string;
title?: string;
target?: string;
score?: number;
};
let pdf: Buffer;
- if (payload.markdown) {
+ if (payload.html) {
+ // Caller supplies a complete, self-contained HTML document (e.g. the
+ // ads earnings report). Render it as-is — no markdown step.
+ pdf = await renderPdfFromHtml(payload.html);
+ } else if (payload.markdown) {
const bodyHtml = await markdownToHtml(payload.markdown);
const html = htmlDocument({
title: payload.title ?? "CrawlProof audit",