4nk/docv
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Refactored log in MessageBus

Browse Source
This commit is contained in:
Sadrinho27 2025-10-02 23:21:14 +02:00
parent dabe614fde
commit 6d9118b564
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
lib/4nk/MessageBus.ts
View File

@ -199,11 +199,10 @@ export default class MessageBus {
const accessToken = userStore.getAccessToken()!; const accessToken = userStore.getAccessToken()!;
const correlationId = uuidv4(); const correlationId = uuidv4();
console.log(correlationId);
this.initMessageListener(correlationId); this.initMessageListener(correlationId);
const unsubscribe = EventBus.getInstance().on('PROCESSES_RETRIEVED', (responseId: string, processes: any) => { const unsubscribe = EventBus.getInstance().on('PROCESSES_RETRIEVED', (responseId: string, processes: any) => {
console.log(responseId); console.log('MessageBus - PROCESSES_RETRIEVED', processes);
if (responseId !== correlationId) { if (responseId !== correlationId) {
return; return;
} }
@ -452,7 +451,7 @@ export default class MessageBus {
this.initMessageListener(correlationId); this.initMessageListener(correlationId);
const unsubscribe = EventBus.getInstance().on('PROCESS_UPDATED', (responseId: string, updatedProcess: any) => { const unsubscribe = EventBus.getInstance().on('PROCESS_UPDATED', (responseId: string, updatedProcess: any) => {
console.log('PROCESS_UPDATED', updatedProcess); console.log('MessageBus - PROCESS_UPDATED', updatedProcess);
if (responseId !== correlationId) { if (responseId !== correlationId) {
return; return;
} }
@ -530,7 +529,7 @@ export default class MessageBus {
this.initMessageListener(correlationId); this.initMessageListener(correlationId);
const unsubscribe = EventBus.getInstance().on('STATE_VALIDATED', (responseId: string, updatedProcess: any) => { const unsubscribe = EventBus.getInstance().on('STATE_VALIDATED', (responseId: string, updatedProcess: any) => {
console.log(updatedProcess); console.log('MessageBus - STATE_VALIDATED', updatedProcess);
if (responseId !== correlationId) { if (responseId !== correlationId) {
return; return;
} }
@ -727,7 +726,6 @@ export default class MessageBus {
EventBus.getInstance().emit('ERROR_PROCESS_UPDATED', correlationId, error); EventBus.getInstance().emit('ERROR_PROCESS_UPDATED', correlationId, error);
return; return;
} }
console.log('PROCESS_UPDATED', message);
EventBus.getInstance().emit('MESSAGE_RECEIVED', message); EventBus.getInstance().emit('MESSAGE_RECEIVED', message);
EventBus.getInstance().emit('PROCESS_UPDATED', correlationId, message.updatedProcess); EventBus.getInstance().emit('PROCESS_UPDATED', correlationId, message.updatedProcess);
break; break;