Method applyProjectConfig

app/src/MQTT/Publisher.cpp:1210–1260

* @brief Loads configuration from a project-supplied JSON object. */

 * @brief Loads configuration from a project-supplied JSON object.
 */
void MQTT::Publisher::applyProjectConfig(const QJsonObject& cfg)
{
  m_inApply = true;

  setEnabled(cfg.value(kKeyEnabled).toBool(false));
  setMode(cfg.value(kKeyMode).toInt(static_cast<int>(Mode::RawRxData)));
  setPublishNotifications(cfg.value(kKeyPublishNotifications).toBool(false));
  setPublishFrequency(cfg.value(kKeyPublishFrequency).toInt(kDefaultPublishHz));
  setTopicBase(cfg.value(kKeyTopicBase).toString());
  setNotificationTopic(cfg.value(kKeyNotificationTopic).toString());
  setScriptCode(cfg.value(kKeyScriptCode).toString());
  setScriptTopic(cfg.value(kKeyScriptTopic).toString());
  setScriptLanguage(cfg.value(kKeyScriptLanguage).toInt(0));

  setHostname(cfg.value(kKeyHostname).toString(QStringLiteral("127.0.0.1")));
  setPort(static_cast<quint16>(cfg.value(kKeyPort).toInt(1883)));

  const bool customCid = cfg.value(kKeyCustomClientId).toBool(false);
  setCustomClientId(customCid);

  const auto cid = cfg.value(kKeyClientId).toString();
  if (customCid && !cid.isEmpty())
    setClientId(cid);
  else
    regenerateClientId();

  reloadCredentialsFromVault();

  setCleanSession(cfg.value(kKeyCleanSession).toBool(true));
  setKeepAlive(static_cast<quint16>(cfg.value(kKeyKeepAlive).toInt(60)));
  setMqttVersion(static_cast<quint8>(cfg.value(kKeyMqttVersion).toInt(2)));

  setSslEnabled(cfg.value(kKeySslEnabled).toBool(false));
  setSslProtocol(static_cast<quint8>(cfg.value(kKeySslProtocol).toInt(5)));
  setPeerVerifyMode(static_cast<quint8>(cfg.value(kKeyPeerVerifyMode).toInt(3)));
  setPeerVerifyDepth(cfg.value(kKeyPeerVerifyDepth).toInt(10));

  m_inApply = false;

  m_savingToProjectModel = true;
  DataModel::ProjectModel::instance().setMqttPublisher(toJson());
  m_savingToProjectModel = false;

  m_skipNextSync = true;
  Q_EMIT configurationChanged();
  m_skipNextSync = false;

  m_reportConnectionErrors = m_enabled;
  m_syncTimer.stop();
  syncToWorker();
}

/**
 * @brief Resets the publisher to default state (used on project close / new).