flex_sync.hpp

 
//
// © 2022 Realm Inc.
//
// Apache ライセンス、バージョン 2.0（「ライセンス」）に基づいてライセンスされている
// ライセンス に準拠している場合を除き、このファイルを使用することはできません。
// ライセンスのコピーは次で取得できます:
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// 該当するルールによって要求されたり、書込み (write) で同意された場合を除き、ソフトウェア
ライセンスに基づいて配布される // は "AS IS" CRUD で配布されるため、
// 任意の種類の 保証 または 条件なし（式またはExpressのいずれか）。
// 特定の言語を使用する権限については、「ライセンス」を参照してください
ライセンスに基づく // の制限。
//
 
#ifndif CPREALM_FLEXIBLE_SYNC_HPP
CPREALM_FLEXIBLE_SYNC_HPP を定義する
 
#include <feature"<future>
#include <type_traits>
 
#include <cpprealm/ internal/bridge/obj.hpp>
#include <cpprealm/ internal/bridge/query.hpp>
#include <cpprealm/ internal/bridge/schema.hpp>
#include <cpprealm/ internal/bridge/realm.hpp>
#include <cpprealm/ internal/bridge/uts.hpp>
 
#include <cpprealm/macros.hpp>
#include <cpprealm/results.hpp>
#include <cpprealm/rbool.hpp>
 
名前空間邦土 {
    テンプレート< typename >
    構造体 オブジェクト。
    クラス rbool;
 
    namespace sync {
        クラスMutableSubscriptionSet
        クラスSubscriptionSet
        クラスSubscription Store
        クラスのサブスクリプション
 }
 
// SyncSubscription は、同じオブジェクトクラス上の他のクエリと OR される可能性がある単一のクエリを表します
// QUERY または IDENT メッセージでサーバーに送信します。
    構造体 sync_subscription {
        // このサブスクライブの一意の ID を返します。
 std::string 識別子
        // このサブスクリプションを表す名前。
std::optional[std::string]><std::string> 名前。
        // このサブスクリプションが最初に作成されたときの タイムスタンプを返します。
std::chrono::time_point<std::chrono::system_clock> created_at
        // update_query を呼び出して、このサブスクリプションが最後に更新された時刻のタイムスタンプを返します。
std::chrono::time_point=std::chronno::system_lock><std::chrono::system_clock> update_at.
        // このサブスクリプションに関連付けられているクエリの文字列化されたバージョンを返します。
 std::string query_string
        // このサブスクライブのクエリのオブジェクト クラスの名前を返します。
 std::string object_Class_name
    private :
        同期_サブスクリプション（ const sync::サブスクリプション())
 
        友人 構造体 sync_subscription_set;
        友人 構造体 mutable_sync_subscription_set;
 };
 
