Skip to content

Commit a027d6e

Browse files
committed
2 parents d6abaad + 1b1ccb3 commit a027d6e

File tree

3 files changed

+26
-12
lines changed

3 files changed

+26
-12
lines changed

package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "@codebolt/codeboltjs",
3-
"version": "1.1.31",
3+
"version": "1.1.32",
44
"description": "",
55
"keywords": [],
66
"author": "",

src/modules/chat.ts

Lines changed: 6 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -9,15 +9,12 @@ import {ChatMessage} from '@codebolt/types'
99
* CustomEventEmitter class that extends the Node.js EventEmitter class.
1010
*/
1111
class CustomEventEmitter extends EventEmitter {}
12+
let eventEmitter= new CustomEventEmitter()
1213
/**
1314
* Chat module to interact with the WebSocket server.
1415
*/
1516
const cbchat = {
16-
/**
17-
* @private
18-
*/
19-
eventEmitter: new CustomEventEmitter(),
20-
17+
2118
/**
2219
* Retrieves the chat history from the server.
2320
* @returns {Promise<ChatMessage[]>} A promise that resolves with an array of ChatMessage objects representing the chat history.
@@ -45,10 +42,10 @@ const cbchat = {
4542
cbws.getWebsocket.on('message', (data: string) => {
4643
const response = JSON.parse(data);
4744
if (response.type === "messageResponse") {
48-
cbchat.eventEmitter.emit("userMessage", response.response);
45+
eventEmitter.emit("userMessage", response.response);
4946
}
5047
});
51-
return cbchat.eventEmitter;
48+
return eventEmitter;
5249
},
5350

5451
/**
@@ -99,12 +96,12 @@ const cbchat = {
9996
if(message.type==='stopProcessClicked')
10097

10198
// Emit a custom event based on the message type
102-
cbchat.eventEmitter.emit("stopProcessClicked", message);
99+
eventEmitter.emit("stopProcessClicked", message);
103100
});
104101

105102
// Return an object that includes the event emitter and the stopProcess method
106103
return {
107-
event: cbchat.eventEmitter,
104+
event: eventEmitter,
108105
stopProcess: () => {
109106
// Implement the logic to stop the process here
110107
console.log("Stopping process...");

src/modules/fs.ts

Lines changed: 19 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -159,8 +159,25 @@ const cbfs = {
159159
});
160160
});
161161
},
162-
listFile:(folderPath?:string)=>{
163-
162+
/**
163+
* @function listFile
164+
* @description Lists all files.
165+
* @returns {Promise<FileListResponse>} A promise that resolves with the list of files.
166+
*/
167+
listFile: (filePath:string) => {
168+
return new Promise((resolve, reject) => {
169+
cbws.getWebsocket.send(JSON.stringify({
170+
"type": "fsEvent",
171+
"action": "fileList",
172+
173+
}));
174+
cbws.getWebsocket.on('message', (data: string) => {
175+
const response = JSON.parse(data);
176+
if (response.type === "fileListResponse") {
177+
resolve(response);
178+
}
179+
});
180+
});
164181
},
165182

166183
};

0 commit comments

Comments
 (0)