adding user registration end points

Author: sembcorpp

backend/user/src/controllers/registration/registerController.ts

@@ -0,0 +1,38 @@
+import { Request, Response } from 'express';
+import { StatusCodes } from 'http-status-codes';
+import { registerService } from '@/services/registration/register-logic';
+import type { IRegisterPayload } from '@/services/registration/register-inputs';
+
+export async function register(req: Request, res: Response) {
+  //Extract the registration data from the request body
+  const { email, username, password, firstName, lastName }: Partial<IRegisterPayload> = req.body;
+
+  //Validate input
+  if (!username || !password || !email || !firstName || !lastName) {
+    return res.status(StatusCodes.UNPROCESSABLE_ENTITY).json('Malformed Request');
+  }
+
+  //Call the registration service
+  const { code, data, error } = await registerService({
+    email,
+    username,
+    firstName,
+    lastName,
+    password,
+  });
+
+  //Handle errors
+  if (error || code !== StatusCodes.CREATED || !data) {
+    const sanitizedErr = error?.message ?? 'An error occurred during registration.';
+    return res.status(code).json(sanitizedErr);
+  }
+
+  //Set JWT token as an HTTP-only cookie
+  return res
+    .status(StatusCodes.CREATED)
+    .cookie('jwtToken', data.cookie, { httpOnly: true }) // Set the JWT token as a cookie
+    .json({
+      message: 'User registered successfully',
+      user: data.user, // Return user data if needed
+    });
+}

backend/user/src/routes/register.ts

@@ -0,0 +1,8 @@
+import express from 'express';
+import { register } from '@/controllers/registration/registerController';
+
+const router = express.Router();
+// Route to handle user registration
+router.post('/', register);
+
+export default router;

backend/user/src/server.ts

@@ -2,6 +2,7 @@ import express, { json } from 'express';
 import pino from 'pino-http';
 import { db } from './lib/db';
 import authRoutes from './routes/auth';
+import registerRoutes from './routes/register';
 import helmet from 'helmet';
 import { sql } from 'drizzle-orm';
 import { logger } from './lib/utils';
@@ -12,6 +13,7 @@ app.use(pino());
 app.use(json());
 app.use(helmet());
 app.use('/auth', authRoutes);
+app.use('/register', registerRoutes);
 app.get('/', async (_req, res) => {
   res.json({
     message: 'OK',

backend/user/src/services/registration/register-inputs.ts

@@ -0,0 +1,7 @@
+export type IRegisterPayload = {
+  email: string;
+  username: string;
+  firstName: string;
+  lastName: string;
+  password: string;
+};

backend/user/src/services/registration/register-logic.ts

@@ -0,0 +1,67 @@
+import { or, eq, getTableColumns } from 'drizzle-orm';
+import { StatusCodes } from 'http-status-codes';
+import bcrypt from 'bcrypt';
+import jwt from 'jsonwebtoken';
+import { db, users } from '@/lib/db';
+import type { IRegisterPayload } from './register-inputs';
+
+const _JWT_SECRET_KEY = 'secret';
+
+const _getSchema = () => {
+  const { id, email, username, firstName, lastName, password } = getTableColumns(users);
+  return {
+    id,
+    email,
+    username,
+    firstName,
+    lastName,
+    password,
+  };
+};
+
+export const registerService = async (payload: IRegisterPayload) => {
+  const { email, username, firstName, lastName, password } = payload;
+
+  //check if user already exists (by username or email)
+  const existingUsers = await db
+    .select(_getSchema())
+    .from(users)
+    .where(or(eq(users.username, username), eq(users.email, email)))
+    .limit(1);
+
+  if (existingUsers.length > 0) {
+    return {
+      code: StatusCodes.CONFLICT,
+      error: {
+        message: 'User with this username or email already exists',
+      },
+    };
+  }
+
+  //hash the password
+  const hashedPassword = bcrypt.hashSync(password, 10); // Use bcrypt to hash the password
+
+  //insert new user into the database
+  const [newUser] = await db
+    .insert(users)
+    .values({
+      email,
+      username,
+      firstName,
+      lastName,
+      password: hashedPassword, //store the hashed password
+    })
+    .returning(_getSchema());
+
+  // generate JWT token for the new user
+  const jwtToken = jwt.sign({ id: newUser.id }, _JWT_SECRET_KEY);
+
+  // return success response with the JWT token
+  return {
+    code: StatusCodes.CREATED,
+    data: {
+      cookie: jwtToken,
+      user: newUser,
+    },
+  };
+};