Skip to content

Commit df02c11

Browse files
changes
1 parent e7952d2 commit df02c11

File tree

2 files changed

+8
-6
lines changed

2 files changed

+8
-6
lines changed

package.json

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "@codebolt/codeboltjs",
3-
"version": "1.1.24",
3+
"version": "1.1.25",
44
"description": "",
55
"keywords": [],
66
"author": "",

src/index.ts

+7-5
Original file line numberDiff line numberDiff line change
@@ -21,22 +21,23 @@ import vectorDB from './modules/vectordb';
2121
import debug from './modules/debug'
2222
import tokenizer from './modules/tokenizer'
2323
import WebSocket, { EventEmitter } from 'ws';
24-
24+
export class CustomEventEmitter extends EventEmitter {}
25+
let eventEmitter= new CustomEventEmitter();
2526

2627
/**
2728
* @class Codebolt
2829
* @description This class provides a unified interface to interact with various modules.
2930
*/
30-
class Codebolt extends EventEmitter { // Extend EventEmitter
31+
class Codebolt { // Extend EventEmitter
3132

3233
/**
3334
* @constructor
3435
* @description Initializes the websocket connection.
3536
*/
3637
constructor() {
37-
super()
38+
3839
this.websocket = cbws.getWebsocket;
39-
this.userMessageListener(); // Call setupMessageListener() to subscribe to WebSocket messages
40+
4041
}
4142
/**
4243
* @method setupMessageListener
@@ -47,9 +48,10 @@ class Codebolt extends EventEmitter { // Extend EventEmitter
4748
this.websocket.on('message', (data: string) => {
4849
const response = JSON.parse(data);
4950
if (response.type === "messageResponse") {
50-
this.emit(response.message)
51+
eventEmitter.emit("userMessage", response.response);
5152
}
5253
});
54+
return eventEmitter;
5355
}
5456
/**
5557
* @method waitForConnection

0 commit comments

Comments
 (0)