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 RegisterChange(napi_env env, napi_callback_info info); 62 static napi_value UnregisterChange(napi_env env, napi_callback_info info); 63 64 static std::string GetBundleName(const napi_env &env, const LibN::NFuncArg &funcArg); CloudSyncNapi(napi_env env,napi_value exports)65 CloudSyncNapi(napi_env env, napi_value exports) : NExporter(env, exports) {}; 66 ~CloudSyncNapi() = default; 67 68 private: 69 static bool CheckRef(napi_env env, napi_ref ref, ChangeListenerNapi &listObj, const std::string &uri); 70 static int32_t RegisterToObs(napi_env env, const RegisterParams ®isterParams); 71 static napi_value UnregisterFromObs(napi_env env, const std::string &uri); 72 static inline std::shared_ptr<CloudSyncCallbackImpl> callback_; 73 std::string className_; 74 static std::mutex sOnOffMutex_; 75 }; 76 77 class CloudSyncCallbackImpl : public CloudSyncCallback, public std::enable_shared_from_this<CloudSyncCallbackImpl> { 78 public: 79 CloudSyncCallbackImpl(napi_env env, napi_value fun); 80 ~CloudSyncCallbackImpl() = default; 81 void OnSyncStateChanged(SyncType type, SyncPromptState state) override; 82 void OnSyncStateChanged(CloudSyncState state, ErrorType error) override; 83 void DeleteReference(); 84 85 class UvChangeMsg { 86 public: UvChangeMsg(std::shared_ptr<CloudSyncCallbackImpl> cloudSyncCallbackIn,CloudSyncState state,ErrorType error)87 UvChangeMsg(std::shared_ptr<CloudSyncCallbackImpl> cloudSyncCallbackIn, CloudSyncState state, ErrorType error) 88 : cloudSyncCallback_(cloudSyncCallbackIn), state_(state), error_(error) 89 { 90 } ~UvChangeMsg()91 ~UvChangeMsg() {} 92 std::weak_ptr<CloudSyncCallbackImpl> cloudSyncCallback_; 93 CloudSyncState state_; 94 ErrorType error_; 95 }; 96 97 private: 98 static void OnComplete(UvChangeMsg *msg); 99 napi_env env_; 100 napi_ref cbOnRef_ = nullptr; 101 }; 102 103 class ChangeListenerNapi { 104 public: 105 class UvChangeMsg { 106 public: UvChangeMsg(napi_env env,napi_ref ref,AAFwk::ChangeInfo & changeInfo,std::string strUri)107 UvChangeMsg(napi_env env, napi_ref ref, AAFwk::ChangeInfo &changeInfo, std::string strUri) 108 : env_(env), ref_(ref), changeInfo_(changeInfo), strUri_(std::move(strUri)) 109 { 110 data_ = nullptr; 111 } ~UvChangeMsg()112 ~UvChangeMsg() {} 113 napi_env env_; 114 napi_ref ref_; 115 AAFwk::ChangeInfo changeInfo_; 116 uint8_t *data_; 117 std::string strUri_; 118 }; 119 ChangeListenerNapi(napi_env env)120 explicit ChangeListenerNapi(napi_env env) : env_(env) {} 121 ChangeListenerNapi(const ChangeListenerNapi & listener)122 ChangeListenerNapi(const ChangeListenerNapi &listener) 123 { 124 this->env_ = listener.env_; 125 this->cbOnRef_ = listener.cbOnRef_; 126 this->cbOffRef_ = listener.cbOffRef_; 127 this->observers_ = listener.observers_; 128 } 129 130 ChangeListenerNapi &operator=(const ChangeListenerNapi &listener) 131 { 132 this->env_ = listener.env_; 133 this->cbOnRef_ = listener.cbOnRef_; 134 this->cbOffRef_ = listener.cbOffRef_; 135 this->observers_ = listener.observers_; 136 return *this; 137 } 138 ~ChangeListenerNapi()139 ~ChangeListenerNapi(){}; 140 void OnChange(CloudChangeListener &listener, const napi_ref cbRef); 141 int32_t UvQueueWork(uv_loop_s *loop, uv_work_t *work); 142 static napi_value SolveOnChange(napi_env env, UvChangeMsg *msg); 143 napi_ref cbOnRef_ = nullptr; 144 napi_ref cbOffRef_ = nullptr; 145 std::vector<std::shared_ptr<CloudNotifyObserver>> observers_; 146 147 private: 148 napi_env env_ = nullptr; 149 }; 150 151 class CloudNotifyObserver { 152 public: CloudNotifyObserver(const ChangeListenerNapi & listObj,std::string uri,napi_ref ref)153 CloudNotifyObserver(const ChangeListenerNapi &listObj, std::string uri, napi_ref ref) 154 : listObj_(listObj), uri_(uri), ref_(ref) 155 { 156 } 157 ~CloudNotifyObserver() = default; 158 159 void OnChange(); 160 void OnchangeExt(const AAFwk::ChangeInfo &changeInfo); 161 162 ChangeListenerNapi listObj_; 163 std::string uri_; 164 napi_ref ref_; 165 }; 166 } // namespace OHOS::FileManagement::CloudSync 167 #endif // OHOS_FILEMGMT_CLOUD_SYNC_NAPI_H 168