fix: reconcile sponsor pipeline with content schema field names

Author: Miriad

app/api/cron/sponsor-outreach/route.ts

@@ -35,11 +35,11 @@ export async function POST(request: Request) {
       )
     ] | order(relevanceScore desc) [0...${MAX_PER_RUN - 1}] {
       _id,
-      company,
+      companyName,
       contactName,
       contactEmail,
       website,
-      industry,
+      category,
       relevanceScore,
       optOutToken
     }`
@@ -58,7 +58,7 @@ export async function POST(request: Request) {
       })
     }
 
-    const results: Array<{ company: string; success: boolean; error?: string }> = []
+    const results: Array<{ companyName: string; success: boolean; error?: string }> = []
 
     for (const sponsor of sponsors) {
       try {
@@ -82,36 +82,28 @@ export async function POST(request: Request) {
           // Create a sponsorLead with source='outbound'
           await sanityWriteClient.create({
             _type: 'sponsorLead',
-            company: sponsor.company,
+            companyName: sponsor.companyName,
             contactName: sponsor.contactName,
             contactEmail: sponsor.contactEmail,
             source: 'outbound',
             status: 'contacted',
-            threadHistory: [
-              {
-                _key: crypto.randomUUID(),
-                date: new Date().toISOString(),
-                direction: 'outbound',
-                subject: email.subject,
-                body: email.body,
-              },
-            ],
-            lastContactedAt: new Date().toISOString(),
+            threadId: crypto.randomUUID(),
+            lastEmailAt: new Date().toISOString(),
           })
 
-          results.push({ company: sponsor.company, success: true })
-          console.log(`[SPONSOR] Outreach sent to: ${sponsor.company}`)
+          results.push({ companyName: sponsor.companyName, success: true })
+          console.log(`[SPONSOR] Outreach sent to: ${sponsor.companyName}`)
         } else {
           results.push({
-            company: sponsor.company,
+            companyName: sponsor.companyName,
             success: false,
             error: 'Email send failed',
           })
         }
       } catch (error) {
         const errorMsg = error instanceof Error ? error.message : String(error)
-        console.error(`[SPONSOR] Outreach failed for ${sponsor.company}:`, errorMsg)
-        results.push({ company: sponsor.company, success: false, error: errorMsg })
+        console.error(`[SPONSOR] Outreach failed for ${sponsor.companyName}:`, errorMsg)
+        results.push({ companyName: sponsor.companyName, success: false, error: errorMsg })
       }
     }
 

app/api/sponsor/opt-out/route.ts

@@ -13,12 +13,12 @@ export async function GET(request: Request) {
 
   try {
     // Query Sanity for sponsorPool entry with matching optOutToken
-    const query = '*[_type == "sponsorPool" && optOutToken == $token][0]{ _id, company }'
+    const query = '*[_type == "sponsorPool" && optOutToken == $token][0]{ _id, companyName }'
     const params = { token } as Record<string, string>
     const sponsor = await sanityWriteClient.fetch(
       query,
       params
-    ) as { _id: string; company: string } | null
+    ) as { _id: string; companyName: string } | null
 
     if (!sponsor) {
       console.warn('[SPONSOR] Opt-out: invalid token:', token)
@@ -31,7 +31,7 @@ export async function GET(request: Request) {
     // Set optedOut = true
     await sanityWriteClient.patch(sponsor._id).set({ optedOut: true }).commit()
 
-    console.log('[SPONSOR] Opt-out processed for:', sponsor.company)
+    console.log('[SPONSOR] Opt-out processed for:', sponsor.companyName)
 
     return new Response(
       renderHtml(

app/api/webhooks/sponsor-inbound/route.ts

@@ -62,23 +62,15 @@ export async function POST(request: Request) {
     // Create sponsorLead in Sanity
     const leadDoc = {
       _type: 'sponsorLead',
-      company: intent.company || company || 'Unknown',
+      companyName: intent.companyName || company || 'Unknown',
       contactName: intent.contactName || fullName,
       contactEmail: email,
       source: 'inbound',
       status: 'new',
       intent: intent.intent,
-      selectedTiers: tiers.length > 0 ? tiers : intent.suggestedTiers,
-      threadHistory: [
-        {
-          _key: crypto.randomUUID(),
-          date: new Date().toISOString(),
-          direction: 'inbound',
-          subject: `Sponsorship inquiry from ${fullName}`,
-          body: message || '',
-        },
-      ],
-      lastContactedAt: new Date().toISOString(),
+      rateCard: tiers.length > 0 ? tiers.join(', ') : intent.suggestedTiers.join(', '),
+      threadId: crypto.randomUUID(),
+      lastEmailAt: new Date().toISOString(),
     }
 
     const created = await sanityWriteClient.create(leadDoc)

lib/sanity-write-client.ts

@@ -9,7 +9,7 @@ const SPONSORSHIP_TIERS = [
 ] as const
 
 export interface SponsorIntent {
-  company: string
+  companyName: string
   contactName: string
   intent: string
   suggestedTiers: string[]
@@ -25,7 +25,7 @@ export async function extractSponsorIntent(message: string): Promise<SponsorInte
   if (!apiKey) {
     console.warn('[SPONSOR] GEMINI_API_KEY not set — returning default intent extraction')
     return {
-      company: '',
+      companyName: '',
       contactName: '',
       intent: message.slice(0, 500),
       suggestedTiers: [],
@@ -46,14 +46,14 @@ Available sponsorship tiers:
 - video-series (custom pricing) — Multi-video series partnership
 
 Analyze this message and extract:
-1. company — The company name (if mentioned)
+1. companyName — The company name (if mentioned)
 2. contactName — The contact person's name (if mentioned)
 3. intent — A brief summary of what they want (1-2 sentences)
 4. suggestedTiers — Which tiers seem relevant based on their message (array of tier values from the list above)
 5. urgency — How urgent this seems: "low", "medium", or "high"
 
 Respond ONLY with valid JSON, no markdown formatting:
-{"company": "", "contactName": "", "intent": "", "suggestedTiers": [], "urgency": "medium"}
+{"companyName": "", "contactName": "", "intent": "", "suggestedTiers": [], "urgency": "medium"}
 
 Message to analyze:
 ${message}`
