Function TEST

pj_runtime/tests/data_processor_service_transform_test.cpp:124–140

};

TEST(DataProcessorTransformTest, UpsertCreatesNamedTopic) {
  Fixture fx;
  fx.seed("speed", {-1.0, 2.0, -3.0});

  const auto rec = fx.service.upsertTransform("pluginA", "negate", {"speed"}, {"speed/negated"}, kNegate, "{}");
  ASSERT_TRUE(rec.has_value()) << rec.error();
  EXPECT_EQ(rec->key, "pluginA/negate");
  EXPECT_EQ(rec->owner_plugin, "pluginA");
  EXPECT_EQ(rec->user_id, "negate");
  EXPECT_EQ(rec->backend, "luau");
  EXPECT_EQ(rec->dataset_id, fx.ds);  // output dataset = the input topic's dataset
  ASSERT_EQ(rec->output_topic_ids.size(), 1u);

  const TopicId out = rec->output_topic_ids.front();
  EXPECT_TRUE(fx.listed(out));
  EXPECT_EQ(readValues(fx.engine, out), (std::vector<double>{1.0, -2.0, 3.0}));
}

TEST(DataProcessorTransformTest, UpsertReplacesExistingNode) {
  Fixture fx;