Method _handleRequest

apps/realtime-server/src/sockets.ts:167–229

(decoder: decoding.Decoder)

    }
  }
  private async _handleRequest(decoder: decoding.Decoder) {
    // Gather commands

    const firstCommandId = decoding.readVarUint(decoder);

    const commandCount = decoding.readVarUint(decoder);

    let commands: RealtimeCommand[] = [];

    for (let i = 0; i < commandCount; i++) {
      const commandType = decoding.readVarUint(decoder);
      const commandArgs = unpack(decoding.readVarUint8Array(decoder));

      commands.push({
        id: firstCommandId + i,
        type: commandType,
        args: commandArgs,
      });
    }

    // Execute commands and gather results

    const promises: PromiseLike<any>[] = [];

    for (const command of commands) {
      promises.push(this._handleCommand(command));
    }

    const results = await Promise.allSettled(promises);

    if (this._dataNotificationBuffer.length > 0) {
      this._flushDataNotificationBuffer();
    }

    // Encode and send response

    commands = commands.filter(
      (command) => command.type === RealtimeCommandType.HGET,
    );

    if (commands.length === 0) {
      return;
    }

    const encoder = encoding.createEncoder();

    encoding.writeVarUint(encoder, RealtimeServerMessageType.RESPONSE);

    encoding.writeVarUint(encoder, commands.length);

    for (const command of commands) {
      const commandIndex = command.id - firstCommandId;

      encoding.writeVarUint(encoder, command.id);

      encoding.writeVarUint8Array(
        encoder,
        pack((results[commandIndex] as any).value),