diff --git a/source/libs/tcs/test/CMakeLists.txt b/source/libs/tcs/test/CMakeLists.txt index 33fe75c589..f0a5fb97a6 100644 --- a/source/libs/tcs/test/CMakeLists.txt +++ b/source/libs/tcs/test/CMakeLists.txt @@ -9,7 +9,7 @@ target_include_directories(tcsTest target_link_libraries(tcsTest tcs - gtest_main + common gtest_main ) enable_testing() add_test( diff --git a/source/libs/tcs/test/tcsTest.cpp b/source/libs/tcs/test/tcsTest.cpp index ed2cb59858..e86c9e02b3 100644 --- a/source/libs/tcs/test/tcsTest.cpp +++ b/source/libs/tcs/test/tcsTest.cpp @@ -6,9 +6,11 @@ #include "tcs.h" #include "tcsInt.h" -int32_t tcsInitEnv() { +int32_t tcsInitEnv(int8_t isBlob) { int32_t code = 0; + extern int8_t tsS3EpNum; + extern char tsS3Hostname[][TSDB_FQDN_LEN]; extern char tsS3AccessKeyId[][TSDB_FQDN_LEN]; extern char tsS3AccessKeySecret[][TSDB_FQDN_LEN]; @@ -21,20 +23,38 @@ int32_t tcsInitEnv() { tsS3BucketName = ""; */ - const char *hostname = "endpoint/.blob.core.windows.net"; - const char *accessKeyId = ""; - const char *accessKeySecret = ""; - const char *bucketName = ""; + tsS3Ablob = isBlob; + if (isBlob) { + const char *hostname = "endpoint/.blob.core.windows.net"; + const char *accessKeyId = ""; + const char *accessKeySecret = ""; + const char *bucketName = ""; - tstrncpy(&tsS3Hostname[0][0], hostname, TSDB_FQDN_LEN); - tstrncpy(&tsS3AccessKeyId[0][0], accessKeyId, TSDB_FQDN_LEN); - tstrncpy(&tsS3AccessKeySecret[0][0], accessKeySecret, TSDB_FQDN_LEN); - tstrncpy(tsS3BucketName, bucketName, TSDB_FQDN_LEN); + tstrncpy(&tsS3Hostname[0][0], hostname, TSDB_FQDN_LEN); + tstrncpy(&tsS3AccessKeyId[0][0], accessKeyId, TSDB_FQDN_LEN); + tstrncpy(&tsS3AccessKeySecret[0][0], accessKeySecret, TSDB_FQDN_LEN); + tstrncpy(tsS3BucketName, bucketName, TSDB_FQDN_LEN); + + } else { + const char *hostname = "endpoint/.blob.core.windows.net"; + const char *accessKeyId = ""; + const char *accessKeySecret = ""; + const char *bucketName = ""; + + tstrncpy(&tsS3Hostname[0][0], hostname, TSDB_FQDN_LEN); + tstrncpy(&tsS3AccessKeyId[0][0], accessKeyId, TSDB_FQDN_LEN); + tstrncpy(&tsS3AccessKeySecret[0][0], accessKeySecret, TSDB_FQDN_LEN); + tstrncpy(tsS3BucketName, bucketName, TSDB_FQDN_LEN); + + // setup s3 env + tsS3EpNum = 1; + } tstrncpy(tsTempDir, "/tmp/", PATH_MAX); tsS3Enabled = true; - tsS3Ablob = true; + if (!tsS3Ablob) { + } return code; } @@ -43,7 +63,7 @@ int32_t tcsInitEnv() { TEST(TcsTest, InterfaceTest) { int code = 0; - code = tcsInitEnv(); + code = tcsInitEnv(true); GTEST_ASSERT_EQ(code, 0); GTEST_ASSERT_EQ(tsS3Enabled, 1); GTEST_ASSERT_EQ(tsS3Ablob, 1); @@ -77,6 +97,44 @@ TEST(TcsTest, InterfaceTest) { tcsUninit(); } +// TEST(TcsTest, DISABLE_InterfaceNonBlobTest) { +TEST(TcsTest, InterfaceNonBlobTest) { + int code = 0; + + code = tcsInitEnv(false); + GTEST_ASSERT_EQ(code, 0); + GTEST_ASSERT_EQ(tsS3Enabled, 1); + GTEST_ASSERT_EQ(tsS3Ablob, 0); + + code = tcsInit(); + GTEST_ASSERT_EQ(code, 0); + + code = tcsCheckCfg(); + GTEST_ASSERT_EQ(code, 0); + /* + code = tcsPutObjectFromFileOffset(file, object_name, offset, size); + GTEST_ASSERT_EQ(code, 0); + code = tcsGetObjectBlock(object_name, offset, size, check, ppBlock); + GTEST_ASSERT_EQ(code, 0); + + tcsDeleteObjectsByPrefix(prefix); + // list object to check + + code = tcsPutObjectFromFile2(file, object, withcp); + GTEST_ASSERT_EQ(code, 0); + code = tcsGetObjectsByPrefix(prefix, path); + GTEST_ASSERT_EQ(code, 0); + code = tcsDeleteObjects(object_name, nobject); + GTEST_ASSERT_EQ(code, 0); + code = tcsGetObjectToFile(object_name, fileName); + GTEST_ASSERT_EQ(code, 0); + + // GTEST_ASSERT_NE(pEnv, nullptr); + */ + + tcsUninit(); +} + /* #include "walInt.h" const char* ranStr = "tvapq02tcp";