MCPcopy Create free account
hub / github.com/CommE2E/comm / handleClientSocketMessage

Method handleClientSocketMessage

keyserver/src/socket/socket.js:414–440  ·  view source on GitHub ↗
(
    message: ClientSocketMessage,
  )

Source from the content-addressed store, hash-verified

412 };
413
414 async handleClientSocketMessage(
415 message: ClientSocketMessage,
416 ): Promise<ServerServerSocketMessage[]> {
417 const resultPromise: Promise<ServerServerSocketMessage[]> = (async () => {
418 if (message.type === clientSocketMessageTypes.INITIAL) {
419 this.markActivityOccurred();
420 return await this.handleInitialClientSocketMessage(message);
421 } else if (message.type === clientSocketMessageTypes.RESPONSES) {
422 this.markActivityOccurred();
423 return await this.handleResponsesClientSocketMessage(message);
424 } else if (message.type === clientSocketMessageTypes.PING) {
425 return this.handlePingClientSocketMessage(message);
426 } else if (message.type === clientSocketMessageTypes.ACK_UPDATES) {
427 this.markActivityOccurred();
428 return await this.handleAckUpdatesClientSocketMessage(message);
429 } else if (message.type === clientSocketMessageTypes.API_REQUEST) {
430 this.markActivityOccurred();
431 return await this.handleAPIRequestClientSocketMessage(message);
432 }
433 return [];
434 })();
435 const timeoutPromise: Promise<empty> = (async () => {
436 await sleep(serverResponseTimeout);
437 throw new ServerError('socket_response_timeout');
438 })();
439 return await Promise.race([resultPromise, timeoutPromise]);
440 }
441
442 async handleInitialClientSocketMessage(
443 message: InitialClientSocketMessage,

Callers 1

SocketClass · 0.95

Tested by

no test coverage detected