Add OAuth support ydb-platform#2311 (ydb-platform#2312)

Author: CyberROFL

ydb/core/protos/replication.proto

@@ -28,6 +28,7 @@ message TReplicationConfig {
     // credentials
     oneof Credentials {
         TStaticCredentials StaticCredentials = 3;
+        string OAuthToken = 7;
     }
 
     // targets to be replicated

ydb/core/tx/replication/controller/replication.cpp

@@ -92,6 +92,9 @@ class TReplication::TImpl {
             case NKikimrReplication::TReplicationConfig::kStaticCredentials:
                 ydbProxy.Reset(CreateYdbProxy(Config.GetSrcEndpoint(), Config.GetSrcDatabase(), Config.GetStaticCredentials()));
                 break;
+            case NKikimrReplication::TReplicationConfig::kOAuthToken:
+                ydbProxy.Reset(CreateYdbProxy(Config.GetSrcEndpoint(), Config.GetSrcDatabase(), Config.GetOAuthToken()));
+                break;
             default:
                 ErrorState(TStringBuilder() << "Unexpected credentials: " << Config.GetCredentialsCase());
                 break;

ydb/core/tx/replication/ut_helpers/test_env.h

@@ -60,6 +60,14 @@ class TEnv {
         }
     }
 
+    explicit TEnv(const TString& builtin)
+        : TEnv(false)
+    {
+        UNIT_ASSERT_STRING_CONTAINS(builtin, "@builtin");
+        Init(builtin);
+        Client.ModifyOwner("/", DomainName, builtin);
+    }
+
     explicit TEnv(const TString& user, const TString& password)
         : TEnv(false)
     {

ydb/core/tx/replication/ydb_proxy/ydb_proxy_ut.cpp

@@ -155,6 +155,17 @@ Y_UNIT_TEST_SUITE(YdbProxy) {
         }
     }
 
+    Y_UNIT_TEST(OAuthToken) {
+        TEnv<true> env("user@builtin");
+        // make dir
+        {
+            auto ev = env.Send<TEvYdbProxy::TEvMakeDirectoryResponse>(
+                new TEvYdbProxy::TEvMakeDirectoryRequest("/Root/dir", {}));
+            UNIT_ASSERT(ev);
+            UNIT_ASSERT(ev->Get()->Result.IsSuccess());
+        }
+    }
+
     Y_UNIT_TEST(CreateTable) {
         TEnv<false> env;
         // invalid key