diff options
| -rw-r--r-- | server.c | 40 |
1 files changed, 39 insertions, 1 deletions
@@ -35,9 +35,11 @@ static void server_handle_client_data(server_t *server, struct epoll_event *event); static void server_handle_server_data(server_t *server, struct epoll_event *event); static void server_client_msg_dipatcher(server_t *server, client_t *client); +static void server_on_nick_msg(server_t *server, client_t *client, string_view_t msg); static void server_on_user_msg(server_t *server, client_t *client, string_view_t msg); static void server_on_ping_msg(server_t *server, client_t *client, string_view_t msg); static void server_on_privmsg_msg(server_t *server, client_t *client, string_view_t msg); +static void server_on_join_msg(server_t *server, client_t *client, string_view_t msg); void server_init(server_t *server, uint32_t port) @@ -216,12 +218,18 @@ server_handle_client_data(server_t *server, struct epoll_event *event) static void server_client_msg_dipatcher(server_t *server, client_t *client) { - string_view_t msg = string_view_from_cstr(client->msg_buf); + string_view_t msg; + msg = string_view_from_cstr(client->msg_buf); + msg = string_view_chop_by_delim(&msg, '\r'); + string_view_t msg_type = string_view_chop_by_delim(&msg, ' '); if (msg_type.size == 0) { return; } + if (string_view_eq(msg_type, string_view_from_cstr("NICK"))) { + return server_on_nick_msg(server, client, msg); + } if (string_view_eq(msg_type, string_view_from_cstr("USER"))) { return server_on_user_msg(server, client, msg); } @@ -231,6 +239,9 @@ server_client_msg_dipatcher(server_t *server, client_t *client) if (string_view_eq(msg_type, string_view_from_cstr("PRIVMSG"))) { return server_on_privmsg_msg(server, client, msg); } + if (string_view_eq(msg_type, string_view_from_cstr("JOIN"))) { + return server_on_join_msg(server, client, msg); + } } static void @@ -247,6 +258,18 @@ server_on_user_msg(server_t *server, } static void +server_on_nick_msg(server_t *server, + client_t *client, + string_view_t msg) +{ + hash_table_remove(server->client_table, client->nick); + + sprintf(client->nick, SVFMT, SVARG(&msg)); + + hash_table_insert(server->client_table, client->nick, client); +} + +static void server_on_ping_msg(server_t *server, client_t *client, string_view_t msg) @@ -274,3 +297,18 @@ server_on_privmsg_msg(server_t *server, string_view_chop_by_delim(&msg, ':'); client_send_msg(client_receiver, ":%s PRIVMSG %s :%.*s\n", client->nick, client_receiver->nick, msg.size, msg.data); } + +static void +server_on_join_msg(server_t *server, + client_t *client, + string_view_t msg) +{ + // FIXME: Create server channel hash_table + client_send_msg( + client, + ":%s!~%s@localhost JOIN "SVFMT"\n", + client->nick, + client->nick, + SVARG(&msg) + ); +} |