feat(life): add comments and replies to life posts

Introduce life_post_comments table for nested comment threads Add API endpoints to create, reply to, and delete comments Implement frontend UI with engagement counts and collapsible threads
2026-05-01 21:29:25 +08:00
parent cd1891cc82
commit a683982b80
9 changed files with 854 additions and 6 deletions
--- a/backend/db/schema.sql
+++ b/backend/db/schema.sql
@@ -134,6 +134,24 @@ ALTER TABLE life_posts DROP COLUMN IF EXISTS link_title;
 CREATE INDEX IF NOT EXISTS life_posts_created_at_idx
  ON life_posts(created_at DESC, id DESC);

+CREATE TABLE IF NOT EXISTS life_post_comments (
+  id integer GENERATED BY DEFAULT AS IDENTITY PRIMARY KEY,
+  post_id integer NOT NULL REFERENCES life_posts(id) ON DELETE CASCADE,
+  parent_comment_id integer REFERENCES life_post_comments(id) ON DELETE SET NULL,
+  body text NOT NULL CHECK (length(body) BETWEEN 1 AND 1000),
+  created_by_user_id integer REFERENCES users(id) ON DELETE SET NULL,
+  deleted_by_user_id integer REFERENCES users(id) ON DELETE SET NULL,
+  deleted_at timestamptz,
+  created_at timestamptz NOT NULL DEFAULT now(),
+  updated_at timestamptz NOT NULL DEFAULT now()
+);
+
+CREATE INDEX IF NOT EXISTS life_post_comments_post_idx
+  ON life_post_comments(post_id, created_at, id);
+
+CREATE INDEX IF NOT EXISTS life_post_comments_parent_idx
+  ON life_post_comments(parent_comment_id, created_at, id);
+
 CREATE TABLE IF NOT EXISTS skills (
  id integer GENERATED BY DEFAULT AS IDENTITY PRIMARY KEY,
  name text NOT NULL UNIQUE,
--- a/backend/src/queries.ts
+++ b/backend/src/queries.ts
@@ -108,6 +108,38 @@ type LifePostPayload = {
  body: string;
 };

+type LifeCommentPayload = {
+  body: string;
+};
+
+type LifeCommentRow = {
+  id: number;
+  postId: number;
+  parentCommentId: number | null;
+  body: string;
+  deleted: boolean;
+  createdAt: Date;
+  updatedAt: Date;
+  author: { id: number; displayName: string } | null;
+};
+
+type LifeComment = LifeCommentRow & {
+  replies: LifeComment[];
+};
+
+type LifePostRow = {
+  id: number;
+  body: string;
+  createdAt: Date;
+  updatedAt: Date;
+  author: { id: number; displayName: string } | null;
+  updatedBy: { id: number; displayName: string } | null;
+};
+
+type LifePost = LifePostRow & {
+  comments: LifeComment[];
+};
+
 type HabitatPayload = {
  name: string;
  translations: TranslationInput;
@@ -1181,6 +1213,15 @@ function cleanLifePostPayload(payload: Record<string, unknown>): LifePostPayload
  return { body };
 }

+function cleanLifeCommentPayload(payload: Record<string, unknown>): LifeCommentPayload {
+  const body = cleanName(payload.body, 'Please enter a comment');
+  if (body.length > 1000) {
+    throw validationError('Comment is too long');
+  }
+
+  return { body };
+}
+
 function lifePostProjection(): string {
  return `
    SELECT
@@ -1202,21 +1243,115 @@ function lifePostProjection(): string {
  `;
 }

-export function listLifePosts() {
-  return query(`
+function lifeCommentProjection(whereClause: string): string {
+  return `
+    SELECT
+      lc.id,
+      lc.post_id AS "postId",
+      lc.parent_comment_id AS "parentCommentId",
+      CASE WHEN lc.deleted_at IS NULL THEN lc.body ELSE '' END AS body,
+      lc.deleted_at IS NOT NULL AS deleted,
+      lc.created_at AS "createdAt",
+      lc.updated_at AS "updatedAt",
+      CASE
+        WHEN lc.deleted_at IS NOT NULL OR comment_user.id IS NULL THEN NULL
+        ELSE json_build_object('id', comment_user.id, 'displayName', comment_user.display_name)
+      END AS author
+    FROM life_post_comments lc
+    LEFT JOIN users comment_user ON comment_user.id = lc.created_by_user_id
+    ${whereClause}
+  `;
+}
+
+function buildLifeCommentTree(rows: LifeCommentRow[]): LifeComment[] {
+  const comments = new Map<number, LifeComment>();
+  const topLevelComments: LifeComment[] = [];
+
+  for (const row of rows) {
+    comments.set(row.id, { ...row, replies: [] });
+  }
+
+  for (const comment of comments.values()) {
+    if (comment.parentCommentId === null) {
+      topLevelComments.push(comment);
+      continue;
+    }
+
+    const parent = comments.get(comment.parentCommentId);
+    if (parent?.parentCommentId === null) {
+      parent.replies.push(comment);
+    } else {
+      topLevelComments.push(comment);
+    }
+  }
+
+  return topLevelComments;
+}
+
+async function lifeCommentsForPosts(postIds: number[]): Promise<Map<number, LifeComment[]>> {
+  const commentsByPost = new Map<number, LifeComment[]>();
+  if (postIds.length === 0) {
+    return commentsByPost;
+  }
+
+  const rows = await query<LifeCommentRow>(
+    `
+      ${lifeCommentProjection('WHERE lc.post_id = ANY($1::integer[])')}
+      ORDER BY lc.created_at, lc.id
+    `,
+    [postIds]
+  );
+
+  for (const postId of postIds) {
+    commentsByPost.set(postId, buildLifeCommentTree(rows.filter((comment) => comment.postId === postId)));
+  }
+
+  return commentsByPost;
+}
+
+async function getLifeCommentById(id: number): Promise<LifeComment | null> {
+  const row = await queryOne<LifeCommentRow>(
+    `
+      ${lifeCommentProjection('WHERE lc.id = $1')}
+    `,
+    [id]
+  );
+
+  return row ? { ...row, replies: [] } : null;
+}
+
+export async function listLifePosts(): Promise<LifePost[]> {
+  const posts = await query<LifePostRow>(`
    ${lifePostProjection()}
    ORDER BY lp.created_at DESC, lp.id DESC
  `);
+
+  const commentsByPost = await lifeCommentsForPosts(posts.map((post) => post.id));
+
+  return posts.map((post) => ({
+    ...post,
+    comments: commentsByPost.get(post.id) ?? []
+  }));
 }

-async function getLifePostById(id: number) {
-  return queryOne(
+async function getLifePostById(id: number): Promise<LifePost | null> {
+  const post = await queryOne<LifePostRow>(
    `
      ${lifePostProjection()}
      WHERE lp.id = $1
    `,
    [id]
  );
+
+  if (!post) {
+    return null;
+  }
+
+  const commentsByPost = await lifeCommentsForPosts([post.id]);
+  return {
+    ...post,
+    comments: commentsByPost.get(post.id) ?? []
+  };
 }

 export async function createLifePost(payload: Record<string, unknown>, userId: number) {
@@ -1265,6 +1400,63 @@ export async function deleteLifePost(id: number, userId: number) {
  return Boolean(result);
 }

+export async function createLifeComment(postId: number, payload: Record<string, unknown>, userId: number) {
+  const cleanPayload = cleanLifeCommentPayload(payload);
+
+  const result = await queryOne<{ id: number }>(
+    `
+      INSERT INTO life_post_comments (post_id, body, created_by_user_id)
+      SELECT $1, $2, $3
+      WHERE EXISTS (SELECT 1 FROM life_posts WHERE id = $1)
+      RETURNING id
+    `,
+    [postId, cleanPayload.body, userId]
+  );
+
+  return result ? getLifeCommentById(result.id) : null;
+}
+
+export async function createLifeCommentReply(
+  postId: number,
+  commentId: number,
+  payload: Record<string, unknown>,
+  userId: number
+) {
+  const cleanPayload = cleanLifeCommentPayload(payload);
+
+  const result = await queryOne<{ id: number }>(
+    `
+      INSERT INTO life_post_comments (post_id, parent_comment_id, body, created_by_user_id)
+      SELECT lc.post_id, lc.id, $3, $4
+      FROM life_post_comments lc
+      WHERE lc.post_id = $1
+        AND lc.id = $2
+        AND lc.parent_comment_id IS NULL
+        AND lc.deleted_at IS NULL
+      RETURNING id
+    `,
+    [postId, commentId, cleanPayload.body, userId]
+  );
+
+  return result ? getLifeCommentById(result.id) : null;
+}
+
+export async function deleteLifeComment(id: number, userId: number) {
+  const result = await queryOne<{ id: number }>(
+    `
+      UPDATE life_post_comments
+      SET deleted_at = now(), deleted_by_user_id = $2, updated_at = now()
+      WHERE id = $1
+        AND created_by_user_id = $2
+        AND deleted_at IS NULL
+      RETURNING id
+    `,
+    [id, userId]
+  );
+
+  return Boolean(result);
+}
+
 export function isConfigType(type: string): type is ConfigType {
  return Object.hasOwn(configDefinitions, type);
 }
--- a/backend/src/server.ts
+++ b/backend/src/server.ts
@@ -10,6 +10,8 @@ import {
  createHabitat,
  createItem,
  createLanguage,
+  createLifeComment,
+  createLifeCommentReply,
  createLifePost,
  createPokemon,
  createRecipe,
@@ -18,6 +20,7 @@ import {
  deleteHabitat,
  deleteItem,
  deleteLanguage,
+  deleteLifeComment,
  deleteLifePost,
  deletePokemon,
  deleteRecipe,
@@ -182,6 +185,31 @@ app.post('/api/life-posts', async (request, reply) => {
  return user ? reply.code(201).send(await createLifePost(request.body as Record<string, unknown>, user.id)) : undefined;
 });

+app.post('/api/life-posts/:postId/comments', async (request, reply) => {
+  const user = await requireVerifiedUser(request, reply);
+  if (!user) {
+    return;
+  }
+  const { postId } = request.params as { postId: string };
+  const comment = await createLifeComment(Number(postId), request.body as Record<string, unknown>, user.id);
+  return comment ? reply.code(201).send(comment) : reply.code(404).send({ message: 'Not found' });
+});
+
+app.post('/api/life-posts/:postId/comments/:commentId/replies', async (request, reply) => {
+  const user = await requireVerifiedUser(request, reply);
+  if (!user) {
+    return;
+  }
+  const { postId, commentId } = request.params as { postId: string; commentId: string };
+  const comment = await createLifeCommentReply(
+    Number(postId),
+    Number(commentId),
+    request.body as Record<string, unknown>,
+    user.id
+  );
+  return comment ? reply.code(201).send(comment) : reply.code(404).send({ message: 'Not found' });
+});
+
 app.put('/api/life-posts/:id', async (request, reply) => {
  const user = await requireVerifiedUser(request, reply);
  if (!user) {
@@ -202,6 +230,16 @@ app.delete('/api/life-posts/:id', async (request, reply) => {
  return deleted ? reply.code(204).send() : reply.code(404).send({ message: 'Not found' });
 });

+app.delete('/api/life-comments/:id', async (request, reply) => {
+  const user = await requireVerifiedUser(request, reply);
+  if (!user) {
+    return;
+  }
+  const { id } = request.params as { id: string };
+  const deleted = await deleteLifeComment(Number(id), user.id);
+  return deleted ? reply.code(204).send() : reply.code(404).send({ message: 'Not found' });
+});
+
 app.get('/api/pokemon', async (request) =>
  listPokemon(request.query as Record<string, string | string[] | undefined>, requestLocale(request))
 );