Function readMembershipTierFromClient

server/src/db/organization-db.ts:275–284

(
  client: PoolClient,
  orgId: string,
  opts: { forUpdate?: boolean } = {},
)

 * caller needs to lock the organizations row as well.
 */
export async function readMembershipTierFromClient(
  client: PoolClient,
  orgId: string,
  opts: { forUpdate?: boolean } = {},
): Promise<MembershipTier | null> {
  const lockSuffix = opts.forUpdate ? ' FOR UPDATE' : '';
  const sql = `SELECT ${MEMBERSHIP_TIER_COLUMNS.join(', ')} FROM organizations WHERE workos_organization_id = $1${lockSuffix}`;
  const result = await client.query<MembershipTierRow>(sql, [orgId]);
  return resolveMembershipTier(result.rows[0] ?? null);
}

/**
 * Infer membership tier from subscription amount and organization type.