X-Git-Url: http://git.silcnet.org/gitweb/?a=blobdiff_plain;f=apps%2Firssi%2Fsrc%2Fsilc%2Fcore%2Fsilc-servers.c;h=476205d450e0cfcf3c00b81e9f4da307873bf1b2;hb=c257b555225193e54d85daf541d29578b3c93882;hp=566b269a5c353dda7b44ae3ea660065774155839;hpb=6617b351fc8655b8772cae80117faf5b35cc0378;p=silc.git diff --git a/apps/irssi/src/silc/core/silc-servers.c b/apps/irssi/src/silc/core/silc-servers.c index 566b269a..476205d4 100644 --- a/apps/irssi/src/silc/core/silc-servers.c +++ b/apps/irssi/src/silc/core/silc-servers.c @@ -1,14 +1,14 @@ /* silc-server.c : irssi - Copyright (C) 2000 - 2001 Timo Sirainen - Pekka Riikonen + Copyright (C) 2000 - 2005 Timo Sirainen + 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 @@ -34,33 +34,46 @@ #include "servers-setup.h" +#include "client_ops.h" #include "silc-servers.h" #include "silc-channels.h" #include "silc-queries.h" +#include "silc-nicklist.h" +#include "silc-cmdqueue.h" #include "window-item-def.h" #include "fe-common/core/printtext.h" +#include "fe-common/core/fe-channels.h" +#include "fe-common/core/keyboard.h" #include "fe-common/silc/module-formats.h" +#include "silc-commands.h" + void silc_servers_reconnect_init(void); void silc_servers_reconnect_deinit(void); -static void silc_send_channel(SILC_SERVER_REC *server, - char *channel, char *msg) +int silc_send_channel(SILC_SERVER_REC *server, + char *channel, char *msg, + SilcMessageFlags flags) { SILC_CHANNEL_REC *rec; - + rec = silc_channel_find(server, channel); - if (rec == NULL || rec->entry == NULL) - return; - - silc_client_send_channel_message(silc_client, server->conn, rec->entry, - NULL, 0, msg, strlen(msg), TRUE); + if (rec == NULL || rec->entry == NULL) { + cmd_return_error_value(CMDERR_NOT_JOINED, FALSE); + } + + silc_client_send_channel_message(silc_client, server->conn, rec->entry, + NULL, flags, msg, strlen(msg), TRUE); + return TRUE; } typedef struct { char *nick; char *msg; + int len; + SilcMessageFlags flags; + SILC_SERVER_REC *server; } PRIVMSG_REC; /* Callback function that sends the private message if the client was @@ -69,57 +82,141 @@ typedef struct { static void silc_send_msg_clients(SilcClient client, SilcClientConnection conn, SilcClientEntry *clients, - uint32 clients_count, + SilcUInt32 clients_count, void *context) { PRIVMSG_REC *rec = context; + SILC_SERVER_REC *server = rec->server; SilcClientEntry target; - - if (clients_count == 0) { - printtext(NULL, NULL, MSGLEVEL_CLIENTERROR, "Unknown nick: %s", rec->nick); + char *nickname = NULL; + + if (!clients_count) { + printtext(NULL, NULL, MSGLEVEL_CLIENTERROR, + "%s: There is no such client", rec->nick); } else { - target = clients[0]; /* FIXME: not a good idea :) */ - - silc_client_send_private_message(client, conn, target, 0, - rec->msg, strlen(rec->msg), + if (clients_count > 1) { + silc_parse_userfqdn(rec->nick, &nickname, NULL); + + /* Find the correct one. The rec->nick might be a formatted nick + so this will find the correct one. */ + clients = silc_client_get_clients_local(silc_client, server->conn, + nickname, rec->nick, + &clients_count); + if (!clients) { + printtext(NULL, NULL, MSGLEVEL_CLIENTERROR, + "%s: There is no such client", rec->nick); + silc_free(nickname); + goto out; + } + silc_free(nickname); + } + + target = clients[0]; + + /* Still check for exact math for nickname, this compares the + real (formatted) nickname and the nick (maybe formatted) that + use gave. This is to assure that `nick' does not match + `nick@host'. */ + if (!silc_utf8_strcasecmp(rec->nick, clients[0]->nickname)) { + printtext(NULL, NULL, MSGLEVEL_CLIENTERROR, + "%s: There is no such client", rec->nick); + goto out; + } + + /* Send the private message */ + silc_client_send_private_message(client, conn, target, + rec->flags, + rec->msg, rec->len, TRUE); } - + + out: g_free(rec->nick); g_free(rec->msg); g_free(rec); } -static void silc_send_msg(SILC_SERVER_REC *server, char *nick, char *msg) +int silc_send_msg(SILC_SERVER_REC *server, char *nick, char *msg, + int msg_len, SilcMessageFlags flags) { PRIVMSG_REC *rec; - SilcClientEntry client_entry; - uint32 num = 0; - char *nickname = NULL, *serv = NULL; - - if (!silc_parse_nickname(nick, &nickname, &serv, &num)) { + SilcClientEntry *clients; + SilcUInt32 clients_count; + char *nickname = NULL; + + if (!silc_parse_userfqdn(nick, &nickname, NULL)) { printformat_module("fe-common/silc", server, NULL, MSGLEVEL_CRAP, SILCTXT_BAD_NICK, nick); - return; + return FALSE; } /* Find client entry */ - client_entry = silc_idlist_get_client(silc_client, server->conn, - nickname, serv, num, FALSE); - if (!client_entry) { + clients = silc_client_get_clients_local(silc_client, server->conn, + nickname, nick, &clients_count); + if (!clients) { rec = g_new0(PRIVMSG_REC, 1); rec->nick = g_strdup(nick); rec->msg = g_strdup(msg); + rec->server = server; + rec->flags = flags; + rec->len = msg_len; /* Could not find client with that nick, resolve it from server. */ silc_client_get_clients(silc_client, server->conn, - nickname, serv, silc_send_msg_clients, rec); - return; + nickname, NULL, silc_send_msg_clients, rec); + silc_free(nickname); + return TRUE; } /* Send the private message directly */ - silc_client_send_private_message(silc_client, server->conn, client_entry, 0, - msg, strlen(msg), TRUE); + silc_free(nickname); + silc_client_send_private_message(silc_client, server->conn, + clients[0], flags, + msg, msg_len, TRUE); + return TRUE; +} + +void silc_send_mime(SILC_SERVER_REC *server, int channel, const char *to, + const char *data, int sign) +{ + char *unescaped_data; + SilcUInt32 unescaped_data_len; + int target_type; + + if (!(IS_SILC_SERVER(server)) || (data == NULL) || (to == NULL)) + return; + + if (channel) { + target_type = SEND_TARGET_CHANNEL; + } else { + target_type = server_ischannel(SERVER(server), to) ? + SEND_TARGET_CHANNEL : SEND_TARGET_NICK; + } + + unescaped_data = silc_unescape_data(data, &unescaped_data_len); + + if (target_type == SEND_TARGET_CHANNEL) { + SILC_CHANNEL_REC *rec; + + rec = silc_channel_find(server, to); + if (rec == NULL || rec->entry == NULL) { + cmd_return_error(CMDERR_NOT_JOINED); + } + + silc_client_send_channel_message(silc_client, server->conn, rec->entry, + NULL, SILC_MESSAGE_FLAG_DATA | + (sign ? SILC_MESSAGE_FLAG_SIGNED : 0), + unescaped_data, unescaped_data_len, TRUE); + } else { + silc_send_msg(server, (char *)to, unescaped_data, unescaped_data_len, + SILC_MESSAGE_FLAG_DATA | + (sign ? SILC_MESSAGE_FLAG_SIGNED : 0)); + + } + + signal_stop(); + + silc_free(unescaped_data); } static int isnickflag_func(char flag) @@ -127,9 +224,9 @@ static int isnickflag_func(char flag) return flag == '@' || flag == '+'; } -static int ischannel_func(const char *data) +static int ischannel_func(SERVER_REC *server, const char *data) { - return *data == '#'; + return FALSE; } const char *get_nick_flags(void) @@ -137,40 +234,101 @@ const char *get_nick_flags(void) return "@\0\0"; } -static void send_message(SILC_SERVER_REC *server, char *target, char *msg) +static void send_message(SILC_SERVER_REC *server, char *target, + char *msg, int target_type) { + char *message = NULL, *t = NULL; + int len; + g_return_if_fail(server != NULL); g_return_if_fail(target != NULL); g_return_if_fail(msg != NULL); - if (*target == '#') - silc_send_channel(server, target, msg); - else - silc_send_msg(server, target, msg); + if (!silc_term_utf8()) { + len = silc_utf8_encoded_len(msg, strlen(msg), SILC_STRING_LOCALE); + message = silc_calloc(len + 1, sizeof(*message)); + g_return_if_fail(message != NULL); + silc_utf8_encode(msg, strlen(msg), SILC_STRING_LOCALE, message, len); + } + + if (target_type == SEND_TARGET_CHANNEL) + silc_send_channel(server, target, message ? message : msg, + SILC_MESSAGE_FLAG_UTF8); + else { + if (!silc_term_utf8()) { + len = silc_utf8_encoded_len(target, strlen(target), SILC_STRING_LOCALE); + t = silc_calloc(len + 1, sizeof(*t)); + g_return_if_fail(t != NULL); + silc_utf8_encode(target, strlen(target), SILC_STRING_LOCALE, t, len); + } + + silc_send_msg(server, t ? t : target, message ? message : msg, + message ? strlen(message) : strlen(msg), + SILC_MESSAGE_FLAG_UTF8); + } + + silc_free(message); + silc_free(t); +} + +void silc_send_heartbeat(SilcSocketConnection sock, + void *hb_context) +{ + SILC_SERVER_REC *server = SILC_SERVER(hb_context); + + if (server == NULL) + return; + + silc_client_send_packet(silc_client, server->conn, SILC_PACKET_HEARTBEAT, + NULL, 0); } static void sig_connected(SILC_SERVER_REC *server) { SilcClientConnection conn; + SilcClientConnectionParams params; + char *file; int fd; if (!IS_SILC_SERVER(server)) return; - conn = silc_client_add_connection(silc_client, + /* Try to read detached session data and use it if found. */ + memset(¶ms, 0, sizeof(params)); + file = silc_get_session_filename(server); + params.detach_data = silc_file_readfile(file, ¶ms.detach_data_len); + if (params.detach_data) + params.detach_data[params.detach_data_len] = 0; + + /* Add connection to the client library */ + conn = silc_client_add_connection(silc_client, ¶ms, server->connrec->address, server->connrec->port, server); server->conn = conn; - + + if (params.detach_data) + printformat_module("fe-common/silc", server, NULL, MSGLEVEL_CRAP, + SILCTXT_REATTACH, server->tag); + + silc_free(params.detach_data); + fd = g_io_channel_unix_get_fd(net_sendbuffer_handle(server->handle)); - if (!silc_client_start_key_exchange(silc_client, conn, fd)) { - /* some internal error occured */ - server_disconnect(SERVER(server)); - signal_stop(); - return; - } + /* Start key exchange with the server */ + silc_client_start_key_exchange(silc_client, conn, fd); + + /* Put default attributes */ + silc_query_attributes_default(silc_client, conn); + + /* initialize heartbeat sending */ + if (settings_get_int("heartbeat") > 0) + silc_socket_set_heartbeat(conn->sock, settings_get_int("heartbeat"), + (void *)server, + (SilcSocketConnectionHBCb)silc_send_heartbeat, + silc_client->schedule); + + server->ftp_sessions = silc_dlist_init(); server->isnickflag = isnickflag_func; server->ischannel = ischannel_func; server->get_nick_flags = get_nick_flags; @@ -179,12 +337,14 @@ static void sig_connected(SILC_SERVER_REC *server) static void sig_disconnected(SILC_SERVER_REC *server) { - if (!IS_SILC_SERVER(server) || server->conn == NULL) + if (!IS_SILC_SERVER(server)) return; - - if (server->conn->sock != NULL) { - silc_client_close_connection(silc_client, NULL, server->conn); - + + silc_dlist_uninit(server->ftp_sessions); + + if (server->conn && server->conn->sock != NULL) { + silc_client_close_connection(silc_client, server->conn); + /* SILC closes the handle */ g_io_channel_unref(net_sendbuffer_handle(server->handle)); net_sendbuffer_destroy(server->handle, FALSE); @@ -192,35 +352,40 @@ static void sig_disconnected(SILC_SERVER_REC *server) } } -SILC_SERVER_REC *silc_server_connect(SILC_SERVER_CONNECT_REC *conn) +SERVER_REC *silc_server_init_connect(SERVER_CONNECT_REC *conn) { SILC_SERVER_REC *server; g_return_val_if_fail(IS_SILC_SERVER_CONNECT(conn), NULL); - if (conn->address == NULL || *conn->address == '\0') + if (conn->address == NULL || *conn->address == '\0') return NULL; if (conn->nick == NULL || *conn->nick == '\0') { - printtext(NULL, NULL, MSGLEVEL_CLIENTERROR, - "Cannot connect: nickname is not set"); + silc_say_error("Cannot connect: nickname is not set"); return NULL; } server = g_new0(SILC_SERVER_REC, 1); server->chat_type = SILC_PROTOCOL; - server->connrec = conn; - if (server->connrec->port <= 0) + server->connrec = (SILC_SERVER_CONNECT_REC *)conn; + server_connect_ref(conn); + + if (server->connrec->port <= 0) server->connrec->port = 706; - if (!server_start_connect((SERVER_REC *) server)) { - server_connect_free(SERVER_CONNECT(conn)); + server_connect_init((SERVER_REC *)server); + return (SERVER_REC *)server; +} + +void silc_server_connect(SERVER_REC *server) +{ + if (!server_start_connect(server)) { + server_connect_unref(server->connrec); g_free(server); - return NULL; + return; } - - return server; } -/* Return a string of all channels in server in server->channels_join() +/* Return a string of all channels in server in server->channels_join() format */ char *silc_server_get_channels(SILC_SERVER_REC *server) @@ -234,7 +399,7 @@ char *silc_server_get_channels(SILC_SERVER_REC *server) chans = g_string_new(NULL); for (tmp = server->channels; tmp != NULL; tmp = tmp->next) { CHANNEL_REC *channel = tmp->data; - + g_string_sprintfa(chans, "%s,", channel->name); } @@ -243,7 +408,7 @@ char *silc_server_get_channels(SILC_SERVER_REC *server) ret = chans->str; g_string_free(chans, FALSE); - + return ret; } @@ -252,73 +417,56 @@ char *silc_server_get_channels(SILC_SERVER_REC *server) /* SYNTAX: BAN [+|-[[@[![@hostname>]]]]] */ /* SYNTAX: CMODE +|- [{ }] */ -/* SYNTAX: CUMODE +|- [@] [-pubkey|] */ -/* SYNTAX: GETKEY */ -/* SYNTAX: INVITE [[@server>] */ +/* SYNTAX: CUMODE +|- [@] */ +/* SYNTAX: GETKEY */ +/* SYNTAX: INVITE [[@hostname>] */ /* SYNTAX: INVITE [+|-[[@[![@hostname>]]]]] */ /* SYNTAX: KEY MSG set|unset|list|agreement|negotiate [] */ -/* SYNTAX: KEY CHANNEL set|unset|list|agreement|negotiate [] */ -/* SYNTAX: KICK [@] [] */ -/* SYNTAX: KILL [@] [] */ -/* SYNTAX: OPER [] */ -/* SYNTAX: SILCOPER [] */ -/* SYNTAX: TOPIC [ */ +/* SYNTAX: KEY CHANNEL set|unset|list|change [] */ +/* SYNTAX: KICK [@] [] */ +/* SYNTAX: KILL [@] [] [-pubkey] */ +/* SYNTAX: OPER [-pubkey] */ +/* SYNTAX: SILCOPER [-pubkey] */ +/* SYNTAX: TOPIC [] */ /* SYNTAX: UMODE +|- */ -/* SYNTAX: WHOIS [@] [] */ -/* SYNTAX: WHOWAS [@] [] */ +/* SYNTAX: WHOIS [[@]] [-details] [-pubkey ] [] */ +/* SYNTAX: WHOWAS [@] [] */ /* SYNTAX: CLOSE [] */ /* SYNTAX: SHUTDOWN */ /* SYNTAX: MOTD [] */ /* SYNTAX: LIST [] */ /* SYNTAX: ME */ -/* SYNTAX: ACTION */ +/* SYNTAX: ACTION [-sign] [-channel] */ /* SYNTAX: AWAY [] */ /* SYNTAX: INFO [] */ /* SYNTAX: NICK */ -/* SYNTAX: NOTICE */ +/* SYNTAX: NOTICE [-sign] [-channel] */ /* SYNTAX: PART [] */ /* SYNTAX: PING */ /* SYNTAX: SCONNECT [] */ /* SYNTAX: USERS */ +/* SYNTAX: FILE SEND [ []] [-no-listener]*/ +/* SYNTAX: FILE ACCEPT [] */ +/* SYNTAX: FILE CLOSE [] */ +/* SYNTAX: FILE */ +/* SYNTAX: JOIN [] [-cipher ] [-hmac ] [-founder] [-auth [ []]]*/ +/* SYNTAX: DETACH */ +/* SYNTAX: WATCH [<-add | -del> ] [-pubkey +|-] */ +/* SYNTAX: STATS */ +/* SYNTAX: ATTR [<-del>