diff --git a/lib/4nk/MessageBus.ts b/lib/4nk/MessageBus.ts index 562c415..9f3d5a1 100644 --- a/lib/4nk/MessageBus.ts +++ b/lib/4nk/MessageBus.ts @@ -787,6 +787,17 @@ export default class MessageBus { EventBus.getInstance().emit('PAIRING_CREATED', correlationId, message.decodedData); break; + case 'CONVERSATION_CREATED': + if (this.errors[correlationId]) { + const error = this.errors[correlationId]; + delete this.errors[correlationId]; + EventBus.getInstance().emit('ERROR_CONVERSATION_CREATED', correlationId, error); + return; + } + EventBus.getInstance().emit('MESSAGE_RECEIVED', message); + EventBus.getInstance().emit('CONVERSATION_CREATED', correlationId, message.decodedData); + break; + case 'ERROR': console.error('Error:', message); this.errors[correlationId] = message.error;