Method onClientHello

packages/server/src/ws/connection.ts:270–290

(msg: ClientHelloMessage)

  }

  private async onClientHello(msg: ClientHelloMessage): Promise<void> {
    this.gotClientHello = true;
    const { subscriptions, cursors } = msg.payload;

    const sync = await this.syncSessions(subscriptions, cursors);

    this.logger.info(
      {
        acceptedCount: sync.accepted.length,
        resyncRequiredCount: sync.resyncRequired.length,
      },
      'client hello',
    );
    this.send(
      buildAck(msg.id, 0, 'success', {
        accepted_subscriptions: sync.accepted,
        resync_required: sync.resyncRequired,
        cursors: sync.serverCursors,
      }),
    );
  }

  /**
   * Shared client_hello/subscribe session sync: