Function toolboxRegisterObjectTopic

pj_datastore/src/plugin_data_host.cpp:1504–1548

}

bool toolboxRegisterObjectTopic(
    void* ctx, DataSourceHandle source, PJ_string_view_t topic_name, PJ_string_view_t metadata_json,
    PJ_object_topic_handle_t* out_handle, PJ_error_t* out_error) noexcept {
  auto* impl = static_cast<DatastoreToolboxHostState*>(ctx);
  if (out_handle == nullptr) {
    propagateError(out_error, "out_handle must not be null");
    return false;
  }
  // Validate the source handle against the engine — same check used by scalar
  // ensureTopic so the toolbox can't register a topic against a dataset that
  // doesn't exist. Scope the engine lock to JUST this read — do NOT hold it
  // across object_store.registerTopic below: the engine and ObjectStore locks
  // must never nest (see pj_datastore/CLAUDE.md).
  {
    auto lock = impl->core.engine.lockEngine();
    if (impl->core.engine.getDataset(source.id) == nullptr) {
      impl->setObjectError(fmt::format("data source {} not found", source.id));
      propagateError(out_error, impl->object_last_error.c_str());
      return false;
    }
  }
  try {
    ObjectTopicDescriptor desc{};
    desc.dataset_id = source.id;
    desc.topic_name = std::string(toStringView(topic_name));
    desc.metadata_json = std::string(toStringView(metadata_json));
    auto result = impl->object_store.registerTopic(desc);
    if (!result) {
      impl->setObjectError(result.error());
      propagateError(out_error, impl->object_last_error.c_str());
      return false;
    }
    out_handle->id = result->id;
    impl->object_last_error.clear();
    return true;
  } catch (const std::exception& e) {
    impl->setObjectError(e.what());
    propagateError(out_error, impl->object_last_error.c_str());
    return false;
  } catch (...) {
    impl->setObjectError("registerObjectTopic: unknown exception");
    propagateError(out_error, impl->object_last_error.c_str());
    return false;
  }
}

bool toolboxPushOwnedObject(
    void* ctx, PJ_object_topic_handle_t topic, int64_t timestamp_ns, const uint8_t* data, uint64_t size,