1 /*
2 * Copyright (c) 2023-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 #include "connection_subscriber.h"
16
17 #include "res_sched_log.h"
18 #include "res_sched_mgr.h"
19 #include "res_type.h"
20
21 namespace OHOS {
22 namespace ResourceSchedule {
MarshallingConnectionData( const AbilityRuntime::ConnectionData& data, nlohmann::json &payload)23 void ConnectionSubscriber::MarshallingConnectionData(
24 const AbilityRuntime::ConnectionData& data, nlohmann::json &payload)
25 {
26 payload["extensionPid"] = data.extensionPid;
27 payload["extensionUid"] = data.extensionUid;
28 payload["extensionBundleName"] = data.extensionBundleName;
29 payload["extensionModuleName"] = data.extensionModuleName;
30 payload["extensionName"] = data.extensionName;
31 payload["extensionType"] = static_cast<uint32_t>(data.extensionType);
32 payload["callerUid"] = data.callerUid;
33 payload["callerPid"] = data.callerPid;
34 payload["callerName"] = data.callerName;
35 }
36
OnExtensionConnected(const AbilityRuntime::ConnectionData& data)37 void ConnectionSubscriber::OnExtensionConnected(const AbilityRuntime::ConnectionData& data)
38 {
39 RESSCHED_LOGI("Ressched ConnectionSubscriber OnExtensionConnected");
40 nlohmann::json payload;
41 MarshallingConnectionData(data, payload);
42 ResSchedMgr::GetInstance().ReportData(
43 ResType::RES_TYPE_CONNECTION_OBSERVER, ResType::ConnectionObserverStatus::EXTENSION_CONNECTED, payload);
44 }
45
OnExtensionDisconnected(const AbilityRuntime::ConnectionData& data)46 void ConnectionSubscriber::OnExtensionDisconnected(const AbilityRuntime::ConnectionData& data)
47 {
48 RESSCHED_LOGI("Ressched ConnectionSubscriber OnExtensionDisconnected");
49 nlohmann::json payload;
50 MarshallingConnectionData(data, payload);
51 ResSchedMgr::GetInstance().ReportData(
52 ResType::RES_TYPE_CONNECTION_OBSERVER, ResType::ConnectionObserverStatus::EXTENSION_DISCONNECTED, payload);
53 }
54
MarshallingDlpStateData(const AbilityRuntime::DlpStateData& data, nlohmann::json &payload)55 void ConnectionSubscriber::MarshallingDlpStateData(const AbilityRuntime::DlpStateData& data, nlohmann::json &payload)
56 {
57 payload["targetPid"] = data.targetPid;
58 payload["targetUid"] = data.targetUid;
59 payload["targetBundleName"] = data.targetBundleName;
60 payload["targetModuleName"] = data.targetModuleName;
61 payload["targetAbilityName"] = data.targetAbilityName;
62 payload["callerUid"] = data.callerUid;
63 payload["callerPid"] = data.callerPid;
64 payload["callerName"] = data.callerName;
65 }
66
OnDlpAbilityOpened(const AbilityRuntime::DlpStateData& data)67 void ConnectionSubscriber::OnDlpAbilityOpened(const AbilityRuntime::DlpStateData& data)
68 {
69 RESSCHED_LOGI("Ressched ConnectionSubscriber OnDlpAbilityOpened");
70 nlohmann::json payload;
71 MarshallingDlpStateData(data, payload);
72 ResSchedMgr::GetInstance().ReportData(
73 ResType::RES_TYPE_CONNECTION_OBSERVER, ResType::ConnectionObserverStatus::DLP_ABILITY_OPENED, payload);
74 }
75
OnDlpAbilityClosed(const AbilityRuntime::DlpStateData& data)76 void ConnectionSubscriber::OnDlpAbilityClosed(const AbilityRuntime::DlpStateData& data)
77 {
78 RESSCHED_LOGI("Ressched ConnectionSubscriber OnDlpAbilityClosed");
79 nlohmann::json payload;
80 MarshallingDlpStateData(data, payload);
81 ResSchedMgr::GetInstance().ReportData(
82 ResType::RES_TYPE_CONNECTION_OBSERVER, ResType::ConnectionObserverStatus::DLP_ABILITY_CLOSED, payload);
83 }
84
OnServiceDied()85 void ConnectionSubscriber::OnServiceDied()
86 {}
87 } // namespace ResourceSchedule
88 } // namespace OHOS
89