44 lines
1.3 KiB
TypeScript
44 lines
1.3 KiB
TypeScript
import type { Tables } from '@/packages/supabase/src/database.types';
|
|
|
|
import { getSupabaseServerAdminClient } from '@kit/supabase/server-admin-client';
|
|
import { getSupabaseServerClient } from '@kit/supabase/server-client';
|
|
|
|
type Account = Tables<{ schema: 'medreport' }, 'accounts'>;
|
|
type Membership = Tables<{ schema: 'medreport' }, 'accounts_memberships'>;
|
|
|
|
export type AccountWithMemberships = Account & { memberships: Membership[] };
|
|
|
|
export async function getAccount(id: string): Promise<AccountWithMemberships> {
|
|
const { data } = await getSupabaseServerClient()
|
|
.schema('medreport')
|
|
.from('accounts')
|
|
.select('*, memberships: accounts_memberships (*)')
|
|
.eq('id', id)
|
|
.single()
|
|
.throwOnError();
|
|
|
|
return data as unknown as AccountWithMemberships;
|
|
}
|
|
|
|
export async function getAccountAdmin({
|
|
primaryOwnerUserId,
|
|
}: {
|
|
primaryOwnerUserId: string;
|
|
}): Promise<AccountWithMemberships> {
|
|
const query = getSupabaseServerAdminClient()
|
|
.schema('medreport')
|
|
.from('accounts')
|
|
.select('*, memberships: accounts_memberships (*)')
|
|
.eq('is_personal_account', true);
|
|
|
|
if (primaryOwnerUserId) {
|
|
query.eq('primary_owner_user_id', primaryOwnerUserId);
|
|
} else {
|
|
throw new Error('primaryOwnerUserId is required');
|
|
}
|
|
|
|
const { data } = await query.single().throwOnError();
|
|
|
|
return data as unknown as AccountWithMemberships;
|
|
}
|