@@ -78,7 +78,7 @@ ${message}`
     }
 
     console.log('[SPONSOR] Gemini intent extraction successful:', {
-      company: parsed.company,
+      companyName: parsed.companyName,
       tiers: parsed.suggestedTiers,
       urgency: parsed.urgency,
     })
@@ -87,7 +87,7 @@ ${message}`
   } catch (error) {
     console.error('[SPONSOR] Gemini intent extraction failed:', error)
     return {
-      company: '',
+      companyName: '',
       contactName: '',
       intent: message.slice(0, 500),
       suggestedTiers: [],

lib/sponsor/gemini-intent.ts

@@ -2,11 +2,11 @@ import { GoogleGenerativeAI } from '@google/generative-ai'
 
 export interface SponsorPoolEntry {
   _id: string
-  company: string
+  companyName: string
   contactName: string
   contactEmail: string
   website?: string
-  industry?: string
+  category?: string
   relevanceScore?: number
   optOutToken?: string
 }
@@ -51,10 +51,10 @@ export async function generateOutreachEmail(
   const prompt = `You are writing a personalized cold outreach email from Alex Patterson, the creator of CodingCat.dev, to a potential sponsor.
 
 Sponsor details:
-- Company: ${sponsor.company}
+- Company: ${sponsor.companyName}
 - Contact: ${sponsor.contactName}
 - Website: ${sponsor.website || 'N/A'}
-- Industry: ${sponsor.industry || 'Technology'}
+- Category: ${sponsor.category || 'Technology'}
 
 Rate card:
 ${rateCard}
@@ -79,7 +79,7 @@ Respond ONLY with valid JSON, no markdown formatting:
     const jsonStr = text.replace(/^\`\`\`json?\n?/i, '').replace(/\n?\`\`\`$/i, '').trim()
     const parsed = JSON.parse(jsonStr) as OutreachEmail
 
-    console.log('[SPONSOR] Gemini outreach email generated for:', sponsor.company)
+    console.log('[SPONSOR] Gemini outreach email generated for:', sponsor.companyName)
     return parsed
   } catch (error) {
     console.error('[SPONSOR] Gemini outreach generation failed:', error)
@@ -93,12 +93,12 @@ function getTemplateEmail(sponsor: SponsorPoolEntry, rateCard: string): Outreach
     : ''
 
   return {
-    subject: `Partnership opportunity with CodingCat.dev — ${sponsor.company}`,
+    subject: `Partnership opportunity with CodingCat.dev — ${sponsor.companyName}`,
     body: `Hi ${sponsor.contactName},
 
 I'm Alex Patterson, creator of CodingCat.dev — a developer education platform reaching 50K+ developers through YouTube, podcasts, and newsletters.
 
-I think ${sponsor.company} would be a great fit for our audience of web developers who are always looking for tools to improve their workflow.
+I think ${sponsor.companyName} would be a great fit for our audience of web developers who are always looking for tools to improve their workflow.
 
 Here are our current sponsorship options:
 

lib/sponsor/gemini-outreach.ts

@@ -7,7 +7,7 @@
 
 export interface SponsorLeadForInvoice {
   _id: string
-  company: string
+  companyName: string
   contactName: string
   contactEmail: string
 }
@@ -34,7 +34,7 @@ export async function createSponsorInvoice(
   // const customer = await stripe.customers.create({
   //   email: lead.contactEmail,
   //   name: lead.contactName,
-  //   metadata: { company: lead.company, sanityLeadId: lead._id },
+  //   metadata: { companyName: lead.companyName, sanityLeadId: lead._id },
   // })
   //
   // // Create invoice
@@ -59,7 +59,7 @@ export async function createSponsorInvoice(
 
   console.log('[SPONSOR] Invoice creation (stubbed):', {
     leadId: lead._id,
-    company: lead.company,
+    company: lead.companyName,
     amount,
     description,
     timestamp: new Date().toISOString(),

lib/sponsor/stripe-service.ts

@@ -43,8 +43,7 @@ import podcastType from "@/sanity/schemas/documents/podcastType";
 import post from "@/sanity/schemas/documents/post";
 import settings from "@/sanity/schemas/singletons/settings";
 import sponsor from "@/sanity/schemas/documents/sponsor";
-import sponsorLead from "@/sanity/schemas/documents/sponsorLead";
-import sponsorPool from "@/sanity/schemas/documents/sponsorPool";
+
 import sponsorshipRequest from "@/sanity/schemas/documents/sponsorshipRequest";
 import youtubeUpdateTask from "@/sanity/schemas/documents/youtubeUpdateTask";
 import { resolveHref } from "@/sanity/lib/utils";
@@ -141,8 +140,6 @@ export default defineConfig({
 			podcastType,
 			post,
 			sponsor,
-			sponsorLead,
-			sponsorPool,
 			youtubeUpdateTask,
 			previewSession,
 			sponsorshipRequest,