Skip to content

Commit f68e7cd

Browse files
committed
updated the codebolt files
1 parent 3a64476 commit f68e7cd

File tree

5 files changed

+50
-36
lines changed

5 files changed

+50
-36
lines changed

package-lock.json

Lines changed: 15 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

src/index.ts

Lines changed: 1 addition & 27 deletions
Original file line numberDiff line numberDiff line change
@@ -22,9 +22,7 @@ import debug from './modules/debug'
2222
import tokenizer from './modules/tokenizer'
2323
import WebSocket from 'ws';
2424
import { EventEmitter } from 'events';
25-
export class CustomEventEmitter extends EventEmitter {}
2625

27-
let eventEmitter= new CustomEventEmitter();
2826

2927
/**
3028
* @class Codebolt
@@ -40,20 +38,7 @@ class Codebolt { // Extend EventEmitter
4038

4139
this.websocket = cbws.getWebsocket;
4240
}
43-
/**
44-
* @method setupMessageListener
45-
* @description Sets up a listener for incoming WebSocket messages.
46-
*/
47-
userMessageListener() {
48-
if (!this.websocket) return;
49-
this.websocket.on('message', (data: string) => {
50-
const response = JSON.parse(data);
51-
if (response.type === "messageResponse") {
52-
eventEmitter.emit("userMessage", response.response);
53-
}
54-
});
55-
return eventEmitter;
56-
}
41+
5742
/**
5843
* @method waitForConnection
5944
* @description Waits for the WebSocket connection to open.
@@ -82,17 +67,6 @@ class Codebolt { // Extend EventEmitter
8267
});
8368
}
8469

85-
/**
86-
* @method start_browser
87-
* @description Starts a new browser page.
88-
* @param {string} objective - The objective of the browser session.
89-
* @param {string} url - The URL to navigate to.
90-
* @param {string} previous_command - The previous command executed.
91-
* @param {string} browser_content - The content of the browser.
92-
*/
93-
start_browser(objective: string, url: string, previous_command: string, browser_content: string) {
94-
cbbrowser.newPage();
95-
}
9670
websocket: WebSocket | null = null;
9771
fs = cbfs;
9872
git = git;

src/modules/browser.ts

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -264,3 +264,12 @@ const cbbrowser = {
264264
}
265265

266266
export default cbbrowser;
267+
268+
269+
270+
/***
271+
272+
start_browser(objective: string, url: string, previous_command: string, browser_content: string) {
273+
cbbrowser.newPage();
274+
}
275+
*/

src/modules/chat.ts

Lines changed: 24 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -3,18 +3,23 @@ import cbws from './websocket';
33
import { EventEmitter } from 'events';
44
import {ChatMessage} from '@codebolt/common'
55

6+
7+
68
/**
79
* CustomEventEmitter class that extends the Node.js EventEmitter class.
810
*/
9-
export class CustomEventEmitter extends EventEmitter {}
10-
11+
class CustomEventEmitter extends EventEmitter {}
1112
/**
1213
* Chat module to interact with the WebSocket server.
1314
*/
1415
const cbchat = {
1516
eventEmitter: new CustomEventEmitter(),
1617

17-
getChatHistory():Promise<ChatMessage[]> {
18+
/**
19+
* Retrieves the chat history from the server.
20+
* @returns {Promise<ChatMessage[]>} A promise that resolves with an array of ChatMessage objects representing the chat history.
21+
*/
22+
getChatHistory: (): Promise<ChatMessage[]> => {
1823
return new Promise((resolve, reject) => {
1924
cbws.getWebsocket.send(JSON.stringify({
2025
"type": "getChatHistory"
@@ -26,15 +31,28 @@ const cbchat = {
2631
}
2732
})
2833
})
29-
34+
},
3035

36+
/**
37+
* @method setupMessageListener
38+
* @description Sets up a listener for incoming WebSocket messages.
39+
*/
40+
userMessageListener: () => {
41+
if (!cbws.getWebsocket) return;
42+
cbws.getWebsocket.on('message', (data: string) => {
43+
const response = JSON.parse(data);
44+
if (response.type === "messageResponse") {
45+
cbchat.eventEmitter.emit("userMessage", response.response);
46+
}
47+
});
48+
return cbchat.eventEmitter;
3149
},
3250

3351
/**
3452
* Sends a message through the WebSocket connection.
3553
* @param {string} message - The message to be sent.
3654
*/
37-
sendMessage(message: string) {
55+
sendMessage: (message: string) => {
3856
console.log(message);
3957
cbws.getWebsocket.send(JSON.stringify({
4058
"type": "sendMessage",
@@ -47,7 +65,7 @@ const cbchat = {
4765
* @param {string} message - The message for which a reply is expected.
4866
* @returns {Promise<any>} A promise that resolves with the reply.
4967
*/
50-
waitforReply(message: string): Promise<any> {
68+
waitforReply: (message: string): Promise<any> => {
5169
return new Promise((resolve, reject) => {
5270
cbws.getWebsocket.send(JSON.stringify({
5371
"type": "waitforReply",

src/modules/terminal.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ import { EventEmitter } from 'events';
44
/**
55
* CustomEventEmitter class that extends the Node.js EventEmitter class.
66
*/
7-
export class CustomEventEmitter extends EventEmitter {}
7+
class CustomEventEmitter extends EventEmitter {}
88
/**
99
* A module for executing commands in a terminal-like environment via WebSocket.
1010
*/

0 commit comments

Comments
 (0)