(
message: ClientSocketMessage,
)
| 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, |
no test coverage detected