1 /*
2 * Copyright (c) 2023-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
16 #include "distributed_file_daemon_manager_impl.h"
17
18 #include "asset/asset_adapter_sa_client.h"
19 #include "copy/file_copy_manager.h"
20 #include "copy/file_size_utils.h"
21 #include "dfs_error.h"
22 #include "distributed_file_daemon_proxy.h"
23 #include "utils_log.h"
24
25 #undef LOG_DOMAIN
26 #undef LOG_TAG
27 #define LOG_DOMAIN 0xD004315
28 #define LOG_TAG "distributedfile_daemon"
29
30 namespace OHOS {
31 namespace Storage {
32 namespace DistributedFile {
33 using namespace OHOS::Storage;
GetInstance()34 DistributedFileDaemonManagerImpl &DistributedFileDaemonManagerImpl::GetInstance()
35 {
36 static DistributedFileDaemonManagerImpl instance;
37 return instance;
38 };
39
OpenP2PConnection(const DistributedHardware::DmDeviceInfo & deviceInfo)40 int32_t DistributedFileDaemonManagerImpl::OpenP2PConnection(const DistributedHardware::DmDeviceInfo &deviceInfo)
41 {
42 auto distributedFileDaemonProxy = DistributedFileDaemonProxy::GetInstance();
43 if (!distributedFileDaemonProxy) {
44 LOGE("proxy is null");
45
46 return OHOS::FileManagement::E_SA_LOAD_FAILED;
47 }
48 return distributedFileDaemonProxy->OpenP2PConnection(deviceInfo);
49 }
50
CloseP2PConnection(const DistributedHardware::DmDeviceInfo & deviceInfo)51 int32_t DistributedFileDaemonManagerImpl::CloseP2PConnection(const DistributedHardware::DmDeviceInfo &deviceInfo)
52 {
53 auto distributedFileDaemonProxy = DistributedFileDaemonProxy::GetInstance();
54 if (!distributedFileDaemonProxy) {
55 LOGE("proxy is null");
56
57 return OHOS::FileManagement::E_SA_LOAD_FAILED;
58 }
59 return distributedFileDaemonProxy->CloseP2PConnection(deviceInfo);
60 }
61
OpenP2PConnectionEx(const std::string & networkId,sptr<IFileDfsListener> remoteReverseObj)62 int32_t DistributedFileDaemonManagerImpl::OpenP2PConnectionEx(const std::string &networkId,
63 sptr<IFileDfsListener> remoteReverseObj)
64 {
65 auto distributedFileDaemonProxy = DistributedFileDaemonProxy::GetInstance();
66 if (!distributedFileDaemonProxy) {
67 LOGE("proxy is null.");
68 return OHOS::FileManagement::E_SA_LOAD_FAILED;
69 }
70 return distributedFileDaemonProxy->OpenP2PConnectionEx(networkId, remoteReverseObj);
71 }
72
CloseP2PConnectionEx(const std::string & networkId)73 int32_t DistributedFileDaemonManagerImpl::CloseP2PConnectionEx(const std::string &networkId)
74 {
75 auto distributedFileDaemonProxy = DistributedFileDaemonProxy::GetInstance();
76 if (!distributedFileDaemonProxy) {
77 LOGE("proxy is null.");
78 return OHOS::FileManagement::E_SA_LOAD_FAILED;
79 }
80 return distributedFileDaemonProxy->CloseP2PConnectionEx(networkId);
81 }
82
PrepareSession(const std::string & srcUri,const std::string & dstUri,const std::string & srcDeviceId,const sptr<IRemoteObject> & listener,HmdfsInfo & info)83 int32_t DistributedFileDaemonManagerImpl::PrepareSession(const std::string &srcUri,
84 const std::string &dstUri,
85 const std::string &srcDeviceId,
86 const sptr<IRemoteObject> &listener,
87 HmdfsInfo &info)
88 {
89 auto distributedFileDaemonProxy = DistributedFileDaemonProxy::GetInstance();
90 if (distributedFileDaemonProxy == nullptr) {
91 LOGE("proxy is null");
92 return OHOS::FileManagement::E_SA_LOAD_FAILED;
93 }
94 return distributedFileDaemonProxy->PrepareSession(srcUri, dstUri, srcDeviceId, listener, info);
95 }
96
RequestSendFile(const std::string & srcUri,const std::string & dstPath,const std::string & remoteDeviceId,const std::string & sessionName)97 int32_t DistributedFileDaemonManagerImpl::RequestSendFile(const std::string &srcUri,
98 const std::string &dstPath,
99 const std::string &remoteDeviceId,
100 const std::string &sessionName)
101 {
102 auto distributedFileDaemonProxy = DistributedFileDaemonProxy::GetInstance();
103 if (distributedFileDaemonProxy == nullptr) {
104 LOGE("proxy is null");
105 return OHOS::FileManagement::E_SA_LOAD_FAILED;
106 }
107 return distributedFileDaemonProxy->RequestSendFile(srcUri, dstPath, remoteDeviceId, sessionName);
108 }
109
GetRemoteCopyInfo(const std::string & srcUri,bool & isFile,bool & isDir)110 int32_t DistributedFileDaemonManagerImpl::GetRemoteCopyInfo(const std::string &srcUri, bool &isFile, bool &isDir)
111 {
112 auto distributedFileDaemonProxy = DistributedFileDaemonProxy::GetInstance();
113 if (distributedFileDaemonProxy == nullptr) {
114 LOGE("proxy is null");
115 return OHOS::FileManagement::E_SA_LOAD_FAILED;
116 }
117 return distributedFileDaemonProxy->GetRemoteCopyInfo(srcUri, isFile, isDir);
118 }
119
CancelCopyTask(const std::string & sessionName)120 int32_t DistributedFileDaemonManagerImpl::CancelCopyTask(const std::string &sessionName)
121 {
122 auto distributedFileDaemonProxy = DistributedFileDaemonProxy::GetInstance();
123 if (distributedFileDaemonProxy == nullptr) {
124 LOGE("proxy is null");
125 return OHOS::FileManagement::E_SA_LOAD_FAILED;
126 }
127 return distributedFileDaemonProxy->CancelCopyTask(sessionName);
128 }
129
CancelCopyTask(const std::string & srcUri,const std::string & dstUri)130 int32_t DistributedFileDaemonManagerImpl::CancelCopyTask(const std::string &srcUri, const std::string &dstUri)
131 {
132 auto distributedFileDaemonProxy = DistributedFileDaemonProxy::GetInstance();
133 if (distributedFileDaemonProxy == nullptr) {
134 LOGE("proxy is null");
135 return OHOS::FileManagement::E_SA_LOAD_FAILED;
136 }
137 return distributedFileDaemonProxy->CancelCopyTask(srcUri, dstUri);
138 }
139
PushAsset(int32_t userId,const sptr<AssetObj> & assetObj,const sptr<IAssetSendCallback> & sendCallback)140 int32_t DistributedFileDaemonManagerImpl::PushAsset(int32_t userId,
141 const sptr<AssetObj> &assetObj,
142 const sptr<IAssetSendCallback> &sendCallback)
143 {
144 LOGI("DistributedFileDaemonManagerImpl PushAsset enter.");
145 auto distributedFileDaemonProxy = DistributedFileDaemonProxy::GetInstance();
146 if (distributedFileDaemonProxy == nullptr) {
147 LOGE("proxy is null");
148 return OHOS::FileManagement::E_SA_LOAD_FAILED;
149 }
150 return distributedFileDaemonProxy->PushAsset(userId, assetObj, sendCallback);
151 }
152
GetDfsSwitchStatus(const std::string & networkId,int32_t & switchStatus)153 int32_t DistributedFileDaemonManagerImpl::GetDfsSwitchStatus(const std::string &networkId, int32_t &switchStatus)
154 {
155 auto distributedFileDaemonProxy = DistributedFileDaemonProxy::GetInstance();
156 if (distributedFileDaemonProxy == nullptr) {
157 LOGE("proxy is null");
158 return OHOS::FileManagement::E_SA_LOAD_FAILED;
159 }
160 return distributedFileDaemonProxy->GetDfsSwitchStatus(networkId, switchStatus);
161 }
162
UpdateDfsSwitchStatus(int32_t switchStatus)163 int32_t DistributedFileDaemonManagerImpl::UpdateDfsSwitchStatus(int32_t switchStatus)
164 {
165 auto distributedFileDaemonProxy = DistributedFileDaemonProxy::GetInstance();
166 if (distributedFileDaemonProxy == nullptr) {
167 LOGE("proxy is null");
168 return OHOS::FileManagement::E_SA_LOAD_FAILED;
169 }
170 return distributedFileDaemonProxy->UpdateDfsSwitchStatus(switchStatus);
171 }
172
GetConnectedDeviceList(std::vector<DfsDeviceInfo> & deviceList)173 int32_t DistributedFileDaemonManagerImpl::GetConnectedDeviceList(std::vector<DfsDeviceInfo> &deviceList)
174 {
175 auto distributedFileDaemonProxy = DistributedFileDaemonProxy::GetInstance();
176 if (distributedFileDaemonProxy == nullptr) {
177 LOGE("proxy is null");
178 return OHOS::FileManagement::E_SA_LOAD_FAILED;
179 }
180 return distributedFileDaemonProxy->GetConnectedDeviceList(deviceList);
181 }
182
RegisterAssetCallback(const sptr<IAssetRecvCallback> & recvCallback)183 int32_t DistributedFileDaemonManagerImpl::RegisterAssetCallback(const sptr<IAssetRecvCallback> &recvCallback)
184 {
185 LOGI("DistributedFileDaemonManagerImpl registerAssetCallback enter.");
186
187 if (recvCallback == nullptr) {
188 LOGE("Register IAssetRecvCallback is null.");
189 return OHOS::FileManagement::E_NULLPTR;
190 }
191 int32_t ret = AssetAdapterSaClient::GetInstance().AddListener(recvCallback);
192 if (ret != OHOS::FileManagement::E_OK) {
193 LOGE("AssetAdapterSaClient addListener fail.");
194 return ret;
195 }
196 return OHOS::FileManagement::E_OK;
197 }
198
UnRegisterAssetCallback(const sptr<IAssetRecvCallback> & recvCallback)199 int32_t DistributedFileDaemonManagerImpl::UnRegisterAssetCallback(const sptr<IAssetRecvCallback> &recvCallback)
200 {
201 LOGI("DistributedFileDaemonManagerImpl unRegisterAssetCallback enter.");
202 if (recvCallback == nullptr) {
203 LOGE("UnRegister IAssetRecvCallback is null.");
204 return OHOS::FileManagement::E_NULLPTR;
205 }
206 int32_t ret = AssetAdapterSaClient::GetInstance().RemoveListener(recvCallback);
207 if (ret != OHOS::FileManagement::E_OK) {
208 LOGE("AssetAdapterSaClient removeListener fail.");
209 return ret;
210 }
211 return OHOS::FileManagement::E_OK;
212 }
213
GetSize(const std::string & uri,bool isSrcUri,uint64_t & size)214 int32_t DistributedFileDaemonManagerImpl::GetSize(const std::string &uri, bool isSrcUri, uint64_t &size)
215 {
216 return FileSizeUtils::GetSize(uri, isSrcUri, size);
217 }
218
IsDirectory(const std::string & uri,bool isSrcUri,bool & isDirectory)219 int32_t DistributedFileDaemonManagerImpl::IsDirectory(const std::string &uri, bool isSrcUri, bool &isDirectory)
220 {
221 return FileSizeUtils::IsDirectory(uri, isSrcUri, isDirectory);
222 }
223
Copy(const std::string & srcUri,const std::string & destUri,ProcessCallback processCallback)224 int32_t DistributedFileDaemonManagerImpl::Copy(const std::string &srcUri,
225 const std::string &destUri, ProcessCallback processCallback)
226 {
227 return FileCopyManager::GetInstance()->Copy(srcUri, destUri, processCallback);
228 }
229
Cancel(const std::string & srcUri,const std::string & destUri)230 int32_t DistributedFileDaemonManagerImpl::Cancel(const std::string &srcUri, const std::string &destUri)
231 {
232 return FileCopyManager::GetInstance()->Cancel(srcUri, destUri);
233 }
234
Cancel()235 int32_t DistributedFileDaemonManagerImpl::Cancel()
236 {
237 return FileCopyManager::GetInstance()->Cancel();
238 }
239 } // namespace DistributedFile
240 } // namespace Storage
241 } // namespace OHOS
242