mirror of
https://github.com/zoriya/Kyoo.git
synced 2026-01-08 05:00:37 -05:00
116 lines
2.5 KiB
TypeScript
116 lines
2.5 KiB
TypeScript
import { and, isNull, sql } from "drizzle-orm";
|
|
import { Elysia, t } from "elysia";
|
|
import { db } from "~/db";
|
|
import { shows } from "~/db/schema";
|
|
import { KError } from "~/models/error";
|
|
import { Show } from "~/models/show";
|
|
import {
|
|
AcceptLanguage,
|
|
Filter,
|
|
Page,
|
|
createPage,
|
|
processLanguages,
|
|
} from "~/models/utils";
|
|
import { desc } from "~/models/utils/descriptions";
|
|
import { getShows, showFilters, showSort } from "./logic";
|
|
|
|
export const showsH = new Elysia({ prefix: "/shows", tags: ["shows"] })
|
|
.model({
|
|
show: Show,
|
|
})
|
|
.get(
|
|
"random",
|
|
async ({ error, redirect }) => {
|
|
const [show] = await db
|
|
.select({ kind: shows.kind, slug: shows.slug })
|
|
.from(shows)
|
|
.orderBy(sql`random()`)
|
|
.limit(1);
|
|
if (!show)
|
|
return error(404, {
|
|
status: 404,
|
|
message: "No shows in the database.",
|
|
});
|
|
return redirect(`/${show.kind}s/${show.slug}`);
|
|
},
|
|
{
|
|
detail: {
|
|
description: "Get a random movie/serie/collection",
|
|
},
|
|
response: {
|
|
302: t.Void({
|
|
description: "Redirected to the appropriate get endpoint.",
|
|
}),
|
|
404: {
|
|
...KError,
|
|
description: "No show in the database.",
|
|
},
|
|
},
|
|
},
|
|
)
|
|
.get(
|
|
"",
|
|
async ({
|
|
query: {
|
|
limit,
|
|
after,
|
|
query,
|
|
sort,
|
|
filter,
|
|
preferOriginal,
|
|
ignoreInCollection,
|
|
},
|
|
headers: { "accept-language": languages },
|
|
request: { url },
|
|
}) => {
|
|
const langs = processLanguages(languages);
|
|
const items = await getShows({
|
|
limit,
|
|
after,
|
|
query,
|
|
sort,
|
|
filter: and(
|
|
ignoreInCollection ? isNull(shows.collectionPk) : undefined,
|
|
filter,
|
|
),
|
|
languages: langs,
|
|
preferOriginal,
|
|
});
|
|
return createPage(items, { url, sort, limit });
|
|
},
|
|
{
|
|
detail: { description: "Get all movies/series/collections" },
|
|
query: t.Object({
|
|
sort: showSort,
|
|
filter: t.Optional(Filter({ def: showFilters })),
|
|
query: t.Optional(t.String({ description: desc.query })),
|
|
limit: t.Integer({
|
|
minimum: 1,
|
|
maximum: 250,
|
|
default: 50,
|
|
description: "Max page size.",
|
|
}),
|
|
after: t.Optional(t.String({ description: desc.after })),
|
|
preferOriginal: t.Optional(
|
|
t.Boolean({
|
|
description: desc.preferOriginal,
|
|
}),
|
|
),
|
|
ignoreInCollection: t.Optional(
|
|
t.Boolean({
|
|
description:
|
|
"If a movie or serie is part of collection, don't return it.",
|
|
default: true,
|
|
}),
|
|
),
|
|
}),
|
|
headers: t.Object({
|
|
"accept-language": AcceptLanguage({ autoFallback: true }),
|
|
}),
|
|
response: {
|
|
200: Page(Show),
|
|
422: KError,
|
|
},
|
|
},
|
|
);
|