ENG-1723-list-group-members-backend

Author: maparent

apps/website/app/utils/supabase/account.ts

@@ -1,5 +1,44 @@
+import type { Database } from "@repo/database/dbTypes";
 import type { DGSupabaseClient } from "@repo/database/lib/client";
 
+type AgentType = Database["public"]["Enums"]["AgentType"] | "group";
+
+export const getGroupMemberList = async (
+  client: DGSupabaseClient,
+  groupId: string,
+): Promise<
+  {
+    id: string;
+    name: string;
+    agentType: AgentType; // eslint-disable-line @typescript-eslint/naming-convention
+    admin: boolean;
+  }[]
+> => {
+  // eslint-disable-next-line @typescript-eslint/naming-convention
+  const results = await client.rpc("group_members", { p_group_id: groupId });
+  if (results.error) throw results.error;
+  if (!results.data) return [];
+  return (
+    results.data
+      // eslint-disable-next-line @typescript-eslint/naming-convention
+      .map(({ id, name, agent_type, admin }) => ({
+        id,
+        name,
+        agentType: agent_type,
+        admin,
+      }))
+      .filter(
+        ({ id, name, agentType, admin }) =>
+          admin !== null && id !== null && name !== null && agentType !== null,
+      ) as unknown as {
+      admin: boolean;
+      id: string;
+      name: string;
+      agentType: AgentType;
+    }[]
+  );
+};
+
 export const createGroup = async (
   client: DGSupabaseClient,
   name: string,

packages/database/src/dbTypes.ts

@@ -1530,6 +1530,16 @@ export type Database = {
         Returns: string
       }
       group_exists: { Args: { group_id_: string }; Returns: boolean }
+      group_members: {
+        Args: { p_group_id: string }
+        Returns: Database["public"]["CompositeTypes"]["group_member_info"][]
+        SetofOptions: {
+          from: "*"
+          to: "group_member_info"
+          isOneToOne: false
+          isSetofReturn: true
+        }
+      }
       in_group: { Args: { group_id_: string }; Returns: boolean }
       in_space: {
         Args: {
@@ -1832,6 +1842,13 @@ export type Database = {
           | Database["public"]["CompositeTypes"]["account_local_input"]
           | null
       }
+      group_member_info: {
+        id: number | null
+        name: string | null
+        platform: Database["public"]["Enums"]["Platform"] | null
+        agent_type: Database["public"]["Enums"]["AgentType"] | null
+        admin: boolean | null
+      }
       inline_embedding_input: {
         model: string | null
         vector: number[] | null

packages/database/supabase/migrations/20260512130625_group_members_function.sql

@@ -0,0 +1,35 @@
+CREATE OR REPLACE VIEW public.my_accounts AS
+SELECT
+    id,
+    name,
+    platform,
+    account_local_id,
+    write_permission,
+    active,
+    agent_type,
+    metadata,
+    dg_account
+FROM public."PlatformAccount"
+WHERE id IN (
+    SELECT "LocalAccess".account_id FROM public."LocalAccess"
+        JOIN public."SpaceAccess" USING (space_id)
+        JOIN public.my_user_accounts() ON (account_uid = my_user_accounts)
+    WHERE permissions >= 'partial'
+    UNION
+    SELECT id FROM public."PlatformAccount" WHERE dg_account = auth.uid()
+);
+
+CREATE TYPE public.group_member_info AS (
+    id BIGINT,
+    name VARCHAR,
+    platform public."Platform",
+    agent_type public."AgentType",
+    admin boolean
+);
+
+CREATE OR REPLACE FUNCTION public.group_members(p_group_id UUID) RETURNS SETOF public.group_member_info
+STABLE
+SET search_path = ''
+LANGUAGE sql AS $$
+    SELECT pa.id, pa.name, pa.platform, pa.agent_type, gm.admin FROM public.my_accounts AS pa JOIN public.group_membership AS gm ON (pa.dg_account=gm.member_id) WHERE gm.group_id=p_group_id;
+$$;

packages/database/supabase/schemas/account.sql

@@ -454,8 +454,25 @@ WHERE id IN (
         JOIN public."SpaceAccess" USING (space_id)
         JOIN public.my_user_accounts() ON (account_uid = my_user_accounts)
     WHERE permissions >= 'partial'
+    UNION
+    SELECT id FROM public."PlatformAccount" WHERE dg_account = auth.uid()
 );
 
+CREATE TYPE public.group_member_info AS (
+    id BIGINT,
+    name VARCHAR,
+    platform public."Platform",
+    agent_type public."AgentType",
+    admin boolean
+);
+
+CREATE OR REPLACE FUNCTION public.group_members(p_group_id UUID) RETURNS SETOF public.group_member_info
+STABLE
+SET search_path = ''
+LANGUAGE sql AS $$
+    SELECT pa.id, pa.name, pa.platform, pa.agent_type, gm.admin FROM public.my_accounts AS pa JOIN public.group_membership AS gm ON (pa.dg_account=gm.member_id) WHERE gm.group_id=p_group_id;
+$$;
+
 DROP POLICY IF EXISTS platform_account_policy ON public."PlatformAccount";
 
 DROP POLICY IF EXISTS platform_account_select_policy ON public."PlatformAccount";