Function processInboundFrame

packages/socketio-shim/src/adapter.ts:188–209

(sid: string, raw: string)

  }

  function processInboundFrame(sid: string, raw: string): void {
    const packet = decodeFrame(raw);
    if (!packet) return;
    switch (packet.type) {
      case PacketType.Disconnect:
        closeSession(sid, 'client disconnected');
        return;
      case PacketType.Heartbeat:
        // Clients echo the heartbeat; nothing to do — the fact that we
        // received any frame already proves liveness.
        return;
      case PacketType.Event: {
        const msg = socketIoEventToNative(packet);
        if (msg) opts.onClientMessage(msg, sid);
        return;
      }
      // Connect/Json/Message/Ack/Error/Noop: ignored. We only care about
      // Event frames for the EtherCalc protocol.
      default:
        return;
    }
  }

  function closeSession(sid: string, reason = 'closed'): void {
    const session = sessions.get(sid);