fix: update resource ID in GET comments API and streamline SQL query execution

Author: kingRayhan

src/app/api/play/route.ts

@@ -3,7 +3,7 @@ import { NextResponse } from "next/server";
 
 export async function GET() {
   const comments = await getComments({
-    resource_id: "05553726-5168-41f3-b2d1-5d27cf5c8beb",
+    resource_id: "16196e73-275a-4af5-9186-39a5fec4244e",
     resource_type: "ARTICLE",
   });
 

src/backend/persistence/sql-functions/get_comments.sql

@@ -1,3 +1,10 @@
+-- Thanks claude 🥰 for the help with this function
+-- Function to recursively fetch comments and their replies up to a certain level
+-- This function retrieves comments for a given resource and organizes them in a nested structure
+-- It uses recursion to fetch replies to comments, limiting the depth to 3 levels
+-- Function: public.get_comments(p_resource_id uuid, p_resource_type character varying, p_parent_id uuid DEFAULT NULL::uuid, p_current_level integer DEFAULT 0)
+
+
 CREATE OR REPLACE FUNCTION public.get_comments(
   p_resource_id uuid, 
   p_resource_type character varying, 
@@ -52,7 +59,7 @@ BEGIN
                     'id', u.id,
                     'name', u.name,
                     'email', u.email,
-                    'username', u.username  -- Fixed: was 'useruser'
+                    'username', u.username
                 ),
                 'replies', get_comments(p_resource_id, p_resource_type, c.id, p_current_level + 1)
             ) ORDER BY c.created_at

src/backend/services/comment.action.ts

@@ -13,86 +13,14 @@ export const getComments = async (
   const input = CommentActionInput.getComments.parse(_input);
 
   const query = sql`
-    WITH RECURSIVE comment_tree AS (
-        -- Root comments
-        SELECT 
-            id, body, user_id, created_at, resource_id, resource_type,
-            0 as level,
-            id as root_id
-        FROM comments 
-        WHERE resource_id = $1 
-          AND resource_type = $2
-        
-        UNION ALL
-        
-        -- Nested replies (up to level 3)
-        SELECT 
-            c.id, c.body, c.user_id, c.created_at, c.resource_id, c.resource_type,
-            ct.level + 1,
-            ct.root_id
-        FROM comments c
-        JOIN comment_tree ct ON c.resource_id = ct.id
-        WHERE c.resource_type = 'COMMENT'
-          AND ct.level < 3  -- This allows up to level 3 (0, 1, 2, 3)
-    ),
-    -- Function to build replies recursively
-    build_replies(parent_id, max_level) AS (
-        SELECT 
-            ct.resource_id as parent_id,
-            3 as max_level,
-            json_agg(
-                json_build_object(
-                    'id', ct.id,
-                    'body', ct.body,
-                    'level', ct.level,
-                    'created_at', ct.created_at,
-                    'parent_id', ct.resource_id,
-                    'author', json_build_object(
-                        'name', u.name,
-                        'email', u.email
-                    ),
-                    'replies', CASE 
-                        WHEN ct.level < 3 THEN 
-                            COALESCE(
-                                (SELECT json_agg(child_reply ORDER BY (child_reply->>'created_at')::timestamp)
-                                FROM build_replies(ct.id, 3) br
-                                CROSS JOIN json_array_elements(br.replies) as child_reply),
-                                '[]'::json
-                            )
-                        ELSE '[]'::json
-                    END
-                ) ORDER BY ct.created_at
-            ) as replies
-        FROM comment_tree ct
-        JOIN users u ON ct.user_id = u.id
-        WHERE ct.resource_id = parent_id AND ct.level > 0
-        GROUP BY ct.resource_id
-    )
-    SELECT json_agg(
-        json_build_object(
-            'id', ct.id,
-            'body', ct.body,
-            'level', ct.level,
-            'created_at', ct.created_at,
-            'parent_id', null,
-            'author', json_build_object(
-                'name', u.name,
-                'email', u.email
-            ),
-            'replies', COALESCE(br.replies, '[]'::json)
-        ) ORDER BY ct.created_at
-    ) as comments
-    FROM comment_tree ct
-    JOIN users u ON ct.user_id = u.id
-    LEFT JOIN build_replies(ct.id, 3) br ON true
-    WHERE ct.level = 0;
+    SELECT get_comments($1, $2);
   `;
 
-  const comments = await pgClient?.executeSQL(query, [
+  const execution_response: any = await pgClient?.executeSQL(query, [
     input.resource_id,
     input.resource_type,
   ]);
-  return comments?.rows?.[0]; // Placeholder for actual database query
+  return execution_response?.rows?.[0]?.get_comments;
 };
 
 export const createMyComment = async (