Agora RTC Objective-C API Reference  Refactor
NGIAgoraSyncClient.h
Go to the documentation of this file.
1 // Copyright (c) 2020 Agora.io. All rights reserved
2 
3 // This program is confidential and proprietary to Agora.io.
4 // And may not be copied, reproduced, modified, disclosed to others, published
5 // or used, in whole or in part, without the express prior written permission
6 // of Agora.io.
7 
8 #pragma once // NOLINT(build/header_guard)
9 #include "AgoraRefPtr.h"
10 #include "AgoraBase.h"
11 #include <functional>
12 #include <api/aosl_ref.h>
13 
14 namespace agora {
15 namespace base {
16 
18  kOk = 0,
19  kFail = -1,
28  kNotLoggedIn = -10,
31 };
32 
33 typedef void(*syncClientCallback)(SyncClientError, void*);
34 typedef void(*dataBaseOpCallback)(SyncClientError, const char*, void*);
35 typedef void(*collectionOpCallback)(SyncClientError, const char*, const char*, void*);
36 typedef void(*queryDocCallback)(SyncClientError error, const char* resultJson, size_t count, bool more, void* userData);
37 
39  kInserted = 0,
40  kPut = 1,
41  kDeleted = 2,
42 
44  kToBePut = 4,
46 
50 };
51 
56  public:
57  struct CollectionEvent {
59  const char* path;
60  const char* value;
61  };
62  virtual void onCollectionEvent(const char* previousJson, const char* curJson, const char* collection, const char* docName,
63  const CollectionEvent* events, int eventSize) = 0;
64  virtual void onDatabaseEvent(const char* databaseName, SyncClientError error) = 0;
65  virtual void onDataException(const char* databaseName, const char* collectionName) = 0;
66  virtual ~ISyncClientObserver() {};
67 };
68 
72 struct SyncConfig {
73  const char* appId;
74  /* shakehand interval in seconds, 0 means enable manual shake hand */
76  /* connection timeout in seconds */
78  /* compact interval in seconds */
79  uint32_t compact_interval;
81 };
82 
84 protected:
85  virtual ~ISyncClient() {}
86 public:
87 
88  virtual int32_t registerSyncClientObserver(ISyncClientObserver* observer, void(*safeDeleter)(ISyncClientObserver*) = OPTIONAL_NULLPTR, aosl_ref_t ares = AOSL_REF_INVALID) = 0;
89  virtual int32_t unregisterSyncClientObserver(ISyncClientObserver* observer) = 0;
90  // client operations
91  virtual int32_t login(const char* token, const char* channelName, user_id_t userId, syncClientCallback callback, void* userData, aosl_ref_t ares = AOSL_REF_INVALID) = 0;
92  virtual int32_t queryDoc(const char* database, const char* coll, const char* range_start, const char* range_end, int64_t limits, bool doc_only, bool count_only, queryDocCallback callback, void* userData, aosl_ref_t ares = AOSL_REF_INVALID) = 0;
93  virtual int32_t logout(aosl_ref_t ares = AOSL_REF_INVALID) = 0;
94  virtual int32_t renewToken(const char* token, aosl_ref_t ares = AOSL_REF_INVALID) = 0;
95 
96  // database operations
97  virtual int32_t connectDatabase(const char* database, dataBaseOpCallback callback, void* userData, aosl_ref_t ares = AOSL_REF_INVALID) = 0;
98  virtual int32_t disconnectDatabase(const char* database,
99  dataBaseOpCallback callback, void* userData, aosl_ref_t ares = AOSL_REF_INVALID) = 0;
100  virtual int32_t createCollection(const char* database, const char* collection,
101  const char** readable, int readSize,
102  collectionOpCallback callback, void* userData, aosl_ref_t ares = AOSL_REF_INVALID) = 0;
103  virtual int32_t deleteCollection(const char* database, const char* collection,
104  collectionOpCallback callback, void* userData, aosl_ref_t ares = AOSL_REF_INVALID) = 0;
105 
106  // collection operations
107  virtual int32_t subscribe(const char* database, const char* collection,
108  util::AString& snapshotJson) = 0;
109  virtual int32_t unsubscribe(const char* database, const char* collection, aosl_ref_t ares = AOSL_REF_INVALID) = 0;
110  virtual int32_t putDoc(const char* database, const char* collection,
111  const char* docName, aosl_ref_t ares = AOSL_REF_INVALID) = 0;
112  virtual int32_t deleteDoc(const char* database, const char* collection,
113  const char* docName, aosl_ref_t ares = AOSL_REF_INVALID) = 0;
114  virtual int32_t getDocs(const char* database, const char* collection,
115  util::AString* docNames, uint32_t docSize) = 0;
116 
117  // document operations
118  virtual int32_t putDocValue(const char* database, const char* collection,
119  const char* docName, const char* jsonValue, aosl_ref_t ares = AOSL_REF_INVALID) = 0;
120  virtual int32_t updateDocValue(const char* database, const char* collection,
121  const char* docName, const char* path,
122  const char* jsonValue, aosl_ref_t ares = AOSL_REF_INVALID) = 0;
123  virtual int32_t deleteDocValue(const char* database, const char* collection,
124  const char* docName, const char* path, aosl_ref_t ares = AOSL_REF_INVALID) = 0;
125  virtual int32_t deleteDocValues(const char* database, const char* collection, const char* docName,
126  const char** path, uint32_t pathSize,
127  aosl_ref_t ares = AOSL_REF_INVALID) = 0;
128  virtual int32_t getDocValue(const char* database, const char* collection,
129  const char* docName, util::AString& jsonValue) = 0;
130  virtual int32_t hasPath(const char* database, const char* collection,
131  const char* docName, const char* path, bool& result) = 0;
132  virtual int32_t keepAliveDoc(const char* database, const char* collection,
133  const char* docName, uint32_t ttl, aosl_ref_t ares = AOSL_REF_INVALID) = 0;
134 
135  // sync operations
136  virtual int32_t shakehand(aosl_ref_t ares = AOSL_REF_INVALID) = 0;
137 };
138 }// namespace base
139 }// namespace agora
agora::base::SyncConfig::compact_interval
uint32_t compact_interval
Definition: NGIAgoraSyncClient.h:79
agora::base::kCollectionNotCreated
@ kCollectionNotCreated
Definition: NGIAgoraSyncClient.h:25
agora::base::kPut
@ kPut
Definition: NGIAgoraSyncClient.h:40
AgoraBase.h
agora::base::ISyncClient::~ISyncClient
virtual ~ISyncClient()
Definition: NGIAgoraSyncClient.h:85
agora::base::ISyncClientObserver::onDatabaseEvent
virtual void onDatabaseEvent(const char *databaseName, SyncClientError error)=0
agora::base::kCollectionExisted
@ kCollectionExisted
Definition: NGIAgoraSyncClient.h:26
agora::base::ISyncClientObserver::~ISyncClientObserver
virtual ~ISyncClientObserver()
Definition: NGIAgoraSyncClient.h:66
agora::base::ISyncClient::queryDoc
virtual int32_t queryDoc(const char *database, const char *coll, const char *range_start, const char *range_end, int64_t limits, bool doc_only, bool count_only, queryDocCallback callback, void *userData, aosl_ref_t ares=AOSL_REF_INVALID)=0
agora::base::kDocNotCreated
@ kDocNotCreated
Definition: NGIAgoraSyncClient.h:30
agora::base::ISyncClient::deleteDocValues
virtual int32_t deleteDocValues(const char *database, const char *collection, const char *docName, const char **path, uint32_t pathSize, aosl_ref_t ares=AOSL_REF_INVALID)=0
agora::base::kDocSyncEnd
@ kDocSyncEnd
Definition: NGIAgoraSyncClient.h:49
agora::base::ISyncClient::renewToken
virtual int32_t renewToken(const char *token, aosl_ref_t ares=AOSL_REF_INVALID)=0
agora::base::kFail
@ kFail
Definition: NGIAgoraSyncClient.h:19
agora::base::kConnectSyncFailed
@ kConnectSyncFailed
Definition: NGIAgoraSyncClient.h:20
agora::base::ISyncClientObserver::CollectionEvent::value
const char * value
Definition: NGIAgoraSyncClient.h:60
agora::base::ISyncClient::disconnectDatabase
virtual int32_t disconnectDatabase(const char *database, dataBaseOpCallback callback, void *userData, aosl_ref_t ares=AOSL_REF_INVALID)=0
agora::base::ISyncClient::keepAliveDoc
virtual int32_t keepAliveDoc(const char *database, const char *collection, const char *docName, uint32_t ttl, aosl_ref_t ares=AOSL_REF_INVALID)=0
agora::base::ISyncClient::connectDatabase
virtual int32_t connectDatabase(const char *database, dataBaseOpCallback callback, void *userData, aosl_ref_t ares=AOSL_REF_INVALID)=0
agora::base::kToBeDeleted
@ kToBeDeleted
Definition: NGIAgoraSyncClient.h:45
agora::base::ISyncClient::putDoc
virtual int32_t putDoc(const char *database, const char *collection, const char *docName, aosl_ref_t ares=AOSL_REF_INVALID)=0
agora::base::syncClientCallback
void(* syncClientCallback)(SyncClientError, void *)
Definition: NGIAgoraSyncClient.h:33
agora::base::kDisconnectDatabaseFailed
@ kDisconnectDatabaseFailed
Definition: NGIAgoraSyncClient.h:22
agora::base::ISyncClient::updateDocValue
virtual int32_t updateDocValue(const char *database, const char *collection, const char *docName, const char *path, const char *jsonValue, aosl_ref_t ares=AOSL_REF_INVALID)=0
agora::base::ISyncClient::putDocValue
virtual int32_t putDocValue(const char *database, const char *collection, const char *docName, const char *jsonValue, aosl_ref_t ares=AOSL_REF_INVALID)=0
agora
Definition: AgoraAtomicOps.h:21
agora::base::SyncConfig::connection_timeout
uint32_t connection_timeout
Definition: NGIAgoraSyncClient.h:77
agora::base::ISyncClientObserver::onDataException
virtual void onDataException(const char *databaseName, const char *collectionName)=0
agora::base::ISyncClient::login
virtual int32_t login(const char *token, const char *channelName, user_id_t userId, syncClientCallback callback, void *userData, aosl_ref_t ares=AOSL_REF_INVALID)=0
agora::base::ISyncClientObserver
Definition: NGIAgoraSyncClient.h:55
agora::base::kTransactionEnd
@ kTransactionEnd
Definition: NGIAgoraSyncClient.h:48
agora::base::ISyncClient::getDocs
virtual int32_t getDocs(const char *database, const char *collection, util::AString *docNames, uint32_t docSize)=0
agora::base::kInvalidParams
@ kInvalidParams
Definition: NGIAgoraSyncClient.h:27
agora::base::SyncConfig
Definition: NGIAgoraSyncClient.h:72
agora::base::kNotLoggedIn
@ kNotLoggedIn
Definition: NGIAgoraSyncClient.h:28
agora::base::kQueryDocFailed
@ kQueryDocFailed
Definition: NGIAgoraSyncClient.h:29
agora::base::ISyncClientObserver::onCollectionEvent
virtual void onCollectionEvent(const char *previousJson, const char *curJson, const char *collection, const char *docName, const CollectionEvent *events, int eventSize)=0
agora::base::SyncConfig::appId
const char * appId
Definition: NGIAgoraSyncClient.h:73
agora::base::ISyncClient::logout
virtual int32_t logout(aosl_ref_t ares=AOSL_REF_INVALID)=0
agora::base::collectionOpCallback
void(* collectionOpCallback)(SyncClientError, const char *, const char *, void *)
Definition: NGIAgoraSyncClient.h:35
agora::base::kCreateCollectionFailed
@ kCreateCollectionFailed
Definition: NGIAgoraSyncClient.h:24
agora::base::ISyncClient::getDocValue
virtual int32_t getDocValue(const char *database, const char *collection, const char *docName, util::AString &jsonValue)=0
agora::base::kToBePut
@ kToBePut
Definition: NGIAgoraSyncClient.h:44
agora::base::ISyncClient::deleteCollection
virtual int32_t deleteCollection(const char *database, const char *collection, collectionOpCallback callback, void *userData, aosl_ref_t ares=AOSL_REF_INVALID)=0
agora::base::kConnectDatabaseFailed
@ kConnectDatabaseFailed
Definition: NGIAgoraSyncClient.h:21
agora::base::ISyncClientObserver::CollectionEvent::type
SyncEventType type
Definition: NGIAgoraSyncClient.h:58
agora::base::kOk
@ kOk
Definition: NGIAgoraSyncClient.h:18
agora::base::ISyncClientObserver::CollectionEvent
Definition: NGIAgoraSyncClient.h:57
agora::base::ISyncClient::subscribe
virtual int32_t subscribe(const char *database, const char *collection, util::AString &snapshotJson)=0
agora::base::ISyncClient::deleteDocValue
virtual int32_t deleteDocValue(const char *database, const char *collection, const char *docName, const char *path, aosl_ref_t ares=AOSL_REF_INVALID)=0
agora::base::dataBaseOpCallback
void(* dataBaseOpCallback)(SyncClientError, const char *, void *)
Definition: NGIAgoraSyncClient.h:34
AgoraRefPtr.h
agora::base::ISyncClient::createCollection
virtual int32_t createCollection(const char *database, const char *collection, const char **readable, int readSize, collectionOpCallback callback, void *userData, aosl_ref_t ares=AOSL_REF_INVALID)=0
agora::base::ISyncClient::hasPath
virtual int32_t hasPath(const char *database, const char *collection, const char *docName, const char *path, bool &result)=0
agora::base::ISyncClient::unsubscribe
virtual int32_t unsubscribe(const char *database, const char *collection, aosl_ref_t ares=AOSL_REF_INVALID)=0
agora::base::ISyncClient::unregisterSyncClientObserver
virtual int32_t unregisterSyncClientObserver(ISyncClientObserver *observer)=0
agora::RefCountInterface
Definition: AgoraRefPtr.h:31
agora::base::queryDocCallback
void(* queryDocCallback)(SyncClientError error, const char *resultJson, size_t count, bool more, void *userData)
Definition: NGIAgoraSyncClient.h:36
agora::util::CopyableAutoPtr
Definition: AgoraBase.h:156
agora::base::kDatabaseNotConnected
@ kDatabaseNotConnected
Definition: NGIAgoraSyncClient.h:23
OPTIONAL_NULLPTR
#define OPTIONAL_NULLPTR
Definition: AgoraBase.h:90
agora::base::ISyncClient::registerSyncClientObserver
virtual int32_t registerSyncClientObserver(ISyncClientObserver *observer, void(*safeDeleter)(ISyncClientObserver *)=OPTIONAL_NULLPTR, aosl_ref_t ares=AOSL_REF_INVALID)=0
agora::base::SyncClientError
SyncClientError
Definition: NGIAgoraSyncClient.h:17
agora::base::ISyncClientObserver::CollectionEvent::path
const char * path
Definition: NGIAgoraSyncClient.h:59
agora::base::ISyncClient
Definition: NGIAgoraSyncClient.h:83
agora::base::kToBeInserted
@ kToBeInserted
Definition: NGIAgoraSyncClient.h:43
agora::base::ISyncClient::shakehand
virtual int32_t shakehand(aosl_ref_t ares=AOSL_REF_INVALID)=0
agora::base::kDeleted
@ kDeleted
Definition: NGIAgoraSyncClient.h:41
agora::base::SyncConfig::SyncConfig
SyncConfig()
Definition: NGIAgoraSyncClient.h:80
agora::base::kInserted
@ kInserted
Definition: NGIAgoraSyncClient.h:39
agora::base::ISyncClient::deleteDoc
virtual int32_t deleteDoc(const char *database, const char *collection, const char *docName, aosl_ref_t ares=AOSL_REF_INVALID)=0
agora::user_id_t
const char * user_id_t
Definition: AgoraBase.h:807
agora::base::SyncEventType
SyncEventType
Definition: NGIAgoraSyncClient.h:38
agora::base::kTransactionBegin
@ kTransactionBegin
Definition: NGIAgoraSyncClient.h:47
agora::base::SyncConfig::shakehand_interval
uint32_t shakehand_interval
Definition: NGIAgoraSyncClient.h:75