flex_sync.hpp

 
//
//저작권 2022 Realm Inc.
//
// Apache 라이선스, 버전 2.0("라이선스")에 따라 라이선스가 부여됩니다.
// 라이선스를 준수하는 경우를 제외하고는 이 파일을 사용할 수 없습니다.
// 다음에서 라이선스 사본을 얻을 수 있습니다.
//
// http://www.apache.org/licences/LICENSE-2.0
//
// 관련 법률에서 요구하거나 문서로 동의하지 않는 한, 소프트웨어
// 라이선스에 따라 배포되는 것은 '있는 그대로' 배포됩니다,
// Express 묵시적이든 어떤 종류의 보증이나 조건도 제공하지 않습니다.
// 권한을 관리하는 특정 언어에 대한 내용은 라이선스를 참조하세요.
// 라이선스에 따른 제한 사항.
//
 
#ifndef CPPREALM_FLEXIBLE_SYNC_HPP
#define CPPRALM_FLEXIBLE_SYNC_HPP
 
#include <future>
#include <type_traits>
 
#include <cpprealm/internal/bridge/obj.hpp>
#include <cpprealm/internal/bridge/ 쿼리.hpp>
#include <cpprealm/internal/bridge/schema.hpp>
#include <cpprealm/internal/bridge/realm.hpp>
#include <cpprealm/internal/bridge/utils.hpp>
 
#include <cpprealm/macros.hpp>
#include <cpprealm/results.hpp>
#include <cpprealm/rbool.hpp>
 
