Function getGroupStats

packages/db/src/services/group.service.ts:253–288

(
  projectId: string,
  groupIds: string[]
)

};

export async function getGroupStats(
  projectId: string,
  groupIds: string[]
): Promise<Map<string, IServiceGroupStats>> {
  if (groupIds.length === 0) {
    return new Map();
  }

  const rows = await chQuery<{
    group_id: string;
    member_count: number;
    last_active_at: string;
  }>(`
    SELECT
      g AS group_id,
      uniqExact(profile_id) AS member_count,
      max(created_at) AS last_active_at
    FROM ${TABLE_NAMES.events}
    ARRAY JOIN groups AS g
    WHERE project_id = ${sqlstring.escape(projectId)}
      AND g IN (${groupIds.map((id) => sqlstring.escape(id)).join(',')})
      AND profile_id != device_id
    GROUP BY g
  `);

  return new Map(
    rows.map((r) => [
      r.group_id,
      {
        groupId: r.group_id,
        memberCount: r.member_count,
        lastActiveAt: r.last_active_at ? new Date(r.last_active_at) : null,
      },
    ])
  );
}

export async function getGroupsByIds(
  projectId: string,