[develop → main] feat: social sign in, token authentication, trainer list, member management, community postlist, membership payment, consultant post

.env.sample

@@ -7,4 +7,12 @@ DB_USERNAME=username
 DB_PASSWORD=password
 DB_DATABASE=database
 
-PORT=3000
+PORT=3000
+
+JWT_SECRET = JWT_SECRET
+JWT_ALGORITHM = "JWT_ALGORITHM"
+
+GRANT_TYPE = GRANT_TYPE
+CLIENT_ID = CLIENT_ID
+SIGN_IN_REDIRECT_URI = REDIRECT_URI
+SIGN_UP_REDIRECT_URI = REDIRECT_URI

api/controllers/consultantController.js

@@ -0,0 +1,14 @@
+const consultantService = require("../services/consultantService");
+const { catchAsync } = require("../utils/error");
+
+const createConsultant = catchAsync(async (req, res) => {
+        const { content, trainerId, threadTypesId = 3 } = await req.body;
+
+        const userId = req.user.userId;
+
+        const thread = await consultantService.createConsultThreads(userId, threadTypesId, content, trainerId);
+
+        res.status(201).json({message : "success"})   
+    });
+
+module.exports = { createConsultant };

api/controllers/managementController.js

@@ -0,0 +1,22 @@
+const managementService = require('../services/managementService');
+const { catchAsync } = require('../utils/error');
+const { addDays, format } = require('date-fns');
+
+const getManagement = catchAsync(async (req, res) => {
+  const { userId, weekday } = req.query;
+  const membership = await managementService.getManagement(userId, weekday);
+  res.json(membership);
+});
+
+const membershipStart = catchAsync(async (req, res) => {
+  const { userId, startDate } = req.body;
+
+  const startDateObject = new Date(startDate);
+  const after30Days = addDays(startDateObject, 30);
+  const endDate = format(after30Days, 'yyyy-MM-dd');
+
+  await managementService.membershipStart(userId, startDate, endDate);
+  res.status(200).json({ message: 'SUCCESS' });
+});
+
+module.exports = { getManagement, membershipStart };

api/controllers/paymentController.js

@@ -0,0 +1,43 @@
+const paymentService = require('../services/paymentService');
+const { catchAsync } = require('../utils/error');
+
+const getMembershipList = catchAsync(async (req, res) => {
+  const memberId = req.user.userId;
+  const membershipList = await paymentService.getMembershipList(memberId);
+
+  res.status(200).json({ membershipData: membershipList });
+});
+
+const getMatchingTrainer = catchAsync(async (req, res) => {
+  const memberId = req.user.userId;
+  const { trainerId } = req.body;
+
+  const matchingTrainer = await paymentService.getMatchingTrainer(
+    trainerId,
+    memberId
+  );
+
+  res.status(200).json({ trainerData: matchingTrainer });
+});
+
+const payForMembership = catchAsync(async (req, res) => {
+  const memberId = req.user.userId;
+  const { trainerId, membershipId, paymentsMethodId } = req.body;
+
+  const paymentInformation = await paymentService.payForMembership(
+    memberId,
+    membershipId,
+    trainerId,
+    paymentsMethodId
+  );
+
+  res
+    .status(200)
+    .json({ message: 'Payment completed', data: paymentInformation });
+});
+
+module.exports = {
+  getMembershipList,
+  getMatchingTrainer,
+  payForMembership,
+};

api/controllers/postController.js

@@ -0,0 +1,10 @@
+const { catchAsync } = require('../utils/error');
+const postService = require('../services/postService');
+
+const getPostListAll = catchAsync(async (req, res) => {
+  const allPosts = await postService.getPostListAll();
+
+  res.status(201).json({ data: allPosts });
+});
+
+module.exports = { getPostListAll };

api/controllers/trainerController.js

@@ -0,0 +1,14 @@
+const trainerService = require('../services/trainerService');
+const { catchAsync } = require('../utils/error');
+
+const getTrainerList = catchAsync(async (req, res) => {
+  const { page = 1, limit = 5 } = req.query;
+  const pageSize = parseInt(limit);
+  const offset = (page - 1) * pageSize;
+
+  const trainerList = await trainerService.getTrainerList(offset, pageSize);
+
+  res.status(200).json({ data: trainerList });
+});
+
+module.exports = { getTrainerList };

api/controllers/userController.js

