Profiles & Invitations

organization({
  allowUserToCreateOrganization: async (user) => {
    // Only the global admin can create profiles (organizations)
    const dbUser = db
      .select({ role: schema.user.role })
      .from(schema.user)
      .where(eq(schema.user.id, user.id))
      .get();
    return dbUser?.role === 'admin';
  },
})

activeOrganizationId: text('active_organization_id').references(() => organization.id, {
  onDelete: 'set null',
})

export const load: PageServerLoad = async ({ params, locals, url, request }) => {
  const invitationId = params.id;

  if (!locals.user) {
    // Redirect to login with return URL
    throw redirect(302, `/login?redirectTo=${encodeURIComponent(url.pathname)}`);
  }

  try {
    // Accept invitation
    await auth.api.acceptInvitation({
      body: {
        invitationId,
      },
      headers: request.headers,
    });

    // Redirect to home on success
    throw redirect(302, '/');
  } catch (error) {
    // Handle errors
    const errorMessage = 'Failed to accept invitation. It may be invalid or expired.';
    return {
      error: errorMessage,
    };
  }
};

organizationId: text('organization_id').references(() => organization.id, { 
  onDelete: 'set null' 
})

uniqueIndex('media_organization_infohash_unique').on(table.organizationId, table.infohash)

const memberCounts = db
  .select({
    organizationId: schema.member.organizationId,
    count: sql<number>`count(*)`,
  })
  .from(schema.member)
  .groupBy(schema.member.organizationId)
  .all();

if (allOrgs.length === 0 && isAdmin) {
  throw redirect(302, '/onboarding');
}