PitchVibe — The AI-Powered Startup Pitch & Founder Discovery Platform

// src/app/actions/submitPitch.ts - Validated Sanity Startup Mutation
"use server";

import { writeClient } from "@/lib/sanity.client";
import { revalidatePath } from "next/cache";
import { z } from "zod";

const pitchSchema = z.object({
  title: z.string().min(5).max(80),
  category: z.enum(["AI / Tech", "E-Commerce", "Health / Wellness", "SaaS", "FinTech"]),
  shortDescription: z.string().min(20).max(200),
  coverImage: z.string().url(),
  pitchMarkdown: z.string().min(50),
  authorId: z.string(),
});

export async function submitStartupPitch(formData: FormData) {
  const rawData = {
    title: formData.get("title") as string,
    category: formData.get("category") as string,
    shortDescription: formData.get("shortDescription") as string,
    coverImage: formData.get("coverImage") as string,
    pitchMarkdown: formData.get("pitchMarkdown") as string,
    authorId: formData.get("authorId") as string,
  };

  const parsed = pitchSchema.parse(rawData);

  // Commit document to Sanity Content Lake
  const newPitch = await writeClient.create({
    _type: "startup",
    title: parsed.title,
    slug: {
      _type: "slug",
      current: parsed.title.toLowerCase().replace(/[^a-z0-9]+/g, "-"),
    },
    category: parsed.category,
    description: parsed.shortDescription,
    image: parsed.coverImage,
    pitch: parsed.pitchMarkdown,
    author: { _type: "reference", _ref: parsed.authorId },
    views: 0,
    upvotes: 0,
    createdAt: new Date().toISOString(),
  });

  revalidatePath("/startup");
  revalidatePath("/");
  return { success: true, slug: newPitch.slug.current };
}

// src/app/actions/vote.ts - Atomic Upvote Handler with Anti-Spam Guard
"use server";

import { writeClient } from "@/lib/sanity.client";
import { revalidateTag } from "next/cache";

export async function upvoteStartup(startupId: string, voterId: string) {
  try {
    // 1. Verify voter hasn't already voted in current cycle (Stored in KV or user votes array)
    const alreadyVoted = await checkExistingVote(startupId, voterId);
    if (alreadyVoted) {
      return { success: false, message: "You have already upvoted this pitch." };
    }

    // 2. Atomic increment on Sanity Document
    await writeClient
      .patch(startupId)
      .inc({ upvotes: 1 })
      .append("voters", [voterId])
      .commit();

    // 3. Invalidate specific startup ISR cache tag
    revalidateTag(`startup-${startupId}`);

    return { success: true };
  } catch (err) {
    console.error("Upvote mutation failed:", err);
    return { success: false, error: "Failed to record upvote." };
  }
}