xref: /aosp_15_r20/external/openscreen/cast/common/channel/namespace_router.cc (revision 3f982cf4871df8771c9d4abe6e9a6f8d829b2736)
1*3f982cf4SFabien Sanglard // Copyright 2019 The Chromium Authors. All rights reserved.
2*3f982cf4SFabien Sanglard // Use of this source code is governed by a BSD-style license that can be
3*3f982cf4SFabien Sanglard // found in the LICENSE file.
4*3f982cf4SFabien Sanglard 
5*3f982cf4SFabien Sanglard #include "cast/common/channel/namespace_router.h"
6*3f982cf4SFabien Sanglard 
7*3f982cf4SFabien Sanglard #include "cast/common/channel/proto/cast_channel.pb.h"
8*3f982cf4SFabien Sanglard 
9*3f982cf4SFabien Sanglard namespace openscreen {
10*3f982cf4SFabien Sanglard namespace cast {
11*3f982cf4SFabien Sanglard 
12*3f982cf4SFabien Sanglard NamespaceRouter::NamespaceRouter() = default;
13*3f982cf4SFabien Sanglard NamespaceRouter::~NamespaceRouter() = default;
14*3f982cf4SFabien Sanglard 
AddNamespaceHandler(std::string namespace_,CastMessageHandler * handler)15*3f982cf4SFabien Sanglard void NamespaceRouter::AddNamespaceHandler(std::string namespace_,
16*3f982cf4SFabien Sanglard                                           CastMessageHandler* handler) {
17*3f982cf4SFabien Sanglard   handlers_.emplace(std::move(namespace_), handler);
18*3f982cf4SFabien Sanglard }
19*3f982cf4SFabien Sanglard 
RemoveNamespaceHandler(const std::string & namespace_)20*3f982cf4SFabien Sanglard void NamespaceRouter::RemoveNamespaceHandler(const std::string& namespace_) {
21*3f982cf4SFabien Sanglard   handlers_.erase(namespace_);
22*3f982cf4SFabien Sanglard }
23*3f982cf4SFabien Sanglard 
OnMessage(VirtualConnectionRouter * router,CastSocket * socket,::cast::channel::CastMessage message)24*3f982cf4SFabien Sanglard void NamespaceRouter::OnMessage(VirtualConnectionRouter* router,
25*3f982cf4SFabien Sanglard                                 CastSocket* socket,
26*3f982cf4SFabien Sanglard                                 ::cast::channel::CastMessage message) {
27*3f982cf4SFabien Sanglard   const std::string& ns = message.namespace_();
28*3f982cf4SFabien Sanglard   auto it = handlers_.find(ns);
29*3f982cf4SFabien Sanglard   if (it != handlers_.end()) {
30*3f982cf4SFabien Sanglard     it->second->OnMessage(router, socket, std::move(message));
31*3f982cf4SFabien Sanglard   }
32*3f982cf4SFabien Sanglard }
33*3f982cf4SFabien Sanglard 
34*3f982cf4SFabien Sanglard }  // namespace cast
35*3f982cf4SFabien Sanglard }  // namespace openscreen
36