Function registerDynamicClient

packages/core/sdk/src/oauth-service.ts:1418–1505

(
    input: RegisterDynamicClientInput,
  )

    });

  const registerDynamicClient = (
    input: RegisterDynamicClientInput,
  ): Effect.Effect<
    OAuthClientSlug,
    OAuthRegisterDynamicError | OrgWriteDeniedError | StorageFailure
  > =>
    Effect.gen(function* () {
      yield* deps.guardOrgWrite(input.owner);
      const issuer = canonicalDcrIssuer(input.issuer, input.registrationEndpoint);
      // Resolved before the reuse decision: a persisted client registered with
      // a DIFFERENT callback must not be reused (strict servers 400 the
      // authorize request), so the reuse lookup compares against this value.
      const flowRedirectUri = input.redirectUri ?? redirectUri ?? null;
      const reuse = yield* decideDcrClientReuse(input, issuer, flowRedirectUri);
      if (reuse.existingSlug !== null) return reuse.existingSlug;

      const slug = reuse.registrationSlug;
      // DCR registers our callback as the client's redirect_uri — fail loudly
      // if the executor has none rather than registering a localhost URL.
      if (flowRedirectUri == null) {
        return yield* new OAuthRegisterDynamicError({
          message: REDIRECT_URI_REQUIRED_MESSAGE,
        });
      }
      const authMethod = pickDcrAuthMethod(input.tokenEndpointAuthMethodsSupported);
      const registrationScopes = dedupeScopes([
        ...input.scopes,
        ...additionalAuthorizationLifecycleScopes(input),
      ]);
      const information = yield* registerDynamicClientDcr(
        {
          registrationEndpoint: input.registrationEndpoint,
          metadata: {
            client_name: input.clientName,
            redirect_uris: [flowRedirectUri],
            grant_types: ["authorization_code", "refresh_token"],
            response_types: ["code"],
            token_endpoint_auth_method: authMethod,
            application_type: isLoopbackHttpUrl(flowRedirectUri) ? "native" : "web",
            scope: registrationScopes.length > 0 ? registrationScopes.join(" ") : undefined,
          },
        },
        { httpClientLayer, endpointUrlPolicy: deps.endpointUrlPolicy },
      ).pipe(
        Effect.mapError((cause) => {
          // Some authorization servers (Vercel, and others that follow RFC 8252
          // strictly) reject anonymous Dynamic Client Registration unless the
          // redirect URI is loopback (http://localhost or http://127.0.0.1).
          // Executor registers its browser origin, so any hosted, tailnet, or
          // LAN origin trips `invalid_redirect_uri`. Turn that opaque RFC code
          // into guidance the user can act on instead of the raw error.
          // oxlint-disable-next-line executor/no-unknown-error-message -- boundary: OAuthDiscoveryError carries a typed `message`
          const rawMessage = cause.message;
          const message =
            cause.error === "invalid_redirect_uri" && !isLoopbackHttpUrl(flowRedirectUri)
              ? `Automatic OAuth setup failed: this server only approves loopback redirect ` +
                `URLs (http://localhost or http://127.0.0.1) for automatic registration, but ` +
                `Executor is using ${flowRedirectUri}. Register an OAuth app manually with that ` +