feat: Introduce database utility scripts, refactor video product retrieval, and ensure correct creator slug usage in the showcase service.

check-slugs.ts

@@ -0,0 +1,35 @@
+import { db } from './src/lib/db';
+import { youtubeChannels, youtubeVideos } from './src/lib/db/schema';
+import { eq } from 'drizzle-orm';
+
+async function check() {
+    try {
+        console.log('Fetching all channels...');
+        const channels = await db.select().from(youtubeChannels);
+        console.log('Channels found:', channels.length);
+        channels.forEach(c => {
+            console.log(`- Slug: ${c.creatorSlug}, ID: ${c.id}, Creator: ${c.creatorId}`);
+        });
+
+        const videoId = 'XSa42Zz_vps';
+        console.log(`\nChecking video associations for: ${videoId}`);
+        const videos = await db.select({
+            video: youtubeVideos,
+            channel: youtubeChannels
+        })
+            .from(youtubeVideos)
+            .innerJoin(youtubeChannels, eq(youtubeVideos.channelId, youtubeChannels.id))
+            .where(eq(youtubeVideos.videoId, videoId));
+
+        console.log('Video records found:', videos.length);
+        videos.forEach(v => {
+            console.log(`- Video Record ID: ${v.video.id}, Channel Slug: ${v.channel.creatorSlug}, Channel ID: ${v.channel.id}`);
+        });
+
+    } catch (err) {
+        console.error('Check failed:', err);
+    }
+    process.exit(0);
+}
+
+check();

db-check.ts

@@ -0,0 +1,29 @@
+import { db } from './src/lib/db';
+import { youtubeChannels, youtubeVideos } from './src/lib/db/schema';
+import { eq, and } from 'drizzle-orm';
+
+async function check() {
+    try {
+        const videoId = 'XSa42Zz_vps';
+        console.log(`Checking video: ${videoId}`);
+
+        const results = await db
+            .select({
+                id: youtubeVideos.id,
+                videoId: youtubeVideos.videoId,
+                channelId: youtubeVideos.channelId,
+                creatorSlug: youtubeChannels.creatorSlug,
+                creatorId: youtubeChannels.creatorId
+            })
+            .from(youtubeVideos)
+            .innerJoin(youtubeChannels, eq(youtubeVideos.channelId, youtubeChannels.id))
+            .where(eq(youtubeVideos.videoId, videoId));
+
+        console.log('Results:', JSON.stringify(results, null, 2));
+    } catch (err) {
+        console.error('Error:', err);
+    }
+    process.exit(0);
+}
+
+check();

src/features/vault/services/showcase.service.ts

@@ -94,7 +94,6 @@ export class ShowcaseService {
         const channel = videoResult[0]?.channel;
 
         if (video && channel) {
-            console.log(`[getShowcaseVault] Found video record: ${video.id} (scanStatus: ${video.scanStatus})`);
             // Attach channel for the 'with' equivalent
             const videoWithChannel = { ...video, channel };
             // Self-healing: If subscriberCount is missing or 0, trigger a background refresh
@@ -230,7 +229,7 @@ export class ShowcaseService {
                             channelName: channel.creatorId === DEMO_USER_ID ? channel.channelName : publicData.vault.channel.channelName,
                             subscriberCount: channel.creatorId === DEMO_USER_ID ? channel.subscriberCount : publicData.vault.channel.subscriberCount,
                             thumbnailUrl: channel.creatorId === DEMO_USER_ID ? channel.thumbnailUrl : publicData.vault.channel.thumbnailUrl,
-                            creatorSlug: channel.creatorId === DEMO_USER_ID ? channel.creatorSlug : `demo-${publicData.vault.channel.channelName.toLowerCase().replace(/[^a-z0-9]+/g, '-')}`,
+                            creatorSlug: channel.creatorSlug, // CRITICAL: Use the real DB slug for routing
                             creatorId: channel.creatorId,
                         },
                         videos: [{
@@ -297,7 +296,11 @@ export class ShowcaseService {
      * @param videoId - The YouTube video ID
      * @param userId - Optional user ID to resolve the correct record in multi-tenant scenarios
      */
-    static async getShowcaseModerationQueue(videoId: string, userId?: string) {
+    static async getVideoProducts(videoId: string, creatorSlug?: string) {
+        // Build where conditions
+        const whereConditions = [
+            sql`${youtubeVideos.id} = ${videoId} OR ${youtubeVideos.videoId} = ${videoId}`
+        ];
         const videoResult = await db
             .select({
                 video: youtubeVideos,

src/features/vault/services/vault.service.ts

@@ -642,6 +642,7 @@ export class VaultService {
    * @param creatorSlug - Optional creator slug to resolve the correct record in multi-tenant scenarios
    */
   static async getVideoProducts(videoId: string, creatorSlug?: string) {
+    console.log(`[getVideoProducts] videoId: ${videoId}, creatorSlug: ${creatorSlug}`);
     // Build where conditions
     const whereConditions = [
       sql`${youtubeVideos.id} = ${videoId} OR ${youtubeVideos.videoId} = ${videoId}`