Browse Source

YT-22751: Rename GetClientOpsFromEnv->GetClientOptionsFromEnv, move related tests to yt/yt/client/api/unittests

\[nodiff:caesar\]
878aead651e24a729a7613f0a0b3a33cde78814f
ignat 6 months ago
parent
commit
7797fb8f12

+ 3 - 3
yt/yt/client/api/options.cpp

@@ -12,7 +12,7 @@ namespace NYT::NApi {
 
 ////////////////////////////////////////////////////////////////////////////////
 
-NApi::TClientOptions GetClientOpsFromEnv()
+NApi::TClientOptions GetClientOptionsFromEnv()
 {
     NApi::TClientOptions options;
 
@@ -37,9 +37,9 @@ NApi::TClientOptions GetClientOpsFromEnv()
     return options;
 }
 
-const NApi::TClientOptions& GetClientOpsFromEnvStatic()
+const NApi::TClientOptions& GetClientOptionsFromEnvStatic()
 {
-    static const NApi::TClientOptions options = GetClientOpsFromEnv();
+    static const NApi::TClientOptions options = GetClientOptionsFromEnv();
     return options;
 }
 

+ 2 - 2
yt/yt/client/api/options.h

@@ -13,10 +13,10 @@ namespace NYT::NApi {
  *  UserName is extracted from YT_USER env variable or uses current system username.
  *  Token is extracted from YT_TOKEN env variable or from file `~/.yt/token`.
  */
-TClientOptions GetClientOpsFromEnv();
+TClientOptions GetClientOptionsFromEnv();
 
 //! Resolves options only once per launch and then returns the cached result.
-const TClientOptions& GetClientOpsFromEnvStatic();
+const TClientOptions& GetClientOptionsFromEnvStatic();
 
 ////////////////////////////////////////////////////////////////////////////////
 

+ 6 - 6
yt/yt/client/cache/unittests/options_ut.cpp → yt/yt/client/api/unittests/options_ut.cpp

@@ -10,7 +10,7 @@
 
 #include <util/system/env.h>
 
-namespace NYT::NClient::NCache {
+namespace NYT::NApi {
 
 ////////////////////////////////////////////////////////////////////////////////
 
@@ -29,7 +29,7 @@ TEST(TClientOptionsTest, TokenFromFile)
         {"YT_TOKEN", ""},
         {"YT_TOKEN_PATH", ""},
     }};
-    const auto clientOptions = NApi::GetClientOpsFromEnv();
+    const auto clientOptions = GetClientOptionsFromEnv();
     EXPECT_TRUE(clientOptions.Token);
     EXPECT_EQ("AAAA-AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA", *clientOptions.Token);
 }
@@ -46,7 +46,7 @@ TEST(TClientOptionsTest, TokenFromYtTokenPath)
         {"YT_TOKEN", ""},
         {"YT_TOKEN_PATH", tokenPath},
     }};
-    const auto clientOptions = NApi::GetClientOpsFromEnv();
+    const auto clientOptions = GetClientOptionsFromEnv();
     EXPECT_TRUE(clientOptions.Token);
     EXPECT_EQ("BBBB-AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA", *clientOptions.Token);
 }
@@ -54,7 +54,7 @@ TEST(TClientOptionsTest, TokenFromYtTokenPath)
 TEST(TClientOptionsTest, TokenFromEnv)
 {
     NTesting::TScopedEnvironment tokenGuard("YT_TOKEN", "BBBB-BBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBB");
-    const auto& clientOptions = NApi::GetClientOpsFromEnv();
+    const auto& clientOptions = GetClientOptionsFromEnv();
     EXPECT_TRUE(clientOptions.Token);
     EXPECT_EQ("BBBB-BBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBB", *clientOptions.Token);
 }
@@ -65,7 +65,7 @@ TEST(TClientOptionsTest, UserFromEnv)
         {"YT_TOKEN", "BBBB-BBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBB"},
         {"YT_USER", "yt_test_user"},
     }};
-    const auto& clientOptions = NApi::GetClientOpsFromEnv();
+    const auto& clientOptions = GetClientOptionsFromEnv();
     EXPECT_TRUE(clientOptions.User);
     EXPECT_EQ("yt_test_user", *clientOptions.User);
 }
@@ -76,7 +76,7 @@ TEST(TClientOptionsTest, AllowEmptyUser)
         {"YT_TOKEN", "BBBB-BBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBB"},
         {"YT_USER", ""},
     }};
-    const auto& clientOptions = NApi::GetClientOpsFromEnv();
+    const auto& clientOptions = GetClientOptionsFromEnv();
     EXPECT_TRUE(!clientOptions.User);
 }
 

+ 16 - 0
yt/yt/client/api/unittests/ya.make

@@ -0,0 +1,16 @@
+GTEST()
+
+INCLUDE(${ARCADIA_ROOT}/yt/ya_cpp.make.inc)
+
+SRCS(
+    options_ut.cpp
+)
+
+INCLUDE(${ARCADIA_ROOT}/yt/opensource.inc)
+
+PEERDIR(
+    library/cpp/testing/common
+    yt/yt/client
+)
+
+END()

