refactor(sdk-utilities): extract handleMicroExit helper from oidc-client

Author: vatsalparikh

packages/oidc-client/src/lib/client.store.ts

@@ -12,7 +12,8 @@ import { causeIsDie, exitIsFail, exitIsSuccess } from 'effect/Micro';
 
 import { authorizeµ, createParAuthorizeUrlµ } from './authorize.request.js';
 import { buildTokenExchangeµ } from './exchange.request.js';
-import { createClientStore, createTokenError, runMicroExit } from './client.store.utils.js';
+import { createClientStore, createTokenError } from './client.store.utils.js';
+import { handleMicroExit } from '@forgerock/sdk-utilities';
 import { isExpiryWithinThreshold } from './token.utils.js';
 import { logoutµ } from './logout.request.js';
 import { oidcApi } from './oidc.api.js';
@@ -257,7 +258,8 @@ export async function oidc<ActionType extends ActionTypes = ActionTypes>({
           }),
         );
 
-        return runMicroExit(getTokensµ, 'Token Exchange failure', 'exchange_error');
+        const result = await Micro.runPromiseExit(getTokensµ);
+        return handleMicroExit(result, 'Token Exchange failure', 'exchange_error');
       },
 
       /**
@@ -443,7 +445,8 @@ export async function oidc<ActionType extends ActionTypes = ActionTypes>({
           ),
         );
 
-        return runMicroExit(revokeµ, 'Token revocation failure', 'auth_error');
+        const result = await Micro.runPromiseExit(revokeµ);
+        return handleMicroExit(result, 'Token revocation failure', 'auth_error');
       },
     },
 
@@ -506,7 +509,8 @@ export async function oidc<ActionType extends ActionTypes = ActionTypes>({
           }),
         );
 
-        return runMicroExit(info, 'User Info retrieval failure', 'auth_error');
+        const result = await Micro.runPromiseExit(info);
+        return handleMicroExit(result, 'User Info retrieval failure', 'auth_error');
       },
 
       /**
@@ -547,11 +551,10 @@ export async function oidc<ActionType extends ActionTypes = ActionTypes>({
           return createTokenError('no_id_token');
         }
 
-        return runMicroExit(
+        const result = await Micro.runPromiseExit(
           logoutµ({ tokens, config, wellknown, store, storageClient }),
-          'Logout_Failure',
-          'auth_error',
         );
+        return handleMicroExit(result, 'Logout_Failure', 'auth_error');
       },
 
       /**
@@ -581,7 +584,8 @@ export async function oidc<ActionType extends ActionTypes = ActionTypes>({
             ? sessionCheckIdTokenµ(wellknown, config, store, storageClient, log, options)
             : sessionCheckNoneµ(wellknown, config, store, storageClient, log, options);
 
-        return runMicroExit(micro, 'Session check failure', 'unknown_error');
+        const result = await Micro.runPromiseExit(micro);
+        return handleMicroExit(result, 'Session check failure', 'unknown_error');
       },
     },
   };

packages/oidc-client/src/lib/client.store.utils.ts

@@ -8,8 +8,6 @@ import type { ActionTypes, RequestMiddleware } from '@forgerock/sdk-request-midd
 import { logger as loggerFn } from '@forgerock/sdk-logger';
 
 import { configureStore, type SerializedError } from '@reduxjs/toolkit';
-import { Micro } from 'effect';
-import { causeIsDie, exitIsFail, exitIsSuccess } from 'effect/Micro';
 import { oidcApi } from './oidc.api.js';
 import { wellknownApi } from './wellknown.api.js';
 
@@ -84,26 +82,6 @@ export function createLogoutError(
   return null;
 }
 
-export async function runMicroExit<T, E>(
-  micro: Micro.Micro<T, E>,
-  defectError: string,
-  defectType: GenericError['type'],
-): Promise<T | E | GenericError> {
-  const result = await Micro.runPromiseExit(micro);
-  if (exitIsSuccess(result)) {
-    return result.value;
-  }
-  if (exitIsFail(result)) {
-    return result.cause.error;
-  }
-  const defect = causeIsDie(result.cause) ? result.cause.defect : undefined;
-  return {
-    error: defectError,
-    message: defect instanceof Error ? defect.message : String(defect ?? 'Unknown defect'),
-    type: defectType,
-  };
-}
-
 export function createTokenError(type: 'no_tokens' | 'no_access_token' | 'no_id_token') {
   let error: GenericError;
 

packages/sdk-utilities/package.json

@@ -40,7 +40,8 @@
     "test:watch": "pnpm nx nxTest --watch"
   },
   "dependencies": {
-    "@forgerock/sdk-types": "workspace:*"
+    "@forgerock/sdk-types": "workspace:*",
+    "effect": "catalog:effect"
   },
   "nx": {
     "tags": ["scope:sdk-utilities"]

packages/sdk-utilities/src/index.ts

@@ -8,6 +8,7 @@
  */
 
 export * from './lib/error/index.js';
+export * from './lib/micro.utils.js';
 export * from './lib/oidc/index.js';
 export * from './lib/strings/index.js';
 export * from './lib/url/index.js';

packages/sdk-utilities/src/lib/micro.utils.ts

@@ -0,0 +1,28 @@
+/*
+ * 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.
+ */
+import { causeIsDie, exitIsFail, exitIsSuccess } from 'effect/Micro';
+import type { MicroExit } from 'effect/Micro';
+import type { GenericError } from '@forgerock/sdk-types';
+
+export function handleMicroExit<T, E>(
+  result: MicroExit<T, E>,
+  defectError: string,
+  defectType: GenericError['type'],
+): T | E | GenericError {
+  if (exitIsSuccess(result)) {
+    return result.value;
+  }
+  if (exitIsFail(result)) {
+    return result.cause.error;
+  }
+  const defect = causeIsDie(result.cause) ? result.cause.defect : undefined;
+  return {
+    error: defectError,
+    message: defect instanceof Error ? defect.message : String(defect ?? 'Unknown defect'),
+    type: defectType,
+  };
+}