[BOW-12][DB][3/3] YouTube stream creation

desktop/src/main/obsHelpers.test.ts

@@ -25,6 +25,8 @@ beforeAll(() => {
     rundowns: [],
     continuityItems: [],
     version: 1,
+    ytBroadcastID: null,
+    ytStreamID: null,
   });
 });
 
@@ -42,6 +44,7 @@ describe("addOrReplaceMediaAsScene", () => {
         order: 1,
         durationSeconds: 15,
         showId: 1,
+        ytBroadcastID: null,
       },
     ],
     durationSeconds: 15,

desktop/src/main/ontimeHelpers.test.ts

@@ -9,13 +9,16 @@ describe("ontimeHelpers", () => {
         name: "Test",
         start: new Date("2023-10-06T19:00:00+01:00"),
         version: 0,
+        ytBroadcastID: null,
+        ytStreamID: null,
         rundowns: [
           {
             id: 1,
             name: "Test Rundown",
             showId: 1,
             order: 1,
             assets: [],
+            ytBroadcastID: null,
             items: [
               {
                 id: 1,

jobrunner/src/jobrunner.integration.test.ts

@@ -5,9 +5,7 @@ import { integrate } from "@bowser/testing";
 
 integrate("doOneJob", () => {
   beforeEach(async () => {
-    await db.$executeRawUnsafe(
-      `TRUNCATE TABLE "base_jobs" RESTART IDENTITY CASCADE`,
-    );
+    await db.$executeRawUnsafe(`DELETE FROM "base_jobs"`);
   });
   it("works", async () => {
     await db.dummyTestJob.create({

jobrunner/src/jobs/ProcessMediaJob.integration.test.ts

@@ -48,12 +48,8 @@ async function uploadTestFileToTus() {
 
 integrate("ProcessMediaJob", () => {
   beforeEach(async () => {
-    await db.$executeRawUnsafe(
-      `TRUNCATE TABLE "base_jobs" RESTART IDENTITY CASCADE`,
-    );
-    await db.$executeRawUnsafe(
-      `TRUNCATE TABLE "shows" RESTART IDENTITY CASCADE`,
-    );
+    await db.$executeRawUnsafe(`DELETE FROM "base_jobs"`);
+    await db.$executeRawUnsafe(`DELETE FROM "shows"`);
   });
   it("works", async () => {
     const testMediaID = await uploadTestFileToTus();

server/app/api/__tests__/__snapshots__/shows.integration.test.ts.snap

@@ -6,5 +6,7 @@ exports[`shows listUpcoming returns upcoming shows 1`] = `
   "name": "Test Show",
   "start": Any<Date>,
   "version": 0,
+  "ytBroadcastID": null,
+  "ytStreamID": null,
 }
 `;

server/app/api/__tests__/shows.integration.test.ts

@@ -7,7 +7,7 @@ const api = appRouter.createCaller({});
 
 integrate("shows", () => {
   beforeEach(async () => {
-    await db.$executeRawUnsafe("TRUNCATE TABLE shows CASCADE");
+    await db.$executeRawUnsafe("DELETE FROM shows");
   });
   describe("listUpcoming", () => {
     it("returns nothing with no shows", async () => {

server/app/shows/[show_id]/actions.integration.test.ts

@@ -1,30 +1,32 @@
 import { db } from "@/lib/db";
 import { reorderShowItems } from "./actions";
 import { integrate } from "@bowser/testing";
+import { ContinuityItem, Rundown, Show } from "@bowser/prisma/client";
 
 jest.mock("server-only", () => ({}));
 jest.mock("next/cache", () => ({ revalidatePath: () => {} }));
 
 const TEST_TIME = new Date("2023-07-21T16:46:35.036Z");
 
 integrate("reorderShowItems", () => {
+  let testShow: Show & {
+    rundowns: Rundown[];
+    continuityItems: ContinuityItem[];
+  };
   beforeEach(async () => {
-    await db.$executeRawUnsafe("TRUNCATE TABLE shows RESTART IDENTITY CASCADE");
-    await db.show.create({
+    await db.$executeRawUnsafe("DELETE FROM shows");
+    testShow = await db.show.create({
       data: {
-        id: 1,
         name: "Test Show",
         start: TEST_TIME,
         rundowns: {
           createMany: {
             data: [
               {
-                id: 1,
                 name: "Test 1",
                 order: 0,
               },
               {
-                id: 2,
                 name: "Test 3",
                 order: 2,
               },
@@ -35,13 +37,11 @@ integrate("reorderShowItems", () => {
           createMany: {
             data: [
               {
-                id: 1,
                 name: "Test 2",
                 durationSeconds: 0,
                 order: 1,
               },
               {
-                id: 2,
                 name: "Test 4",
                 durationSeconds: 0,
                 order: 3,
@@ -50,135 +50,66 @@ integrate("reorderShowItems", () => {
           },
         },
       },
+      include: {
+        rundowns: true,
+        continuityItems: true,
+      },
     });
   });
 
   test("move 2 to 1", async () => {
-    await reorderShowItems(1, "continuity_item", 1, 0);
+    await reorderShowItems(
+      testShow.id,
+      "continuity_item",
+      testShow.continuityItems[0].id,
+      0,
+    );
     const newShow = await db.show.findFirstOrThrow({
-      where: { id: 1 },
+      where: { id: testShow.id },
       include: { rundowns: true, continuityItems: true },
     });
     const newItems = [...newShow.rundowns, ...newShow.continuityItems].sort(
       (a, b) => a.order - b.order,
     );
-    expect(newItems).toMatchInlineSnapshot(`
-      [
-        {
-          "durationSeconds": 0,
-          "id": 1,
-          "mediaId": null,
-          "name": "Test 2",
-          "order": 0,
-          "showId": 1,
-        },
-        {
-          "id": 1,
-          "name": "Test 1",
-          "order": 1,
-          "showId": 1,
-        },
-        {
-          "id": 2,
-          "name": "Test 3",
-          "order": 2,
-          "showId": 1,
-        },
-        {
-          "durationSeconds": 0,
-          "id": 2,
-          "mediaId": null,
-          "name": "Test 4",
-          "order": 3,
-          "showId": 1,
-        },
-      ]
-    `);
+    expect(newItems.map((x) => x.id)).toEqual([
+      testShow.continuityItems[0].id,
+      testShow.rundowns[0].id,
+      testShow.rundowns[1].id,
+      testShow.continuityItems[1].id,
+    ]);
   });
 
   test("move 3 to 1", async () => {
-    await reorderShowItems(1, "rundown", 2, 0);
+    await reorderShowItems(testShow.id, "rundown", testShow.rundowns[1].id, 0);
     const newShow = await db.show.findFirstOrThrow({
-      where: { id: 1 },
+      where: { id: testShow.id },
       include: { rundowns: true, continuityItems: true },
     });
     const newItems = [...newShow.rundowns, ...newShow.continuityItems].sort(
       (a, b) => a.order - b.order,
     );
-    expect(newItems).toMatchInlineSnapshot(`
-      [
-        {
-          "id": 2,
-          "name": "Test 3",
-          "order": 0,
-          "showId": 1,
-        },
-        {
-          "id": 1,
-          "name": "Test 1",
-          "order": 1,
-          "showId": 1,
-        },
-        {
-          "durationSeconds": 0,
-          "id": 1,
-          "mediaId": null,
-          "name": "Test 2",
-          "order": 2,
-          "showId": 1,
-        },
-        {
-          "durationSeconds": 0,
-          "id": 2,
-          "mediaId": null,
-          "name": "Test 4",
-          "order": 3,
-          "showId": 1,
-        },
-      ]
-    `);
+    expect(newItems.map((x) => x.id)).toEqual([
+      testShow.rundowns[1].id,
+      testShow.rundowns[0].id,
+      testShow.continuityItems[0].id,
+      testShow.continuityItems[1].id,
+    ]);
   });
 
   test("move 1 to 4", async () => {
-    await reorderShowItems(1, "rundown", 1, 3);
+    await reorderShowItems(testShow.id, "rundown", testShow.rundowns[0].id, 3);
     const newShow = await db.show.findFirstOrThrow({
-      where: { id: 1 },
+      where: { id: testShow.id },
       include: { rundowns: true, continuityItems: true },
     });
     const newItems = [...newShow.rundowns, ...newShow.continuityItems].sort(
       (a, b) => a.order - b.order,
     );
-    expect(newItems).toMatchInlineSnapshot(`
-      [
-        {
-          "durationSeconds": 0,
-          "id": 1,
-          "mediaId": null,
-          "name": "Test 2",
-          "order": 0,
-          "showId": 1,
-        },
-        {
-          "id": 2,
-          "name": "Test 3",
-          "order": 1,
-          "showId": 1,
-        },
-        {
-          "durationSeconds": 0,
-          "id": 2,
-          "mediaId": null,
-          "name": "Test 4",
-          "order": 2,
-          "showId": 1,
-        },
-        {
-          "id": 1,
-          "name": "Test 1",
-          "order": 3,
-          "showId": 1,
-        },
-      ]
-    `);
+    expect(newItems.map((x) => x.id)).toEqual([
+      testShow.continuityItems[0].id,
+      testShow.rundowns[1].id,
+      testShow.continuityItems[1].id,
+      testShow.rundowns[0].id,
+    ]);
   });
 });