|
@@ -1,5 +1,6 @@
|
|
import mqtt from 'mqtt';
|
|
import mqtt from 'mqtt';
|
|
import { MQTT_BROKER_URL } from '../API/config';
|
|
import { MQTT_BROKER_URL } from '../API/config';
|
|
|
|
+import emitter from '../utils/eventEmitter';
|
|
|
|
|
|
interface MqttMessage {
|
|
interface MqttMessage {
|
|
dcm?: string;
|
|
dcm?: string;
|
|
@@ -31,6 +32,7 @@ const handleMqttMessage = (message: MqttMessage) => {
|
|
case 'TASK_Success':
|
|
case 'TASK_Success':
|
|
console.log('Task succeeded:', message);
|
|
console.log('Task succeeded:', message);
|
|
// Handle success, e.g., process DCM and thumbnail files
|
|
// Handle success, e.g., process DCM and thumbnail files
|
|
|
|
+ emitter.emit('TASK_SUCCESS');
|
|
break;
|
|
break;
|
|
case 'TASK_Failure':
|
|
case 'TASK_Failure':
|
|
console.error('Task failed:', message.message);
|
|
console.error('Task failed:', message.message);
|