Add UI for multi-library management #59 (#63)

* feat: add ui for library source management

* fix: lint

server/api/v1/admin/library/sources/index.delete.ts

@@ -0,0 +1,25 @@
+import { type } from "arktype";
+import { throwingArktype } from "~/server/arktype";
+import aclManager from "~/server/internal/acls";
+import prisma from "~/server/internal/db/database";
+
+const DeleteLibrarySource = type({
+  id: "string",
+}).configure(throwingArktype);
+
+export default defineEventHandler<{ body: typeof DeleteLibrarySource.infer }>(
+  async (h3) => {
+    const allowed = await aclManager.allowSystemACL(h3, [
+      "library:sources:delete",
+    ]);
+    if (!allowed) throw createError({ statusCode: 403 });
+
+    const body = await readValidatedBody(h3, DeleteLibrarySource);
+
+    return await prisma.library.delete({
+      where: {
+        id: body.id,
+      },
+    });
+  },
+);

server/api/v1/admin/library/sources/index.get.ts

@@ -0,0 +1,16 @@
+import type { Library } from "~/prisma/client";
+import aclManager from "~/server/internal/acls";
+import libraryManager from "~/server/internal/library";
+
+export type WorkingLibrarySource = Library & { working: boolean };
+
+export default defineEventHandler(async (h3) => {
+  const allowed = await aclManager.allowSystemACL(h3, ["library:sources:read"]);
+  if (!allowed) throw createError({ statusCode: 403 });
+
+  const sources = await libraryManager.fetchLibraries();
+
+  // Fetch other library data here
+
+  return sources;
+});

server/api/v1/admin/library/sources/index.patch.ts

@@ -0,0 +1,67 @@
+import { type } from "arktype";
+import { throwingArktype } from "~/server/arktype";
+import aclManager from "~/server/internal/acls";
+import prisma from "~/server/internal/db/database";
+import libraryManager from "~/server/internal/library";
+import { libraryConstructors } from "~/server/plugins/05.library-init";
+import type { WorkingLibrarySource } from "./index.get";
+
+const UpdateLibrarySource = type({
+  id: "string",
+  name: "string",
+  options: "object",
+}).configure(throwingArktype);
+
+export default defineEventHandler<{ body: typeof UpdateLibrarySource.infer }>(
+  async (h3) => {
+    const allowed = await aclManager.allowSystemACL(h3, [
+      "library:sources:update",
+    ]);
+    if (!allowed) throw createError({ statusCode: 403 });
+
+    const body = await readValidatedBody(h3, UpdateLibrarySource);
+
+    const source = await prisma.library.findUnique({ where: { id: body.id } });
+    if (!source)
+      throw createError({
+        statusCode: 400,
+        statusMessage: "Library source not found",
+      });
+
+    const constructor = libraryConstructors[source.backend];
+
+    try {
+      const newLibrary = constructor(body.options, source.id);
+
+      // Test we can actually use it
+      if ((await newLibrary.listGames()) === undefined) {
+        throw "Library failed to fetch games.";
+      }
+
+      const updatedSource = await prisma.library.update({
+        where: {
+          id: source.id,
+        },
+        data: {
+          name: body.name,
+          options: body.options,
+        },
+      });
+
+      await libraryManager.removeLibrary(source.id);
+      await libraryManager.addLibrary(newLibrary);
+
+      const workingSource: WorkingLibrarySource = {
+        ...updatedSource,
+        working: true,
+      };
+
+      return workingSource;
+    } catch (e) {
+      throw createError({
+        statusCode: 400,
+        statusMessage: `Failed to create source: ${e}`,
+      });
+    }
+  },
+);

server/api/v1/admin/library/sources/index.post.ts

