Add message routing testcases and related bugfixes
- Handle XOS sensor tasks specially to route events correctly
- Add a 'req_id' optional field to manager request API for client-side req-res mapping
- Fix several bugs related to message routing
- Rename event names for consistency
- Separate kickstart call-back event from kickstart request
- Shorten ping/pong timeout for socket.io for fast response
- Add a 'dag_id' field to tasks in essences
- Notify event arrivals to workflow run clients to let them get events as soon as possible
- Small code refinements
Change-Id: Ibc4182027eb5e2854f1603e339fffbe76e9ba621
diff --git a/spec/clients.spec.js b/spec/clients.spec.js
index 9996944..1a40975 100644
--- a/spec/clients.spec.js
+++ b/spec/clients.spec.js
@@ -80,7 +80,7 @@
workflowRunId = message.workflow_run_id;
// call-back
- workflowManagerClient.emit(eventrouter.serviceEvents.WORKFLOW_KICKSTART, {
+ workflowManagerClient.emit(eventrouter.serviceEvents.WORKFLOW_NOTIFY_NEW_RUN, {
workflow_id: workflowId,
workflow_run_id: workflowRunId
})
@@ -128,12 +128,12 @@
if(register) {
let essence = essenceLoader.loadEssence(essenceFileName, true);
- workflowManagerClient.emit(eventrouter.serviceEvents.WORKFLOW_REG_ESSENCE, {
+ workflowManagerClient.emit(eventrouter.serviceEvents.WORKFLOW_REGISTER_ESSENCE, {
essence: essence
});
workflowManagerClient.on(
- eventrouter.serviceEvents.WORKFLOW_REG_ESSENCE,
+ eventrouter.serviceEvents.WORKFLOW_REGISTER_ESSENCE,
(workflowRegResult) => {
callback(null, workflowRegResult);
}
@@ -182,7 +182,7 @@
afterEach(function(done) {
// remove workflow run
- workflowManagerClient.emit(server.serviceEvents.WORKFLOW_RUN_REMOVE, {
+ workflowManagerClient.emit(server.serviceEvents.WORKFLOW_REMOVE_RUN, {
workflow_id: workflowId,
workflow_run_id: workflowRunId
});
@@ -325,4 +325,4 @@
}, 100);
});
});
-})();
\ No newline at end of file
+})();