feat: Implement admin management for product requests and affiliate proposals, including new database migrations and expanded dashboard statistics.

diagnose-api-simple.ts

@@ -1,47 +0,0 @@
-
-import * as dotenv from 'dotenv';
-dotenv.config();
-
-async function diagnose() {
-    const videoId = '6RDECCcWiQA';
-    const apiKey = process.env.GOOGLE_GENERATIVE_AI_API_KEY;
-    console.log('--- Diagnosing YouTube API for:', videoId, '---');
-    console.log('API Key exists:', !!apiKey);
-
-    if (!apiKey) {
-        console.error('No API key found');
-        process.exit(1);
-    }
-
-    try {
-        console.log('Fetching video snippet...');
-        const videoApiRes = await fetch(`https://www.googleapis.com/youtube/v3/videos?part=snippet&id=${videoId}&key=${apiKey}`);
-        const videoApiData = await videoApiRes.json() as any;
-        console.log('Video API Items count:', videoApiData.items?.length);
-
-        if (videoApiData.items?.[0]) {
-            const channelId = videoApiData.items[0].snippet.channelId;
-            console.log('Channel ID found:', channelId);
-
-            console.log('Fetching channel stats...');
-            const channelApiRes = await fetch(`https://www.googleapis.com/youtube/v3/channels?part=snippet,statistics&id=${channelId}&key=${apiKey}`);
-            const channelApiData = await channelApiRes.json() as any;
-
-            if (channelApiData.items?.[0]) {
-                const stats = channelApiData.items[0].statistics;
-                console.log('Channel Stats:', JSON.stringify(stats, null, 2));
-                console.log('Subscriber Count:', stats.subscriberCount);
-            } else {
-                console.log('No channel items found. Data:', JSON.stringify(channelApiData, null, 2));
-            }
-        } else {
-            console.log('No video items found. Data:', JSON.stringify(videoApiData, null, 2));
-        }
-    } catch (err) {
-        console.error('Fetch Error:', err);
-    }
-
-    process.exit(0);
-}
-
-diagnose();

diagnose-oembed.ts

@@ -1,21 +0,0 @@
-
-import { ShowcaseService } from './src/features/vault/services/showcase.service';
-import * as dotenv from 'dotenv';
-dotenv.config();
-
-async function diagnose() {
-    const videoId = '6RDECCcWiQA';
-    console.log('--- Diagnosing getOEmbedData for:', videoId, '---');
-
-    // Access the private method for testing
-    const data = await (ShowcaseService as any).getOEmbedData(videoId);
-
-    console.log('Result:', JSON.stringify(data, null, 2));
-
-    process.exit(0);
-}
-
-diagnose().catch(err => {
-    console.error(err);
-    process.exit(1);
-});

drizzle/0016_futuristic_skrulls.sql

@@ -0,0 +1,22 @@
+CREATE TABLE "analysis_notifications" (
+	"id" text PRIMARY KEY NOT NULL,
+	"video_id" text NOT NULL,
+	"email_hash" text NOT NULL,
+	"email_encrypted" text NOT NULL,
+	"status" text DEFAULT 'PENDING' NOT NULL,
+	"unsubscribe_token" text NOT NULL,
+	"created_at" timestamp (3) with time zone DEFAULT now() NOT NULL,
+	"updated_at" timestamp (3) with time zone DEFAULT now() NOT NULL
+);
+--> statement-breakpoint
+ALTER TABLE "video_scan_jobs" ALTER COLUMN "status" SET DATA TYPE text;--> statement-breakpoint
+ALTER TABLE "video_scan_jobs" ALTER COLUMN "status" SET DEFAULT 'pending'::text;--> statement-breakpoint
+ALTER TABLE "youtube_videos" ALTER COLUMN "scan_status" SET DATA TYPE text;--> statement-breakpoint
+ALTER TABLE "youtube_videos" ALTER COLUMN "scan_status" SET DEFAULT 'pending'::text;--> statement-breakpoint
+DROP TYPE "public"."video_scan_status";--> statement-breakpoint
+CREATE TYPE "public"."video_scan_status" AS ENUM('pending_analysis', 'in_progress', 'awaiting_approval', 'completed', 'failed', 'idle', 'pending');--> statement-breakpoint
+ALTER TABLE "video_scan_jobs" ALTER COLUMN "status" SET DEFAULT 'pending'::"public"."video_scan_status";--> statement-breakpoint
+ALTER TABLE "video_scan_jobs" ALTER COLUMN "status" SET DATA TYPE "public"."video_scan_status" USING "status"::"public"."video_scan_status";--> statement-breakpoint
+ALTER TABLE "youtube_videos" ALTER COLUMN "scan_status" SET DEFAULT 'pending'::"public"."video_scan_status";--> statement-breakpoint
+ALTER TABLE "youtube_videos" ALTER COLUMN "scan_status" SET DATA TYPE "public"."video_scan_status" USING "scan_status"::"public"."video_scan_status";--> statement-breakpoint
+ALTER TABLE "analysis_notifications" ADD CONSTRAINT "analysis_notifications_video_id_youtube_videos_id_fk" FOREIGN KEY ("video_id") REFERENCES "public"."youtube_videos"("id") ON DELETE cascade ON UPDATE no action;

drizzle/meta/0016_snapshot.json

