chore: backend

Author: NiranjanaNS

backend/src/data-source.ts

@@ -5,7 +5,7 @@ import { Otp } from './entities/opt';
 if (!process.env.DATABASE_URL) {
   throw new Error('DATABASE_URL is not defined');
 }
-export const appDataSouce = new DataSource({
+export const appDataSource = new DataSource({
   type: 'postgres',
   url: process.env.DATABASE_URL,
   ssl: {

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

@@ -3,7 +3,7 @@ import { logger } from '../../utils/logger';
 import { emailSchema, registerSchema } from './auth.schema';
 import { sendOtpEmail } from '../../Services/email.service';
 import { generateotp } from '../../utils/otp';
-import { appDataSouce } from '../../data-source';
+import { appDataSource } from '../../data-source';
 import { Otp } from '../../entities/opt';
 import { User } from '../../entities/User';
 
@@ -20,7 +20,7 @@ export const sendOtp = async (
         .status(400)
         .json({ message: 'validation vailed', error: result.error?.format() });
     }
-    const otpRep = appDataSouce.getRepository(Otp);
+    const otpRep = appDataSource.getRepository(Otp);
     const otpcode = generateotp();
     logger.debug({ otpcode }, 'otp is');
     const email = result.data?.email;
@@ -49,7 +49,7 @@ export const verifyotp = async (
       return res.status(400).json({ message: ' otp and email are required' });
     }
 
-    const otpRepo = appDataSouce.getRepository(Otp);
+    const otpRepo = appDataSource.getRepository(Otp);
     const otpRecord = await otpRepo.findOne({
       where: {
         email,
@@ -101,8 +101,8 @@ export const register = async (
     if (!otpId) {
       return res.status(400).json({ message: 'otpid requuired' });
     }
-    const otpRepo = appDataSouce.getRepository(Otp);
-    const userRepo = appDataSouce.getRepository(User);
+    const otpRepo = appDataSource.getRepository(Otp);
+    const userRepo = appDataSource.getRepository(User);
 
     const otpRecord = await otpRepo.findOne({
       where: { id: otpId },

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

@@ -3,6 +3,10 @@ export const emailSchema = z.object({
   email: z.string().email('Invalid email'),
 });
 
+export const numberSchema = z.object({
+  phoneNumber: z.number(),
+});
+
 export const registerSchema = z.object({
   otpId: z.string().uuid(),
   name: z.string().min(1, 'name is required'),

backend/src/modules/health/health.ts

@@ -1,16 +1,16 @@
 import express from 'express';
-import { appDataSouce } from '../../data-source';
+import { appDataSource } from '../../data-source';
 const Healthrouter = express.Router();
 Healthrouter.get('/', async (req, res) => {
   try {
-    if (!appDataSouce.isInitialized) {
+    if (!appDataSource.isInitialized) {
       return res.status(503).json({
         status: 'eroor',
         service: 'mysocial-code-backend',
         db: 'not initialized',
       });
     }
-    await appDataSouce.query('SELECT 1');
+    await appDataSource.query('SELECT 1');
     return res.status(200).json({
       status: 'ok',
       service: 'mysocial-code-backend',

backend/src/modules/user/user.controller.ts

@@ -1,7 +1,7 @@
 import { NextFunction, Request, Response } from 'express';
 import { PutObjectCommand } from '@aws-sdk/client-s3';
 import { r2 } from '../../utils/r2';
-import { appDataSouce } from '../../data-source';
+import { appDataSource } from '../../data-source';
 import { User } from '../../entities/User';
 import { logger } from '../../utils/logger';
 export const uploadAvatar = async (
@@ -25,7 +25,7 @@ export const uploadAvatar = async (
       }),
     );
     const imageUrl = `${process.env.R2_ENDPOINT}/${process.env.R2_BUCKET_NAME}/${key}`;
-    const userRepo = appDataSouce.getRepository(User);
+    const userRepo = appDataSource.getRepository(User);
     await userRepo.update(userId, { profileImageUrl: imageUrl });
     res
       .status(200)

backend/src/server.ts

@@ -2,14 +2,14 @@ import dotenv from 'dotenv';
 dotenv.config();
 import app from './app';
 import { logger } from './utils/logger';
-import { appDataSouce } from './data-source';
+import { appDataSource } from './data-source';
 if (!process.env.PORT) {
   throw new Error('PORT is not defined in environment variables');
 }
 
 (async () => {
   try {
-    await appDataSouce.initialize();
+    await appDataSource.initialize();
     logger.info('database connected success fully');
   } catch (error) {
     logger.error({ err: error }, 'error connecting the database');