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 #ifndef OHOS_FILEMGMT_CLOUD_SYNC_NAPI_H 17 #define OHOS_FILEMGMT_CLOUD_SYNC_NAPI_H 18 19 #include "cloud_sync_callback.h" 20 #include "data_ability_observer_interface.h" 21 #include "data_ability_observer_stub.h" 22 #include "dataobs_mgr_client.h" 23 #include "filemgmt_libn.h" 24 #include "uv.h" 25 26 namespace OHOS::FileManagement::CloudSync { 27 const int32_t ARGS_ONE = 1; 28 29 struct BundleEntity { 30 std::string bundleName_; BundleEntityBundleEntity31 explicit BundleEntity(const std::string bundleName): bundleName_(bundleName){}; 32 }; 33 34 struct CloudChangeListener { 35 NotifyType notifyType; 36 AAFwk::ChangeInfo changeInfo; 37 std::string strUri; 38 }; 39 40 struct RegisterParams { 41 std::string uri; 42 bool recursion; 43 napi_ref cbOnRef; 44 }; 45 46 class CloudSyncCallbackImpl; 47 class ChangeListenerNapi; 48 class CloudNotifyObserver; 49 class CloudSyncNapi : public LibN::NExporter { 50 public: 51 void SetClassName(const std::string classname); 52 std::string GetClassName() override; 53 bool Export() override; 54 bool ToExport(std::vector<napi_property_descriptor> props); 55 static napi_value Constructor(napi_env env, napi_callback_info info); 56 57 static napi_value Start(napi_env env, napi_callback_info info); 58 static napi_value Stop(napi_env env, napi_callback_info info); 59 static napi_value OnCallback(napi_env env, napi_callback_info info); 60 static napi_value OffCallback(napi_env env, napi_callback_info info); 61 static napi_value GetFileSyncState(napi_env env, napi_callback_info info); 62 static napi_value RegisterChange(napi_env env, napi_callback_info info); 63 static napi_value UnregisterChange(napi_env env, napi_callback_info info); 64 static napi_value OptimizeStorage(napi_env env, napi_callback_info info); 65 66 static std::string GetBundleName(const napi_env &env, const LibN::NFuncArg &funcArg); CloudSyncNapi(napi_env env,napi_value exports)67 CloudSyncNapi(napi_env env, napi_value exports) : NExporter(env, exports) {}; 68 ~CloudSyncNapi() = default; 69 70 private: 71 static bool CheckRef(napi_env env, napi_ref ref, ChangeListenerNapi &listObj, const std::string &uri); 72 static int32_t RegisterToObs(napi_env env, const RegisterParams ®isterParams); 73 static napi_value UnregisterFromObs(napi_env env, const std::string &uri); 74 static inline std::shared_ptr<CloudSyncCallbackImpl> callback_; 75 std::string className_; 76 static std::mutex sOnOffMutex_; 77 }; 78 79 class CloudSyncCallbackImpl : public CloudSyncCallback, public std::enable_shared_from_this<CloudSyncCallbackImpl> { 80 public: 81 CloudSyncCallbackImpl(napi_env env, napi_value fun); 82 ~CloudSyncCallbackImpl() = default; 83 void OnSyncStateChanged(SyncType type, SyncPromptState state) override; 84 void OnSyncStateChanged(CloudSyncState state, ErrorType error) override; 85 void DeleteReference(); 86 87 class UvChangeMsg { 88 public: UvChangeMsg(std::shared_ptr<CloudSyncCallbackImpl> cloudSyncCallbackIn,CloudSyncState state,ErrorType error)89 UvChangeMsg(std::shared_ptr<CloudSyncCallbackImpl> cloudSyncCallbackIn, CloudSyncState state, ErrorType error) 90 : cloudSyncCallback_(cloudSyncCallbackIn), state_(state), error_(error) 91 { 92 } ~UvChangeMsg()93 ~UvChangeMsg() {} 94 std::weak_ptr<CloudSyncCallbackImpl> cloudSyncCallback_; 95 CloudSyncState state_; 96 ErrorType error_; 97 }; 98 99 private: 100 static void OnComplete(UvChangeMsg *msg); 101 napi_env env_; 102 napi_ref cbOnRef_ = nullptr; 103 }; 104 105 class ChangeListenerNapi { 106 public: 107 class UvChangeMsg { 108 public: UvChangeMsg(napi_env env,napi_ref ref,AAFwk::ChangeInfo & changeInfo,std::string strUri)109 UvChangeMsg(napi_env env, napi_ref ref, AAFwk::ChangeInfo &changeInfo, std::string strUri) 110 : env_(env), ref_(ref), changeInfo_(changeInfo), strUri_(std::move(strUri)) 111 { 112 data_ = nullptr; 113 } ~UvChangeMsg()114 ~UvChangeMsg() {} 115 napi_env env_; 116 napi_ref ref_; 117 AAFwk::ChangeInfo changeInfo_; 118 uint8_t *data_; 119 std::string strUri_; 120 }; 121 ChangeListenerNapi(napi_env env)122 explicit ChangeListenerNapi(napi_env env) : env_(env) {} 123 ChangeListenerNapi(const ChangeListenerNapi & listener)124 ChangeListenerNapi(const ChangeListenerNapi &listener) 125 { 126 this->env_ = listener.env_; 127 this->cbOnRef_ = listener.cbOnRef_; 128 this->cbOffRef_ = listener.cbOffRef_; 129 this->observers_ = listener.observers_; 130 } 131 132 ChangeListenerNapi &operator=(const ChangeListenerNapi &listener) 133 { 134 this->env_ = listener.env_; 135 this->cbOnRef_ = listener.cbOnRef_; 136 this->cbOffRef_ = listener.cbOffRef_; 137 this->observers_ = listener.observers_; 138 return *this; 139 } 140 ~ChangeListenerNapi()141 ~ChangeListenerNapi(){}; 142 void OnChange(CloudChangeListener &listener, const napi_ref cbRef); 143 int32_t UvQueueWork(uv_loop_s *loop, uv_work_t *work); 144 static napi_value SolveOnChange(napi_env env, UvChangeMsg *msg); 145 napi_ref cbOnRef_ = nullptr; 146 napi_ref cbOffRef_ = nullptr; 147 std::vector<std::shared_ptr<CloudNotifyObserver>> observers_; 148 149 private: 150 napi_env env_ = nullptr; 151 }; 152 153 class CloudNotifyObserver { 154 public: CloudNotifyObserver(const ChangeListenerNapi & listObj,std::string uri,napi_ref ref)155 CloudNotifyObserver(const ChangeListenerNapi &listObj, std::string uri, napi_ref ref) 156 : listObj_(listObj), uri_(uri), ref_(ref) 157 { 158 } 159 ~CloudNotifyObserver() = default; 160 161 void OnChange(); 162 void OnchangeExt(const AAFwk::ChangeInfo &changeInfo); 163 164 ChangeListenerNapi listObj_; 165 std::string uri_; 166 napi_ref ref_; 167 }; 168 } // namespace OHOS::FileManagement::CloudSync 169 #endif // OHOS_FILEMGMT_CLOUD_SYNC_NAPI_H 170