1 /* 2 * Copyright (c) 2023 Huawei Device Co., Ltd. 3 * Licensed under the Apache License, Version 2.0 (the "License"); 4 * you may not use this file except in compliance with the License. 5 * You may obtain a copy of the License at 6 * 7 * http://www.apache.org/licenses/LICENSE-2.0 8 * 9 * Unless required by applicable law or agreed to in writing, software 10 * distributed under the License is distributed on an "AS IS" BASIS, 11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12 * See the License for the specific language governing permissions and 13 * limitations under the License. 14 */ 15 16 #ifndef OHOS_DISTRIBUTED_DATA_CLOUD_CLOUD_SERVICE_PROXY_H 17 #define OHOS_DISTRIBUTED_DATA_CLOUD_CLOUD_SERVICE_PROXY_H 18 19 #include "concurrent_map.h" 20 #include "icloud_service.h" 21 #include "iremote_object.h" 22 #include "iremote_proxy.h" 23 #include "cloud_notifier_stub.h" 24 25 namespace OHOS::CloudData { 26 using namespace DistributedRdb; 27 class CloudServiceProxy : public IRemoteProxy<ICloudService> { 28 public: 29 explicit CloudServiceProxy(const sptr<IRemoteObject> &object); 30 virtual ~CloudServiceProxy() = default; 31 int32_t EnableCloud(const std::string &id, const std::map<std::string, int32_t> &switches) override; 32 int32_t DisableCloud(const std::string &id) override; 33 int32_t ChangeAppSwitch(const std::string &id, const std::string &bundleName, int32_t appSwitch) override; 34 int32_t Clean(const std::string &id, const std::map<std::string, int32_t> &actions) override; 35 int32_t NotifyDataChange(const std::string &id, const std::string &bundleName) override; 36 int32_t NotifyDataChange(const std::string &eventId, const std::string &extraData, int32_t userId) override; 37 std::pair<int32_t, std::map<std::string, StatisticInfos>> QueryStatistics( 38 const std::string &id, const std::string &bundleName, const std::string &storeId) override; 39 int32_t SetGlobalCloudStrategy(Strategy strategy, const std::vector<CommonType::Value> &values) override; 40 41 std::pair<int32_t, std::vector<NativeRdb::ValuesBucket>> AllocResourceAndShare(const std::string &storeId, 42 const DistributedRdb::PredicatesMemo &predicates, const std::vector<std::string> &columns, 43 const Participants &participants) override; 44 int32_t Share(const std::string &sharingRes, const Participants &participants, Results &results) override; 45 int32_t Unshare(const std::string &sharingRes, const Participants &participants, Results &results) override; 46 int32_t Exit(const std::string &sharingRes, std::pair<int32_t, std::string> &result) override; 47 int32_t ChangePrivilege(const std::string &sharingRes, const Participants &participants, Results &results) override; 48 int32_t Query(const std::string &sharingRes, QueryResults &results) override; 49 int32_t QueryByInvitation(const std::string &invitation, QueryResults &results) override; 50 int32_t ConfirmInvitation(const std::string &invitation, int32_t confirmation, 51 std::tuple<int32_t, std::string, std::string> &result) override; 52 int32_t ChangeConfirmation( 53 const std::string &sharingRes, int32_t confirmation, std::pair<int32_t, std::string> &result) override; 54 55 int32_t SetCloudStrategy(Strategy strategy, const std::vector<CommonType::Value> &values) override; 56 std::pair<int32_t, QueryLastResults> QueryLastSyncInfo( 57 const std::string &id, const std::string &bundleName, const std::string &storeId) override; 58 int32_t CloudSync(const std::string &bundleName, const std::string &storeId, const Option &option, 59 const AsyncDetail &async) override; 60 int32_t InitNotifier(sptr<IRemoteObject> notifier) override; 61 int32_t InitNotifier(); 62 63 private: 64 int32_t DoAsync(const std::string &bundleName, const std::string &storeId, Option option); 65 void OnSyncComplete(uint32_t seqNum, Details &&result); 66 sptr<IRemoteObject> remote_; 67 sptr<CloudNotifierStub> notifier_; 68 ConcurrentMap<uint32_t, AsyncDetail> syncCallbacks_; 69 }; 70 } // namespace OHOS::CloudData 71 #endif // OHOS_DISTRIBUTED_DATA_CLOUD_CLOUD_SERVICE_PROXY_H