| 15 | } |
| 16 | |
| 17 | void ExtenderProtocol::ProcessExtenderMessage(net::MessageContext& context, net::MessageWrapper & msg) |
| 18 | { |
| 19 | switch (msg.msg_case()) { |
| 20 | case net::MessageWrapper::kPostLua: |
| 21 | { |
| 22 | if (gExtender->GetServer().HasExtensionState()) { |
| 23 | auto& postMsg = msg.post_lua(); |
| 24 | esv::LuaServerPin pin(esv::ExtensionState::Get()); |
| 25 | if (pin) { |
| 26 | pin->OnNetMessageReceived(postMsg.channel_name(), postMsg.payload(), postMsg.module(), |
| 27 | postMsg.request_id(), postMsg.reply_id(), context.UserID, |
| 28 | postMsg.serializer() == net::SerializerType::SERIALIZER_BINARY); |
| 29 | } |
| 30 | } |
| 31 | break; |
| 32 | } |
| 33 | |
| 34 | case net::MessageWrapper::kC2SExtenderHello: |
| 35 | { |
| 36 | auto const& hello = msg.c2s_extender_hello(); |
| 37 | DEBUG("Got extender support notification from user %d (version %d)", context.UserID.Id, hello.version()); |
| 38 | gExtender->GetServer().GetNetworkManager().AllowExtenderMessages(context.UserID.GetPeerId(), (net::ProtoVersion)hello.version()); |
| 39 | break; |
| 40 | } |
| 41 | |
| 42 | case net::MessageWrapper::kUserVars: |
| 43 | { |
| 44 | SyncUserVars(msg.user_vars()); |
| 45 | break; |
| 46 | } |
| 47 | |
| 48 | default: |
| 49 | OsiErrorS("Unknown extension message type received!"); |
| 50 | } |
| 51 | } |
| 52 | |
| 53 | void NetworkManager::Reset() |
| 54 | { |
nothing calls this directly
no test coverage detected