Function TEST

pj_runtime/tests/data_processor_service_test.cpp:64–88

}

TEST(DataProcessorServiceTest, AppliesAbsoluteFilterAndMaterializesOutput) {
  DataEngine engine;
  DataProcessorService service(engine);
  service.setFilterCatalogue(catalogueFromSource(kAbsoluteSrc));
  const DatasetId ds = *engine.createDataset(DatasetDescriptor{.source_name = "t", .time_domain_id = 0});

  DataWriter writer = engine.createWriter();
  auto handle = writer.registerScalarSeries(ds, "speed", NumericType::kFloat64);
  const TopicId src = handle->topic_id;
  writer.appendScalar(*handle, 0, -1.0);
  writer.appendScalar(*handle, 1'000'000'000LL, 2.0);
  writer.appendScalar(*handle, 2'000'000'000LL, -3.0);
  engine.commitChunks(writer.flushAll());

  const auto result = service.applyFilter(src, ds, "absolute", "speed[Absolute]");
  ASSERT_TRUE(result.has_value()) << result.error();
  EXPECT_NE(result->output_topic_id, 0u);
  EXPECT_EQ(result->output_name, "speed[Absolute]");

  const auto vals = readValues(engine, result->output_topic_id);
  ASSERT_EQ(vals.size(), 3u);
  EXPECT_DOUBLE_EQ(vals[0], 1.0);
  EXPECT_DOUBLE_EQ(vals[1], 2.0);
  EXPECT_DOUBLE_EQ(vals[2], 3.0);
}

TEST(DataProcessorServiceTest, IntegralFilterAccumulates) {
  DataEngine engine;