/* packet_receive.c Author: Pekka Riikonen Copyright (C) 1997 - 2000 Pekka Riikonen This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 2 of the License, or (at your option) any later version. This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. */ /* * Server packet routines to handle received packets. */ /* $Id$ */ #include "serverincludes.h" #include "server_internal.h" extern char *server_version; /* Received private message. This resolves the destination of the message and sends the packet. This is used by both server and router. If the destination is our locally connected client this sends the packet to the client. This may also send the message for further routing if the destination is not in our server (or router). */ void silc_server_private_message(SilcServer server, SilcSocketConnection sock, SilcPacketContext *packet) { SilcClientID *id; SilcServerEntry router; SilcSocketConnection dst_sock; SilcClientEntry client; SilcIDListData idata; SILC_LOG_DEBUG(("Start")); if (!packet->dst_id) goto err; /* Decode destination Client ID */ id = silc_id_str2id(packet->dst_id, SILC_ID_CLIENT); if (!id) { SILC_LOG_ERROR(("Could not decode destination Client ID, dropped")); goto err; } /* If the destination belongs to our server we don't have to route the message anywhere but to send it to the local destination. */ client = silc_idlist_find_client_by_id(server->local_list, id, NULL); if (client) { /* It exists, now deliver the message to the destination */ dst_sock = (SilcSocketConnection)client->connection; /* If we are router and the client has router then the client is in our cell but not directly connected to us. */ if (server->server_type == SILC_ROUTER && client->router) { /* We are of course in this case the client's router thus the real "router" of the client is the server who owns the client. Thus we will send the packet to that server. */ router = (SilcServerEntry)dst_sock->user_data; idata = (SilcIDListData)router; silc_server_send_private_message(server, dst_sock, idata->send_key, idata->hmac, packet); return; } /* Seems that client really is directly connected to us */ idata = (SilcIDListData)client; silc_server_send_private_message(server, dst_sock, idata->send_key, idata->hmac, packet); return; } /* Destination belongs to someone not in this server. If we are normal server our action is to send the packet to our router. */ if (server->server_type == SILC_SERVER && !server->standalone) { router = server->router; /* Send to primary route */ if (router) { dst_sock = (SilcSocketConnection)router->connection; idata = (SilcIDListData)router; silc_server_send_private_message(server, dst_sock, idata->send_key, idata->hmac, packet); } return; } /* We are router and we will perform route lookup for the destination and send the message to fastest route. */ if (server->server_type == SILC_ROUTER && !server->standalone) { /* Check first that the ID is valid */ client = silc_idlist_find_client_by_id(server->global_list, id, NULL); if (client) { dst_sock = silc_server_route_get(server, id, SILC_ID_CLIENT); router = (SilcServerEntry)dst_sock->user_data; idata = (SilcIDListData)router; /* Get fastest route and send packet. */ if (router) silc_server_send_private_message(server, dst_sock, idata->send_key, idata->hmac, packet); return; } } err: silc_server_send_error(server, sock, "No such nickname: Private message not sent"); } /* Processes incoming command reply packet. The command reply packet may be destined to one of our clients or it may directly for us. We will call the command reply routine after processing the packet. */ void silc_server_command_reply(SilcServer server, SilcSocketConnection sock, SilcPacketContext *packet) { SilcBuffer buffer = packet->buffer; SilcClientEntry client = NULL; SilcSocketConnection dst_sock; SilcIDListData idata; SilcClientID *id = NULL; SILC_LOG_DEBUG(("Start")); /* Source must be server or router */ if (packet->src_id_type != SILC_ID_SERVER && sock->type != SILC_SOCKET_TYPE_ROUTER) return; if (packet->dst_id_type == SILC_ID_CHANNEL) return; if (packet->dst_id_type == SILC_ID_CLIENT) { /* Destination must be one of ours */ id = silc_id_str2id(packet->dst_id, SILC_ID_CLIENT); client = silc_idlist_find_client_by_id(server->local_list, id, NULL); if (!client) { SILC_LOG_ERROR(("Cannot process command reply to unknown client")); silc_free(id); return; } } if (packet->dst_id_type == SILC_ID_SERVER) { /* For now this must be for us */ if (SILC_ID_SERVER_COMPARE(packet->dst_id, server->id_string)) { SILC_LOG_ERROR(("Cannot process command reply to unknown server")); return; } } /* Execute command reply locally for the command */ silc_server_command_reply_process(server, sock, buffer); if (packet->dst_id_type == SILC_ID_CLIENT && client && id) { /* Relay the packet to the client */ dst_sock = (SilcSocketConnection)client->connection; silc_buffer_push(buffer, SILC_PACKET_HEADER_LEN + packet->src_id_len + packet->dst_id_len + packet->padlen); silc_packet_send_prepare(dst_sock, 0, 0, buffer->len); silc_buffer_put(dst_sock->outbuf, buffer->data, buffer->len); idata = (SilcIDListData)client; /* Encrypt packet */ silc_packet_encrypt(idata->send_key, idata->hmac, dst_sock->outbuf, buffer->len); /* Send the packet */ silc_server_packet_send_real(server, dst_sock, TRUE); silc_free(id); } } /* Process received channel message. The message can be originated from client or server. */ void silc_server_channel_message(SilcServer server, SilcSocketConnection sock, SilcPacketContext *packet) { SilcChannelEntry channel = NULL; SilcChannelClientEntry chl; SilcChannelID *id = NULL; void *sender = NULL; SILC_LOG_DEBUG(("Processing channel message")); /* Sanity checks */ if (packet->dst_id_type != SILC_ID_CHANNEL) { SILC_LOG_DEBUG(("Received bad message for channel, dropped")); goto out; } /* Find channel entry */ id = silc_id_str2id(packet->dst_id, SILC_ID_CHANNEL); channel = silc_idlist_find_channel_by_id(server->local_list, id, NULL); if (!channel) { channel = silc_idlist_find_channel_by_id(server->global_list, id, NULL); if (!channel) { SILC_LOG_DEBUG(("Could not find channel")); goto out; } } /* See that this client is on the channel. If the message is coming from router we won't do the check as the message is from client that we don't know about. Also, if the original sender is not client (as it can be server as well) we don't do the check. */ sender = silc_id_str2id(packet->src_id, packet->src_id_type); if (sock->type != SILC_SOCKET_TYPE_ROUTER && packet->src_id_type == SILC_ID_CLIENT) { silc_list_start(channel->user_list); while ((chl = silc_list_get(channel->user_list)) != SILC_LIST_END) { if (chl->client && !SILC_ID_CLIENT_COMPARE(chl->client->id, sender)) break; } if (chl == SILC_LIST_END) goto out; } /* Distribute the packet to our local clients. This will send the packet for further routing as well, if needed. */ silc_server_packet_relay_to_channel(server, sock, channel, sender, packet->src_id_type, packet->buffer->data, packet->buffer->len, FALSE); out: if (sender) silc_free(sender); if (id) silc_free(id); } /* Received channel key packet. We distribute the key to all of our locally connected clients on the channel. */ void silc_server_channel_key(SilcServer server, SilcSocketConnection sock, SilcPacketContext *packet) { SilcBuffer buffer = packet->buffer; SilcChannelEntry channel; if (packet->src_id_type != SILC_ID_SERVER) return; /* Save the channel key */ channel = silc_server_save_channel_key(server, buffer, NULL); if (!channel) return; /* Distribute the key to everybody who is on the channel. If we are router we will also send it to locally connected servers. */ silc_server_send_channel_key(server, sock, channel, FALSE); } /* Received packet to replace a ID. This checks that the requested ID exists and replaces it with the new one. */ void silc_server_replace_id(SilcServer server, SilcSocketConnection sock, SilcPacketContext *packet) { SilcBuffer buffer = packet->buffer; unsigned char *old_id = NULL, *new_id = NULL; SilcIdType old_id_type, new_id_type; unsigned short old_id_len, new_id_len; void *id = NULL, *id2 = NULL; if (sock->type == SILC_SOCKET_TYPE_CLIENT || packet->src_id_type == SILC_ID_CLIENT) return; SILC_LOG_DEBUG(("Replacing ID")); silc_buffer_unformat(buffer, SILC_STR_UI_SHORT(&old_id_type), SILC_STR_UI16_NSTRING_ALLOC(&old_id, &old_id_len), SILC_STR_UI_SHORT(&new_id_type), SILC_STR_UI16_NSTRING_ALLOC(&new_id, &new_id_len), SILC_STR_END); if (old_id_type != new_id_type) goto out; if (old_id_len != silc_id_get_len(old_id_type) || new_id_len != silc_id_get_len(new_id_type)) goto out; id = silc_id_str2id(old_id, old_id_type); if (!id) goto out; id2 = silc_id_str2id(new_id, new_id_type); if (!id2) goto out; /* If we are router and this packet is not already broadcast packet we will broadcast it. The sending socket really cannot be router or the router is buggy. If this packet is coming from router then it must have the broadcast flag set already and we won't do anything. */ if (!server->standalone && server->server_type == SILC_ROUTER && sock->type == SILC_SOCKET_TYPE_SERVER && !(packet->flags & SILC_PACKET_FLAG_BROADCAST)) { SILC_LOG_DEBUG(("Broadcasting received Replace ID packet")); silc_server_packet_send(server, server->router->connection, packet->type, packet->flags | SILC_PACKET_FLAG_BROADCAST, buffer->data, buffer->len, FALSE); } /* Replace the old ID */ switch(old_id_type) { case SILC_ID_CLIENT: { SilcBuffer nidp, oidp; SilcClientEntry client = NULL; SILC_LOG_DEBUG(("Old Client ID id(%s)", silc_id_render(id, SILC_ID_CLIENT))); SILC_LOG_DEBUG(("New Client ID id(%s)", silc_id_render(id2, SILC_ID_CLIENT))); if ((client = silc_idlist_replace_client_id(server->local_list, id, id2)) == NULL) if (server->server_type == SILC_ROUTER) client = silc_idlist_replace_client_id(server->global_list, id, id2); if (client) { oidp = silc_id_payload_encode(id, SILC_ID_CLIENT); nidp = silc_id_payload_encode(id2, SILC_ID_CLIENT); /* Send the NICK_CHANGE notify type to local clients on the channels this client is joined to. */ silc_server_send_notify_on_channels(server, client, SILC_NOTIFY_TYPE_NICK_CHANGE, 2, oidp->data, oidp->len, nidp->data, nidp->len); silc_buffer_free(nidp); silc_buffer_free(oidp); } break; } case SILC_ID_SERVER: SILC_LOG_DEBUG(("Old Server ID id(%s)", silc_id_render(id, SILC_ID_CLIENT))); SILC_LOG_DEBUG(("New Server ID id(%s)", silc_id_render(id2, SILC_ID_CLIENT))); if (silc_idlist_replace_server_id(server->local_list, id, id2) == NULL) if (server->server_type == SILC_ROUTER) silc_idlist_replace_server_id(server->global_list, id, id2); break; case SILC_ID_CHANNEL: /* XXX Hmm... Basically this cannot occur. Channel ID's cannot be re-generated. */ silc_free(id2); break; default: silc_free(id2); break; } out: if (id) silc_free(id); if (old_id) silc_free(old_id); if (new_id) silc_free(new_id); } /* Received New Client packet and processes it. Creates Client ID for the client. Client becomes registered after calling this functions. */ SilcClientEntry silc_server_new_client(SilcServer server, SilcSocketConnection sock, SilcPacketContext *packet) { SilcBuffer buffer = packet->buffer; SilcClientEntry client; SilcIDCacheEntry cache; SilcClientID *client_id; SilcBuffer reply; SilcIDListData idata; char *username = NULL, *realname = NULL, *id_string; SILC_LOG_DEBUG(("Creating new client")); if (sock->type != SILC_SOCKET_TYPE_CLIENT) return NULL; /* Take client entry */ client = (SilcClientEntry)sock->user_data; idata = (SilcIDListData)client; /* Fetch the old client cache entry so that we can update it. */ if (!silc_idcache_find_by_context(server->local_list->clients, sock->user_data, &cache)) { SILC_LOG_ERROR(("Lost client's cache entry - bad thing")); return NULL; } /* Parse incoming packet */ silc_buffer_unformat(buffer, SILC_STR_UI16_STRING_ALLOC(&username), SILC_STR_UI16_STRING_ALLOC(&realname), SILC_STR_END); /* Create Client ID */ silc_id_create_client_id(server->id, server->rng, server->md5hash, username, &client_id); /* Update client entry */ idata->registered = TRUE; client->nickname = strdup(username); client->username = username; client->userinfo = realname; client->id = client_id; /* Update the cache entry */ cache->id = (void *)client_id; cache->type = SILC_ID_CLIENT; cache->data = username; silc_idcache_sort_by_data(server->local_list->clients); /* Notify our router about new client on the SILC network */ if (!server->standalone) silc_server_send_new_id(server, (SilcSocketConnection) server->router->connection, server->server_type == SILC_ROUTER ? TRUE : FALSE, client->id, SILC_ID_CLIENT, SILC_ID_CLIENT_LEN); /* Send the new client ID to the client. */ id_string = silc_id_id2str(client->id, SILC_ID_CLIENT); reply = silc_buffer_alloc(2 + 2 + SILC_ID_CLIENT_LEN); silc_buffer_pull_tail(reply, SILC_BUFFER_END(reply)); silc_buffer_format(reply, SILC_STR_UI_SHORT(SILC_ID_CLIENT), SILC_STR_UI_SHORT(SILC_ID_CLIENT_LEN), SILC_STR_UI_XNSTRING(id_string, SILC_ID_CLIENT_LEN), SILC_STR_END); silc_server_packet_send(server, sock, SILC_PACKET_NEW_ID, 0, reply->data, reply->len, FALSE); silc_free(id_string); silc_buffer_free(reply); /* Send some nice info to the client */ SILC_SERVER_SEND_NOTIFY(server, sock, SILC_NOTIFY_TYPE_NONE, ("Welcome to the SILC Network %s@%s", username, sock->hostname)); if (server->server_type == SILC_ROUTER) { SILC_SERVER_SEND_NOTIFY(server, sock, SILC_NOTIFY_TYPE_NONE, ("There are %d clients on %d servers in SILC " "Network", server->stat.clients, server->stat.servers)); SILC_SERVER_SEND_NOTIFY(server, sock, SILC_NOTIFY_TYPE_NONE, ("There are %d clients on %d server in our cell", server->stat.cell_clients, server->stat.cell_servers)); SILC_SERVER_SEND_NOTIFY(server, sock, SILC_NOTIFY_TYPE_NONE, ("I have %d clients, %d channels, %d servers and " "%d routers", server->stat.my_clients, server->stat.my_channels, server->stat.my_servers, server->stat.my_routers)); SILC_SERVER_SEND_NOTIFY(server, sock, SILC_NOTIFY_TYPE_NONE, ("%d server operators and %d router operators " "online", server->stat.my_server_ops, server->stat.my_router_ops)); } else { SILC_SERVER_SEND_NOTIFY(server, sock, SILC_NOTIFY_TYPE_NONE, ("I have %d clients and %d channels formed", server->stat.my_clients, server->stat.my_channels)); SILC_SERVER_SEND_NOTIFY(server, sock, SILC_NOTIFY_TYPE_NONE, ("%d operators online", server->stat.my_server_ops)); } SILC_SERVER_SEND_NOTIFY(server, sock, SILC_NOTIFY_TYPE_NONE, ("Your host is %s, running version %s", server->config->server_info->server_name, server_version)); SILC_SERVER_SEND_NOTIFY(server, sock, SILC_NOTIFY_TYPE_NONE, ("Your connection is secured with %s cipher, " "key length %d bits", idata->send_key->cipher->name, idata->send_key->cipher->key_len)); SILC_SERVER_SEND_NOTIFY(server, sock, SILC_NOTIFY_TYPE_NONE, ("Your current nickname is %s", client->nickname)); /* Send motd */ silc_server_send_motd(server, sock); return client; } /* Create new server. This processes received New Server packet and saves the received Server ID. The server is our locally connected server thus we save all the information and save it to local list. This funtion can be used by both normal server and router server. If normal server uses this it means that its router has connected to the server. If router uses this it means that one of the cell's servers is connected to the router. */ SilcServerEntry silc_server_new_server(SilcServer server, SilcSocketConnection sock, SilcPacketContext *packet) { SilcBuffer buffer = packet->buffer; SilcServerEntry new_server; SilcIDCacheEntry cache; SilcServerID *server_id; SilcIDListData idata; unsigned char *server_name, *id_string; unsigned short id_len; SILC_LOG_DEBUG(("Creating new server")); if (sock->type != SILC_SOCKET_TYPE_SERVER && sock->type != SILC_SOCKET_TYPE_ROUTER) return NULL; /* Take server entry */ new_server = (SilcServerEntry)sock->user_data; idata = (SilcIDListData)new_server; /* Fetch the old server cache entry so that we can update it. */ if (!silc_idcache_find_by_context(server->local_list->servers, sock->user_data, &cache)) { SILC_LOG_ERROR(("Lost server's cache entry - bad thing")); return NULL; } /* Parse the incoming packet */ silc_buffer_unformat(buffer, SILC_STR_UI16_NSTRING_ALLOC(&id_string, &id_len), SILC_STR_UI16_STRING_ALLOC(&server_name), SILC_STR_END); if (id_len > buffer->len) { silc_free(id_string); silc_free(server_name); return NULL; } /* Get Server ID */ server_id = silc_id_str2id(id_string, SILC_ID_SERVER); silc_free(id_string); /* Update client entry */ idata->registered = TRUE; new_server->server_name = server_name; new_server->id = server_id; /* Update the cache entry */ cache->id = (void *)server_id; cache->type = SILC_ID_SERVER; cache->data = server_name; silc_idcache_sort_by_data(server->local_list->servers); /* Distribute the information about new server in the SILC network to our router. If we are normal server we won't send anything since this connection must be our router connection. */ if (server->server_type == SILC_ROUTER && !server->standalone && server->router->connection != sock) silc_server_send_new_id(server, server->router->connection, TRUE, new_server->id, SILC_ID_SERVER, SILC_ID_SERVER_LEN); if (server->server_type == SILC_ROUTER) server->stat.cell_servers++; return new_server; } /* Processes incoming New ID packet. New ID Payload is used to distribute information about newly registered clients and servers. */ void silc_server_new_id(SilcServer server, SilcSocketConnection sock, SilcPacketContext *packet) { SilcBuffer buffer = packet->buffer; SilcIDList id_list; SilcServerEntry router; SilcSocketConnection router_sock; SilcIDPayload idp; SilcIdType id_type; unsigned char *hash = NULL; void *id; SILC_LOG_DEBUG(("Processing new ID")); if (sock->type == SILC_SOCKET_TYPE_CLIENT || server->server_type == SILC_SERVER || packet->src_id_type != SILC_ID_SERVER) return; idp = silc_id_payload_parse(buffer); if (!idp) return; id_type = silc_id_payload_get_type(idp); /* Normal server cannot have other normal server connections */ if (id_type == SILC_ID_SERVER && sock->type == SILC_SOCKET_TYPE_SERVER) goto out; id = silc_id_payload_get_id(idp); if (!id) goto out; /* If the sender of this packet is server and we are router we need to broadcast this packet to other routers in the network. */ if (!server->standalone && server->server_type == SILC_ROUTER && sock->type == SILC_SOCKET_TYPE_SERVER && !(packet->flags & SILC_PACKET_FLAG_BROADCAST)) { SILC_LOG_DEBUG(("Broadcasting received New ID packet")); silc_server_packet_send(server, server->router->connection, packet->type, packet->flags | SILC_PACKET_FLAG_BROADCAST, buffer->data, buffer->len, FALSE); } if (sock->type == SILC_SOCKET_TYPE_SERVER) id_list = server->local_list; else id_list = server->global_list; router_sock = sock; router = sock->user_data; switch(id_type) { case SILC_ID_CLIENT: { SilcClientEntry entry; SILC_LOG_DEBUG(("New client id(%s) from [%s] %s", silc_id_render(id, SILC_ID_CLIENT), sock->type == SILC_SOCKET_TYPE_SERVER ? "Server" : "Router", sock->hostname)); /* As a router we keep information of all global information in our global list. Cell wide information however is kept in the local list. The client is put to global list and we will take the hash value of the Client ID and save it to the ID Cache system for fast searching in the future. */ hash = silc_calloc(sizeof(((SilcClientID *)id)->hash), sizeof(unsigned char)); memcpy(hash, ((SilcClientID *)id)->hash, sizeof(((SilcClientID *)id)->hash)); entry = silc_idlist_add_client(id_list, hash, NULL, NULL, id, router, router_sock); entry->nickname = NULL; if (sock->type == SILC_SOCKET_TYPE_SERVER) server->stat.cell_clients++; server->stat.clients++; #if 0 /* XXX Adding two ID's with same IP number replaces the old entry thus gives wrong route. Thus, now disabled until figured out a better way to do this or when removed the whole thing. This could be removed because entry->router->connection gives always the most optimal route for the ID anyway (unless new routes (faster perhaps) are established after receiving this ID, this we don't know however). */ /* Add route cache for this ID */ silc_server_route_add(silc_server_route_hash( ((SilcClientID *)id)->ip.s_addr, server->id->port), ((SilcClientID *)id)->ip.s_addr, router); #endif } break; case SILC_ID_SERVER: SILC_LOG_DEBUG(("New server id(%s) from [%s] %s", silc_id_render(id, SILC_ID_SERVER), sock->type == SILC_SOCKET_TYPE_SERVER ? "Server" : "Router", sock->hostname)); /* As a router we keep information of all global information in our global list. Cell wide information however is kept in the local list. */ silc_idlist_add_server(id_list, NULL, 0, id, router, router_sock); if (sock->type == SILC_SOCKET_TYPE_SERVER) server->stat.cell_servers++; server->stat.servers++; #if 0 /* Add route cache for this ID */ silc_server_route_add(silc_server_route_hash( ((SilcServerID *)id)->ip.s_addr, ((SilcServerID *)id)->port), ((SilcServerID *)id)->ip.s_addr, router); #endif break; case SILC_ID_CHANNEL: SILC_LOG_ERROR(("Channel cannot be registered with NEW_ID packet")); break; default: break; } out: silc_id_payload_free(idp); } /* Received Remove Channel User packet to remove a user from a channel. Routers notify other routers that user has left a channel. Client must not send this packet. Normal server may send this packet but must not receive it. */ void silc_server_remove_channel_user(SilcServer server, SilcSocketConnection sock, SilcPacketContext *packet) { SilcBuffer buffer = packet->buffer; unsigned char *tmp1 = NULL, *tmp2 = NULL; SilcClientID *client_id = NULL; SilcChannelID *channel_id = NULL; SilcChannelEntry channel; SilcClientEntry client; SILC_LOG_DEBUG(("Removing user from channel")); if (sock->type == SILC_SOCKET_TYPE_CLIENT || server->server_type == SILC_SERVER) return; silc_buffer_unformat(buffer, SILC_STR_UI16_STRING_ALLOC(&tmp1), SILC_STR_UI16_STRING_ALLOC(&tmp2), SILC_STR_END); if (!tmp1 || !tmp2) goto out; client_id = silc_id_str2id(tmp1, SILC_ID_CLIENT); channel_id = silc_id_str2id(tmp2, SILC_ID_CHANNEL); if (!client_id || !channel_id) goto out; /* If we are router and this packet is not already broadcast packet we will broadcast it. The sending socket really cannot be router or the router is buggy. If this packet is coming from router then it must have the broadcast flag set already and we won't do anything. */ if (!server->standalone && server->server_type == SILC_ROUTER && sock->type == SILC_SOCKET_TYPE_SERVER && !(packet->flags & SILC_PACKET_FLAG_BROADCAST)) { SILC_LOG_DEBUG(("Broadcasting received Remove Channel User packet")); silc_server_packet_send(server, server->router->connection, packet->type, packet->flags | SILC_PACKET_FLAG_BROADCAST, buffer->data, buffer->len, FALSE); } /* Get channel entry */ channel = silc_idlist_find_channel_by_id(server->local_list, channel_id, NULL); if (!channel) { channel = silc_idlist_find_channel_by_id(server->global_list, channel_id, NULL); if (!channel) goto out; } /* Get client entry */ client = silc_idlist_find_client_by_id(server->local_list, client_id, NULL); if (!client) { client = silc_idlist_find_client_by_id(server->global_list, client_id, NULL); if (!client) goto out; } /* Remove user from channel */ silc_server_remove_from_one_channel(server, sock, channel, client, TRUE); out: if (tmp1) silc_free(tmp1); if (tmp2) silc_free(tmp2); if (client_id) silc_free(client_id); if (channel_id) silc_free(channel_id); } /* Received New Channel packet. Information about new channels in the network are distributed using this packet. Save the information about the new channel. */ void silc_server_new_channel(SilcServer server, SilcSocketConnection sock, SilcPacketContext *packet) { unsigned char *id; SilcChannelID *channel_id; unsigned short channel_id_len; char *channel_name; SILC_LOG_DEBUG(("Processing New Channel")); if (sock->type != SILC_SOCKET_TYPE_ROUTER || server->server_type == SILC_SERVER || packet->src_id_type != SILC_ID_SERVER) return; /* Parse payload */ if (!silc_buffer_unformat(packet->buffer, SILC_STR_UI16_STRING_ALLOC(&channel_name), SILC_STR_UI16_NSTRING_ALLOC(&id, &channel_id_len), SILC_STR_END)) return; if (!channel_name || !id) return; /* Decode the channel ID */ channel_id = silc_id_str2id(id, SILC_ID_CHANNEL); if (!channel_id) return; silc_free(id); SILC_LOG_DEBUG(("New channel id(%s) from [Router] %s", silc_id_render(channel_id, SILC_ID_CHANNEL), sock->hostname)); /* Add the new channel. Add it always to global list since if we receive this packet then it cannot be created by ourselves but some other router hence global channel. */ silc_idlist_add_channel(server->global_list, channel_name, 0, channel_id, server->router->connection, NULL); server->stat.channels++; } /* Received notify packet. Server can receive notify packets from router. Server then relays the notify messages to clients if needed. */ void silc_server_notify(SilcServer server, SilcSocketConnection sock, SilcPacketContext *packet) { SilcNotifyPayload payload; SilcNotifyType type; SilcArgumentPayload args; SilcChannelID *channel_id; SilcClientID *client_id, *client_id2; SilcChannelEntry channel; SilcClientEntry client; unsigned char *tmp; unsigned int tmp_len; SILC_LOG_DEBUG(("Start")); if (sock->type == SILC_SOCKET_TYPE_CLIENT || packet->src_id_type != SILC_ID_SERVER) return; /* XXX: For now we expect that the we are normal server and that the sender is router. Server could send (protocol allows it) notify to router but we don't support it yet. */ if (server->server_type != SILC_SERVER && sock->type != SILC_SOCKET_TYPE_ROUTER) return; payload = silc_notify_payload_parse(packet->buffer); if (!payload) return; type = silc_notify_get_type(payload); args = silc_notify_get_args(payload); if (!args) goto out; switch(type) { case SILC_NOTIFY_TYPE_JOIN: /* * Distribute the notify to local clients on the channel */ SILC_LOG_DEBUG(("JOIN notify")); channel_id = silc_id_str2id(packet->dst_id, packet->dst_id_type); if (!channel_id) goto out; /* Get channel entry */ channel = silc_idlist_find_channel_by_id(server->local_list, channel_id, NULL); if (!channel) { silc_free(channel_id); goto out; } /* Get client ID */ tmp = silc_argument_get_arg_type(args, 1, &tmp_len); if (!tmp) { silc_free(channel_id); goto out; } client_id = silc_id_payload_parse_id(tmp, tmp_len); /* Send to channel */ silc_server_packet_send_to_channel(server, NULL, channel, packet->type, FALSE, packet->buffer->data, packet->buffer->len, FALSE); /* If the the client is not in local list we check global list (ie. the channel will be global channel) and if it does not exist then create entry for the client. */ client = silc_idlist_find_client_by_id(server->local_list, client_id, NULL); if (!client) { SilcChannelClientEntry chl; client = silc_idlist_find_client_by_id(server->global_list, client_id, NULL); if (!client) client = silc_idlist_add_client(server->global_list, NULL, NULL, NULL, client_id, sock->user_data, sock); /* The channel is global now */ channel->global_users = TRUE; /* Now actually JOIN the global client to the channel */ chl = silc_calloc(1, sizeof(*chl)); chl->client = client; chl->channel = channel; silc_list_add(channel->user_list, chl); silc_list_add(client->channels, chl); } else { silc_free(client_id); } break; case SILC_NOTIFY_TYPE_LEAVE: /* * Distribute the notify to local clients on the channel */ SILC_LOG_DEBUG(("LEAVE notify")); channel_id = silc_id_str2id(packet->dst_id, packet->dst_id_type); if (!channel_id) goto out; /* Get channel entry */ channel = silc_idlist_find_channel_by_id(server->local_list, channel_id, NULL); if (!channel) { silc_free(channel_id); goto out; } /* Get client ID */ tmp = silc_argument_get_arg_type(args, 1, &tmp_len); if (!tmp) { silc_free(channel_id); goto out; } client_id = silc_id_payload_parse_id(tmp, tmp_len); /* Send to channel */ silc_server_packet_send_to_channel(server, NULL, channel, packet->type, FALSE, packet->buffer->data, packet->buffer->len, FALSE); /* Get client entry */ client = silc_idlist_find_client_by_id(server->global_list, client_id, NULL); if (!client) { client = silc_idlist_find_client_by_id(server->local_list, client_id, NULL); if (!client) { silc_free(channel_id); goto out; } } silc_free(client_id); /* Remove the user from channel */ silc_server_remove_from_one_channel(server, sock, channel, client, FALSE); break; case SILC_NOTIFY_TYPE_SIGNOFF: /* * Distribute the notify to local clients on the channel */ SILC_LOG_DEBUG(("SIGNOFF notify")); /* Get client ID */ tmp = silc_argument_get_arg_type(args, 1, &tmp_len); if (!tmp) goto out; client_id = silc_id_payload_parse_id(tmp, tmp_len); /* Get client entry */ client = silc_idlist_find_client_by_id(server->global_list, client_id, NULL); if (!client) { client = silc_idlist_find_client_by_id(server->local_list, client_id, NULL); if (!client) { silc_free(client_id); goto out; } } silc_free(client_id); /* Remove the client from all channels */ silc_server_remove_from_channels(server, NULL, client); /* Remove the client entry */ silc_idlist_del_client(server->global_list, client); break; case SILC_NOTIFY_TYPE_NICK_CHANGE: { /* * Distribute the notify to local clients on the channel */ unsigned char *id, *id2; SILC_LOG_DEBUG(("NICK CHANGE notify")); /* Get old client ID */ id = silc_argument_get_arg_type(args, 1, &tmp_len); if (!id) goto out; client_id = silc_id_payload_parse_id(id, tmp_len); /* Get new client ID */ id2 = silc_argument_get_arg_type(args, 2, &tmp_len); if (!id2) goto out; client_id2 = silc_id_payload_parse_id(id2, tmp_len); SILC_LOG_DEBUG(("Old Client ID id(%s)", silc_id_render(client_id, SILC_ID_CLIENT))); SILC_LOG_DEBUG(("New Client ID id(%s)", silc_id_render(client_id2, SILC_ID_CLIENT))); /* Replace the Client ID */ client = silc_idlist_replace_client_id(server->global_list, client_id, client_id2); if (!client) client = silc_idlist_replace_client_id(server->local_list, client_id, client_id2); if (client) /* Send the NICK_CHANGE notify type to local clients on the channels this client is joined to. */ silc_server_send_notify_on_channels(server, client, SILC_NOTIFY_TYPE_NICK_CHANGE, 2, id, tmp_len, id2, tmp_len); silc_free(client_id); if (!client) silc_free(client_id2); break; } case SILC_NOTIFY_TYPE_TOPIC_SET: /* * Distribute the notify to local clients on the channel */ SILC_LOG_DEBUG(("TOPIC SET notify (not-impl XXX)")); break; case SILC_NOTIFY_TYPE_CMODE_CHANGE: /* * Distribute the notify to local clients on the channel */ SILC_LOG_DEBUG(("CMODE CHANGE notify (not-impl XXX)")); break; case SILC_NOTIFY_TYPE_CUMODE_CHANGE: /* * Distribute the notify to local clients on the channel */ SILC_LOG_DEBUG(("CUMODE CHANGE notify (not-impl XXX)")); break; /* Ignore rest notify types for now */ case SILC_NOTIFY_TYPE_NONE: case SILC_NOTIFY_TYPE_INVITE: case SILC_NOTIFY_TYPE_MOTD: default: break; } out: silc_notify_payload_free(payload); } /* Received new channel user packet. Information about new users on a channel are distributed between routers using this packet. The router receiving this will redistribute it and also sent JOIN notify to local clients on the same channel. Normal server sends JOIN notify to its local clients on the channel. */ void silc_server_new_channel_user(SilcServer server, SilcSocketConnection sock, SilcPacketContext *packet) { unsigned char *tmpid1, *tmpid2; SilcClientID *client_id = NULL; SilcChannelID *channel_id = NULL; unsigned short channel_id_len; unsigned short client_id_len; SilcClientEntry client; SilcChannelEntry channel; SilcChannelClientEntry chl; SilcBuffer clidp; SILC_LOG_DEBUG(("Start")); if (sock->type == SILC_SOCKET_TYPE_CLIENT || server->server_type != SILC_ROUTER || packet->src_id_type != SILC_ID_SERVER) return; /* Parse payload */ if (!silc_buffer_unformat(packet->buffer, SILC_STR_UI16_NSTRING_ALLOC(&tmpid1, &channel_id_len), SILC_STR_UI16_NSTRING_ALLOC(&tmpid2, &client_id_len), SILC_STR_END)) return; if (!tmpid1 || !tmpid2) return; /* Decode the channel ID */ channel_id = silc_id_str2id(tmpid1, SILC_ID_CHANNEL); if (!channel_id) goto out; /* Decode the client ID */ client_id = silc_id_str2id(tmpid2, SILC_ID_CLIENT); if (!client_id) goto out; /* Find the channel */ channel = silc_idlist_find_channel_by_id(server->local_list, channel_id, NULL); if (!channel) { channel = silc_idlist_find_channel_by_id(server->global_list, channel_id, NULL); if (!channel) goto out; } /* If we are router and this packet is not already broadcast packet we will broadcast it. */ if (!server->standalone && server->server_type == SILC_ROUTER && !(packet->flags & SILC_PACKET_FLAG_BROADCAST)) { SILC_LOG_DEBUG(("Broadcasting received New Channel User packet")); silc_server_packet_send(server, server->router->connection, packet->type, packet->flags | SILC_PACKET_FLAG_BROADCAST, packet->buffer->data, packet->buffer->len, FALSE); } /* Get client entry */ client = silc_idlist_find_client_by_id(server->local_list, client_id, NULL); if (!client) { client = silc_idlist_find_client_by_id(server->global_list, client_id, NULL); if (!client) goto out; } /* Join the client to the channel by adding it to channel's user list. Add also the channel to client entry's channels list for fast cross- referencing. */ chl = silc_calloc(1, sizeof(*chl)); chl->client = client; chl->channel = channel; silc_list_add(channel->user_list, chl); silc_list_add(client->channels, chl); server->stat.chanclients++; /* Send JOIN notify to local clients on the channel. As we are router it is assured that this is sent only to our local clients and locally connected servers if needed. */ clidp = silc_id_payload_encode(client_id, SILC_ID_CLIENT); silc_server_send_notify_to_channel(server, sock, channel, FALSE, SILC_NOTIFY_TYPE_JOIN, 1, clidp->data, clidp->len); silc_buffer_free(clidp); client_id = NULL; out: if (client_id) silc_free(client_id); if (channel_id) silc_free(channel_id); silc_free(tmpid1); silc_free(tmpid2); } /* Processes incoming REMOVE_ID packet. The packet is used to notify routers that certain ID should be removed. After that the ID will become invalid. */ void silc_server_remove_id(SilcServer server, SilcSocketConnection sock, SilcPacketContext *packet) { SilcIDList id_list; SilcIDPayload idp; SilcIdType id_type; void *id, *id_entry; SILC_LOG_DEBUG(("Start")); if (sock->type == SILC_SOCKET_TYPE_CLIENT || server->server_type == SILC_SERVER || packet->src_id_type != SILC_ID_SERVER) return; idp = silc_id_payload_parse(packet->buffer); if (!idp) return; id_type = silc_id_payload_get_type(idp); id = silc_id_payload_get_id(idp); if (!id) goto out; /* If the sender of this packet is server and we are router we need to broadcast this packet to other routers in the network. */ if (!server->standalone && server->server_type == SILC_ROUTER && sock->type == SILC_SOCKET_TYPE_SERVER && !(packet->flags & SILC_PACKET_FLAG_BROADCAST)) { SILC_LOG_DEBUG(("Broadcasting received Remove ID packet")); silc_server_packet_send(server, server->router->connection, packet->type, packet->flags | SILC_PACKET_FLAG_BROADCAST, packet->buffer->data, packet->buffer->len, FALSE); } if (sock->type == SILC_SOCKET_TYPE_SERVER) id_list = server->local_list; else id_list = server->global_list; /* Remove the ID */ switch (id_type) { case SILC_ID_CLIENT: id_entry = silc_idlist_find_client_by_id(id_list, (SilcClientID *)id, NULL); if (id_entry) { /* Remove from channels */ silc_server_remove_from_channels(server, NULL, id_entry); /* Remove the client entry */ silc_idlist_del_client(id_list, (SilcClientEntry)id_entry); server->stat.clients--; SILC_LOG_DEBUG(("Removed client id(%s) from [%s] %s", silc_id_render(id, SILC_ID_CLIENT), sock->type == SILC_SOCKET_TYPE_SERVER ? "Server" : "Router", sock->hostname)); } break; case SILC_ID_SERVER: id_entry = silc_idlist_find_server_by_id(id_list, (SilcServerID *)id, NULL); if (id_entry) { silc_idlist_del_server(id_list, (SilcServerEntry)id_entry); server->stat.servers--; SILC_LOG_DEBUG(("Removed server id(%s) from [%s] %s", silc_id_render(id, SILC_ID_SERVER), sock->type == SILC_SOCKET_TYPE_SERVER ? "Server" : "Router", sock->hostname)); } break; case SILC_ID_CHANNEL: id_entry = silc_idlist_find_channel_by_id(id_list, (SilcChannelID *)id, NULL); if (id_entry) { silc_idlist_del_channel(id_list, (SilcChannelEntry)id_entry); server->stat.channels--; SILC_LOG_DEBUG(("Removed channel id(%s) from [%s] %s", silc_id_render(id, SILC_ID_CHANNEL), sock->type == SILC_SOCKET_TYPE_SERVER ? "Server" : "Router", sock->hostname)); } break; default: break; } out: silc_id_payload_free(idp); }