Merge pull request #64 from kaleido-io/idempotency

Add unique exception for idempotency conflicts

Author: nguyer

lib/firefly.ts

@@ -510,6 +510,10 @@ export default class FireFly extends HttpBase {
     return this.getMany<FireFlyContractListenerResponse[]>('/contracts/listeners', filter, options);
   }
 
+  async deleteContractListener(id: string, options?: FireFlyDeleteOptions) {
+    await this.deleteOne(`/contracts/listeners/${id}`, options);
+  }
+
   getContractAPIListeners(
     apiName: string,
     eventPath: string,

lib/http.ts

@@ -8,6 +8,7 @@ import {
   FireFlyReplaceOptions,
   FireFlyUpdateOptions,
   FireFlyDeleteOptions,
+  FireFlyIdempotencyError,
 } from './interfaces';
 
 function isSuccess(status: number) {
@@ -74,8 +75,12 @@ export default class HttpBase {
   protected async wrapError<T>(response: Promise<AxiosResponse<T>>) {
     return response.catch((err) => {
       if (axios.isAxiosError(err)) {
-        const errorMessage = err.response?.data?.error;
-        const ffError = new FireFlyError(errorMessage ?? err.message, err, err.request.path);
+        const errorMessage = err.response?.data?.error ?? err.message;
+        const errorClass =
+          errorMessage?.includes('FF10430') || errorMessage?.includes('FF10431')
+            ? FireFlyIdempotencyError
+            : FireFlyError;
+        const ffError = new errorClass(errorMessage, err, err.request.path);
         if (this.errorHandler !== undefined) {
           this.errorHandler(ffError);
         }

lib/interfaces.ts

@@ -21,6 +21,8 @@ export class FireFlyError extends Error {
   }
 }
 
+export class FireFlyIdempotencyError extends FireFlyError {}
+
 interface FireFlyBaseHttpOptions {
   requestConfig?: AxiosRequestConfig;
 }

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@hyperledger/firefly-sdk",
-  "version": "1.2.6",
+  "version": "1.2.7",
   "description": "Client SDK for Hyperledger FireFly",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",