[CHE-120] Add Total Posts Display On Threads

client/src/components/Forums/ThreadDetails/ThreadDetails.tsx

@@ -59,6 +59,9 @@ const ThreadDetail = ({ forumId, threadId }: ThreadDetailProps) => {
     }
   };
 
+  const totalPosts: number = posts.length + 1;
+
+  if (pending) return null;
   if (loading) return <div>Loading...</div>;
   if (error) return <div>Error: {error}</div>;
   if (!thread) return <div>Thread not found.</div>;
@@ -96,6 +99,9 @@ const ThreadDetail = ({ forumId, threadId }: ThreadDetailProps) => {
           </div>
         ))}
       </div>
+      <div className="mt-4">
+        <strong>Total Posts:</strong> {totalPosts}
+      </div>
     </div>
   );
 };

client/src/components/Forums/ThreadsDisplay/ThreadsDisplay.tsx

@@ -45,6 +45,12 @@ const ThreadsDisplay = ({ forumId, onThreadSelect }: ThreadsDisplayProps) => {
     setCreatingThread(!creatingThread);
   };
 
+  function formatReplies(count: number) {
+    if (count === 0) return 'No replies';
+    if (count === 1) return '1 reply';
+    return `${count} replies`;
+  }
+
   if (loading) return <div>Loading...</div>;
   if (error) return <div>Error: {error}</div>;
 
@@ -77,6 +83,8 @@ const ThreadsDisplay = ({ forumId, onThreadSelect }: ThreadsDisplayProps) => {
             <small>
               Started by {thread.user.firstName} on{' '}
               {new Date(thread.createdAt).toLocaleDateString()}
+              <span className="mx-2 text-gray-400">|</span>
+              <span className="italic">{formatReplies(thread.postCount)}</span>
             </small>
           </li>
         ))}

client/types/forums.ts

@@ -12,6 +12,7 @@ export interface Thread {
   content: string;
   user: IUser;
   createdAt: string;
+  postCount: number;
 }
 
 export interface IForum {

server/controllers/forumController.ts

@@ -1,7 +1,6 @@
 import { Request, Response, NextFunction } from 'express';
 import Forum from '../models/forumModel';
-import Thread from '../models/threadModel';
-import { sortAndPopulate } from './helpers/queryHelpers';
+import { aggregateThreadsWithPostCount } from './helpers/queryHelpers';
 
 // ENDPOINT  POST api/forums
 // PURPOSE   Create a new forum
@@ -51,12 +50,12 @@ const getForumById = async (req: Request, res: Response, next: NextFunction) =>
 
   try {
     const forum = await Forum.findById(forumId);
+
     if (!forum) {
       return res.status(404).json({ message: 'Forum not found' });
     }
 
-    const threadsQuery = Thread.find({ forum: forumId });
-    const threads = await sortAndPopulate(threadsQuery);
+    const threads = await aggregateThreadsWithPostCount(forumId, 'createdAt', -1);
 
     res.status(200).json({ forum, threads });
   } catch (error) {

server/controllers/helpers/queryHelpers.ts

@@ -1,14 +1,81 @@
-import mongoose, { Query } from "mongoose";
+import Thread from '../../models/threadModel';
+import mongoose from 'mongoose';
 
 type SortOrder = 1 | -1;
 
-export const sortAndPopulate = (
-  query: Query<any, any, any>,
-  sortField: string = "createdAt",
+interface SortAndPopulateQuery<T> {
+  sort: (arg: { [key: string]: SortOrder }) => SortAndPopulateQuery<T>;
+  populate: (field: string, select?: string) => SortAndPopulateQuery<T>;
+  exec: () => Promise<T>;
+}
+interface AggregateQuery<T> {
+  sort: (arg: { [key: string]: SortOrder }) => AggregateQuery<T>;
+  project: (field: { [key: string]: 0 | 1 }) => AggregateQuery<T>;
+  lookup: (lookupOptions: {
+    from: string;
+    localField: string;
+    foreignField: string;
+    as: string;
+  }) => AggregateQuery<T>;
+  exec: () => Promise<T[]>;
+}
+
+export const sortAndPopulate = <T>(
+  query: SortAndPopulateQuery<T>,
+  sortField: string = 'createdAt',
   sortOrder: number = -1,
-  populateField: string = "user",
-  selectFields: string = "firstName lastName"
+  populateField: string = 'user',
+  selectFields: string = 'firstName lastName',
 ) => {
   const sortObj = { [sortField]: sortOrder } as { [key: string]: SortOrder };
   return query.sort(sortObj).populate(populateField, selectFields).exec();
 };
+
+export const aggregateSort = <T>(
+  pipeline: AggregateQuery<T>,
+  sortField: string = 'createdAt',
+  sortOrder: SortOrder = -1,
+) => {
+  const sortObj: Record<string, SortOrder> = { [sortField]: sortOrder };
+  return pipeline.sort(sortObj).exec();
+};
+
+export const aggregateThreadsWithPostCount = (
+  forumId?: string,
+  sortField: string = 'createdAt',
+  sortOrder: SortOrder = -1,
+) => {
+  const baseStages = [
+    {
+      $lookup: {
+        from: 'posts',
+        localField: '_id',
+        foreignField: 'thread',
+        as: 'posts',
+      },
+    },
+    {
+      $addFields: {
+        postCount: { $size: '$posts' },
+      },
+    },
+    {
+      $project: {
+        posts: 0,
+      },
+    },
+  ];
+
+  const threadsAggregate = forumId
+    ? [
+        {
+          $match: {
+            forum: new mongoose.Types.ObjectId(forumId),
+          },
+        },
+        ...baseStages,
+      ]
+    : baseStages;
+
+  return aggregateSort(Thread.aggregate(threadsAggregate), sortField, sortOrder);
+};

server/controllers/threadController.ts

@@ -2,7 +2,7 @@ import { Request, Response, NextFunction } from 'express';
 import Post from '../models/postModel';
 import Thread from '../models/threadModel';
 import { CustomRequest } from '../types/customRequest';
-import { sortAndPopulate } from './helpers/queryHelpers';
+import { sortAndPopulate, aggregateThreadsWithPostCount } from './helpers/queryHelpers';
 
 // ENDPOINT  POST api/:forumId/threads
 // PURPOSE   Create a new thread
@@ -39,8 +39,8 @@ const createThread = async (req: CustomRequest, res: Response, next: NextFunctio
 // ACCESS    Private
 const getAllThreads = async (req: CustomRequest, res: Response, next: NextFunction) => {
   try {
-    const threadsQuery = Thread.find({});
-    const threads = await sortAndPopulate(threadsQuery);
+    const threads = await aggregateThreadsWithPostCount(undefined, 'createdAt', -1);
+
     res.status(200).json(threads);
   } catch (error) {
     next({
@@ -60,6 +60,7 @@ const listThreadsByForumId = async (req: Request, res: Response, next: NextFunct
   try {
     const threadsQuery = Thread.find({ forum: forumId });
     const threads = await sortAndPopulate(threadsQuery);
+
     res.status(200).json(threads);
   } catch (error) {
     next({