Function addObjectTopic

pj_runtime/tests/app_session_test.cpp:362–376

}

PJ::ObjectTopicId addObjectTopic(
    PJ::AppSession& session, PJ::DatasetId dataset_id, const std::string& topic_name,
    PJ::sdk::BuiltinObjectType object_type, PJ::Timestamp timestamp = 0) {
  const std::string metadata =
      std::string{R"({"builtin_object_type":")"} + std::string(PJ::sdk::name(object_type)) + R"("})";
  auto& object_store = session.sessionManager().objectStore();
  auto topic = object_store.registerTopic(
      PJ::ObjectTopicDescriptor{.dataset_id = dataset_id, .topic_name = topic_name, .metadata_json = metadata});
  EXPECT_TRUE(topic.has_value()) << topic.error();
  if (!topic.has_value()) {
    return {};
  }
  EXPECT_TRUE(object_store.pushOwned(*topic, timestamp, std::vector<uint8_t>{1}).has_value());
  return *topic;
}

std::size_t mergedSampleCount(PJ::AppSession& session, PJ::DatasetId dataset, const std::string& topic) {
  for (const PJ::TopicId tid : session.sessionManager().dataEngine().listTopics(dataset)) {