Enhance Sponsor management with email and bulk operations

__tests__/lib/sponsor/sponsorForConference.test.ts

@@ -4,6 +4,8 @@ import {
   SponsorForConferenceUpdateSchema,
   SponsorTagSchema,
   ImportAllHistoricSponsorsSchema,
+  BulkUpdateSponsorCRMSchema,
+  BulkDeleteSponsorCRMSchema,
 } from '@/server/schemas/sponsorForConference'
 
 describe('SponsorForConferenceInputSchema', () => {
@@ -180,3 +182,53 @@ describe('ImportAllHistoricSponsorsSchema', () => {
     expect(result.success).toBe(false)
   })
 })
+
+describe('BulkUpdateSponsorCRMSchema', () => {
+  it('passes with valid ids and status', () => {
+    const result = BulkUpdateSponsorCRMSchema.safeParse({
+      ids: ['id-1', 'id-2'],
+      status: 'negotiating',
+    })
+    expect(result.success).toBe(true)
+  })
+
+  it('passes with add_tags', () => {
+    const result = BulkUpdateSponsorCRMSchema.safeParse({
+      ids: ['id-1'],
+      add_tags: ['high-priority', 'returning-sponsor'],
+    })
+    expect(result.success).toBe(true)
+  })
+
+  it('fails with empty ids array', () => {
+    const result = BulkUpdateSponsorCRMSchema.safeParse({
+      ids: [],
+      status: 'closed-won',
+    })
+    expect(result.success).toBe(false)
+  })
+
+  it('fails with invalid status', () => {
+    const result = BulkUpdateSponsorCRMSchema.safeParse({
+      ids: ['id-1'],
+      status: 'invalid',
+    })
+    expect(result.success).toBe(false)
+  })
+})
+
+describe('BulkDeleteSponsorCRMSchema', () => {
+  it('passes with valid ids', () => {
+    const result = BulkDeleteSponsorCRMSchema.safeParse({
+      ids: ['id-1', 'id-2'],
+    })
+    expect(result.success).toBe(true)
+  })
+
+  it('fails with empty ids', () => {
+    const result = BulkDeleteSponsorCRMSchema.safeParse({
+      ids: [],
+    })
+    expect(result.success).toBe(false)
+  })
+})

package.json

@@ -58,6 +58,7 @@
     "html2canvas-pro": "^1.6.6",
     "jose": "^6.1.3",
     "jsonld": "^9.0.0",
+    "nanoid": "^5.1.6",
     "next": "^16.1.6",
     "next-auth": "5.0.0-beta.30",
     "next-sanity": "^12.0.15",

src/app/(admin)/admin/api/sponsors/email/send/route.ts

@@ -0,0 +1,92 @@
+import { auth, NextAuthRequest } from '@/lib/auth'
+import {
+  setupEmailRoute,
+  convertPortableTextToHTML,
+  renderEmailTemplate,
+  createEmailSuccessResponse,
+  createEmailErrorResponse,
+} from '@/lib/email/route-helpers'
+import { resend, retryWithBackoff } from '@/lib/email/config'
+import { getSponsor } from '@/lib/sponsor/sanity'
+
+export const POST = auth(async (req: NextAuthRequest) => {
+  try {
+    const body = await req.json()
+    const { sponsorId } = body
+
+    if (!sponsorId) {
+      return createEmailErrorResponse('sponsorId is required', 400)
+    }
+
+    const { context, error } = await setupEmailRoute(req, body, {
+      sponsors: true,
+      sponsorContact: true,
+    })
+
+    if (error) return error
+
+    const { conference, messagePortableText, subject } = context!
+
+    // Fetch sponsor contacts
+    const { sponsor, error: sponsorError } = await getSponsor(sponsorId, true)
+    if (sponsorError || !sponsor) {
+      return createEmailErrorResponse(
+        sponsorError?.message || 'Sponsor not found',
+        404,
+      )
+    }
+
+    const contacts = 'contact_persons' in sponsor ? sponsor.contact_persons : []
+    const recipients = contacts
+      ?.filter((c) => c.email)
+      .map((c) => ({ email: c.email, name: c.name }))
+
+    if (!recipients || recipients.length === 0) {
+      return createEmailErrorResponse(
+        'Sponsor has no contact persons with email addresses',
+        400,
+      )
+    }
+
+    const { htmlContent, error: htmlError } =
+      await convertPortableTextToHTML(messagePortableText)
+    if (htmlError) return htmlError
+
+    const emailTemplate = renderEmailTemplate({
+      conference,
+      subject,
+      htmlContent: htmlContent!,
+    })
+
+    if (!conference.sponsor_email) {
+      return createEmailErrorResponse(
+        'Missing sponsor_email in conference configuration',
+        500,
+      )
+    }
+
+    const result = await retryWithBackoff(async () => {
+      return await resend.emails.send({
+        from: `${conference.organizer || 'Cloud Native Days'} <${conference.sponsor_email}>`,
+        to: recipients.map((r) => r.email),
+        subject,
+        react: emailTemplate,
+      })
+    })
+
+    if (result.error) {
+      return createEmailErrorResponse(result.error.message, 500)
+    }
+
+    return createEmailSuccessResponse({
+      emailId: result.data?.id,
+      recipientCount: recipients.length,
+    })
+  } catch (err) {
+    console.error('[SponsorIndividualEmail] Unexpected error:', err)
+    return createEmailErrorResponse(
+      err instanceof Error ? err.message : 'Failed to send email',
+      500,
+    )
+  }
+})