feat: add comment

Author: ynwd

modules/home/home.handler.ts

@@ -6,6 +6,12 @@ import {
   getPosts,
 } from "@app/modules/home/home.service.ts";
 
+// Add these imports for comment handling
+import {
+  createComment,
+  getCommentsByPostId,
+} from "@app/modules/home/home.service.ts";
+
 export default async function homeHandler(req: HttpRequest, ctx: Context) {
   const ses = await getSession(req, ctx);
   const isLogin = ses?.isLogin;
@@ -128,3 +134,90 @@ export async function deletePostHandler(req: HttpRequest, ctx: Context) {
     });
   }
 }
+
+// Handle comment creation
+export async function commentHandler(req: HttpRequest, ctx: Context) {
+  try {
+    const body = await req.json();
+    const { content, postId } = body;
+
+    if (!content || typeof content !== "string" || content.trim() === "") {
+      return new Response(JSON.stringify({ error: "Content is required" }), {
+        status: 400,
+        headers: { "Content-Type": "application/json" },
+      });
+    }
+
+    if (!postId) {
+      return new Response(JSON.stringify({ error: "Post ID is required" }), {
+        status: 400,
+        headers: { "Content-Type": "application/json" },
+      });
+    }
+
+    // Get the user from session
+    const ses = await getSession(req, ctx);
+    if (!ses?.isLogin) {
+      return new Response(
+        JSON.stringify({ error: "Login required to comment" }),
+        {
+          status: 401,
+          headers: { "Content-Type": "application/json" },
+        },
+      );
+    }
+
+    const username = ses.username || "";
+
+    // Create the comment
+    const comment = await createComment({
+      content,
+      postId,
+      author: username,
+    });
+
+    return new Response(JSON.stringify(comment), {
+      status: 201,
+      headers: {
+        "Content-Type": "application/json",
+      },
+    });
+  } catch (error) {
+    console.error("Error processing comment request:", error);
+    return new Response(JSON.stringify({ error: "Invalid request" }), {
+      status: 400,
+      headers: { "Content-Type": "application/json" },
+    });
+  }
+}
+
+// Get comments for a post
+export async function getCommentsHandler(req: HttpRequest, _ctx: Context) {
+  try {
+    const url = new URL(req.url);
+    const pathParts = url.pathname.split("/");
+    const postId = pathParts[pathParts.length - 1];
+
+    if (!postId) {
+      return new Response(JSON.stringify({ error: "Post ID is required" }), {
+        status: 400,
+        headers: { "Content-Type": "application/json" },
+      });
+    }
+
+    const comments = await getCommentsByPostId(postId);
+
+    return new Response(JSON.stringify(comments), {
+      status: 200,
+      headers: {
+        "Content-Type": "application/json",
+      },
+    });
+  } catch (error) {
+    console.error("Error fetching comments:", error);
+    return new Response(JSON.stringify({ error: "Server error" }), {
+      status: 500,
+      headers: { "Content-Type": "application/json" },
+    });
+  }
+}

modules/home/home.service.ts

@@ -103,3 +103,65 @@ export async function deletePostById(id: string): Promise<boolean> {
     return false;
   }
 }
+
+// Comment interface
+interface CommentInput {
+  content: string;
+  postId: string;
+  author: string;
+}
+
+interface Comment {
+  id: string;
+  content: string;
+  postId: string;
+  timestamp: string;
+  author: string;
+}
+
+// Create a new comment
+export async function createComment(input: CommentInput): Promise<Comment> {
+  const id = ulid();
+  const comment: Comment = {
+    id,
+    content: input.content,
+    postId: input.postId,
+    timestamp: new Date().toISOString(),
+    author: input.author,
+  };
+
+  const primaryKey = ["comments", id];
+  console.log("Creating comment with ID:", id);
+
+  const atomic = kv.atomic()
+    .check({ key: primaryKey, versionstamp: null })
+    .set(primaryKey, comment);
+
+  const res = await atomic.commit();
+  console.log("Comment creation result:", res);
+  if (!res.ok) throw new Error("Failed to create comment");
+
+  return comment;
+}
+
+// Get comments for a specific post
+export async function getCommentsByPostId(postId: string): Promise<Comment[]> {
+  console.log("Fetching comments for post:", postId);
+  const results: Comment[] = [];
+
+  const iterator = kv.list<Comment>({ prefix: ["comments"] });
+
+  for await (const entry of iterator) {
+    if (entry.value.postId === postId) {
+      results.push(entry.value);
+    }
+  }
+
+  // Sort comments by timestamp (newest first)
+  const comments = results.sort((a, b) =>
+    new Date(a.timestamp).getTime() - new Date(b.timestamp).getTime()
+  );
+
+  console.log(`Retrieved ${comments.length} comments for post ${postId}`);
+  return comments;
+}

modules/home/mod.ts

@@ -2,7 +2,9 @@ import { Fastro } from "@app/mod.ts";
 import pageLayout from "@app/modules/home/home.layout.tsx";
 import pageComponent from "@app/modules/home/home.page.tsx";
 import pageHandler, {
+  commentHandler,
   deletePostHandler,
+  getCommentsHandler,
   postHandler,
 } from "@app/modules/home/home.handler.ts";
 import postDetailComponent from "@app/modules/home/post.page.tsx";
@@ -33,9 +35,8 @@ export default function (s: Fastro) {
   // Add API endpoint for deleting a post
   s.delete("/api/post/:id", deletePostHandler);
 
-  // Log registered routes after registration
-  // console.log("Registered pages:", Object.keys(s.getPages()));
-  // console.log("Registered routes:", Object.keys(s.getRoutes()));
+  s.post("/api/comment", commentHandler);
+  s.get("/api/comments/:id", getCommentsHandler);
 
   return s;
 }