--- export const prerender = false; import { isAuthenticated, ADMIN_COOKIE } from '@admin/lib/admin-auth'; import { buildTitleMetadataAvailabilitySql, buildTitleMetadataProjectionSql, } from '@/lib/catalog-metadata'; interface Env { DB: D1Database } const runtime = Astro.locals.runtime as { env: Env } | undefined; const db = runtime?.env?.DB; if (!db || !await isAuthenticated(Astro.cookies.get(ADMIN_COOKIE)?.value, db)) { return Astro.redirect('/admin/login', 302); } interface ScraperRun { id: number; chain_id: string; city_id: string; started_at: string; finished_at: string | null; status: string; movies_found: number; showtimes_found: number; error_message: string | null; } interface Stats { total: number; metadata_ready: number; visible: number; showtimes_total: number; showtimes_today: number; missing_posters: number; } interface ComingSoonTitle { id: string; title_en: string; title_ar: string | null; release_date: string | null; metadata_popularity: number | null; metadata_rating: number | null; } interface ShowtimeLeader { id: string; title_en: string; cinema_count: number; showtime_count: number; } interface WaitlistCity { city_name: string; demand: number; } interface BookingClickTitle { title_en: string; clicks: number; } interface TitleAlertTitle { title_en: string; signups: number; } let stats: Stats = { total: 0, metadata_ready: 0, visible: 0, showtimes_total: 0, showtimes_today: 0, missing_posters: 0 }; let recentRuns: ScraperRun[] = []; let chainHealth: ScraperRun[] = []; let dbError: string | null = null; let comingSoon: ComingSoonTitle[] = []; let showtimeLeaders: ShowtimeLeader[] = []; let waitlistHotspots: WaitlistCity[] = []; let bookingClicks: BookingClickTitle[] = []; let bookingClicksAvailable = false; let titleAlerts: TitleAlertTitle[] = []; let titleAlertsAvailable = false; if (db) { try { const [total, metadataReady, visible, posterless, st, stToday] = await db.batch([ db.prepare('SELECT COUNT(*) as n FROM titles'), db.prepare(`SELECT COUNT(*) as n FROM titles WHERE ${buildTitleMetadataAvailabilitySql()}`), db.prepare('SELECT COUNT(*) as n FROM titles WHERE poster_url IS NOT NULL AND synopsis_en IS NOT NULL AND duration_min IS NOT NULL'), db.prepare('SELECT COUNT(*) as n FROM titles WHERE poster_url IS NULL'), db.prepare('SELECT COUNT(*) as n FROM showtimes'), db.prepare("SELECT COUNT(*) as n FROM showtimes WHERE DATE(showtime) = DATE('now')"), ]); stats = { total: (total.results[0] as any)?.n ?? 0, metadata_ready: (metadataReady.results[0] as any)?.n ?? 0, visible: (visible.results[0] as any)?.n ?? 0, showtimes_total: (st.results[0] as any)?.n ?? 0, showtimes_today: (stToday.results[0] as any)?.n ?? 0, missing_posters: (posterless.results[0] as any)?.n ?? 0, }; const [runs, health] = await db.batch([ db.prepare('SELECT * FROM scraper_runs ORDER BY id DESC LIMIT 50'), db.prepare('SELECT * FROM scraper_runs WHERE id IN (SELECT MAX(id) FROM scraper_runs GROUP BY chain_id) ORDER BY chain_id'), ]); recentRuns = (runs.results as ScraperRun[]); chainHealth = (health.results as ScraperRun[]); } catch (e) { dbError = String(e); } // Release intelligence queries — separate try/catch so a failure here never breaks the dashboard try { const [csRes, slRes, wlRes] = await db.batch([ db.prepare(` SELECT id, title_en, title_ar, release_date, ${buildTitleMetadataProjectionSql()} FROM titles WHERE status = 'coming_soon' ORDER BY COALESCE(release_date,'9999') ASC, COALESCE(metadata_popularity,0) DESC LIMIT 8 `), db.prepare(` SELECT t.id, t.title_en, COUNT(DISTINCT s.cinema_id) AS cinema_count, COUNT(s.id) AS showtime_count FROM titles t JOIN showtimes s ON s.title_id = t.id WHERE t.status = 'now_playing' GROUP BY t.id ORDER BY cinema_count DESC, showtime_count DESC LIMIT 8 `), db.prepare(` SELECT city_name, COUNT(*) AS demand FROM city_waitlist GROUP BY city_name ORDER BY demand DESC LIMIT 10 `), ]); comingSoon = csRes.results as ComingSoonTitle[]; showtimeLeaders = slRes.results as ShowtimeLeader[]; waitlistHotspots = wlRes.results as WaitlistCity[]; } catch (_) { // Intelligence queries failed — dashboard still works } // booking_clicks may not exist yet — handle gracefully try { const bcRes = await db.prepare(` SELECT t.title_en, COUNT(bc.id) AS clicks FROM booking_clicks bc JOIN titles t ON t.id = bc.title_id WHERE bc.clicked_at >= datetime('now', '-7 days') GROUP BY bc.title_id ORDER BY clicks DESC LIMIT 5 `).all(); bookingClicks = bcRes.results as BookingClickTitle[]; bookingClicksAvailable = true; } catch (_) { // booking_clicks table not yet available } // title_alerts may not exist yet — handle gracefully try { const taRes = await db.prepare(` SELECT t.title_en, COUNT(ta.id) AS signups FROM title_alerts ta JOIN titles t ON t.id = ta.title_id GROUP BY ta.title_id ORDER BY signups DESC LIMIT 5 `).all(); titleAlerts = taRes.results as TitleAlertTitle[]; titleAlertsAvailable = true; } catch (_) { // title_alerts table not yet available } } else { dbError = 'D1 database binding not available.'; } function duration(started: string, finished: string | null): string { if (!finished) return '—'; const ms = new Date(finished).getTime() - new Date(started).getTime(); if (ms < 0) return '—'; const s = Math.round(ms / 1000); return s < 60 ? `${s}s` : `${Math.floor(s / 60)}m ${s % 60}s`; } function relativeTime(dt: string | null): string { if (!dt) return '—'; const diffMs = Date.now() - new Date(dt).getTime(); const m = Math.floor(diffMs / 60000); if (m < 1) return 'just now'; if (m < 60) return `${m}m ago`; const h = Math.floor(m / 60); if (h < 24) return `${h}h ago`; return `${Math.floor(h / 24)}d ago`; } --- CultRoll Admin

Dashboard

Generated at {new Date().toISOString().replace('T',' ').slice(0,19)} UTC
{dbError &&
⚠ DB error: {dbError}
}
Visible Movies
{stats.visible}
of {stats.total} total
0 ? 'ok' : 'warn'}`}>
Metadata Ready
{stats.metadata_ready}
{stats.total - stats.metadata_ready} pending
0 ? 'warn' : 'ok'}`}>
Missing Posters
{stats.missing_posters}
of {stats.total} movies
Total Showtimes
{stats.showtimes_total}
{stats.showtimes_today} today

