Moved basic usage topic test from ydb repo

.github/workflows/tests.yaml

@@ -116,4 +116,4 @@ jobs:
     - name: Test
       shell: bash
       run: |
-        ctest -j$(nproc) --preset integration
+        YDB_VERSION=${{ matrix.ydb-version }} ctest -j$(nproc) --preset integration

src/client/persqueue_public/CMakeLists.txt

@@ -1,35 +1,12 @@
 add_subdirectory(codecs)
 add_subdirectory(impl)
+add_subdirectory(include)
 
 _ydb_sdk_add_library(cpp-client-ydb_persqueue_public INTERFACE)
 
 target_link_libraries(cpp-client-ydb_persqueue_public INTERFACE
   yutil
-  cpp-client-ydb_persqueue_core
+  client-ydb_persqueue_public-include
   client-ydb_persqueue_public-impl
   client-ydb_persqueue_public-codecs
 )
-
-generate_enum_serilization(cpp-client-ydb_persqueue_public
-  ${YDB_SDK_SOURCE_DIR}/src/client/persqueue_public/include/control_plane.h
-  INCLUDE_HEADERS
-  src/client/persqueue_public/include/control_plane.h
-)
-
-generate_enum_serilization(cpp-client-ydb_persqueue_public
-  ${YDB_SDK_SOURCE_DIR}/src/client/persqueue_public/include/read_events.h
-  INCLUDE_HEADERS
-  src/client/persqueue_public/include/read_events.h
-)
-
-generate_enum_serilization(cpp-client-ydb_persqueue_public
-  ${YDB_SDK_SOURCE_DIR}/src/client/persqueue_public/include/write_events.h
-  INCLUDE_HEADERS
-  src/client/persqueue_public/include/write_events.h
-)
-
-generate_enum_serilization(cpp-client-ydb_persqueue_public
-  ${YDB_SDK_SOURCE_DIR}/src/client/persqueue_public/include/write_session.h
-  INCLUDE_HEADERS
-  src/client/persqueue_public/include/write_session.h
-)

src/client/persqueue_public/impl/CMakeLists.txt

@@ -12,6 +12,7 @@ target_link_libraries(client-ydb_persqueue_public-impl PUBLIC
   impl-ydb_internal-make_request
   client-ydb_common_client-impl
   client-ydb_driver
+  client-ydb_persqueue_public-include
   string_utils-misc
 )
 

src/client/persqueue_public/impl/persqueue.cpp

@@ -48,7 +48,7 @@ TCredentials::TCredentials(const Ydb::PersQueue::V1::Credentials& settings)
             break;
         }
         default: {
-            ythrow yexception() << "unsupported credentials type " << ::NPersQueue::ObfuscateString(ToString(Credentials_));
+            ythrow yexception() << "unsupported credentials type " << ::NPersQueue::ObfuscateString(Credentials_.ShortDebugString());
         }
     }
 }

src/client/persqueue_public/include/CMakeLists.txt

@@ -0,0 +1,32 @@
+_ydb_sdk_add_library(client-ydb_persqueue_public-include)
+
+target_link_libraries(client-ydb_persqueue_public-include PUBLIC
+  yutil
+  api-grpc
+  api-grpc-draft
+  api-protos
+)
+
+generate_enum_serilization(client-ydb_persqueue_public-include
+  ${YDB_SDK_SOURCE_DIR}/src/client/persqueue_public/include/control_plane.h
+  INCLUDE_HEADERS
+  src/client/persqueue_public/include/control_plane.h
+)
+
+generate_enum_serilization(client-ydb_persqueue_public-include
+  ${YDB_SDK_SOURCE_DIR}/src/client/persqueue_public/include/read_events.h
+  INCLUDE_HEADERS
+  src/client/persqueue_public/include/read_events.h
+)
+
+generate_enum_serilization(client-ydb_persqueue_public-include
+  ${YDB_SDK_SOURCE_DIR}/src/client/persqueue_public/include/write_events.h
+  INCLUDE_HEADERS
+  src/client/persqueue_public/include/write_events.h
+)
+
+generate_enum_serilization(client-ydb_persqueue_public-include
+  ${YDB_SDK_SOURCE_DIR}/src/client/persqueue_public/include/write_session.h
+  INCLUDE_HEADERS
+  src/client/persqueue_public/include/write_session.h
+)

src/client/topic/impl/read_session_impl.ipp

@@ -994,7 +994,7 @@ inline void TSingleClusterReadSessionImpl<true>::OnReadDoneImpl(
             BreakConnectionAndReconnectImpl(EStatus::INTERNAL_ERROR,
                                             TStringBuilder()
                                                 << "Got unexpected partition stream data message. Topic: "
-                                                << partitionData.topic() << ". Partition: " << partitionData.partition()
+                                                << partitionData.topic().ShortDebugString() << ". Partition: " << partitionData.partition()
                                                 << " AssignId: " << partitionData.cookie().assign_id(),
                                             deferred);
             return;
@@ -1031,9 +1031,9 @@ inline void TSingleClusterReadSessionImpl<true>::OnReadDoneImpl(
         if (firstOffset == std::numeric_limits<ui64>::max()) {
             BreakConnectionAndReconnectImpl(EStatus::INTERNAL_ERROR,
                                             TStringBuilder() << "Got empty data message. Topic: "
-                                                << partitionData.topic()
+                                                << partitionData.topic().ShortDebugString()
                                                 << ". Partition: " << partitionData.partition()
-                                                << " message: " << msg,
+                                                << " message: " << msg.ShortDebugString(),
                                             deferred);
             return;
         }
@@ -1042,7 +1042,7 @@ inline void TSingleClusterReadSessionImpl<true>::OnReadDoneImpl(
         if (!CookieMapping.AddMapping(cookie)) {
             BreakConnectionAndReconnectImpl(EStatus::INTERNAL_ERROR,
                                             TStringBuilder() << "Got unexpected data message. Topic: "
-                                                << partitionData.topic()
+                                                << partitionData.topic().ShortDebugString()
                                                 << ". Partition: " << partitionData.partition()
                                                 << ". Cookie mapping already has such cookie",
                                             deferred);
@@ -1150,7 +1150,7 @@ inline void TSingleClusterReadSessionImpl<true>::OnReadDoneImpl(
     TDeferredActions<true>& deferred) {
     Y_ABORT_UNLESS(Lock.IsLocked());
 
-    LOG_LAZY(Log, TLOG_DEBUG, GetLogPrefix() << "Committed response: " << msg);
+    LOG_LAZY(Log, TLOG_DEBUG, GetLogPrefix() << "Committed response: " << msg.ShortDebugString());
 
     std::map<ui64, TIntrusivePtr<TPartitionStreamImpl<true>>> partitionStreams;
     for (const Ydb::PersQueue::V1::CommitCookie& cookieProto : msg.cookies()) {

tests/integration/CMakeLists.txt

@@ -3,3 +3,4 @@ add_subdirectory(bulk_upsert)
 add_subdirectory(server_restart)
 add_subdirectory(sessions)
 add_subdirectory(sessions_pool)
+add_subdirectory(topic)

tests/integration/topic/CMakeLists.txt

@@ -0,0 +1,11 @@
+add_ydb_test(NAME topic_it GTEST
+  SOURCES
+    basic_usage.cpp
+  LINK_LIBRARIES
+    yutil
+    YDB-CPP-SDK::Topic
+    cpp-client-ydb_persqueue_public
+    api-grpc
+  LABELS
+    integration
+)