1 /* 2 * Copyright (c) 2021 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 RUNTIME_CONTEXT_H 17 #define RUNTIME_CONTEXT_H 18 19 #include <cstdint> 20 #include <functional> 21 #include <string> 22 23 #include "auto_launch.h" 24 #include "auto_launch_export.h" 25 #include "cloud/icloud_data_translate.h" 26 #include "icommunicator_aggregator.h" 27 #include "iprocess_system_api_adapter.h" 28 #include "ithread_pool.h" 29 #include "kv_store_observer.h" 30 #include "kvdb_properties.h" 31 #include "macro_utils.h" 32 #include "notification_chain.h" 33 #include "types_export.h" 34 35 namespace DistributedDB { 36 using TimerId = uint64_t; 37 using TimerAction = std::function<int(TimerId timerId)>; 38 using TimerFinalizer = std::function<void(void)>; 39 using TaskAction = std::function<void(void)>; 40 using TimeChangedAction = std::function<void(void *)>; 41 using TimeFinalizeAction = std::function<void(void)>; 42 using LockStatusNotifier = std::function<void(void *isLocked)>; 43 using UserChangedAction = std::function<void(void *)>; 44 45 class RuntimeContext { 46 public: 47 DISABLE_COPY_ASSIGN_MOVE(RuntimeContext); 48 49 // Global setting interfaces. 50 virtual void SetProcessLabel(const std::string &label) = 0; 51 virtual std::string GetProcessLabel() const = 0; 52 53 // If the pre adapter is not nullptr, set new adapter will release the pre adapter, 54 // must be called after SetCommunicatorAggregator 55 virtual int SetCommunicatorAdapter(IAdapter *adapter) = 0; 56 virtual int GetCommunicatorAggregator(ICommunicatorAggregator *&outAggregator) = 0; 57 virtual void SetCommunicatorAggregator(ICommunicatorAggregator *inAggregator) = 0; 58 virtual int GetLocalIdentity(std::string &outTarget) = 0; 59 60 // Timer interfaces. 61 virtual int SetTimer(int milliSeconds, const TimerAction &action, 62 const TimerFinalizer &finalizer, TimerId &timerId) = 0; 63 virtual int ModifyTimer(TimerId timerId, int milliSeconds) = 0; 64 virtual void RemoveTimer(TimerId timerId, bool wait = false) = 0; 65 66 // Task interfaces. 67 virtual int ScheduleTask(const TaskAction &task) = 0; 68 virtual int ScheduleQueuedTask(const std::string &queueTag, 69 const TaskAction &task) = 0; 70 71 // Shrink as much memory as possible. 72 virtual void ShrinkMemory(const std::string &description) = 0; 73 74 // Register a time changed lister, it will be callback when local time changed. 75 virtual NotificationChain::Listener *RegisterTimeChangedLister(const TimeChangedAction &action, 76 const TimeFinalizeAction &finalize, int &errCode) = 0; 77 78 // Get the global context object(singleton), never return nullptr. 79 static RuntimeContext *GetInstance(); 80 81 virtual int SetPermissionCheckCallback(const PermissionCheckCallback &callback) = 0; 82 83 virtual int SetPermissionCheckCallback(const PermissionCheckCallbackV2 &callback) = 0; 84 85 virtual int SetPermissionCheckCallback(const PermissionCheckCallbackV3 &callback) = 0; 86 87 virtual int RunPermissionCheck(const PermissionCheckParam ¶m, uint8_t flag) const = 0; 88 89 virtual int EnableKvStoreAutoLaunch(const KvDBProperties &properties, AutoLaunchNotifier notifier, 90 const AutoLaunchOption &option) = 0; 91 92 virtual int DisableKvStoreAutoLaunch(const std::string &normalIdentifier, const std::string &dualTupleIdentifier, 93 const std::string &userId) = 0; 94 95 virtual void GetAutoLaunchSyncDevices(const std::string &identifier, std::vector<std::string> &devices) const = 0; 96 97 virtual void SetAutoLaunchRequestCallback(const AutoLaunchRequestCallback &callback, DBTypeInner type) = 0; 98 99 virtual NotificationChain::Listener *RegisterLockStatusLister(const LockStatusNotifier &action, int &errCode) = 0; 100 101 virtual bool IsAccessControlled() const = 0; 102 103 virtual int SetSecurityOption(const std::string &filePath, const SecurityOption &option) const = 0; 104 105 virtual int GetSecurityOption(const std::string &filePath, SecurityOption &option) const = 0; 106 107 virtual bool CheckDeviceSecurityAbility(const std::string &devId, const SecurityOption &option) const = 0; 108 109 virtual int SetProcessSystemApiAdapter(const std::shared_ptr<IProcessSystemApiAdapter> &adapter) = 0; 110 111 virtual bool IsProcessSystemApiAdapterValid() const = 0; 112 113 virtual bool IsCommunicatorAggregatorValid() const = 0; 114 115 // Notify TIME_CHANGE_EVENT. 116 virtual void NotifyTimestampChanged(TimeOffset offset) const = 0; 117 118 virtual void SetStoreStatusNotifier(const StoreStatusNotifier ¬ifier) = 0; 119 120 virtual void NotifyDatabaseStatusChange(const std::string &userId, const std::string &appId, 121 const std::string &storeId, const std::string &deviceId, bool onlineStatus) = 0; 122 123 virtual int SetSyncActivationCheckCallback(const SyncActivationCheckCallback &callback) = 0; 124 125 virtual int SetSyncActivationCheckCallback(const SyncActivationCheckCallbackV2 &callback) = 0; 126 127 virtual bool IsSyncerNeedActive(const DBProperties &properties) const = 0; 128 129 virtual NotificationChain::Listener *RegisterUserChangedListener(const UserChangedAction &action, 130 EventType event) = 0; 131 132 virtual int NotifyUserChanged() const = 0; 133 134 // Generate global sessionId in current process 135 virtual uint32_t GenerateSessionId() = 0; 136 137 virtual void DumpCommonInfo(int fd) = 0; 138 139 virtual void CloseAutoLaunchConnection(DBTypeInner type, const DBProperties &properties) = 0; 140 141 virtual int SetPermissionConditionCallback(const PermissionConditionCallback &callback) = 0; 142 143 virtual std::map<std::string, std::string> GetPermissionCheckParam(const DBProperties &properties) = 0; 144 145 virtual void StopTaskPool() = 0; 146 147 virtual void StopTimeTickMonitorIfNeed() = 0; 148 149 virtual void SetTranslateToDeviceIdCallback(const TranslateToDeviceIdCallback &callback) = 0; 150 151 virtual int TranslateDeviceId(const std::string &deviceId, 152 const StoreInfo &info, std::string &newDeviceId) = 0; 153 154 virtual bool ExistTranslateDevIdCallback() const = 0; 155 156 virtual void SetThreadPool(const std::shared_ptr<IThreadPool> &threadPool) = 0; 157 158 virtual std::shared_ptr<IThreadPool> GetThreadPool() const = 0; 159 160 virtual void SetCloudTranslate(const std::shared_ptr<ICloudDataTranslate> &dataTranslate) = 0; 161 virtual int AssetToBlob(const Asset &asset, std::vector<uint8_t> &blob) = 0; 162 virtual int AssetsToBlob(const Assets &assets, std::vector<uint8_t> &blob) = 0; 163 virtual int BlobToAsset(const std::vector<uint8_t> &blob, Asset &asset) = 0; 164 virtual int BlobToAssets(std::vector<uint8_t> &blob, Assets &assets) = 0; 165 protected: 166 RuntimeContext() = default; ~RuntimeContext()167 virtual ~RuntimeContext() {} 168 }; 169 } // namespace DistributedDB 170 171 #endif // RUNTIME_CONTEXT_H 172