feat: better cache some stuff

routes/api/movies/enhance/[name].ts

@@ -1,62 +1,35 @@
 import { HandlerContext, Handlers } from "$fresh/server.ts";
-import {
-  createDocument,
-  getDocument,
-  transformDocument,
-} from "@lib/documents.ts";
+import { createDocument } from "@lib/documents.ts";
 import { fileExtension } from "https://deno.land/x/file_extension@v2.1.0/mod.ts";
-import { getMovie, type Movie } from "@lib/resource/movies.ts";
+import { createMovie, getMovie } from "@lib/resource/movies.ts";
 import * as tmdb from "@lib/tmdb.ts";
-import { parse, stringify } from "https://deno.land/std@0.194.0/yaml/mod.ts";
-import { formatDate, safeFileName } from "@lib/string.ts";
+import { safeFileName } from "@lib/string.ts";
 import { json } from "@lib/helpers.ts";
-import { AccessDeniedError, BadRequestError } from "@lib/errors.ts";
+import {
+  AccessDeniedError,
+  BadRequestError,
+  NotFoundError,
+} from "@lib/errors.ts";
+import * as cache from "@lib/cache/cache.ts";
 
-async function updateMovieMetadata(
-  name: string,
-  metadata: Partial<Movie["meta"]>,
-) {
-  const docId = `Media/movies/${name}.md`;
-
-  let currentDoc = await getDocument(docId);
-  if (!currentDoc) return;
-
-  if (!currentDoc.startsWith("---\n---\n")) {
-    currentDoc = `---\n---\n\n${currentDoc}`;
-  }
-
-  const newDoc = transformDocument(currentDoc, (root) => {
-    const frontmatterNode = root.children.find((c) => c.type === "yaml");
-
-    const frontmatter = frontmatterNode?.value as string;
-
-    const value = parse(frontmatter) as Movie["meta"];
-
-    const newValue = {
-      ...metadata,
-      date: formatDate(metadata.date),
-      ...value,
-    };
-
-    frontmatterNode.value = stringify(newValue);
-
-    return root;
-  });
-
-  return createDocument(docId, newDoc);
-}
+const isString = (input: string | undefined): input is string => {
+  return typeof input === "string";
+};
 
 const POST = async (
   req: Request,
   ctx: HandlerContext,
 ): Promise<Response> => {
-  const movie = await getMovie(ctx.params.name);
-
   const session = ctx.state.session;
   if (!session) {
     throw new AccessDeniedError();
   }
 
+  const movie = await getMovie(ctx.params.name);
+  if (!movie) {
+    throw new NotFoundError();
+  }
+
   const body = await req.json();
   const name = ctx.params.name;
   const { tmdbId } = body;
@@ -69,33 +42,41 @@ const POST = async (
     await tmdb.getMovieCredits(tmdbId);
 
   const releaseDate = movieDetails.release_date;
-  const posterPath = movieDetails.poster_path;
+  if (releaseDate && !movie.meta.date) {
+    movie.meta.date = new Date(releaseDate);
+  }
+
   const director =
     movieCredits?.crew?.filter?.((person) => person.job === "Director")[0];
+  if (director && !movie.meta.author) {
+    movie.meta.author = director.name;
+  }
+
+  if (movieDetails.genres) {
+    movie.tags = [
+      ...new Set([
+        ...movie.tags.map((g) => g.toLowerCase()),
+        ...movieDetails.genres.map((g) => g.name?.toLowerCase()),
+      ].filter(isString)),
+    ];
+  }
 
   let finalPath = "";
+  const posterPath = movieDetails.poster_path;
   if (posterPath && !movie.meta.image) {
     const poster = await tmdb.getMoviePoster(posterPath);
     const extension = fileExtension(posterPath);
 
     finalPath = `Media/movies/images/${safeFileName(name)}_cover.${extension}`;
     await createDocument(finalPath, poster);
+    movie.meta.image = finalPath;
   }
 
-  const metadata = {} as Movie["meta"];
-  if (releaseDate) {
-    metadata.date = new Date(releaseDate);
-  }
-  if (finalPath) {
-    metadata.image = finalPath;
-  }
-  if (director) {
-    metadata.author = director.name;
-  }
+  await createMovie(movie);
 
-  await updateMovieMetadata(name, metadata);
+  cache.del(`documents:Media:movies:${name}.md`);
 
-  return json(movieCredits);
+  return json(movie);
 };
 
 export const handler: Handlers = {

routes/api/series/enhance/[name].ts

@@ -14,47 +14,12 @@ import {
   BadRequestError,
   NotFoundError,
 } from "@lib/errors.ts";
-import { getSeries, Series } from "@lib/resource/series.ts";
+import { createSeries, getSeries, Series } from "@lib/resource/series.ts";
+import * as cache from "@lib/cache/cache.ts";
 
-async function updateSeriesMetadata(
-  name: string,
-  metadata: Partial<Series["meta"]>,
-) {
-  const docId = `Media/series/${name}.md`;
-
-  console.log({ docId, metadata });
-
-  let currentDoc = await getDocument(docId);
-  if (!currentDoc) {
-    throw new NotFoundError();
-  }
-
-  if (!currentDoc.startsWith("---\n---\n")) {
-    currentDoc = `---\n---\n\n${currentDoc}`;
-  }
-
-  const newDoc = transformDocument(currentDoc, (root) => {
-    const frontmatterNode = root.children.find((c) => c.type === "yaml");
-
-    const frontmatter = frontmatterNode?.value as string;
-
-    const value = parse(frontmatter) as Series["meta"];
-
-    const newValue = {
-      ...metadata,
-      date: formatDate(metadata.date),
-      ...value,
-    };
-
-    frontmatterNode.value = stringify(newValue);
-
-    return root;
-  });
-
-  console.log(newDoc);
-
-  return createDocument(docId, newDoc);
-}
+const isString = (input: string | undefined): input is string => {
+  return typeof input === "string";
+};
 
 const POST = async (
   req: Request,
@@ -82,9 +47,24 @@ const POST = async (
     await tmdb.getSeriesCredits(tmdbId);
 
   const releaseDate = seriesDetails.first_air_date;
+  if (releaseDate && series.meta.date) {
+    series.meta.date = new Date(releaseDate);
+  }
   const posterPath = seriesDetails.poster_path;
   const director = seriesCredits &&
     seriesCredits.crew?.filter?.((person) => person.job === "Director")[0];
+  if (director && director.name && !series.meta.author) {
+    series.meta.author = director.name;
+  }
+
+  if (seriesDetails.genres) {
+    series.tags = [
+      ...new Set([
+        ...series.tags.map((t) => t.toLowerCase()),
+        ...seriesDetails.genres.map((g) => g.name?.toLowerCase()),
+      ].filter(isString)),
+    ];
+  }
 
   let finalPath = "";
   if (posterPath && !series.meta.image) {
@@ -93,22 +73,13 @@ const POST = async (
 
     finalPath = `Media/series/images/${safeFileName(name)}_cover.${extension}`;
     await createDocument(finalPath, poster);
+    series.meta.image = finalPath;
   }
+  await createSeries(series);
 
-  const metadata = {} as Series["meta"];
-  if (releaseDate) {
-    metadata.date = new Date(releaseDate);
-  }
-  if (finalPath) {
-    metadata.image = finalPath;
-  }
-  if (director && director.name) {
-    metadata.author = director.name;
-  }
+  cache.del(`documents:Media:series:${name}.md`);
 
-  await updateSeriesMetadata(name, metadata);
-
-  return json(seriesCredits);
+  return json(series);
 };
 
 export const handler: Handlers = {

routes/api/tmdb/query.ts

@@ -2,14 +2,6 @@ import { HandlerContext, Handlers } from "$fresh/server.ts";
 import { searchMovie, searchTVShow } from "@lib/tmdb.ts";
 import * as cache from "@lib/cache/cache.ts";
 import { AccessDeniedError, BadRequestError } from "@lib/errors.ts";
-import { json } from "@lib/helpers.ts";
-
-type CachedMovieQuery = {
-  lastUpdated: number;
-  data: unknown;
-};
-
-const CACHE_INTERVAL = 1000 * 60 * 24 * 30;
 
 const GET = async (
   req: Request,
@@ -30,27 +22,10 @@ const GET = async (
 
   const type = u.searchParams.get("type") || "movie";
 
-  const cacheId = `/${type}/query/${query}`;
-
-  const cachedResponse = await cache.get<CachedMovieQuery>(cacheId);
-  if (
-    cachedResponse && Date.now() < (cachedResponse.lastUpdated + CACHE_INTERVAL)
-  ) {
-    return json(cachedResponse.data);
-  }
-
   const res = type === "movie"
     ? await searchMovie(query)
     : await searchTVShow(query);
 
-  cache.set(
-    cacheId,
-    JSON.stringify({
-      lastUpdated: Date.now(),
-      data: res,
-    }),
-  );
-
   return new Response(JSON.stringify(res.results));
 };