添加本地存储
This commit is contained in:
shell committed
1 parent
95b68b9542
commit
e8b91b1a59
5 files changed
+255
No files matched your search
@@ -0,0 +1,128 @@
|
||||
#include "seafile/fs/seafile_store.hpp"
|
||||
|
||||
#include <sqlite_orm/sqlite_orm.h>
|
||||
#include <string>
|
||||
|
||||
#include "seafile/api/account_info.hpp"
|
||||
#include "seafile/api/repo_info.hpp"
|
||||
#include "seafile/fs/storage/repo_entry.hpp"
|
||||
|
||||
//
|
||||
// Created by Shell on 2026/7/16.
|
||||
//
|
||||
namespace seafile::fs {
|
||||
using RepoEntry = storage::RepoEntry;
|
||||
using AccountInfo = api::AccountInfo;
|
||||
using RepoInfo = api::RepoInfo;
|
||||
|
||||
namespace {
|
||||
auto make_storage(const std::string &path) {
|
||||
// clang-format off
|
||||
return sqlite_orm::make_storage(path,
|
||||
sqlite_orm::make_table("account_info",
|
||||
sqlite_orm::make_column("space_usage", &AccountInfo::space_usage),
|
||||
sqlite_orm::make_column("avatar_url", &AccountInfo::avatar_url),
|
||||
sqlite_orm::make_column("email", &AccountInfo::email),
|
||||
sqlite_orm::make_column("name", &AccountInfo::name),
|
||||
sqlite_orm::make_column("total", &AccountInfo::total),
|
||||
sqlite_orm::make_column("usage", &AccountInfo::usage),
|
||||
sqlite_orm::make_column("login_id", &AccountInfo::login_id),
|
||||
sqlite_orm::make_column("department", &AccountInfo::department),
|
||||
sqlite_orm::make_column("contact_email", &AccountInfo::contact_email),
|
||||
sqlite_orm::make_column("institution", &AccountInfo::institution),
|
||||
sqlite_orm::make_column("is_staff", &AccountInfo::is_staff),
|
||||
sqlite_orm::make_column("file_updates_email_interval", &AccountInfo::file_updates_email_interval),
|
||||
sqlite_orm::make_column("collaborate_email_interval",&AccountInfo::collaborate_email_interval)
|
||||
),
|
||||
sqlite_orm::make_table("repo_info",
|
||||
sqlite_orm::make_column("type",&RepoInfo::type),
|
||||
sqlite_orm::make_column("id",&RepoInfo::id),
|
||||
sqlite_orm::make_column("owner",&RepoInfo::owner),
|
||||
sqlite_orm::make_column("name",&RepoInfo::name),
|
||||
sqlite_orm::make_column("mtime",&RepoInfo::mtime),
|
||||
sqlite_orm::make_column("size",&RepoInfo::size),
|
||||
sqlite_orm::make_column("encrypted",&RepoInfo::encrypted),
|
||||
sqlite_orm::make_column("root",&RepoInfo::root),
|
||||
sqlite_orm::make_column("permission",&RepoInfo::permission),
|
||||
sqlite_orm::make_column("modifier_email",&RepoInfo::modifier_email),
|
||||
sqlite_orm::make_column("modifier_contact_email",&RepoInfo::modifier_contact_email),
|
||||
sqlite_orm::make_column("modifier_name",&RepoInfo::modifier_name),
|
||||
sqlite_orm::make_column("file_count",&RepoInfo::file_count),
|
||||
sqlite_orm::make_column("head_commit_id",&RepoInfo::head_commit_id),
|
||||
sqlite_orm::make_column("enc_version",&RepoInfo::enc_version),
|
||||
sqlite_orm::make_column("salt",&RepoInfo::salt),
|
||||
sqlite_orm::make_column("magic",&RepoInfo::magic),
|
||||
sqlite_orm::make_column("random_key",&RepoInfo::random_key)
|
||||
),
|
||||
sqlite_orm::make_table("repo_entry",
|
||||
sqlite_orm::make_column("type",&RepoEntry::type),
|
||||
sqlite_orm::make_column("name",&RepoEntry::name),
|
||||
sqlite_orm::make_column("path",&RepoEntry::path),
|
||||
sqlite_orm::make_column("id",&RepoEntry::id),
|
||||
sqlite_orm::make_column("mtime",&RepoEntry::mtime),
|
||||
sqlite_orm::make_column("modifier_email",&RepoEntry::modifier_email),
|
||||
sqlite_orm::make_column("size",&RepoEntry::size),
|
||||
sqlite_orm::make_column("is_locked",&RepoEntry::is_locked),
|
||||
sqlite_orm::make_column("lock_owner",&RepoEntry::lock_owner),
|
||||
sqlite_orm::make_column("lock_time",&RepoEntry::lock_time),
|
||||
sqlite_orm::make_column("locked_by_me",&RepoEntry::locked_by_me),
|
||||
sqlite_orm::make_column("permission",&RepoEntry::permission),
|
||||
sqlite_orm::make_column("modifier_contact_email",&RepoEntry::modifier_contact_email),
|
||||
sqlite_orm::make_column("modifier_name",&RepoEntry::modifier_name),
|
||||
sqlite_orm::make_column("starred",&RepoEntry::starred))
|
||||
);
|
||||
//clang-format on
|
||||
}
|
||||
}
|
||||
|
||||
struct SeafileStore::Database {
|
||||
using Storage = decltype(make_storage(""));
|
||||
Storage storage;
|
||||
|
||||
explicit Database(const std::string &path)
|
||||
: storage(make_storage(path)) {
|
||||
}
|
||||
};
|
||||
|
||||
SeafileStore::SeafileStore(const std::string &db_path, const std::string &server, const std::string &user,
|
||||
const std::string &password) : api(server) {
|
||||
this->database = std::make_unique<Database>(db_path);
|
||||
this->user = user;
|
||||
this->password = password;
|
||||
this->api_server = server;
|
||||
}
|
||||
|
||||
tl::expected<RepoEntry, api::SeafileException> SeafileStore::findRepoEntry(
|
||||
const std::string &repo_id, const std::string &path) {
|
||||
auto &storage = this->database->storage;
|
||||
const auto entry = storage.get_optional<RepoEntry>(
|
||||
sqlite_orm::where(
|
||||
sqlite_orm::and_(
|
||||
sqlite_orm::c(&RepoEntry::path) == path,
|
||||
sqlite_orm::c(&RepoEntry::repo_id) == repo_id
|
||||
)
|
||||
));
|
||||
if (entry) {
|
||||
return *entry;
|
||||
}
|
||||
return tl::make_unexpected(api::SeafileException("entry not exists"));
|
||||
}
|
||||
|
||||
tl::expected<bool, api::SeafileException> SeafileStore::checkIsUpdated(const std::string &repo_id) {
|
||||
auto &storage = this->database->storage;
|
||||
const auto repo = storage.get_optional<RepoInfo>(
|
||||
sqlite_orm::where(
|
||||
sqlite_orm::c(&RepoInfo::id) == repo_id
|
||||
));
|
||||
if (!repo) {
|
||||
return true;
|
||||
}
|
||||
const auto& commit_id = repo.value().head_commit_id;
|
||||
const auto repo_info = this->api.repoInfo(repo_id,this->token,this->token_type);
|
||||
if (repo_info) {
|
||||
return repo_info.value().head_commit_id == commit_id;
|
||||
}
|
||||
|
||||
return tl::make_unexpected(repo_info.error());
|
||||
}
|
||||
}
|
||||
Reference in new issue
Block a user