1 /*
2 * Copyright (c) 2024 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 #include "include/observer_bridge_mock.h"
16
17 namespace OHOS::DistributedKv {
ObserverBridge(AppId appId,StoreId storeId,int32_t subUser,std::shared_ptr<Observer> observer,const Convertor & cvt)18 ObserverBridge::ObserverBridge(AppId appId, StoreId storeId, int32_t subUser, std::shared_ptr<Observer> observer,
19 const Convertor &cvt) : appId_(std::move(appId)), storeId_(std::move(storeId)), subUser_(subUser),
20 observer_(std::move(observer)), convert_(cvt)
21 {
22 }
23
~ObserverBridge()24 ObserverBridge::~ObserverBridge() { }
25
OnServiceDeath()26 void ObserverBridge::OnServiceDeath()
27 {
28 if (BObserverBridge::observerBridge != nullptr) {
29 return BObserverBridge::observerBridge->OnServiceDeath();
30 }
31 }
32
RegisterRemoteObserver(uint32_t realType)33 Status ObserverBridge::RegisterRemoteObserver(uint32_t realType)
34 {
35 if (BObserverBridge::observerBridge != nullptr) {
36 return BObserverBridge::observerBridge->RegisterRemoteObserver(realType);
37 }
38 return ERROR;
39 }
40
UnregisterRemoteObserver(uint32_t realType)41 Status ObserverBridge::UnregisterRemoteObserver(uint32_t realType)
42 {
43 return SUCCESS;
44 }
45
OnChange(const DBChangedData & data)46 void ObserverBridge::OnChange(const DBChangedData &data) { }
47
ObserverClient(std::shared_ptr<Observer> observer,const Convertor & cvt)48 ObserverBridge::ObserverClient::ObserverClient(std::shared_ptr<Observer> observer, const Convertor &cvt)
49 : KvStoreObserverClient(observer), convert_(cvt), realType_(0)
50 {
51 }
52
OnChange(const ChangeNotification & data)53 void ObserverBridge::ObserverClient::OnChange(const ChangeNotification &data) { }
54
OnChange(const DataOrigin & origin,Keys && keys)55 void ObserverBridge::ObserverClient::OnChange(const DataOrigin &origin, Keys &&keys) { }
56
57 template <class T>
ConvertDB(const T & dbEntries,std::string & deviceId,const Convertor & convert)58 std::vector<Entry> ObserverBridge::ConvertDB(const T &dbEntries, std::string &deviceId, const Convertor &convert)
59 {
60 std::vector<Entry> entries(dbEntries.size());
61 return entries;
62 }
63
64 } // namespace OHOS::DistributedKv