X-Git-Url: http://git.silcnet.org/gitweb/?p=silc.git;a=blobdiff_plain;f=lib%2Fsilcclient%2Fclient_notify.c;h=f42ebaa6482bc21f6cd9d16e86df364b0d426847;hp=b4d4a78e8e166228f6c0b6e4f80f49099f3438cd;hb=382d15d447b7a95390decfa783836ae4fe255b3d;hpb=2f93ad66ac16ad7c8bde97d1298bb78aad5b4f35 diff --git a/lib/silcclient/client_notify.c b/lib/silcclient/client_notify.c index b4d4a78e..f42ebaa6 100644 --- a/lib/silcclient/client_notify.c +++ b/lib/silcclient/client_notify.c @@ -1,16 +1,15 @@ /* - client_notify.c + client_notify.c Author: Pekka Riikonen - Copyright (C) 1997 - 2001 Pekka Riikonen + Copyright (C) 1997 - 2002 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. - + the Free Software Foundation; version 2 of the License. + 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 @@ -22,15 +21,45 @@ important packets sent by the server. They tell different things to the client such as nick changes, mode changes etc. */ -#include "clientlibincludes.h" +#include "silcincludes.h" +#include "silcclient.h" #include "client_internal.h" +/* Context used for resolving client, channel and server info. */ typedef struct { - SilcPacketContext *packet; + void *packet; void *context; SilcSocketConnection sock; } *SilcClientNotifyResolve; +SILC_TASK_CALLBACK(silc_client_notify_check_client) +{ + SilcClientNotifyResolve res = (SilcClientNotifyResolve)context; + SilcClient client = res->context; + SilcClientConnection conn = res->sock->user_data; + SilcClientID *client_id = res->packet; + silc_client_get_client_by_id_resolve(client, conn, client_id, + NULL, NULL, NULL); + silc_free(client_id); + silc_socket_free(res->sock); + silc_free(res); +} + +SILC_TASK_CALLBACK(silc_client_notify_del_client_cb) +{ + SilcClientNotifyResolve res = (SilcClientNotifyResolve)context; + SilcClient client = res->context; + SilcClientConnection conn = res->sock->user_data; + SilcClientID *client_id = res->packet; + SilcClientEntry client_entry; + client_entry = silc_client_get_client_by_id(client, conn, client_id); + if (client_entry) + silc_client_del_client(client, conn, client_entry); + silc_free(client_id); + silc_socket_free(res->sock); + silc_free(res); +} + /* Called when notify is received and some async operation (such as command) is required before processing the notify message. This calls again the silc_client_notify_by_server and reprocesses the original notify packet. */ @@ -41,48 +70,114 @@ static void silc_client_notify_by_server_pending(void *context, void *context2) SilcClientCommandReplyContext reply = (SilcClientCommandReplyContext)context2; - if (reply) { - SilcCommandStatus status; - unsigned char *tmp = silc_argument_get_arg_type(reply->args, 1, NULL); - SILC_GET16_MSB(status, tmp); - if (status != SILC_STATUS_OK) { - silc_socket_free(res->sock); - return; - } - } + SILC_LOG_DEBUG(("Start")); + + if (reply && !silc_command_get_status(reply->payload, NULL, NULL)) + goto out; silc_client_notify_by_server(res->context, res->sock, res->packet); + + out: silc_socket_free(res->sock); + silc_packet_context_free(res->packet); + silc_free(res); } -/* Destructor for the pending command callback */ +/* Resets the channel entry's resolve_cmd_ident after whatever-thing + was resolved is completed. */ -static void silc_client_notify_by_server_destructor(void *context) +static void silc_client_channel_cond(void *context, void *context2) { SilcClientNotifyResolve res = (SilcClientNotifyResolve)context; - silc_packet_context_free(res->packet); + SilcClient client = res->context; + SilcClientConnection conn = res->sock->user_data; + SilcChannelID *channel_id = res->packet; + SilcChannelEntry channel; + channel = silc_client_get_channel_by_id(client, conn, channel_id); + if (channel) + channel->resolve_cmd_ident = 0; + silc_free(channel_id); + silc_socket_free(res->sock); silc_free(res); } -/* Resolve client information from server by Client ID. */ +/* Function that starts waiting for the `cmd_ident' to arrive and + marks the channel info being resolved. */ + +static void silc_client_channel_set_wait(SilcClient client, + SilcClientConnection conn, + SilcChannelEntry channel, + SilcUInt16 cmd_ident) +{ + SilcClientNotifyResolve res; + + if (!channel->resolve_cmd_ident) { + res = silc_calloc(1, sizeof(*res)); + res->context = client; + res->sock = silc_socket_dup(conn->sock); + res->packet = silc_id_dup(channel->id, SILC_ID_CHANNEL); + silc_client_command_pending(conn, SILC_COMMAND_NONE, cmd_ident, + silc_client_channel_cond, res); + channel->resolve_cmd_ident = cmd_ident; + } +} + +/* Attaches to the channel's resolving cmd ident and calls the + notify handling with `packet' after it's received. */ + +static void silc_client_channel_wait(SilcClient client, + SilcClientConnection conn, + SilcChannelEntry channel, + SilcPacketContext *packet) +{ + SilcClientNotifyResolve res; + + if (!channel->resolve_cmd_ident) + return; + + res = silc_calloc(1, sizeof(*res)); + res->packet = silc_packet_context_dup(packet); + res->context = client; + res->sock = silc_socket_dup(conn->sock); + + silc_client_command_pending(conn, SILC_COMMAND_NONE, + channel->resolve_cmd_ident, + silc_client_notify_by_server_pending, res); +} + +/* Resolve client, channel or server information. */ static void silc_client_notify_by_server_resolve(SilcClient client, SilcClientConnection conn, SilcPacketContext *packet, - SilcClientID *client_id) + SilcIdType id_type, + void *id) { SilcClientNotifyResolve res = silc_calloc(1, sizeof(*res)); - SilcBuffer idp = silc_id_payload_encode(client_id, SILC_ID_CLIENT); + SilcBuffer idp = silc_id_payload_encode(id, id_type); res->packet = silc_packet_context_dup(packet); res->context = client; res->sock = silc_socket_dup(conn->sock); - silc_client_send_command(client, conn, SILC_COMMAND_WHOIS, ++conn->cmd_ident, - 1, 3, idp->data, idp->len); - silc_client_command_pending(conn, SILC_COMMAND_WHOIS, conn->cmd_ident, - silc_client_notify_by_server_destructor, - silc_client_notify_by_server_pending, res); + /* For client resolving use WHOIS, and otherwise use IDENTIFY */ + if (id_type == SILC_ID_CLIENT) { + silc_client_command_register(client, SILC_COMMAND_WHOIS, NULL, NULL, + silc_client_command_reply_whois_i, 0, + ++conn->cmd_ident); + silc_client_command_send(client, conn, SILC_COMMAND_WHOIS, conn->cmd_ident, + 1, 4, idp->data, idp->len); + silc_client_command_pending(conn, SILC_COMMAND_WHOIS, conn->cmd_ident, + silc_client_notify_by_server_pending, res); + } else { + silc_client_command_register(client, SILC_COMMAND_IDENTIFY, NULL, NULL, + silc_client_command_reply_identify_i, 0, + ++conn->cmd_ident); + silc_client_command_send(client, conn, SILC_COMMAND_IDENTIFY, + conn->cmd_ident, 1, 5, idp->data, idp->len); + silc_client_command_pending(conn, SILC_COMMAND_IDENTIFY, conn->cmd_ident, + silc_client_notify_by_server_pending, res); + } silc_buffer_free(idp); } @@ -98,18 +193,18 @@ void silc_client_notify_by_server(SilcClient client, SilcNotifyType type; SilcArgumentPayload args; - SilcIDPayload idp; + void *id; + SilcIdType id_type; SilcClientID *client_id = NULL; SilcChannelID *channel_id = NULL; SilcServerID *server_id = NULL; - SilcClientEntry client_entry; - SilcClientEntry client_entry2; + SilcClientEntry client_entry = NULL; + SilcClientEntry client_entry2 = NULL; SilcChannelEntry channel; SilcChannelUser chu; SilcServerEntry server; - SilcIDCacheEntry id_cache = NULL; unsigned char *tmp; - uint32 tmp_len, mode; + SilcUInt32 tmp_len, mode; SILC_LOG_DEBUG(("Start")); @@ -125,8 +220,8 @@ void silc_client_notify_by_server(SilcClient client, switch(type) { case SILC_NOTIFY_TYPE_NONE: /* Notify application */ - client->ops->notify(client, conn, type, - silc_argument_get_arg_type(args, 1, NULL)); + client->internal->ops->notify(client, conn, type, + silc_argument_get_arg_type(args, 1, NULL)); break; case SILC_NOTIFY_TYPE_INVITE: @@ -142,29 +237,27 @@ void silc_client_notify_by_server(SilcClient client, if (!tmp) goto out; - channel_id = silc_id_payload_parse_id(tmp, tmp_len); + channel_id = silc_id_payload_parse_id(tmp, tmp_len, NULL); if (!channel_id) goto out; /* Get the channel entry */ - channel = NULL; - if (silc_idcache_find_by_id_one(conn->channel_cache, (void *)channel_id, - &id_cache)) - channel = (SilcChannelEntry)id_cache->context; + channel = silc_client_get_channel_by_id(client, conn, channel_id); /* Get sender Client ID */ tmp = silc_argument_get_arg_type(args, 3, &tmp_len); if (!tmp) goto out; - client_id = silc_id_payload_parse_id(tmp, tmp_len); + client_id = silc_id_payload_parse_id(tmp, tmp_len, NULL); if (!client_id) goto out; /* Find Client entry and if not found query it */ client_entry = silc_client_get_client_by_id(client, conn, client_id); if (!client_entry) { - silc_client_notify_by_server_resolve(client, conn, packet, client_id); + silc_client_notify_by_server_resolve(client, conn, packet, + SILC_ID_CLIENT, client_id); goto out; } @@ -174,7 +267,8 @@ void silc_client_notify_by_server(SilcClient client, goto out; /* Notify application */ - client->ops->notify(client, conn, type, channel, tmp, client_entry); + client->internal->ops->notify(client, conn, type, channel, tmp, + client_entry); break; case SILC_NOTIFY_TYPE_JOIN: @@ -190,14 +284,15 @@ void silc_client_notify_by_server(SilcClient client, if (!tmp) goto out; - client_id = silc_id_payload_parse_id(tmp, tmp_len); + client_id = silc_id_payload_parse_id(tmp, tmp_len, NULL); if (!client_id) goto out; /* Find Client entry and if not found query it */ client_entry = silc_client_get_client_by_id(client, conn, client_id); if (!client_entry) { - silc_client_notify_by_server_resolve(client, conn, packet, client_id); + silc_client_notify_by_server_resolve(client, conn, packet, + SILC_ID_CLIENT, client_id); goto out; } @@ -207,8 +302,10 @@ void silc_client_notify_by_server(SilcClient client, client_entry->status &= ~SILC_CLIENT_STATUS_RESOLVING; goto out; } + silc_client_notify_by_server_resolve(client, conn, packet, + SILC_ID_CLIENT, client_id); client_entry->status |= SILC_CLIENT_STATUS_RESOLVING; - silc_client_notify_by_server_resolve(client, conn, packet, client_id); + client_entry->resolve_cmd_ident = conn->cmd_ident; goto out; } else { if (client_entry != conn->local_entry) @@ -220,28 +317,28 @@ void silc_client_notify_by_server(SilcClient client, if (!tmp) goto out; - channel_id = silc_id_payload_parse_id(tmp, tmp_len); + channel_id = silc_id_payload_parse_id(tmp, tmp_len, NULL); if (!channel_id) goto out; /* Get channel entry */ - if (!silc_idcache_find_by_id_one(conn->channel_cache, (void *)channel_id, - &id_cache)) + channel = silc_client_get_channel_by_id(client, conn, channel_id); + if (!channel) break; - channel = (SilcChannelEntry)id_cache->context; - - /* Add client to channel */ - if (client_entry != conn->local_entry) { + /* Join the client to channel */ + if (!silc_client_on_channel(channel, client_entry)) { chu = silc_calloc(1, sizeof(*chu)); chu->client = client_entry; - silc_list_add(channel->clients, chu); + chu->channel = channel; + silc_hash_table_add(channel->user_list, client_entry, chu); + silc_hash_table_add(client_entry->channels, channel, chu); } /* Notify application. The channel entry is sent last as this notify is for channel but application don't know it from the arguments sent by server. */ - client->ops->notify(client, conn, type, client_entry, channel); + client->internal->ops->notify(client, conn, type, client_entry, channel); break; case SILC_NOTIFY_TYPE_LEAVE: @@ -257,7 +354,7 @@ void silc_client_notify_by_server(SilcClient client, if (!tmp) goto out; - client_id = silc_id_payload_parse_id(tmp, tmp_len); + client_id = silc_id_payload_parse_id(tmp, tmp_len, NULL); if (!client_id) goto out; @@ -272,26 +369,37 @@ void silc_client_notify_by_server(SilcClient client, SILC_ID_CHANNEL); if (!channel_id) goto out; - if (!silc_idcache_find_by_id_one(conn->channel_cache, (void *)channel_id, - &id_cache)) + channel = silc_client_get_channel_by_id(client, conn, channel_id); + if (!channel) break; - channel = (SilcChannelEntry)id_cache->context; - /* Remove client from channel */ - silc_list_start(channel->clients); - while ((chu = silc_list_get(channel->clients)) != SILC_LIST_END) { - if (chu->client == client_entry) { - silc_list_del(channel->clients, chu); - silc_free(chu); - break; - } + chu = silc_client_on_channel(channel, client_entry); + if (chu) { + silc_hash_table_del(client_entry->channels, channel); + silc_hash_table_del(channel->user_list, client_entry); + silc_free(chu); + } + + /* Some client implementations actually quit network by first doing + LEAVE and then immediately SIGNOFF. We'll check for this by doing + check for the client after 5 - 34 seconds. If it is not valid after + that we'll remove the client from cache. */ + if (!silc_hash_table_count(client_entry->channels)) { + SilcClientNotifyResolve res = silc_calloc(1, sizeof(*res)); + res->context = client; + res->sock = silc_socket_dup(conn->sock); + res->packet = silc_id_dup(client_id, SILC_ID_CLIENT); + silc_schedule_task_add(client->schedule, conn->sock->sock, + silc_client_notify_check_client, res, + (5 + (silc_rng_get_rn16(client->rng) % 29)), + 0, SILC_TASK_TIMEOUT, SILC_TASK_PRI_NORMAL); } /* Notify application. The channel entry is sent last as this notify is for channel but application don't know it from the arguments sent by server. */ - client->ops->notify(client, conn, type, client_entry, channel); + client->internal->ops->notify(client, conn, type, client_entry, channel); break; case SILC_NOTIFY_TYPE_SIGNOFF: @@ -306,7 +414,7 @@ void silc_client_notify_by_server(SilcClient client, if (!tmp) goto out; - client_id = silc_id_payload_parse_id(tmp, tmp_len); + client_id = silc_id_payload_parse_id(tmp, tmp_len, NULL); if (!client_id) goto out; @@ -320,7 +428,7 @@ void silc_client_notify_by_server(SilcClient client, silc_client_remove_from_channels(client, conn, client_entry); /* Remove from cache */ - silc_idcache_del_by_context(conn->client_cache, client_entry); + silc_idcache_del_by_context(conn->internal->client_cache, client_entry); /* Get signoff message */ tmp = silc_argument_get_arg_type(args, 2, &tmp_len); @@ -328,7 +436,7 @@ void silc_client_notify_by_server(SilcClient client, tmp = NULL; /* Notify application */ - client->ops->notify(client, conn, type, client_entry, tmp); + client->internal->ops->notify(client, conn, type, client_entry, tmp); /* Free data */ silc_client_del_client_entry(client, conn, client_entry); @@ -341,62 +449,80 @@ void silc_client_notify_by_server(SilcClient client, SILC_LOG_DEBUG(("Notify: TOPIC_SET")); - /* Get Client ID */ + /* Get channel entry */ + channel_id = silc_id_str2id(packet->dst_id, packet->dst_id_len, + SILC_ID_CHANNEL); + if (!channel_id) + goto out; + channel = silc_client_get_channel_by_id(client, conn, channel_id); + if (!channel) + break; + + /* Get ID */ tmp = silc_argument_get_arg_type(args, 1, &tmp_len); if (!tmp) goto out; - - idp = silc_id_payload_parse(tmp, tmp_len); - if (!idp) + id = silc_id_payload_parse_id(tmp, tmp_len, &id_type); + if (!id) goto out; /* Find Client entry */ - if (silc_id_payload_get_type(idp) == SILC_ID_CLIENT) { - client_id = silc_id_payload_parse_id(tmp, tmp_len); - if (!client_id) { - silc_id_payload_free(idp); - goto out; - } - + if (id_type == SILC_ID_CLIENT) { /* Find Client entry */ - client_entry = - silc_client_get_client_by_id(client, conn, client_id); - if (!client_entry) - goto out; - } else if (silc_id_payload_get_type(idp) == SILC_ID_SERVER) { - server_id = silc_id_payload_parse_id(tmp, tmp_len); - if (!server_id) { - silc_id_payload_free(idp); + client_id = id; + client_entry = silc_client_get_client_by_id(client, conn, client_id); + if (!client_entry) { + silc_client_channel_set_wait(client, conn, channel, + conn->cmd_ident + 1); + silc_client_notify_by_server_resolve(client, conn, packet, + SILC_ID_CLIENT, client_id); goto out; } - + } else if (id_type == SILC_ID_SERVER) { + /* Find Server entry */ + server_id = id; server = silc_client_get_server_by_id(client, conn, server_id); if (!server) { - silc_id_payload_free(idp); - silc_free(server_id); + silc_client_channel_set_wait(client, conn, channel, + conn->cmd_ident + 1); + silc_client_notify_by_server_resolve(client, conn, packet, + SILC_ID_SERVER, server_id); + server = silc_client_add_server(client, conn, NULL, NULL, server_id); + if (!server) + goto out; + + server->resolve_cmd_ident = conn->cmd_ident; + server_id = NULL; + goto out; + } + + /* If entry being resoled, wait for it before processing this notify */ + if (server->resolve_cmd_ident) { + SilcClientNotifyResolve res = silc_calloc(1, sizeof(*res)); + res->packet = silc_packet_context_dup(packet); + res->context = client; + res->sock = silc_socket_dup(conn->sock); + silc_client_command_pending(conn, SILC_COMMAND_NONE, + server->resolve_cmd_ident, + silc_client_notify_by_server_pending, res); goto out; } /* Save the pointer to the client_entry pointer */ client_entry = (SilcClientEntry)server; - silc_free(server_id); } else { - channel_id = silc_id_payload_parse_id(tmp, tmp_len); - if (!channel_id) { - silc_id_payload_free(idp); - goto out; - } - - channel = silc_client_get_channel_by_id(client, conn, channel_id); - if (!channel) { - silc_id_payload_free(idp); - silc_free(channel_id); + /* Find Channel entry */ + silc_free(channel_id); + channel_id = id; + client_entry = (SilcClientEntry) + silc_client_get_channel_by_id(client, conn, channel_id); + if (!client_entry) { + silc_client_channel_set_wait(client, conn, channel, + conn->cmd_ident + 1); + silc_client_notify_by_server_resolve(client, conn, packet, + SILC_ID_CHANNEL, channel_id); goto out; } - - /* Save the pointer to the client_entry pointer */ - client_entry = (SilcClientEntry)channel; - silc_free(channel_id); } /* Get topic */ @@ -404,24 +530,18 @@ void silc_client_notify_by_server(SilcClient client, if (!tmp) goto out; - /* Get channel entry */ - channel_id = silc_id_str2id(packet->dst_id, packet->dst_id_len, - SILC_ID_CHANNEL); - if (!channel_id) + /* If information is being resolved for this channel, wait for it */ + if (channel->resolve_cmd_ident) { + silc_client_channel_wait(client, conn, channel, packet); goto out; - if (!silc_idcache_find_by_id_one(conn->channel_cache, (void *)channel_id, - &id_cache)) - break; - - channel = (SilcChannelEntry)id_cache->context; + } /* Notify application. The channel entry is sent last as this notify is for channel but application don't know it from the arguments sent by server. */ - client->ops->notify(client, conn, type, silc_id_payload_get_type(idp), - client_entry, tmp, channel); + client->internal->ops->notify(client, conn, type, id_type, + client_entry, tmp, channel); - silc_id_payload_free(idp); break; case SILC_NOTIFY_TYPE_NICK_CHANGE: @@ -439,12 +559,12 @@ void silc_client_notify_by_server(SilcClient client, if (!tmp) goto out; - client_id = silc_id_payload_parse_id(tmp, tmp_len); + client_id = silc_id_payload_parse_id(tmp, tmp_len, NULL); if (!client_id) goto out; /* Ignore my ID */ - if (SILC_ID_CLIENT_COMPARE(client_id, conn->local_id)) + if (conn->local_id && SILC_ID_CLIENT_COMPARE(client_id, conn->local_id)) break; /* Find old Client entry */ @@ -452,6 +572,19 @@ void silc_client_notify_by_server(SilcClient client, if (!client_entry) goto out; silc_free(client_id); + client_id = NULL; + + /* Wait for resolving if necessary */ + if (client_entry->status & SILC_CLIENT_STATUS_RESOLVING) { + SilcClientNotifyResolve res = silc_calloc(1, sizeof(*res)); + res->packet = silc_packet_context_dup(packet); + res->context = client; + res->sock = silc_socket_dup(conn->sock); + silc_client_command_pending(conn, SILC_COMMAND_NONE, + client_entry->resolve_cmd_ident, + silc_client_notify_by_server_pending, res); + goto out; + } client_entry->valid = FALSE; @@ -460,32 +593,70 @@ void silc_client_notify_by_server(SilcClient client, if (!tmp) goto out; - client_id = silc_id_payload_parse_id(tmp, tmp_len); + client_id = silc_id_payload_parse_id(tmp, tmp_len, NULL); if (!client_id) goto out; - /* Find Client entry and if not found resolve it */ - client_entry2 = silc_client_get_client_by_id(client, conn, client_id); - if (!client_entry2) { - silc_client_notify_by_server_resolve(client, conn, packet, client_id); + /* Take the nickname */ + tmp = silc_argument_get_arg_type(args, 3, NULL); + if (!tmp) goto out; - } else { - if (client_entry2 != conn->local_entry) - silc_client_nickname_format(client, conn, client_entry2); + + /* Check whether nickname changed at all. It is possible that nick + change notify is received but nickname didn't changed, only the + ID changes. Check whether the hashes in the Client ID match, if + they do nickname didn't change. */ + if (SILC_ID_COMPARE_HASH(client_entry->id, client_id)) { + /* Nickname didn't change. Update only the ID */ + silc_idcache_del_by_context(conn->internal->client_cache, + client_entry); + silc_free(client_entry->id); + client_entry->id = silc_id_dup(client_id, SILC_ID_CLIENT); + silc_idcache_add(conn->internal->client_cache, strdup(tmp), + client_entry->id, client_entry, 0, NULL); + + /* Notify application */ + client->internal->ops->notify(client, conn, type, + client_entry, client_entry); + break; } - /* Remove the old from cache */ - silc_idcache_del_by_context(conn->client_cache, client_entry); + /* Create new client entry, and save all old information with the + new nickname and client ID */ + client_entry2 = silc_client_add_client(client, conn, NULL, NULL, + client_entry->realname, + silc_id_dup(client_id, + SILC_ID_CLIENT), 0); + if (!client_entry2) + goto out; + + if (client_entry->server) + client_entry2->server = strdup(client_entry->server); + if (client_entry->username) + client_entry2->username = strdup(client_entry->username); + if (client_entry->hostname) + client_entry2->hostname = strdup(client_entry->hostname); + client_entry2->fingerprint = client_entry->fingerprint; + client_entry2->fingerprint_len = client_entry->fingerprint_len; + client_entry->fingerprint = NULL; + client_entry->fingerprint_len = NULL; + silc_client_update_client(client, conn, client_entry2, tmp, NULL, NULL, + client_entry->mode); + /* Remove the old from cache */ + silc_idcache_del_by_context(conn->internal->client_cache, client_entry); + /* Replace old ID entry with new one on all channels. */ silc_client_replace_from_channels(client, conn, client_entry, client_entry2); /* Notify application */ - client->ops->notify(client, conn, type, client_entry, client_entry2); - - /* Free data */ + client->internal->ops->notify(client, conn, type, + client_entry, client_entry2); + + /* Free old client entry */ silc_client_del_client_entry(client, conn, client_entry); + break; case SILC_NOTIFY_TYPE_CMODE_CHANGE: @@ -495,71 +666,117 @@ void silc_client_notify_by_server(SilcClient client, SILC_LOG_DEBUG(("Notify: CMODE_CHANGE")); - /* Get Client ID */ + /* Get channel entry */ + channel_id = silc_id_str2id(packet->dst_id, packet->dst_id_len, + SILC_ID_CHANNEL); + if (!channel_id) + goto out; + channel = silc_client_get_channel_by_id(client, conn, channel_id); + if (!channel) + goto out; + + /* Get ID */ tmp = silc_argument_get_arg_type(args, 1, &tmp_len); if (!tmp) goto out; - - idp = silc_id_payload_parse(tmp, tmp_len); - if (!idp) + id = silc_id_payload_parse_id(tmp, tmp_len, &id_type); + if (!id) goto out; /* Find Client entry */ - if (silc_id_payload_get_type(idp) == SILC_ID_CLIENT) { - client_id = silc_id_payload_parse_id(tmp, tmp_len); - if (!client_id) { - silc_id_payload_free(idp); - goto out; - } - + if (id_type == SILC_ID_CLIENT) { + /* Find Client entry */ + client_id = id; client_entry = silc_client_get_client_by_id(client, conn, client_id); if (!client_entry) { - silc_id_payload_free(idp); + silc_client_channel_set_wait(client, conn, channel, + conn->cmd_ident + 1); + silc_client_notify_by_server_resolve(client, conn, packet, + SILC_ID_CLIENT, client_id); goto out; } - } else { - server_id = silc_id_payload_parse_id(tmp, tmp_len); - if (!server_id) { - silc_id_payload_free(idp); + + if (!client_entry->nickname) { + if (client_entry->status & SILC_CLIENT_STATUS_RESOLVING) { + /* Attach to existing resolving */ + SilcClientNotifyResolve res = silc_calloc(1, sizeof(*res)); + res->packet = silc_packet_context_dup(packet); + res->context = client; + res->sock = silc_socket_dup(conn->sock); + silc_client_command_pending(conn, SILC_COMMAND_NONE, + client_entry->resolve_cmd_ident, + silc_client_notify_by_server_pending, + res); + goto out; + } + + /* Do new resolving */ + silc_client_channel_set_wait(client, conn, channel, + conn->cmd_ident + 1); + silc_client_notify_by_server_resolve(client, conn, packet, + SILC_ID_CLIENT, client_id); goto out; } - + } else if (id_type == SILC_ID_SERVER) { + /* Find Server entry */ + server_id = id; server = silc_client_get_server_by_id(client, conn, server_id); if (!server) { - silc_id_payload_free(idp); - silc_free(server_id); + silc_client_channel_set_wait(client, conn, channel, + conn->cmd_ident + 1); + silc_client_notify_by_server_resolve(client, conn, packet, + SILC_ID_SERVER, server_id); + server = silc_client_add_server(client, conn, NULL, NULL, server_id); + if (!server) + goto out; + + server->resolve_cmd_ident = conn->cmd_ident; + server_id = NULL; + goto out; + } + + /* If entry being resoled, wait for it before processing this notify */ + if (server->resolve_cmd_ident) { + SilcClientNotifyResolve res = silc_calloc(1, sizeof(*res)); + res->packet = silc_packet_context_dup(packet); + res->context = client; + res->sock = silc_socket_dup(conn->sock); + silc_client_command_pending(conn, SILC_COMMAND_NONE, + server->resolve_cmd_ident, + silc_client_notify_by_server_pending, res); goto out; } /* Save the pointer to the client_entry pointer */ client_entry = (SilcClientEntry)server; - silc_free(server_id); + } else { + /* Find Channel entry */ + silc_free(channel_id); + channel_id = id; + client_entry = (SilcClientEntry) + silc_client_get_channel_by_id(client, conn, channel_id); + if (!client_entry) { + silc_client_channel_set_wait(client, conn, channel, + conn->cmd_ident + 1); + silc_client_notify_by_server_resolve(client, conn, packet, + SILC_ID_CHANNEL, channel_id); + goto out; + } } /* Get the mode */ tmp = silc_argument_get_arg_type(args, 2, &tmp_len); - if (!tmp) { - silc_id_payload_free(idp); + if (!tmp) goto out; - } SILC_GET32_MSB(mode, tmp); - /* Get channel entry */ - channel_id = silc_id_str2id(packet->dst_id, packet->dst_id_len, - SILC_ID_CHANNEL); - if (!channel_id) { - silc_id_payload_free(idp); - goto out; - } - if (!silc_idcache_find_by_id_one(conn->channel_cache, (void *)channel_id, - &id_cache)) { - silc_id_payload_free(idp); + /* If information is being resolved for this channel, wait for it */ + if (channel->resolve_cmd_ident) { + silc_client_channel_wait(client, conn, channel, packet); goto out; } - channel = (SilcChannelEntry)id_cache->context; - /* Save the new mode */ channel->mode = mode; @@ -584,10 +801,8 @@ void silc_client_notify_by_server(SilcClient client, /* Notify application. The channel entry is sent last as this notify is for channel but application don't know it from the arguments sent by server. */ - client->ops->notify(client, conn, type, silc_id_payload_get_type(idp), - client_entry, mode, NULL, tmp, channel); - - silc_id_payload_free(idp); + client->internal->ops->notify(client, conn, type, id_type, + client_entry, mode, NULL, tmp, channel); break; case SILC_NOTIFY_TYPE_CUMODE_CHANGE: @@ -597,20 +812,102 @@ void silc_client_notify_by_server(SilcClient client, SILC_LOG_DEBUG(("Notify: CUMODE_CHANGE")); - /* Get Client ID */ + /* Get channel entry */ + channel_id = silc_id_str2id(packet->dst_id, packet->dst_id_len, + SILC_ID_CHANNEL); + if (!channel_id) + goto out; + channel = silc_client_get_channel_by_id(client, conn, channel_id); + if (!channel) + break; + + /* Get 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); - if (!client_id) + id = silc_id_payload_parse_id(tmp, tmp_len, &id_type); + if (!id) goto out; /* Find Client entry */ - client_entry = silc_client_get_client_by_id(client, conn, client_id); - if (!client_entry) { - silc_client_notify_by_server_resolve(client, conn, packet, client_id); - goto out; + if (id_type == SILC_ID_CLIENT) { + /* Find Client entry */ + client_id = id; + client_entry = silc_client_get_client_by_id(client, conn, client_id); + if (!client_entry) { + silc_client_channel_set_wait(client, conn, channel, + conn->cmd_ident + 1); + silc_client_notify_by_server_resolve(client, conn, packet, + SILC_ID_CLIENT, client_id); + goto out; + } + + if (!client_entry->nickname) { + if (client_entry->status & SILC_CLIENT_STATUS_RESOLVING) { + /* Attach to existing resolving */ + SilcClientNotifyResolve res = silc_calloc(1, sizeof(*res)); + res->packet = silc_packet_context_dup(packet); + res->context = client; + res->sock = silc_socket_dup(conn->sock); + silc_client_command_pending(conn, SILC_COMMAND_NONE, + client_entry->resolve_cmd_ident, + silc_client_notify_by_server_pending, + res); + goto out; + } + + /* Do new resolving */ + silc_client_channel_set_wait(client, conn, channel, + conn->cmd_ident + 1); + silc_client_notify_by_server_resolve(client, conn, packet, + SILC_ID_CLIENT, client_id); + goto out; + } + } else if (id_type == SILC_ID_SERVER) { + /* Find Server entry */ + server_id = id; + server = silc_client_get_server_by_id(client, conn, server_id); + if (!server) { + silc_client_channel_set_wait(client, conn, channel, + conn->cmd_ident + 1); + silc_client_notify_by_server_resolve(client, conn, packet, + SILC_ID_SERVER, server_id); + server = silc_client_add_server(client, conn, NULL, NULL, server_id); + if (!server) + goto out; + + server->resolve_cmd_ident = conn->cmd_ident; + server_id = NULL; + goto out; + } + + /* If entry being resoled, wait for it before processing this notify */ + if (server->resolve_cmd_ident) { + SilcClientNotifyResolve res = silc_calloc(1, sizeof(*res)); + res->packet = silc_packet_context_dup(packet); + res->context = client; + res->sock = silc_socket_dup(conn->sock); + silc_client_command_pending(conn, SILC_COMMAND_NONE, + server->resolve_cmd_ident, + silc_client_notify_by_server_pending, res); + goto out; + } + + /* Save the pointer to the client_entry pointer */ + client_entry = (SilcClientEntry)server; + } else { + /* Find Channel entry */ + silc_free(channel_id); + channel_id = id; + client_entry = (SilcClientEntry) + silc_client_get_channel_by_id(client, conn, channel_id); + if (!client_entry) { + silc_client_channel_set_wait(client, conn, channel, + conn->cmd_ident + 1); + silc_client_notify_by_server_resolve(client, conn, packet, + SILC_ID_CHANNEL, channel_id); + goto out; + } } /* Get the mode */ @@ -620,47 +917,42 @@ void silc_client_notify_by_server(SilcClient client, SILC_GET32_MSB(mode, tmp); + /* If information is being resolved for this channel, wait for it */ + if (channel->resolve_cmd_ident) { + silc_client_channel_wait(client, conn, channel, packet); + goto out; + } + /* Get target Client ID */ tmp = silc_argument_get_arg_type(args, 3, &tmp_len); if (!tmp) goto out; silc_free(client_id); - client_id = silc_id_payload_parse_id(tmp, tmp_len); + client_id = silc_id_payload_parse_id(tmp, tmp_len, NULL); if (!client_id) goto out; /* Find target Client entry */ client_entry2 = silc_client_get_client_by_id(client, conn, client_id); - if (!client_entry2) - goto out; - - /* Get channel entry */ - channel_id = silc_id_str2id(packet->dst_id, packet->dst_id_len, - SILC_ID_CHANNEL); - if (!channel_id) + if (!client_entry2) { + silc_client_notify_by_server_resolve(client, conn, packet, + SILC_ID_CLIENT, client_id); goto out; - if (!silc_idcache_find_by_id_one(conn->channel_cache, (void *)channel_id, - &id_cache)) - break; - - channel = (SilcChannelEntry)id_cache->context; + } /* Save the mode */ - silc_list_start(channel->clients); - while ((chu = silc_list_get(channel->clients)) != SILC_LIST_END) { - if (chu->client == client_entry) { - chu->mode = mode; - break; - } - } + chu = silc_client_on_channel(channel, client_entry2); + if (chu) + chu->mode = mode; /* Notify application. The channel entry is sent last as this notify is for channel but application don't know it from the arguments sent by server. */ - client->ops->notify(client, conn, type, client_entry, mode, - client_entry2, channel); + client->internal->ops->notify(client, conn, type, + id_type, client_entry, mode, + client_entry2, channel); break; case SILC_NOTIFY_TYPE_MOTD: @@ -676,7 +968,7 @@ void silc_client_notify_by_server(SilcClient client, goto out; /* Notify application */ - client->ops->notify(client, conn, type, tmp); + client->internal->ops->notify(client, conn, type, tmp); break; case SILC_NOTIFY_TYPE_CHANNEL_CHANGE: @@ -691,43 +983,32 @@ void silc_client_notify_by_server(SilcClient client, tmp = silc_argument_get_arg_type(args, 1, &tmp_len); if (!tmp) goto out; - channel_id = silc_id_payload_parse_id(tmp, tmp_len); + channel_id = silc_id_payload_parse_id(tmp, tmp_len, NULL); if (!channel_id) goto out; - - /* Get the channel entry */ - if (!silc_idcache_find_by_id_one(conn->channel_cache, (void *)channel_id, - &id_cache)) - break; - channel = (SilcChannelEntry)id_cache->context; - - SILC_LOG_DEBUG(("Old Channel ID id(%s)", - silc_id_render(channel->id, SILC_ID_CHANNEL))); - - /* Remove the old channel entry */ - silc_idcache_del_by_context(conn->channel_cache, channel); + /* Get the channel entry */ + channel = silc_client_get_channel_by_id(client, conn, channel_id); + if (!channel) + goto out; - /* Free the old ID */ - silc_free(channel->id); + silc_free(channel_id); + channel_id = NULL; /* Get the new ID */ tmp = silc_argument_get_arg_type(args, 2, &tmp_len); if (!tmp) goto out; - channel->id = silc_id_payload_parse_id(tmp, tmp_len); - if (!channel->id) + channel_id = silc_id_payload_parse_id(tmp, tmp_len, NULL); + if (!channel_id) goto out; - SILC_LOG_DEBUG(("New Channel ID id(%s)", - silc_id_render(channel->id, SILC_ID_CHANNEL))); - - /* Add the channel entry again to ID cache */ - silc_idcache_add(conn->channel_cache, channel->channel_name, - channel->id, channel, 0, NULL); + /* Replace the Channel ID */ + if (silc_client_replace_channel_id(client, conn, channel, channel_id)) + channel_id = NULL; /* Notify application */ - client->ops->notify(client, conn, type, channel, channel); + client->internal->ops->notify(client, conn, type, channel, channel); break; case SILC_NOTIFY_TYPE_KICKED: @@ -742,7 +1023,7 @@ void silc_client_notify_by_server(SilcClient client, if (!tmp) goto out; - client_id = silc_id_payload_parse_id(tmp, tmp_len); + client_id = silc_id_payload_parse_id(tmp, tmp_len, NULL); if (!client_id) goto out; @@ -756,29 +1037,28 @@ void silc_client_notify_by_server(SilcClient client, SILC_ID_CHANNEL); if (!channel_id) goto out; - if (!silc_idcache_find_by_id_one(conn->channel_cache, (void *)channel_id, - &id_cache)) + channel = silc_client_get_channel_by_id(client, conn, channel_id); + if (!channel) break; - channel = (SilcChannelEntry)id_cache->context; - - /* Get the kicker */ + /* From protocol version 1.1 we get the kicker's client ID as well */ tmp = silc_argument_get_arg_type(args, 3, &tmp_len); - if (!tmp) - goto out; - - client_id = silc_id_payload_parse_id(tmp, tmp_len); - if (!client_id) - goto out; + if (tmp) { + silc_free(client_id); + client_id = silc_id_payload_parse_id(tmp, tmp_len, NULL); + if (!client_id) + goto out; - /* Find kicker's client entry and if not found resolve it */ - client_entry2 = silc_client_get_client_by_id(client, conn, client_id); - if (!client_entry2) { - silc_client_notify_by_server_resolve(client, conn, packet, client_id); - goto out; - } else { - if (client_entry2 != conn->local_entry) - silc_client_nickname_format(client, conn, client_entry2); + /* Find kicker's client entry and if not found resolve it */ + client_entry2 = silc_client_get_client_by_id(client, conn, client_id); + if (!client_entry2) { + silc_client_notify_by_server_resolve(client, conn, packet, + SILC_ID_CLIENT, client_id); + goto out; + } else { + if (client_entry2 != conn->local_entry) + silc_client_nickname_format(client, conn, client_entry2); + } } /* Get comment */ @@ -787,55 +1067,139 @@ void silc_client_notify_by_server(SilcClient client, /* Notify application. The channel entry is sent last as this notify is for channel but application don't know it from the arguments sent by server. */ - client->ops->notify(client, conn, type, client_entry, tmp, - client_entry2, channel); + client->internal->ops->notify(client, conn, type, client_entry, tmp, + client_entry2, channel); - /* If I was kicked from channel, remove the channel */ + /* Remove kicked client from channel */ if (client_entry == conn->local_entry) { + /* If I was kicked from channel, remove the channel */ if (conn->current_channel == channel) conn->current_channel = NULL; - silc_idcache_del_by_id(conn->channel_cache, channel->id); - silc_free(channel->channel_name); - silc_free(channel->id); - silc_free(channel->key); - silc_cipher_free(channel->channel_key); - silc_free(channel); + silc_client_del_channel(client, conn, channel); + } else { + chu = silc_client_on_channel(channel, client_entry); + if (chu) { + silc_hash_table_del(client_entry->channels, channel); + silc_hash_table_del(channel->user_list, client_entry); + silc_free(chu); + } + + if (!silc_hash_table_count(client_entry->channels)) { + SilcClientNotifyResolve res = silc_calloc(1, sizeof(*res)); + res->context = client; + res->sock = silc_socket_dup(conn->sock); + res->packet = silc_id_dup(client_entry->id, SILC_ID_CLIENT); + silc_schedule_task_add(client->schedule, conn->sock->sock, + silc_client_notify_check_client, res, + (5 + (silc_rng_get_rn16(client->rng) % 529)), + 0, SILC_TASK_TIMEOUT, SILC_TASK_PRI_NORMAL); + } } break; case SILC_NOTIFY_TYPE_KILLED: - /* - * A client (maybe me) was killed from the network. - */ + { + /* + * A client (maybe me) was killed from the network. + */ + char *comment; + SilcUInt32 comment_len; - SILC_LOG_DEBUG(("Notify: KILLED")); + SILC_LOG_DEBUG(("Notify: KILLED")); - /* Get Client ID */ - tmp = silc_argument_get_arg_type(args, 1, &tmp_len); - if (!tmp) - goto out; + /* 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); - if (!client_id) - goto out; + client_id = silc_id_payload_parse_id(tmp, tmp_len, NULL); + if (!client_id) + goto out; - /* Find Client entry */ - client_entry = silc_client_get_client_by_id(client, conn, client_id); - if (!client_entry) - goto out; + /* Find Client entry */ + client_entry = silc_client_get_client_by_id(client, conn, client_id); + if (!client_entry) + goto out; - /* Get comment */ - tmp = silc_argument_get_arg_type(args, 2, &tmp_len); + /* Get comment */ + comment = silc_argument_get_arg_type(args, 2, &comment_len); + + /* From protocol version 1.1 we get killer's client ID as well */ + tmp = silc_argument_get_arg_type(args, 3, &tmp_len); + if (tmp) { + silc_free(client_id); + client_id = NULL; + id = silc_id_payload_parse_id(tmp, tmp_len, &id_type); + if (!id) + goto out; + + /* Find Client entry */ + if (id_type == SILC_ID_CLIENT) { + /* Find Client entry */ + client_id = id; + client_entry2 = silc_client_get_client_by_id(client, conn, + client_id); + if (!client_entry) { + silc_client_notify_by_server_resolve(client, conn, packet, + SILC_ID_CLIENT, client_id); + goto out; + } + } else if (id_type == SILC_ID_SERVER) { + /* Find Server entry */ + server_id = id; + server = silc_client_get_server_by_id(client, conn, server_id); + if (!server) { + silc_client_notify_by_server_resolve(client, conn, packet, + SILC_ID_SERVER, server_id); + server = silc_client_add_server(client, conn, NULL, NULL, + server_id); + if (!server) + goto out; + + server->resolve_cmd_ident = conn->cmd_ident; + server_id = NULL; + goto out; + } + + if (server->resolve_cmd_ident) { + SilcClientNotifyResolve res = silc_calloc(1, sizeof(*res)); + res->packet = silc_packet_context_dup(packet); + res->context = client; + res->sock = silc_socket_dup(conn->sock); + silc_client_command_pending(conn, SILC_COMMAND_NONE, + server->resolve_cmd_ident, + silc_client_notify_by_server_pending, + res); + goto out; + } + + /* Save the pointer to the client_entry pointer */ + client_entry2 = (SilcClientEntry)server; + } else { + /* Find Channel entry */ + channel_id = id; + channel = silc_client_get_channel_by_id(client, conn, channel_id); + if (!channel) { + silc_client_notify_by_server_resolve(client, conn, packet, + SILC_ID_CHANNEL, channel_id); + goto out; + } + + /* Save the pointer to the client_entry pointer */ + client_entry2 = (SilcClientEntry)channel; + silc_free(channel_id); + channel_id = NULL; + } + } - /* Notify application. */ - client->ops->notify(client, conn, type, client_entry, tmp); + /* Notify application. */ + client->internal->ops->notify(client, conn, type, client_entry, + comment, id_type, client_entry2); - if (client_entry != conn->local_entry) { - /* Remove client from all channels */ - silc_client_remove_from_channels(client, conn, client_entry); - silc_client_del_client(client, conn, client_entry); + if (client_entry != conn->local_entry) + /* Remove the client from all channels and free it */ + silc_client_del_client(client, conn, client_entry); } - break; case SILC_NOTIFY_TYPE_SERVER_SIGNOFF: @@ -845,7 +1209,7 @@ void silc_client_notify_by_server(SilcClient client, * from channels as they quit as well. */ SilcClientEntry *clients = NULL; - uint32 clients_count = 0; + SilcUInt32 clients_count = 0; int i; SILC_LOG_DEBUG(("Notify: SIGNOFF")); @@ -854,7 +1218,7 @@ void silc_client_notify_by_server(SilcClient client, /* Get Client ID */ tmp = silc_argument_get_arg_type(args, i + 1, &tmp_len); if (tmp) { - client_id = silc_id_payload_parse_id(tmp, tmp_len); + client_id = silc_id_payload_parse_id(tmp, tmp_len, NULL); if (!client_id) goto out; @@ -874,7 +1238,8 @@ void silc_client_notify_by_server(SilcClient client, /* Notify application. We don't keep server entries so the server entry is returned as NULL. The client's are returned as array of SilcClientEntry pointers. */ - client->ops->notify(client, conn, type, NULL, clients, clients_count); + client->internal->ops->notify(client, conn, type, NULL, + clients, clients_count); for (i = 0; i < clients_count; i++) { /* Remove client from all channels */ @@ -882,7 +1247,7 @@ void silc_client_notify_by_server(SilcClient client, if (client_entry == conn->local_entry) continue; - silc_client_remove_from_channels(client, conn, client_entry); + /* Remove the client from all channels and free it */ silc_client_del_client(client, conn, client_entry); } silc_free(clients); @@ -890,6 +1255,125 @@ void silc_client_notify_by_server(SilcClient client, } break; + case SILC_NOTIFY_TYPE_ERROR: + { + /* + * Some has occurred and server is notifying us about it. + */ + SilcStatus error; + + tmp = silc_argument_get_arg_type(args, 1, &tmp_len); + if (!tmp && tmp_len != 1) + goto out; + error = (SilcStatus)tmp[0]; + + SILC_LOG_DEBUG(("Notify: ERROR (%d)", error)); + + if (error == SILC_STATUS_ERR_NO_SUCH_CLIENT_ID) { + tmp = silc_argument_get_arg_type(args, 2, &tmp_len); + if (tmp) { + client_id = silc_id_payload_parse_id(tmp, tmp_len, NULL); + if (!client_id) + goto out; + client_entry = silc_client_get_client_by_id(client, conn, + client_id); + if (client_entry) + silc_client_del_client(client, conn, client_entry); + } + } + + /* Notify application. */ + client->internal->ops->notify(client, conn, type, error); + } + break; + + case SILC_NOTIFY_TYPE_WATCH: + { + /* + * Received notify about some client we are watching + */ + SilcNotifyType notify = 0; + bool del_client = FALSE; + + SILC_LOG_DEBUG(("Notify: WATCH")); + + /* Get sender 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, NULL); + if (!client_id) + goto out; + + /* Find Client entry and if not found query it */ + client_entry = silc_client_get_client_by_id(client, conn, client_id); + if (!client_entry) { + silc_client_notify_by_server_resolve(client, conn, packet, + SILC_ID_CLIENT, client_id); + goto out; + } + + /* Get user mode */ + tmp = silc_argument_get_arg_type(args, 3, &tmp_len); + if (!tmp || tmp_len != 4) + goto out; + SILC_GET32_MSB(mode, tmp); + + /* Get notify type */ + tmp = silc_argument_get_arg_type(args, 4, &tmp_len); + if (tmp && tmp_len != 2) + goto out; + if (tmp) + SILC_GET16_MSB(notify, tmp); + + /* Get nickname */ + tmp = silc_argument_get_arg_type(args, 2, NULL); + if (tmp) { + char *tmp_nick = NULL; + + if (client->internal->params->nickname_parse) + client->internal->params->nickname_parse(client_entry->nickname, + &tmp_nick); + else + tmp_nick = strdup(tmp); + + /* If same nick, the client was new to us and has become "present" + to network. Send NULL as nick to application. */ + if (tmp_nick && !strcmp(tmp, tmp_nick)) + tmp = NULL; + + silc_free(tmp_nick); + } + + /* Notify application. */ + client->internal->ops->notify(client, conn, type, client_entry, + tmp, mode, notify); + + client_entry->mode = mode; + + /* If nickname was changed, remove the client entry unless the + client is on some channel */ + if (tmp && notify == SILC_NOTIFY_TYPE_NICK_CHANGE && + !silc_hash_table_count(client_entry->channels)) + del_client = TRUE; + else if (notify == SILC_NOTIFY_TYPE_SIGNOFF || + notify == SILC_NOTIFY_TYPE_SERVER_SIGNOFF || + notify == SILC_NOTIFY_TYPE_KILLED) + del_client = TRUE; + + if (del_client) { + SilcClientNotifyResolve res = silc_calloc(1, sizeof(*res)); + res->context = client; + res->sock = silc_socket_dup(conn->sock); + res->packet = client_id; + client_id = NULL; + silc_schedule_task_add(client->schedule, conn->sock->sock, + silc_client_notify_del_client_cb, res, + 1, 0, SILC_TASK_TIMEOUT, SILC_TASK_PRI_NORMAL); + } + } + break; + default: break; } @@ -898,4 +1382,5 @@ void silc_client_notify_by_server(SilcClient client, silc_notify_payload_free(payload); silc_free(client_id); silc_free(channel_id); + silc_free(server_id); }