Removal of callbacks from getJsonResponse function

warp-contracts · Nov 8, 2023 · 44d414e · 44d414e
1 parent 889a3f5
commit 44d414e
Show file tree

Hide file tree

Showing 3 changed files with 64 additions and 76 deletions.
diff --git a/src/contract/sequencer/CentralizedSequencerClient.ts b/src/contract/sequencer/CentralizedSequencerClient.ts
@@ -1,6 +1,6 @@
 import { BundlrResponse } from 'contract/Contract';
 import { WarpFetchWrapper } from 'core/WarpFetchWrapper';
-import { NetworkCommunicationError, getJsonResponse } from '../../utils/utils';
+import { NetworkCommunicationError } from '../../utils/utils';
 import { DataItem } from 'warp-arbundles';
 import { SendDataItemResponse, SequencerClient } from './SequencerClient';
 
@@ -28,7 +28,7 @@ export class CentralizedSequencerClient implements SequencerClient {
    * It sends an interaction to the sequencer and checks if the response has a status of 301 (Moved Permanently).
    */
   async sendDataItem(dataItem: DataItem): Promise<SendDataItemResponse> {
-    const result = this.warpFetchWrapper.fetch(this.registerUrl, {
+    const response = await this.warpFetchWrapper.fetch(this.registerUrl, {
       redirect: 'manual',
       method: 'POST',
       headers: {
@@ -37,25 +37,23 @@ export class CentralizedSequencerClient implements SequencerClient {
       },
       body: dataItem.getRaw()
     });
-    return getJsonResponse<SendDataItemResponse>(
-      result,
-      (result) => {
-        return {
-          bundlrResponse: result as BundlrResponse,
-          sequencerMoved: false
-        };
-      },
-      async (response) => {
-        if (response.status == 301) {
-          return {
-            bundlrResponse: undefined,
-            sequencerMoved: true
-          };
-        }
 
-        const text = await response.text();
-        throw new NetworkCommunicationError(`Wrong response code: ${response.status}. ${text}`);
-      }
-    );
+    if (response.ok) {
+      const bundlrResponse = (await response.json()) as BundlrResponse;
+      return {
+        bundlrResponse,
+        sequencerMoved: false
+      };
+    }
+
+    if (response.status == 301) {
+      return {
+        bundlrResponse: undefined,
+        sequencerMoved: true
+      };
+    }
+
+    const text = await response.text();
+    throw new NetworkCommunicationError(`Wrong response code: ${response.status}. ${text}`);
   }
 }
diff --git a/src/contract/sequencer/DecentralizedSequencerClient.ts b/src/contract/sequencer/DecentralizedSequencerClient.ts
@@ -122,44 +122,42 @@ export class DecentralizedSequencerClient implements SequencerClient {
   }
 
   private async tryToSendDataItem(dataItem: DataItem): Promise<boolean> {
-    const response = this.warpFetchWrapper.fetch(this.sendDataItemUrl, {
+    const response = await this.warpFetchWrapper.fetch(this.sendDataItemUrl, {
       method: 'POST',
       headers: {
         'Content-Type': 'application/octet-stream'
       },
       body: dataItem.getRaw()
     });
 
-    return getJsonResponse<boolean>(
-      response,
-      () => true,
-      async (response) => {
-        if (response.status == 503) {
-          return false;
-        }
-
-        if (response.status == 409) {
-          const error = await response.json();
-          throw new Error(
-            `Interaction (id = ${await dataItem.id}) rejected by the sequencer due to an invalid nonce, error message: ${
-              error.message.RawLog
-            }}`
-          );
-        }
-
-        if (response.status == 400) {
-          const error = await response.json();
-          throw new Error(
-            `Interaction (id = ${await dataItem.id}) rejected by the sequencer: error type: ${
-              error.type
-            }, error message: ${JSON.stringify(error.message)}`
-          );
-        }
-
-        const text = await response.text();
-        throw new NetworkCommunicationError(`Wrong response code: ${response.status}. ${text}`);
-      }
-    );
+    if (response.ok) {
+      return true;
+    }
+
+    if (response.status == 503) {
+      return false;
+    }
+
+    if (response.status == 409) {
+      const error = await response.json();
+      throw new Error(
+        `Interaction (id = ${await dataItem.id}) rejected by the sequencer due to an invalid nonce, error message: ${
+          error.message.RawLog
+        }}`
+      );
+    }
+
+    if (response.status == 400) {
+      const error = await response.json();
+      throw new Error(
+        `Interaction (id = ${await dataItem.id}) rejected by the sequencer: error type: ${
+          error.type
+        }, error message: ${JSON.stringify(error.message)}`
+      );
+    }
+
+    const text = await response.text();
+    throw new NetworkCommunicationError(`Wrong response code: ${response.status}. ${text}`);
   }
 
   /**
@@ -183,29 +181,26 @@ export class DecentralizedSequencerClient implements SequencerClient {
   }
 
   private async checkTx(dataItemId: string): Promise<CheckTxResponse> {
-    const response = this.warpFetchWrapper.fetch(this.getTxUrl, {
+    const response = await this.warpFetchWrapper.fetch(this.getTxUrl, {
       method: 'POST',
       headers: {
         'Content-Type': 'application/json'
       },
       body: JSON.stringify({ data_item_id: dataItemId })
     });
 
-    return getJsonResponse<CheckTxResponse>(
-      response,
-      (result) => {
-        this.logger.info(`The transaction with hash ${result.tx_hash} confirmed.`);
-        return { confirmed: true, txHash: result.tx_hash };
-      },
-      async (response) => {
-        if (response.status == 404) {
-          this.logger.debug(`The transaction with data item id (${dataItemId}) not confirmed yet.`);
-          return { confirmed: false };
-        }
-
-        const text = await response.text();
-        throw new NetworkCommunicationError(`${response.status}: ${text}`);
-      }
-    );
+    if (response.ok) {
+      const result = await response.json();
+      this.logger.info(`The transaction with hash ${result.tx_hash} confirmed.`);
+      return { confirmed: true, txHash: result.tx_hash };
+    }
+
+    if (response.status == 404) {
+      this.logger.debug(`The transaction with data item id (${dataItemId}) not confirmed yet.`);
+      return { confirmed: false };
+    }
+
+    const text = await response.text();
+    throw new NetworkCommunicationError(`${response.status}: ${text}`);
   }
 }
diff --git a/src/utils/utils.ts b/src/utils/utils.ts
@@ -1,5 +1,6 @@
 /* eslint-disable */
 import copy from 'fast-copy';
+import { Buffer } from 'warp-isomorphic';
 import { KnownErrors } from '../core/modules/impl/handler/JsHandlerApi';
 
 export const sleep = (ms: number): Promise<void> => {
@@ -94,7 +95,7 @@ export class NetworkCommunicationError<T> extends Error {
   }
 }
 
-export async function getJsonResponse<T>(response: Promise<Response>, successCallback?: (result: any) => T, errorCallback?: (response: Response) => Promise<T>): Promise<T> {
+export async function getJsonResponse<T>(response: Promise<Response>): Promise<T> {
   let r: Response;
   try {
     r = await response;
@@ -103,18 +104,12 @@ export async function getJsonResponse<T>(response: Promise<Response>, successCal
   }
 
   if (!r?.ok) {
-    if (errorCallback) {
-      return errorCallback(r)
-    }
     const text = await r.text();
     throw new NetworkCommunicationError(`Wrong response code: ${r.status}. ${text}`);
   }
 
   try {
     const result = await r.json();
-    if (successCallback) {
-      return successCallback(result);
-    }
     return result as T;
   } catch (e) {
     throw new NetworkCommunicationError(`Error while parsing json response: ${JSON.stringify(e)}`);