feat: add local QA initialization for clips, playlists, queues, and their resources

mitchdowney · mitchdowney · commit e40b8b762a40 · 2025-10-24T20:52:30.000-05:00
diff --git a/Makefile b/Makefile
@@ -1,6 +1,10 @@
 local_qa_init_data:
 	npm run faker local create/feeds-channels-items
 	npm run faker local create/accounts/accounts
+	npm run faker local create/clips/clips
 	npm run faker local create/playlists/playlists
+	npm run faker local create/playlists/playlistResources
+	npm run faker local create/queues/queues
+	npm run faker local create/queues/queueResources
 	npm run faker local create/stats/statsAggregated
 	npm run faker local create/accounts/accountFollowings
diff --git a/src/faker/create/clips/clips.ts b/src/faker/create/clips/clips.ts
@@ -0,0 +1,49 @@
+import { AccountService, ClipService, ItemService } from 'podverse-orm';
+import { MediumEnum, SharableStatusEnum } from 'podverse-helpers';
+import { FAKER } from '../../constants';
+
+export default async function () {
+  const accountService = new AccountService();
+  const clipService = new ClipService();
+  const itemService = new ItemService();
+
+  const sharableStatuses = [
+    SharableStatusEnum.Public,
+    SharableStatusEnum.Unlisted,
+    SharableStatusEnum.Private
+  ];
+
+  for (const acc of FAKER.ACCOUNTS) {
+    try {
+      const createdAccount = await accountService.getByEmail(acc.email);
+      if (!createdAccount) throw new Error('Account not found after creation');
+
+      for (let i = 0; i < 30; i++) {
+        const medium_id = i % 2 === 0 ? MediumEnum.Podcast : MediumEnum.Video;
+        const item = await itemService.getRandomItem(medium_id);
+
+
+        const maxTime = 600;
+        const minDuration = 15;
+        const setEndTime = Math.random() < 0.75;
+        const start_time = Math.floor(Math.random() * (maxTime - minDuration));
+        let end_time: number | undefined = undefined;
+        if (setEndTime) {
+          const maxEnd = Math.min(start_time + minDuration + Math.floor(Math.random() * (maxTime - start_time - minDuration)), maxTime);
+          end_time = Math.max(start_time + minDuration, maxEnd);
+        }
+
+        await clipService.create(createdAccount.id, {
+          title: `Clip ${i + 1} for ${acc.email} with status ${sharableStatuses[i % sharableStatuses.length]}`,
+          description: `Auto-generated clip #${i + 1} for ${acc.email} with status ${sharableStatuses[i % sharableStatuses.length]}`,
+          item_id_text: item.id_text,
+          sharable_status_id: sharableStatuses[i % sharableStatuses.length],
+          start_time: start_time.toString(),
+          ...(end_time !== undefined ? { end_time: end_time.toString() } : {})
+        });
+      }
+    } catch (err) {
+      console.error(`Error creating account ${acc.email}:`, err);
+    }
+  }
+}
diff --git a/src/faker/create/playlists/playlistResources.ts b/src/faker/create/playlists/playlistResources.ts
@@ -0,0 +1,47 @@
+import { AccountService, ClipService, ItemService, ItemSoundbiteService,
+  PlaylistResourceService, PlaylistService } from 'podverse-orm';
+import { FAKER } from '../../constants';
+
+export default async function () {
+  const accountService = new AccountService();
+  const clipService = new ClipService();
+  const itemService = new ItemService();
+  const itemSoundbiteService = new ItemSoundbiteService();
+  const playlistService = new PlaylistService();
+  const playlistResourceService = new PlaylistResourceService();
+  
+  for (const acc of FAKER.ACCOUNTS) {
+    try {
+      const createdAccount = await accountService.getByEmail(acc.email);
+      if (!createdAccount) throw new Error('Account not found after creation');
+
+      const playlistsResponse = await playlistService.getManyPrivate(createdAccount.id);
+      const playlists = playlistsResponse[0];
+
+      for (const playlist of playlists) {
+        if (playlist) {
+          for (let i = 0; i < 50; i++) {
+            if (i % 3 === 0) {
+              const item = await itemService.getRandomItem(playlist.medium_id);
+              if (item) {
+                await playlistResourceService.addItemToPlaylistFirst(playlist.id_text, item.id_text);
+              }
+            } else if (i % 3 === 1) {
+              const clip = await clipService.getRandomClip(playlist.medium_id);
+              if (clip) {
+                await playlistResourceService.addClipToPlaylistFirst(playlist.id_text, clip.id_text);
+              }
+            } else {
+              const itemSoundbite = await itemSoundbiteService.getRandomItemSoundbite(playlist.medium_id);
+              if (itemSoundbite) {
+                await playlistResourceService.addItemSoundbiteToPlaylistFirst(playlist.id_text, itemSoundbite.id_text);
+              }
+            }
+          }
+        }
+      }
+    } catch (err) {
+      console.error(`Error creating queues:`, err);
+    }
+  }
+}
diff --git a/src/faker/create/queues/queueResources.ts b/src/faker/create/queues/queueResources.ts
@@ -0,0 +1,96 @@
+import { AccountService, ClipService, ItemService, ItemSoundbiteService,
+  QueueResourceService, QueueService} from 'podverse-orm';
+import { FAKER } from '../../constants';
+
+export default async function () {
+  const accountService = new AccountService();
+  const clipService = new ClipService();
+  const itemService = new ItemService();
+  const itemSoundbiteService = new ItemSoundbiteService();
+  const queueService = new QueueService();
+  const queueResourceService = new QueueResourceService();
+  
+  for (const acc of FAKER.ACCOUNTS) {
+    try {
+      const createdAccount = await accountService.getByEmail(acc.email);
+      if (!createdAccount) throw new Error('Account not found after creation');
+
+      const queues = await queueService.getAllPrivate(createdAccount.id);
+      for (const queue of queues) {
+        if (queue) {
+          for (let i = 0; i < 50; i++) {
+            try {
+              if (i % 3 === 0) {
+                const item = await itemService.getRandomItem(queue.medium_id);
+                if (item) {
+                  await queueResourceService.addItemToQueueNext(queue.id_text, item.id_text);
+                }
+              } else if (i % 3 === 1) {
+                const clip = await clipService.getRandomClip(queue.medium_id);
+                if (clip) {
+                  await queueResourceService.addClipToQueueNext(queue.id_text, clip.id_text);
+                }
+              } else {
+                const itemSoundbite = await itemSoundbiteService.getRandomItemSoundbite(queue.medium_id);
+                if (itemSoundbite) {
+                  await queueResourceService.addItemSoundbiteToQueueNext(queue.id_text, itemSoundbite.id_text);
+                }
+              }
+            } catch (err) {
+              console.log('Error adding to queue:', err);
+            }
+          }
+
+          for (let i = 0; i < 50; i++) {
+            try {
+              if (i % 3 === 0) {
+                const item = await itemService.getRandomItem(queue.medium_id);
+                if (item) {
+                  await queueResourceService.addItemToHistory(
+                    queue.id_text,
+                    item.id_text,
+                    {
+                      playback_position: (Math.floor(Math.random() * 600)).toString(),
+                      media_file_duration: (600 + Math.floor(Math.random() * 600)).toString(),
+                      completed: Math.random() < 0.5
+                    }
+                  );
+                }
+              } else if (i % 3 === 1) {
+                const clip = await clipService.getRandomClip(queue.medium_id);
+                if (clip) {
+                  await queueResourceService.addClipToHistory(
+                    queue.id_text,
+                    clip.id_text,
+                    {
+                      playback_position: (Math.floor(Math.random() * 300)).toString(),
+                      media_file_duration: (300 + Math.floor(Math.random() * 300)).toString(),
+                      completed: Math.random() < 0.5
+                    }
+                  );
+                }
+              } else {
+                const itemSoundbite = await itemSoundbiteService.getRandomItemSoundbite(queue.medium_id);
+                if (itemSoundbite) {
+                  await queueResourceService.addItemSoundbiteToHistory(
+                    queue.id_text,
+                    itemSoundbite.id_text,
+                    {
+                      playback_position: (Math.floor(Math.random() * 120)).toString(),
+                      media_file_duration: (120 + Math.floor(Math.random() * 120)).toString(),
+                      completed: Math.random() < 0.5
+                    }
+                  );
+                }
+              } 
+            } catch (err) {
+              console.log('Error adding to history:', err);
+            }     
+          }
+        }
+      }
+    } catch (err) {
+      console.error(`Error creating queues:`, err);
+    }
+  }
+}
diff --git a/src/faker/create/queues/queues.ts b/src/faker/create/queues/queues.ts
@@ -0,0 +1,18 @@
+import { AccountService, QueueService } from 'podverse-orm';
+import { FAKER } from '../../constants';
+
+export default async function () {
+  const accountService = new AccountService();
+  const queueService = new QueueService();
+  
+  for (const acc of FAKER.ACCOUNTS) {
+    try {
+      const createdAccount = await accountService.getByEmail(acc.email);
+      if (!createdAccount) throw new Error('Account not found after creation');
+
+      await queueService.getAllPrivate(createdAccount.id);
+    } catch (err) {
+      console.error(`Error creating queues:`, err);
+    }
+  }
+}
