Method saveDataProcessors

pj_app/src/MainWindow.cpp:3092–3162

}

QDomElement MainWindow::saveDataProcessors(QDomDocument& doc) const {
  QDomElement element = doc.createElement(QStringLiteral("data_processors"));
  for (const auto& recipe : session_->sessionManager().dataProcessorService().recipes()) {
    // Resolve the input column to a stable (topic, field) path so it rebinds on
    // reload exactly like a plotted curve.
    const QString input_key = QStringLiteral("dataset:%1/topic:%2/column:%3")
                                  .arg(recipe.dataset_id)
                                  .arg(recipe.input_topic_id)
                                  .arg(recipe.input_column_index);
    const std::optional<CurveDescriptor> input_desc = session_->catalogModel().curveDescriptor(input_key);
    if (!input_desc.has_value()) {
      continue;  // input field is gone; nothing to persist
    }
    QDomElement processor = doc.createElement(QStringLiteral("processor"));
    processor.setAttribute(QStringLiteral("input_topic"), input_desc->topic_name);
    processor.setAttribute(QStringLiteral("input_field"), input_desc->field_path);
    processor.setAttribute(QStringLiteral("processor_id"), QString::fromStdString(recipe.processor_id));
    processor.setAttribute(QStringLiteral("output_name"), QString::fromStdString(recipe.output_name));
    if (recipe.processor) {
      layout_xml::appendJsonAsCdata(doc, processor, QString::fromStdString(recipe.processor->saveParams()));
    }
    // Embed the filter's Luau source so the layout reopens on a machine without
    // this filter installed (resolved by restore's source_fallback leg). A named
    // child element, NOT a second direct CDATA child — restore reads params via
    // directCdataText, which ignores child elements. Empty for native C++ builtins.
    if (!recipe.filter_source.empty()) {
      QDomElement source_el = doc.createElement(QStringLiteral("source_fallback"));
      layout_xml::appendJsonAsCdata(doc, source_el, QString::fromStdString(recipe.filter_source));
      processor.appendChild(source_el);
    }
    element.appendChild(processor);
  }
  // Plugin-created transforms (pj.data_processors.v1): named, owner-tagged nodes
  // that carry their script + bindings BY VALUE, so they replay on load WITHOUT the
  // originating plugin (needed only for re-editing). Persisted in the same snapshot
  // block as the per-curve filters above; restore re-installs them via
  // DataProcessorService::restoreTransform. Inputs/outputs are topic NAMES (the
  // engine resolves them on restore), so no (topic, field) rebinding is needed here.
  for (const auto& recipe : session_->sessionManager().dataProcessorService().transformRecipes()) {
    QDomElement transform = doc.createElement(QStringLiteral("transform"));
    transform.setAttribute(QStringLiteral("owner_plugin"), QString::fromStdString(recipe.owner_plugin));
    transform.setAttribute(QStringLiteral("id"), QString::fromStdString(recipe.user_id));
    transform.setAttribute(QStringLiteral("backend"), QString::fromStdString(recipe.backend));
    transform.setAttribute(QStringLiteral("api_version"), QString::fromStdString(recipe.api_version));
    if (!recipe.backend_version.empty()) {
      transform.setAttribute(QStringLiteral("backend_version"), QString::fromStdString(recipe.backend_version));
    }
    for (const auto& input_name : recipe.inputs) {
      QDomElement in = doc.createElement(QStringLiteral("input"));
      in.setAttribute(QStringLiteral("name"), QString::fromStdString(input_name));
      transform.appendChild(in);
    }
    for (const auto& output_name : recipe.outputs) {
      QDomElement out = doc.createElement(QStringLiteral("output"));
      out.setAttribute(QStringLiteral("name"), QString::fromStdString(output_name));
      transform.appendChild(out);
    }
    // params (create(params), JSON) and script (the full backend payload, Luau today)