feat: implement bulk affiliate link generation in moderation queue

src/features/marketplace/actions/trigger-bulk-marketplace-match.ts

@@ -0,0 +1,56 @@
+'use server';
+
+import { inngest } from '@/inngest/client';
+import { db } from '@/lib/db';
+import { detectedObjects, youtubeVideos, youtubeChannels } from '@/lib/db/schema';
+import { eq, and, inArray } from 'drizzle-orm';
+import { auth } from '@/lib/auth';
+import { headers } from 'next/headers';
+
+export async function triggerBulkMarketplaceMatchAction(detectedObjectIds: string[]) {
+    if (!detectedObjectIds || detectedObjectIds.length === 0) {
+        return { success: false, error: 'No IDs provided' };
+    }
+
+    const session = await auth.api.getSession({
+        headers: await headers(),
+    });
+
+    if (!session?.user?.id) {
+        throw new Error('Unauthorized');
+    }
+
+    const userId = session.user.id;
+    const userEmail = session.user.email;
+    const adminEmails = process.env.ADMIN_EMAILS?.split(',') || [];
+    const isAdmin = adminEmails.includes(userEmail);
+
+    // If not admin, verify object ownership for ALL objects
+    if (!isAdmin) {
+        const result = await db
+            .select({ id: detectedObjects.id })
+            .from(detectedObjects)
+            .innerJoin(youtubeVideos, eq(detectedObjects.videoId, youtubeVideos.id))
+            .innerJoin(youtubeChannels, eq(youtubeVideos.channelId, youtubeChannels.id))
+            .where(
+                and(
+                    inArray(detectedObjects.id, detectedObjectIds),
+                    eq(youtubeChannels.creatorId, userId)
+                )
+            );
+
+        if (result.length !== detectedObjectIds.length) {
+            throw new Error('Some objects not found or access denied');
+        }
+    }
+
+    // Trigger matching in bulk
+    await inngest.send({
+        name: 'discovery/objects.match-marketplace',
+        data: {
+            detectedObjectIds
+        },
+    });
+
+    return { success: true, count: detectedObjectIds.length };
+}

src/features/moderation/components/moderation-queue.tsx

@@ -13,10 +13,11 @@ import { approveDetection } from '../actions/approve-detection';
 import { rejectDetection } from '../actions/reject-detection';
 import { bulkApprove } from '../actions/bulk-approve';
 import { bulkReject } from '../actions/bulk-reject';
+import { triggerBulkMarketplaceMatchAction } from '@/features/marketplace/actions/trigger-bulk-marketplace-match';
 import { resetDetection } from '../actions/edit-detection';
 import { EditDetectionDialog } from './edit-detection-dialog';
 import { AddProductDialog } from './add-product-dialog';
-import { Check, X, ShieldCheck, ShoppingCart, Filter, CheckCircle2, Clock, CheckCircle, ShieldAlert, MousePointerClick, Heart } from 'lucide-react';
+import { Check, X, ShieldCheck, ShoppingCart, Filter, CheckCircle2, Clock, CheckCircle, ShieldAlert, MousePointerClick, Heart, Sparkles } from 'lucide-react';
 import Image from 'next/image';
 
 interface Detection {
@@ -159,6 +160,18 @@ export function ModerationQueue({ initialDetections, userId, videos, stats, init
         });
     };
 
+    const handleBulkGenerateLinks = async () => {
+        startTransition(async () => {
+            const result = await triggerBulkMarketplaceMatchAction(selectedIds);
+            if (result.success) {
+                toast.success(`Generation triggered for ${result.count} items. Results will appear in a few moments.`);
+                setSelectedIds([]);
+            } else {
+                toast.error(result.error || 'Failed to trigger link generation');
+            }
+        });
+    };
+
     const handleReset = async (id: string) => {
         startTransition(async () => {
             const result = await resetDetection(id);
@@ -310,6 +323,9 @@ export function ModerationQueue({ initialDetections, userId, videos, stats, init
                     <Button size="sm" onClick={handleBulkApprove} disabled={isPending}>
                         <Check className="w-4 h-4 mr-1" /> Approve
                     </Button>
+                    <Button size="sm" variant="outline" className="bg-emerald-500/10 hover:bg-emerald-500/20 text-emerald-500 border-none" onClick={handleBulkGenerateLinks} disabled={isPending}>
+                        <Sparkles className="w-4 h-4 mr-1" /> Generate Links
+                    </Button>
                     <Button size="sm" variant="destructive" onClick={handleBulkReject} disabled={isPending}>
                         <X className="w-4 h-4 mr-1" /> Reject
                     </Button>