patch smqp

CHANGELOG.md

@@ -1,5 +1,9 @@
 # Changelog
 
+# 20.0.2
+
+- patch away package prettier from smqp
+
 # 20.0.1
 
 - hoist current definition environment output to engine environment output if run fails

lib/index.cjs

@@ -613,30 +613,19 @@ Execution.prototype._onChildMessage = function onChildMessage(routingKey, messag
 
       newState = 'idle';
       break;
-    case 'definition.error':
+    case 'definition.error': {
+      this._saveOutput(owner.environment.output);
       this._teardownDefinition(owner);
       newState = 'error';
       break;
+    }
     case 'activity.wait': {
       if (listener) listener.emit('wait', owner.getApi(message), this);
       break;
     }
     case 'process.end': {
-      if (!message.content.output) break;
-      const environment = this.environment;
-
-      for (const key in message.content.output) {
-        switch (key) {
-          case 'data': {
-            environment.output.data = environment.output.data || {};
-            environment.output.data = { ...environment.output.data, ...message.content.output.data };
-            break;
-          }
-          default: {
-            environment.output[key] = message.content.output[key];
-          }
-        }
-      }
+      if (message.content.inbound) break;
+      this._saveOutput(message.content.output);
       break;
     }
   }
@@ -678,6 +667,21 @@ Execution.prototype._teardownDefinition = function teardownDefinition(definition
   definition.broker.cancel('_engine_definition');
 };
 
+Execution.prototype._saveOutput = function saveOutput(output) {
+  if (!output || typeof output !== 'object') return;
+
+  const environmentOutput = this.environment.output;
+
+  for (const key in output) {
+    if (key === 'data') {
+      const data = (environmentOutput.data = environmentOutput.data || {});
+      environmentOutput.data = { ...data, ...output.data };
+    } else {
+      environmentOutput[key] = output[key];
+    }
+  }
+};
+
 Execution.prototype.getState = function getState() {
   const definitions = [];
   for (const definition of this.definitions) {

package.json

@@ -1,7 +1,7 @@
 {
   "name": "bpmn-engine",
   "description": "BPMN 2.0 execution engine. Open source javascript workflow engine.",
-  "version": "20.0.1",
+  "version": "20.0.2",
   "type": "module",
   "module": "./src/index.js",
   "main": "./lib/index.cjs",
@@ -73,6 +73,6 @@
     "bpmn-moddle": "^9.0.1",
     "debug": "^4.3.4",
     "moddle-context-serializer": "^4.2.0",
-    "smqp": "^8.2.3"
+    "smqp": "^8.2.4"
   }
 }