1fb299fa2Sopenharmony_ci/*
2fb299fa2Sopenharmony_ci * Copyright (c) 2023 Huawei Device Co., Ltd.
3fb299fa2Sopenharmony_ci * Licensed under the Apache License, Version 2.0 (the "License");
4fb299fa2Sopenharmony_ci * you may not use this file except in compliance with the License.
5fb299fa2Sopenharmony_ci * You may obtain a copy of the License at
6fb299fa2Sopenharmony_ci *
7fb299fa2Sopenharmony_ci *     http://www.apache.org/licenses/LICENSE-2.0
8fb299fa2Sopenharmony_ci *
9fb299fa2Sopenharmony_ci * Unless required by applicable law or agreed to in writing, software
10fb299fa2Sopenharmony_ci * distributed under the License is distributed on an "AS IS" BASIS,
11fb299fa2Sopenharmony_ci * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12fb299fa2Sopenharmony_ci * See the License for the specific language governing permissions and
13fb299fa2Sopenharmony_ci * limitations under the License.
14fb299fa2Sopenharmony_ci */
15fb299fa2Sopenharmony_ci#ifndef UPDATER_EVENT_H
16fb299fa2Sopenharmony_ci#define UPDATER_EVENT_H
17fb299fa2Sopenharmony_ci
18fb299fa2Sopenharmony_ci#include <functional>
19fb299fa2Sopenharmony_ci#include <string>
20fb299fa2Sopenharmony_ci#include <map>
21fb299fa2Sopenharmony_ci#include <mutex>
22fb299fa2Sopenharmony_ci#include <vector>
23fb299fa2Sopenharmony_ci
24fb299fa2Sopenharmony_ci#include "event_id.h"
25fb299fa2Sopenharmony_ci
26fb299fa2Sopenharmony_cinamespace Updater {
27fb299fa2Sopenharmony_ciclass UpdaterEvent {
28fb299fa2Sopenharmony_ci    using EventHandler = std::function<void()>;
29fb299fa2Sopenharmony_cipublic:
30fb299fa2Sopenharmony_ci    static void Subscribe(enum EventId id, EventHandler handler)
31fb299fa2Sopenharmony_ci    {
32fb299fa2Sopenharmony_ci        std::unique_lock<std::mutex> lock(mutex_);
33fb299fa2Sopenharmony_ci        eventMap_[id].push_back(handler);
34fb299fa2Sopenharmony_ci    }
35fb299fa2Sopenharmony_ci    static void Invoke(enum EventId id)
36fb299fa2Sopenharmony_ci    {
37fb299fa2Sopenharmony_ci        std::unique_lock<std::mutex> lock(mutex_);
38fb299fa2Sopenharmony_ci        for (const auto &handler : eventMap_[id]) {
39fb299fa2Sopenharmony_ci            if (handler != nullptr) {
40fb299fa2Sopenharmony_ci                handler();
41fb299fa2Sopenharmony_ci            }
42fb299fa2Sopenharmony_ci        }
43fb299fa2Sopenharmony_ci    }
44fb299fa2Sopenharmony_ciprivate:
45fb299fa2Sopenharmony_ci    static inline std::mutex mutex_ {};
46fb299fa2Sopenharmony_ci    static inline std::map<enum EventId, std::vector<EventHandler>> eventMap_ {};
47fb299fa2Sopenharmony_ci};
48fb299fa2Sopenharmony_ci} // Updater
49fb299fa2Sopenharmony_ci#endif // UPDATER_EVENT_H