fix PR comments by copilot

Author: Bhargavkonidena

lib/MessageBuilder.cc

@@ -60,29 +60,35 @@ void MessageBuilder::checkMetadata() {
 MessageBuilder& MessageBuilder::setContent(const void* data, size_t size) {
     checkMetadata();
     impl_->payload = SharedBuffer::copy((char*)data, size);
+    impl_->metadata.clear_null_value();
     return *this;
 }
 
 MessageBuilder& MessageBuilder::setAllocatedContent(void* data, size_t size) {
     checkMetadata();
     impl_->payload = SharedBuffer::wrap((char*)data, size);
+    impl_->metadata.clear_null_value();
     return *this;
 }
 
 MessageBuilder& MessageBuilder::setContent(const std::string& data) {
     checkMetadata();
     impl_->payload = SharedBuffer::copy((char*)data.c_str(), data.length());
+    impl_->metadata.clear_null_value();
     return *this;
 }
 
 MessageBuilder& MessageBuilder::setContent(std::string&& data) {
     checkMetadata();
     impl_->payload = SharedBuffer::take(std::move(data));
+    impl_->metadata.clear_null_value();
     return *this;
 }
 
 MessageBuilder& MessageBuilder::setContent(const KeyValue& data) {
+    checkMetadata();
     impl_->keyValuePtr = data.impl_;
+    impl_->metadata.clear_null_value();
     return *this;
 }
 
@@ -160,6 +166,7 @@ MessageBuilder& MessageBuilder::disableReplication(bool flag) {
 MessageBuilder& MessageBuilder::setNullValue() {
     checkMetadata();
     impl_->metadata.set_null_value(true);
+    impl_->payload = SharedBuffer();
     return *this;
 }
 

tests/ReaderTest.cc

@@ -1055,12 +1055,9 @@ TEST(ReaderTest, testReadCompactedWithNullValue) {
     ASSERT_EQ(ResultOk, client.createProducer(topicName, producer));
 
     // Send messages with keys
-    ASSERT_EQ(ResultOk,
-              producer.send(MessageBuilder().setPartitionKey("key1").setContent("value1").build()));
-    ASSERT_EQ(ResultOk,
-              producer.send(MessageBuilder().setPartitionKey("key2").setContent("value2").build()));
-    ASSERT_EQ(ResultOk,
-              producer.send(MessageBuilder().setPartitionKey("key3").setContent("value3").build()));
+    ASSERT_EQ(ResultOk, producer.send(MessageBuilder().setPartitionKey("key1").setContent("value1").build()));
+    ASSERT_EQ(ResultOk, producer.send(MessageBuilder().setPartitionKey("key2").setContent("value2").build()));
+    ASSERT_EQ(ResultOk, producer.send(MessageBuilder().setPartitionKey("key3").setContent("value3").build()));
 
     // Send a tombstone (null value) for key2
     auto tombstone = MessageBuilder().setPartitionKey("key2").setNullValue().build();
@@ -1075,10 +1072,9 @@ TEST(ReaderTest, testReadCompactedWithNullValue) {
     // Trigger compaction via admin API
     {
         std::string compactUrl =
-            adminUrl + "admin/v2/persistent/public/default/testReadCompactedWithNullValue-" +
-            std::to_string(time(nullptr)) + "/compaction";
-        // Note: Compaction is async, we just trigger it
-        makePutRequest(compactUrl, "");
+            adminUrl + "admin/v2/" + topicName.substr(strlen("persistent://")) + "/compaction";
+        int res = makePutRequest(compactUrl, "");
+        ASSERT_TRUE(res == 204 || res == 409) << "Failed to trigger compaction, res: " << res;
     }
 
     // Create a reader with readCompacted enabled
@@ -1091,18 +1087,11 @@ TEST(ReaderTest, testReadCompactedWithNullValue) {
     std::map<std::string, std::string> keyValues;
     std::set<std::string> nullValueKeys;
 
-    for (int i = 0; i < 10; i++) {
-        bool hasMessageAvailable = false;
-        ASSERT_EQ(ResultOk, reader.hasMessageAvailable(hasMessageAvailable));
-        if (!hasMessageAvailable) {
-            break;
-        }
-
+    bool hasMessageAvailable = false;
+    ASSERT_EQ(ResultOk, reader.hasMessageAvailable(hasMessageAvailable));
+    while (hasMessageAvailable) {
         Message msg;
-        Result res = reader.readNext(msg, 3000);
-        if (res != ResultOk) {
-            break;
-        }
+        ASSERT_EQ(ResultOk, reader.readNext(msg, 3000));
 
         std::string key = msg.getPartitionKey();
         if (msg.hasNullValue()) {
@@ -1112,6 +1101,8 @@ TEST(ReaderTest, testReadCompactedWithNullValue) {
             keyValues[key] = msg.getDataAsString();
             LOG_INFO("Received message for key: " << key << ", value: " << msg.getDataAsString());
         }
+
+        ASSERT_EQ(ResultOk, reader.hasMessageAvailable(hasMessageAvailable));
     }
 
     // Verify we received the tombstone for key2