1 /*
2  * Copyright (c) 2022 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 DATASHARESERVICE_DATA_SHARE_SERVICE_PROXY_H
17 #define DATASHARESERVICE_DATA_SHARE_SERVICE_PROXY_H
18 
19 #include <atomic>
20 #include <iremote_proxy.h>
21 #include <list>
22 
23 #include "idata_share_service.h"
24 
25 namespace OHOS::DataShare {
26 class DataShareServiceProxy final : public IRemoteProxy<IDataShareService> {
27 public:
28     explicit DataShareServiceProxy(const sptr<IRemoteObject> &object);
29     int Insert(const Uri &uri, const Uri &extUri, const DataShareValuesBucket &valuesBucket) override;
30 
31     int Update(const Uri &uri, const Uri &extUri, const DataSharePredicates &predicate,
32         const DataShareValuesBucket &valuesBucket) override;
33 
34     int Delete(const Uri &uri, const Uri &extUri, const DataSharePredicates &predicate) override;
35 
36     std::pair<int32_t, int32_t> InsertEx(const Uri &uri, const Uri &extUri,
37         const DataShareValuesBucket &valuesBucket) override;
38 
39     std::pair<int32_t, int32_t> UpdateEx(const Uri &uri, const Uri &extUri, const DataSharePredicates &predicate,
40         const DataShareValuesBucket &valuesBucket) override;
41 
42     std::pair<int32_t, int32_t> DeleteEx(const Uri &uri, const Uri &extUri,
43         const DataSharePredicates &predicate) override;
44 
45     std::shared_ptr<DataShareResultSet> Query(const Uri &uri, const Uri &extUri, const DataSharePredicates &predicates,
46         std::vector<std::string> &columns, DatashareBusinessError &businessError) override;
47 
48     int AddQueryTemplate(const std::string &uri, int64_t subscriberId, Template &tpl) override;
49 
50     int DelQueryTemplate(const std::string &uri, int64_t subscriberId) override;
51 
52     std::vector<OperationResult> Publish(const Data &data, const std::string &bundleName) override;
53 
54     Data GetPublishedData(const std::string &bundleName, int &resultCode) override;
55 
56     std::vector<OperationResult> SubscribeRdbData(const std::vector<std::string> &uris, const TemplateId &templateId,
57         const sptr<IDataProxyRdbObserver> &observer) override;
58 
59     std::vector<OperationResult> UnSubscribeRdbData(
60         const std::vector<std::string> &uris, const TemplateId &templateId) override;
61 
62     std::vector<OperationResult> EnableSubscribeRdbData(
63         const std::vector<std::string> &uris, const TemplateId &templateId) override;
64 
65     std::vector<OperationResult> DisableSubscribeRdbData(
66         const std::vector<std::string> &uris, const TemplateId &templateId) override;
67 
68     std::vector<OperationResult> SubscribePublishedData(const std::vector<std::string> &uris, int64_t subscriberId,
69         const sptr<IDataProxyPublishedDataObserver> &observer) override;
70 
71     std::vector<OperationResult> UnSubscribePublishedData(
72         const std::vector<std::string> &uris, int64_t subscriberId) override;
73 
74     std::vector<OperationResult> EnableSubscribePublishedData(
75         const std::vector<std::string> &uris, int64_t subscriberId) override;
76 
77     std::vector<OperationResult> DisableSubscribePublishedData(
78         const std::vector<std::string> &uris, int64_t subscriberId) override;
79     void Notify(const std::string &uri) override;
80 
81     int SetSilentSwitch(const Uri &uri, bool enable) override;
82 
83     int GetSilentProxyStatus(const std::string &uri) override;
84 
85     int RegisterObserver(const Uri &uri,
86         const sptr<OHOS::IRemoteObject> &dataObserver) override;
87 
88     int UnRegisterObserver(const Uri &uri,
89         const sptr<OHOS::IRemoteObject> &dataObserver) override;
90 
91 private:
92     static inline BrokerDelegator<DataShareServiceProxy> delegator_;
93 };
94 } // namespace OHOS::DataShare
95 #endif
96