+ 2 - 2
yt/yt/client/cache/cache.cpp

@@ -116,7 +116,7 @@ IClientsCachePtr CreateClientsCache(
 
 IClientsCachePtr CreateClientsCache(const TConnectionConfigPtr& config)
 {
-    return CreateClientsCache(config, NApi::GetClientOpsFromEnvStatic());
+    return CreateClientsCache(config, NApi::GetClientOptionsFromEnvStatic());
 }
 
 IClientsCachePtr CreateClientsCache(const NApi::TClientOptions& options)
@@ -128,7 +128,7 @@ IClientsCachePtr CreateClientsCache(const NApi::TClientOptions& options)
 
 IClientsCachePtr CreateClientsCache()
 {
-    return CreateClientsCache(NApi::GetClientOpsFromEnvStatic());
+    return CreateClientsCache(NApi::GetClientOptionsFromEnvStatic());
 }
 
 ////////////////////////////////////////////////////////////////////////////////

+ 2 - 2
yt/yt/client/cache/rpc.cpp

@@ -60,12 +60,12 @@ NApi::IClientPtr CreateClient(const NApi::NRpcProxy::TConnectionConfigPtr& confi
 
 NApi::IClientPtr CreateClient(const NApi::NRpcProxy::TConnectionConfigPtr& config)
 {
-    return CreateClient(config, NApi::GetClientOpsFromEnvStatic());
+    return CreateClient(config, NApi::GetClientOptionsFromEnvStatic());
 }
 
 NApi::IClientPtr CreateClient(TStringBuf clusterUrl)
 {
-    return CreateClient(clusterUrl, NApi::GetClientOpsFromEnvStatic());
+    return CreateClient(clusterUrl, NApi::GetClientOptionsFromEnvStatic());
 }
 
 NApi::IClientPtr CreateClient(TStringBuf cluster, TStringBuf proxyRole)

+ 0 - 1
yt/yt/client/cache/unittests/ya.make

@@ -4,7 +4,6 @@ INCLUDE(${ARCADIA_ROOT}/yt/ya_cpp.make.inc)
 
 SRCS(
     cache_ut.cpp
-    options_ut.cpp
 )
 
 INCLUDE(${ARCADIA_ROOT}/yt/opensource.inc)

+ 5 - 5
yt/yt/client/federated/unittests/cache_ut.cpp

@@ -22,7 +22,7 @@ TEST(TFederatedClientsCacheTest, GetSameClient)
     auto ytClientsCache = CreateFederatedClientsCache(
         New<TConnectionConfig>(),
         New<TClientsCacheConfig>(),
-        NApi::GetClientOpsFromEnvStatic());
+        NApi::GetClientOptionsFromEnvStatic());
 
     auto client1 = ytClientsCache->GetClient("localhost");
     auto client2 = ytClientsCache->GetClient("localhost");
@@ -41,7 +41,7 @@ TEST(TFederatedClientsCacheTest, GetFederatedWithEmptyConfig)
     auto ytClientsCache = CreateFederatedClientsCache(
         New<TConnectionConfig>(),
         New<TClientsCacheConfig>(),
-        NApi::GetClientOpsFromEnvStatic());
+        NApi::GetClientOptionsFromEnvStatic());
 
     EXPECT_THROW(
         ytClientsCache->GetClient("primary+secondary"),
@@ -61,7 +61,7 @@ TEST(TFederatedClientsCacheTest, ConfigurationAndClusterUrlMismatch1)
     auto ytClientsCache = CreateFederatedClientsCache(
         connectionConfig,
         New<TClientsCacheConfig>(),
-        NApi::GetClientOpsFromEnvStatic());
+        NApi::GetClientOptionsFromEnvStatic());
 
     EXPECT_THROW(
         ytClientsCache->GetClient("primary+tertiary"),
@@ -83,7 +83,7 @@ TEST(TFederatedClientsCacheTest, ConfigurationAndClusterUrlMismatch2)
     auto ytClientsCache = CreateFederatedClientsCache(
         connectionConfig,
         New<TClientsCacheConfig>(),
-        NApi::GetClientOpsFromEnvStatic());
+        NApi::GetClientOptionsFromEnvStatic());
 
     EXPECT_THROW(
         ytClientsCache->GetClient("primary+tertiary"),
@@ -103,7 +103,7 @@ TEST(TFederatedClientsCacheTest, ConfigurationMissingCluster)
     auto ytClientsCache = CreateFederatedClientsCache(
         connectionConfig,
         New<TClientsCacheConfig>(),
-        NApi::GetClientOpsFromEnvStatic());
+        NApi::GetClientOptionsFromEnvStatic());
 
     EXPECT_THROW(
         ytClientsCache->GetClient("primary+secondary+tertiary"),

+ 1 - 0
yt/yt/client/ya.make

@@ -227,6 +227,7 @@ RECURSE(
 )
 
 RECURSE_FOR_TESTS(
+    api/unittests
     table_client/unittests
     unittests
 )