Skip to content

Commit e7b2682

Browse files
format
1 parent f7053cd commit e7b2682

File tree

1 file changed

+31
-28
lines changed

1 file changed

+31
-28
lines changed

src/lib/lspClient.js

Lines changed: 31 additions & 28 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ export default class lspClient {
44
constructor(wsUrl, modes) {
55
this.wsUrl = wsUrl;
66
// Convert modes array to string if needed, or keep as string
7-
this.modes = Array.isArray(modes) ? modes.join(',') : modes;
7+
this.modes = Array.isArray(modes) ? modes.join(",") : modes;
88
this.socket = null;
99
this.languageProvider = null;
1010
this.registeredEditors = new Set();
@@ -17,7 +17,7 @@ export default class lspClient {
1717
*/
1818
async connect() {
1919
if (this.isConnected) {
20-
console.warn('LSP client is already connected');
20+
console.warn("LSP client is already connected");
2121
return;
2222
}
2323

@@ -27,26 +27,26 @@ export default class lspClient {
2727

2828
// Set up WebSocket event handlers
2929
this.socket.onopen = () => {
30-
console.log('LSP WebSocket connected');
30+
console.log("LSP WebSocket connected");
3131
this.isConnected = true;
3232
this.reconnectAttempts = 0;
3333
this._initializeLanguageProvider();
3434
};
3535

3636
this.socket.onclose = (event) => {
37-
console.log('LSP WebSocket disconnected', event);
37+
console.log("LSP WebSocket disconnected", event);
3838
this.isConnected = false;
3939
};
4040

4141
this.socket.onerror = (error) => {
42-
console.error('LSP WebSocket error:', error);
42+
console.error("LSP WebSocket error:", error);
4343
this.isConnected = false;
4444
};
4545

4646
// Wait for connection to be established
4747
await this._waitForConnection();
4848
} catch (error) {
49-
console.error('Failed to connect to LSP server:', error);
49+
console.error("Failed to connect to LSP server:", error);
5050
throw error;
5151
}
5252
}
@@ -56,13 +56,13 @@ export default class lspClient {
5656
*/
5757
disconnect() {
5858
if (!this.isConnected) {
59-
console.warn('LSP client is not connected');
59+
console.warn("LSP client is not connected");
6060
return;
6161
}
6262

6363
try {
6464
// Remove all registered editors
65-
this.registeredEditors.forEach(editor => {
65+
this.registeredEditors.forEach((editor) => {
6666
this.removeEditor(editor);
6767
});
6868

@@ -79,9 +79,9 @@ export default class lspClient {
7979
}
8080

8181
this.isConnected = false;
82-
console.log('LSP client disconnected');
82+
console.log("LSP client disconnected");
8383
} catch (error) {
84-
console.error('Error during disconnect:', error);
84+
console.error("Error during disconnect:", error);
8585
}
8686
}
8787

@@ -92,33 +92,32 @@ export default class lspClient {
9292
*/
9393
addEditor(editor) {
9494
if (!editor) {
95-
console.error('Editor is required');
95+
console.error("Editor is required");
9696
return false;
9797
}
9898

9999
if (this.registeredEditors.has(editor)) {
100-
console.warn('Editor is already registered');
100+
console.warn("Editor is already registered");
101101
return true;
102102
}
103103

104104
if (!this.isConnected || !this.languageProvider) {
105-
console.error('LSP client is not connected. Call connect() first.');
105+
console.error("LSP client is not connected. Call connect() first.");
106106
return false;
107107
}
108108

109109
try {
110-
111110
this.languageProvider.registerEditor(editor);
112111
this.registeredEditors.add(editor);
113112

114113
const session = editor.getSession();
115-
session.on('changeAnnotation', () => {
114+
session.on("changeAnnotation", () => {
116115
editor.renderer.updateBackMarkers();
117116
});
118-
console.log('Editor registered with LSP client');
117+
console.log("Editor registered with LSP client");
119118
return true;
120119
} catch (error) {
121-
console.error('Failed to register editor:', error);
120+
console.error("Failed to register editor:", error);
122121
return false;
123122
}
124123
}
@@ -130,12 +129,12 @@ export default class lspClient {
130129
*/
131130
removeEditor(editor) {
132131
if (!editor) {
133-
console.error('Editor is required');
132+
console.error("Editor is required");
134133
return false;
135134
}
136135

137136
if (!this.registeredEditors.has(editor)) {
138-
console.warn('Editor is not registered');
137+
console.warn("Editor is not registered");
139138
return true;
140139
}
141140

@@ -146,10 +145,10 @@ export default class lspClient {
146145
}
147146

148147
this.registeredEditors.delete(editor);
149-
console.log('Editor unregistered from LSP client');
148+
console.log("Editor unregistered from LSP client");
150149
return true;
151150
} catch (error) {
152-
console.error('Failed to unregister editor:', error);
151+
console.error("Failed to unregister editor:", error);
153152
return false;
154153
}
155154
}
@@ -159,7 +158,11 @@ export default class lspClient {
159158
* @returns {boolean}
160159
*/
161160
isConnectedToServer() {
162-
return this.isConnected && this.socket && this.socket.readyState === WebSocket.OPEN;
161+
return (
162+
this.isConnected &&
163+
this.socket &&
164+
this.socket.readyState === WebSocket.OPEN
165+
);
163166
}
164167

165168
/**
@@ -186,9 +189,9 @@ export default class lspClient {
186189

187190
try {
188191
this.languageProvider = AceLanguageClient.for(serverData);
189-
console.log('Language provider initialized');
192+
console.log("Language provider initialized");
190193
} catch (error) {
191-
console.error('Failed to initialize language provider:', error);
194+
console.error("Failed to initialize language provider:", error);
192195
throw error;
193196
}
194197
}
@@ -201,19 +204,19 @@ export default class lspClient {
201204
_waitForConnection() {
202205
return new Promise((resolve, reject) => {
203206
const timeout = setTimeout(() => {
204-
reject(new Error('Connection timeout'));
207+
reject(new Error("Connection timeout"));
205208
}, 10000); // 10 second timeout
206209

207210
if (this.socket.readyState === WebSocket.OPEN) {
208211
clearTimeout(timeout);
209212
resolve();
210213
} else {
211-
this.socket.addEventListener('open', () => {
214+
this.socket.addEventListener("open", () => {
212215
clearTimeout(timeout);
213216
resolve();
214217
});
215218

216-
this.socket.addEventListener('error', (error) => {
219+
this.socket.addEventListener("error", (error) => {
217220
clearTimeout(timeout);
218221
reject(error);
219222
});
@@ -238,4 +241,4 @@ client.removeEditor(editor1);
238241
239242
// Disconnect when done
240243
client.disconnect();
241-
*/
244+
*/

0 commit comments

Comments
 (0)