1 /*
2 * Copyright (c) 2023 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 "form_data_proxy_mgr.h"
17
18 #include "fms_log_wrapper.h"
19 #include "form_bms_helper.h"
20 #include "form_data_mgr.h"
21 #include "form_data_proxy_record.h"
22 #include "form_util.h"
23 #include "form_mgr_errors.h"
24
25 namespace OHOS {
26 namespace AppExecFwk {
FormDataProxyMgr()27 FormDataProxyMgr::FormDataProxyMgr()
28 {}
29
~FormDataProxyMgr()30 FormDataProxyMgr::~FormDataProxyMgr()
31 {}
32
SubscribeFormData(int64_t formId,const std::vector<FormDataProxy> & formDataProxies,const AAFwk::Want & want)33 ErrCode FormDataProxyMgr::SubscribeFormData(int64_t formId, const std::vector<FormDataProxy> &formDataProxies,
34 const AAFwk::Want &want)
35 {
36 HILOG_DEBUG("subscribe form data. formId:%{public}s, proxy data size:%{public}zu",
37 std::to_string(formId).c_str(), formDataProxies.size());
38 if (formDataProxies.empty()) {
39 HILOG_DEBUG("empty formDataProxies");
40 return ERR_OK;
41 }
42
43 FormRecord formRecord;
44 if (!FormDataMgr::GetInstance().GetFormRecord(formId, formRecord)) {
45 HILOG_ERROR("not exist such form:%{public}" PRId64 ".", formId);
46 return ERR_APPEXECFWK_FORM_NOT_EXIST_ID;
47 }
48
49 if (!formRecord.isDataProxy) {
50 HILOG_DEBUG("not data proxy form, formId:%{public}" PRId64 ".", formId);
51 return ERR_OK;
52 }
53
54 {
55 std::lock_guard<std::mutex> lock(formDataProxyRecordMutex_);
56 auto search = formDataProxyRecordMap_.find(formId);
57 if (search != formDataProxyRecordMap_.end()) {
58 if (search->second != nullptr) {
59 HILOG_DEBUG("the form has already subscribed, formId:%{public}s", std::to_string(formId).c_str());
60 search->second->UnsubscribeFormData();
61 }
62 }
63 }
64
65 ApplicationInfo appInfo;
66 if (FormBmsHelper::GetInstance().GetApplicationInfo(formRecord.bundleName, FormUtil::GetCurrentAccountId(),
67 appInfo) != ERR_OK) {
68 HILOG_ERROR("get app info failed");
69 return ERR_APPEXECFWK_FORM_COMMON_CODE;
70 }
71 std::shared_ptr<FormDataProxyRecord> formDataProxyRecord = std::make_shared<FormDataProxyRecord>(formId,
72 formRecord.bundleName, formRecord.uiSyntax, appInfo.accessTokenId, formRecord.uid);
73 formDataProxyRecord->SetWant(want);
74 auto ret = formDataProxyRecord->SubscribeFormData(formDataProxies);
75 if (ret != ERR_OK) {
76 HILOG_ERROR("SubscribeFormData failed");
77 return ret;
78 }
79 std::lock_guard<std::mutex> lock(formDataProxyRecordMutex_);
80 formDataProxyRecordMap_[formId] = formDataProxyRecord;
81 return ERR_OK;
82 }
83
UnsubscribeFormData(int64_t formId)84 ErrCode FormDataProxyMgr::UnsubscribeFormData(int64_t formId)
85 {
86 HILOG_DEBUG("unsubscribe form data. formId:%{public}s", std::to_string(formId).c_str());
87 std::shared_ptr<FormDataProxyRecord> record = nullptr;
88 {
89 std::lock_guard<std::mutex> lock(formDataProxyRecordMutex_);
90 auto search = formDataProxyRecordMap_.find(formId);
91 if (search != formDataProxyRecordMap_.end()) {
92 record = search->second;
93 formDataProxyRecordMap_.erase(formId);
94 }
95 }
96 if (record != nullptr) {
97 record->UnsubscribeFormData();
98 }
99
100 return ERR_OK;
101 }
102
UpdateSubscribeFormData(int64_t formId,const std::vector<FormDataProxy> & formDataProxies)103 void FormDataProxyMgr::UpdateSubscribeFormData(int64_t formId, const std::vector<FormDataProxy> &formDataProxies)
104 {
105 HILOG_DEBUG("update subscribe form data. formId:%{public}s", std::to_string(formId).c_str());
106 std::lock_guard<std::mutex> lock(formDataProxyRecordMutex_);
107 auto search = formDataProxyRecordMap_.find(formId);
108 if (search != formDataProxyRecordMap_.end()) {
109 if (search->second != nullptr) {
110 search->second->UpdateSubscribeFormData(formDataProxies);
111 }
112 }
113 }
114
ProduceFormDataProxies(int64_t formId,const std::vector<FormDataProxy> & formDataProxies)115 void FormDataProxyMgr::ProduceFormDataProxies(int64_t formId, const std::vector<FormDataProxy> &formDataProxies)
116 {
117 std::lock_guard<std::mutex> lock(formDataProxiesMutex_);
118 formDataProxiesMap_[formId] = formDataProxies;
119 }
120
ConsumeFormDataProxies(int64_t formId,std::vector<FormDataProxy> & formDataProxies)121 bool FormDataProxyMgr::ConsumeFormDataProxies(int64_t formId, std::vector<FormDataProxy> &formDataProxies)
122 {
123 std::lock_guard<std::mutex> lock(formDataProxiesMutex_);
124 auto search = formDataProxiesMap_.find(formId);
125 if (search == formDataProxiesMap_.end()) {
126 HILOG_DEBUG("no form data proxies, formId:%{public}s", std::to_string(formId).c_str());
127 return false;
128 }
129 formDataProxies = search->second;
130 formDataProxiesMap_.erase(search);
131 return true;
132 }
133
EnableSubscribeFormData(const std::vector<int64_t> & formIds)134 void FormDataProxyMgr::EnableSubscribeFormData(const std::vector<int64_t> &formIds)
135 {
136 std::lock_guard<std::mutex> lock(formDataProxyRecordMutex_);
137 for (const auto &formId : formIds) {
138 auto search = formDataProxyRecordMap_.find(formId);
139 if (search != formDataProxyRecordMap_.end()) {
140 if (search->second != nullptr) {
141 search->second->EnableSubscribeFormData();
142 }
143 }
144 }
145 }
146
DisableSubscribeFormData(const std::vector<int64_t> & formIds)147 void FormDataProxyMgr::DisableSubscribeFormData(const std::vector<int64_t> &formIds)
148 {
149 std::lock_guard<std::mutex> lock(formDataProxyRecordMutex_);
150 for (const auto &formId : formIds) {
151 auto search = formDataProxyRecordMap_.find(formId);
152 if (search != formDataProxyRecordMap_.end()) {
153 if (search->second != nullptr) {
154 search->second->DisableSubscribeFormData();
155 HILOG_INFO("formId:%{public}s", std::to_string(formId).c_str());
156 }
157 }
158 }
159 }
160
RetryFailureSubscribes()161 void FormDataProxyMgr::RetryFailureSubscribes()
162 {
163 std::lock_guard<std::mutex> lock(formDataProxyRecordMutex_);
164 for (auto& record : formDataProxyRecordMap_) {
165 record.second->RetryFailureSubscribes();
166 }
167 }
168
GetFormSubscribeInfo(const int64_t formId,std::vector<std::string> & subscribedKeys,int32_t & count)169 void FormDataProxyMgr::GetFormSubscribeInfo(
170 const int64_t formId, std::vector<std::string> &subscribedKeys, int32_t &count)
171 {
172 auto search = formDataProxyRecordMap_.find(formId);
173 if (search != formDataProxyRecordMap_.end()) {
174 if (search->second != nullptr) {
175 search->second->GetFormSubscribeInfo(subscribedKeys, count);
176 }
177 }
178 }
179 } // namespace AppExecFwk
180 } // namespace OHOS
181