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