connect method

  1. @override
Future<MqttClientConnectionStatus> connect (
  1. String server,
  2. int port
)
override

Connect

Implementation

@override
Future<MqttClientConnectionStatus> connect(String server, int port) {
  final completer = Completer<MqttClientConnectionStatus>();
  MqttLogger.log('MqttWs2Connection::connect');
  Uri uri;
  try {
    uri = Uri.parse(server);
  } on Exception {
    final message =
        'MqttWsConnection::The URI supplied for the WS2 connection '
        'is not valid - $server';
    throw NoConnectionException(message);
  }
  if (uri.scheme != 'wss') {
    final message = 'MqttWsConnection::The URI supplied for the WS2 has an '
        'incorrect scheme - $server';
    throw NoConnectionException(message);
  }
  if (port != null) {
    uri = uri.replace(port: port);
  }
  final uriString = uri.toString();
  MqttLogger.log(
      'MqttWs2Connection:: WS URL is $uriString, protocols are $protocols');

  try {
    SecureSocket.connect(uri.host, uri.port, context: context)
        .then((Socket socket) {
      MqttLogger.log('MqttWs2Connection::connect - securing socket');
      _performWSHandshake(socket, uri).then((bool b) {
        client = WebSocket.fromUpgradedSocket(
            _DetachedSocket(socket, _subscription),
            serverSide: false);
        readWrapper = ReadWrapper();
        messageStream = MqttByteBuffer(typed.Uint8Buffer());
        MqttLogger.log('MqttWs2Connection::connect - start listening');
        _startListening();
        completer.complete();
      }).catchError((dynamic e) {
        onError(e);
        completer.completeError(e);
      });
    });
  } on SocketException catch (e) {
    final message = 'MqttWs2Connection::The connection to the message broker '
        '{$server}:{$port} could not be made. Error is ${e.toString()}';
    completer.completeError(e);
    throw NoConnectionException(message);
  } on HandshakeException catch (e) {
    final message =
        'MqttWs2Connection::Handshake exception to the message broker '
        '{$server}:{$port}. Error is ${e.toString()}';
    completer.completeError(e);
    throw NoConnectionException(message);
  } on TlsException catch (e) {
    final message =
        'MqttWs2Connection::TLS exception raised on secure connection. '
        'Error is ${e.toString()}';
    throw NoConnectionException(message);
  }
  return completer.future;
}