connect method

Future<void> connect(ButtplugClientConnector connector)

Implementation

Future<void> connect(ButtplugClientConnector connector) async {
  _communicator = ButtplugClientCommunicator(connector);
  connector.messageStream.listen((message) {
    if (message.deviceList != null) {
      for (var deviceInfo in message.deviceList!.devices.values) {
        if (!_devices.containsKey(deviceInfo.deviceIndex)) {
          var device = ButtplugClientDevice(deviceInfo, _communicator!);
          _devices[device.index] = device;
          _communicator!.eventStreamController.add(DeviceAddedEvent(device));
        }
      }
      List<int> removedDevices = [];
      for (var index in _devices.keys) {
        if (_devices.keys
            .where((x) => message.deviceList!.devices.values.where((y) => index == y.deviceIndex).isNotEmpty)
            .isEmpty) {
          removedDevices.add(index);
        }
      }
      for (var removedIndex in removedDevices) {
        var device = _devices[removedIndex]!;
        _devices.remove(removedIndex);
        _communicator!.eventStreamController.add(DeviceRemovedEvent(device));
      }
      _communicator!.eventStreamController.add(DeviceListReceivedEvent());
    }
  });

  await _communicator!.connect();

  // Send RequestServerInfo, expect back ServerInfo
  var requestServerInfo = RequestServerInfo();
  requestServerInfo.clientName = name;
  ButtplugServerMessage serverInfo = await _communicator!.sendMessageExpectReply(requestServerInfo);
  if (serverInfo.serverInfo == null) {
    throw ButtplugClientException(
      "Did not receive ServerInfo message back from server on handshake: ${jsonEncode(serverInfo.toJson())}.",
    );
  }
  _serverName = serverInfo.serverInfo!.serverName;

  // Send RequestDeviceList, expect back DeviceList
  var requestDeviceList = RequestDeviceList();
  ButtplugServerMessage deviceListWrapper = await _communicator!.sendMessageExpectReply(requestDeviceList);
  if (deviceListWrapper.deviceList == null) {
    throw ButtplugClientException("Did not receive DeviceList message back from server on handshake.");
  }
  var deviceList = deviceListWrapper.deviceList!;
  for (var device in deviceList.devices.values) {
    _devices[device.deviceIndex] = ButtplugClientDevice(device, _communicator!);
  }
}