Function organizationFromDatabase

apps/cloud/src/mcp/session-meta.ts:139–182

(
  organizationId: string,
)

 * defect.
 */
const organizationFromDatabase = (
  organizationId: string,
): Effect.Effect<
  { readonly id: string; readonly name: string; readonly slug?: string },
  McpSessionMetaUnavailableError | OrganizationNotFoundError,
  UserStoreService | WorkOSClient
> =>
  Effect.gen(function* () {
    let attempts = 0;
    // `Effect.retry` retries every failure it sees, so definitive failures are
    // lifted OUT of the error channel before the schedule ever runs and only
    // the retryable ones are left in it.
    const attempt = Effect.suspend(() => {
      attempts += 1;
      return resolveOrganization(organizationId).pipe(
        Effect.result,
        Effect.flatMap((outcome) =>
          Result.isFailure(outcome) && isRetryableOrganizationLookupFailure(outcome.failure)
            ? Effect.fail(outcome.failure)
            : Effect.succeed(outcome),
        ),
      );
    });

    // Two nested Results: the outer one is "the retries ran out", the inner one
    // is "the lookup failed definitively on the first look". Both mean the same
    // thing to the caller.
    const retried = yield* attempt.pipe(Effect.retry(RETRY_SCHEDULE), Effect.result);
    const outcome = Result.isFailure(retried) ? Result.fail(retried.failure) : retried.success;

    if (Result.isFailure(outcome)) {
      return yield* new McpSessionMetaUnavailableError({
        reason: failureReason(outcome.failure),
        attempts,
      });
    }
    const organization = outcome.success;
    if (!organization) return yield* new OrganizationNotFoundError({ organizationId });
    return organization;
  }).pipe(
    Effect.withSpan("mcp.session.resolve_organization", {
      attributes: { "mcp.auth.organization_id": organizationId },
    }),
  );

/**
 * Build the session meta for an init, preferring the org identity the request