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 #include "mock_single_kv_store.h"
17 #include "types.h"
18 
19 namespace {
20     bool g_mockGetEntriesRet = true;
21 }
22 
MockGetEntries(bool mockRet)23 void MockGetEntries(bool mockRet)
24 {
25     g_mockGetEntriesRet = mockRet;
26 }
27 
28 namespace OHOS {
29 namespace DistributedKv {
GetEntries(const Key & prefixKey,std::vector<Entry> & entries) const30 Status MockSingleKvStore::GetEntries(const Key &prefixKey, std::vector<Entry> &entries) const
31 {
32     Entry entry;
33     entries.emplace_back(entry);
34     if (false == g_mockGetEntriesRet) {
35         return Status::INVALID_ARGUMENT;
36     }
37     return Status::SUCCESS;
38 }
39 
GetEntries(const DataQuery & query,std::vector<Entry> & entries) const40 Status MockSingleKvStore::GetEntries(const DataQuery &query, std::vector<Entry> &entries) const
41 {
42     return Status::SUCCESS;
43 }
44 
GetResultSet(const Key & prefixKey,std::shared_ptr<KvStoreResultSet> & resultSet) const45 Status MockSingleKvStore::GetResultSet(const Key &prefixKey, std::shared_ptr<KvStoreResultSet> &resultSet) const
46 {
47     return Status::SUCCESS;
48 }
49 
GetResultSet(const DataQuery & query,std::shared_ptr<KvStoreResultSet> & resultSet) const50 Status MockSingleKvStore::GetResultSet(
51     const DataQuery &query, std::shared_ptr<KvStoreResultSet> &resultSet) const
52 {
53     return Status::SUCCESS;
54 }
55 
CloseResultSet(std::shared_ptr<KvStoreResultSet> & resultSet)56 Status MockSingleKvStore::CloseResultSet(std::shared_ptr<KvStoreResultSet> &resultSet)
57 {
58     return Status::SUCCESS;
59 }
60 
GetCount(const DataQuery & query,int & result) const61 Status MockSingleKvStore::GetCount(const DataQuery &query, int &result) const
62 {
63     return Status::SUCCESS;
64 }
65 
Sync(const std::vector<std::string> & deviceIds,SyncMode mode,uint32_t allowedDelayMs)66 Status MockSingleKvStore::Sync(const std::vector<std::string> &deviceIds, SyncMode mode, uint32_t allowedDelayMs)
67 {
68     return Status::SUCCESS;
69 }
70 
RemoveDeviceData(const std::string & device)71 Status MockSingleKvStore::RemoveDeviceData(const std::string &device)
72 {
73     return Status::SUCCESS;
74 }
75 
GetStoreId() const76 StoreId MockSingleKvStore::GetStoreId() const
77 {
78     StoreId storeId;
79     storeId.storeId = "";
80     return storeId;
81 }
82 
Delete(const Key & key)83 Status MockSingleKvStore::Delete(const Key &key)
84 {
85     return Status::SUCCESS;
86 }
87 
Put(const Key & key,const Value & value)88 Status MockSingleKvStore::Put(const Key &key, const Value &value)
89 {
90     return Status::INVALID_ARGUMENT;
91 }
92 
Get(const Key & key,Value & value)93 Status MockSingleKvStore::Get(const Key &key, Value &value)
94 {
95     return Status::SUCCESS;
96 }
97 
SubscribeKvStore(SubscribeType subscribeType,std::shared_ptr<KvStoreObserver> observer)98 Status MockSingleKvStore::SubscribeKvStore(SubscribeType subscribeType, std::shared_ptr<KvStoreObserver> observer)
99 {
100     return Status::SUCCESS;
101 }
102 
UnSubscribeKvStore(SubscribeType subscribeType,std::shared_ptr<KvStoreObserver> observer)103 Status MockSingleKvStore::UnSubscribeKvStore(SubscribeType subscribeType, std::shared_ptr<KvStoreObserver> observer)
104 {
105     return Status::SUCCESS;
106 }
107 
RegisterSyncCallback(std::shared_ptr<KvStoreSyncCallback> callback)108 Status MockSingleKvStore::RegisterSyncCallback(std::shared_ptr<KvStoreSyncCallback> callback)
109 {
110     return Status::SUCCESS;
111 }
112 
UnRegisterSyncCallback()113 Status MockSingleKvStore::UnRegisterSyncCallback()
114 {
115     return Status::SUCCESS;
116 }
117 
PutBatch(const std::vector<Entry> & entries)118 Status MockSingleKvStore::PutBatch(const std::vector<Entry> &entries)
119 {
120     return Status::SUCCESS;
121 }
122 
DeleteBatch(const std::vector<Key> & keys)123 Status MockSingleKvStore::DeleteBatch(const std::vector<Key> &keys)
124 {
125     return Status::SUCCESS;
126 }
127 
StartTransaction()128 Status MockSingleKvStore::StartTransaction()
129 {
130     return Status::SUCCESS;
131 }
132 
Commit()133 Status MockSingleKvStore::Commit()
134 {
135     return Status::SUCCESS;
136 }
137 
Rollback()138 Status MockSingleKvStore::Rollback()
139 {
140     return Status::SUCCESS;
141 }
142 
SetSyncParam(const KvSyncParam & syncParam)143 Status MockSingleKvStore::SetSyncParam(const KvSyncParam &syncParam)
144 {
145     return Status::SUCCESS;
146 }
147 
GetSyncParam(KvSyncParam & syncParam)148 Status MockSingleKvStore::GetSyncParam(KvSyncParam &syncParam)
149 {
150     return Status::SUCCESS;
151 }
152 
SetCapabilityEnabled(bool enabled) const153 Status MockSingleKvStore::SetCapabilityEnabled(bool enabled) const
154 {
155     return Status::SUCCESS;
156 }
157 
SetCapabilityRange(const std::vector<std::string> & localLabels,const std::vector<std::string> & remoteSupportLabels) const158 Status MockSingleKvStore::SetCapabilityRange(
159     const std::vector<std::string> &localLabels, const std::vector<std::string> &remoteSupportLabels) const
160 {
161     return Status::SUCCESS;
162 }
163 
GetSecurityLevel(SecurityLevel & securityLevel) const164 Status MockSingleKvStore::GetSecurityLevel(SecurityLevel &securityLevel) const
165 {
166     return Status::SUCCESS;
167 }
168 
Sync(const std::vector<std::string> & deviceIds,SyncMode mode,const DataQuery & query,std::shared_ptr<KvStoreSyncCallback> syncCallback)169 Status MockSingleKvStore::Sync(const std::vector<std::string> &deviceIds, SyncMode mode,
170     const DataQuery &query, std::shared_ptr<KvStoreSyncCallback> syncCallback)
171 {
172     return Status::SUCCESS;
173 }
174 
SubscribeWithQuery(const std::vector<std::string> & deviceIds,const DataQuery & query)175 Status MockSingleKvStore::SubscribeWithQuery(const std::vector<std::string> &deviceIds, const DataQuery &query)
176 {
177     return Status::SUCCESS;
178 }
179 
UnsubscribeWithQuery(const std::vector<std::string> & deviceIds,const DataQuery & query)180 Status MockSingleKvStore::UnsubscribeWithQuery(const std::vector<std::string> &deviceIds, const DataQuery &query)
181 {
182     return Status::SUCCESS;
183 }
184 
Backup(const std::string & file,const std::string & baseDir)185 Status MockSingleKvStore::Backup(const std::string &file, const std::string &baseDir)
186 {
187     return Status::SUCCESS;
188 }
189 
Restore(const std::string & file,const std::string & baseDir)190 Status MockSingleKvStore::Restore(const std::string &file, const std::string &baseDir)
191 {
192     return Status::SUCCESS;
193 }
194 
DeleteBackup(const std::vector<std::string> & files,const std::string & baseDir,std::map<std::string,DistributedKv::Status> & status)195 Status MockSingleKvStore::DeleteBackup(
196     const std::vector<std::string> &files, const std::string &baseDir,
197     std::map<std::string, DistributedKv::Status> &status)
198 {
199     return Status::SUCCESS;
200 }
201 }  // namespace DistributedKv
202 }  // namespace OHOS
203