@@ -0,0 +1,2165 @@
+{
+  "id": "dd255094-b338-48a4-a1c5-2d69e82dfb8f",
+  "prevId": "2c5eb6dc-754a-47f3-bf8b-6c37e56fa9c7",
+  "version": "7",
+  "dialect": "postgresql",
+  "tables": {
+    "public.account": {
+      "name": "account",
+      "schema": "",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "text",
+          "primaryKey": true,
+          "notNull": true
+        },
+        "account_id": {
+          "name": "account_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "provider_id": {
+          "name": "provider_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "user_id": {
+          "name": "user_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "access_token": {
+          "name": "access_token",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "refresh_token": {
+          "name": "refresh_token",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "id_token": {
+          "name": "id_token",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "access_token_expires_at": {
+          "name": "access_token_expires_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "refresh_token_expires_at": {
+          "name": "refresh_token_expires_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "scope": {
+          "name": "scope",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "password": {
+          "name": "password",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "created_at": {
+          "name": "created_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "updated_at": {
+          "name": "updated_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": true
+        }
+      },
+      "indexes": {},
+      "foreignKeys": {
+        "account_user_id_users_id_fk": {
+          "name": "account_user_id_users_id_fk",
+          "tableFrom": "account",
+          "tableTo": "users",
+          "columnsFrom": [
+            "user_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "no action",
+          "onUpdate": "no action"
+        }
+      },
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {},
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.admin_moderation": {
+      "name": "admin_moderation",
+      "schema": "",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "text",
+          "primaryKey": true,
+          "notNull": true
+        },
+        "detection_id": {
+          "name": "detection_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "admin_id": {
+          "name": "admin_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "action": {
+          "name": "action",
+          "type": "admin_moderation_type",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "reason_code": {
+          "name": "reason_code",
+          "type": "reason_code",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "original_values": {
+          "name": "original_values",
+          "type": "jsonb",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "corrected_values": {
+          "name": "corrected_values",
+          "type": "jsonb",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "train_ai_flag": {
+          "name": "train_ai_flag",
+          "type": "boolean",
+          "primaryKey": false,
+          "notNull": true,
+          "default": true
+        },
+        "created_at": {
+          "name": "created_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "updated_at": {
+          "name": "updated_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        }
+      },
+      "indexes": {},
+      "foreignKeys": {
+        "admin_moderation_detection_id_detected_objects_id_fk": {
+          "name": "admin_moderation_detection_id_detected_objects_id_fk",
+          "tableFrom": "admin_moderation",
+          "tableTo": "detected_objects",
+          "columnsFrom": [
+            "detection_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "cascade",
+          "onUpdate": "no action"
+        },
+        "admin_moderation_admin_id_users_id_fk": {
+          "name": "admin_moderation_admin_id_users_id_fk",
+          "tableFrom": "admin_moderation",
+          "tableTo": "users",
+          "columnsFrom": [
+            "admin_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "no action",
+          "onUpdate": "no action"
+        }
+      },
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {},
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.affiliate_proposals": {
+      "name": "affiliate_proposals",
+      "schema": "",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "text",
+          "primaryKey": true,
+          "notNull": true
+        },
+        "object_id": {
+          "name": "object_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "video_id": {
+          "name": "video_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "creator_id": {
+          "name": "creator_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "submitter_name": {
+          "name": "submitter_name",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "submitter_email": {
+          "name": "submitter_email",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "product_url": {
+          "name": "product_url",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "affiliate_url": {
+          "name": "affiliate_url",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "product_name": {
+          "name": "product_name",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "price": {
+          "name": "price",
+          "type": "real",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "image_url": {
+          "name": "image_url",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "note": {
+          "name": "note",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "status": {
+          "name": "status",
+          "type": "affiliate_submission_status",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "'PENDING'"
+        },
+        "created_at": {
+          "name": "created_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "updated_at": {
+          "name": "updated_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        }
+      },
+      "indexes": {},
+      "foreignKeys": {
+        "affiliate_proposals_object_id_detected_objects_id_fk": {
+          "name": "affiliate_proposals_object_id_detected_objects_id_fk",
+          "tableFrom": "affiliate_proposals",
+          "tableTo": "detected_objects",
+          "columnsFrom": [
+            "object_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "set null",
+          "onUpdate": "no action"
+        },
+        "affiliate_proposals_video_id_youtube_videos_id_fk": {
+          "name": "affiliate_proposals_video_id_youtube_videos_id_fk",
+          "tableFrom": "affiliate_proposals",
+          "tableTo": "youtube_videos",
+          "columnsFrom": [
+            "video_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "cascade",
+          "onUpdate": "no action"
+        },
+        "affiliate_proposals_creator_id_users_id_fk": {
+          "name": "affiliate_proposals_creator_id_users_id_fk",
+          "tableFrom": "affiliate_proposals",
+          "tableTo": "users",
+          "columnsFrom": [
+            "creator_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "no action",
+          "onUpdate": "no action"
+        }
+      },
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {},
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.affiliate_revenue": {
+      "name": "affiliate_revenue",
+      "schema": "",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "text",
+          "primaryKey": true,
+          "notNull": true
+        },
+        "marketplace_match_id": {
+          "name": "marketplace_match_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "amount": {
+          "name": "amount",
+          "type": "real",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "recorded_at": {
+          "name": "recorded_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "order_id": {
+          "name": "order_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "created_at": {
+          "name": "created_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "updated_at": {
+          "name": "updated_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        }
+      },
+      "indexes": {
+        "affiliate_revenue_marketplace_match_id_idx": {
+          "name": "affiliate_revenue_marketplace_match_id_idx",
+          "columns": [
+            {
+              "expression": "marketplace_match_id",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": false,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        },
+        "affiliate_revenue_recorded_at_idx": {
+          "name": "affiliate_revenue_recorded_at_idx",
+          "columns": [
+            {
+              "expression": "recorded_at",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": false,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        }
+      },
+      "foreignKeys": {
+        "affiliate_revenue_marketplace_match_id_marketplace_matches_id_fk": {
+          "name": "affiliate_revenue_marketplace_match_id_marketplace_matches_id_fk",
+          "tableFrom": "affiliate_revenue",
+          "tableTo": "marketplace_matches",
+          "columnsFrom": [
+            "marketplace_match_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "cascade",
+          "onUpdate": "no action"
+        }
+      },
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {},
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.analysis_notifications": {
+      "name": "analysis_notifications",
+      "schema": "",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "text",
+          "primaryKey": true,
+          "notNull": true
+        },
+        "video_id": {
+          "name": "video_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "email_hash": {
+          "name": "email_hash",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "email_encrypted": {
+          "name": "email_encrypted",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "status": {
+          "name": "status",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "'PENDING'"
+        },
+        "unsubscribe_token": {
+          "name": "unsubscribe_token",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "created_at": {
+          "name": "created_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "updated_at": {
+          "name": "updated_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        }
+      },
+      "indexes": {},
+      "foreignKeys": {
+        "analysis_notifications_video_id_youtube_videos_id_fk": {
+          "name": "analysis_notifications_video_id_youtube_videos_id_fk",
+          "tableFrom": "analysis_notifications",
+          "tableTo": "youtube_videos",
+          "columnsFrom": [
+            "video_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "cascade",
+          "onUpdate": "no action"
+        }
+      },
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {},
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.bounty_pledges": {
+      "name": "bounty_pledges",
+      "schema": "",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "text",
+          "primaryKey": true,
+          "notNull": true
+        },
+        "product_id": {
+          "name": "product_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "marketplace_match_id": {
+          "name": "marketplace_match_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "email_hash": {
+          "name": "email_hash",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "encrypted_email": {
+          "name": "encrypted_email",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "pledge_amount": {
+          "name": "pledge_amount",
+          "type": "real",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "currency": {
+          "name": "currency",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "'USD'"
+        },
+        "status": {
+          "name": "status",
+          "type": "bounty_pledge_status",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "'ACTIVE'"
+        },
+        "consent_timestamp": {
+          "name": "consent_timestamp",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "consent_ip": {
+          "name": "consent_ip",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "unsubscribe_token": {
+          "name": "unsubscribe_token",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "notified_at": {
+          "name": "notified_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "created_at": {
+          "name": "created_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "updated_at": {
+          "name": "updated_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        }
+      },
+      "indexes": {
+        "bounty_pledges_product_id_idx": {
+          "name": "bounty_pledges_product_id_idx",
+          "columns": [
+            {
+              "expression": "product_id",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": false,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        },
+        "bounty_pledges_status_idx": {
+          "name": "bounty_pledges_status_idx",
+          "columns": [
+            {
+              "expression": "status",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": false,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        },
+        "bounty_pledges_email_hash_idx": {
+          "name": "bounty_pledges_email_hash_idx",
+          "columns": [
+            {
+              "expression": "email_hash",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": false,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        }
+      },
+      "foreignKeys": {
+        "bounty_pledges_marketplace_match_id_marketplace_matches_id_fk": {
+          "name": "bounty_pledges_marketplace_match_id_marketplace_matches_id_fk",
+          "tableFrom": "bounty_pledges",
+          "tableTo": "marketplace_matches",
+          "columnsFrom": [
+            "marketplace_match_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "cascade",
+          "onUpdate": "no action"
+        }
+      },
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {},
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.detected_objects": {
+      "name": "detected_objects",
+      "schema": "",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "text",
+          "primaryKey": true,
+          "notNull": true
+        },
+        "video_id": {
+          "name": "video_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "object_name": {
+          "name": "object_name",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "category": {
+          "name": "category",
+          "type": "object_category",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "confidence_score": {
+          "name": "confidence_score",
+          "type": "real",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "frame_timestamp": {
+          "name": "frame_timestamp",
+          "type": "integer",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "detection_metadata": {
+          "name": "detection_metadata",
+          "type": "jsonb",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "thumbnail_url": {
+          "name": "thumbnail_url",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "status": {
+          "name": "status",
+          "type": "detection_status",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "'pending_review'"
+        },
+        "moderation_status": {
+          "name": "moderation_status",
+          "type": "moderation_status",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "'PENDING'"
+        },
+        "moderated_at": {
+          "name": "moderated_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "moderated_by": {
+          "name": "moderated_by",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "moderation_metadata": {
+          "name": "moderation_metadata",
+          "type": "jsonb",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "created_at": {
+          "name": "created_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "updated_at": {
+          "name": "updated_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        }
+      },
+      "indexes": {},
+      "foreignKeys": {
+        "detected_objects_video_id_youtube_videos_id_fk": {
+          "name": "detected_objects_video_id_youtube_videos_id_fk",
+          "tableFrom": "detected_objects",
+          "tableTo": "youtube_videos",
+          "columnsFrom": [
+            "video_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "cascade",
+          "onUpdate": "no action"
+        },
+        "detected_objects_moderated_by_users_id_fk": {
+          "name": "detected_objects_moderated_by_users_id_fk",
+          "tableFrom": "detected_objects",
+          "tableTo": "users",
+          "columnsFrom": [
+            "moderated_by"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "no action",
+          "onUpdate": "no action"
+        }
+      },
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {},
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.interest_pledges": {
+      "name": "interest_pledges",
+      "schema": "",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "text",
+          "primaryKey": true,
+          "notNull": true
+        },
+        "marketplace_match_id": {
+          "name": "marketplace_match_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "detected_object_id": {
+          "name": "detected_object_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "email_hash": {
+          "name": "email_hash",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "email_encrypted": {
+          "name": "email_encrypted",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "status": {
+          "name": "status",
+          "type": "interest_pledge_status",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "'ACTIVE'"
+        },
+        "consent_timestamp": {
+          "name": "consent_timestamp",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "consent_ip": {
+          "name": "consent_ip",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "unsubscribe_token": {
+          "name": "unsubscribe_token",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "consent_metadata": {
+          "name": "consent_metadata",
+          "type": "jsonb",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "notified_at": {
+          "name": "notified_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "created_at": {
+          "name": "created_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "updated_at": {
+          "name": "updated_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        }
+      },
+      "indexes": {
+        "interest_pledges_marketplace_match_id_idx": {
+          "name": "interest_pledges_marketplace_match_id_idx",
+          "columns": [
+            {
+              "expression": "marketplace_match_id",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": false,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        },
+        "interest_pledges_detected_object_id_idx": {
+          "name": "interest_pledges_detected_object_id_idx",
+          "columns": [
+            {
+              "expression": "detected_object_id",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": false,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        },
+        "interest_pledges_unsubscribe_token_idx": {
+          "name": "interest_pledges_unsubscribe_token_idx",
+          "columns": [
+            {
+              "expression": "unsubscribe_token",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": true,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        }
+      },
+      "foreignKeys": {
+        "interest_pledges_marketplace_match_id_marketplace_matches_id_fk": {
+          "name": "interest_pledges_marketplace_match_id_marketplace_matches_id_fk",
+          "tableFrom": "interest_pledges",
+          "tableTo": "marketplace_matches",
+          "columnsFrom": [
+            "marketplace_match_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "cascade",
+          "onUpdate": "no action"
+        },
+        "interest_pledges_detected_object_id_detected_objects_id_fk": {
+          "name": "interest_pledges_detected_object_id_detected_objects_id_fk",
+          "tableFrom": "interest_pledges",
+          "tableTo": "detected_objects",
+          "columnsFrom": [
+            "detected_object_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "cascade",
+          "onUpdate": "no action"
+        }
+      },
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {},
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.marketplace_matches": {
+      "name": "marketplace_matches",
+      "schema": "",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "text",
+          "primaryKey": true,
+          "notNull": true
+        },
+        "object_id": {
+          "name": "object_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "marketplace": {
+          "name": "marketplace",
+          "type": "marketplace_type",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "product_id": {
+          "name": "product_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "product_name": {
+          "name": "product_name",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "price": {
+          "name": "price",
+          "type": "real",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "availability_status": {
+          "name": "availability_status",
+          "type": "availability_status",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "affiliate_url": {
+          "name": "affiliate_url",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "image_url": {
+          "name": "image_url",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "link_status": {
+          "name": "link_status",
+          "type": "link_status",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "'ACTIVE'"
+        },
+        "last_checked_at": {
+          "name": "last_checked_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "check_attempts": {
+          "name": "check_attempts",
+          "type": "integer",
+          "primaryKey": false,
+          "notNull": true,
+          "default": 0
+        },
+        "check_metadata": {
+          "name": "check_metadata",
+          "type": "jsonb",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "matched_at": {
+          "name": "matched_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "created_at": {
+          "name": "created_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "updated_at": {
+          "name": "updated_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        }
+      },
+      "indexes": {
+        "marketplace_matches_link_status_idx": {
+          "name": "marketplace_matches_link_status_idx",
+          "columns": [
+            {
+              "expression": "link_status",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": false,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        },
+        "marketplace_matches_last_checked_at_idx": {
+          "name": "marketplace_matches_last_checked_at_idx",
+          "columns": [
+            {
+              "expression": "last_checked_at",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": false,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        }
+      },
+      "foreignKeys": {
+        "marketplace_matches_object_id_detected_objects_id_fk": {
+          "name": "marketplace_matches_object_id_detected_objects_id_fk",
+          "tableFrom": "marketplace_matches",
+          "tableTo": "detected_objects",
+          "columnsFrom": [
+            "object_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "cascade",
+          "onUpdate": "no action"
+        }
+      },
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {},
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.product_clicks": {
+      "name": "product_clicks",
+      "schema": "",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "text",
+          "primaryKey": true,
+          "notNull": true
+        },
+        "marketplace_match_id": {
+          "name": "marketplace_match_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "clicked_at": {
+          "name": "clicked_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "viewer_ip": {
+          "name": "viewer_ip",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "user_agent": {
+          "name": "user_agent",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "referrer": {
+          "name": "referrer",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "created_at": {
+          "name": "created_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "updated_at": {
+          "name": "updated_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        }
+      },
+      "indexes": {
+        "product_clicks_marketplace_match_id_idx": {
+          "name": "product_clicks_marketplace_match_id_idx",
+          "columns": [
+            {
+              "expression": "marketplace_match_id",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": false,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        },
+        "product_clicks_clicked_at_idx": {
+          "name": "product_clicks_clicked_at_idx",
+          "columns": [
+            {
+              "expression": "clicked_at",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": false,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        }
+      },
+      "foreignKeys": {
+        "product_clicks_marketplace_match_id_marketplace_matches_id_fk": {
+          "name": "product_clicks_marketplace_match_id_marketplace_matches_id_fk",
+          "tableFrom": "product_clicks",
+          "tableTo": "marketplace_matches",
+          "columnsFrom": [
+            "marketplace_match_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "cascade",
+          "onUpdate": "no action"
+        }
+      },
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {},
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.product_requests": {
+      "name": "product_requests",
+      "schema": "",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "text",
+          "primaryKey": true,
+          "notNull": true
+        },
+        "video_id": {
+          "name": "video_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "creator_id": {
+          "name": "creator_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "viewer_name": {
+          "name": "viewer_name",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "viewer_email": {
+          "name": "viewer_email",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "note": {
+          "name": "note",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "image_url": {
+          "name": "image_url",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "frame_timestamp": {
+          "name": "frame_timestamp",
+          "type": "integer",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "status": {
+          "name": "status",
+          "type": "request_status",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "'PENDING'"
+        },
+        "created_at": {
+          "name": "created_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "updated_at": {
+          "name": "updated_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        }
+      },
+      "indexes": {},
+      "foreignKeys": {
+        "product_requests_video_id_youtube_videos_id_fk": {
+          "name": "product_requests_video_id_youtube_videos_id_fk",
+          "tableFrom": "product_requests",
+          "tableTo": "youtube_videos",
+          "columnsFrom": [
+            "video_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "cascade",
+          "onUpdate": "no action"
+        },
+        "product_requests_creator_id_users_id_fk": {
+          "name": "product_requests_creator_id_users_id_fk",
+          "tableFrom": "product_requests",
+          "tableTo": "users",
+          "columnsFrom": [
+            "creator_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "no action",
+          "onUpdate": "no action"
+        }
+      },
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {},
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.session": {
+      "name": "session",
+      "schema": "",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "text",
+          "primaryKey": true,
+          "notNull": true
+        },
+        "expires_at": {
+          "name": "expires_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "token": {
+          "name": "token",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "created_at": {
+          "name": "created_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "updated_at": {
+          "name": "updated_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "ip_address": {
+          "name": "ip_address",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "user_agent": {
+          "name": "user_agent",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "user_id": {
+          "name": "user_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        }
+      },
+      "indexes": {},
+      "foreignKeys": {
+        "session_user_id_users_id_fk": {
+          "name": "session_user_id_users_id_fk",
+          "tableFrom": "session",
+          "tableTo": "users",
+          "columnsFrom": [
+            "user_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "no action",
+          "onUpdate": "no action"
+        }
+      },
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {
+        "session_token_unique": {
+          "name": "session_token_unique",
+          "nullsNotDistinct": false,
+          "columns": [
+            "token"
+          ]
+        }
+      },
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.users": {
+      "name": "users",
+      "schema": "",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "text",
+          "primaryKey": true,
+          "notNull": true
+        },
+        "name": {
+          "name": "name",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "email": {
+          "name": "email",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "email_verified": {
+          "name": "email_verified",
+          "type": "boolean",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "image": {
+          "name": "image",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "created_at": {
+          "name": "created_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "updated_at": {
+          "name": "updated_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": true
+        }
+      },
+      "indexes": {},
+      "foreignKeys": {},
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {
+        "users_email_unique": {
+          "name": "users_email_unique",
+          "nullsNotDistinct": false,
+          "columns": [
+            "email"
+          ]
+        }
+      },
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.verification": {
+      "name": "verification",
+      "schema": "",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "text",
+          "primaryKey": true,
+          "notNull": true
+        },
+        "identifier": {
+          "name": "identifier",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "value": {
+          "name": "value",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "expires_at": {
+          "name": "expires_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "created_at": {
+          "name": "created_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "updated_at": {
+          "name": "updated_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": false
+        }
+      },
+      "indexes": {},
+      "foreignKeys": {},
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {},
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.video_scan_jobs": {
+      "name": "video_scan_jobs",
+      "schema": "",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "text",
+          "primaryKey": true,
+          "notNull": true
+        },
+        "channel_id": {
+          "name": "channel_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "user_id": {
+          "name": "user_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "status": {
+          "name": "status",
+          "type": "video_scan_status",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "'pending'"
+        },
+        "progress": {
+          "name": "progress",
+          "type": "integer",
+          "primaryKey": false,
+          "notNull": true,
+          "default": 0
+        },
+        "total_videos": {
+          "name": "total_videos",
+          "type": "integer",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "scanned_videos": {
+          "name": "scanned_videos",
+          "type": "integer",
+          "primaryKey": false,
+          "notNull": true,
+          "default": 0
+        },
+        "error_message": {
+          "name": "error_message",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "inngest_run_id": {
+          "name": "inngest_run_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "created_at": {
+          "name": "created_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "updated_at": {
+          "name": "updated_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        }
+      },
+      "indexes": {},
+      "foreignKeys": {
+        "video_scan_jobs_channel_id_youtube_channels_id_fk": {
+          "name": "video_scan_jobs_channel_id_youtube_channels_id_fk",
+          "tableFrom": "video_scan_jobs",
+          "tableTo": "youtube_channels",
+          "columnsFrom": [
+            "channel_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "cascade",
+          "onUpdate": "no action"
+        },
+        "video_scan_jobs_user_id_users_id_fk": {
+          "name": "video_scan_jobs_user_id_users_id_fk",
+          "tableFrom": "video_scan_jobs",
+          "tableTo": "users",
+          "columnsFrom": [
+            "user_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "no action",
+          "onUpdate": "no action"
+        }
+      },
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {},
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.youtube_channels": {
+      "name": "youtube_channels",
+      "schema": "",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "text",
+          "primaryKey": true,
+          "notNull": true
+        },
+        "creator_id": {
+          "name": "creator_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "channel_id": {
+          "name": "channel_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "channel_name": {
+          "name": "channel_name",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "creator_slug": {
+          "name": "creator_slug",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "subscriber_count": {
+          "name": "subscriber_count",
+          "type": "integer",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "thumbnail_url": {
+          "name": "thumbnail_url",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "connected_at": {
+          "name": "connected_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "sync_status": {
+          "name": "sync_status",
+          "type": "sync_status",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "'idle'"
+        },
+        "channel_type": {
+          "name": "channel_type",
+          "type": "channel_type",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "'external'"
+        },
+        "platform": {
+          "name": "platform",
+          "type": "platform",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "'youtube'"
+        }
+      },
+      "indexes": {
+        "creator_channel_idx": {
+          "name": "creator_channel_idx",
+          "columns": [
+            {
+              "expression": "creator_id",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            },
+            {
+              "expression": "channel_id",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": true,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        }
+      },
+      "foreignKeys": {
+        "youtube_channels_creator_id_users_id_fk": {
+          "name": "youtube_channels_creator_id_users_id_fk",
+          "tableFrom": "youtube_channels",
+          "tableTo": "users",
+          "columnsFrom": [
+            "creator_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "no action",
+          "onUpdate": "no action"
+        }
+      },
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {
+        "youtube_channels_creator_slug_unique": {
+          "name": "youtube_channels_creator_slug_unique",
+          "nullsNotDistinct": false,
+          "columns": [
+            "creator_slug"
+          ]
+        }
+      },
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.youtube_videos": {
+      "name": "youtube_videos",
+      "schema": "",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "text",
+          "primaryKey": true,
+          "notNull": true
+        },
+        "channel_id": {
+          "name": "channel_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "video_id": {
+          "name": "video_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "title": {
+          "name": "title",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "description": {
+          "name": "description",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "thumbnail_url": {
+          "name": "thumbnail_url",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "duration": {
+          "name": "duration",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "view_count": {
+          "name": "view_count",
+          "type": "integer",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "availability_status": {
+          "name": "availability_status",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "'unknown'"
+        },
+        "scan_status": {
+          "name": "scan_status",
+          "type": "video_scan_status",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "'pending'"
+        },
+        "published_at": {
+          "name": "published_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "platform": {
+          "name": "platform",
+          "type": "platform",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "'youtube'"
+        },
+        "url": {
+          "name": "url",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "width": {
+          "name": "width",
+          "type": "integer",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "height": {
+          "name": "height",
+          "type": "integer",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "is_in_workbench": {
+          "name": "is_in_workbench",
+          "type": "boolean",
+          "primaryKey": false,
+          "notNull": true,
+          "default": true
+        },
+        "created_at": {
+          "name": "created_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "updated_at": {
+          "name": "updated_at",
+          "type": "timestamp (3) with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        }
+      },
+      "indexes": {
+        "channel_video_idx": {
+          "name": "channel_video_idx",
+          "columns": [
+            {
+              "expression": "channel_id",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            },
+            {
+              "expression": "video_id",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": true,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        }
+      },
+      "foreignKeys": {
+        "youtube_videos_channel_id_youtube_channels_id_fk": {
+          "name": "youtube_videos_channel_id_youtube_channels_id_fk",
+          "tableFrom": "youtube_videos",
+          "tableTo": "youtube_channels",
+          "columnsFrom": [
+            "channel_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "cascade",
+          "onUpdate": "no action"
+        }
+      },
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {},
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    }
+  },
+  "enums": {
+    "public.admin_moderation_type": {
+      "name": "admin_moderation_type",
+      "schema": "public",
+      "values": [
+        "corrected",
+        "marked_incorrect"
+      ]
+    },
+    "public.affiliate_submission_status": {
+      "name": "affiliate_submission_status",
+      "schema": "public",
+      "values": [
+        "PENDING",
+        "APPROVED",
+        "REJECTED"
+      ]
+    },
+    "public.availability_status": {
+      "name": "availability_status",
+      "schema": "public",
+      "values": [
+        "IN_STOCK",
+        "SOLD_OUT",
+        "DISCONTINUED"
+      ]
+    },
+    "public.bounty_pledge_status": {
+      "name": "bounty_pledge_status",
+      "schema": "public",
+      "values": [
+        "ACTIVE",
+        "WITHDRAWN",
+        "FULFILLED"
+      ]
+    },
+    "public.channel_type": {
+      "name": "channel_type",
+      "schema": "public",
+      "values": [
+        "verified",
+        "external"
+      ]
+    },
+    "public.detection_status": {
+      "name": "detection_status",
+      "schema": "public",
+      "values": [
+        "pending_review",
+        "approved",
+        "rejected",
+        "flagged"
+      ]
+    },
+    "public.interest_pledge_status": {
+      "name": "interest_pledge_status",
+      "schema": "public",
+      "values": [
+        "ACTIVE",
+        "NOTIFIED",
+        "EXPIRED"
+      ]
+    },
+    "public.link_status": {
+      "name": "link_status",
+      "schema": "public",
+      "values": [
+        "ACTIVE",
+        "CHECKING",
+        "BROKEN"
+      ]
+    },
+    "public.marketplace_type": {
+      "name": "marketplace_type",
+      "schema": "public",
+      "values": [
+        "amazon",
+        "ebay",
+        "etsy"
+      ]
+    },
+    "public.moderation_status": {
+      "name": "moderation_status",
+      "schema": "public",
+      "values": [
+        "PENDING",
+        "APPROVED",
+        "REJECTED"
+      ]
+    },
+    "public.object_category": {
+      "name": "object_category",
+      "schema": "public",
+      "values": [
+        "Tech",
+        "Fashion",
+        "Furniture",
+        "Audio",
+        "Other",
+        "Person",
+        "Apparel"
+      ]
+    },
+    "public.platform": {
+      "name": "platform",
+      "schema": "public",
+      "values": [
+        "youtube",
+        "instagram",
+        "tiktok",
+        "facebook"
+      ]
+    },
+    "public.reason_code": {
+      "name": "reason_code",
+      "schema": "public",
+      "values": [
+        "wrong_object",
+        "wrong_category",
+        "false_positive",
+        "unclear_image",
+        "duplicate",
+        "out_of_scope"
+      ]
+    },
+    "public.request_status": {
+      "name": "request_status",
+      "schema": "public",
+      "values": [
+        "PENDING",
+        "FULFILLED",
+        "DISMISSED"
+      ]
+    },
+    "public.sync_status": {
+      "name": "sync_status",
+      "schema": "public",
+      "values": [
+        "idle",
+        "syncing",
+        "errored"
+      ]
+    },
+    "public.video_scan_status": {
+      "name": "video_scan_status",
+      "schema": "public",
+      "values": [
+        "pending_analysis",
+        "in_progress",
+        "awaiting_approval",
+        "completed",
+        "failed",
+        "idle",
+        "pending"
+      ]
+    }
+  },
+  "schemas": {},
+  "sequences": {},
+  "roles": {},
+  "policies": {},
+  "views": {},
+  "_meta": {
+    "columns": {},
+    "schemas": {},
+    "tables": {}
+  }
+}

drizzle/meta/_journal.json

@@ -113,6 +113,13 @@
       "when": 1770685990509,
       "tag": "0015_orange_black_knight",
       "breakpoints": true
+    },
+    {
+      "idx": 16,
+      "version": "7",
+      "when": 1770771189811,
+      "tag": "0016_futuristic_skrulls",
+      "breakpoints": true
     }
   ]
 }

reproduce-issue.ts

@@ -1,33 +0,0 @@
-
-async function main() {
-    const videoId = 'BtAoUN0-yxg';
-    console.log(`Fetching OEmbed for ${videoId}...`);
-    try {
-        const response = await fetch(`https://www.youtube.com/oembed?url=https://www.youtube.com/watch?v=${videoId}&format=json`);
-        const data = await response.json();
-        console.log('OEmbed Data:', JSON.stringify(data, null, 2));
-
-        const authorHandle = data.author_url?.split('/').pop() || data.author_name;
-        console.log('Author Handle:', authorHandle);
-
-        const rawSlug = authorHandle.toLowerCase().replace(/[^a-z0-9]+/g, '-');
-        let expectedSlug = rawSlug.replace(/^-+|-+$/g, '');
-        console.log('Raw Slug:', expectedSlug);
-
-        if (!expectedSlug || expectedSlug.length < 2) {
-            console.log('Using Fallback...');
-            // Mimic fallback
-            const fallbackId = 'shadow-handle-fallback';
-            const suffix = `-${Date.now().toString(36)}`;
-            expectedSlug = `user-${fallbackId}${suffix}`;
-            console.log('Fallback Slug:', expectedSlug);
-        } else {
-            console.log('Final Slug:', expectedSlug);
-        }
-
-    } catch (error) {
-        console.error('Fetch Error:', error);
-    }
-}
-
-main();

src/app/admin/dashboard/page.tsx

@@ -1,6 +1,6 @@
 import { getAdminStats } from "@/features/admin/actions/stats";
 import { Card, CardContent, CardHeader, CardTitle, CardDescription } from "@/components/ui/card";
-import { Users, Video, ShoppingBag, Eye, ArrowRight, PlayCircle, Clock } from "lucide-react";
+import { Users, Video, ShoppingBag, Eye, ArrowRight, PlayCircle, Clock, MessagesSquare, Link2 } from "lucide-react";
 import { Button } from "@/components/ui/button";
 import Link from "next/link";
 
@@ -58,15 +58,41 @@ export default async function AdminDashboardPage() {
                     </Card>
                 </Link>
 
-                <Link href="/admin/moderation" className="block outline-none focus-visible:ring-2 focus-visible:ring-ring rounded-xl">
+                <Link href="/admin/moderation?minPledges=1" className="block outline-none focus-visible:ring-2 focus-visible:ring-ring rounded-xl">
                     <Card className="hover:border-emerald-500/50 transition-colors cursor-pointer h-full">
                         <CardHeader className="flex flex-row items-center justify-between space-y-0 pb-2">
-                            <CardTitle className="text-sm font-medium">High Interest Items</CardTitle>
+                            <CardTitle className="text-sm font-medium">Interest Items</CardTitle>
                             <ShoppingBag className="h-4 w-4 text-emerald-500" />
                         </CardHeader>
                         <CardContent>
                             <div className="text-2xl font-bold">{stats.highInterestItems}</div>
-                            <p className="text-xs text-muted-foreground">5+ interest pledges</p>
+                            <p className="text-xs text-muted-foreground">Any user interest</p>
+                        </CardContent>
+                    </Card>
+                </Link>
+
+                <Link href="/admin/requests" className="block outline-none focus-visible:ring-2 focus-visible:ring-ring rounded-xl">
+                    <Card className="hover:border-amber-500/50 transition-colors cursor-pointer h-full">
+                        <CardHeader className="flex flex-row items-center justify-between space-y-0 pb-2">
+                            <CardTitle className="text-sm font-medium">Fan Requests</CardTitle>
+                            <MessagesSquare className="h-4 w-4 text-amber-500" />
+                        </CardHeader>
+                        <CardContent>
+                            <div className="text-2xl font-bold">{stats.pendingRequests}</div>
+                            <p className="text-xs text-muted-foreground">Awaiting sourcing</p>
+                        </CardContent>
+                    </Card>
+                </Link>
+
+                <Link href="/admin/requests" className="block outline-none focus-visible:ring-2 focus-visible:ring-ring rounded-xl">
+                    <Card className="hover:border-blue-500/50 transition-colors cursor-pointer h-full">
+                        <CardHeader className="flex flex-row items-center justify-between space-y-0 pb-2">
+                            <CardTitle className="text-sm font-medium">Link Proposals</CardTitle>
+                            <Link2 className="h-4 w-4 text-blue-500" />
+                        </CardHeader>
+                        <CardContent>
+                            <div className="text-2xl font-bold">{stats.pendingProposals}</div>
+                            <p className="text-xs text-muted-foreground">User suggested links</p>
                         </CardContent>
                     </Card>
                 </Link>
@@ -106,24 +132,26 @@ export default async function AdminDashboardPage() {
                     </CardContent>
                 </Card>
 
-                <Card className="col-span-3">
-                    <CardHeader>
-                        <CardTitle>Platform Stats</CardTitle>
-                        <CardDescription>Overall product health metrics.</CardDescription>
-                    </CardHeader>
-                    <CardContent>
-                        <div className="space-y-4">
-                            <div className="flex items-center justify-between">
-                                <span className="text-sm font-medium">Total Products Linked</span>
-                                <span className="text-lg font-bold">{stats.totalProducts}</span>
-                            </div>
-                            <div className="w-full bg-secondary h-2 rounded-full overflow-hidden">
-                                <div className="bg-primary h-full" style={{ width: '100%' }} />
+                <Link href="/admin/moderation?status=all" className="col-span-3 block outline-none focus-visible:ring-2 focus-visible:ring-ring rounded-xl">
+                    <Card className="hover:border-primary/50 transition-colors cursor-pointer h-full">
+                        <CardHeader>
+                            <CardTitle>Platform Stats</CardTitle>
+                            <CardDescription>Overall product health metrics.</CardDescription>
+                        </CardHeader>
+                        <CardContent>
+                            <div className="space-y-4">
+                                <div className="flex items-center justify-between">
+                                    <span className="text-sm font-medium">Total Products Linked</span>
+                                    <span className="text-lg font-bold">{stats.totalProducts}</span>
+                                </div>
+                                <div className="w-full bg-secondary h-2 rounded-full overflow-hidden">
+                                    <div className="bg-primary h-full" style={{ width: '100%' }} />
+                                </div>
+                                <p className="text-xs text-muted-foreground">Values reflect cumulative platform growth since launch.</p>
                             </div>
-                            <p className="text-xs text-muted-foreground">Values reflect cumulative platform growth since launch.</p>
-                        </div>
-                    </CardContent>
-                </Card>
+                        </CardContent>
+                    </Card>
+                </Link>
             </div>
         </div>
     );

src/app/admin/moderation/page.tsx

@@ -3,7 +3,7 @@ import { getAdminSession } from "@/lib/admin";
 import { AdminModerationService } from "@/features/moderation/services/admin-moderation.service";
 import { AdminModerationQueue } from "@/features/moderation/components/admin-moderation-queue";
 import { Card, CardContent, CardHeader, CardTitle } from "@/components/ui/card";
-import { ShieldCheck, Flag, CheckCircle2, XCircle, ArrowLeft } from "lucide-react";
+import { ShieldCheck, Flag, CheckCircle2, XCircle, ArrowLeft, Clock, Globe } from "lucide-react";
 import Link from "next/link";
 
 export const metadata = {
@@ -11,16 +11,28 @@ export const metadata = {
     description: "High-ambiguity tag moderation for ops admins",
 };
 
-export default async function AdminModerationPage() {
+export default async function AdminModerationPage({
+    searchParams,
+}: {
+    searchParams: Promise<{ [key: string]: string | string[] | undefined }>;
+}) {
     const session = await getAdminSession();
 
     if (!session) {
         redirect("/login?callbackUrl=/admin/moderation");
     }
 
+    const params = await searchParams;
+    const status = typeof params.status === 'string' ? params.status as any : undefined;
+    const minPledges = typeof params.minPledges === 'string' ? parseInt(params.minPledges) : 0;
+
     const adminService = new AdminModerationService();
     const [rawQueue, stats] = await Promise.all([
-        adminService.getAdminQueue({ limit: 50 }),
+        adminService.getAdminQueue({
+            limit: 100,
+            minPledges,
+            status
+        }),
         adminService.getAdminQueueStats(),
     ]);
 
@@ -48,42 +60,65 @@ export default async function AdminModerationPage() {
             </div>
 
             {/* Stats Overview */}
-            <div className="grid grid-cols-1 md:grid-cols-3 gap-6">
-                <Card className="bg-card/40 backdrop-blur-md border-border/40">
-                    <CardHeader className="flex flex-row items-center justify-between pb-2 space-y-0">
-                        <CardTitle className="text-sm font-medium">Flagged Queue</CardTitle>
-                        <Flag className="w-4 h-4 text-amber-500" />
-                    </CardHeader>
-                    <CardContent>
-                        <div className="text-2xl font-bold">{stats.flagged}</div>
-                        <p className="text-xs text-muted-foreground">Awaiting review</p>
-                    </CardContent>
-                </Card>
+            <div className="grid grid-cols-2 lg:grid-cols-4 gap-4 md:gap-6">
+                <Link href="/admin/moderation?status=flagged" className="block outline-none">
+                    <Card className={`h-full bg-card/40 backdrop-blur-md border-border/40 hover:border-amber-500/50 transition-colors cursor-pointer ${status === 'flagged' ? 'border-amber-500/50 ring-1 ring-amber-500/50' : ''}`}>
+                        <CardHeader className="flex flex-row items-center justify-between pb-2 space-y-0">
+                            <CardTitle className="text-sm font-medium">Flagged Queue</CardTitle>
+                            <Flag className="w-4 h-4 text-amber-500" />
+                        </CardHeader>
+                        <CardContent>
+                            <div className="text-2xl font-bold">{stats.flagged}</div>
+                            <p className="text-xs text-muted-foreground">AI detections</p>
+                        </CardContent>
+                    </Card>
+                </Link>
+
+                <Link href="/admin/moderation?status=pending_creator" className="block outline-none">
+                    <Card className={`h-full bg-card/40 backdrop-blur-md border-border/40 hover:border-blue-500/50 transition-colors cursor-pointer ${status === 'pending_creator' ? 'border-blue-500/50 ring-1 ring-blue-500/50' : ''}`}>
+                        <CardHeader className="flex flex-row items-center justify-between pb-2 space-y-0">
+                            <CardTitle className="text-sm font-medium">Pending Creator</CardTitle>
+                            <Clock className="w-4 h-4 text-blue-500" />
+                        </CardHeader>
+                        <CardContent>
+                            <div className="text-2xl font-bold">{stats.pendingCreator}</div>
+                            <p className="text-xs text-muted-foreground">Waiting for acceptance</p>
+                        </CardContent>
+                    </Card>
+                </Link>
 
-                <Card className="bg-card/40 backdrop-blur-md border-border/40">
-                    <CardHeader className="flex flex-row items-center justify-between pb-2 space-y-0">
-                        <CardTitle className="text-sm font-medium">Corrected Today</CardTitle>
-                        <CheckCircle2 className="w-4 h-4 text-emerald-500" />
-                    </CardHeader>
-                    <CardContent>
-                        <div className="text-2xl font-bold">{stats.correctedToday}</div>
-                        <p className="text-xs text-muted-foreground">Moved to creator queue</p>
-                    </CardContent>
-                </Card>
+                <Link href="/admin/moderation?status=live" className="block outline-none">
+                    <Card className={`h-full bg-card/40 backdrop-blur-md border-border/40 hover:border-emerald-500/50 transition-colors cursor-pointer ${status === 'live' ? 'border-emerald-500/50 ring-1 ring-emerald-500/50' : ''}`}>
+                        <CardHeader className="flex flex-row items-center justify-between pb-2 space-y-0">
+                            <CardTitle className="text-sm font-medium">Live Catalog</CardTitle>
+                            <Globe className="w-4 h-4 text-emerald-500" />
+                        </CardHeader>
+                        <CardContent>
+                            <div className="text-2xl font-bold">{stats.live}</div>
+                            <p className="text-xs text-muted-foreground">Visible in Vaults</p>
+                        </CardContent>
+                    </Card>
+                </Link>
 
-                <Card className="bg-card/40 backdrop-blur-md border-border/40">
-                    <CardHeader className="flex flex-row items-center justify-between pb-2 space-y-0">
-                        <CardTitle className="text-sm font-medium">Rejected Today</CardTitle>
-                        <XCircle className="w-4 h-4 text-rose-500" />
-                    </CardHeader>
-                    <CardContent>
-                        <div className="text-2xl font-bold">{stats.markedIncorrectToday}</div>
-                        <p className="text-xs text-muted-foreground">Marked as false positives</p>
-                    </CardContent>
-                </Card>
+                <Link href="/admin/moderation?status=rejected" className="block outline-none">
+                    <Card className={`h-full bg-card/40 backdrop-blur-md border-border/40 hover:border-rose-500/50 transition-colors cursor-pointer ${status === 'rejected' ? 'border-rose-500/50 ring-1 ring-rose-500/50' : ''}`}>
+                        <CardHeader className="flex flex-row items-center justify-between pb-2 space-y-0">
+                            <CardTitle className="text-sm font-medium">Rejected</CardTitle>
+                            <XCircle className="w-4 h-4 text-rose-500" />
+                        </CardHeader>
+                        <CardContent>
+                            <div className="text-2xl font-bold">{stats.rejected}</div>
+                            <p className="text-xs text-muted-foreground">Admin rejected</p>
+                        </CardContent>
+                    </Card>
+                </Link>
             </div>
 
-            <AdminModerationQueue initialDetections={queue} />
+            <AdminModerationQueue
+                initialDetections={queue}
+                initialMinPledges={status === 'flagged' ? minPledges : 0}
+                initialCategory={typeof params.category === 'string' ? params.category : "all"}
+            />
         </div>
     );
 }

src/app/admin/requests/page.tsx

@@ -0,0 +1,111 @@
+import { auth } from '@/lib/auth';
+import { headers } from 'next/headers';
+import { redirect } from 'next/navigation';
+import { db } from '@/lib/db';
+import {
+    productRequests,
+    affiliateProposals,
+    youtubeVideos,
+    youtubeChannels,
+    users,
+} from '@/lib/db/schema';
+import { eq, desc, and, isNull, sql } from 'drizzle-orm';
+import { Clock, ArrowLeft, ExternalLink, MessagesSquare, Link2 as LinkIcon } from 'lucide-react';
+import { Card, CardContent } from '@/components/ui/card';
+import { Tabs, TabsContent, TabsList, TabsTrigger } from '@/components/ui/tabs';
+import Link from 'next/link';
+import { UserNav } from '@/components/auth/user-nav';
+import { Badge } from '@/components/ui/badge';
+import { getAdminRequests, getAdminProposals } from '@/features/admin/actions/requests';
+
+import { AdminRequestList } from '@/features/admin/components/admin-request-list';
+import { AdminProposalList } from '@/features/admin/components/admin-proposal-list';
+
+export default async function AdminRequestsPage() {
+    // Basic admin check - for now just session check, 
+    // real admin check would be on session.user.role
+    const session = await auth.api.getSession({
+        headers: await headers(),
+    });
+
+    if (!session?.user) {
+        redirect('/login');
+    }
+
+    // In a real app, check for ADMIN role here
+    // if (session.user.role !== 'ADMIN') redirect('/dashboard');
+
+    const requests = await getAdminRequests();
+    const proposals = await getAdminProposals();
+
+    return (
+        <div className="space-y-8 animate-in fade-in duration-500">
+            <div className="flex items-center justify-between">
+                <div className="flex items-center gap-4">
+                    <Link href="/admin/dashboard" className="inline-flex items-center gap-1.5 text-sm text-muted-foreground hover:text-foreground transition-colors">
+                        <ArrowLeft className="h-4 w-4" />
+                        Admin Dashboard
+                    </Link>
+                </div>
+                <UserNav />
+            </div>
+
+            <div className="space-y-2">
+                <h1 className="text-4xl font-extrabold tracking-tight">Global Opportunity Hub</h1>
+                <p className="text-muted-foreground text-lg">
+                    Manage fan requests and community link proposals across all creators.
+                </p>
+            </div>
+
+            <div className="grid grid-cols-1 md:grid-cols-2 gap-4">
+                <Card className="glass border-white/10 text-left">
+                    <CardContent className="pt-6">
+                        <div className="flex items-center justify-between">
+                            <div>
+                                <div className="text-2xl font-bold text-orange-400">
+                                    {requests.filter(r => r.status === 'PENDING').length}
+                                </div>
+                                <p className="text-sm text-gray-400 mt-1">Pending Fan Requests</p>
+                            </div>
+                            <MessagesSquare className="h-8 w-8 text-orange-400/20" />
+                        </div>
+                    </CardContent>
+                </Card>
+                <Card className="glass border-white/10 text-left">
+                    <CardContent className="pt-6">
+                        <div className="flex items-center justify-between">
+                            <div>
+                                <div className="text-2xl font-bold text-blue-400">
+                                    {proposals.filter(p => p.status === 'PENDING').length}
+                                </div>
+                                <p className="text-sm text-gray-400 mt-1">Pending Link Proposals</p>
+                            </div>
+                            <LinkIcon className="h-8 w-8 text-blue-400/20" />
+                        </div>
+                    </CardContent>
+                </Card>
+            </div>
+
+            <Tabs defaultValue="requests" className="w-full">
+                <TabsList className="grid w-full max-w-md grid-cols-2 bg-secondary/50 border border-border/50">
+                    <TabsTrigger value="requests" className="gap-2">
+                        <MessagesSquare className="h-4 w-4" />
+                        Fan Requests
+                    </TabsTrigger>
+                    <TabsTrigger value="proposals" className="gap-2">
+                        <LinkIcon className="h-4 w-4" />
+                        Link Proposals
+                    </TabsTrigger>
+                </TabsList>
+
+                <TabsContent value="requests" className="mt-6">
+                    <AdminRequestList requests={requests as any} />
+                </TabsContent>
+
+                <TabsContent value="proposals" className="mt-6">
+                    <AdminProposalList proposals={proposals as any} />
+                </TabsContent>
+            </Tabs>
+        </div>
+    );
+}

src/features/admin/actions/requests.ts

@@ -0,0 +1,43 @@
+"use server";
+
+import { db } from "@/lib/db";
+import {
+    productRequests,
+    affiliateProposals,
+    youtubeVideos,
+    youtubeChannels,
+    users,
+} from "@/lib/db/schema";
+import { eq, desc, and } from "drizzle-orm";
+
+export async function getAdminRequests() {
+    const requests = await db.query.productRequests.findMany({
+        with: {
+            video: {
+                with: {
+                    channel: true
+                }
+            },
+            creator: true,
+        },
+        orderBy: [desc(productRequests.createdAt)],
+    });
+
+    return requests;
+}
+
+export async function getAdminProposals() {
+    const proposals = await db.query.affiliateProposals.findMany({
+        with: {
+            video: {
+                with: {
+                    channel: true
+                }
+            },
+            creator: true,
+        },
+        orderBy: [desc(affiliateProposals.createdAt)],
+    });
+
+    return proposals;
+}

src/features/admin/actions/stats.ts

@@ -1,7 +1,14 @@
 "use server";
 
 import { db } from "@/lib/db";
-import { users, youtubeVideos, detectedObjects, interestPledges } from "@/lib/db/schema";
+import {
+    users,
+    youtubeVideos,
+    detectedObjects,
+    interestPledges,
+    productRequests,
+    affiliateProposals,
+} from "@/lib/db/schema";
 import { count, eq, sql } from "drizzle-orm";
 import { auth } from "@/lib/auth";
 import { headers } from "next/headers";
@@ -30,19 +37,31 @@ export async function getAdminStats() {
     const [awaitingApproval] = await db.select({ count: count() }).from(youtubeVideos).where(eq(youtubeVideos.scanStatus, 'awaiting_approval'));
     const [totalProducts] = await db.select({ count: count() }).from(detectedObjects);
 
-    // High Interest Items: Detections with 5+ "I want this" requests
-    const highInterestCount = await db
+    // Interest Items: Detections with 1+ "I want this" requests
+    const interestCount = await db
         .select({ count: sql<number>`count(distinct ${detectedObjects.id})` })
         .from(detectedObjects)
         .innerJoin(interestPledges, eq(detectedObjects.id, interestPledges.detectedObjectId))
         .groupBy(detectedObjects.id)
-        .having(sql`count(${interestPledges.id}) >= 5`);
+        .having(sql`count(${interestPledges.id}) >= 1`);
+
+    // Pending Community Requests
+    const [pendingRequests] = await db.select({ count: count() })
+        .from(productRequests)
+        .where(eq(productRequests.status, 'PENDING'));
+
+    // Pending Affiliate Proposals
+    const [pendingProposals] = await db.select({ count: count() })
+        .from(affiliateProposals)
+        .where(eq(affiliateProposals.status, 'PENDING'));
 
     return {
         totalUsers: Number(userCount.count),
         pendingAnalysis: Number(pendingAnalysis.count),
         awaitingApproval: Number(awaitingApproval.count),
         totalProducts: Number(totalProducts.count),
-        highInterestItems: highInterestCount.length
+        highInterestItems: interestCount.length,
+        pendingRequests: Number(pendingRequests.count),
+        pendingProposals: Number(pendingProposals.count),
     };
 }

src/features/admin/components/admin-proposal-list.tsx

@@ -0,0 +1,228 @@
+'use client';
+
+import React, { useState, useTransition } from 'react';
+import { Card, CardContent, CardHeader, CardTitle } from '@/components/ui/card';
+import { Badge } from '@/components/ui/badge';
+import { Button } from '@/components/ui/button';
+import { Check, X, Link2, ExternalLink, User, Clock, Tv, Search, Filter } from 'lucide-react';
+import { approveProposal, rejectProposal } from '@/features/moderation/actions/handle-proposal';
+import { toast } from 'sonner';
+import { formatDistanceToNow } from 'date-fns';
+import { Label } from '@/components/ui/label';
+import { Select, SelectContent, SelectItem, SelectTrigger, SelectValue } from '@/components/ui/select';
+import { Input } from '@/components/ui/input';
+
+interface Proposal {
+    id: string;
+    productName: string;
+    productUrl: string;
+    affiliateUrl: string;
+    submitterName: string | null;
+    submitterEmail: string | null;
+    note: string | null;
+    status: 'PENDING' | 'APPROVED' | 'REJECTED';
+    createdAt: Date;
+    video: {
+        title: string;
+        channel: {
+            channelName: string;
+        };
+    };
+}
+
+interface AdminProposalListProps {
+    proposals: Proposal[];
+}
+
+export function AdminProposalList({ proposals: initialProposals }: AdminProposalListProps) {
+    const [proposals, setProposals] = useState(initialProposals);
+    const [isPending, startTransition] = useTransition();
+    const [filterStatus, setFilterStatus] = useState<string>('PENDING');
+    const [searchQuery, setSearchQuery] = useState('');
+
+    const handleApprove = (id: string) => {
+        startTransition(async () => {
+            const result = await approveProposal(id);
+            if (result.success) {
+                setProposals(prev => prev.map(p => p.id === id ? { ...p, status: 'APPROVED' } : p));
+                toast.success('Proposal approved and added to Vault!');
+            } else {
+                toast.error(result.error || 'Failed to approve');
+            }
+        });
+    };
+
+    const handleReject = (id: string) => {
+        startTransition(async () => {
+            const result = await rejectProposal(id);
+            if (result.success) {
+                setProposals(prev => prev.map(p => p.id === id ? { ...p, status: 'REJECTED' } : p));
+                toast.success('Proposal rejected');
+            } else {
+                toast.error(result.error || 'Failed to reject');
+            }
+        });
+    };
+
+    const filteredProposals = proposals.filter(p => {
+        if (p.status !== filterStatus) return false;
+        if (searchQuery) {
+            const query = searchQuery.toLowerCase();
+            return (
+                p.productName.toLowerCase().includes(query) ||
+                (p.submitterName?.toLowerCase().includes(query) ?? false) ||
+                (p.submitterEmail?.toLowerCase().includes(query) ?? false) ||
+                (p.video.title.toLowerCase().includes(query)) ||
+                (p.video.channel.channelName.toLowerCase().includes(query))
+            );
+        }
+        return true;
+    });
+
+    const stats = {
+        pending: proposals.filter(p => p.status === 'PENDING').length,
+        approved: proposals.filter(p => p.status === 'APPROVED').length,
+        rejected: proposals.filter(p => p.status === 'REJECTED').length,
+    };
+
+    return (
+        <div className="space-y-6">
+            {/* Filter Bar */}
+            <div className="flex flex-col gap-4 bg-card/50 p-4 rounded-lg border border-border/50 backdrop-blur-sm">
+                <div className="flex flex-wrap items-center gap-4">
+                    <div className="space-y-1">
+                        <Label>Status</Label>
+                        <Select value={filterStatus} onValueChange={setFilterStatus}>
+                            <SelectTrigger className="w-[150px] h-9 bg-background/50">
+                                <SelectValue placeholder="Status" />
+                            </SelectTrigger>
+                            <SelectContent>
+                                <SelectItem value="PENDING">Pending ({stats.pending})</SelectItem>
+                                <SelectItem value="APPROVED">Approved ({stats.approved})</SelectItem>
+                                <SelectItem value="REJECTED">Rejected ({stats.rejected})</SelectItem>
+                            </SelectContent>
+                        </Select>
+                    </div>
+
+                    <div className="space-y-1 flex-grow">
+                        <Label>Search</Label>
+                        <div className="relative">
+                            <Search className="absolute left-2.5 top-2.5 h-4 w-4 text-muted-foreground" />
+                            <Input
+                                placeholder="Search by product, creator, video, submitter..."
+                                value={searchQuery}
+                                onChange={(e) => setSearchQuery(e.target.value)}
+                                className="pl-9 h-9 bg-background/50"
+                            />
+                        </div>
+                    </div>
+                </div>
+            </div>
+
+            <div className="grid gap-6">
+                {filteredProposals.length > 0 ? (
+                    filteredProposals.map((proposal) => (
+                        <Card key={proposal.id} className="glass border-white/10 hover:border-white/20 transition-all overflow-hidden group">
+                            <CardHeader className="pb-3 border-b border-white/5 bg-white/5">
+                                <div className="flex items-center justify-between">
+                                    <div className="space-y-1">
+                                        <div className="flex items-center gap-2">
+                                            <CardTitle className="text-lg">{proposal.productName}</CardTitle>
+                                            <Badge variant={proposal.status === 'PENDING' ? 'secondary' : proposal.status === 'APPROVED' ? 'default' : 'destructive'} className="text-[10px] uppercase font-bold tracking-wider">
+                                                {proposal.status}
+                                            </Badge>
+                                            <div className="flex items-center gap-1.5 text-[10px] font-bold text-amber-500 uppercase tracking-widest bg-amber-500/10 px-2 py-0.5 rounded-full border border-amber-500/20">
+                                                <Tv className="h-3 w-3" />
+                                                {proposal.video.channel.channelName}
+                                            </div>
+                                        </div>
+                                        <p className="text-xs text-muted-foreground flex items-center gap-1">
+                                            <Clock className="h-3 w-3" />
+                                            Submitted {formatDistanceToNow(new Date(proposal.createdAt))} ago •
+                                            <span className="text-white/40 ml-1 truncate max-w-[200px] inline-block">{proposal.video.title}</span>
+                                        </p>
+                                    </div>
+                                    {proposal.status === 'PENDING' && (
+                                        <div className="flex items-center gap-2">
+                                            <Button
+                                                size="sm"
+                                                variant="ghost"
+                                                onClick={() => handleReject(proposal.id)}
+                                                disabled={isPending}
+                                                className="text-red-400 hover:text-red-300 hover:bg-red-400/10"
+                                            >
+                                                <X className="h-4 w-4 mr-1.5" />
+                                                Reject
+                                            </Button>
+                                            <Button
+                                                size="sm"
+                                                onClick={() => handleApprove(proposal.id)}
+                                                disabled={isPending}
+                                                className="bg-green-600 hover:bg-green-500 text-white"
+                                            >
+                                                <Check className="h-4 w-4 mr-1.5" />
+                                                Approve & List
+                                            </Button>
+                                        </div>
+                                    )}
+                                </div>
+                            </CardHeader>
+                            <CardContent className="py-4 grid sm:grid-cols-2 gap-6">
+                                <div className="space-y-4">
+                                    <div className="space-y-1.5">
+                                        <span className="text-[10px] font-bold uppercase tracking-wider text-muted-foreground">Original Link</span>
+                                        <a
+                                            href={proposal.productUrl}
+                                            target="_blank"
+                                            rel="noopener noreferrer"
+                                            className="flex items-center gap-2 text-sm text-blue-400 hover:underline group"
+                                        >
+                                            View Product Page
+                                            <ExternalLink className="h-3 w-3 opacity-0 group-hover:opacity-100 transition-opacity" />
+                                        </a>
+                                    </div>
+                                    <div className="space-y-1.5">
+                                        <span className="text-[10px] font-bold uppercase tracking-wider text-muted-foreground">Affiliate Link</span>
+                                        <div className="bg-white/5 border border-white/10 rounded-md p-2 flex items-center justify-between">
+                                            <span className="text-xs font-mono truncate text-gray-300">{proposal.affiliateUrl}</span>
+                                            <a href={proposal.affiliateUrl} target="_blank" rel="noopener noreferrer">
+                                                <Button variant="ghost" size="icon" className="h-6 w-6">
+                                                    <ExternalLink className="h-3 w-3" />
+                                                </Button>
+                                            </a>
+                                        </div>
+                                    </div>
+                                </div>
+                                <div className="space-y-4">
+                                    <div className="space-y-1.5">
+                                        <span className="text-[10px] font-bold uppercase tracking-wider text-muted-foreground">Submitter Details</span>
+                                        <div className="flex items-center gap-2 text-sm text-gray-200">
+                                            <User className="h-3.5 w-3.5 text-muted-foreground" />
+                                            {proposal.submitterName || 'Anonymous'}
+                                            {proposal.submitterEmail && (
+                                                <span className="text-muted-foreground ml-1">({proposal.submitterEmail})</span>
+                                            )}
+                                        </div>
+                                    </div>
+                                    {proposal.note && (
+                                        <div className="space-y-1.5">
+                                            <span className="text-[10px] font-bold uppercase tracking-wider text-muted-foreground">Note</span>
+                                            <p className="text-sm text-gray-300 italic border-l-2 border-primary/30 pl-3">
+                                                "{proposal.note}"
+                                            </p>
+                                        </div>
+                                    )}
+                                </div>
+                            </CardContent>
+                        </Card>
+                    ))
+                ) : (
+                    <div className="py-20 text-center space-y-4 bg-muted/20 rounded-xl border-2 border-dashed border-border/50">
+                        <h3 className="text-xl font-semibold text-muted-foreground">No proposals found</h3>
+                        <p className="text-muted-foreground text-sm">Try adjusting your filters or search query.</p>
+                    </div>
+                )}
+            </div>
+        </div>
+    );
+}

src/features/admin/components/admin-request-list.tsx

@@ -0,0 +1,236 @@
+'use client';
+
+import React, { useState } from 'react';
+import { Card, CardContent, CardFooter, CardHeader, CardTitle } from '@/components/ui/card';
+import { Badge } from '@/components/ui/badge';
+import { formatDistanceToNow } from 'date-fns';
+import { CheckCircle, Clock, ShieldAlert, Filter, Search, User, Mail, Video as VideoIcon, Tv } from 'lucide-react';
+import { Label } from '@/components/ui/label';
+import { Select, SelectContent, SelectItem, SelectTrigger, SelectValue } from '@/components/ui/select';
+import { Input } from '@/components/ui/input';
+import { updateRequestStatus } from '@/actions/submit-request';
+import { toast } from 'sonner';
+import Image from 'next/image';
+
+interface Request {
+    id: string;
+    videoId: string;
+    creatorId: string;
+    viewerName: string | null;
+    viewerEmail: string | null;
+    note: string;
+    imageUrl: string | null;
+    status: string;
+    createdAt: Date;
+    video: {
+        title: string;
+        channel: {
+            channelName: string;
+        };
+    };
+    creator: {
+        name: string | null;
+    };
+}
+
+interface AdminRequestListProps {
+    requests: Request[];
+}
+
+export function AdminRequestList({ requests: initialRequests }: AdminRequestListProps) {
+    const [requests, setRequests] = useState(initialRequests);
+    const [filterStatus, setFilterStatus] = useState<string>('PENDING');
+    const [sortBy, setSortBy] = useState<string>('date');
+    const [searchQuery, setSearchQuery] = useState('');
+
+    const stats = {
+        pending: requests.filter(r => r.status === 'PENDING').length,
+        fulfilled: requests.filter(r => r.status === 'FULFILLED').length,
+        dismissed: requests.filter(r => r.status === 'DISMISSED').length,
+    };
+
+    const filteredRequests = requests.filter(r => {
+        if (r.status !== filterStatus) return false;
+        if (searchQuery) {
+            const query = searchQuery.toLowerCase();
+            return (
+                r.note.toLowerCase().includes(query) ||
+                (r.viewerName?.toLowerCase().includes(query) ?? false) ||
+                (r.viewerEmail?.toLowerCase().includes(query) ?? false) ||
+                (r.video.title.toLowerCase().includes(query)) ||
+                (r.video.channel.channelName.toLowerCase().includes(query))
+            );
+        }
+        return true;
+    }).sort((a, b) => {
+        if (sortBy === 'date') {
+            return new Date(b.createdAt).getTime() - new Date(a.createdAt).getTime();
+        }
+        return 0;
+    });
+
+    const handleStatusUpdate = async (id: string, newStatus: 'PENDING' | 'FULFILLED' | 'DISMISSED') => {
+        try {
+            const result = await updateRequestStatus(id, newStatus);
+            if (result.success) {
+                setRequests(prev => prev.map(r => r.id === id ? { ...r, status: newStatus } : r));
+                toast.success(`Request marked as ${newStatus.toLowerCase()}`);
+            } else {
+                toast.error(result.error || 'Failed to update status');
+            }
+        } catch (err) {
+            toast.error('Failed to update request status');
+        }
+    };
+
+    const statCards = [
+        { status: 'PENDING', title: 'Pending Review', count: stats.pending, icon: <Clock className="w-5 h-5 text-amber-500" />, description: 'Awaiting action', activeClasses: 'ring-2 ring-amber-500 bg-amber-500/10 border-amber-500/50' },
+        { status: 'FULFILLED', title: 'Fulfilled', count: stats.fulfilled, icon: <CheckCircle className="w-5 h-5 text-emerald-500" />, description: 'Added to Vault', activeClasses: 'ring-2 ring-emerald-500 bg-emerald-500/10 border-emerald-500/50' },
+        { status: 'DISMISSED', title: 'Dismissed', count: stats.dismissed, icon: <ShieldAlert className="w-5 h-5 text-rose-500" />, description: 'Hidden requests', activeClasses: 'ring-2 ring-rose-500 bg-rose-500/10 border-rose-500/50' },
+    ];
+
+    return (
+        <div className="space-y-6">
+            {/* Stat Cards */}
+            <div className="grid grid-cols-1 md:grid-cols-3 gap-4">
+                {statCards.map(({ status, title, count, icon, description, activeClasses }) => (
+                    <button
+                        key={status}
+                        type="button"
+                        onClick={() => setFilterStatus(status)}
+                        className={`text-left p-4 rounded-lg border transition-all group ${filterStatus === status ? activeClasses : 'bg-card/40 backdrop-blur-md border-border/40 hover:bg-card/60'
+                            }`}
+                    >
+                        <div className="flex items-center justify-between pb-2">
+                            <span className="text-sm font-medium">{title}</span>
+                            <div className="p-2 bg-background/50 rounded-lg group-hover:scale-110 transition-transform">
+                                {icon}
+                            </div>
+                        </div>
+                        <div className="text-3xl font-bold">{count}</div>
+                        <p className="text-xs text-muted-foreground mt-1">{description}</p>
+                    </button>
+                ))}
+            </div>
+
+            {/* Filter Bar */}
+            <div className="flex flex-col gap-4 bg-card/50 p-4 rounded-lg border border-border/50 backdrop-blur-sm">
+                <div className="flex flex-wrap items-center gap-4">
+                    <div className="space-y-1">
+                        <Label>Sort By</Label>
+                        <Select value={sortBy} onValueChange={setSortBy}>
+                            <SelectTrigger className="w-[150px] h-9 bg-background/50">
+                                <SelectValue placeholder="Sort By" />
+                            </SelectTrigger>
+                            <SelectContent>
+                                <SelectItem value="date">Date (Newest)</SelectItem>
+                            </SelectContent>
+                        </Select>
+                    </div>
+
+                    <div className="space-y-1 flex-grow">
+                        <Label>Search</Label>
+                        <div className="relative">
+                            <Search className="absolute left-2.5 top-2.5 h-4 w-4 text-muted-foreground" />
+                            <Input
+                                placeholder="Search by note, creator, video, name or email..."
+                                value={searchQuery}
+                                onChange={(e) => setSearchQuery(e.target.value)}
+                                className="pl-9 h-9 bg-background/50"
+                            />
+                        </div>
+                    </div>
+                </div>
+
+                <div className="flex items-center justify-between">
+                    <div className="text-sm text-muted-foreground">
+                        Showing {filteredRequests.length} of {requests.filter(r => r.status === filterStatus).length} {filterStatus.toLowerCase()} requests
+                    </div>
+                </div>
+            </div>
+
+            {filteredRequests.length > 0 ? (
+                <div className="grid grid-cols-1 md:grid-cols-2 lg:grid-cols-3 gap-6">
+                    {filteredRequests.map((request) => (
+                        <Card key={request.id} className="bg-card/60 border-white/10 overflow-hidden flex flex-col hover:border-primary/20 transition-all group">
+                            {request.imageUrl && (
+                                <div className="relative aspect-video w-full overflow-hidden border-b border-white/10">
+                                    <Image
+                                        src={request.imageUrl}
+                                        alt="Requested product"
+                                        fill
+                                        className="object-cover group-hover:scale-105 transition-transform duration-500"
+                                    />
+                                </div>
+                            )}
+                            <CardHeader className="pb-2">
+                                <div className="flex justify-between items-start gap-2">
+                                    <div className="flex flex-col gap-1.5">
+                                        <Badge variant={request.status === 'PENDING' ? 'secondary' : 'default'} className="w-fit bg-primary/20 text-primary border-primary/30 text-[10px] uppercase font-bold tracking-wider">
+                                            {request.status}
+                                        </Badge>
+                                        <div className="flex items-center gap-1.5 text-[10px] font-bold text-amber-500 uppercase tracking-widest bg-amber-500/10 px-2 py-0.5 rounded-full border border-amber-500/20">
+                                            <Tv className="h-3 w-3" />
+                                            {request.video.channel.channelName}
+                                        </div>
+                                    </div>
+                                    <span className="text-[10px] text-muted-foreground flex items-center gap-1">
+                                        <Clock className="h-3 w-3" />
+                                        {formatDistanceToNow(new Date(request.createdAt), { addSuffix: true })}
+                                    </span>
+                                </div>
+                                <CardTitle className="text-base mt-3 text-white line-clamp-2 leading-snug">
+                                    {request.note}
+                                </CardTitle>
+                            </CardHeader>
+                            <CardContent className="space-y-3 flex-grow pb-4">
+                                <div className="flex items-center gap-2 text-xs text-muted-foreground bg-white/5 p-2 rounded-lg">
+                                    <VideoIcon className="h-3.5 w-3.5 shrink-0 text-primary/70" />
+                                    <span className="truncate italic">"{request.video.title}"</span>
+                                </div>
+                                <div className="space-y-1.5 px-1">
+                                    <div className="flex items-center gap-2 text-xs text-muted-foreground">
+                                        <User className="h-3.5 w-3.5 shrink-0" />
+                                        <span><span className="text-white/60">From:</span> {request.viewerName || 'Anonymous'}</span>
+                                    </div>
+                                    {request.viewerEmail && (
+                                        <div className="flex items-center gap-2 text-xs text-muted-foreground">
+                                            <Mail className="h-3.5 w-3.5 shrink-0" />
+                                            <span className="truncate">{request.viewerEmail}</span>
+                                        </div>
+                                    )}
+                                </div>
+                            </CardContent>
+                            <CardFooter className="flex gap-2 pt-4 border-t border-white/5 bg-white/5 mt-auto">
+                                <button
+                                    onClick={() => handleStatusUpdate(request.id, 'FULFILLED')}
+                                    disabled={request.status === 'FULFILLED'}
+                                    className="flex-1 h-9 rounded-lg bg-emerald-500/10 text-emerald-500 border border-emerald-500/20 text-xs font-bold hover:bg-emerald-500 hover:text-white transition-all disabled:opacity-50"
+                                >
+                                    Mark Fulfilled
+                                </button>
+                                <button
+                                    onClick={() => handleStatusUpdate(request.id, 'DISMISSED')}
+                                    disabled={request.status === 'DISMISSED'}
+                                    className="flex-1 h-9 rounded-lg bg-white/5 text-muted-foreground border border-white/10 text-xs font-bold hover:bg-rose-500/10 hover:text-rose-500 hover:border-rose-500/20 transition-all disabled:opacity-50"
+                                >
+                                    Dismiss
+                                </button>
+                            </CardFooter>
+                        </Card>
+                    ))}
+                </div>
+            ) : (
+                <div className="py-20 text-center space-y-4 bg-muted/20 rounded-xl border-2 border-dashed border-border/50">
+                    <div className="flex justify-center">
+                        <ShieldAlert className="w-12 h-12 text-muted-foreground opacity-20" />
+                    </div>
+                    <div className="space-y-2">
+                        <h3 className="text-xl font-semibold">No requests found</h3>
+                        <p className="text-muted-foreground">Try adjusting your filters or search query.</p>
+                    </div>
+                </div>
+            )}
+        </div>
+    );
+}

src/features/moderation/components/admin-detection-card.tsx

@@ -16,6 +16,7 @@ interface AdminDetection {
         category: string;
         confidenceScore: number;
         frameTimestamp: number;
+        status: string;
     };
     video: {
         title: string;
@@ -25,6 +26,7 @@ interface AdminDetection {
         channelName: string;
     };
     marketplaceMatches: any[];
+    pledgeCount?: number;
 }
 
 interface AdminDetectionCardProps {
@@ -42,6 +44,8 @@ export function AdminDetectionCard({ detection, onActionSuccess }: AdminDetectio
         return `${min}:${sec.toString().padStart(2, "0")}`;
     };
 
+    const isHighInterest = (detection.pledgeCount || 0) >= 5;
+
     return (
         <>
             <Card className="group overflow-hidden bg-card/40 backdrop-blur-md border-border/40 hover:ring-2 hover:ring-primary/50 transition-all">
@@ -58,15 +62,27 @@ export function AdminDetectionCard({ detection, onActionSuccess }: AdminDetectio
                             <ShieldCheck className="w-8 h-8 text-muted-foreground opacity-20" />
                         </div>
                     )}
-                    <div className="absolute top-2 left-2">
-                        <Badge variant="outline" className="bg-amber-500/20 border-amber-500/40 text-amber-500 backdrop-blur-sm flex items-center gap-1">
-                            <AlertTriangle className="w-3 h-3" /> Flagged
-                        </Badge>
+                    <div className="absolute top-2 left-2 flex flex-col gap-1.5">
+                        {detection.detection.status === "flagged" && (
+                            <Badge variant="outline" className="bg-amber-500/20 border-amber-500/40 text-amber-500 backdrop-blur-sm flex items-center gap-1 w-fit">
+                                <AlertTriangle className="w-3 h-3" /> Flagged
+                            </Badge>
+                        )}
+                        {isHighInterest && (
+                            <Badge variant="outline" className="bg-emerald-500/20 border-emerald-500/40 text-emerald-500 backdrop-blur-sm flex items-center gap-1 w-fit">
+                                <ShieldCheck className="w-3 h-3" /> High Interest
+                            </Badge>
+                        )}
                     </div>
-                    <div className="absolute top-2 right-2">
+                    <div className="absolute top-2 right-2 flex flex-col items-end gap-1.5">
                         <Badge variant="outline" className="bg-background/80 backdrop-blur-sm">
-                            {Math.round(detection.detection.confidenceScore * 100)}% Confidence
+                            {Math.round(detection.detection.confidenceScore * 100)}% Match
                         </Badge>
+                        {(detection.pledgeCount || 0) > 0 && (
+                            <Badge variant="outline" className="bg-primary/20 border-primary/40 text-primary-foreground backdrop-blur-sm font-bold">
+                                {detection.pledgeCount} Pledges
+                            </Badge>
+                        )}
                     </div>
                     <div className="absolute bottom-2 left-2 flex gap-2">
                         <Badge variant="secondary" className="bg-background/80 backdrop-blur-sm flex items-center gap-1">

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

@@ -31,20 +31,31 @@ interface AdminDetection {
         channelName: string;
     };
     marketplaceMatches: any[];
+    pledgeCount?: number;
 }
 
 interface AdminModerationQueueProps {
     initialDetections: AdminDetection[];
+    initialMinPledges?: number;
+    initialCategory?: string;
+    initialMinConfidence?: number;
 }
 
-export function AdminModerationQueue({ initialDetections }: AdminModerationQueueProps) {
+export function AdminModerationQueue({
+    initialDetections,
+    initialMinPledges = 0,
+    initialCategory = "all",
+    initialMinConfidence = 0
+}: AdminModerationQueueProps) {
     const [detections, setDetections] = useState(initialDetections);
-    const [filterCategory, setFilterCategory] = useState<string>("all");
-    const [minConfidence, setMinConfidence] = useState(0);
+    const [filterCategory, setFilterCategory] = useState<string>(initialCategory);
+    const [minConfidence, setMinConfidence] = useState(initialMinConfidence);
+    const [minPledges, setMinPledges] = useState(initialMinPledges);
 
     const filteredDetections = detections.filter(d =>
         (filterCategory === "all" || d.detection.category === filterCategory) &&
-        d.detection.confidenceScore >= minConfidence
+        d.detection.confidenceScore >= minConfidence &&
+        (d.pledgeCount || 0) >= minPledges
     );
 
     const categories = Array.from(new Set(initialDetections.map(d => d.detection.category)));
@@ -61,7 +72,7 @@ export function AdminModerationQueue({ initialDetections }: AdminModerationQueue
                     <div className="space-y-1">
                         <Label>Category</Label>
                         <Select value={filterCategory} onValueChange={setFilterCategory}>
-                            <SelectTrigger className="w-[180px]">
+                            <SelectTrigger className="w-[160px]">
                                 <SelectValue placeholder="All Categories" />
                             </SelectTrigger>
                             <SelectContent>
@@ -82,13 +93,26 @@ export function AdminModerationQueue({ initialDetections }: AdminModerationQueue
                             step="0.05"
                             value={minConfidence}
                             onChange={(e) => setMinConfidence(parseFloat(e.target.value))}
-                            className="w-[200px]"
+                            className="w-[150px]"
+                        />
+                    </div>
+
+                    <div className="space-y-1">
+                        <Label>Min Pledges ({minPledges})</Label>
+                        <Input
+                            type="range"
+                            min="0"
+                            max="20"
+                            step="1"
+                            value={minPledges}
+                            onChange={(e) => setMinPledges(parseInt(e.target.value))}
+                            className="w-[150px] accent-emerald-500"
                         />
                     </div>
                 </div>
 
-                <Button variant="outline" size="sm" onClick={() => { setFilterCategory("all"); setMinConfidence(0); }}>
-                    <RotateCcw className="w-4 h-4 mr-2" /> Reset Filters
+                <Button variant="outline" size="sm" onClick={() => { setFilterCategory("all"); setMinConfidence(0); setMinPledges(0); }}>
+                    <RotateCcw className="w-4 h-4 mr-2" /> Reset
                 </Button>
             </div>
 

src/features/moderation/services/admin-moderation.service.ts

@@ -5,8 +5,9 @@ import {
     youtubeVideos,
     youtubeChannels,
     adminModeration,
+    interestPledges,
 } from "@/lib/db/schema";
-import { eq, and, desc, sql, asc } from "drizzle-orm";
+import { eq, and, or, desc, sql, asc } from "drizzle-orm";
 
 export interface AdminQueueFilters {
     category?: string;
@@ -15,6 +16,8 @@ export interface AdminQueueFilters {
     sortOrder?: "asc" | "desc";
     limit?: number;
     offset?: number;
+    minPledges?: number;
+    status?: "flagged" | "pending_creator" | "live" | "rejected" | "all";
 }
 
 export class AdminModerationService {
@@ -26,6 +29,11 @@ export class AdminModerationService {
         const limit = filters?.limit || 20;
         const offset = filters?.offset || 0;
 
+        const pledgeCountSubquery = db.select({
+            detectedObjectId: interestPledges.detectedObjectId,
+            count: sql<number>`count(*)::int`.as('pledge_count')
+        }).from(interestPledges).groupBy(interestPledges.detectedObjectId).as('pc');
+
         const baseQuery = db
             .select({
                 detection: detectedObjects,
@@ -53,10 +61,11 @@ export class AdminModerationService {
             '[]'::json
           )
         `.as("marketplace_matches"),
+                pledgeCount: sql<number>`COALESCE(${pledgeCountSubquery.count}, 0)`.as("pledge_count"),
             })
             .from(detectedObjects)
-            .innerJoin(youtubeVideos, eq(detectedObjects.videoId, youtubeVideos.id))
-            .innerJoin(
+            .leftJoin(youtubeVideos, eq(detectedObjects.videoId, youtubeVideos.id))
+            .leftJoin(
                 youtubeChannels,
                 eq(youtubeVideos.channelId, youtubeChannels.id)
             )
@@ -64,9 +73,31 @@ export class AdminModerationService {
                 marketplaceMatches,
                 eq(detectedObjects.id, marketplaceMatches.objectId)
             )
+            .leftJoin(
+                pledgeCountSubquery,
+                eq(detectedObjects.id, pledgeCountSubquery.detectedObjectId)
+            )
             .where(
                 and(
-                    eq(detectedObjects.status, "flagged"),
+                    filters?.status && filters.status !== 'all'
+                        ? filters.status === 'flagged'
+                            ? and(
+                                or(eq(detectedObjects.status, 'flagged'), eq(detectedObjects.status, 'pending_review')),
+                                eq(detectedObjects.moderationStatus, 'PENDING')
+                            )
+                            : filters.status === 'pending_creator'
+                                ? and(eq(detectedObjects.status, 'approved'), eq(detectedObjects.moderationStatus, 'PENDING'))
+                                : filters.status === 'live'
+                                    ? eq(detectedObjects.moderationStatus, 'APPROVED')
+                                    : filters.status === 'rejected'
+                                        ? or(eq(detectedObjects.status, 'rejected'), eq(detectedObjects.moderationStatus, 'REJECTED'))
+                                        : undefined
+                        : !filters?.status
+                            ? or(
+                                and(eq(detectedObjects.status, 'flagged'), eq(detectedObjects.moderationStatus, 'PENDING')),
+                                sql`COALESCE(${pledgeCountSubquery.count}, 0) >= ${filters?.minPledges ?? 0}`
+                            )
+                            : undefined,
                     filters?.category ? eq(detectedObjects.category, filters.category as any) : undefined,
                     filters?.minConfidence
                         ? sql`${detectedObjects.confidenceScore} >= ${filters.minConfidence}`
@@ -76,7 +107,8 @@ export class AdminModerationService {
             .groupBy(
                 detectedObjects.id,
                 youtubeVideos.id,
-                youtubeChannels.id
+                youtubeChannels.id,
+                pledgeCountSubquery.count
             );
 
         // Sorting logic
@@ -93,9 +125,15 @@ export class AdminModerationService {
                     : desc(detectedObjects.createdAt);
         }
 
+        console.log('--- getAdminQueue Filters ---', filters);
         const queue = (await baseQuery.orderBy(orderBy).limit(limit).offset(offset)) as any[];
+        console.log('--- getAdminQueue Result Count ---', queue.length);
 
-        return queue;
+        return queue.map(item => ({
+            ...item,
+            video: item.video?.id ? item.video : { id: 'unknown', title: 'Unknown Video', thumbnailUrl: '' },
+            channel: item.channel?.creatorId ? item.channel : { creatorId: 'unknown', channelName: 'Unknown Creator' },
+        }));
     }
 
     /**
@@ -105,32 +143,39 @@ export class AdminModerationService {
         const flaggedCountResult = await db
             .select({ count: sql<number>`count(*)::int` })
             .from(detectedObjects)
-            .where(eq(detectedObjects.status, "flagged"));
-
-        const correctedTodayResult = await db
-            .select({ count: sql<number>`count(*)::int` })
-            .from(adminModeration)
             .where(
                 and(
-                    eq(adminModeration.action, "corrected"),
-                    sql`${adminModeration.createdAt} >= date_trunc('day', now())`
+                    or(eq(detectedObjects.status, 'flagged'), eq(detectedObjects.status, 'pending_review')),
+                    eq(detectedObjects.moderationStatus, 'PENDING')
                 )
             );
 
-        const incorrectTodayResult = await db
+        const pendingCreatorCountResult = await db
             .select({ count: sql<number>`count(*)::int` })
-            .from(adminModeration)
-            .where(
-                and(
-                    eq(adminModeration.action, "marked_incorrect"),
-                    sql`${adminModeration.createdAt} >= date_trunc('day', now())`
-                )
-            );
+            .from(detectedObjects)
+            .where(and(eq(detectedObjects.status, "approved"), eq(detectedObjects.moderationStatus, "PENDING")));
+
+        const liveCountResult = await db
+            .select({ count: sql<number>`count(*)::int` })
+            .from(detectedObjects)
+            .where(eq(detectedObjects.moderationStatus, "APPROVED"));
+
+        const rejectedCountResult = await db
+            .select({ count: sql<number>`count(*)::int` })
+            .from(detectedObjects)
+            .where(or(eq(detectedObjects.status, "rejected"), eq(detectedObjects.moderationStatus, "REJECTED")));
+
+        const totalCountResult = await db
+            .select({ count: sql<number>`count(*)::int` })
+            .from(detectedObjects)
+            .where(eq(detectedObjects.moderationStatus, "APPROVED"));
 
         return {
             flagged: flaggedCountResult[0]?.count || 0,
-            correctedToday: correctedTodayResult[0]?.count || 0,
-            markedIncorrectToday: incorrectTodayResult[0]?.count || 0,
+            pendingCreator: pendingCreatorCountResult[0]?.count || 0,
+            live: liveCountResult[0]?.count || 0,
+            rejected: rejectedCountResult[0]?.count || 0,
+            total: totalCountResult[0]?.count || 0,
         };
     }
 

src/features/vault/components/product-card.tsx

@@ -410,8 +410,9 @@ export function ProductCard({ product, priority = false, onTimestampClick, creat
           </Link>
         )}
 
-        {/* "I want this" as secondary option ONLY for IN_STOCK items with active AND valid affiliate links */}
-        {product.availabilityStatus === 'IN_STOCK' && product.linkStatus !== 'BROKEN' && product.affiliateUrl && (
+        {/* "I want this" as secondary option ONLY for items where we HAVE a match but NO affiliate link or a BROKEN one */}
+        {/* PM decision: If an active link already exists, we hide this to avoid confusing metrics */}
+        {product.availabilityStatus === 'IN_STOCK' && (product.linkStatus === 'BROKEN' || !product.affiliateUrl) && (
           <Button
             variant="outline"
             className="w-full"