Function toolboxObjectListTopics

pj_datastore/src/plugin_data_host.cpp:1760–1789

}

bool toolboxObjectListTopics(
    void* ctx, PJ_object_topic_handle_t* out_buffer, uint64_t buffer_capacity, uint64_t* out_count,
    PJ_error_t* out_error) noexcept {
  auto* impl = static_cast<DatastoreToolboxObjectReadHostState*>(ctx);
  if (out_count == nullptr) {
    propagateError(out_error, "out_count must not be null");
    return false;
  }
  try {
    const auto ids = impl->store.listTopics();
    *out_count = ids.size();
    if (out_buffer != nullptr) {
      // buffer_capacity is uint64_t (ABI); ids.size() is size_t. Compare in
      // uint64_t, then index with size_t (n <= ids.size(), so it fits).
      const std::size_t n = static_cast<std::size_t>(std::min<uint64_t>(buffer_capacity, ids.size()));
      for (std::size_t i = 0; i < n; ++i) {
        out_buffer[i] = PJ_object_topic_handle_t{ids[i].id};
      }
    }
    return true;
  } catch (const std::exception& e) {
    impl->setError(e.what());
    propagateError(out_error, impl->last_error.c_str());
    return false;
  } catch (...) {
    impl->setError("listTopics: unknown exception");
    propagateError(out_error, impl->last_error.c_str());
    return false;
  }
}

const char* toolboxObjectTopicMetadata(void* ctx, PJ_object_topic_handle_t topic) noexcept {
  auto* impl = static_cast<DatastoreToolboxObjectReadHostState*>(ctx);