(provider: WebsocketProvider, buf: Uint8Array, emitSynced: boolean)
| 106 | console.warn(`Permission denied to access ${provider.url}.\n${reason}`) |
| 107 | |
| 108 | const readMessage = (provider: WebsocketProvider, buf: Uint8Array, emitSynced: boolean) => { |
| 109 | const decoder = decoding.createDecoder(buf) |
| 110 | const encoder = encoding.createEncoder() |
| 111 | const messageType = decoding.readVarUint(decoder) |
| 112 | const messageHandler = provider.messageHandlers[messageType] |
| 113 | if (/** @type {any} */ messageHandler) { |
| 114 | messageHandler(encoder, decoder, provider, emitSynced, messageType) |
| 115 | } else { |
| 116 | console.error('Unable to compute message') |
| 117 | } |
| 118 | return encoder |
| 119 | } |
| 120 | |
| 121 | const setupWS = (provider: WebsocketProvider) => { |
| 122 | if (provider.shouldConnect && provider.ws === null) { |
no outgoing calls
no test coverage detected