Method open

app/src/IO/Drivers/MQTT.cpp:159–205

* @brief Opens the broker connection. Subscription is issued once Connected. */

 * @brief Opens the broker connection. Subscription is issued once Connected.
 */
bool IO::Drivers::MQTT::open(const QIODevice::OpenMode mode)
{
  Q_UNUSED(mode);

  const auto& token = Licensing::CommercialToken::current();
  if (!token.isValid() || !SS_LICENSE_GUARD()
      || token.featureTier() < Licensing::FeatureTier::Trial) {
    Misc::Utilities::showMessageBox(
      tr("MQTT Feature Requires a Commercial License"),
      tr("Subscribing to an MQTT broker is only available with a valid Serial Studio license "
         "or an active trial."),
      QMessageBox::Warning);
    return false;
  }

  if (m_hostname.isEmpty() || m_port == 0) {
    qCWarning(lcMqttSub) << "open() rejected: missing hostname or port" << m_hostname << m_port;
    return false;
  }

  if (m_topicFilter.isEmpty()) {
    qCWarning(lcMqttSub) << "open() rejected: empty topic filter";
    return false;
  }

  if (m_client.state() != QMqttClient::Disconnected) {
    qCInfo(lcMqttSub) << "open() no-op; state already" << m_client.state();
    return true;
  }

  if (m_clientId.isEmpty())
    regenerateClientId();

  applyPendingToClient();
  m_userWantsOpen = true;

  qCInfo(lcMqttSub).nospace() << "Connecting to " << (m_sslEnabled ? "mqtts://" : "mqtt://")
                              << m_hostname << ":" << m_port << " clientId=" << m_clientId
                              << " topic=" << m_topicFilter;

  if (m_sslEnabled)
    m_client.connectToHostEncrypted(m_sslConfiguration);
  else
    m_client.connectToHost();

  return true;
}

//--------------------------------------------------------------------------------------------------
// Property getters