[WIP] FE API Service

backend/src/controllers/local-events.ts

@@ -1,5 +1,6 @@
 import type { Request, Response } from "express";
 import { prisma } from "../services/db.js";
+import { PrismaClient } from "@prisma/client";
 
 type LocalEvent = {
   id: string;

backend/src/controllers/tmdb.ts

@@ -2,6 +2,7 @@ import type { Request, Response } from "express";
 import { prisma } from "../services/db.js";
 import { Prisma } from "@prisma/client";
 import { randomUUID } from "crypto";
+import type { Movie } from "../types/models";
 
 type TmdbMovie = {
   id: number;
@@ -78,23 +79,26 @@ export async function saveMovie(mapped: MovieInsert) {
   });
 }
 
-// Express handler
+// Gets a movie from TMDB and saves it to the local db
 export const getMovie = async (req: Request, res: Response) => {
-  const { movieId: tmdbId } = req.params; // route: /movies/:movieId (TMDB id)
-
-  if (!tmdbId) {
-    return res.status(400).json({ message: "Movie ID is required" });
-  }
+  const { movieId: tmdbId } = req.params;
+  if (!tmdbId) return res.status(400).json({ message: "Movie ID is required" });
 
   try {
     const tmdb = await fetchTmdbMovie(tmdbId);
-    const mapped = mapTmdbToMovie(tmdb);
-    const saved = await saveMovie(mapped);
+    const mappedAppModel = mapTmdbToMovie(tmdb);
+    const prismaCreate = mappedAppModel;
+
+    // create or update if it already exists
+    const saved = await prisma.movie.upsert({
+      where: { movieId: prismaCreate.movieId },
+      create: prismaCreate,
+      update: prismaCreate,
+    });
 
-    // Convert BigInt to number for JSON serialization
     const movieResponse = {
       ...saved,
-      imdbRating: saved.imdbRating ? Number(saved.imdbRating) : null,
+      imdbRating: saved.imdbRating != null ? Number(saved.imdbRating) : null,
     };
 
     res.json({
@@ -113,52 +117,31 @@ export const getMovie = async (req: Request, res: Response) => {
 // PUT /movies/:movieId
 export const updateMovie = async (req: Request, res: Response) => {
   const { movieId } = req.params;
+  if (!movieId) return res.status(400).json({ message: "Movie ID is required" });
 
-  if (!movieId) {
-    return res.status(400).json({ message: "Movie ID is required" });
-  }
-
-  const { title, description, languages, imdbRating, localRating, numRatings } =
-    req.body;
-
-  const updateData: Partial<Prisma.movieUpdateInput> = {};
-
-  if (title !== undefined) updateData.title = title;
-  if (description !== undefined) updateData.description = description;
-  if (languages !== undefined) updateData.languages = languages;
-  if (imdbRating !== undefined) updateData.imdbRating = imdbRating;
-  if (localRating !== undefined) updateData.localRating = String(localRating);
-  if (numRatings !== undefined) updateData.numRatings = String(numRatings);
+  const body = req.body as Partial<Movie>;
+  const updateData = mapMovieToPrismaUpdate(body);
 
   if (Object.keys(updateData).length === 0) {
     return res.status(400).json({ message: "No fields to update" });
   }
 
   try {
     const updatedMovie = await prisma.movie.update({
-      where: { movieId: movieId },
+      where: { movieId },
       data: updateData,
     });
 
-    // Convert BigInt to number for JSON serialization
     const movieResponse = {
       ...updatedMovie,
-      imdbRating: updatedMovie.imdbRating
-        ? Number(updatedMovie.imdbRating)
-        : null,
+      imdbRating: updatedMovie.imdbRating != null ? Number(updatedMovie.imdbRating) : null,
     };
 
-    res.json({
-      message: "Movie updated successfully",
-      data: movieResponse,
-    });
+    res.json({ message: "Movie updated successfully", data: movieResponse });
   } catch (err) {
     console.error("updateMovie error:", err);
 
-    if (
-      err instanceof Prisma.PrismaClientKnownRequestError &&
-      err.code === "P2025"
-    ) {
+    if (err instanceof Prisma.PrismaClientKnownRequestError && err.code === "P2025") {
       return res.status(404).json({ message: "Movie not found" });
     }
 
@@ -201,30 +184,16 @@ export const deleteMovie = async (req: Request, res: Response) => {
 };
 
 export const getMovieById = async (req: Request, res: Response) => {
-  // Fetch movie from YOUR database using the local UUID
-  // No TMDB call needed
   const { movieId } = req.params;
-  if (!movieId) {
-    return res.status(400).json({ message: "Movie ID is required" });
-  }
+  if (!movieId) return res.status(400).json({ message: "Movie ID is required" });
+
   try {
-    const movie = await prisma.movie.findUnique({
-      where: { movieId: movieId },
-    });
-    if (!movie) {
-      return res.status(404).json({ message: "Movie not found." });
-    }
+    const movie = await prisma.movie.findUnique({ where: { movieId } });
+    if (!movie) return res.status(404).json({ message: "Movie not found." });
 
-    // Convert BigInt to number for JSON serialization
-    const movieResponse = {
-      ...movie,
-      imdbRating: movie.imdbRating ? Number(movie.imdbRating) : null,
-    };
+    const movieResponse = mapMovieDbToApi(movie);
 
-    res.json({
-      message: "Movie found successfully",
-      data: movieResponse,
-    });
+    res.json({ message: "Movie found successfully", data: movieResponse });
   } catch (err) {
     console.error("getMovieById error:", err);
     res.status(500).json({
@@ -233,3 +202,107 @@ export const getMovieById = async (req: Request, res: Response) => {
     });
   }
 };
+
+// -------- helpers --------
+const isNonEmptyString = (v: unknown): v is string =>
+  typeof v === "string" && v.length > 0;
+
+const toBigIntNullable = (
+  v: unknown,
+  { forUpdate = false }: { forUpdate?: boolean } = {}
+): bigint | null | undefined => {
+  if (v === undefined) return undefined;  // skip
+  if (v === null) return forUpdate ? null : undefined; // update: explicit null, create: skip
+
+  if (typeof v === "bigint") return v;
+
+  if (typeof v === "number" && Number.isFinite(v)) {
+    return BigInt(Math.round(v));
+  }
+
+  if (typeof v === "string") {
+    const trimmed = v.trim();
+    if (!isNonEmptyString(trimmed)) return forUpdate ? null : undefined;
+
+    // Try strict BigInt first, then numeric parse fallback
+    try {
+      return BigInt(trimmed);
+    } catch {
+      const n = Number(trimmed);
+      if (Number.isFinite(n)) return BigInt(Math.round(n));
+    }
+  }
+
+  return forUpdate ? null : undefined;
+};
+
+const toJsonStringArray = (v: unknown): string[] | undefined => {
+  if (v == null) return undefined;              // undefined or null => skip
+  if (Array.isArray(v)) return v.filter(x => x != null).map(String);
+  return undefined;
+};
+
+// -------- mappers --------
+export function mapMovieDbToApi(dbMovie: Prisma.movieGetPayload<{}>): Movie {
+  return {
+    movieId: dbMovie.movieId,
+    title: dbMovie.title,
+    description: dbMovie.description,
+    languages: dbMovie.languages ? (dbMovie.languages as string[]) : null,
+    imdbRating: dbMovie.imdbRating != null ? Number(dbMovie.imdbRating) : null,
+    localRating: dbMovie.localRating,
+    numRatings: dbMovie.numRatings,
+  };
+}
+
+export function mapMoviesDbToApi(dbMovies: Prisma.movieGetPayload<{}>[]): Movie[] {
+  return dbMovies.map(mapMovieDbToApi);
+}
+
+export const mapMovieToPrismaUpdate = (
+  patch: Partial<Movie>
+): Prisma.movieUpdateInput => {
+  const data: Prisma.movieUpdateInput = {};
+
+  if ("title" in patch) data.title = patch.title ?? null;
+  if ("description" in patch) data.description = patch.description ?? null;
+
+  if ("languages" in patch) {
+    if (patch.languages === null) {
+      data.languages = Prisma.DbNull;             // clear JSON column
+    } else {
+      data.languages = toJsonStringArray(patch.languages); // string[] | undefined
+    }
+  }
+
+  if ("imdbRating" in patch) {
+    data.imdbRating = toBigIntNullable(patch.imdbRating, { forUpdate: true }) as
+      | bigint
+      | null
+      | undefined;
+  }
+
+  if ("localRating" in patch) {
+    if (patch.localRating === undefined) {
+      // leave undefined (no-op)
+    } else if (patch.localRating === null) {
+      data.localRating = null;
+    } else {
+      data.localRating = String(patch.localRating);
+    }
+  }
+
+  if ("numRatings" in patch) {
+    if (patch.numRatings === undefined) {
+      // no-op
+    } else if (patch.numRatings === null) {
+      data.numRatings = null;
+    } else {
+      data.numRatings = String(patch.numRatings);
+    }
+  }
+
+  return data;
+};
+
+