Marketing/4ventures-client-portal
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: preview de placement en pipeline de creatividades

Browse Source 
Cada pieza muestra mock Meta/Google Ads o RRSS (feed, Stories, LinkedIn) como el Ad Tracker, con copy, media y canal editables.

Co-authored-by: Cursor <cursoragent@cursor.com>
This commit is contained in:
4Ventures
2026-09-23 03:36:28 +02:00
parent b4ee23874e
commit a7704567bd
6 changed files with 1448 additions and 207 deletions
Download Patch File Download Diff File Expand all files Collapse all files

147
src/app/api/creatives/route.ts
View File

@@ -10,6 +10,31 @@ import {
userRole,
} from '@/lib/agency';
const SELECT =
'id,title,status,channel,placement,format,headline,primary_text,description,cta,media_url,brand_name,landing_url,mime_type,bytes,created_at,updated_at';
const CHANNELS = new Set([
'meta_ads',
'google_ads',
'instagram',
'facebook',
'linkedin',
'tiktok',
'stories',
'other',
]);
const FORMATS = new Set([
'image',
'video',
'carousel',
'reel',
'story',
'rsa',
'pmax',
'other',
]);
const ALLOWED_STATUS = new Set(['draft', 'in_review', 'approved', 'rejected']);
async function resolveTenantId(user: {
app_metadata?: Record<string, unknown>;
user_metadata?: Record<string, unknown>;
@@ -23,6 +48,30 @@ async function resolveTenantId(user: {
return { tenantId: homeTenantId(user), viaView: false };
}
function str(v: unknown, max = 2000): string | null {
if (typeof v !== 'string') return null;
const t = v.trim();
if (!t) return null;
return t.slice(0, max);
}
function previewFields(body: Record<string, unknown>) {
const channel = str(body.channel, 40);
const format = str(body.format, 40);
return {
channel: channel && CHANNELS.has(channel) ? channel : null,
placement: str(body.placement, 40),
format: format && FORMATS.has(format) ? format : null,
headline: str(body.headline, 500),
primary_text: str(body.primary_text, 8000),
description: str(body.description, 2000),
cta: str(body.cta, 120),
media_url: str(body.media_url, 2000),
brand_name: str(body.brand_name, 200),
landing_url: str(body.landing_url, 2000),
};
}
export async function GET() {
const supabase = await createClient();
const {
@@ -43,10 +92,23 @@ export async function GET() {
);
}
const r = await fetch(
`${supabaseUrl()}/rest/v1/creatives?tenant_id=eq.${encodeURIComponent(tenantId)}&select=id,title,status,mime_type,bytes,created_at,updated_at&order=updated_at.desc`,
`${supabaseUrl()}/rest/v1/creatives?tenant_id=eq.${encodeURIComponent(tenantId)}&select=${SELECT}&order=updated_at.desc`,
{ headers, cache: 'no-store' }
);
if (!r.ok) {
// Fallback if preview columns not migrated yet
const fallback = await fetch(
`${supabaseUrl()}/rest/v1/creatives?tenant_id=eq.${encodeURIComponent(tenantId)}&select=id,title,status,mime_type,bytes,created_at,updated_at&order=updated_at.desc`,
{ headers, cache: 'no-store' }
);
if (fallback.ok) {
return NextResponse.json({
creatives: await fallback.json(),
viewTenantId: tenantId,
warning:
'Aplica sql/creatives_preview.sql para canales, copy y media preview',
});
}
return NextResponse.json({
creatives: [],
warning: await r.text(),
@@ -61,14 +123,25 @@ export async function GET() {
const { data, error } = await supabase
.from('creatives')
.select('id,title,status,mime_type,bytes,created_at,updated_at')
.select(SELECT)
.order('updated_at', { ascending: false });
if (error) {
return NextResponse.json(
{ creatives: [], warning: error.message },
{ status: 200 }
);
const { data: basic, error: e2 } = await supabase
.from('creatives')
.select('id,title,status,mime_type,bytes,created_at,updated_at')
.order('updated_at', { ascending: false });
if (e2) {
return NextResponse.json(
{ creatives: [], warning: error.message },
{ status: 200 }
);
}
return NextResponse.json({
creatives: basic ?? [],
warning:
'Aplica sql/creatives_preview.sql para canales, copy y media preview',
});
}
return NextResponse.json({ creatives: data ?? [] });
@@ -88,8 +161,8 @@ export async function POST(req: NextRequest) {
return NextResponse.json({ error: 'Usuario sin tenant_id' }, { status: 403 });
}
const body = await req.json().catch(() => ({}));
const title = typeof body.title === 'string' ? body.title.trim() : '';
const body = (await req.json().catch(() => ({}))) as Record<string, unknown>;
const title = str(body.title, 300);
if (!title) {
return NextResponse.json({ error: 'title requerido' }, { status: 400 });
}
@@ -99,6 +172,7 @@ export async function POST(req: NextRequest) {
title,
status: 'draft',
created_by: user.id,
...previewFields(body),
};
if (viaView) {
@@ -131,18 +205,36 @@ export async function POST(req: NextRequest) {
const { data, error } = await supabase
.from('creatives')
.insert(row)
.select('id,title,status,created_at')
.select(SELECT)
.single();
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
// Retry without preview columns if migration pending
const { data: basic, error: e2 } = await supabase
.from('creatives')
.insert({
tenant_id: tenantId,
title,
status: 'draft',
created_by: user.id,
})
.select('id,title,status,created_at')
.single();
if (e2) {
return NextResponse.json({ error: error.message }, { status: 500 });
}
return NextResponse.json(
{
creative: basic,
warning: 'Preview columns missing — apply sql/creatives_preview.sql',
},
{ status: 201 }
);
}
return NextResponse.json({ creative: data }, { status: 201 });
}
const ALLOWED = new Set(['draft', 'in_review', 'approved', 'rejected']);
export async function PATCH(req: NextRequest) {
const supabase = await createClient();
const {
@@ -152,11 +244,23 @@ export async function PATCH(req: NextRequest) {
return NextResponse.json({ error: 'Unauthorized' }, { status: 401 });
}
const body = await req.json().catch(() => ({}));
const id = typeof body.id === 'string' ? body.id.trim() : '';
const status = typeof body.status === 'string' ? body.status.trim() : '';
if (!id || !ALLOWED.has(status)) {
return NextResponse.json({ error: 'id y status válidos requeridos' }, { status: 400 });
const body = (await req.json().catch(() => ({}))) as Record<string, unknown>;
const id = str(body.id, 80);
if (!id) {
return NextResponse.json({ error: 'id requerido' }, { status: 400 });
}
const clean: Record<string, unknown> = {
updated_at: new Date().toISOString(),
};
if (typeof body.status === 'string' && ALLOWED_STATUS.has(body.status)) {
clean.status = body.status;
}
const title = str(body.title, 300);
if (title) clean.title = title;
for (const [k, v] of Object.entries(previewFields(body))) {
if (k in body) clean[k] = v;
}
const agency = isAgencyRole(userRole(user));
@@ -172,10 +276,7 @@ export async function PATCH(req: NextRequest) {
'Content-Type': 'application/json',
Prefer: 'return=representation',
},
body: JSON.stringify({
status,
updated_at: new Date().toISOString(),
}),
body: JSON.stringify(clean),
}
);
if (!r.ok) {
@@ -187,9 +288,9 @@ export async function PATCH(req: NextRequest) {
const { data, error } = await supabase
.from('creatives')
.update({ status, updated_at: new Date().toISOString() })
.update(clean)
.eq('id', id)
.select('id,title,status')
.select(SELECT)
.single();
if (error) {
return NextResponse.json({ error: error.message }, { status: 500 });