1 /*
2 * Copyright (C) 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 "advanced_datashare_observer.h"
17
18 #include "ans_log_wrapper.h"
19 #include "if_system_ability_manager.h"
20 #include "iservice_registry.h"
21 #include "system_ability_definition.h"
22
23 namespace OHOS {
24 namespace Notification {
25 namespace {
26 constexpr const char *SETTING_URI_PROXY =
27 "datashare:///com.ohos.settingsdata/entry/settingsdata/SETTINGSDATA?Proxy=true";
28 constexpr const char *SETTINGS_DATASHARE_URI =
29 "datashare:///com.ohos.settingsdata/entry/settingsdata/USER_SETTINGSDATA_SECURE_100?Proxy=true";
30 constexpr const char *SETTINGS_DATA_EXT_URI = "datashare:///com.ohos.settingsdata.DataAbility";
31 constexpr const int32_t E_OK = 0;
32 constexpr const int32_t E_DATA_SHARE_NOT_READY = 1055;
33 } // namespace
34
35 AdvancedDatashareObserver::AdvancedDatashareObserver() = default;
36 AdvancedDatashareObserver::~AdvancedDatashareObserver() = default;
37
CreateDataShareHelper()38 std::shared_ptr<DataShare::DataShareHelper> AdvancedDatashareObserver::CreateDataShareHelper()
39 {
40 sptr<ISystemAbilityManager> saManager = SystemAbilityManagerClient::GetInstance().GetSystemAbilityManager();
41 if (saManager == nullptr) {
42 ANS_LOGE("The sa manager is nullptr.");
43 return nullptr;
44 }
45 sptr<IRemoteObject> remoteObj = saManager->GetSystemAbility(ADVANCED_NOTIFICATION_SERVICE_ABILITY_ID);
46 if (remoteObj == nullptr) {
47 ANS_LOGE("The remoteObj is nullptr.");
48 return nullptr;
49 }
50 return DataShare::DataShareHelper::Creator(remoteObj, SETTINGS_DATASHARE_URI, SETTINGS_DATA_EXT_URI);
51 }
52
UnRegisterSettingsObserver(const Uri & uri,const sptr<AAFwk::IDataAbilityObserver> & dataObserver)53 void AdvancedDatashareObserver::UnRegisterSettingsObserver(
54 const Uri &uri, const sptr<AAFwk::IDataAbilityObserver> &dataObserver)
55 {
56 std::shared_ptr<DataShare::DataShareHelper> settingHelper = CreateDataShareHelper();
57 if (settingHelper == nullptr) {
58 ANS_LOGE("UnRegister settings observer failed by nullptr");
59 return;
60 }
61 settingHelper->UnregisterObserver(uri, dataObserver);
62 }
63
RegisterSettingsObserver(const Uri & uri,const sptr<AAFwk::IDataAbilityObserver> & dataObserver)64 void AdvancedDatashareObserver::RegisterSettingsObserver(
65 const Uri &uri, const sptr<AAFwk::IDataAbilityObserver> &dataObserver)
66 {
67 ANS_LOGD("AdvancedDatashareObserver::RegisterSettingsObserver enter");
68 std::shared_ptr<DataShare::DataShareHelper> settingHelper = CreateDataShareHelper();
69 if (settingHelper == nullptr) {
70 ANS_LOGE("Register settings observer by nullptr");
71 return;
72 }
73 settingHelper->RegisterObserver(uri, dataObserver);
74 settingHelper->Release();
75 }
76
CheckIfSettingsDataReady()77 bool AdvancedDatashareObserver::CheckIfSettingsDataReady()
78 {
79 if (isDataShareReady_) {
80 return true;
81 }
82 sptr<ISystemAbilityManager> saManager = SystemAbilityManagerClient::GetInstance().GetSystemAbilityManager();
83 if (saManager == nullptr) {
84 ANS_LOGE("The sa manager is nullptr.");
85 return false;
86 }
87 sptr<IRemoteObject> remoteObj = saManager->GetSystemAbility(ADVANCED_NOTIFICATION_SERVICE_ABILITY_ID);
88 if (remoteObj == nullptr) {
89 ANS_LOGE("The remoteObj is nullptr.");
90 return false;
91 }
92 std::pair<int, std::shared_ptr<DataShare::DataShareHelper>> ret =
93 DataShare::DataShareHelper::Create(remoteObj, SETTING_URI_PROXY, SETTINGS_DATA_EXT_URI);
94 ANS_LOGI("create data_share helper, ret=%{public}d", ret.first);
95 if (ret.first == E_OK) {
96 ANS_LOGI("create data_share helper success");
97 auto helper = ret.second;
98 if (helper != nullptr) {
99 bool releaseRet = helper->Release();
100 ANS_LOGI("release data_share helper, releaseRet=%{public}d", releaseRet);
101 }
102 isDataShareReady_ = true;
103 return true;
104 } else if (ret.first == E_DATA_SHARE_NOT_READY) {
105 isDataShareReady_ = false;
106 return false;
107 }
108 ANS_LOGI("data_share unknown.");
109 return true;
110 }
111
112 } // namespace Notification
113 } // namespace OHOS
114