Method onPacketReady

web/src/rpc_server.ts:220–263

(header: Uint8Array, body: Uint8Array)

  }

  private onPacketReady(header: Uint8Array, body: Uint8Array): void {
    if (this.inst === undefined) {
      // initialize server.
      const reader = new ByteStreamReader(body);
      const code = reader.readU32();
      const ver = Uint8ArrayToString(reader.readByteArray());
      const nargs = reader.readU32();

      // nargs=0 means no session_constructor_args (LocalSession request).
      // WASM RPC requires ["rpc.WasmSession", wasm_binary]. Wait for proper init.
      if (nargs === 0) {
        this.log("Received LocalSession init (nargs=0), waiting for WasmSession init...");
        this.requestBytes(SizeOf.I64);
        this.state = RPCServerState.ReceivePacketHeader;
        return;
      }

      const args = [];
      for (let i = 0; i < nargs; ++i) {
        const typeIndex = reader.readU32();
        if (typeIndex === TypeIndex.kTVMFFIRawStr) {
          const str = Uint8ArrayToString(reader.readByteArray());
          args.push(str);
        } else if (typeIndex === TypeIndex.kTVMFFIStr) {
          reader.readU32(); // skip duplicate type_index
          const str = Uint8ArrayToString(reader.readByteArray());
          args.push(str);
        } else if (typeIndex === TypeIndex.kTVMFFIByteArrayPtr) {
          args.push(reader.readByteArray());
        } else if (typeIndex === TypeIndex.kTVMFFIBytes) {
          reader.readU32(); // skip duplicate type_index
          args.push(reader.readByteArray());
        } else {
          throw new Error("cannot support type index " + typeIndex);
        }
      }
      this.onInitServer(args, header, body);
    } else {
      assert(this.serverRecvData !== undefined);
      this.serverRecvData(header, body);
      this.requestBytes(SizeOf.I64);
      this.state = RPCServerState.ReceivePacketHeader;
    }
  }

  /** Event handler during server initialization. */
  private onInitServer(