implement endpoints for list, create & remove of notification methods; move owner check of notification method into own file

api/src/routes/notification-method.ts

@@ -0,0 +1,135 @@
+import { Hono } from 'hono'
+import { getDbContext } from '../db/client'
+import { notificationMethod, notificationProvider } from '../db/schema'
+import { eq, and } from 'drizzle-orm'
+import { getUser } from '../lib/user-auth'
+import { DatabaseError, InvalidParameter, MissingParameter } from '../errors'
+import { Message } from '../types/response'
+
+const app = new Hono()
+
+/**
+ * Gets you the id of a notificaton provider by name
+ * @param db DB connection (as const)
+ * @param name Name of the notification provider
+ * @returns Id of the specified notification provider's name (undefined if not exists)
+ */
+async function getProviderId(db: ReturnType<typeof getDbContext>, name: string){
+  try{
+    const provider = await db.select({
+      id: notificationProvider.id
+    }).from(notificationProvider)
+    .where(eq(notificationProvider.name, name)).get();
+
+    return provider?.id;
+  }
+  catch(e){
+    throw new InvalidParameter('provider');
+  }
+}
+
+/** Returns a list of all notification methods a user owns */
+app.get('/list', async (c) => {
+  const db = getDbContext(c);
+  const user = await getUser(c);
+
+  try{
+    const methods = await db.select({
+      id: notificationMethod.id,
+      webhook: notificationMethod.webhookUrl,
+      name: notificationMethod.shownName,
+      provider: notificationProvider.name
+    }).from(notificationMethod)
+    .where(eq(notificationMethod.userId, user.id))
+    .innerJoin(notificationProvider, eq(notificationMethod.notificationProviderId, notificationProvider.id));
+
+    return c.json(methods);
+  }
+  catch(e){
+    throw new DatabaseError();
+  }
+})
+
+/** Lists all available notification providers */
+app.get('/list-providers', async (c) => {
+  const db = getDbContext(c);
+
+  try{
+    const providers = await db.selectDistinct({
+      name: notificationProvider.name
+    }).from(notificationProvider)
+    .where(eq(notificationProvider.isActive, true));
+
+    return c.json(providers);
+  }
+  catch{
+    throw new DatabaseError();
+  }
+})
+
+/** Creates a new notification method from url, name & provider */
+app.post('/add-method', async (c) => {
+  const db = getDbContext(c);
+  const user = await getUser(c);
+
+  const { url, name, provider } = c.req.query();
+
+  if(!url || !name || !provider) throw new MissingParameter();
+
+  const providerId = await getProviderId(db, provider);
+  if(!providerId) throw new InvalidParameter('provider');
+
+  try{
+    const newMethod = await db.insert(notificationMethod).values({
+      webhookUrl: url,
+      shownName: name,
+      userId: user.id,
+      notificationProviderId: providerId
+    }).returning().onConflictDoNothing().get();
+
+    return c.json(
+      newMethod
+      ? new Message('Successfull created new notification method.', {
+        id: newMethod.id,
+        webhook: newMethod.webhookUrl,
+        name: newMethod.shownName
+      })
+      : new Message('Notification method with this URL already exists. No changes made.')
+    );
+  }
+  catch(e){
+    throw new DatabaseError();
+  }
+})
+
+/** Removes a existing notification method by id (has to be owned by the current user) */
+app.delete('/remove-method/:id', async (c) => {
+  const db = getDbContext(c);
+  const user = await getUser(c);
+  const methodId = parseInt(c.req.param('id'));
+
+  if(!methodId) throw new InvalidParameter('id');
+
+  try{
+    const res = await db.delete(notificationMethod).where(
+      and(
+        eq(notificationMethod.id, methodId),
+        eq(notificationMethod.userId, user.id)
+      )
+    ).returning();
+
+    return c.json(new Message(
+      res.length > 0
+      ? `Notification method ${methodId} was removed.`
+      : `No matching notification method with id ${methodId}. No changes made.`,
+      {
+        notificationMethodId: methodId
+      }
+    ))
+  }
+  catch{
+    throw new DatabaseError();
+  }
+})
+
+export default app