Compare commits
2 Commits
76e375c488
...
573ae549be
Author | SHA1 | Date | |
---|---|---|---|
573ae549be | |||
fca149f998 |
@ -9,6 +9,7 @@
|
|||||||
* ~~\#22 [Unit Test] Complete FUSE unit tests~~
|
* ~~\#22 [Unit Test] Complete FUSE unit tests~~
|
||||||
* ~~\#33 Complete initial v2.0 documentation~~
|
* ~~\#33 Complete initial v2.0 documentation~~
|
||||||
* \#42 [bug] Remote mount directory listing on Windows connected to Linux is failing
|
* \#42 [bug] Remote mount directory listing on Windows connected to Linux is failing
|
||||||
|
* ~~\#43 [bug] Directories are not importing properly for Sia~~
|
||||||
|
|
||||||
### Changes from v2.0.5-rc
|
### Changes from v2.0.5-rc
|
||||||
|
|
||||||
|
@ -213,7 +213,6 @@ public:
|
|||||||
}
|
}
|
||||||
|
|
||||||
auto url = construct_url(curl, request.get_path(), cfg) + parameters;
|
auto url = construct_url(curl, request.get_path(), cfg) + parameters;
|
||||||
fmt::println("url|{}", url);
|
|
||||||
curl_easy_setopt(curl, CURLOPT_URL, url.c_str());
|
curl_easy_setopt(curl, CURLOPT_URL, url.c_str());
|
||||||
|
|
||||||
multi_request curl_request(curl, stop_requested);
|
multi_request curl_request(curl, stop_requested);
|
||||||
|
@ -584,8 +584,6 @@ void base_provider::process_removed_items(stop_type &stop_requested) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (utils::string::to_bool(meta[META_DIRECTORY])) {
|
if (utils::string::to_bool(meta[META_DIRECTORY])) {
|
||||||
fmt::println("checking|{}|{}", api_path,
|
|
||||||
json(meta).dump());
|
|
||||||
bool exists{};
|
bool exists{};
|
||||||
if (is_directory(api_path, exists) !=
|
if (is_directory(api_path, exists) !=
|
||||||
api_error::success) {
|
api_error::success) {
|
||||||
@ -596,8 +594,6 @@ void base_provider::process_removed_items(stop_type &stop_requested) {
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
fmt::println("not found|{}|{}", api_path,
|
|
||||||
json(meta).dump());
|
|
||||||
process_removed_directories(
|
process_removed_directories(
|
||||||
{
|
{
|
||||||
removed_item{api_path, true, ""},
|
removed_item{api_path, true, ""},
|
||||||
|
@ -369,7 +369,6 @@ auto sia_provider::get_object_info(const std::string &api_path,
|
|||||||
get.path = "/api/bus/object" + api_path;
|
get.path = "/api/bus/object" + api_path;
|
||||||
get.query["bucket"] = get_bucket(get_sia_config());
|
get.query["bucket"] = get_bucket(get_sia_config());
|
||||||
get.query["onlymetadata"] = "true";
|
get.query["onlymetadata"] = "true";
|
||||||
fmt::println("bucket|{}|{}", get.query["bucket"], get.path);
|
|
||||||
|
|
||||||
std::string error_data;
|
std::string error_data;
|
||||||
get.response_handler = [&error_data, &object_info](auto &&data,
|
get.response_handler = [&error_data, &object_info](auto &&data,
|
||||||
@ -512,7 +511,6 @@ auto sia_provider::is_directory(const std::string &api_path, bool &exists) const
|
|||||||
exists = false;
|
exists = false;
|
||||||
|
|
||||||
json file_data{};
|
json file_data{};
|
||||||
fmt::println("{}", api_path + '/');
|
|
||||||
auto res{get_object_info(api_path + '/', file_data)};
|
auto res{get_object_info(api_path + '/', file_data)};
|
||||||
if (res == api_error::item_not_found) {
|
if (res == api_error::item_not_found) {
|
||||||
return api_error::success;
|
return api_error::success;
|
||||||
@ -638,7 +636,6 @@ auto sia_provider::read_file_bytes(const std::string &api_path,
|
|||||||
++idx) {
|
++idx) {
|
||||||
long response_code{};
|
long response_code{};
|
||||||
const auto notify_retry = [&]() {
|
const auto notify_retry = [&]() {
|
||||||
fmt::println("{}", std::string(buffer.begin(), buffer.end()));
|
|
||||||
if (response_code == 0) {
|
if (response_code == 0) {
|
||||||
utils::error::raise_api_path_error(
|
utils::error::raise_api_path_error(
|
||||||
function_name, api_path, api_error::comm_error,
|
function_name, api_path, api_error::comm_error,
|
||||||
|
@ -78,7 +78,7 @@ struct remote_sia final {
|
|||||||
struct remote_linux_to_winfsp final {
|
struct remote_linux_to_winfsp final {
|
||||||
static constexpr const provider_type type{provider_type::remote};
|
static constexpr const provider_type type{provider_type::remote};
|
||||||
static constexpr const provider_type type2{provider_type::unknown};
|
static constexpr const provider_type type2{provider_type::unknown};
|
||||||
static constexpr const std::uint16_t port{30001U};
|
static constexpr const std::uint16_t port{40001U};
|
||||||
};
|
};
|
||||||
|
|
||||||
template <typename provider_t> class fuse_test : public ::testing::Test {
|
template <typename provider_t> class fuse_test : public ::testing::Test {
|
||||||
@ -123,7 +123,7 @@ protected:
|
|||||||
|
|
||||||
auto r_cfg = config->get_remote_mount();
|
auto r_cfg = config->get_remote_mount();
|
||||||
r_cfg.enable = true;
|
r_cfg.enable = true;
|
||||||
r_cfg.api_port = 30000U;
|
r_cfg.api_port = 40000U;
|
||||||
config->set_remote_mount(r_cfg);
|
config->set_remote_mount(r_cfg);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -170,7 +170,7 @@ protected:
|
|||||||
|
|
||||||
auto r_cfg = config->get_remote_mount();
|
auto r_cfg = config->get_remote_mount();
|
||||||
r_cfg.enable = true;
|
r_cfg.enable = true;
|
||||||
r_cfg.api_port = 30000U;
|
r_cfg.api_port = 40000U;
|
||||||
config->set_remote_mount(r_cfg);
|
config->set_remote_mount(r_cfg);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -188,7 +188,7 @@ protected:
|
|||||||
execute_mount(drive_args, mount_location);
|
execute_mount(drive_args, mount_location);
|
||||||
};
|
};
|
||||||
|
|
||||||
const auto mount_remote = [&](std::uint16_t port = 30000U) {
|
const auto mount_remote = [&](std::uint16_t port = 40000U) {
|
||||||
{
|
{
|
||||||
mount_location2 = mount_location;
|
mount_location2 = mount_location;
|
||||||
|
|
||||||
|
@ -69,7 +69,7 @@ struct remote_sia final {
|
|||||||
struct remote_winfsp_to_linux final {
|
struct remote_winfsp_to_linux final {
|
||||||
static constexpr const provider_type type{provider_type::remote};
|
static constexpr const provider_type type{provider_type::remote};
|
||||||
static constexpr const provider_type type2{provider_type::unknown};
|
static constexpr const provider_type type2{provider_type::unknown};
|
||||||
static constexpr const std::uint16_t port{30001U};
|
static constexpr const std::uint16_t port{40001U};
|
||||||
};
|
};
|
||||||
|
|
||||||
template <typename provider_t> class winfsp_test : public ::testing::Test {
|
template <typename provider_t> class winfsp_test : public ::testing::Test {
|
||||||
@ -112,7 +112,7 @@ protected:
|
|||||||
|
|
||||||
auto r_cfg = config->get_remote_mount();
|
auto r_cfg = config->get_remote_mount();
|
||||||
r_cfg.enable = true;
|
r_cfg.enable = true;
|
||||||
r_cfg.api_port = 30000U;
|
r_cfg.api_port = 40000U;
|
||||||
config->set_remote_mount(r_cfg);
|
config->set_remote_mount(r_cfg);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -154,7 +154,7 @@ protected:
|
|||||||
|
|
||||||
auto r_cfg = config->get_remote_mount();
|
auto r_cfg = config->get_remote_mount();
|
||||||
r_cfg.enable = true;
|
r_cfg.enable = true;
|
||||||
r_cfg.api_port = 30000U;
|
r_cfg.api_port = 40000U;
|
||||||
config->set_remote_mount(r_cfg);
|
config->set_remote_mount(r_cfg);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -170,7 +170,7 @@ protected:
|
|||||||
execute_mount(drive_args, mount_location);
|
execute_mount(drive_args, mount_location);
|
||||||
};
|
};
|
||||||
|
|
||||||
const auto mount_remote = [&](std::uint16_t port = 30000U) {
|
const auto mount_remote = [&](std::uint16_t port = 40000U) {
|
||||||
{
|
{
|
||||||
auto test_directory = utils::path::combine(
|
auto test_directory = utils::path::combine(
|
||||||
test::get_test_output_dir(),
|
test::get_test_output_dir(),
|
||||||
@ -244,7 +244,9 @@ protected:
|
|||||||
static void TearDownTestCase() {
|
static void TearDownTestCase() {
|
||||||
if (provider_t::type == provider_type::remote) {
|
if (provider_t::type == provider_type::remote) {
|
||||||
execute_unmount(drive_args2, mount_location);
|
execute_unmount(drive_args2, mount_location);
|
||||||
|
if (provider_t::type2 != provider_type::unknown) {
|
||||||
execute_unmount(drive_args, mount_location2);
|
execute_unmount(drive_args, mount_location2);
|
||||||
|
}
|
||||||
} else {
|
} else {
|
||||||
execute_unmount(drive_args, mount_location);
|
execute_unmount(drive_args, mount_location);
|
||||||
}
|
}
|
||||||
@ -298,7 +300,8 @@ std::string winfsp_test<provider_t>::mount_location2;
|
|||||||
|
|
||||||
// using winfsp_provider_types = ::testing::Types<local_s3, remote_s3,
|
// using winfsp_provider_types = ::testing::Types<local_s3, remote_s3,
|
||||||
// local_sia, remote_sia>;
|
// local_sia, remote_sia>;
|
||||||
using winfsp_provider_types = ::testing::Types<local_s3, remote_s3>;
|
// using winfsp_provider_types = ::testing::Types<local_s3, remote_s3>;
|
||||||
|
using winfsp_provider_types = ::testing::Types<remote_winfsp_to_linux>;
|
||||||
} // namespace repertory
|
} // namespace repertory
|
||||||
|
|
||||||
#endif // defined(_WIN32)
|
#endif // defined(_WIN32)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user