connectAuto method

@override Future<MqttConnectionStatus?> connectAuto(String server, int port)

Connect Auto

Implementation

@override
Future<MqttConnectionStatus?> connectAuto(String server, int port) {
  final completer = Completer<MqttConnectionStatus?>();
  MqttLogger.log('MqttServerSecureConnection::connectAuto - entered');
  try {
    SecureSocket.connect(server, port,
            onBadCertificate: onBadCertificate, context: context)
        .then((SecureSocket socket) {
      MqttLogger.log(
          'MqttServerSecureConnection::connectAuto - securing socket');
      // Socket options
      final applied = _applySocketOptions(socket, socketOptions);
      if (applied) {
        MqttLogger.log(
            'MqttServerSecureConnection::connectAuto - socket options applied');
      }
      client = socket;
      MqttLogger.log(
          'MqttServerSecureConnection::connectAuto - start listening');
      _startListening();
      completer.complete();
    }).catchError((dynamic e) {
      if (_isSocketTimeout(e)) {
        final message =
            'MqttNormalConnection::connectAuto - The connection to the message broker '
            '{$server}:{$port} could not be made, a socket timeout has occurred';
        MqttLogger.log(message);
        completer.complete();
      } else {
        onError(e);
        completer.completeError(e);
      }
    });
  } on SocketException catch (e) {
    final message =
        'MqttServerSecureConnection::connectAuto - The connection to the message broker '
        '{$server}:{$port} could not be made. Error is ${e.toString()}';
    completer.completeError(e);
    throw MqttNoConnectionException(message);
  } on HandshakeException catch (e) {
    final message =
        'MqttServerSecureConnection::connectAuto - Handshake exception to the message broker '
        '{$server}:{$port}. Error is ${e.toString()}';
    completer.completeError(e);
    throw MqttNoConnectionException(message);
  } on TlsException catch (e) {
    final message =
        'MqttServerSecureConnection::connectAuto - TLS exception raised on secure '
        'connection. Error is ${e.toString()}';
    throw MqttNoConnectionException(message);
  }
  return completer.future;
}