Integration TestCases

README.md

@@ -208,7 +208,6 @@ Refer to [Kafka Ubuntu 22.04 setup guide](https://www.fosstechnix.com/install-ap
 
 4. Reload systemd:
 
-
     ```bash
     $ sudo systemctl daemon-reload
     ```
@@ -275,7 +274,6 @@ Refer to [Kafka Ubuntu 22.04 setup guide](https://www.fosstechnix.com/install-ap
 
 ### Install Redis
 
-
 Refer to [Redis Ubuntu 22.04 setup guide](https://www.digitalocean.com/community/tutorials/how-to-install-and-secure-redis-on-ubuntu-22-04)
 
 1. Update the package list:

src/constants/common.js

@@ -27,6 +27,7 @@ module.exports = {
 		'/user/v1/organization/list',
 		'/user/v1/user-role/default',
 		'/user/v1/account/validateUserSession',
+		'/user/v1/account/searchByEmailIds',
 	],
 	notificationEmailType: 'email',
 	accessTokenExpiry: process.env.ACCESS_TOKEN_EXPIRY,

src/controllers/v1/account.js

@@ -310,4 +310,24 @@ module.exports = class Account {
 			return error
 		}
 	}
+
+	/**
+	 * Account Search By Email
+	 * @method
+	 * @name list
+	 * @param {Object} req -request data with method POST.
+	 * @param {Object} req.body -request body contains user deatils.
+	 * @param {Array} req.body.userIds -contains emailIds.
+	 * @returns {JSON} - all accounts data
+	 */
+	async searchByEmailIds(req) {
+		try {
+			const result = await accountService.searchByEmailIds(req)
+			return result
+		} catch (error) {
+			return error
+		}
+	}
+
+	listByEmailIds
 }

src/helpers/responses.js

@@ -5,7 +5,7 @@
  * Description : Response constants used in this service
  */
 
-const form = require('@generics/form')
+const form = require('../generics/form')
 const { elevateLog, correlationId } = require('elevate-logger')
 const logger = elevateLog.init()
 const successResponse = async ({ statusCode = 500, responseCode = 'OK', message, result = [], meta = {} }) => {

src/integration-test/account/account.spec.js

@@ -27,81 +27,97 @@ describe('/user/v1/account', function () {
 			password: password,
 			isAMentor: false,
 		})
-
 		logError(res)
 		expect(res.statusCode).toBe(201)
 		expect(res.body).toMatchSchema(responseSchema.createProfileSchema)
 	})
+
 	it('/login', async () => {
-		let insertedUserDetails = await insertUser()
 		let res = await request.post('/user/v1/account/login').send({
-			email: insertedUserDetails.email,
-			password: insertedUserDetails.password,
+			email: userEmail,
+			password: password,
 		})
-
 		logError(res)
 		expect(res.statusCode).toBe(200)
 		expect(res.body).toMatchSchema(responseSchema.loginSchema)
 	})
 
-	it('/verifyMentor', async () => {
-		let res = await request.get('/user/v1/account/verifyMentor').query({ userId: userDetails.userId })
-
-		logError(res)
-		expect(res.statusCode).toBe(200)
-		expect(res.body).toMatchSchema(responseSchema.verifyMentor)
-	})
-
-	it('/verifyUser', async () => {
-		let res = await request.get('/user/v1/account/verifyUser').query({ userId: userDetails.userId })
-
-		logError(res)
-		expect(res.statusCode).toBe(200)
-		expect(res.body).toMatchSchema(responseSchema.verifyUser)
-	})
-
 	it('/acceptTermsAndCondition', async () => {
 		let res = await request.patch('/user/v1/account/acceptTermsAndCondition')
 
 		logError(res)
 		expect(res.statusCode).toBe(200)
 		expect(res.body).toMatchSchema(responseSchema.acceptTermsAndConditionSchema)
 	})
