diff --git a/packages/fluence-js/package.json b/packages/fluence-js/package.json index a3b65b93..03d2a203 100644 --- a/packages/fluence-js/package.json +++ b/packages/fluence-js/package.json @@ -1,6 +1,6 @@ { "name": "@fluencelabs/fluence", - "version": "0.27.3", + "version": "0.27.4", "description": "TypeScript implementation of Fluence Peer", "main": "./dist/index.js", "typings": "./dist/index.d.ts", diff --git a/packages/fluence-js/src/internal/FluencePeer.ts b/packages/fluence-js/src/internal/FluencePeer.ts index 427dc107..d235e914 100644 --- a/packages/fluence-js/src/internal/FluencePeer.ts +++ b/packages/fluence-js/src/internal/FluencePeer.ts @@ -655,6 +655,11 @@ export class FluencePeer { return; } + // Do not proceed further if the particle is expired + if (item.particle.hasExpired()) { + return; + } + // Do not continue if there was an error in particle interpretation if (item.result instanceof Error) { log.error('Interpreter failed: ', jsonify(item.result.message)); @@ -699,6 +704,10 @@ export class FluencePeer { particleContext: item.particle.getParticleContext(), }; + if (item.particle.hasExpired()) { + // just in case do not call any services if the particle is already expired + return; + } this._execSingleCallRequest(req) .catch((err): CallServiceResult => { if (err instanceof ServiceError) {