diff --git a/api/src/base.ts b/api/src/base.ts index d6de2a49..abfd1d86 100644 --- a/api/src/base.ts +++ b/api/src/base.ts @@ -11,6 +11,7 @@ import { showsH } from "./controllers/shows/shows"; import { staffH } from "./controllers/staff"; import { studiosH } from "./controllers/studios"; import { videosH } from "./controllers/videos"; +import { watchlistH } from "./controllers/watchlist"; import type { KError } from "./models/error"; export const base = new Elysia({ name: "base" }) @@ -93,4 +94,5 @@ export const app = new Elysia({ prefix }) permissions: ["core.write"], }, (app) => app.use(videosH).use(seed), - ); + ) + .use(watchlistH); diff --git a/api/src/controllers/watchlist.ts b/api/src/controllers/watchlist.ts new file mode 100644 index 00000000..8a937134 --- /dev/null +++ b/api/src/controllers/watchlist.ts @@ -0,0 +1,123 @@ +import { and, isNotNull, isNull } from "drizzle-orm"; +import Elysia, { t } from "elysia"; +import { auth, getUserInfo } from "~/auth"; +import { shows } from "~/db/schema"; +import { KError } from "~/models/error"; +import { Show } from "~/models/show"; +import { + AcceptLanguage, + Filter, + Page, + createPage, + isUuid, + processLanguages, +} from "~/models/utils"; +import { desc } from "~/models/utils/descriptions"; +import { getShows, showFilters, showSort, watchStatusQ } from "./shows/logic"; + +export const watchlistH = new Elysia({ tags: ["profiles"] }) + .use(auth) + .guard({ + 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, + }), + ), + }), + response: { + 200: Page(Show), + 422: KError, + }, + }) + .get( + "/profiles/me/watchlist", + async ({ + query: { limit, after, query, sort, filter, preferOriginal }, + headers: { "accept-language": languages }, + request: { url }, + jwt: { sub }, + }) => { + const langs = processLanguages(languages); + const items = await getShows({ + limit, + after, + query, + sort, + filter: and( + isNotNull(watchStatusQ.status), + isNull(shows.collectionPk), + filter, + ), + languages: langs, + preferOriginal, + userId: sub, + }); + return createPage(items, { url, sort, limit }); + }, + { + detail: { description: "Get all movies/series in your watchlist" }, + headers: t.Object( + { + "accept-language": AcceptLanguage({ autoFallback: true }), + }, + { additionalProperties: true }, + ), + }, + ) + .get( + "/profiles/:id/watchlist", + async ({ + params: { id }, + query: { limit, after, query, sort, filter, preferOriginal }, + headers: { "accept-language": languages, authorization }, + request: { url }, + }) => { + if (!isUuid(id)) { + const uInfo = await getUserInfo(id, { authorization }); + id = uInfo.id; + } + + const langs = processLanguages(languages); + const items = await getShows({ + limit, + after, + query, + sort, + filter: and( + isNotNull(watchStatusQ.status), + isNull(shows.collectionPk), + filter, + ), + languages: langs, + preferOriginal, + userId: id, + }); + return createPage(items, { url, sort, limit }); + }, + { + detail: { description: "Get all movies/series in someone's watchlist" }, + params: t.Object({ + id: t.String({ + description: + "The id or username of the user to read the watchlist of", + example: "zoriya", + }), + }), + headers: t.Object({ + authorization: t.TemplateLiteral("Bearer ${string}"), + "accept-language": AcceptLanguage({ autoFallback: true }), + }), + permissions: ["users.read"], + }, + ); diff --git a/api/src/index.ts b/api/src/index.ts index 0926dc30..1769ddaf 100644 --- a/api/src/index.ts +++ b/api/src/index.ts @@ -61,6 +61,10 @@ new Elysia() name: "images", description: "Routes about images: posters, thumbnails...", }, + { + name: "profiles", + description: "Routes about user profiles, watchlist & history.", + }, ], components: { securitySchemes: {