feat: implement AccountWebPushDeviceController and add related routes for managing web push devices

Author: mitchdowney

src/controllers/account/accountWebPushDevice.ts

@@ -0,0 +1,125 @@
+import { Request, Response } from 'express';
+import Joi from 'joi';
+import { AccountWebPushDeviceService } from 'podverse-orm';
+import { handleGenericErrorResponse } from '@api/controllers/helpers/error';
+import { validateBodyObject } from '@api/lib/validation';
+import { ensureAuthenticated } from '@api/lib/auth';
+
+const createAccountWebPushDeviceSchema = Joi.object({
+  endpoint: Joi.string().uri().required(),
+  p256dh: Joi.string().required(),
+  auth: Joi.string().required()
+});
+
+const updateAccountWebPushDeviceSchema = Joi.object({
+  endpoint: Joi.string().uri().required(),
+  p256dh: Joi.string().required(),
+  auth: Joi.string().required()
+});
+
+const deleteAccountWebPushDeviceSchema = Joi.object({
+  endpoint: Joi.string().uri().required()
+});
+
+const updateLocaleForAccountSchema = Joi.object({
+  locale: Joi.string().required()
+});
+
+export class AccountWebPushDeviceController {
+  private static accountWebPushDeviceService = new AccountWebPushDeviceService();
+
+  static async create(req: Request, res: Response): Promise<void> {
+    ensureAuthenticated(req, res, async () => {
+      validateBodyObject(createAccountWebPushDeviceSchema, req, res, async () => {
+        try {
+          const jwtUser = req.user!;
+          const { endpoint, p256dh, auth } = req.body as {
+            endpoint: string;
+            p256dh: string;
+            auth: string;
+          };
+          const accountWebPushDevice = await AccountWebPushDeviceController
+            .accountWebPushDeviceService.create(jwtUser.id, {
+              endpoint,
+              p256dh,
+              auth
+            });
+          res.json(accountWebPushDevice);
+        } catch (error) {
+          handleGenericErrorResponse(res, error);
+        }
+      });
+    });
+  }
+
+  static async update(req: Request, res: Response): Promise<void> {
+    ensureAuthenticated(req, res, async () => {
+      validateBodyObject(updateAccountWebPushDeviceSchema, req, res, async () => {
+        try {
+          const jwtUser = req.user!;
+          const { endpoint, p256dh, auth } = req.body as {
+            endpoint: string;
+            p256dh: string;
+            auth: string;
+          };
+          const accountWebPushDevice = await AccountWebPushDeviceController
+            .accountWebPushDeviceService.update(jwtUser.id, {
+              endpoint,
+              p256dh,
+              auth
+            });
+          res.json(accountWebPushDevice);
+        } catch (error) {
+          handleGenericErrorResponse(res, error);
+        }
+      });
+    });
+  }
+
+  static async delete(req: Request, res: Response): Promise<void> {
+    ensureAuthenticated(req, res, async () => {
+      validateBodyObject(deleteAccountWebPushDeviceSchema, req, res, async () => {
+        try {
+          const jwtUser = req.user!;
+          const { endpoint } = req.body as {
+            endpoint: string;
+          };
+          await AccountWebPushDeviceController
+            .accountWebPushDeviceService.delete(jwtUser.id, {
+              endpoint
+            });
+          res.json({ message: 'WebPush device deleted successfully' });
+        } catch (error) {
+          handleGenericErrorResponse(res, error);
+        }
+      });
+    });
+  }
+
+  static async getAllForAccount(req: Request, res: Response): Promise<void> {
+    ensureAuthenticated(req, res, async () => {
+      try {
+        const jwtUser = req.user!;
+        const devices = await AccountWebPushDeviceController.accountWebPushDeviceService.getAllForAccount(jwtUser.id);
+        res.json(devices);
+      } catch (error) {
+        handleGenericErrorResponse(res, error);
+      }
+    });
+  }
+
+  static async updateLocaleForAccount(req: Request, res: Response): Promise<void> {
+    ensureAuthenticated(req, res, async () => {
+      validateBodyObject(updateLocaleForAccountSchema, req, res, async () => {
+        try {
+          const jwtUser = req.user!;
+          const { locale } = req.body as { locale: string };
+          await AccountWebPushDeviceController.accountWebPushDeviceService.updateLocaleForAccount(jwtUser.id, { locale });
+          res.json({ message: 'Locale updated for account devices' });
+        } catch (error) {
+          handleGenericErrorResponse(res, error);
+        }
+      });
+    });
+  }
+}

src/routes/account.ts

@@ -9,6 +9,7 @@ import { AccountFollowingPlaylistController } from '@api/controllers/account/acc
 import { AccountNotificationChannelController } from '@api/controllers/account/accountNotificationChannel';
 import { AccountNotificationChannelTypeController } from '@api/controllers/account/accountNotificationChannelType';
 import { AccountFCMDeviceController } from '@api/controllers/account/accountFCMDevice';
+import { AccountWebPushDeviceController } from '@api/controllers/account/accountWebPushDevice';
 import { rateLimitEndpoint } from '@api/lib/rateLimiter';
 
 const router = Router();
@@ -34,6 +35,12 @@ router.delete('/fcm-device/delete', asyncHandler(AccountFCMDeviceController.dele
 router.get('/fcm-device/all-for-account', asyncHandler(AccountFCMDeviceController.getAllForAccount));
 router.put('/fcm-device/update-locale', asyncHandler(AccountFCMDeviceController.updateLocaleForAccount));
 
+router.post('/webpush-device/create', asyncHandler(AccountWebPushDeviceController.create));
+router.put('/webpush-device/update', asyncHandler(AccountWebPushDeviceController.update));
+router.delete('/webpush-device/delete', asyncHandler(AccountWebPushDeviceController.delete));
+router.get('/webpush-device/all-for-account', asyncHandler(AccountWebPushDeviceController.getAllForAccount));
+router.put('/webpush-device/update-locale', asyncHandler(AccountWebPushDeviceController.updateLocaleForAccount));
+
 router.post('/follow/account', asyncHandler(AccountFollowingAccountController.followAccount));
 router.post('/unfollow/account', asyncHandler(AccountFollowingAccountController.unfollowAccount));