Moved tests

Author: Gazizonoki

bad_tests.txt

@@ -0,0 +1,6 @@
+- Restarts
+- WithoutPartitionPartitionRelocation
+- WithoutPartitionUnknownEndpoint
+- WithoutPartitionWithSplit
+- WithoutPartitionWithRestart
+?? DirectWriteWithoutDescribeResourcesPermission

cmake/testing.cmake

@@ -53,8 +53,6 @@ function(add_ydb_test)
       EXTRA_ARGS ${YDB_TEST_TEST_ARG}
       WORKING_DIRECTORY ${YDB_TEST_WORKING_DIRECTORY}
       PROPERTIES LABELS ${YDB_TEST_LABELS}
-      PROPERTIES PROCESSORS 1
-      PROPERTIES TIMEOUT 600
     )
 
     target_link_libraries(${YDB_TEST_NAME} PRIVATE

include/ydb-cpp-sdk/library/retry/retry_policy.h

@@ -7,7 +7,6 @@
 
 #include <functional>
 #include <limits>
-#include <optional>
 #include <memory>
 
 //! Retry policy.

src/client/topic/ut/describe_topic_ut.cpp

@@ -1,17 +1,8 @@
 #include "ut_utils/topic_sdk_test_setup.h"
 
-#include <format>
-#include <src/library/persqueue/topic_parser_public/topic_parser.h>
-#include <src/api/protos/persqueue_error_codes_v1.pb.h>
 #include <ydb-cpp-sdk/client/topic/client.h>
-#include <src/client/persqueue_public/persqueue.h>
-#include <src/client/topic/common/log_lazy.h>
-#include <src/client/topic/impl/common.h>
 
 #include <library/cpp/testing/unittest/registar.h>
-#include <library/cpp/testing/unittest/tests_data.h>
-#include <library/cpp/threading/future/future.h>
-#include <library/cpp/threading/future/async.h>
 
 namespace NYdb::NTopic::NTests {
 
@@ -258,106 +249,10 @@ namespace NYdb::NTopic::NTests {
             }
         }
 
-        Y_UNIT_TEST(Basic) {
-            TTopicSdkTestSetup setup(TEST_CASE_NAME);
-            TTopicClient client = setup.MakeClient();
-
-            DescribeTopic(setup, client, false, false, false, false);
-            DescribeConsumer(setup, client, false, false, false, false);
-            DescribePartition(setup, client, false, false, false, false);
-        }
-
-        Y_UNIT_TEST(Statistics) {
-            // TODO(abcdef): temporarily deleted
-            return;
-
-            TTopicSdkTestSetup setup(TEST_CASE_NAME);
-            TTopicClient client = setup.MakeClient();
-
-            // Get empty description
-            DescribeTopic(setup, client, true, false, false, false);
-            DescribeConsumer(setup, client, true, false, false, false);
-            DescribePartition(setup, client, true, false, false, false);
-
-            const size_t messagesCount = 1;
-
-            // Write a message
-            {
-                auto writeSettings = TWriteSessionSettings().Path(TEST_TOPIC).MessageGroupId(TEST_MESSAGE_GROUP_ID).Codec(ECodec::RAW);
-                auto writeSession = client.CreateSimpleBlockingWriteSession(writeSettings);
-                std::string message(32_MB, 'x');
-
-                for(size_t i = 0; i < messagesCount; ++i) {
-                    UNIT_ASSERT(writeSession->Write(message, {}, TInstant::Now() - TDuration::Seconds(100)));
-                }
-                writeSession->Close();
-            }
-
-            // Read a message
-            {
-                auto readSettings = TReadSessionSettings().ConsumerName(TEST_CONSUMER).AppendTopics(TEST_TOPIC);
-                auto readSession = client.CreateReadSession(readSettings);
-
-                // Event 1: start partition session
-                {
-                    std::optional<TReadSessionEvent::TEvent> event = readSession->GetEvent(true);
-                    UNIT_ASSERT(event);
-                    auto startPartitionSession = std::get_if<TReadSessionEvent::TStartPartitionSessionEvent>(&event.value());
-                    UNIT_ASSERT_C(startPartitionSession, DebugString(*event));
-
-                    startPartitionSession->Confirm();
-                }
-
-                // Event 2: data received
-                {
-                    std::optional<TReadSessionEvent::TEvent> event = readSession->GetEvent(true);
-                    UNIT_ASSERT(event);
-                    auto dataReceived = std::get_if<TReadSessionEvent::TDataReceivedEvent>(&event.value());
-                    UNIT_ASSERT_C(dataReceived, DebugString(*event));
-
-                    dataReceived->Commit();
-                }
-
-                // Event 3: commit acknowledgement
-                {
-                    std::optional<TReadSessionEvent::TEvent> event = readSession->GetEvent(true);
-                    UNIT_ASSERT(event);
-                    auto commitOffsetAck = std::get_if<TReadSessionEvent::TCommitOffsetAcknowledgementEvent>(&event.value());
-
-                    UNIT_ASSERT_C(commitOffsetAck, DebugString(*event));
-
-                    UNIT_ASSERT_VALUES_EQUAL(commitOffsetAck->GetCommittedOffset(), messagesCount);
-                }
-            }
-
-            // Additional write
-            {
-                auto writeSettings = TWriteSessionSettings().Path(TEST_TOPIC).MessageGroupId(TEST_MESSAGE_GROUP_ID).Codec(ECodec::RAW);
-                auto writeSession = client.CreateSimpleBlockingWriteSession(writeSettings);
-                std::string message(32, 'x');
-
-                for(size_t i = 0; i < messagesCount; ++i) {
-                    UNIT_ASSERT(writeSession->Write(message));
-                }
-                writeSession->Close();
-            }
-            Sleep(TDuration::Seconds(3));
-
-            // Get non-empty description
-
-            DescribeTopic(setup, client, true, true, false, false);
-            DescribeConsumer(setup, client, true, true, false, false);
-            DescribePartition(setup, client, true, true, false, false);
-        }
-
         Y_UNIT_TEST(Location) {
             TTopicSdkTestSetup setup(TEST_CASE_NAME);
             TTopicClient client = setup.MakeClient();
 
-            DescribeTopic(setup, client, false, false, true, false);
-            DescribeConsumer(setup, client, false, false, true, false);
-            DescribePartition(setup, client, false, false, true, false);
-
             // Describe with KillTablets
             DescribeTopic(setup, client, false, false, true, true);
             DescribeConsumer(setup, client, false, false, true, true);

src/client/topic/ut/trace_ut.cpp

@@ -1,11 +1,18 @@
+add_subdirectory(utils)
+
 add_ydb_test(NAME topic_it GTEST
   SOURCES
     basic_usage.cpp
+    describe_topic.cpp
+    fixture.cpp
+    local_partition.cpp
+    trace.cpp
   LINK_LIBRARIES
-    yutil
-    YDB-CPP-SDK::Topic
+    topic_it_utils
     cpp-client-ydb_persqueue_public
+    YDB-CPP-SDK::Discovery
     api-grpc
+    yutil
   LABELS
     integration
 )