connect method

void connect()

Connect to the collection WebSocket

Implementation

void connect() {
  _reconnecting = ReconnectingWebSocket(url, {
    'api_key': apiKey,
    if (filters != null) 'filters': filters,
  });

  _reconnecting!.connect();
  _reconnecting!.onMessage((ev) {
    try {
      final data = jsonDecode(ev.data as String) as Map<String, dynamic>;
      final eventType = data['event'];

      switch (eventType) {
        case 'connected':
          _onConnected?.call(data);
          break;
        case 'create':
          _onCreate?.call(data);
          break;
        case 'update':
          _onUpdate?.call(data);
          break;
        case 'delete':
          _onDelete?.call(data);
          break;
        default:
        // Unknown event
      }
    } catch (err) {
      _onError?.call({'error': err.toString()});
    }
  });
}