Compare commits
2 Commits
87f83b6f30
...
103dae6d08
Author | SHA1 | Date | |
---|---|---|---|
103dae6d08 | |||
821ed7b25e |
@ -362,6 +362,15 @@ auto s3_provider::get_directory_items(const std::string &api_path,
|
||||
directory_item_list &list) const
|
||||
-> api_error {
|
||||
try {
|
||||
bool exists{};
|
||||
auto res = is_directory(api_path, exists);
|
||||
if (res != api_error::success) {
|
||||
return res;
|
||||
}
|
||||
if (not exists) {
|
||||
return api_error::directory_not_found;
|
||||
}
|
||||
|
||||
const auto cfg = get_config().get_s3_config();
|
||||
const auto is_encrypted = not cfg.encryption_token.empty();
|
||||
std::string key;
|
||||
|
@ -40,8 +40,8 @@ TEST(encrypting_reader, get_encrypted_file_name) {
|
||||
EXPECT_TRUE(source_file != nullptr);
|
||||
if (source_file) {
|
||||
stop_type stop_requested = false;
|
||||
utils::encryption::encrypting_reader reader("test.dat", source_file_name,
|
||||
stop_requested, token);
|
||||
utils::encryption::encrypting_reader reader(
|
||||
"test.dat", source_file_name, stop_requested, token, std::nullopt);
|
||||
|
||||
auto file_name = reader.get_encrypted_file_name();
|
||||
std::cout << file_name << std::endl;
|
||||
|
7
tests/fixtures/winfsp_fixture.hpp
vendored
7
tests/fixtures/winfsp_fixture.hpp
vendored
@ -52,7 +52,7 @@ protected:
|
||||
"./winfsp_test" + std::to_string(PROVIDER_INDEX)));
|
||||
|
||||
app_config src_cfg(provider_type::s3,
|
||||
utils::path::combine(get_test_dir(), {"filebase"}));
|
||||
utils::path::combine(get_test_dir(), {"storj"}));
|
||||
config = std::make_unique<app_config>(
|
||||
provider_type::s3,
|
||||
"./winfsp_test" + std::to_string(PROVIDER_INDEX));
|
||||
@ -68,6 +68,11 @@ protected:
|
||||
->set_value_by_name("S3Config.Region",
|
||||
src_cfg.get_s3_config().region)
|
||||
.empty());
|
||||
EXPECT_FALSE(
|
||||
config
|
||||
->set_value_by_name("S3Config.EncryptionToken",
|
||||
src_cfg.get_s3_config().encryption_token)
|
||||
.empty());
|
||||
EXPECT_FALSE(
|
||||
config
|
||||
->set_value_by_name("S3Config.URL", src_cfg.get_s3_config().url)
|
||||
|
@ -523,9 +523,8 @@ TEST(fuse_drive, all_tests) {
|
||||
config_ptr =
|
||||
std::make_unique<app_config>(provider_type::s3, cfg_directory);
|
||||
{
|
||||
app_config src_cfg(
|
||||
provider_type::s3,
|
||||
utils::path::combine(get_test_dir(), {"filebase"}));
|
||||
app_config src_cfg(provider_type::s3,
|
||||
utils::path::combine(get_test_dir(), {"storj"}));
|
||||
config_ptr->set_enable_drive_events(true);
|
||||
config_ptr->set_event_level(event_level::verbose);
|
||||
config_ptr->set_s3_config(src_cfg.get_s3_config());
|
||||
|
@ -168,6 +168,10 @@ static void create_directory_clone_source_meta(i_provider &provider) {
|
||||
|
||||
EXPECT_EQ(meta_orig.size(), meta_clone.size());
|
||||
for (const auto &kv : meta_orig) {
|
||||
if (kv.first == META_KEY) {
|
||||
EXPECT_STRNE(kv.second.c_str(), meta_clone[kv.first].c_str());
|
||||
continue;
|
||||
}
|
||||
EXPECT_STREQ(kv.second.c_str(), meta_clone[kv.first].c_str());
|
||||
}
|
||||
|
||||
@ -290,6 +294,7 @@ static void get_api_path_from_source(const app_config &cfg,
|
||||
provider.get_api_path_from_source(fsi.source_path, api_path));
|
||||
|
||||
EXPECT_STREQ("/pt01.txt", api_path.c_str());
|
||||
EXPECT_EQ(api_error::success, provider.remove_file("/pt01.txt"));
|
||||
}
|
||||
|
||||
static void
|
||||
@ -579,7 +584,7 @@ TEST(providers, s3_provider) {
|
||||
app_config cfg(provider_type::s3, config_path);
|
||||
{
|
||||
app_config src_cfg(provider_type::s3,
|
||||
utils::path::combine(get_test_dir(), {"filebase"}));
|
||||
utils::path::combine(get_test_dir(), {"storj"}));
|
||||
cfg.set_s3_config(src_cfg.get_s3_config());
|
||||
}
|
||||
|
||||
|
Reference in New Issue
Block a user