feat: send otp api created

Author: shanuvr

backend/package.json

@@ -10,6 +10,8 @@
   "dependencies": {
     "dotenv": "^17.2.3",
     "express": "^5.2.1",
+    "form-data": "^4.0.5",
+    "mailgun.js": "^12.4.1",
     "pg": "^8.16.3",
     "pino": "^10.1.0",
     "pino-http": "^11.0.0",
@@ -26,6 +28,7 @@
     "@typescript-eslint/eslint-plugin": "^8.51.0",
     "@typescript-eslint/parser": "^8.51.0",
     "eslint": "^9.39.2",
+    "ts-node": "^10.9.2",
     "ts-node-dev": "^2.0.0",
     "typescript": "~5.9.3",
     "typescript-eslint": "^8.51.0"

backend/src/Services/email.service.ts

@@ -0,0 +1,24 @@
+import Mailgun from 'mailgun.js';
+import FormData from 'form-data';
+import { logger } from '../utils/logger';
+
+const mailgun = new Mailgun(FormData);
+
+const mg = mailgun.client({
+  username: 'api',
+  key: process.env.MAILGUN_API_KEY!,
+});
+
+export const sendOtpEmail = async (to: string, otp: string) => {
+  try {
+    await mg.messages.create(process.env.MAILGUN_DOMAIN!, {
+      from: process.env.MAIL_FROM_EMAIL!,
+      to,
+      subject: 'Your SocialCode verification code',
+      text: `Your SocialCode verification code is ${otp}. This code expires in 5 minutes.`,
+    });
+  } catch (err) {
+    logger.error({ err }, 'Error sending OTP email');
+    throw new Error('Failed to send OTP email');
+  }
+};

backend/src/app.ts

@@ -3,13 +3,17 @@ import { pinoHttp } from 'pino-http';
 import { logger } from './utils/logger';
 import { notFound } from './middleware/notFound';
 import { errorHandler } from './middleware/errorHandler';
-import Healthrouter from './routes/health';
+import Healthrouter from './modules/health/health';
+import authRouter from './modules/auth/auth.routes'
+
+
 const app = express();
 app.use(express.json());
 app.use(
   pinoHttp({ logger, autoLogging: { ignore: (req) => req.url === 'health' } }),
 );
 app.use('/health', Healthrouter);
+app.use('/auth', authRouter);
 app.use(notFound);
 app.use(errorHandler);
 export default app;

backend/src/data-source.ts

@@ -1,6 +1,7 @@
 import 'dotenv/config';
 import { DataSource } from 'typeorm';
 import { User } from './entities/User';
+import { Otp } from './entities/opt';
 if (!process.env.DATABASE_URL) {
   throw new Error('DATABASE_URL is not defined');
 }
@@ -10,6 +11,6 @@ export const appDataSouce = new DataSource({
   ssl: {
     rejectUnauthorized: false,
   },
-  entities: [User],
+  entities: [User,Otp],
   synchronize: true,
 });

backend/src/entities/opt.ts

@@ -0,0 +1,22 @@
+import {
+  Entity,
+  PrimaryGeneratedColumn,
+  Column,
+  CreateDateColumn,
+} from 'typeorm';
+
+@Entity('otps')
+export class Otp {
+  @PrimaryGeneratedColumn('uuid')
+  id!: string;
+  @Column()
+  email!: string;
+  @Column()
+  otp!: string;
+  @Column({ type: 'timestamp' })
+  expiresAt!: Date;
+  @Column({default:false})
+  verified!: boolean;
+  @CreateDateColumn()
+  createdAt!: Date;
+}

backend/src/middleware/errorHandler.ts

@@ -1,18 +1,37 @@
 import { Request, Response, NextFunction } from 'express';
+import { logger } from '../utils/logger';
+
+type AppError = {
+  statusCode?: number;
+  message?: string;
+};
 
 export const errorHandler = (
   err: unknown,
   req: Request,
   res: Response,
   _next: NextFunction,
 ) => {
-  console.error(err);
+  logger.info('reached inside global error');
+  const error = err as AppError;
 
-  let message = 'Internal Server Error';
+  const statusCode = error.statusCode ?? 500;
+  const message =
+    statusCode === 500
+      ? 'Internal Server Error'
+      : (error.message ?? 'Something went wrong');
 
-  if (err instanceof Error) {
-    message = err.message;
-  }
+  logger.error(
+    {
+      err,
+      path: req.path,
+      method: req.method,
+    },
+    'Unhandled error',
+  );
 
-  res.status(500).json({ message });
+  res.status(statusCode).json({
+    success: false,
+    message,
+  });
 };

backend/src/modules/auth/auth.controller.ts

@@ -0,0 +1,37 @@
+import { Request, Response, NextFunction } from 'express';
+import { logger } from '../../utils/logger';
+import { emailSchema } from './auth.schema';
+import { sendOtpEmail } from '../../Services/email.service';
+import { generateotp } from '../../utils/otp';
+import { appDataSouce } from '../../data-source';
+import { Otp } from '../../entities/opt';
+export const sendOtp = async (
+  req: Request,
+  res: Response,
+  next: NextFunction,
+) => {
+  try {
+    logger.info('reached');
+    const result = emailSchema.safeParse(req.body);
+    if (!result.success) {
+      return res
+        .status(400)
+        .json({ message: 'validation vailed', error: result.error?.format() });}
+        const otpRep = appDataSouce.getRepository(Otp)
+      const otpcode = generateotp()
+      logger.debug({otpcode},"otp is")
+      const email = result.data?.email;
+      await sendOtpEmail(email.toString(),otpcode.toString())
+      await otpRep.delete({email})
+      await otpRep.save({
+        email,
+        otp:otpcode.toString(),
+        expiresAt: new Date(Date.now()+5*60*1000)
+
+      })
+    res.status(200).json({ message: "otp sent success fully ",success:true });
+  } catch (err) {
+    logger.error('error in register');
+    next(err);
+  }
+};

backend/src/modules/auth/auth.routes.ts

@@ -0,0 +1,6 @@
+import express from 'express';
+import { sendOtp } from './auth.controller';
+const authRouter = express.Router();
+authRouter.post('/send-otp', sendOtp);
+
+export default authRouter;

backend/src/modules/auth/auth.schema.ts

@@ -0,0 +1,4 @@
+import { z } from 'zod';
+export const emailSchema = z.object({
+  email: z.string().email('Invalid email'),
+});

backend/src/routes/health.ts backend/src/modules/health/health.tsbackend/src/routes/health.ts renamed to backend/src/modules/health/health.ts

@@ -1,5 +1,5 @@
 import express from 'express';
-import { appDataSouce } from '../data-source';
+import { appDataSouce } from '../../data-source';
 const Healthrouter = express.Router();
 Healthrouter.get('/', async (req, res) => {
   try {