chore(shared): add rxjs util operators

apps/shared/src/index.ts

@@ -24,3 +24,8 @@ export * from './modules/tsa/index.js';
 export * from './interceptors/response-format.interceptor.js';
 
 export * from './staticStorage.js';
+
+export * from './rxjs/extract-response-data.js';
+export * from './rxjs/handle-empty-response.js';
+export * from './rxjs/handle-request-timeout.js';
+export * from './rxjs/handle-ssi-response.js';

apps/shared/src/rxjs/extract-response-data.ts

+import { map } from 'rxjs';
+
+export const exrtactResponseData = () => map(({ data }) => data);

apps/shared/src/rxjs/handle-empty-response.ts

+import { InternalServerErrorException, Logger } from '@nestjs/common';
+import { catchError, of } from 'rxjs';
+
+export const handleEmptyResponse = (
+  message = 'Make sure SSI abstraction is running',
+) =>
+  catchError((error) => {
+    if (
+      error instanceof Error &&
+      error.constructor.name === 'EmptyResponseException'
+    ) {
+      Logger.error(error.message);
+      message && Logger.error(message);
+      throw new InternalServerErrorException();
+    }
+    return of(error);
+  });

apps/shared/src/rxjs/handle-request-timeout.ts

+import { throwError, timeout } from 'rxjs';
+
+export const handleRequestTimeout = (timeoutMs: number = 10000) =>
+  // eslint-disable-next-line @typescript-eslint/no-explicit-any
+  timeout<any, any>({
+    each: timeoutMs,
+    with: () => throwError(() => new Error('Request timed out')),
+  });

apps/shared/src/rxjs/handle-ssi-response.ts

+import { pipe } from 'rxjs';
+
+import { exrtactResponseData } from './extract-response-data.js';
+import { handleEmptyResponse } from './handle-empty-response.js';
+import { handleRequestTimeout } from './handle-request-timeout.js';
+
+export const handleSSIResponse = pipe(
+  handleRequestTimeout(),
+  handleEmptyResponse(),
+  exrtactResponseData(),
+);