@@ -0,0 +1,88 @@
+const userService = require('../services/userService');
+const { catchAsync } = require('../utils/error');
+
+const kakaoSignIn = catchAsync(async (req, res) => {
+  const authCode = await req.query.code;
+  const endPoint = await req.path;
+  const redirectUri = await userService.getRedirectUri(endPoint);
+  const kakaoAccessToken = await userService.getKaKaoAccessToken(
+    authCode,
+    redirectUri
+  );
+  const { email, gender, birthyear, birthday } =
+    await userService.getUserInformation(kakaoAccessToken);
+  const age = await userService.calculateAge(birthyear, birthday);
+  const user = await userService.getUserByEmail(email);
+  if (!user) {
+    await userService.createUser(email, gender, age);
+    await res.status(401).json({
+      message: 'SIGN UP REQUIRED',
+    });
+  } else if (
+    user.email &&
+    user.age &&
+    user.gender &&
+    !user.nickname &&
+    !user.height &&
+    !user.weight
+  ) {
+    await res.status(401).json({
+      message: 'SIGN UP REQUIRED',
+    });
+  } else if (
+    user.email &&
+    user.age &&
+    user.gender &&
+    user.nickname &&
+    user.height &&
+    user.weight
+  ) {
+    const token = await userService.createToken(email);
+    await res
+      .status(200)
+      .json({ authorization: token, message: 'SIGN IN COMPLETED' });
+  }
+});
+
+const kakaoSignUp = catchAsync(async (req, res) => {
+  const authCode = await req.query.code;
+  const endPoint = await req.path;
+  const redirectUri = await userService.getRedirectUri(endPoint);
+  const kakaoAccessToken = await userService.getKaKaoAccessToken(
+    authCode,
+    redirectUri
+  );
+  const { email } = await userService.getUserInformation(kakaoAccessToken);
+  const { nickname, height, weight } = await req.body;
+
+  if (!nickname || !height || !weight) {
+    const error = new Error('KEY_ERROR');
+    error.statusCode = 400;
+
+    throw error;
+  }
+
+  await userService.addAdditionalInfo(email, nickname, height, weight);
+  const token = await userService.createToken(email);
+  await res.status(200).json({
+    message: 'SIGN UP COMPLETED',
+    authorization: token,
+  });
+});
+
+const checkDuplicateNickname = catchAsync(async (req, res) => {
+  const { nickname } = await req.body;
+  const result = await userService.checkDuplicateNickname(nickname);
+
+  result
+    ? res.status(409).json({ message: 'DUPLICATED NICKNAME' })
+    : res.status(200).json({
+        message: 'AVAILABLE NICKNAME',
+      });
+});
+
+module.exports = {
+  kakaoSignIn,
+  kakaoSignUp,
+  checkDuplicateNickname,
+};

api/models/consultantDao.js

@@ -0,0 +1,27 @@
+const {dataSource} = require("./dataSource");
+
+const createConsultant = async (userId, threadTypesId, content, trainerProfileId) => {
+    try{    
+     await dataSource.query(
+    `
+    INSERT INTO threads (
+        user_id,
+        thread_types_id,
+        content,
+        trainer_profile_id
+    ) VALUES (
+        ?,
+        ?,
+        ?,
+        ?
+    )
+     `,
+     [userId, threadTypesId, content, trainerProfileId]   
+    ) 
+    }catch{
+      const error = new Error("error");
+      error.statusCode = 400;
+      throw error;  
+    }};
+
+    module.exports = { createConsultant };

api/models/managementDao.js

@@ -0,0 +1,117 @@
+const { dataSource } = require('./dataSource');
+
+const getMembershipByUser = async (userId) => {
+  try {
+    const membership = await dataSource.query(
+      `
+     SELECT 
+     m.name as membershipName,
+     u.start_date as startDate,
+     u.end_date as endDate
+     FROM members_memberships u
+     JOIN memberships m
+     ON m.id = u.membership_id
+     WHERE member_id = ?;
+    `,
+      [userId]
+    );
+    return membership;
+  } catch {
+    const error = new Error('dataSource Error');
+    error.statusCode = 400;
+    throw error;
+  }
+};
+
+const getExerciseList = async (memberId, weekday) => {
+  try {
+    const exerciseList = await dataSource.query(
+      `
+     SELECT 
+        id as exerciseId,
+        name as exerciseName,
+        description as exerciseDescription,
+        image_url as exerciseImageUrl,
+        checkbox as exerciseCheckbox
+     FROM exercises 
+     WHERE member_id = ?
+     AND weekday = ?;
+    `,
+      [memberId, weekday]
+    );
+    return exerciseList;
+  } catch {
+    const error = new Error('dataSource Error');
+    error.statusCode = 400;
+    throw error;
+  }
+};
+
+const getDietList = async (memberId, weekday) => {
+  try {
+    const dietList = await dataSource.query(
+      `
+     SELECT 
+        id as dietId,
+        name as dietName,
+        description as dietDescription
+     FROM diets
+     WHERE member_id = ?
+     AND weekday = ?;
+    `,
+      [memberId, weekday]
+    );
+    return dietList;
+  } catch {
+    const error = new Error('dataSource Error');
+    error.statusCode = 400;
+    throw error;
+  }
+};
+
+const membershipStart = async (startDate, endDate, membershipId, userId) => {
+  try {
+    const result = await dataSource.query(
+      `
+     UPDATE members_memberships
+     SET start_date = ?,   
+         end_date = ?
+     WHERE membership_id = ?
+     AND member_id = ?;
+
+    `,
+      [startDate, endDate, membershipId, userId]
+    );
+    return result;
+  } catch {
+    const error = new Error('dataSource Error');
+    error.statusCode = 400;
+    throw error;
+  }
+};
+
+const getMembershipIdByUser = async (userId) => {
+  try {
+    const membershipId = await dataSource.query(
+      `
+    SELECT membership_id
+    FROM members_memberships
+    WHERE member_id = ?;
+    `,
+      [userId]
+    );
+    return membershipId;
+  } catch {
+    const error = new Error('dataSource Error');
+    error.statusCode = 400;
+    throw error;
+  }
+};
+
+module.exports = {
+  getExerciseList,
+  getDietList,
+  getMembershipByUser,
+  membershipStart,
+  getMembershipIdByUser,
+};