From 5b8c2f21ad1d19b314760723bb481c0e5fe98797 Mon Sep 17 00:00:00 2001 From: Luis Fernando Molina Date: Thu, 24 Sep 2020 19:06:30 +0200 Subject: [PATCH] Update taskManagerServer.js --- taskManagerServer.js | 27 +++++++++++++++++++++++++++ 1 file changed, 27 insertions(+) diff --git a/taskManagerServer.js b/taskManagerServer.js index e32d14a3a..381c4237a 100644 --- a/taskManagerServer.js +++ b/taskManagerServer.js @@ -38,6 +38,7 @@ eventsServerClient.createEventHandler('Task Manager') eventsServerClient.listenToEvent('Task Manager', 'Run Task', undefined, undefined, undefined, runTask) eventsServerClient.listenToEvent('Task Manager', 'Stop Task', undefined, undefined, undefined, stopTask) + eventsServerClient.listenToEvent('Task Manager', 'Task Status', undefined, undefined, undefined, taskStatus) console.log('Task Manager Server Started.') @@ -148,6 +149,32 @@ console.log('[WARN] BackendServers -> Task Manager Server -> stopTask -> Cannot delete Task that does not exist.') } } + + function taskStatus(message) { + //console.log('[INFO] BackendServers -> Task Manager Server -> taskStatus -> Entering function.') + if (message.event === undefined) { + console.log('[WARN] BackendServers -> Task Manager Server -> taskStatus -> Message Received Without Event -> message = ' + JSON.stringify(message).substring(0, 1000)) + return + } + + if (message.event.taskId === undefined) { + console.log('[WARN] BackendServers -> Task Manager Server -> taskStatus -> Message Received Without taskId -> message = ' + JSON.stringify(message).substring(0, 1000)) + return + } + //console.log('[INFO] BackendServers -> Task Manager Server -> taskStatus -> Task Name = ' + message.event.taskName) + //console.log('[INFO] BackendServers -> Task Manager Server -> taskStatus -> Task Id = ' + message.event.taskId) + + let task = tasksMap.get(message.event.taskId) + + let event = {status: 'Undefined'} + if (task) { + event.status = 'Task Process Running' + eventsServerClient.raiseEvent('Task Client - ' + task.id, 'Task Status', event.status) + } else { + event.status = 'Task Process Not Running' + eventsServerClient.raiseEvent('Task Client - ' + task.id, 'Task Status', event.status) + } + } } function newEventsServerClient() {