Test POST /videos

api/src/controllers/videos.ts

@@ -7,11 +7,10 @@ import {
 	conflictUpdateAllExcept,
 	jsonbBuildObject,
 	jsonbObjectAgg,
-	sqlarr,
 	values,
 } from "~/db/utils";
 import { bubbleVideo } from "~/models/examples";
-import { Page, isUuid } from "~/models/utils";
+import { isUuid } from "~/models/utils";
 import { Guesses, SeedVideo, Video } from "~/models/video";
 import { comment } from "~/utils";
 import { computeVideoSlug } from "./seed/insert/entries";
@@ -138,10 +137,11 @@ export const videosH = new Elysia({ prefix: "/videos", tags: ["videos"] })
 						})
 						.from(
 							values(
-								body.flatMap((x) =>
-									x.for.map((e) => ({
+								body.flatMap((x) => {
+									if (!x.for) return [];
+									return x.for.map((e) => ({
 										path: x.path,
-										needRendering: x.for.length > 1,
+										needRendering: x.for!.length > 1,
 										entry: {
 											...e,
 											movie:
@@ -157,8 +157,8 @@ export const videosH = new Elysia({ prefix: "/videos", tags: ["videos"] })
 														: { slug: e.serie }
 													: undefined,
 										},
-									})),
-								),
+									}));
+								}),
 							).as("j"),
 						)
 						.innerJoin(vidsI, eq(vidsI.path, sql`j.path`))

api/src/db/utils.ts

@@ -103,7 +103,10 @@ export const nullif = <T>(val: SQL<T> | Column, eq: SQL<T>) => {
 	return sql<T>`nullif(${val}, ${eq})`;
 };
 
-export const jsonbObjectAgg = <T>(key: SQLWrapper, value: SQL<T> | SQLWrapper) => {
+export const jsonbObjectAgg = <T>(
+	key: SQLWrapper,
+	value: SQL<T> | SQLWrapper,
+) => {
 	return sql<
 		Record<string, T>
 	>`jsonb_object_agg(${sql.join([key, value], sql.raw(","))})`;

api/src/models/video.ts

@@ -68,44 +68,47 @@ export const SeedVideo = t.Object({
 
 	guess: Guess,
 
-	for: t.Array(
-		t.Union([
-			t.Object({
-				slug: t.String({
-					format: "slug",
-					examples: ["made-in-abyss-dawn-of-the-deep-soul"],
-				}),
-			}),
-			t.Object({
-				externalId: t.Optional(t.Union([EpisodeId, ExternalId()])),
-			}),
-			t.Object({
-				movie: t.Union([
-					t.String({ format: "uuid" }),
-					t.String({ format: "slug", examples: ["bubble"] }),
-				]),
-			}),
-			t.Intersect([
+	for: t.Optional(
+		t.Array(
+			t.Union([
 				t.Object({
-					serie: t.Union([
+					slug: t.String({
+						format: "slug",
+						examples: ["made-in-abyss-dawn-of-the-deep-soul"],
+					}),
+				}),
+				t.Object({
+					externalId: t.Optional(t.Union([EpisodeId, ExternalId()])),
+				}),
+				t.Object({
+					movie: t.Union([
 						t.String({ format: "uuid" }),
-						t.String({ format: "slug", examples: ["made-in-abyss"] }),
+						t.String({ format: "slug", examples: ["bubble"] }),
 					]),
 				}),
-				t.Union([
+				t.Intersect([
 					t.Object({
-						season: t.Integer({ minimum: 1 }),
-						episode: t.Integer(),
-					}),
-					t.Object({
-						order: t.Number(),
-					}),
-					t.Object({
-						special: t.Integer(),
+						serie: t.Union([
+							t.String({ format: "uuid" }),
+							t.String({ format: "slug", examples: ["made-in-abyss"] }),
+						]),
 					}),
+					t.Union([
+						t.Object({
+							season: t.Integer({ minimum: 1 }),
+							episode: t.Integer(),
+						}),
+						t.Object({
+							order: t.Number(),
+						}),
+						t.Object({
+							special: t.Integer(),
+						}),
+					]),
 				]),
 			]),
-		]),
+			{ default: [] },
+		),
 	),
 });
 export type SeedVideo = Prettify<typeof SeedVideo.static>;

api/tests/videos/scanner.test.ts

@@ -0,0 +1,50 @@
+import { beforeAll, describe, expect, it } from "bun:test";
+import { eq } from "drizzle-orm";
+import { createVideo } from "tests/helpers";
+import { expectStatus } from "tests/utils";
+import { db } from "~/db";
+import { entries, shows, videos } from "~/db/schema";
+
+beforeAll(async () => {
+	await db.delete(shows);
+	await db.delete(entries);
+	await db.delete(videos);
+});
+
+describe("Video seeding", () => {
+	it("Can create a video without entry", async () => {
+		const [resp, body] = await createVideo({
+			guess: { title: "mia", from: "test" },
+			part: null,
+			path: "/video/mia s1e13.mkv",
+			rendering: "sha",
+			version: 1,
+		});
+
+		expectStatus(resp, body).toBe(201);
+		expect(body).toBeArrayOfSize(1);
+		expect(body[0].id).toBeString();
+
+		const vid = await db.query.videos.findFirst({
+			where: eq(videos.id, body[0].id),
+			with: {
+				evj: { with: { entry: true } },
+			},
+		});
+
+		expect(vid).not.toBeNil();
+		expect(vid!.path).toBe("/video/mia s1e13.mkv");
+		expect(vid!.guess).toBe({ title: "mia", from: "test" });
+
+		expect(body[0].slug).toBe("mia");
+		// videos created without entries should create an /unknown entry.
+		expect(vid!.evj).toBeArrayOfSize(1);
+		expect(vid!.evj[0].slug).toBe("mia");
+		expect(vid!.evj[0].entry).toMatchObject({
+			kind: "unknown",
+			name: "mia",
+			// should we store the video path in the unknown entry?
+			// in db it would be the `description` field
+		});
+	});
+});