feat: RRSS hub estilo Miia + Ad Tracker por cliente

Replica agua-miia/rrss (hub, archivo, octubre 2026 con 27 piezas) y añade Ad Tracker por tenant al estilo Brava (periodos, Meta+Google, CPL/clics, campañas).

Co-authored-by: Cursor <cursoragent@cursor.com>
This commit is contained in:
4Ventures
2026-09-23 02:55:14 +02:00
parent a1a3c26c30
commit b4ee23874e
10 changed files with 2455 additions and 38 deletions

View File

@@ -0,0 +1,84 @@
import { NextResponse } from 'next/server';
import { createClient } from '@/lib/supabase/server';
import { resolveActiveTenant, restGet } from '@/lib/tenant-context';
import { isAgencyRole, serviceHeaders, supabaseUrl, userRole } from '@/lib/agency';
import octPlan from '@/data/rrss-octubre-2026.json';
export const dynamic = 'force-dynamic';
/**
* POST — publish bundled RRSS month plan into documents for the active tenant.
* Agency only. Idempotent upsert by title + type.
*/
export async function POST() {
const supabase = await createClient();
const {
data: { user },
} = await supabase.auth.getUser();
if (!user) {
return NextResponse.json({ error: 'Unauthorized' }, { status: 401 });
}
if (!isAgencyRole(userRole(user))) {
return NextResponse.json({ error: 'Solo agencia' }, { status: 403 });
}
const ctx = await resolveActiveTenant(user);
if (!ctx.tenantId || ctx.portfolioWide) {
return NextResponse.json(
{ error: 'Selecciona un cliente en Contexto' },
{ status: 400 }
);
}
const headers = serviceHeaders();
if (!headers) {
return NextResponse.json({ error: 'no service role' }, { status: 500 });
}
const title = `RRSS ${octPlan.label}`;
const tid = encodeURIComponent(ctx.tenantId);
const existing = await restGet<Array<{ id: string }>>(
`/rest/v1/documents?tenant_id=eq.${tid}&type=eq.calendar&title=eq.${encodeURIComponent(title)}&select=id&limit=1`
);
const payload = {
tenant_id: ctx.tenantId,
type: 'calendar',
title,
content: octPlan,
};
let res: Response;
if (existing.data?.[0]?.id) {
res = await fetch(
`${supabaseUrl()}/rest/v1/documents?id=eq.${existing.data[0].id}`,
{
method: 'PATCH',
headers: { ...headers, 'Content-Type': 'application/json', Prefer: 'return=representation' },
body: JSON.stringify({ content: octPlan, title }),
}
);
} else {
res = await fetch(`${supabaseUrl()}/rest/v1/documents`, {
method: 'POST',
headers: { ...headers, 'Content-Type': 'application/json', Prefer: 'return=representation' },
body: JSON.stringify(payload),
});
}
if (!res.ok) {
return NextResponse.json(
{ error: await res.text() },
{ status: 502 }
);
}
const row = await res.json();
return NextResponse.json({
ok: true,
tenant: ctx.label,
month: octPlan.month,
pieces: (octPlan.pieces || []).length,
document: Array.isArray(row) ? row[0] : row,
});
}