From 020167df08c535a71b7c265af14a132e46890afe Mon Sep 17 00:00:00 2001
From: Koncord <stas5978@gmail.com>
Date: Sat, 1 Apr 2017 02:35:34 +0800
Subject: [PATCH] [Server] Add PlayerProcessor

---
 apps/openmw-mp/CMakeLists.txt      |  2 ++
 apps/openmw-mp/PlayerProcessor.cpp | 39 ++++++++++++++++++++++++++++++
 apps/openmw-mp/PlayerProcessor.hpp | 35 +++++++++++++++++++++++++++
 3 files changed, 76 insertions(+)
 create mode 100644 apps/openmw-mp/PlayerProcessor.cpp
 create mode 100644 apps/openmw-mp/PlayerProcessor.hpp

diff --git a/apps/openmw-mp/CMakeLists.txt b/apps/openmw-mp/CMakeLists.txt
index 6bf7be1c6..c4d65f179 100644
--- a/apps/openmw-mp/CMakeLists.txt
+++ b/apps/openmw-mp/CMakeLists.txt
@@ -79,6 +79,8 @@ set(SERVER
     Script/Functions/Spells.cpp Script/Functions/Timer.cpp Script/Functions/Positions.cpp
     Script/Functions/Cells.cpp Script/Functions/World.cpp Script/Functions/Miscellaneous.cpp
 
+    PlayerProcessor.cpp
+
     Script/API/TimerAPI.cpp Script/API/PublicFnAPI.cpp
         ${PawnScript_Sources}
         ${LuaScript_Sources}
diff --git a/apps/openmw-mp/PlayerProcessor.cpp b/apps/openmw-mp/PlayerProcessor.cpp
new file mode 100644
index 000000000..e5b34e0e1
--- /dev/null
+++ b/apps/openmw-mp/PlayerProcessor.cpp
@@ -0,0 +1,39 @@
+//
+// Created by koncord on 31.03.17.
+//
+
+#include "PlayerProcessor.hpp"
+#include "Networking.hpp"
+//#include <boost/foreach.hpp>
+
+using namespace mwmp;
+
+PlayerProcessor::processors_t PlayerProcessor::processors;
+
+void PlayerProcessor::AddProcessor(PlayerProcessor *processor) noexcept
+{
+    for(auto &p : processors)
+    {
+        if(processor->packetID == p.first)
+            throw std::logic_error("processor " + p.second->strPacketID + " already registered. Check " +
+                                           processor->className + " and " + p.second->className);
+    }
+    processors.insert(processors_t::value_type(processor->GetPacketID(), processor));
+}
+
+bool PlayerProcessor::Process(RakNet::Packet &packet) noexcept
+{
+    //BOOST_FOREACH(processors_t::value_type &processor, processors)
+    for(auto &processor : processors)
+    {
+        if(processor.first == packet.data[0])
+        {
+            Player *player = Players::getPlayer(packet.guid);
+            PlayerPacket *myPacket = Networking::get().getPlayerController()->GetPacket(packet.data[0]);
+
+            processor.second->Do(*myPacket, *player);
+            return true;
+        }
+    }
+    return false;
+}
\ No newline at end of file
diff --git a/apps/openmw-mp/PlayerProcessor.hpp b/apps/openmw-mp/PlayerProcessor.hpp
new file mode 100644
index 000000000..e4ac344db
--- /dev/null
+++ b/apps/openmw-mp/PlayerProcessor.hpp
@@ -0,0 +1,35 @@
+//
+// Created by koncord on 31.03.17.
+//
+
+#ifndef OPENMW_BASEPLAYERPROCESSOR_HPP
+#define OPENMW_BASEPLAYERPROCESSOR_HPP
+
+#include <components/openmw-mp/Base/BasePacketProcessor.hpp>
+#include <components/openmw-mp/Packets/BasePacket.hpp>
+#include <components/openmw-mp/NetworkMessages.hpp>
+#include <unordered_map>
+#include <memory>
+//#include <boost/unordered_map.hpp>
+//#include <boost/shared_ptr.hpp>
+#include "Player.hpp"
+
+namespace mwmp
+{
+    class PlayerProcessor : public BasePacketProcessor
+    {
+    public:
+
+        virtual void Do(PlayerPacket &packet, Player &player) = 0;
+
+        static bool Process(RakNet::Packet &packet) noexcept;
+        static void AddProcessor(PlayerProcessor *processor) noexcept;
+
+        //typedef boost::unordered_map<unsigned char, boost::shared_ptr<PlayerProcessor> > processors_t;
+        typedef std::unordered_map<unsigned char, std::unique_ptr<PlayerProcessor> > processors_t;
+    private:
+        static processors_t processors;
+    };
+}
+
+#endif //OPENMW_BASEPLAYERPROCESSOR_HPP