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