Cutlery/Kyoo
1
0
Fork 0
mirror of https://github.com/zoriya/Kyoo.git synced 2025-05-31 04:04:21 -04:00
Code Issues Packages Projects Releases Wiki Activity

Fix entries insertion (special numbers not saved)

Browse Source
This commit is contained in:
Zoe Roux 2025-01-28 12:33:53 +01:00
parent b0637aeb6a
commit e9c7cfe832
No known key found for this signature in database
3 changed files with 15 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
api/src/controllers/seed/insert/entries.ts
View File

@ -1,4 +1,4 @@
import { type SQL, eq, sql } from "drizzle-orm"; import { type Column, type SQL, eq, sql } from "drizzle-orm";
import { db } from "~/db"; import { db } from "~/db";
import { import {
entries, entries,
@ -11,6 +11,8 @@ import type { SeedEntry } from "~/models/entry";
import { processOptImage } from "../images"; import { processOptImage } from "../images";
import { guessNextRefresh } from "../refresh"; import { guessNextRefresh } from "../refresh";
type EntryI = typeof entries.$inferInsert;
const generateSlug = (showSlug: string, entry: SeedEntry): string => { const generateSlug = (showSlug: string, entry: SeedEntry): string => {
switch (entry.kind) { switch (entry.kind) {
case "episode": case "episode":
@ -27,14 +29,20 @@ export const insertEntries = async (
items: SeedEntry[], items: SeedEntry[],
) => { ) => {
const retEntries = await db.transaction(async (tx) => { const retEntries = await db.transaction(async (tx) => {
const vals = items.map((seed) => { const vals: EntryI[] = items.map((seed) => {
const { translations, videos, ...entry } = seed; const { translations, videos, ...entry } = seed;
return { return {
...entry, ...entry,
showPk: show.pk, showPk: show.pk,
slug: generateSlug(show.slug, seed), slug: generateSlug(show.slug, seed),
thumbnails: processOptImage(seed.thumbnail), thumbnail: processOptImage(seed.thumbnail),
nextRefresh: guessNextRefresh(entry.airDate ?? new Date()), nextRefresh: guessNextRefresh(entry.airDate ?? new Date()),
episodeNumber:
entry.kind === "episode"
? entry.episodeNumber
: entry.kind === "special"
? entry.number
: undefined,
}; };
}); });
const ret = await tx const ret = await tx
@ -111,10 +119,10 @@ export const insertEntries = async (
})); }));
}; };
export function computeVideoSlug(showSlug: SQL, needsRendering: SQL) { export function computeVideoSlug(showSlug: SQL | Column, needsRendering: SQL) {
return sql<string>` return sql<string>`
concat( concat(
${showSlug}::text, ${showSlug},
case when ${videos.part} is not null then ('-p' || ${videos.part}) else '' end, case when ${videos.part} is not null then ('-p' || ${videos.part}) else '' end,
case when ${videos.version} <> 1 then ('-v' || ${videos.version}) else '' end, case when ${videos.version} <> 1 then ('-v' || ${videos.version}) else '' end,
case when ${needsRendering} then concat('-', ${videos.rendering}) else '' end case when ${needsRendering} then concat('-', ${videos.rendering}) else '' end

2
api/src/db/schema/entries.ts
View File

@ -63,7 +63,7 @@ export const entries = schema.table(
extraKind: text(), extraKind: text(),
airDate: date(), airDate: date(),
runtime: integer(), runtime: integer(),
thumbnails: image(), thumbnail: image(),
externalId: entry_extid(), externalId: entry_extid(),

2
api/src/db/schema/videos.ts
View File

@ -34,7 +34,7 @@ export const videos = schema.table(
); );
export const entryVideoJoin = schema.table( export const entryVideoJoin = schema.table(
"entry_video_jointure", "entry_video_join",
{ {
entry: integer() entry: integer()
.notNull() .notNull()