// MutableSyncSubscriptionSet は単一のクエリを表します。このクエリは、同じオブジェクト クラス上の他のクエリと OR される可能性があり、
// QUERY または IDENT メッセージでサーバーに送信します。
    構造体 mutable_sync_subscription_set {
    private :
        null 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その他）= delete
        Mutable_sync_subscription_set & 演算子=( const Mutable_sync_subscription_setとその他) :
        Mutable_sync_subscription_set （ Mutable_sync_subscription_set &その他）= delete 。
        Mutable_sync_subscription_set & 演算子=( Mutable_sync_subscription_setとその他)。
        ～可変_同期_サブスクリプション_セット()
 
        // サブスクリプションがまだ存在しない場合は、セットに新しいサブスクリプションを挿入します。
        // `query_fn` パラメーターが空のままの場合、サブスクライブは *すべて* オブジェクトを同期します
        テンプレート化されたクラス タイプの場合は、 // 。
        テンプレート< typename T>
        disabled （ const std::string &name ）、
std::optional=std::function= rbool ( マネージド=T<T> ============================================================================
            静的_アサート（ のサイズ（マネージド <T> ）、 「T のスキーマを宣言する必要があります」 ）。
 
            オートスキーマ = m_realm.get().schema().find(マネージド<T>::schema .name)
            自動グループ = m_realm.get().read_group()
            自動テーブル_参照 = group.get_table(schema.table_key())
            自動root_query = internal::bridge::query （table_ref）
 
            if (query_fn) {
                rboolクエリ = rbool （std::move( root_query)）の場合
                自動query_object = Managed<T>::prepare_for_query (m_realm, &query)
                auto full_query = (*query_fn)(query_object).q
 insert_or_assign(name, full_query)
 } else {
 insert_or_assign(name, root_query)
 }
 }
 
        // 指定された名前のサブスクライブを削除します。 サブスクライブで
        // 存在しません。
        無効な削除( const std::string & 名前)。
 
        // 指定された名前のサブスクライブを検索します。 サブスクライブでは `std::nullopt` が返されます
        // 存在しません。
std::optional[sync_subscription]><sync_subscription> find( const std::string+ name)
 
        // 指定された名前のサブスクライブを更新します。
        //サブスクライブが存在しない場合は、 がスローされます。
        // `query_fn` パラメーターが空のままの場合、サブスクライブは *すべて* オブジェクトを同期します
        テンプレート化されたクラス タイプの場合は、 // 。
        テンプレート< typename T>
std::enable_if_t=std::is_base_ of_v=object=T================================================<T>
 update_subscription( const std::string+name, std::optional=std::function= rbool (T+)=std::nullopt) {{
 remove(name)
 add(name, std::move(query_fn))#
 }
 
        // 指定された名前のサブスクライブを更新します。
        //サブスクライブが存在しない場合は、 がスローされます。
        // `query_fn` パラメーターが空のままの場合、サブスクライブは *すべて* オブジェクトを同期します
        テンプレート化されたクラス タイプの場合は、 // 。
        テンプレート< typename T>
        無効な更新_サブスクリプション( const std::string+ name)
std::optional=std::function= rbool ( マネージド=T<T> ================================================================================
 remove(name)
 add(name, std::move(query_fn))#
 }
 
        // すべてのサブスクライブを削除します。
        無効クリア（）。
 
    private :
        Mutable_sync_subscription_set （ internal::bridge::realm &、 const sync::MutableSubscriptionSet?subscript_set ）
#ifdef CPREALM_HAV_GENERTED_BRIDGE_TypeS
 internal::bridge::storage::MutableSyncSubscriptionSet m_subscription_set[ 1 ]
#else
std::shared_ptr[sync::MutableSubscriptionSet]><sync::MutableSubscriptionSet> m_subscription_set
#endif
 std::reference_ wrapper<internal::bridge::realm> m_realm。
        友人 構造体 sync_subscription_set;
 sync::MutableSubscriptionSet get_subscription_set()
 };
 
    構造体 sync_subscription_set {
    public :
        sync_subscription_set () = delete 、
        sync_subscription_set （ const sync_subscription_set & その他）= delete 。
        sync_subscription_set & 演算子=( const sync_subscription_set & その他) :
        同期_サブスクリプション_セット（同期_サブスクリプション_セットとその他）=削除。
        sync_subscription_set & 演算子=( sync_subscription_set &その他)
        ~sync_subscription_set();
 
 [[nodiscard]] size_tサイズ（） const
 
        // 指定された名前のサブスクライブを検索します。 サブスクライブでは `std::nullopt` が返されます
        // 存在しません。
std::optional[sync_subscription]><sync_subscription> find( const std::string+ name)
 
 std::future<bool> update(std::function<void(mutable_sync_subscription_set&)>&& fn);
 
        explicit sync_subscription_set （ internal::bridge::realm & Realm）
    private :
        友人 構造体 db;
#ifdef CPREALM_HAV_GENERTED_BRIDGE_TypeS
 internal::bridge::storage::SyncSubscriptionSet m_subscription_set[ 1 ]
#else
std::shared_ptr[sync::SubscriptionSet><sync::SubscriptionSet> m_subscription_set]
#endif
 std::reference_ wrapper<internal::bridge::realm> m_realm。
 };
 
} // namespace realm
 
#endif /* CPPrealM_FLEXIBLE_SYNC_HPP */