Updates to common package

Author: seantokuzo

examples_new/microservices/common/package-lock.json

@@ -16,9 +16,11 @@
   "author": "",
   "license": "ISC",
   "dependencies": {
-    "express": "^4.18.2"
+    "express": "^4.18.2",
+    "jsonwebtoken": "^9.0.2"
   },
   "devDependencies": {
-    "@types/express": "^4.17.21"
+    "@types/express": "^4.17.21",
+    "@types/jsonwebtoken": "^9.0.5"
   }
 }

examples_new/microservices/common/package.json

@@ -0,0 +1,5 @@
+export enum Events {
+  USER_CREATED = 'USER_CREATED',
+  ITEM_CREATED = 'ITEM_CREATED',
+  ORDER_CREATED = 'ORDER_CREATED',
+}

examples_new/microservices/common/src/events/events.ts

@@ -0,0 +1,26 @@
+import { NextFunction, Request, Response } from 'express';
+import jwt, { JwtPayload } from 'jsonwebtoken';
+
+interface UserPayload extends JwtPayload {
+  userId: string;
+}
+
+export interface CurrentUserRequest extends Request {
+  currentUser?: string;
+}
+//middleware to check if there is a cookie
+// if there is a cookie, we decode jwt and attach the current user id
+export const currentUser = (req: CurrentUserRequest, res: Response, next: NextFunction) => {
+  const { token } = req.cookies;
+
+  if (!token) return next();
+
+
+  try {
+    const payload = jwt.verify(token, process.env.JWT_KEY!) as UserPayload;
+    req.currentUser = payload.userId;
+    return next()
+  } catch (err) {
+    throw new Error('🎃Internal Error');
+  }
+};

examples_new/microservices/common/src/middlewares/currentUser.ts

@@ -0,0 +1,11 @@
+import { CurrentUserRequest } from './currentUser';
+import { NotAuthorizedError } from '../errors/not-authorized-error';
+import { NextFunction, Response } from 'express';
+// take in req, res and next as arguments - include their types from express package
+export const requireAuth = (req: CurrentUserRequest, res: Response, next: NextFunction) => {
+  // check if req.currentUser exists
+  // if it does, move onto to the next middleware
+  if (req.currentUser) return next();
+  // if not throw a not authorized error
+  throw new NotAuthorizedError();
+};