feat: Create the whole CRUD for topics threads posts and user

Signed-off-by: amanraj <raj.aman4001@gmail.com>

Author: consoledotaman

apps/server/src/index.ts

@@ -40,7 +40,7 @@ fastify.register(fastifyOauth2, {
 		auth: fastifyOauth2.GOOGLE_CONFIGURATION,
 	},
 	scope: ["openid", "profile", "email"],
-	startRedirectPath: "/auth/google",
+	startRedirectPath: "/api/auth/google",
 	callbackUri: env.GOOGLE_REDIRECT_URI,
 	cookie: {
 		secure: env.NODE_ENV === "production",

apps/server/src/routers/index.ts

@@ -1,17 +1,17 @@
 import type { FastifyInstance } from "fastify";
 import { authRoutes } from "./auth";
 import { postRoutes } from "./posts";
+import { statsRoutes } from "./stats";
 import { threadRoutes } from "./threads";
 import { topicRoutes } from "./topics";
 import { userRoutes } from "./user";
 
 export async function appRouter(fastify: FastifyInstance) {
-	// Ensure the request object has a userId property at runtime
-	// Middleware will assign the real ID when authenticated
 	fastify.decorateRequest("userId", undefined);
-	fastify.register(authRoutes, { prefix: "/auth" });
-	fastify.register(userRoutes, { prefix: "/user" });
-	fastify.register(topicRoutes);
-	fastify.register(threadRoutes);
-	fastify.register(postRoutes);
+	fastify.register(authRoutes, { prefix: "/api/auth" });
+	fastify.register(userRoutes, { prefix: "/api/user" });
+	fastify.register(topicRoutes, { prefix: "/api" });
+	fastify.register(threadRoutes, { prefix: "/api" });
+	fastify.register(postRoutes, { prefix: "/api" });
+	fastify.register(statsRoutes, { prefix: "/api" });
 }

apps/server/src/routers/posts.ts

@@ -44,22 +44,18 @@ export async function postRoutes(fastify: FastifyInstance) {
       const threadId = params.data.id;
       try {
         const postsQuery = DrizzleClient.select({
-            // Post Data
             postId: postsTable.id,
             content: postsTable.content,
             createdAt: postsTable.createdAt,
-            // Assuming we will track likes/votes later
             likes: postsTable.vote, 
 
-            // Author/User Data
             authorId: usersTable.id,
             authorName:sql<string>`
                 CASE 
                     WHEN ${usersTable.username} IS NOT NULL THEN ${usersTable.username} 
                     ELSE ${usersTable.firstName} 
                 END
             `.as('authorName'), 
-            // authorRole: usersTable.role,     
 
 
 
@@ -71,7 +67,6 @@ export async function postRoutes(fastify: FastifyInstance) {
         .limit(limit)
         .offset(offset);
 
-        // --- 🎯 COUNT QUERY (remains the same) ---
         const countQuery = DrizzleClient.select({ total: count() })
             .from(postsTable)
             .where(eq(postsTable.threadId, threadId));
@@ -138,7 +133,6 @@ export async function postRoutes(fastify: FastifyInstance) {
 					.status(400)
 					.send({ success: false, error: "Invalid request body" });
 
-			// Ensure thread exists
 			const thread = await DrizzleClient.query.threads.findFirst({
 				where: (t, { eq }) => eq(t.id, body.data.threadId),
 			});

apps/server/src/routers/stats.ts

@@ -0,0 +1,45 @@
+import { count } from "drizzle-orm";
+import type { FastifyInstance } from "fastify";
+import { DrizzleClient } from "../db/index";
+import { posts as postsTable } from "../db/schema/post.schema";
+import { threads as threadsTable } from "../db/schema/thread.schema";
+import { topics as topicsTable } from "../db/schema/topic.schema";
+import { users as usersTable } from "../db/schema/user.schema";
+import { optionalAuth } from "./auth";
+
+export async function statsRoutes(fastify: FastifyInstance) {
+	fastify.get(
+		"/stats",
+		{
+			preHandler: optionalAuth,
+		},
+		async (request, reply) => {
+			try {
+				const [topicsCount, threadsCount, postsCount, usersCount] =
+					await Promise.all([
+						DrizzleClient.select({ total: count() }).from(topicsTable),
+						DrizzleClient.select({ total: count() }).from(threadsTable),
+						DrizzleClient.select({ total: count() }).from(postsTable),
+						DrizzleClient.select({ total: count() }).from(usersTable),
+					]);
+
+				return reply.status(200).send({
+					success: true,
+					stats: {
+						totalTopics: topicsCount[0]?.total ?? 0,
+						totalThreads: threadsCount[0]?.total ?? 0,
+						totalPosts: postsCount[0]?.total ?? 0,
+						totalMembers: usersCount[0]?.total ?? 0,
+					},
+				});
+			} catch (error) {
+				fastify.log.error("Error fetching stats:", error);
+				return reply.status(500).send({
+					success: false,
+					error: "Failed to fetch stats",
+				});
+			}
+		},
+	);
+}
+