All checks were successful
BlockStorage/repertory/pipeline/head This commit looks good
Reviewed-on: #18
467 lines
13 KiB
C++
467 lines
13 KiB
C++
/*
|
|
Copyright <2018-2024> <scott.e.graves@protonmail.com>
|
|
|
|
Permission is hereby granted, free of charge, to any person obtaining a copy
|
|
of this software and associated documentation files (the "Software"), to deal
|
|
in the Software without restriction, including without limitation the rights
|
|
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
|
copies of the Software, and to permit persons to whom the Software is
|
|
furnished to do so, subject to the following conditions:
|
|
|
|
The above copyright notice and this permission notice shall be included in all
|
|
copies or substantial portions of the Software.
|
|
|
|
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
|
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
|
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
|
|
SOFTWARE.
|
|
*/
|
|
#include "utils/file.hpp"
|
|
|
|
#include "utils/common.hpp"
|
|
#include "utils/error.hpp"
|
|
#include "utils/unix.hpp"
|
|
#include "utils/windows.hpp"
|
|
|
|
namespace {
|
|
auto traverse_directory(
|
|
std::string_view path,
|
|
std::function<bool(repertory::utils::file::directory)> directory_action,
|
|
std::function<bool(repertory::utils::file::file)> file_action) -> bool {
|
|
auto res{true};
|
|
|
|
#if defined(_WIN32)
|
|
WIN32_FIND_DATAA fd{};
|
|
auto search = repertory::utils::path::combine(path, {"*.*"});
|
|
auto find = ::FindFirstFileA(search.c_str(), &fd);
|
|
if (find == INVALID_HANDLE_VALUE) {
|
|
throw std::runtime_error(
|
|
"failed to open directory|" + std::string{path} + '|' +
|
|
std::to_string(repertory::utils::get_last_error_code()));
|
|
}
|
|
|
|
do {
|
|
if (fd.dwFileAttributes & FILE_ATTRIBUTE_DIRECTORY) {
|
|
if ((std::string_view(fd.cFileName) != ".") &&
|
|
(std::string_view(fd.cFileName) != "..")) {
|
|
res = directory_action(repertory::utils::file::directory{
|
|
repertory::utils::path::combine(path, {fd.cFileName})});
|
|
}
|
|
} else {
|
|
res = file_action(repertory::utils::file::file(
|
|
repertory::utils::path::combine(path, {fd.cFileName})));
|
|
}
|
|
} while (res && (::FindNextFileA(find, &fd) != 0));
|
|
|
|
::FindClose(find);
|
|
#else // !defined(_WIN32)
|
|
auto *root = opendir(std::string{path}.c_str());
|
|
if (root == nullptr) {
|
|
throw std::runtime_error(
|
|
"failed to open directory|" + std::string{path} + '|' +
|
|
std::to_string(repertory::utils::get_last_error_code()));
|
|
}
|
|
|
|
struct dirent *de{nullptr};
|
|
while (res && (de = readdir(root))) {
|
|
if (de->d_type == DT_DIR) {
|
|
if ((std::string_view(de->d_name) != ".") &&
|
|
(std::string_view(de->d_name) != "..")) {
|
|
res = directory_action(repertory::utils::file::directory(
|
|
repertory::utils::path::combine(path, {de->d_name})));
|
|
}
|
|
} else {
|
|
res = file_action(repertory::utils::file::file(
|
|
repertory::utils::path::combine(path, {de->d_name})));
|
|
}
|
|
}
|
|
|
|
closedir(root);
|
|
#endif // defined(_WIN32)
|
|
|
|
return res;
|
|
}
|
|
} // namespace
|
|
|
|
namespace repertory::utils::file {
|
|
auto directory::copy_to(std::string_view new_path,
|
|
bool overwrite) const -> bool {
|
|
static constexpr const std::string_view function_name{
|
|
static_cast<const char *>(__FUNCTION__),
|
|
};
|
|
|
|
try {
|
|
throw std::runtime_error("failed to copy directory|" + path_ + '|' +
|
|
std::string{new_path} + '+' +
|
|
std::to_string(overwrite) + "|not implemented");
|
|
} catch (const std::exception &e) {
|
|
utils::error::handle_exception(function_name, e);
|
|
} catch (...) {
|
|
utils::error::handle_exception(function_name);
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
auto directory::count(bool recursive) const -> std::uint64_t {
|
|
static constexpr const std::string_view function_name{
|
|
static_cast<const char *>(__FUNCTION__),
|
|
};
|
|
|
|
try {
|
|
std::uint64_t ret{0U};
|
|
|
|
traverse_directory(
|
|
path_,
|
|
[&ret, &recursive](auto dir_item) -> bool {
|
|
if (recursive) {
|
|
ret += dir_item.count(true);
|
|
}
|
|
|
|
++ret;
|
|
return true;
|
|
},
|
|
[&ret](auto /* file_item */) -> bool {
|
|
++ret;
|
|
return true;
|
|
});
|
|
|
|
return ret;
|
|
} catch (const std::exception &e) {
|
|
utils::error::handle_exception(function_name, e);
|
|
} catch (...) {
|
|
utils::error::handle_exception(function_name);
|
|
}
|
|
|
|
return 0U;
|
|
}
|
|
|
|
auto directory::create_directory(std::string_view path) const
|
|
-> fs_directory_t {
|
|
static constexpr const std::string_view function_name{
|
|
static_cast<const char *>(__FUNCTION__),
|
|
};
|
|
|
|
try {
|
|
auto abs_path = utils::path::combine(path_, {path});
|
|
if (directory{abs_path}.exists()) {
|
|
return std::make_unique<directory>(abs_path);
|
|
}
|
|
|
|
#if defined(_WIN32)
|
|
auto res = ::SHCreateDirectory(nullptr,
|
|
utils::string::from_utf8(abs_path).c_str());
|
|
if (res != ERROR_SUCCESS) {
|
|
throw std::runtime_error("failed to create directory|" +
|
|
std::string{abs_path} + '|' +
|
|
std::to_string(res));
|
|
}
|
|
#else // !defined(_WIN32)
|
|
auto ret{true};
|
|
auto paths =
|
|
utils::string::split(abs_path, utils::path::directory_seperator, false);
|
|
|
|
std::string current_path;
|
|
for (std::size_t idx = 0U; ret && (idx < paths.size()); ++idx) {
|
|
if (paths.at(idx).empty()) {
|
|
current_path = utils::path::directory_seperator;
|
|
continue;
|
|
}
|
|
|
|
current_path = utils::path::combine(current_path, {paths.at(idx)});
|
|
auto status = mkdir(current_path.c_str(), S_IRWXU);
|
|
ret = ((status == 0) || (errno == EEXIST));
|
|
}
|
|
#endif
|
|
|
|
return std::make_unique<directory>(abs_path);
|
|
} catch (const std::exception &e) {
|
|
utils::error::handle_exception(function_name, e);
|
|
} catch (...) {
|
|
utils::error::handle_exception(function_name);
|
|
}
|
|
|
|
return nullptr;
|
|
}
|
|
|
|
auto directory::exists() const -> bool {
|
|
#if defined(_WIN32)
|
|
return ::PathIsDirectoryA(path_.c_str()) != 0;
|
|
#else // !defined(_WIN32)
|
|
struct stat64 st {};
|
|
return (stat64(path_.c_str(), &st) == 0 && S_ISDIR(st.st_mode));
|
|
#endif // defined(_WIN32)
|
|
|
|
return false;
|
|
}
|
|
|
|
auto directory::get_directory(std::string_view path) const -> fs_directory_t {
|
|
static constexpr const std::string_view function_name{
|
|
static_cast<const char *>(__FUNCTION__),
|
|
};
|
|
|
|
try {
|
|
auto dir_path = utils::path::combine(path_, {path});
|
|
return fs_directory_t{
|
|
directory{dir_path}.exists() ? new directory{dir_path} : nullptr,
|
|
};
|
|
} catch (const std::exception &e) {
|
|
utils::error::handle_exception(function_name, e);
|
|
} catch (...) {
|
|
utils::error::handle_exception(function_name);
|
|
}
|
|
|
|
return nullptr;
|
|
}
|
|
|
|
auto directory::get_directories() const -> std::vector<fs_directory_t> {
|
|
static constexpr const std::string_view function_name{
|
|
static_cast<const char *>(__FUNCTION__),
|
|
};
|
|
|
|
try {
|
|
std::vector<fs_directory_t> ret{};
|
|
|
|
traverse_directory(
|
|
path_,
|
|
[&ret](auto dir_item) -> bool {
|
|
ret.emplace_back(fs_directory_t{
|
|
new directory(dir_item.get_path()),
|
|
});
|
|
|
|
return true;
|
|
},
|
|
[](auto /* file_item */) -> bool { return true; });
|
|
|
|
return ret;
|
|
} catch (const std::exception &e) {
|
|
utils::error::handle_exception(function_name, e);
|
|
} catch (...) {
|
|
utils::error::handle_exception(function_name);
|
|
}
|
|
|
|
return {};
|
|
}
|
|
|
|
auto directory::create_file(std::string_view file_name,
|
|
bool read_only) const -> fs_file_t {
|
|
static constexpr const std::string_view function_name{
|
|
static_cast<const char *>(__FUNCTION__),
|
|
};
|
|
|
|
try {
|
|
auto file_path = utils::path::combine(path_, {file_name});
|
|
return file::open_or_create_file(file_path, read_only);
|
|
} catch (const std::exception &e) {
|
|
utils::error::handle_exception(function_name, e);
|
|
} catch (...) {
|
|
utils::error::handle_exception(function_name);
|
|
}
|
|
|
|
return nullptr;
|
|
}
|
|
|
|
auto directory::get_file(std::string_view path) const -> fs_file_t {
|
|
static constexpr const std::string_view function_name{
|
|
static_cast<const char *>(__FUNCTION__),
|
|
};
|
|
|
|
try {
|
|
auto file_path = utils::path::combine(path_, {path});
|
|
return fs_file_t{
|
|
file{file_path}.exists() ? new file(file_path) : nullptr,
|
|
};
|
|
} catch (const std::exception &e) {
|
|
utils::error::handle_exception(function_name, e);
|
|
} catch (...) {
|
|
utils::error::handle_exception(function_name);
|
|
}
|
|
|
|
return nullptr;
|
|
}
|
|
|
|
auto directory::get_files() const -> std::vector<fs_file_t> {
|
|
static constexpr const std::string_view function_name{
|
|
static_cast<const char *>(__FUNCTION__),
|
|
};
|
|
|
|
try {
|
|
std::vector<fs_file_t> ret{};
|
|
|
|
traverse_directory(
|
|
path_, [](auto /* dir_item */) -> bool { return true; },
|
|
[&ret](auto file_item) -> bool {
|
|
ret.emplace_back(fs_file_t{
|
|
new file(file_item.get_path()),
|
|
});
|
|
return true;
|
|
});
|
|
|
|
return ret;
|
|
} catch (const std::exception &e) {
|
|
utils::error::handle_exception(function_name, e);
|
|
} catch (...) {
|
|
utils::error::handle_exception(function_name);
|
|
}
|
|
|
|
return {};
|
|
}
|
|
|
|
auto directory::get_items() const -> std::vector<fs_item_t> {
|
|
static constexpr const std::string_view function_name{
|
|
static_cast<const char *>(__FUNCTION__),
|
|
};
|
|
|
|
try {
|
|
std::vector<fs_item_t> ret{};
|
|
|
|
traverse_directory(
|
|
path_,
|
|
[&ret](auto dir_item) -> bool {
|
|
ret.emplace_back(fs_item_t{
|
|
new directory(dir_item.get_path()),
|
|
});
|
|
return true;
|
|
},
|
|
[&ret](auto file_item) -> bool {
|
|
ret.emplace_back(fs_item_t{
|
|
new file(file_item.get_path()),
|
|
});
|
|
return true;
|
|
});
|
|
|
|
return ret;
|
|
} catch (const std::exception &e) {
|
|
utils::error::handle_exception(function_name, e);
|
|
} catch (...) {
|
|
utils::error::handle_exception(function_name);
|
|
}
|
|
|
|
return {};
|
|
}
|
|
|
|
auto directory::is_symlink() const -> bool {
|
|
static constexpr const std::string_view function_name{
|
|
static_cast<const char *>(__FUNCTION__),
|
|
};
|
|
|
|
try {
|
|
return std::filesystem::is_symlink(path_);
|
|
} catch (const std::exception &e) {
|
|
utils::error::handle_exception(function_name, e);
|
|
} catch (...) {
|
|
utils::error::handle_exception(function_name);
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
auto directory::move_to(std::string_view new_path) -> bool {
|
|
static constexpr const std::string_view function_name{
|
|
static_cast<const char *>(__FUNCTION__),
|
|
};
|
|
|
|
try {
|
|
throw std::runtime_error("failed to move directory|" + path_ + '|' +
|
|
std::string{new_path} + "|not implemented");
|
|
} catch (const std::exception &e) {
|
|
utils::error::handle_exception(function_name, e);
|
|
} catch (...) {
|
|
utils::error::handle_exception(function_name);
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
auto directory::remove() -> bool {
|
|
static constexpr const std::string_view function_name{
|
|
static_cast<const char *>(__FUNCTION__),
|
|
};
|
|
|
|
if (not exists()) {
|
|
return true;
|
|
}
|
|
|
|
return utils::retry_action([this]() -> bool {
|
|
try {
|
|
#if defined(_WIN32)
|
|
return ::RemoveDirectoryA(path_.c_str());
|
|
#else // !defined(_WIN32)
|
|
return (rmdir(path_.c_str()) == 0);
|
|
#endif // defined(_WIN32)
|
|
} catch (const std::exception &e) {
|
|
utils::error::handle_exception(function_name, e);
|
|
} catch (...) {
|
|
utils::error::handle_exception(function_name);
|
|
}
|
|
|
|
return false;
|
|
});
|
|
}
|
|
|
|
auto directory::remove_recursively() -> bool {
|
|
static constexpr const std::string_view function_name{
|
|
static_cast<const char *>(__FUNCTION__),
|
|
};
|
|
|
|
try {
|
|
if (not exists()) {
|
|
return true;
|
|
}
|
|
|
|
if (not traverse_directory(
|
|
path_,
|
|
[](auto dir_item) -> bool { return dir_item.remove_recursively(); },
|
|
[](auto file_item) -> bool { return file_item.remove(); })) {
|
|
return false;
|
|
}
|
|
|
|
return remove();
|
|
} catch (const std::exception &e) {
|
|
utils::error::handle_exception(function_name, e);
|
|
} catch (...) {
|
|
utils::error::handle_exception(function_name);
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
auto directory::size(bool recursive) const -> std::uint64_t {
|
|
static constexpr const std::string_view function_name{
|
|
static_cast<const char *>(__FUNCTION__),
|
|
};
|
|
|
|
try {
|
|
std::uint64_t ret{0U};
|
|
|
|
traverse_directory(
|
|
path_,
|
|
[&ret, &recursive](auto dir_item) -> bool {
|
|
if (recursive) {
|
|
ret += dir_item.size(true);
|
|
}
|
|
|
|
return true;
|
|
},
|
|
[&ret](auto file_item) -> bool {
|
|
auto cur_size = file_item.size();
|
|
if (cur_size.has_value()) {
|
|
ret += cur_size.value();
|
|
}
|
|
return true;
|
|
});
|
|
|
|
return ret;
|
|
} catch (const std::exception &e) {
|
|
utils::error::handle_exception(function_name, e);
|
|
} catch (...) {
|
|
utils::error::handle_exception(function_name);
|
|
}
|
|
|
|
return 0U;
|
|
}
|
|
} // namespace repertory::utils::file
|