-	it('/list', async () => {
-		let res = await request.patch('/user/v1/account/list').query({ type: 'mentee', page: 1, limit: 2 })
 
-		logError(res)
-		expect(res.statusCode).toBe(200)
-		expect(res.body).toMatchSchema(responseSchema.listSchema)
-	})
 	it('/generateToken', async () => {
 		let res = await request
 			.post('/user/v1/account/generateToken')
 			.query({ type: 'mentee', page: 1, limit: 2 })
 			.send({
-				refreshToken: userDetails.refreshToken,
+				refresh_token: userDetails.refreshToken,
 			})
 
 		logError(res)
 		expect(res.statusCode).toBe(200)
 		expect(res.body).toMatchSchema(responseSchema.generateTokenSchema)
 	})
-	it('/changeRole', async () => {
-		let res = await request.post('/user/v1/account/changeRole').send({
-			email: userDetails.email,
-		})
-		userDetails = await logIn()
 
-		logError(res)
-		expect(res.statusCode).toBe(200)
-		expect(res.body).toMatchSchema(responseSchema.changeRoleSchema)
-	})
 	it('/logout', async () => {
 		let res = await request.post('/user/v1/account/logout').send({
-			refreshToken: userDetails.refreshToken,
+			refresh_token: userDetails.refreshToken,
 		})
 		logError(res)
 		expect(res.statusCode).toBe(200)
 		expect(res.body).toMatchSchema(responseSchema.logoutSchema)
 	})
+
+	// search , changerole , verifyMentor , verifyuser doesn't have permissions and it is used in rolevalidation
+
+	// it('/search', async () => {
+	// 	console.log(userDetails.userId)
+	// 	let res = await request.post('/user/v1/account/search')
+	// 	.set({
+	// 		'internal_access_token': 'internal_access_token',
+	// 		Connection: 'keep-alive',
+	// 		'Content-Type': 'application/json',
+	// 	})
+	// 	.send({
+	// 		userIds : [456]
+	// 	})
+
+	// 	logError(res)
+	// 	expect(res.statusCode).toBe(200)
+	// 	console.log("listr ======",res.body)
+	// 	expect(res.body).toMatchSchema(responseSchema.listSchema)
+	// })
+
+	// it('/changeRole', async () => {
+	// 	let res = await request.post('/user/v1/account/changeRole').send({
+	// 		email: userDetails.email,
+	// 		role : 'mentor'
+	// 	})
+	// 	userDetails = await logIn()
+
+	// 	logError(res)
+	// 	expect(res.statusCode).toBe(200)
+	// 	expect(res.body).toMatchSchema(responseSchema.changeRoleSchema)
+	// })
+
+	// it('/verifyMentor', async () => {
+	// 	console.log(userDetails)
+	// 	let res = await request.get('/user/v1/account/verifyMentor').query({ userId: userDetails.userId })
+
+	// 	logError(res)
+	// 	expect(res.statusCode).toBe(200)
+	// 	expect(res.body).toMatchSchema(responseSchema.verifyMentor)
+	// })
+
+	// it('/verifyUser', async () => {
+	// 	let res = await request.get('/user/v1/account/verifyUser').query({ userId: userDetails.userId })
+
+	// 	logError(res)
+	// 	expect(res.statusCode).toBe(200)
+	// 	expect(res.body).toMatchSchema(responseSchema.verifyUser)
+	// })
 })

src/integration-test/account/accountData.js

@@ -1,4 +1,5 @@
 const usersData = require('@database/queries/users')
+const UserCredentialQueries = require('@database/queries/userCredential')
 const { faker } = require('@faker-js/faker')
 const utilsHelper = require('@generics/utils')
 const crypto = require('crypto')
@@ -10,12 +11,23 @@ const insertUser = async () => {
 		let password = faker.internet.password()
 		bodyData = {
 			name: 'Nevil',
-			email: { address: email, verified: false },
+			email: email,
 			password: password,
 			isAMentor: false,
+			organization_id: 1,
+			roles: [3],
+			otp: process.env.ENABLE_EMAIL_OTP_VERIFICATION,
 		}
 		bodyData.password = utilsHelper.hashPassword(bodyData.password)
-		await usersData.createUser(bodyData)
+		const res = await usersData.create(bodyData)
+		const userCredentialsBody = {
+			email: email,
+			password: password,
+			organization_id: bodyData.organization_id,
+			user_id: res.user_id,
+		}
+		await UserCredentialQueries.create(userCredentialsBody)
+
 		return {
 			email: email,
 			password: password,