@@ -0,0 +1,69 @@
+import { type } from "arktype";
+import { randomUUID } from "crypto";
+import { LibraryBackend } from "~/prisma/client";
+import { throwingArktype } from "~/server/arktype";
+import aclManager from "~/server/internal/acls";
+import prisma from "~/server/internal/db/database";
+import libraryManager from "~/server/internal/library";
+import { libraryConstructors } from "~/server/plugins/05.library-init";
+import type { WorkingLibrarySource } from "./index.get";
+
+const CreateLibrarySource = type({
+  name: "string",
+  backend: "string",
+  options: "object",
+}).configure(throwingArktype);
+
+export default defineEventHandler<{ body: typeof CreateLibrarySource.infer }>(
+  async (h3) => {
+    const allowed = await aclManager.allowSystemACL(h3, [
+      "library:sources:new",
+    ]);
+    if (!allowed) throw createError({ statusCode: 403 });
+
+    const body = await readValidatedBody(h3, CreateLibrarySource);
+    const backend = Object.values(LibraryBackend).find(
+      (e) => e == body.backend,
+    );
+    if (!backend)
+      throw createError({
+        statusCode: 400,
+        statusMessage: "Invalid source backend.",
+      });
+
+    const constructor = libraryConstructors[backend];
+
+    try {
+      const id = randomUUID();
+      const library = constructor(body.options, id);
+
+      // Test we can actually use it
+      if ((await library.listGames()) === undefined) {
+        throw "Library failed to fetch games.";
+      }
+
+      const source = await prisma.library.create({
+        data: {
+          id,
+          name: body.name,
+          backend,
+          options: body.options,
+        },
+      });
+
+      await libraryManager.addLibrary(library);
+
+      const workingSource: WorkingLibrarySource = {
+        ...source,
+        working: true,
+      };
+
+      return workingSource;
+    } catch (e) {
+      throw createError({
+        statusCode: 400,
+        statusMessage: `Failed to create source: ${e}`,
+      });
+    }
+  },
+);

server/internal/acls/descriptions.ts

@@ -49,6 +49,11 @@ export const systemACLDescriptions: ObjectFromList<typeof systemACLs> = {
   "auth:simple:invitation:delete": "Delete a simple auth invitation.",
 
   "library:read": "Fetch a list of all games on this instance.",
+  "library:sources:read":
+    "Fetch a list of all library sources on this instance",
+  "library:sources:new": "Create a new library source.",
+  "library:sources:update": "Update existing library sources.",
+  "library:sources:delete": "Delete library sources.",
 
   "notifications:read": "Read system notifications.",
   "notifications:mark": "Mark system notifications as read.",

server/internal/acls/index.ts

@@ -50,6 +50,11 @@ export const systemACLs = [
   "notifications:delete",
 
   "library:read",
+  "library:sources:read",
+  "library:sources:new",
+  "library:sources:update",
+  "library:sources:delete",
+
   "game:read",
   "game:update",
   "game:delete",

server/internal/library/filesystem.ts

@@ -30,7 +30,9 @@ export class FilesystemProvider
 
     this.myId = id;
     this.config = config;
-    fs.mkdirSync(this.config.baseDir, { recursive: true });
+
+    if (!fs.existsSync(this.config.baseDir))
+      throw "Base directory does not exist.";
   }
 
   id(): string {

server/internal/library/index.ts

@@ -20,6 +20,19 @@ class LibraryManager {
     this.libraries.set(library.id(), library);
   }
 
+  removeLibrary(id: string) {
+    this.libraries.delete(id);
+  }
+
+  async fetchLibraries() {
+    const libraries = await prisma.library.findMany({});
+    const libraryWithMetadata = libraries.map((e) => ({
+      ...e,
+      working: this.libraries.has(e.id),
+    }));
+    return libraryWithMetadata;
+  }
+
   async fetchAllUnimportedGames() {
     const unimportedGames: { [key: string]: string[] } = {};
 

server/plugins/05.library-init.ts

@@ -7,7 +7,7 @@ import { FilesystemProvider } from "../internal/library/filesystem";
 import libraryManager from "../internal/library";
 import path from "path";
 
-const libraryConstructors: {
+export const libraryConstructors: {
   [key in LibraryBackend]: (
     value: JsonValue,
     id: string,