removed private protobuf dependency from public class WriteAck

Author: zinal

topic/src/main/java/tech/ydb/topic/write/WriteAck.java

@@ -2,8 +2,6 @@
 
 import java.time.Duration;
 
-import tech.ydb.proto.topic.YdbTopic;
-
 /**
  * @author Nikolay Perfilov
  */
@@ -50,13 +48,6 @@ public Statistics getStatistics() {
         return statistics;
     }
 
-    private static Duration convert(com.google.protobuf.Duration d) {
-        if (d == null) {
-            return Duration.ZERO;
-        }
-        return Duration.ofSeconds(d.getSeconds(), d.getNanos());
-    }
-
     public static class Details {
         private final long offset;
 
@@ -76,12 +67,14 @@ public static class Statistics {
         private final Duration maxQueueWaitTime;
         private final Duration minQueueWaitTime;
 
-        public Statistics(YdbTopic.StreamWriteMessage.WriteResponse.WriteStatistics src) {
-            this.persistingTime          = convert(src.getPersistingTime());
-            this.partitionQuotaWaitTime  = convert(src.getPartitionQuotaWaitTime());
-            this.topicQuotaWaitTime      = convert(src.getTopicQuotaWaitTime());
-            this.maxQueueWaitTime        = convert(src.getMaxQueueWaitTime());
-            this.minQueueWaitTime        = convert(src.getMinQueueWaitTime());
+        public Statistics(Duration persistingTime,
+                Duration partitionQuotaWaitTime, Duration topicQuotaWaitTime,
+                Duration maxQueueWaitTime, Duration minQueueWaitTime) {
+            this.persistingTime = persistingTime;
+            this.partitionQuotaWaitTime = partitionQuotaWaitTime;
+            this.topicQuotaWaitTime = topicQuotaWaitTime;
+            this.maxQueueWaitTime = maxQueueWaitTime;
+            this.minQueueWaitTime = minQueueWaitTime;
         }
 
         public Duration getPersistingTime() {

topic/src/main/java/tech/ydb/topic/write/impl/WriterImpl.java

@@ -1,6 +1,7 @@
 package tech.ydb.topic.write.impl;
 
 import java.io.IOException;
+import java.time.Duration;
 import java.util.Deque;
 import java.util.LinkedList;
 import java.util.List;
@@ -320,6 +321,13 @@ protected void onShutdown(String reason) {
         }
     }
 
+    private static Duration convertDuration(com.google.protobuf.Duration d) {
+        if (d == null) {
+            return Duration.ZERO;
+        }
+        return Duration.ofSeconds(d.getSeconds(), d.getNanos());
+    }
+
     private class WriteSessionImpl extends WriteSession {
         protected String sessionId;
         private final MessageSender messageSender;
@@ -423,7 +431,14 @@ private void onWriteResponse(YdbTopic.StreamWriteMessage.WriteResponse response)
             logger.debug("[{}] Received WriteResponse with {} WriteAcks", streamId, acks.size());
             WriteAck.Statistics statistics = null;
             if (response.getWriteStatistics() != null) {
-                statistics = new WriteAck.Statistics(response.getWriteStatistics());
+                YdbTopic.StreamWriteMessage.WriteResponse.WriteStatistics src = response.getWriteStatistics();
+                statistics = new WriteAck.Statistics(
+                    convertDuration(src.getPersistingTime()),
+                    convertDuration(src.getPartitionQuotaWaitTime()),
+                    convertDuration(src.getTopicQuotaWaitTime()),
+                    convertDuration(src.getMaxQueueWaitTime()),
+                    convertDuration(src.getMinQueueWaitTime())
+                );
             }
             int inFlightFreed = 0;
             long bytesFreed = 0;