Moved "fix arcadia linkage and recurse" commit from ydb repo

Author: ildar-khisambeev

src/client/persqueue_core/CMakeLists.txt

@@ -5,4 +5,5 @@ add_library(cpp-client-ydb_persqueue_core INTERFACE)
 
 target_link_libraries(cpp-client-ydb_persqueue_core INTERFACE
   cpp-client-ydb_persqueue_public
+  client-ydb_persqueue_core-impl
 )

src/client/persqueue_core/impl/CMakeLists.txt

@@ -1,5 +1,10 @@
-add_library(client-ydb_persqueue_core-impl INTERFACE)
+add_library(client-ydb_persqueue_core-impl)
 
-target_link_libraries(client-ydb_persqueue_core-impl INTERFACE
+target_link_libraries(client-ydb_persqueue_core-impl PUBLIC
+  yutil
   client-ydb_topic-impl
 )
+
+target_sources(client-ydb_persqueue_core-impl PRIVATE
+  common.cpp
+)

src/client/persqueue_core/impl/common.cpp

@@ -0,0 +1,58 @@
+#include "common.h"
+
+#include <src/util/charset/unidata.h>
+
+namespace NYdb::NPersQueue {
+
+ERetryErrorClass GetRetryErrorClass(EStatus status) {
+    switch (status) {
+    case EStatus::SUCCESS:          // NoRetry?
+    case EStatus::INTERNAL_ERROR:   // NoRetry?
+    case EStatus::ABORTED:
+    case EStatus::UNAVAILABLE:
+    case EStatus::GENERIC_ERROR:    // NoRetry?
+    case EStatus::BAD_SESSION:      // NoRetry?
+    case EStatus::SESSION_EXPIRED:
+    case EStatus::CANCELLED:
+    case EStatus::UNDETERMINED:
+    case EStatus::SESSION_BUSY:
+    case EStatus::CLIENT_INTERNAL_ERROR:
+    case EStatus::CLIENT_CANCELLED:
+    case EStatus::CLIENT_OUT_OF_RANGE:
+        return ERetryErrorClass::ShortRetry;
+
+    case EStatus::OVERLOADED:
+    case EStatus::TIMEOUT:
+    case EStatus::TRANSPORT_UNAVAILABLE:
+    case EStatus::CLIENT_RESOURCE_EXHAUSTED:
+    case EStatus::CLIENT_DEADLINE_EXCEEDED:
+    case EStatus::CLIENT_LIMITS_REACHED:
+    case EStatus::CLIENT_DISCOVERY_FAILED:
+        return ERetryErrorClass::LongRetry;
+
+    case EStatus::SCHEME_ERROR:
+    case EStatus::STATUS_UNDEFINED:
+    case EStatus::BAD_REQUEST:
+    case EStatus::UNAUTHORIZED:
+    case EStatus::PRECONDITION_FAILED:
+    case EStatus::UNSUPPORTED:
+    case EStatus::ALREADY_EXISTS:
+    case EStatus::NOT_FOUND:
+    case EStatus::EXTERNAL_ERROR:
+    case EStatus::CLIENT_UNAUTHENTICATED:
+    case EStatus::CLIENT_CALL_UNIMPLEMENTED:
+        return ERetryErrorClass::NoRetry;
+    }
+}
+
+ERetryErrorClass GetRetryErrorClassV2(EStatus status) {
+    switch (status) {
+        case EStatus::SCHEME_ERROR:
+            return ERetryErrorClass::NoRetry;
+        default:
+            return GetRetryErrorClass(status);
+
+    }
+}
+
+}  // namespace NYdb::NPersQueue

src/client/persqueue_core/impl/common.h

@@ -1,8 +1,10 @@
 #pragma once
 
-#include <src/client/topic/impl/common.h>
+#include <ydb-cpp-sdk/client/types/status_codes.h>
+
+#include <src/library/retry/retry.h>
 
 namespace NYdb::NPersQueue {
-    using NTopic::GetRetryErrorClass;
-    using NTopic::GetRetryErrorClassV2;
+    ERetryErrorClass GetRetryErrorClass(EStatus status);
+    ERetryErrorClass GetRetryErrorClassV2(EStatus status);
 }

src/client/persqueue_core/persqueue.h

@@ -1,3 +1,4 @@
 #pragma once
 
 #include <src/client/persqueue_public/persqueue.h>
+#include <src/client/persqueue_core/impl/common.h>