Function acceptInvitation

apps/sim/lib/invitations/core.ts:266–577

(
  input: AcceptInvitationInput
)

}

export async function acceptInvitation(
  input: AcceptInvitationInput
): Promise<AcceptInvitationResult> {
  const inv = await getInvitationById(input.invitationId)

  if (!inv) {
    return { success: false, kind: 'not-found' }
  }

  if (input.token && inv.token !== input.token) {
    return { success: false, kind: 'invalid-token' }
  }

  if (inv.status !== 'pending') {
    return { success: false, kind: 'already-processed' }
  }

  if (isInvitationExpired(inv)) {
    await db
      .update(invitation)
      .set({ status: 'expired', updatedAt: new Date() })
      .where(and(eq(invitation.id, inv.id), eq(invitation.status, 'pending')))
    return { success: false, kind: 'expired' }
  }

  if (normalizeEmail(input.userEmail) !== normalizeEmail(inv.email)) {
    return { success: false, kind: 'email-mismatch' }
  }

  let membershipAlreadyExists = false
  let acceptedMembershipIntent = inv.membershipIntent
  let shouldJoinOrganization = inv.membershipIntent !== 'external'

  const primaryGrant = inv.grants[0]
  let billingOwnerUserId = inv.inviterId
  let workspaceOrganizationId = inv.organizationId
  if (primaryGrant) {
    const grantWorkspace = await getWorkspaceWithOwner(primaryGrant.workspaceId)
    if (grantWorkspace) {
      billingOwnerUserId = grantWorkspace.billedAccountUserId
      workspaceOrganizationId = grantWorkspace.organizationId ?? inv.organizationId
    }
  }

  const existingMembership = await getUserOrganization(input.userId)
  const inviteeAlreadyInDifferentOrg =
    !!existingMembership &&
    (workspaceOrganizationId ? existingMembership.organizationId !== workspaceOrganizationId : true)

  if (shouldJoinOrganization && inviteeAlreadyInDifferentOrg) {
    if (await downgradeOrRejectCrossOrgInvite(inv)) {
      acceptedMembershipIntent = 'external'
      shouldJoinOrganization = false
    } else {
      return { success: false, kind: 'already-in-organization' }
    }
  }