Function TEST

pj_scene2D/tests/streaming_video_decoder_test.cpp:701–745

const std::string kBframeVideo = "pj_scene2D/testdata/test_1080p_bframes.mp4";

TEST(StreamingVideoDecoderBframeTest, PushWithDtsAndDecode) {
  if (!std::filesystem::exists(kBframeVideo)) {
    GTEST_SKIP() << "test_1080p_bframes.mp4 not found";
  }
  auto packets = test::extractAnnexBPackets(kBframeVideo);
  ASSERT_GT(packets.size(), 10u);

  // Verify this video actually has non-monotonic PTS (B-frames)
  bool has_non_monotonic_pts = false;
  for (size_t i = 1; i < packets.size(); ++i) {
    if (packets[i].timestamp < packets[i - 1].timestamp) {
      has_non_monotonic_pts = true;
      break;
    }
  }
  ASSERT_TRUE(has_non_monotonic_pts) << "test video should have B-frames with non-monotonic PTS";

  // Verify DTS IS monotonic
  for (size_t i = 1; i < packets.size(); ++i) {
    ASSERT_GE(packets[i].dts, packets[i - 1].dts) << "DTS should be monotonic at i=" << i;
  }

  // Push using DTS as ObjectStore timestamp
  ObjectStore store;
  auto topic_result = store.registerTopic({0, "video/bframes", R"({"media_class":"video","encoding":"h264"})"});
  auto topic = topic_result.value();

  for (const auto& pkt : packets) {
    auto result = store.pushOwned(topic, pkt.dts, pkt.data);
    ASSERT_TRUE(result.has_value()) << "push failed at dts=" << pkt.dts << ": " << result.error();
  }

  EXPECT_EQ(store.entryCount(topic), packets.size());

  // Decode via StreamingVideoDecoder
  StreamingVideoDecoder decoder;
  decoder.attach(&store, topic);

  auto range = store.timeRange(topic);
  auto result = decoder.decodeAt(range.second);
  ASSERT_TRUE(result.has_value()) << result.error();
  EXPECT_FALSE(result->isNull());
  EXPECT_EQ(result->width, 1920);
  EXPECT_EQ(result->height, 1080);
}

TEST(StreamingVideoDecoderBframeTest, LiveStreamWithDts) {
  if (!std::filesystem::exists(kBframeVideo)) {