api: add CategoriesController, wire category routes in Router

Author: GhCristea

src/api/CategoriesController.res

@@ -0,0 +1,97 @@
+// Categories HTTP handlers — mirrors ItemsController pattern
+// Each handler takes ~svc explicitly — no global registry access
+// Returns Handler.t (curried) so Router can bind at startup
+
+// ─── Param helpers ──────────────────────────────────────────────────────────────────────────────
+
+let getIdParam = (params: Js.Dict.t<string>): result<int, AppError.t> =>
+  params
+  ->Js.Dict.get("id")
+  ->Result.fromOption(AppError.BadRequest("Missing id"))
+  ->Result.flatMap(s =>
+    Int.fromString(s)->Result.fromOption(AppError.BadRequest("id must be an integer"))
+  )
+
+// ─── Handlers ───────────────────────────────────────────────────────────────────────────────────
+
+let list = (~svc: CategoryService.t): Handler.t =>
+  async (_req, _params) =>
+    svc.findAll()
+    ->Result.map(cats => cats->Array.map(Category.toJson)->Js.Json.array)
+    ->AppError.toResponse
+
+let get = (~svc: CategoryService.t): Handler.t =>
+  async (_req, params) =>
+    getIdParam(params)
+    ->Result.flatMap(svc.findById)
+    ->Result.map(Category.toJson)
+    ->AppError.toResponse
+
+let create = (~svc: CategoryService.t): Handler.t =>
+  async (req, _params) => {
+    let json = await req->Bun.json
+    json
+    ->Schemas.parseCategoryBody
+    ->Result.flatMap(inputs =>
+      switch inputs {
+      | [single] => svc.insert(single)->Result.map(cat => [cat])
+      | many     => svc.insertMany(many)
+      }
+    )
+    ->Result.map(cats => cats->Array.map(Category.toJson)->Js.Json.array)
+    ->AppError.toResponse
+  }
+
+let replace = (~svc: CategoryService.t): Handler.t =>
+  async (req, params) => {
+    let json = await req->Bun.json
+    getIdParam(params)
+    ->Result.flatMap(id =>
+      json
+      ->Schemas.parseCategoryReplace
+      ->Result.map(input => ({id, name: input.name, description: input.description}: Schema.Categories.replaceRow))
+      ->Result.flatMap(svc.replace)
+    )
+    ->Result.map(Category.toJson)
+    ->AppError.toResponse
+  }
+
+let replaceMany = (~svc: CategoryService.t): Handler.t =>
+  async (req, _params) => {
+    let json = await req->Bun.json
+    json
+    ->Schemas.parseCategoryReplaceMany
+    ->Result.flatMap(svc.replaceMany)
+    ->Result.map(cats => cats->Array.map(Category.toJson)->Js.Json.array)
+    ->AppError.toResponse
+  }
+
+let patch = (~svc: CategoryService.t): Handler.t =>
+  async (req, params) => {
+    let json = await req->Bun.json
+    getIdParam(params)
+    ->Result.flatMap(id =>
+      json
+      ->Schemas.parseCategoryPatch
+      ->Result.flatMap(input => svc.patch(id, input))
+    )
+    ->Result.map(Category.toJson)
+    ->AppError.toResponse
+  }
+
+let delete = (~svc: CategoryService.t): Handler.t =>
+  async (_req, params) =>
+    getIdParam(params)
+    ->Result.flatMap(svc.delete)
+    ->Result.map(_ => Js.Json.null)
+    ->AppError.toResponse
+
+let deleteMany = (~svc: CategoryService.t): Handler.t =>
+  async (req, _params) => {
+    let json = await req->Bun.json
+    json
+    ->Schemas.parseCategoryDeleteMany
+    ->Result.flatMap(svc.deleteMany)
+    ->Result.map(_ => Js.Json.null)
+    ->AppError.toResponse
+  }

src/api/ItemsController.res

@@ -80,6 +80,19 @@ let replaceMany = (~svc: ItemService.t): Handler.t =>
     ->AppError.toResponse
   }
 
+let patch = (~svc: ItemService.t): Handler.t =>
+  async (req, params) => {
+    let json = await req->Bun.json
+    getIdParam(params)
+    ->Result.flatMap(id =>
+      json
+      ->Schemas.parsePatch
+      ->Result.flatMap(input => svc.patch(id, input))
+    )
+    ->Result.map(Item.toJson)
+    ->AppError.toResponse
+  }
+
 let delete = (~svc: ItemService.t): Handler.t =>
   async (_req, params) =>
     getIdParam(params)

src/api/Router.res

@@ -20,19 +20,30 @@ let extractParams = (pattern: string, path: string): option<Js.Dict.t<string>> =
 }
 
 let make = (registry: ServiceRegistry.t): (Bun.request => promise<Bun.response>) => {
-  let items  = registry.items
-  let cats   = registry.categories
+  let items = registry.items
+  let cats  = registry.categories
 
   // Exact routes first, parameterised after — longest patterns before shorter ones
   let routes: array<(string, string, Handler.t)> = [
+    // Items
     ("GET",    "/rest/items",                ItemsController.list(~svc=items)),
     ("POST",   "/rest/items",                ItemsController.create(~svc=items)),
     ("PUT",    "/rest/items",                ItemsController.replaceMany(~svc=items)),
     ("DELETE", "/rest/items",                ItemsController.deleteMany(~svc=items)),
     ("GET",    "/rest/items/:id/categories", ItemsController.getCategories(~svc=items, ~catSvc=cats)),
     ("GET",    "/rest/items/:id",            ItemsController.get(~svc=items)),
     ("PUT",    "/rest/items/:id",            ItemsController.replace(~svc=items)),
+    ("PATCH",  "/rest/items/:id",            ItemsController.patch(~svc=items)),
     ("DELETE", "/rest/items/:id",            ItemsController.delete(~svc=items)),
+    // Categories
+    ("GET",    "/rest/categories",           CategoriesController.list(~svc=cats)),
+    ("POST",   "/rest/categories",           CategoriesController.create(~svc=cats)),
+    ("PUT",    "/rest/categories",           CategoriesController.replaceMany(~svc=cats)),
+    ("DELETE", "/rest/categories",           CategoriesController.deleteMany(~svc=cats)),
+    ("GET",    "/rest/categories/:id",       CategoriesController.get(~svc=cats)),
+    ("PUT",    "/rest/categories/:id",       CategoriesController.replace(~svc=cats)),
+    ("PATCH",  "/rest/categories/:id",       CategoriesController.patch(~svc=cats)),
+    ("DELETE", "/rest/categories/:id",       CategoriesController.delete(~svc=cats)),
   ]
 
   async (req: Bun.request): promise<Bun.response> => {