Decode source id in topic data handler (#17554)

Author: FloatingCrowbar

ydb/core/viewer/tests/canondata/result.json

@@ -801,7 +801,7 @@
                     "Message": "Y29tcHJlc3NlZC1tZXNzYWdlLTA=",
                     "Offset": 11,
                     "OriginalSize": 20,
-                    "ProducerId": "text",
+                    "ProducerId": "not-zero-number-text",
                     "SeqNo": 12,
                     "StorageSize": 38,
                     "TimestampDiff": "not-zero-number",
@@ -813,7 +813,7 @@
                     "Message": "Y29tcHJlc3NlZC1tZXNzYWdlLTE=",
                     "Offset": 12,
                     "OriginalSize": 20,
-                    "ProducerId": "text",
+                    "ProducerId": "not-zero-number-text",
                     "SeqNo": 13,
                     "StorageSize": 38,
                     "TimestampDiff": "not-zero-number",
@@ -825,7 +825,7 @@
                     "Message": "Y29tcHJlc3NlZC1tZXNzYWdlLTI=",
                     "Offset": 13,
                     "OriginalSize": 20,
-                    "ProducerId": "text",
+                    "ProducerId": "not-zero-number-text",
                     "SeqNo": 14,
                     "StorageSize": 38,
                     "TimestampDiff": "not-zero-number",
@@ -837,7 +837,7 @@
                     "Message": "Y29tcHJlc3NlZC1tZXNzYWdlLTM=",
                     "Offset": 14,
                     "OriginalSize": 20,
-                    "ProducerId": "text",
+                    "ProducerId": "not-zero-number-text",
                     "SeqNo": 15,
                     "StorageSize": 38,
                     "TimestampDiff": "not-zero-number",
@@ -849,7 +849,7 @@
                     "Message": "Y29tcHJlc3NlZC1tZXNzYWdlLTQ=",
                     "Offset": 15,
                     "OriginalSize": 20,
-                    "ProducerId": "text",
+                    "ProducerId": "not-zero-number-text",
                     "SeqNo": 16,
                     "StorageSize": 38,
                     "TimestampDiff": "not-zero-number",
@@ -878,7 +878,7 @@
                     ],
                     "Offset": 10,
                     "OriginalSize": 17,
-                    "ProducerId": "text",
+                    "ProducerId": "not-zero-number-text",
                     "SeqNo": 11,
                     "StorageSize": 37,
                     "TimestampDiff": "not-zero-number",
@@ -897,7 +897,7 @@
                     "Message": "Y29tcHJlc3NlZC1tZXNzYWdlLTk=",
                     "Offset": 20,
                     "OriginalSize": 20,
-                    "ProducerId": "text",
+                    "ProducerId": "not-zero-number-text",
                     "SeqNo": 21,
                     "StorageSize": 38,
                     "TimestampDiff": "not-zero-number",
@@ -916,7 +916,7 @@
                     "Message": "bWVzc2FnZS0w",
                     "Offset": 0,
                     "OriginalSize": 9,
-                    "ProducerId": "text",
+                    "ProducerId": "not-zero-number-text",
                     "SeqNo": 1,
                     "StorageSize": 9,
                     "TimestampDiff": "not-zero-number",
@@ -928,7 +928,7 @@
                     "Message": "bWVzc2FnZS0x",
                     "Offset": 1,
                     "OriginalSize": 9,
-                    "ProducerId": "text",
+                    "ProducerId": "not-zero-number-text",
                     "SeqNo": 2,
                     "StorageSize": 9,
                     "TimestampDiff": "not-zero-number",
@@ -940,7 +940,7 @@
                     "Message": "bWVzc2FnZS0y",
                     "Offset": 2,
                     "OriginalSize": 9,
-                    "ProducerId": "text",
+                    "ProducerId": "not-zero-number-text",
                     "SeqNo": 3,
                     "StorageSize": 9,
                     "TimestampDiff": "not-zero-number",
@@ -952,7 +952,7 @@
                     "Message": "bWVzc2FnZS0z",
                     "Offset": 3,
                     "OriginalSize": 9,
-                    "ProducerId": "text",
+                    "ProducerId": "not-zero-number-text",
                     "SeqNo": 4,
                     "StorageSize": 9,
                     "TimestampDiff": "not-zero-number",
@@ -964,7 +964,7 @@
                     "Message": "bWVzc2FnZS00",
                     "Offset": 4,
                     "OriginalSize": 9,
-                    "ProducerId": "text",
+                    "ProducerId": "not-zero-number-text",
                     "SeqNo": 5,
                     "StorageSize": 9,
                     "TimestampDiff": "not-zero-number",

ydb/core/viewer/viewer_topic_data.cpp

@@ -181,7 +181,11 @@ void TTopicData::FillProtoResponse(ui64 maxSingleMessageSize, ui64 maxTotalSize)
             setData(*messageProto, std::move(*dataChunk.MutableData()));
         }
         messageProto->SetCodec(dataChunk.GetCodec());
-        messageProto->SetProducerId(r.GetSourceId());
+        TString decodedSrcId;
+        if (!r.GetSourceId().empty()) {
+            decodedSrcId = NPQ::NSourceIdEncoding::Decode(r.GetSourceId());
+        }
+        messageProto->SetProducerId(decodedSrcId);
         messageProto->SetSeqNo(r.GetSeqNo());
 
         if (dataChunk.MessageMetaSize() > 0) {