fix build

Author: CyberROFL

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

@@ -1,12 +1,12 @@
 #pragma once
 
-#include "worker.h"
+#include <ydb/core/tx/replication/ydb_proxy/topic_message.h>
 
 namespace NKikimr::NReplication::NService {
 
-struct TRecord: public TEvWorker::TEvData::TRecord {
+struct TRecord: public TTopicMessage {
     explicit TRecord(ui64 offset, const TString& data)
-        : TEvWorker::TEvData::TRecord(offset, data, TInstant::Zero(), "MessageGroupId", "ProducerId", 42)
+        : TTopicMessage(offset, data)
     {}
 };
 

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

@@ -1,3 +1,4 @@
+#include "common_ut.h"
 #include "s3_writer.h"
 #include "worker.h"
 
@@ -60,8 +61,7 @@ Y_UNIT_TEST_SUITE(S3Writer) {
         UNIT_ASSERT_VALUES_EQUAL(s3Mock.GetData().at("/TEST/writer.AtufpxzetsqaVnEuozdXpD.json"),
                                  R"({"finished":false,"table_name":"/MyRoot/Table","writer_name":"AtufpxzetsqaVnEuozdXpD"})");
 
-        using TRecord = TEvWorker::TEvData::TRecord;
-        env.Send<TEvWorker::TEvPoll>(writer, new TEvWorker::TEvData({
+        env.Send<TEvWorker::TEvPoll>(writer, new TEvWorker::TEvData(0, "TestSource", {
             TRecord(1, R"({"key":[1], "update":{"value":"10"}})"),
             TRecord(2, R"({"key":[2], "update":{"value":"20"}})"),
             TRecord(3, R"({"key":[3], "update":{"value":"30"}})"),
@@ -75,7 +75,7 @@ Y_UNIT_TEST_SUITE(S3Writer) {
                                  R"({"key":[2], "update":{"value":"20"}})" "\n"
                                  R"({"key":[3], "update":{"value":"30"}})" "\n");
 
-        auto res = env.Send<TEvWorker::TEvGone>(writer, new TEvWorker::TEvData({}));
+        auto res = env.Send<TEvWorker::TEvGone>(writer, new TEvWorker::TEvData(0, "TestSource", {}));
 
         UNIT_ASSERT_VALUES_EQUAL(res->Get()->Status, TEvWorker::TEvGone::DONE);
         UNIT_ASSERT_VALUES_EQUAL(s3Mock.GetData().size(), 2);

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

@@ -1,6 +1,7 @@
+#include "common_ut.h"
 #include "service.h"
 #include "table_writer.h"
-#include "common_ut.h"
+#include "worker.h"
 
 #include <ydb/core/tx/datashard/ut_common/datashard_ut_common.h>
 #include <ydb/core/tx/replication/ut_helpers/test_env.h>

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

@@ -1,6 +1,7 @@
+#include "common_ut.h"
 #include "service.h"
 #include "transfer_writer.h"
-#include "common_ut.h"
+#include "worker.h"
 
 #include <ydb/core/fq/libs/row_dispatcher/purecalc_compilation/compile_service.h>
 #include <ydb/core/tx/datashard/ut_common/datashard_ut_common.h>

ydb/core/tx/replication/service/ut_s3_writer/ya.make

@@ -6,6 +6,7 @@ SIZE(MEDIUM)
 
 PEERDIR(
     ydb/core/tx/replication/ut_helpers
+    ydb/core/tx/replication/ydb_proxy
     library/cpp/string_utils/base64
     library/cpp/testing/unittest
 )

ydb/core/tx/replication/service/ut_table_writer/ya.make

@@ -7,6 +7,7 @@ SIZE(MEDIUM)
 PEERDIR(
     ydb/core/tx/datashard/ut_common
     ydb/core/tx/replication/ut_helpers
+    ydb/core/tx/replication/ydb_proxy
     library/cpp/string_utils/base64
     library/cpp/testing/unittest
 )

ydb/core/tx/replication/service/ut_transfer_writer/ya.make

@@ -7,6 +7,7 @@ SIZE(MEDIUM)
 PEERDIR(
     ydb/core/tx/datashard/ut_common
     ydb/core/tx/replication/ut_helpers
+    ydb/core/tx/replication/ydb_proxy
     library/cpp/string_utils/base64
     library/cpp/testing/unittest
 )