Release Intelligence

Week snapshot for exhibitor & distributor conversations
↓ CSV ↓ JSON
Coming Soon Upcoming titles to pitch, sorted by release date
{comingSoon.length === 0 ?
No coming-soon titles in database.
: ( {comingSoon.map(t => ( ))}
Title Release Popularity Rating
{t.title_en} {t.title_ar &&
{t.title_ar}
} 		{t.release_date ?? '—'} {t.metadata_popularity != null ? t.metadata_popularity.toFixed(1) : '—'} {t.metadata_rating != null ? t.metadata_rating.toFixed(1) : '—'}
) }
Showtime Leaders Now-playing titles by cinema breadth
{showtimeLeaders.length === 0 ?
No showtime data available.
: ( {showtimeLeaders.map((t, i) => ( ))}
Title Cinemas Showtimes
{i + 1}.{' '} {t.title_en} {t.cinema_count} {t.showtime_count}
) }
City Demand Waitlist signups by city
{waitlistHotspots.length === 0 ?
No waitlist signups yet.
: ( {waitlistHotspots.map(w => ( ))}
CitySignups
{w.city_name} {w.demand}
) }
Booking Intent {bookingClicksAvailable ? 'Clicks on booking links (7 days)' : 'Table not yet available'}
{!bookingClicksAvailable ?
Waiting for booking_clicks table.
: bookingClicks.length === 0 ?
No booking clicks recorded in the last 7 days.
: ( {bookingClicks.map(bc => ( ))}
TitleClicks (7d)
{bc.title_en} {bc.clicks}
) }
Title Alert Demand {titleAlertsAvailable ? 'Signups per upcoming title' : 'Table not yet available'}
{!titleAlertsAvailable ?
Waiting for title_alerts table.
: titleAlerts.length === 0 ?
No title alert signups recorded yet.
: ( {titleAlerts.map(ta => ( ))}
TitleSignups
{ta.title_en} {ta.signups}
) }
Scraper Worker Queue
Operational Status
Loading...
Fetching secured /status and /stats
Source Adapter Health — Last Run
{chainHealth.length === 0 &&

No runs recorded yet.

} {chainHealth.map(run => (
{run.status} {run.chain_id}
{run.movies_found} movies · {run.showtimes_found} showtimes
{relativeTime(run.started_at)} took {duration(run.started_at, run.finished_at)} details →
{run.error_message &&
{run.error_message.slice(0, 80)}
}
))}
Recent Runs (last 50)
{recentRuns.length === 0 && ( )} {recentRuns.map(run => ( ))}
# Chain City Status Started Duration Movies Showtimes Error
No runs recorded.
#{run.id} {run.chain_id} {run.city_id ?? '—'} {run.status} {relativeTime(run.started_at)} {duration(run.started_at, run.finished_at)} {run.movies_found ?? 0} {run.showtimes_found ?? 0} {run.error_message ?? ''}