Function runOAuthCallback

packages/core/api/src/oauth-popup.ts:192–241

(
  input: RunOAuthCallbackInput<TAuth, E, R>,
)

 * can still render and close itself.
 */
export const runOAuthCallback = <TAuth, E, R>(
  input: RunOAuthCallbackInput<TAuth, E, R>,
): Effect.Effect<string, never, R> => {
  const providerError = providerErrorMessage(input.urlParams);
  const callbackState = decodeOAuthCallbackState(input.urlParams.state);
  const sessionId = callbackState?.state ?? input.urlParams.state;
  const result =
    providerError == null
      ? input
          .complete({
            state: sessionId,
            code: input.urlParams.code ?? null,
            error: null,
            callbackDomain: input.urlParams.domain ?? input.urlParams.site ?? null,
          })
          .pipe(
            Effect.map(
              (auth): OAuthPopupResult<TAuth> => ({
                type: OAUTH_POPUP_MESSAGE_TYPE,
                ok: true,
                sessionId,
                ...auth,
              }),
            ),
          )
      : Effect.succeed<OAuthPopupResult<TAuth>>({
          type: OAUTH_POPUP_MESSAGE_TYPE,
          ok: false,
          sessionId,
          error: providerError.short,
          ...(providerError.details ? { errorDetails: providerError.details } : {}),
        });

  return result.pipe(
    Effect.catchCause((cause) => {
      const { short, details } = input.toErrorMessage(Cause.squash(cause));
      return Effect.succeed<OAuthPopupResult<TAuth>>({
        type: OAUTH_POPUP_MESSAGE_TYPE,
        ok: false,
        sessionId,
        error: short,
        ...(details && details !== short ? { errorDetails: details } : {}),
      });
    }),
    Effect.tap((result) =>
      Effect.sync(() => completionListener?.(result as OAuthPopupResult<unknown>)),
    ),
    Effect.map((result) => popupDocument(result, input.channelName)),
  );
};