feat: merge all Phase 1 branches into dev — complete content engine

Merges 5 Phase 1 branches + Phase 0 foundation into dev:
- phase0/complete: Next.js 16, Sanity v5, React 19.2, Supabase, CI
- phase1a/content-pipeline: 4 Sanity schemas (contentIdea, automatedVideo, sponsorLead, sponsorPool)
- phase1b/video-pipeline: ElevenLabs TTS, GCS upload, Pexels B-roll, Remotion Lambda
- phase1c/distribution-pipeline: YouTube uploads, Resend email, Sanity webhook
- phase1d/sponsor-pipeline: Gemini intent extraction, outbound cron, Stripe stub
- phase1e/dashboard: Supabase auth, Content Ops dashboard, video pipeline UI

Post-merge fixes:
- Created shared libs: lib/gemini.ts, lib/sanity-write-client.ts, lib/youtube-upload.ts, lib/resend-notify.ts
- Fixed package.json with correct Phase 0 versions + Phase 1 additions
- Added serverExternalPackages for Remotion/rspack native binaries
- Fixed distribute route notifySubscribers call signature
- Added @supabase/ssr and @supabase/supabase-js dependencies

Build: TypeScript passes (tsc --noEmit), Next.js 16.1.6 webpack compilation succeeds.
Note: Sanity typegen prebuild needs Sanity Studio config fix (separate issue).
Note: middleware.ts deprecated warning — should migrate to proxy pattern.

Co-authored-by: upgrade <upgrade@miriad.systems>

Author: Miriad

app/api/webhooks/sanity-distribute/route.ts

@@ -108,7 +108,7 @@ export async function POST(req: NextRequest): Promise<NextResponse> {
     // Step 4: Email (non-fatal)
     const ytUrl = youtubeVideoId ? `https://www.youtube.com/watch?v=${youtubeVideoId}` : payload.videoUrl || "";
     try {
-      await notifySubscribers({ videoTitle: metadata.title, videoUrl: ytUrl, shortDescription: metadata.description.slice(0, 280), thumbnailUrl: `https://img.youtube.com/vi/${youtubeVideoId}/maxresdefault.jpg` });
+      await notifySubscribers({ subject: `New Video: ${metadata.title}`, videoTitle: metadata.title, videoUrl: ytUrl, description: metadata.description.slice(0, 280) });
     } catch (e) { console.warn("[sanity-distribute] Email error:", e); }
 
     // Step 5: Mark published

lib/gemini.ts

@@ -0,0 +1,14 @@
+import { GoogleGenerativeAI } from "@google/generative-ai";
+
+const genAI = new GoogleGenerativeAI(process.env.GEMINI_API_KEY || "");
+
+/**
+ * Generate text content using Gemini Flash.
+ * Used across the content engine for script generation, metadata, and intent extraction.
+ */
+export async function generateWithGemini(prompt: string): Promise<string> {
+	const model = genAI.getGenerativeModel({ model: "gemini-2.0-flash" });
+	const result = await model.generateContent(prompt);
+	const response = result.response;
+	return response.text();
+}

lib/resend-notify.ts

@@ -0,0 +1,37 @@
+/**
+ * Notify email subscribers about new content via Resend.
+ * Stubbed — requires RESEND_API_KEY to be configured.
+ */
+export async function notifySubscribers(opts: {
+	subject: string;
+	videoTitle: string;
+	videoUrl: string;
+	description: string;
+}): Promise<{ sent: boolean; error?: string }> {
+	const apiKey = process.env.RESEND_API_KEY;
+	if (!apiKey) {
+		console.warn("[resend-notify] RESEND_API_KEY not set — skipping email notification");
+		return { sent: false, error: "RESEND_API_KEY not configured" };
+	}
+
+	try {
+		const { Resend } = await import("resend");
+		const resend = new Resend(apiKey);
+
+		await resend.emails.send({
+			from: "CodingCat.dev <noreply@codingcat.dev>",
+			to: ["subscribers@codingcat.dev"], // TODO: fetch subscriber list
+			subject: opts.subject,
+			html: `
+				<h1>${opts.videoTitle}</h1>
+				<p>${opts.description}</p>
+				<a href="${opts.videoUrl}">Watch Now</a>
+			`,
+		});
+
+		return { sent: true };
+	} catch (error) {
+		console.error("[resend-notify] Failed to send:", error);
+		return { sent: false, error: String(error) };
+	}
+}

lib/sanity-write-client.ts

@@ -0,0 +1,15 @@
+import { createClient } from "next-sanity";
+
+import { apiVersion, dataset, projectId } from "@/sanity/lib/api";
+
+// Server-side Sanity client with write access (uses SANITY_API_TOKEN)
+export const sanityWriteClient = createClient({
+	projectId,
+	dataset,
+	apiVersion,
+	useCdn: false,
+	token: process.env.SANITY_API_TOKEN,
+});
+
+// Alias for compatibility
+export const writeClient = sanityWriteClient;

lib/youtube-upload.ts

@@ -0,0 +1,64 @@
+import { google } from "googleapis";
+
+const oauth2Client = new google.auth.OAuth2(
+	process.env.YOUTUBE_CLIENT_ID,
+	process.env.YOUTUBE_CLIENT_SECRET,
+);
+oauth2Client.setCredentials({
+	refresh_token: process.env.YOUTUBE_REFRESH_TOKEN,
+});
+
+const youtube = google.youtube({ version: "v3", auth: oauth2Client });
+
+/**
+ * Upload a video to YouTube (main channel video, 16:9).
+ */
+export async function uploadVideo(opts: {
+	title: string;
+	description: string;
+	tags: string[];
+	videoUrl: string;
+}): Promise<{ videoId: string; url: string }> {
+	// Fetch the video from GCS URL
+	const response = await fetch(opts.videoUrl);
+	if (!response.ok) throw new Error(`Failed to fetch video: ${response.statusText}`);
+
+	const res = await youtube.videos.insert({
+		part: ["snippet", "status"],
+		requestBody: {
+			snippet: {
+				title: opts.title,
+				description: opts.description,
+				tags: opts.tags,
+				categoryId: "28", // Science & Technology
+			},
+			status: {
+				privacyStatus: "public",
+				selfDeclaredMadeForKids: false,
+			},
+		},
+		media: {
+			body: response.body as unknown as NodeJS.ReadableStream,
+		},
+	});
+
+	const videoId = res.data.id || "";
+	return { videoId, url: `https://youtube.com/watch?v=${videoId}` };
+}
+
+/**
+ * Upload a Short to YouTube (9:16 vertical).
+ */
+export async function uploadShort(opts: {
+	title: string;
+	description: string;
+	tags: string[];
+	videoUrl: string;
+}): Promise<{ videoId: string; url: string }> {
+	// Shorts are just regular uploads with #Shorts in title/description
+	return uploadVideo({
+		...opts,
+		title: `${opts.title} #Shorts`,
+		description: `${opts.description}\n\n#Shorts`,
+	});
+}

next.config.ts

@@ -11,6 +11,13 @@ const nextConfig: NextConfig = {
 			},
 		],
 	},
+	serverExternalPackages: [
+		"@remotion/lambda",
+		"@remotion/bundler",
+		"@remotion/cli",
+		"@rspack/core",
+		"@rspack/binding",
+	],
 };
 
 export default nextConfig;