feat(oidc-client): improve Effect usage

Author: cerebrl

packages/oidc-client/src/lib/authorize.request.ts

@@ -1,9 +1,12 @@
+<<<<<<< HEAD
 /*
  * Copyright (c) 2025 Ping Identity Corporation. All rights reserved.
  *
  * This software may be modified and distributed under the terms
  * of the MIT license. See the LICENSE file for details.
  */
+=======
+>>>>>>> f35d74ad (feat(oidc-client): improve Effect usage)
 import { CustomLogger } from '@forgerock/sdk-logger';
 import { GetAuthorizationUrlOptions } from '@forgerock/sdk-oidc';
 import { Micro } from 'effect';
@@ -19,18 +22,39 @@ import {
 import type { WellKnownResponse } from '@forgerock/sdk-types';
 
 import type { OidcConfig } from './config.types.js';
+<<<<<<< HEAD
 import { AuthorizeErrorResponse, AuthorizeSuccessResponse } from './authorize.request.types.js';
+=======
+import { AuthorizeSuccessResponse } from './authorize.request.types.js';
+>>>>>>> f35d74ad (feat(oidc-client): improve Effect usage)
 
 export async function authorizeµ(
   wellknown: WellKnownResponse,
   config: OidcConfig,
   log: CustomLogger,
   options?: GetAuthorizationUrlOptions,
 ) {
+<<<<<<< HEAD
   return buildAuthorizeOptionsµ(wellknown, config, options).pipe(
     Micro.flatMap(([url, config, options]) => createAuthorizeUrlµ(url, config, options)),
     Micro.tap((url) => log.debug('Authorize URL created', url)),
     Micro.tapError((url) => Micro.sync(() => log.error('Error creating authorize URL', url))),
+=======
+  const buildAuthorizeRequestµ = buildAuthorizeOptionsµ(wellknown, config, options).pipe(
+    Micro.flatMap(([url, config, options]) => createAuthorizeUrlµ(url, config, options)),
+    (effect) => {
+      return Micro.matchEffect(effect, {
+        onSuccess: (url) => {
+          log.debug('Created authorization URL', { url });
+          return effect;
+        },
+        onFailure: (error) => {
+          log.error('Error creating authorization URL', { error });
+          return effect;
+        },
+      });
+    },
+>>>>>>> f35d74ad (feat(oidc-client): improve Effect usage)
     Micro.flatMap(([url, config, options]) => {
       if (options.responseMode === 'pi.flow') {
         /**
@@ -40,12 +64,24 @@ export async function authorizeµ(
          */
         return authorizeFetchµ(url).pipe(
           Micro.flatMap((response) => {
+<<<<<<< HEAD
             if ('authorizeResponse' in response) {
               log.debug('Received authorize response', response.authorizeResponse);
               return Micro.succeed(response.authorizeResponse);
             }
             log.error('Error in authorize response', response);
             return Micro.fail(createAuthorizeErrorµ(response, wellknown, config, options));
+=======
+            return Micro.gen(function* () {
+              if ('authorizeResponse' in response) {
+                log.debug('Received authorize response', response.authorizeResponse);
+                return yield* Micro.succeed(response.authorizeResponse as AuthorizeSuccessResponse);
+              }
+              log.error('Error in authorize response', response);
+              const errorResponse = response as { error: string; error_description: string };
+              return yield* createAuthorizeErrorµ(errorResponse, wellknown, config, options);
+            });
+>>>>>>> f35d74ad (feat(oidc-client): improve Effect usage)
           }),
         );
       } else {
@@ -55,16 +91,33 @@ export async function authorizeµ(
          */
         return authorizeIframeµ(url, config).pipe(
           Micro.flatMap((response) => {
+<<<<<<< HEAD
             if ('code' in response && 'state' in response) {
               log.debug('Received authorization code', response);
               return Micro.succeed(response as unknown as AuthorizeSuccessResponse);
             }
             log.error('Error in authorize response', response);
             const errorResponse = response as unknown as AuthorizeErrorResponse;
             return Micro.fail(createAuthorizeErrorµ(errorResponse, wellknown, config, options));
+=======
+            return Micro.gen(function* () {
+              if ('code' in response && 'state' in response) {
+                log.debug('Received authorization code', response);
+                return yield* Micro.succeed(response as unknown as AuthorizeSuccessResponse);
+              }
+              log.error('Error in authorize response', response);
+              const errorResponse = response as { error: string; error_description: string };
+              return yield* createAuthorizeErrorµ(errorResponse, wellknown, config, options);
+            });
+>>>>>>> f35d74ad (feat(oidc-client): improve Effect usage)
           }),
         );
       }
     }),
   );
+<<<<<<< HEAD
+=======
+
+  return Micro.runPromiseExit(buildAuthorizeRequestµ);
+>>>>>>> f35d74ad (feat(oidc-client): improve Effect usage)
 }