1f857971dSopenharmony_ci/*
2f857971dSopenharmony_ci * Copyright (c) 2022-2023 Huawei Device Co., Ltd.
3f857971dSopenharmony_ci * Licensed under the Apache License, Version 2.0 (the "License");
4f857971dSopenharmony_ci * you may not use this file except in compliance with the License.
5f857971dSopenharmony_ci * You may obtain a copy of the License at
6f857971dSopenharmony_ci *
7f857971dSopenharmony_ci *     http://www.apache.org/licenses/LICENSE-2.0
8f857971dSopenharmony_ci *
9f857971dSopenharmony_ci * Unless required by applicable law or agreed to in writing, software
10f857971dSopenharmony_ci * distributed under the License is distributed on an "AS IS" BASIS,
11f857971dSopenharmony_ci * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12f857971dSopenharmony_ci * See the License for the specific language governing permissions and
13f857971dSopenharmony_ci * limitations under the License.
14f857971dSopenharmony_ci */
15f857971dSopenharmony_ci
16f857971dSopenharmony_ci#ifndef MSG_HANDLER_H
17f857971dSopenharmony_ci#define MSG_HANDLER_H
18f857971dSopenharmony_ci
19f857971dSopenharmony_ci#include <functional>
20f857971dSopenharmony_ci#include <map>
21f857971dSopenharmony_ci#include <string>
22f857971dSopenharmony_ci
23f857971dSopenharmony_ci#include "proto.h"
24f857971dSopenharmony_ci
25f857971dSopenharmony_cinamespace OHOS {
26f857971dSopenharmony_cinamespace Msdp {
27f857971dSopenharmony_cinamespace DeviceStatus {
28f857971dSopenharmony_citemplate<typename K, typename V>
29f857971dSopenharmony_ciclass MsgHandler {
30f857971dSopenharmony_cipublic:
31f857971dSopenharmony_ci    struct MsgCallback {
32f857971dSopenharmony_ci        K id;
33f857971dSopenharmony_ci        V fun;
34f857971dSopenharmony_ci    };
35f857971dSopenharmony_ci
36f857971dSopenharmony_cipublic:
37f857971dSopenharmony_ci    void Clear()
38f857971dSopenharmony_ci    {
39f857971dSopenharmony_ci        callbacks_.clear();
40f857971dSopenharmony_ci    }
41f857971dSopenharmony_ci    bool CheckKey(K id)
42f857971dSopenharmony_ci    {
43f857971dSopenharmony_ci        return (GetMsgCallback(id) != nullptr);
44f857971dSopenharmony_ci    }
45f857971dSopenharmony_ci
46f857971dSopenharmony_ci    const std::string& GetDebugInfo() const
47f857971dSopenharmony_ci    {
48f857971dSopenharmony_ci        std::string str;
49f857971dSopenharmony_ci        for (auto &iter : callbacks_) {
50f857971dSopenharmony_ci            str += std::to_string(iter.first);
51f857971dSopenharmony_ci            str += ',';
52f857971dSopenharmony_ci        }
53f857971dSopenharmony_ci        if (!str.empty()) {
54f857971dSopenharmony_ci            str.resize(str.size() - 1);
55f857971dSopenharmony_ci        }
56f857971dSopenharmony_ci
57f857971dSopenharmony_ci        return std::move(str);
58f857971dSopenharmony_ci    }
59f857971dSopenharmony_ci
60f857971dSopenharmony_ci    bool RegisterEvent(MsgCallback& msg)
61f857971dSopenharmony_ci    {
62f857971dSopenharmony_ci        auto it = callbacks_.find(msg.id);
63f857971dSopenharmony_ci        if (it != callbacks_.end()) {
64f857971dSopenharmony_ci            return false;
65f857971dSopenharmony_ci        }
66f857971dSopenharmony_ci        callbacks_[msg.id] = msg.fun;
67f857971dSopenharmony_ci        return true;
68f857971dSopenharmony_ci    }
69f857971dSopenharmony_ci
70f857971dSopenharmony_ciprotected:
71f857971dSopenharmony_ci    virtual ~MsgHandler() = default;
72f857971dSopenharmony_ci    V *GetMsgCallback(K id)
73f857971dSopenharmony_ci    {
74f857971dSopenharmony_ci        auto iter = callbacks_.find(id);
75f857971dSopenharmony_ci        if (iter == callbacks_.end()) {
76f857971dSopenharmony_ci            return nullptr;
77f857971dSopenharmony_ci        }
78f857971dSopenharmony_ci        return &iter->second;
79f857971dSopenharmony_ci    }
80f857971dSopenharmony_ci
81f857971dSopenharmony_ciprotected:
82f857971dSopenharmony_ci    std::map<K, V> callbacks_;
83f857971dSopenharmony_ci};
84f857971dSopenharmony_ci} // namespace DeviceStatus
85f857971dSopenharmony_ci} // namespace Msdp
86f857971dSopenharmony_ci} // namespace OHOS
87f857971dSopenharmony_ci#endif // MSG_HANDLER_H
88