1 files changed, 51 insertions, 0 deletions
diff --git a/game/server/chat.cc b/game/server/chat.cc
new file mode 100644
index 0000000..709d21b
--- /dev/null
+++ b/game/server/chat.cc
@@ -0,0 +1,51 @@
+#include "server/pch.hh"
+#include "server/chat.hh"
+
+#include "server/globals.hh"
+#include "server/sessions.hh"
+#include "shared/protocol.hh"
+
+static void on_chat_message_packet(const protocol::ChatMessage &packet)
+{
+    if(packet.type == protocol::ChatMessage::TEXT_MESSAGE) {
+        if(auto session = sessions::find(packet.peer))
+            server_chat::broadcast(packet.message.c_str(), session->client_username.c_str());
+        else server_chat::broadcast(packet.message.c_str(), packet.sender.c_str());
+    }
+}
+
+void server_chat::init(void)
+{
+    globals::dispatcher.sink<protocol::ChatMessage>().connect<&on_chat_message_packet>();
+}
+
+void server_chat::broadcast(const char *message)
+{
+    server_chat::broadcast(message, "server");
+}
+
+void server_chat::broadcast(const char *message, const char *sender)
+{
+    protocol::ChatMessage packet;
+    packet.type = protocol::ChatMessage::TEXT_MESSAGE;
+    packet.message = std::string(message);
+    packet.sender = std::string(sender);
+
+    protocol::broadcast(globals::server_host, protocol::encode(packet));
+
+    spdlog::info("<{}> {}", sender, message);
+}
+
+void server_chat::send(Session *session, const char *message)
+{
+    server_chat::send(session, message, "server");
+}
+
+void server_chat::send(Session *session, const char *message, const char *sender)
+{
+    protocol::ChatMessage packet;
+    packet.type = protocol::ChatMessage::TEXT_MESSAGE;
+    packet.message = std::string(message);
+    packet.sender = std::string(sender);
+    protocol::broadcast(globals::server_host, protocol::encode(packet));
+}