game/server/chat.cc


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

#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(std::string_view message)
{
    server_chat::broadcast(message, "server");
}

void server_chat::broadcast(std::string_view message, std::string_view sender)
{
    protocol::ChatMessage packet;
    packet.type = protocol::ChatMessage::TEXT_MESSAGE;
    packet.message = message;
    packet.sender = sender;

    protocol::broadcast(globals::server_host, protocol::encode(packet));

    spdlog::info("<{}> {}", sender, message);
}

void server_chat::send(Session* session, std::string_view message)
{
    server_chat::send(session, message, "server");
}

void server_chat::send(Session* session, std::string_view message, std::string_view sender)
{
    protocol::ChatMessage packet;
    packet.type = protocol::ChatMessage::TEXT_MESSAGE;
    packet.message = message;
    packet.sender = sender;
    protocol::broadcast(globals::server_host, protocol::encode(packet));
}