1 /*
2  * Copyright (c) 2022 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 OHOS_ABILITY_RUNTIME_APP_STATE_OBSERVER_MANAGER_H
17 #define OHOS_ABILITY_RUNTIME_APP_STATE_OBSERVER_MANAGER_H
18 
19 #include <map>
20 #include <mutex>
21 #include <set>
22 #include <string>
23 
24 #include "ability_foreground_state_observer_interface.h"
25 #include "app_foreground_state_observer_interface.h"
26 #include "app_running_record.h"
27 #include "app_state_data.h"
28 #include "cpp/mutex.h"
29 #include "iapp_state_callback.h"
30 #include "iapplication_state_observer.h"
31 #include "page_state_data.h"
32 #include "permission_constants.h"
33 #include "permission_verification.h"
34 #include "singleton.h"
35 #include "task_handler_wrap.h"
36 #include "uri_permission_manager_client.h"
37 
38 namespace OHOS {
39 namespace AppExecFwk {
40 using AppStateObserverMap = std::map<sptr<IApplicationStateObserver>, std::vector<std::string>>;
41 using AppForegroundStateObserverSet = std::set<sptr<IAppForegroundStateObserver>>;
42 using AbilityforegroundObserverSet = std::set<sptr<IAbilityForegroundStateObserver>>;
43 
44 enum class ObserverType {
45     APPLICATION_STATE_OBSERVER,
46     APP_FOREGROUND_STATE_OBSERVER,
47     ABILITY_FOREGROUND_STATE_OBSERVER,
48 };
49 class AppStateObserverManager : public std::enable_shared_from_this<AppStateObserverManager> {
50     DECLARE_DELAYED_SINGLETON(AppStateObserverManager)
51 public:
52     void Init();
53     int32_t RegisterApplicationStateObserver(const sptr<IApplicationStateObserver> &observer,
54         const std::vector<std::string> &bundleNameList = {});
55     int32_t UnregisterApplicationStateObserver(const sptr<IApplicationStateObserver> &observer);
56     int32_t RegisterAppForegroundStateObserver(const sptr<IAppForegroundStateObserver> &observer);
57     int32_t UnregisterAppForegroundStateObserver(const sptr<IAppForegroundStateObserver> &observer);
58     int32_t RegisterAbilityForegroundStateObserver(const sptr<IAbilityForegroundStateObserver> &observer);
59     int32_t UnregisterAbilityForegroundStateObserver(const sptr<IAbilityForegroundStateObserver> &observer);
60     void StateChangedNotifyObserver(
61         const AbilityStateData abilityStateData, bool isAbility, bool isFromWindowFocusChanged);
62     void OnAppStateChanged(const std::shared_ptr<AppRunningRecord> &appRecord, const ApplicationState state,
63         bool needNotifyApp, bool isFromWindowFocusChanged);
64     void OnAppStarted(const std::shared_ptr<AppRunningRecord> &appRecord);
65     void OnAppStopped(const std::shared_ptr<AppRunningRecord> &appRecord);
66     void OnProcessCreated(const std::shared_ptr<AppRunningRecord> &appRecord, bool isPreload);
67     void OnProcessStateChanged(const std::shared_ptr<AppRunningRecord> &appRecord);
68     void OnRenderProcessCreated(const std::shared_ptr<RenderRecord> &RenderRecord);
69     void OnChildProcessCreated(std::shared_ptr<ChildProcessRecord> childRecord);
70     void OnProcessDied(const std::shared_ptr<AppRunningRecord> &appRecord);
71     void OnRenderProcessDied(const std::shared_ptr<RenderRecord> &renderRecord);
72     void OnChildProcessDied(std::shared_ptr<ChildProcessRecord> childRecord);
73     void OnProcessReused(const std::shared_ptr<AppRunningRecord> &appRecord);
74     void OnPageShow(const PageStateData pageStateData);
75     void OnPageHide(const PageStateData pageStateData);
76     void OnAppCacheStateChanged(const std::shared_ptr<AppRunningRecord> &appRecord, ApplicationState state);
77 private:
78     void HandleAppStateChanged(const std::shared_ptr<AppRunningRecord> &appRecord, const ApplicationState state,
79         bool needNotifyApp, bool isFromWindowFocusChanged);
80     void HandleOnAppStarted(const std::shared_ptr<AppRunningRecord> &appRecord);
81     void HandleOnAppStopped(const std::shared_ptr<AppRunningRecord> &appRecord);
82     void HandleStateChangedNotifyObserver(
83         const AbilityStateData abilityStateData, bool isAbility, bool isFromWindowFocusChanged);
84     void HandleOnAppProcessCreated(const std::shared_ptr<AppRunningRecord> &appRecord, bool isPreload);
85     void HandleOnRenderProcessCreated(const std::shared_ptr<RenderRecord> &RenderRecord);
86     void HandleOnChildProcessCreated(std::shared_ptr<ChildProcessRecord> childRecord);
87     void HandleOnAppProcessDied(const std::shared_ptr<AppRunningRecord> &appRecord);
88     void HandleOnRenderProcessDied(const std::shared_ptr<RenderRecord> &RenderRecord);
89     void HandleOnChildProcessDied(std::shared_ptr<ChildProcessRecord> childRecord);
90     bool ObserverExist(const sptr<IRemoteBroker> &observer);
91     bool IsAppForegroundObserverExist(const sptr<IRemoteBroker> &observer);
92     bool IsAbilityForegroundObserverExist(const sptr<IRemoteBroker> &observer);
93     void AddObserverDeathRecipient(const sptr<IRemoteBroker> &observer, const ObserverType &type);
94     void RemoveObserverDeathRecipient(const sptr<IRemoteBroker> &observer);
95     AppStateObserverMap GetAppStateObserverMapCopy();
96     AppForegroundStateObserverSet GetAppForegroundStateObserverSetCopy();
97     AbilityforegroundObserverSet GetAbilityforegroundObserverSetCopy();
98     ProcessData WrapProcessData(const std::shared_ptr<AppRunningRecord> &appRecord);
99     ProcessData WrapRenderProcessData(const std::shared_ptr<RenderRecord> &renderRecord);
100     int32_t WrapChildProcessData(ProcessData &processData, std::shared_ptr<ChildProcessRecord> childRecord);
101     void OnObserverDied(const wptr<IRemoteObject> &remote, const ObserverType &type);
102     AppStateData WrapAppStateData(const std::shared_ptr<AppRunningRecord> &appRecord,
103     const ApplicationState state);
104     void HandleOnProcessCreated(const ProcessData &data);
105     void HandleOnProcessStateChanged(const std::shared_ptr<AppRunningRecord> &appRecord);
106     void HandleOnProcessDied(const ProcessData &data);
107     void HandleOnProcessResued(const std::shared_ptr<AppRunningRecord> &appRecord);
108     void HandleOnPageShow(const PageStateData pageStateData);
109     void HandleOnPageHide(const PageStateData pageStateData);
110     void HandleOnAppCacheStateChanged(const std::shared_ptr<AppRunningRecord> &appRecord, ApplicationState state);
111 
112 private:
113     std::shared_ptr<AAFwk::TaskHandlerWrap> handler_;
114     int32_t dummyCode_ = 0;
115     ffrt::mutex observerLock_;
116     AppStateObserverMap appStateObserverMap_;
117     ffrt::mutex appForegroundObserverLock_;
118     AppForegroundStateObserverSet appForegroundStateObserverSet_;
119     ffrt::mutex abilityforegroundObserverLock_;
120     AbilityforegroundObserverSet abilityforegroundObserverSet_;
121     ffrt::mutex recipientMapMutex_;
122     std::map<sptr<IRemoteObject>, sptr<IRemoteObject::DeathRecipient>> recipientMap_;
123 };
124 }  // namespace AppExecFwk
125 }  // namespace OHOS
126 #endif  // OHOS_ABILITY_RUNTIME_APP_STATE_OBSERVER_MANAGER_H
127