Release/0.11.8

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@super-protocol/ctl",
-  "version": "0.11.6",
+  "version": "0.11.8",
   "description": "A tool for publishing values in a secure and reliable way.",
   "main": "./build/index.js",
   "type": "commonjs",
@@ -36,7 +36,7 @@
     "@iarna/toml": "^2.2.5",
     "@super-protocol/distributed-secrets": "1.1.7",
     "@super-protocol/dto-js": "1.1.2",
-    "@super-protocol/sdk-js": "3.11.4",
+    "@super-protocol/sdk-js": "3.11.12",
     "@super-protocol/sp-files-addon": "^0.11.0",
     "@types/tar-stream": "^3.1.3",
     "axios": "1.6.2",

src/error.utils.ts

@@ -0,0 +1,29 @@
+interface ApiErrorResponse {
+  response?: {
+    status?: number;
+    errors?: Array<{ message?: string }>;
+  };
+}
+
+const isApiError = (error: unknown): error is ApiErrorResponse =>
+  error !== null && typeof error === 'object' && 'response' in error;
+
+export function getErrorMessage(error: unknown, baseMessage: string): string {
+  if (!isApiError(error)) {
+    return baseMessage;
+  }
+
+  const { response } = error;
+  const status = response?.status;
+
+  if (typeof status === 'number' && status >= 500) {
+    return `${baseMessage}: Server error - code = ${status}`;
+  }
+
+  const errorMessage = response?.errors?.[0]?.message;
+  if (errorMessage) {
+    return `${baseMessage}: ${errorMessage}`;
+  }
+
+  return baseMessage;
+}

src/services/fetchOffers.ts

@@ -3,6 +3,8 @@ import { GraphQLClient } from 'graphql-request';
 import { ErrorWithCustomMessage, formatDate, getObjectKey } from '../utils';
 import getGqlHeaders from './gqlHeaders';
 import { OfferType } from '@super-protocol/sdk-js';
+import doWithRetries from './doWithRetries';
+import { getErrorMessage } from '../error.utils';
 
 export type FetchOffersParams = {
   backendUrl: string;
@@ -54,26 +56,26 @@ export default async (
   const headers = getGqlHeaders(params.accessToken);
 
   try {
-    const { result } = await sdk.Offers(
-      {
-        pagination: {
-          first: params.limit,
-          after: params.cursor,
-          sortDir: 'DESC',
-          sortBy: 'origins.createdDate',
+    const { result } = await doWithRetries(() =>
+      sdk.Offers(
+        {
+          pagination: {
+            first: params.limit,
+            after: params.cursor,
+            sortDir: 'DESC',
+            sortBy: 'origins.createdDate',
+          },
+          filter: { id: params.id, ids: params.ids },
         },
-        filter: { id: params.id, ids: params.ids },
-      },
-      headers,
+        headers,
+      ),
     );
 
     return {
       list: result.page.edges?.map((item) => item.node) || [],
       cursor: result.page.pageInfo?.endCursor || '',
     };
-  } catch (error: any) {
-    let message = 'Fetching offers error';
-    if (error?.response?.errors[0]?.message) message += ': ' + error.response.errors[0].message;
-    throw ErrorWithCustomMessage(message, error);
+  } catch (error: unknown) {
+    throw ErrorWithCustomMessage(getErrorMessage(error, 'Fetching offers error'), error);
   }
 };