fix ydb-platform#2

Author: nshestakov

ydb/core/tx/replication/service/common_ut.h

@@ -0,0 +1,13 @@
+#pragma once
+
+#include "worker.h"
+
+namespace NKikimr::NReplication::NService {
+
+struct TRecord: public TEvWorker::TEvData::TRecord {
+    explicit TRecord(ui64 offset, const TString& data)
+        : TEvWorker::TEvData::TRecord(offset, data, TInstant::Zero(), "MessageGroupId", "ProducerId", 42)
+    {}
+};
+
+}

ydb/core/tx/replication/service/table_writer_ut.cpp

@@ -1,6 +1,6 @@
 #include "service.h"
 #include "table_writer.h"
-#include "worker.h"
+#include "common_ut.h"
 
 #include <ydb/core/tx/datashard/ut_common/datashard_ut_common.h>
 #include <ydb/core/tx/replication/ut_helpers/test_env.h>
@@ -17,10 +17,6 @@ namespace NKikimr::NReplication::NService {
 Y_UNIT_TEST_SUITE(LocalTableWriter) {
     using namespace NTestHelpers;
 
-    TEvWorker::TEvData::TRecord TRecord(ui64 offset, const TString& data) {
-        return TEvWorker::TEvData::TRecord(offset, data, TInstant::Zero(), "MessageGroupId", "ProducerId", 13 /* seqNo */);
-    }
-
     Y_UNIT_TEST(WriteTable) {
         TEnv env;
         env.GetRuntime().SetLogPriority(NKikimrServices::REPLICATION_SERVICE, NLog::PRI_DEBUG);

ydb/core/tx/replication/service/transfer_writer_ut.cpp

@@ -1,6 +1,6 @@
 #include "service.h"
 #include "transfer_writer.h"
-#include "worker.h"
+#include "common_ut.h"
 
 #include <ydb/core/fq/libs/row_dispatcher/purecalc_compilation/compile_service.h>
 #include <ydb/core/tx/datashard/ut_common/datashard_ut_common.h>
@@ -18,10 +18,6 @@ namespace NKikimr::NReplication::NService {
 Y_UNIT_TEST_SUITE(TransferWriter) {
     using namespace NTestHelpers;
 
-    TEvWorker::TEvData::TRecord TRecord(ui64 offset, const TString& data) {
-        return TEvWorker::TEvData::TRecord(offset, data, TInstant::Zero(), "MessageGroupId", "ProducerId", 13 /* seqNo */);
-    }
-
     Y_UNIT_TEST(Write_ColumnTable) {
         TEnv env;
         env.GetRuntime().SetLogPriority(NKikimrServices::REPLICATION_SERVICE, NLog::PRI_DEBUG);