add follow and modify fyp page

src/app.ts

@@ -11,6 +11,7 @@ import indexRouter from './routes/index';
 import { config } from 'dotenv';
 import { AppDataSource } from './config/data-source';
 import handlebarsHelpers from 'handlebars-helpers';
+import { User } from './entities/user.entity';
 config();
 
 const app = express();
@@ -37,6 +38,11 @@ hbs.registerHelper('t', (key: string) => {
   return i18next.t(key);
 });
 
+hbs.registerHelper('isFollowing', function(user: User, followingUsers: Array<User>) {
+  return followingUsers.some(followingUser => followingUser.userId === user.userId);
+});
+
+
 app.use(
   session({
     resave: false,

src/controllers/follow.controller.ts

@@ -0,0 +1,80 @@
+import { Request, Response } from 'express';
+import { FollowService } from '../services/follow.service';
+import asyncHandler from 'express-async-handler';
+import i18next from 'i18next';
+import { isAuthenticated } from '../middlewares/auth.middleware';
+
+const { t } = i18next;
+const followService = new FollowService();
+
+// Follow a user
+export const followUser = [
+  isAuthenticated,
+  asyncHandler(async (req: Request, res: Response) => {
+    const followerId = req.session.user?.id || 0;
+    const followedId = parseInt(req.params.userId, 10);
+
+    try {
+      await followService.followUser(followerId, followedId);
+      req.flash('flashMessage', t('message.followSuccess'));
+      res.redirect(`/users/${followedId}`);
+    } catch (error) {
+      console.error(error);
+      const err = error as Error;
+      req.flash('flashMessage', err.message);
+      res.redirect(`/users/${followedId}`);
+    }
+  }),
+];
+
+// Unfollow a user
+export const unfollowUser = [
+  isAuthenticated,
+  asyncHandler(async (req: Request, res: Response) => {
+    const followerId = req.session.user?.id || 0;
+    const followedId = parseInt(req.params.userId, 10);
+
+    try {
+      await followService.unfollowUser(followerId, followedId);
+      req.flash('flashMessage', t('message.unfollowSuccess'));
+      res.redirect(`/users/${followedId}`);
+    } catch (error) {
+      console.error(error);
+      res.redirect(`/users/${followedId}`);
+    }
+  }),
+];
+
+// Get followers of a user
+export const getFollowers = asyncHandler(async (req: Request, res: Response) => {
+  const userId = parseInt(req.params.userId, 10);
+
+  try {
+    const followers = await followService.getFollowers(userId);
+    res.render('user/followers', {
+      followers,
+      title: t('title.followers'),
+      flashMessage: req.flash('flashMessage'),
+    });
+  } catch (error) {
+    console.error(error);
+    res.status(500).send(t('error.serverError'));
+  }
+});
+
+// Get following users of a user
+export const getFollowing = asyncHandler(async (req: Request, res: Response) => {
+  const userId = parseInt(req.params.userId, 10);
+
+  try {
+    const following = await followService.getFollowing(userId);
+    res.render('user/following', {
+      following,
+      title: t('title.following'),
+      flashMessage: req.flash('flashMessage'),
+    });
+  } catch (error) {
+    console.error(error);
+    res.status(500).send(t('error.serverError'));
+  }
+});

src/controllers/user.controller.ts

@@ -13,9 +13,12 @@ import { validateSessionRole,
         validateActiveUser,
         sanitizeContent } from '../utils/';
 import { PostService } from '../services/post.service';
+import { FollowService } from '../services/follow.service';
+import { User } from '../entities/user.entity';
 
 const userService = new UserService();
 const postService = new PostService();
+const followService = new FollowService();
 
 async function validateUserById(req: Request, res: Response) {
   const id = parseInt(req.params.id);
@@ -35,9 +38,18 @@ export const getUsers = asyncHandler(async (req: Request, res: Response) => {
   const page = parseInt(req.query.page as string, 10) || 1;
   try {
     const users = await userService.getAllUsers(page);
+    const currentUserId = req.session.user?.id;
+
+    let followingUsers: User[] = [];
+    if (req.session.user) {
+      followingUsers = await followService.getFollowing(req.session.user?.id);
+    }
+
     res.render('users/index', {
       title: t ('title.users'),
       users: users,
+      followingUsers: followingUsers,
+      currentUserId: currentUserId,
       userRole: req.session.user?.role,
       userStatus: UserStatus,
       isAdmin: validateAdminRole(req),
@@ -60,8 +72,12 @@ export const getUserById = asyncHandler(async (req: Request, res: Response) => {
   const sanitizedPosts = posts.map(post => ({
     ...post,
     content: sanitizeContent(post.content)
-  }));;
-  // Admin and page owner can Edit profile.
+  }));
+  let isFollowing = false;
+  if (req.session.user) {
+    isFollowing = await followService.isFollowing(req.session.user?.id, id);
+  }
+
   res.render('users/show', {
     title: 'title.userProfile',
     user: userDto,
@@ -70,6 +86,7 @@ export const getUserById = asyncHandler(async (req: Request, res: Response) => {
     userRole: req.session.user?.role,
     userPosts: sanitizedPosts,
     userStatus: UserStatus,
+    isFollowing: isFollowing,
     isOwner: id == req.session.user?.id,
     isAdmin: validateAdminRole(req)
   });

src/locales/en/translation.json

@@ -45,7 +45,8 @@
     "bookmark": "Bookmark",
     "latestPost": "See latest posts",
     "addNewUser": "Add New User",
-    "update": "Update"
+    "update": "Update",
+    "unfollow": "Unfollow"
   },
   "content" : {
     "username": "Username",

src/public/js/script.js

@@ -76,4 +76,93 @@ $(document).ready(function() {
     $('#commentForm').toggle();
   });
 
+  $('.btn-follow').on('click', function() {
+      const userId = $(this).data('user-id');
+      const button = $(this);
+
+      console.log('Follow button clicked');
+      console.log('userId:', userId);
+      console.log('button:', button);
+
+      $.ajax({
+          url: `/follow/follow/${userId}`,
+          method: 'POST',
+          success: function() {
+              alert('User followed successfully');
+          },
+          error: function() {
+              alert('Error following user');
+          }
+      });
+
+      console.log('Follow button clicked');
+  });
+
+  $('.btn-unfollow').on('click', function() {
+      const userId = $(this).data('user-id');
+      const button = $(this);
+
+      console.log('Unfollow button clicked');
+      console.log('userId:', userId);
+      console.log('button:', button);
+
+      $.ajax({
+          url: `/follow/unfollow/${userId}`,
+          method: 'POST',
+          success: function() {
+              alert('User unfollowed successfully');
+          },
+          error: function() {
+              alert('Error unfollowing user');
+          }
+      });
+
+      console.log('Unfollow button clicked');
+  });
+
+  $('.unfollow-btn').on('click', function() {
+      const userId = $(this).data('user-id');
+      const button = $(this);
+
+      console.log('Unfollow button clicked');
+      console.log('userId:', userId);
+      console.log('button:', button);
+
+      $.ajax({
+          url: `/follow/unfollow/${userId}`,
+          method: 'POST',
+          success: function() {
+              alert('User unfollowed successfully');
+          },
+          error: function() {
+              alert('Error unfollowing user');
+          }
+      });
+
+      console.log('Unfollow button clicked');
+  });
+
+  $('.follow-btn').on('click', function() {
+      const userId = $(this).data('user-id');
+      const button = $(this);
+
+      console.log('Follow button clicked');
+      console.log('userId:', userId);
+      console.log('button:', button);
+
+      $.ajax({
+          url: `/follow/follow/${userId}`,
+          method: 'POST',
+          success: function() {
+              alert('User followed successfully');
+          },
+          error: function() {
+              alert('Error following user');
+          }
+      });
+
+      console.log('Follow button clicked');
+  });
+
+
 });

src/routes/follow.route.ts

@@ -0,0 +1,25 @@
+// routes/follow.routes.ts
+
+import express from 'express';
+import {
+  followUser,
+  unfollowUser,
+  getFollowers,
+  getFollowing,
+} from '../controllers/follow.controller';
+
+const router = express.Router();
+
+// Follow a user
+router.post('/follow/:userId', followUser);
+
+// Unfollow a user
+router.post('/unfollow/:userId', unfollowUser);
+
+// Get followers of a user
+router.get('/:userId/followers', getFollowers);
+
+// Get following users of a user
+router.get('/:userId/following', getFollowing);
+
+export default router;

src/routes/index.ts

@@ -7,6 +7,7 @@ import postRouter from './post.route';
 import userRouter from './user.route';
 import commentRouter from './comment.route';
 import tagRouter from './tag.route';
+import followRouter from './follow.route';
 
 const router: Router = Router();
 
@@ -17,5 +18,6 @@ router.use('/posts', postRouter);
 router.use('/users', userRouter);
 router.use('/comments', commentRouter);
 router.use('/tags', tagRouter);
+router.use('/follow', followRouter);
 
 export default router;

src/services/follow.service.ts

@@ -0,0 +1,95 @@
+import { AppDataSource } from '../config/data-source';
+import { User } from '../entities/user.entity';
+
+export class FollowService {
+  private userRepository = AppDataSource.getRepository(User);
+
+  async followUser(followerId: number, followedId: number): Promise<void> {
+    if (followerId === followedId) {
+      throw new Error('You cannot follow yourself');
+    }
+
+    const follower = await this.userRepository.findOne({
+      where: { userId: followerId },
+      relations: ['following'],
+    });
+
+    const followed = await this.userRepository.findOne({
+      where: { userId: followedId },
+    });
+
+    if (!follower || !followed) {
+      throw new Error('User not found');
+    }
+
+    if (follower.following.some(user => user.userId === followedId)) {
+      throw new Error('You are already following this user');
+    }
+
+    follower.following.push(followed);
+    await this.userRepository.save(follower);
+  }
+
+  async unfollowUser(followerId: number, followedId: number): Promise<void> {
+    if (followerId === followedId) {
+      throw new Error('You cannot unfollow yourself');
+    }
+
+    const follower = await this.userRepository.findOne({
+      where: { userId: followerId },
+      relations: ['following'],
+    });
+
+    if (!follower) {
+      throw new Error('User not found');
+    }
+
+    follower.following = follower.following.filter(user => user.userId !== followedId);
+    await this.userRepository.save(follower);
+  }
+
+  async getFollowers(userId: number): Promise<User[]> {
+    const user = await this.userRepository.findOne({
+      where: { userId },
+      relations: ['followers'],
+    });
+
+    if (!user) {
+      throw new Error('User not found');
+    }
+
+    return user.followers;
+  }
+
+  async getFollowing(userId: number): Promise<User[]> {
+    const user = await this.userRepository.findOne({
+      where: { userId },
+      relations: ['following'],
+      select: {
+        following: {
+          userId: true,
+          username: true,
+        }
+      }
+    });
+
+    if (!user) {
+      throw new Error('User not found');
+    }
+
+    return user.following;
+  }
+
+  async isFollowing(followerId: number, followedId: number): Promise<boolean> {
+    const follower = await this.userRepository.findOne({
+      where: { userId: followerId },
+      relations: ['following'],
+    });
+
+    if (!follower) {
+      throw new Error('User not found');
+    }
+
+    return follower.following.some(user => user.userId === followedId);
+  }
+}