네임스페이스 영역 {
    템플릿 <typename>
    구조체 객체;
    클래스 rbool;
 
    namespace sync {
        클래스 MutableSubscriptionSet;
        클래스 SubscriptionSet;
        클래스 SubscriptionStore;
        클래스 구독;
 }
 
// SyncSubscription은 동일한 객체 클래스에 대한 다른 쿼리와 OR 처리될 수 있는 단일 쿼리 를 나타냅니다.
// QUERY 또는 IDENT 메시지로 서버 에 보냅니다.
    구조체 sync_subscription {
        // 이 구독 의 고유 ID 를 반환합니다.
 std::string 식별자;
        // 이 구독 을 나타내는 이름입니다.
 std::optional<std::string> 이름;
        // 이 구독 이 원래 생성된 시점의 타임스탬프를 반환합니다.
 std::chrono::time_point<std::chrono::system_clock> created_at;
        // update_query를 호출하여 이 구독 이 마지막으로 업데이트된 시간의 타임스탬프를 반환합니다.
 std::chrono::time_point<std::chrono::system_clock> updated_at;
        // 이 구독 과 연결된 쿼리 의 문자열화된 버전을 반환합니다.
 std::string query_string;
        // 이 구독에 대한 쿼리의 객체 클래스 이름을 반환합니다.
 std::string object_class_name;
    private:
        sync_subscription(const sync::Subscription&);
 
        친구 구조체 sync_subscription_set;
        친구 구조체 mutable_sync_subscription_set;
 };
 
// MutableSyncSubscriptionSet는 동일한 객체 클래스에 대한 다른 쿼리와 OR 연산될 수 있는 단일 쿼리를 나타냅니다.
// QUERY 또는 IDENT 메시지로 서버 에 보냅니다.
    구조체 mutable_sync_subscription_set {
    private:
        oid insert_or_assign(const std::string& name, const internal::bridge::query&);
    public:
        mutable_sync_subscription_set() = delete;
        mutable_sync_subscription_set(const mutable_sync_subscription_set& other) = delete;
        mutable_sync_subscription_set& 연산자=(const mutable_sync_subscription_set& other) ;
        mutable_sync_subscription_set(mutable_sync_subscription_set&& other) = 삭제;
        mutable_sync_subscription_set& 연산자=(mutable_sync_subscription_set&& other);
        ~mutable_sync_subscription_set();
 
        // 아직 구독이 없는 경우 세트에 새 구독을 삽입합니다.
        // `query_fn` 매개변수를 비워 두면 구독 은 *모든* 객체를 동기화 합니다.
        // 템플릿 클래스 유형의 경우.
        템플릿<typename T>
        oid add(const std::string &name ,
 std::optional<std::function<rbool(managed<T> &)>> &&query_fn = std::nullopt) {
            static_assert(sizeof(managed<T>), "Must explain schema for T");
 
            자동 스키마 = m_realm.get(). 스키마().find(managed<T>:: 스키마.name);
            자동 그룹 = m_realm.get().read_group();
            auto table_ref = group.get_table(schema.table_key());
            auto root_query = internal::bridge:: 쿼리(table_ref);
 
            if (query_fn) {
                rbool 쿼리 = rbool(std::move(root_query));
                auto query_object = managed<T>::prepare_for_query(m_realm, &query);
                auto full_query = (*query_fn)(query_object).q;
 insert_or_assign(name, full_query);
 } 기타 {
 insert_or_assign(name, root_query);
 }
 }
 
        // 지정된 이름에 대한 구독을 제거합니다. 구독이 다음과 같은 경우 발생합니다.
        // 존재하지 않습니다.
        무효 제거(const std::string& name);
 
        // 지정된 이름에 대한 구독 을 찾습니다. 구독 은 `std::nullopt`를 반환합니다.
        // 존재하지 않습니다.
 std::optional<sync_subscription> find(const std::string& name);
 
        // 지정된 이름에 대한 구독 을 업데이트합니다.
        // 구독 이 존재하지 않으면 예외가 발생합니다.
        // `query_fn` 매개변수를 비워 두면 구독 은 *모든* 객체를 동기화 합니다.
        // 템플릿 클래스 유형의 경우.
        템플릿 <typename T>
 std::enable_if_t<std::is_base_of_v< 객체<T>, T>>
 update_subscription(const std::string& name, std::optional<std::function<rbool(T&)>>&& query_fn = std::nullopt) {
 (이름)을 제거 합니다.
 add(name, std::move(query_fn));
 }
 
        // 지정된 이름에 대한 구독 을 업데이트합니다.
        // 구독 이 존재하지 않으면 예외가 발생합니다.
        // `query_fn` 매개변수를 비워 두면 구독 은 *모든* 객체를 동기화 합니다.
        // 템플릿 클래스 유형의 경우.
        템플릿 <typename T>
        update_subscription (const std::string& name,
 std::optional<std::function<rbool(managed<T>&)>>&& query_fn = std::nullopt) {
 (이름)을 제거 합니다.
 add(name, std::move(query_fn));
 }
 
        // 모든 구독을 제거합니다.
        무효 clear();
 
    private:
        mutable_sync_subscription_set(internal::bridge::realm&, const sync::MutableSubscriptionSet& Subscription_set);
#ifdef CPPRALM_HAVE_GENERATED_BRIDGE_TYPES
 internal::bridge:: 저장::MutableSyncSubscriptionSet m_subscription_set[1];
#else
 std::shared_ptr<sync::MutableSubscriptionSet> m_subscription_set;
#endif
 std::reference_wrapper<internal::bridge::realm> m_realm;
        친구 구조체 sync_subscription_set;
 동기화::MutableSubscriptionSet get_subscription_set();
 };
 
    구조체 sync_subscription_set {
    public:
        sync_subscription_set() = 삭제;
        sync_subscription_set(const sync_subscription_set& other) = 삭제;
        sync_subscription_set& operator=(const sync_subscription_set& other) ;
        sync_subscription_set(sync_subscription_set&& other) = 삭제;
        sync_subscription_set& 연산자=(sync_subscription_set&& other);
        ~sync_subscription_set();
 
 [[nodiscard]] size_t size() const;
 
        // 지정된 이름에 대한 구독 을 찾습니다. 구독 은 `std::nullopt`를 반환합니다.
        // 존재하지 않습니다.
 std::optional<sync_subscription> find(const std::string& name);
 
 std::future<bool> update(std::function<void(mutable_sync_subscription_set&)>&& fn);
 
        명시적 sync_subscription_set(internal::bridge::realm& Realm);
    private:
        친구 구조체 db;
#ifdef CPPRALM_HAVE_GENERATED_BRIDGE_TYPES
 internal::bridge:: 저장::SyncSubscriptionSet m_subscription_set[1];
#else
 std::shared_ptr<sync::SubscriptionSet> m_subscription_set;
#endif
 std::reference_wrapper<internal::bridge::realm> m_realm;
 };
 
} // 네임스페이스 영역
 
#endif /* CPPREALM_FLEXIBLE_SYNC_HPP */