apps/irssi/src/fe-common/core/fe-server.c

   1 /*
   2  fe-server.c : irssi
   3
   4     Copyright (C) 1999-2001 Timo Sirainen
   5
   6     This program is free software; you can redistribute it and/or modify
   7     it under the terms of the GNU General Public License as published by
   8     the Free Software Foundation; either version 2 of the License, or
   9     (at your option) any later version.
  10
  11     This program is distributed in the hope that it will be useful,
  12     but WITHOUT ANY WARRANTY; without even the implied warranty of
  13     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14     GNU General Public License for more details.
  15
  16     You should have received a copy of the GNU General Public License along
  17     with this program; if not, write to the Free Software Foundation, Inc.,
  18     51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
  19 */
  20
  21 #include "module.h"
  22 #include "signals.h"
  23 #include "commands.h"
  24 #include "network.h"
  25 #include "levels.h"
  26 #include "settings.h"
  27
  28 #include "chat-protocols.h"
  29 #include "chatnets.h"
  30 #include "servers.h"
  31 #include "servers-setup.h"
  32 #include "servers-reconnect.h"
  33
  34 #include "module-formats.h"
  35 #include "printtext.h"
  36
  37 static void print_servers(void)
  38 {
  39         GSList *tmp;
  40
  41         for (tmp = servers; tmp != NULL; tmp = tmp->next) {
  42                 SERVER_REC *rec = tmp->data;
  43
  44                 printformat(NULL, NULL, MSGLEVEL_CRAP, TXT_SERVER_LIST,
  45                             rec->tag, rec->connrec->address, rec->connrec->port,
  46                             rec->connrec->chatnet == NULL ? "" : rec->connrec->chatnet, rec->connrec->nick);
  47         }
  48 }
  49
  50 static void print_lookup_servers(void)
  51 {
  52         GSList *tmp;
  53         for (tmp = lookup_servers; tmp != NULL; tmp = tmp->next) {
  54                 SERVER_REC *rec = tmp->data;
  55
  56                 printformat(NULL, NULL, MSGLEVEL_CRAP, TXT_SERVER_LOOKUP_LIST,
  57                             rec->tag, rec->connrec->address, rec->connrec->port,
  58                             rec->connrec->chatnet == NULL ? "" : rec->connrec->chatnet, rec->connrec->nick);
  59         }
  60 }
  61
  62 static void print_reconnects(void)
  63 {
  64         GSList *tmp;
  65         char *tag, *next_connect;
  66         int left;
  67
  68         for (tmp = reconnects; tmp != NULL; tmp = tmp->next) {
  69                 RECONNECT_REC *rec = tmp->data;
  70                 SERVER_CONNECT_REC *conn = rec->conn;
  71
  72                 tag = g_strdup_printf("RECON-%d", rec->tag);
  73                 left = rec->next_connect-time(NULL);
  74                 next_connect = g_strdup_printf("%02d:%02d", left/60, left%60);
  75                 printformat(NULL, NULL, MSGLEVEL_CRAP, TXT_SERVER_RECONNECT_LIST,
  76                             tag, conn->address, conn->port,
  77                             conn->chatnet == NULL ? "" : conn->chatnet,
  78                             conn->nick, next_connect);
  79                 g_free(next_connect);
  80                 g_free(tag);
  81         }
  82 }
  83
  84 static SERVER_SETUP_REC *create_server_setup(GHashTable *optlist)
  85 {
  86         CHAT_PROTOCOL_REC *rec;
  87         SERVER_SETUP_REC *server;
  88         char *chatnet;
  89
  90         rec = chat_protocol_find_net(optlist);
  91         if (rec == NULL)
  92                 rec = chat_protocol_get_default();
  93         else {
  94                 chatnet = g_hash_table_lookup(optlist, rec->chatnet);
  95                 if (chatnet_find(chatnet) == NULL) {
  96                         printformat(NULL, NULL, MSGLEVEL_CLIENTNOTICE,
  97                                     TXT_UNKNOWN_CHATNET, chatnet);
  98                         return NULL;
  99                 }
 100         }
 101
 102         server = rec->create_server_setup();
 103         server->chat_type = rec->id;
 104         return server;
 105 }
 106
 107 static void cmd_server_add(const char *data)
 108 {
 109         GHashTable *optlist;
 110         SERVER_SETUP_REC *rec;
 111         char *addr, *portstr, *password, *value, *chatnet;
 112         void *free_arg;
 113         int port;
 114
 115         if (!cmd_get_params(data, &free_arg, 3 | PARAM_FLAG_OPTIONS,
 116                             "server add", &optlist, &addr, &portstr, &password))
 117                 return;
 118
 119         if (*addr == '\0') cmd_param_error(CMDERR_NOT_ENOUGH_PARAMS);
 120         port = *portstr == '\0' ? DEFAULT_SERVER_ADD_PORT : atoi(portstr);
 121
 122         chatnet = g_hash_table_lookup(optlist, "network");
 123
 124         rec = server_setup_find(addr, port, chatnet);
 125
 126         if (rec == NULL) {
 127                 rec = create_server_setup(optlist);
 128                 if (rec == NULL) {
 129                         cmd_params_free(free_arg);
 130                         return;
 131                 }
 132                 rec->address = g_strdup(addr);
 133                 rec->port = port;
 134         } else {
 135                 value = g_hash_table_lookup(optlist, "port");
 136                 if (value != NULL && *value != '\0') rec->port = atoi(value);
 137
 138                 if (*password != '\0') g_free_and_null(rec->password);
 139                 if (g_hash_table_lookup(optlist, "host")) {
 140                         g_free_and_null(rec->own_host);
 141                         rec->own_ip4 = rec->own_ip6 = NULL;
 142                 }
 143         }
 144
 145         if (g_hash_table_lookup(optlist, "6"))
 146                 rec->family = AF_INET6;
 147         else if (g_hash_table_lookup(optlist, "4"))
 148                 rec->family = AF_INET;
 149
 150         if (g_hash_table_lookup(optlist, "ssl"))
 151                 rec->use_ssl = TRUE;
 152
 153         value = g_hash_table_lookup(optlist, "ssl_cert");
 154         if (value != NULL && *value != '\0')
 155                 rec->ssl_cert = g_strdup(value);
 156
 157         value = g_hash_table_lookup(optlist, "ssl_pkey");
 158         if (value != NULL && *value != '\0')
 159                 rec->ssl_pkey = g_strdup(value);
 160
 161         if (g_hash_table_lookup(optlist, "ssl_verify"))
 162                 rec->ssl_verify = TRUE;
 163
 164         value = g_hash_table_lookup(optlist, "ssl_cafile");
 165         if (value != NULL && *value != '\0')
 166                 rec->ssl_cafile = g_strdup(value);
 167
 168         value = g_hash_table_lookup(optlist, "ssl_capath");
 169         if (value != NULL && *value != '\0')
 170                 rec->ssl_capath = g_strdup(value);
 171
 172         if ((rec->ssl_cafile != NULL && rec->ssl_cafile[0] != '\0')
 173         ||  (rec->ssl_capath != NULL && rec->ssl_capath[0] != '\0'))
 174                 rec->ssl_verify = TRUE;
 175
 176         if ((rec->ssl_cert != NULL && rec->ssl_cert[0] != '\0') || rec->ssl_verify == TRUE)
 177                 rec->use_ssl = TRUE;
 178
 179         if (g_hash_table_lookup(optlist, "auto")) rec->autoconnect = TRUE;
 180         if (g_hash_table_lookup(optlist, "noauto")) rec->autoconnect = FALSE;
 181         if (g_hash_table_lookup(optlist, "proxy")) rec->no_proxy = FALSE;
 182         if (g_hash_table_lookup(optlist, "noproxy")) rec->no_proxy = TRUE;
 183
 184         if (*password != '\0' && strcmp(password, "-") != 0) rec->password = g_strdup(password);
 185         value = g_hash_table_lookup(optlist, "host");
 186         if (value != NULL && *value != '\0') {
 187                 rec->own_host = g_strdup(value);
 188                 rec->own_ip4 = rec->own_ip6 = NULL;
 189         }
 190
 191         signal_emit("server add fill", 2, rec, optlist);
 192
 193         server_setup_add(rec);
 194         printformat(NULL, NULL, MSGLEVEL_CLIENTNOTICE,
 195                     TXT_SETUPSERVER_ADDED, addr, port);
 196
 197         cmd_params_free(free_arg);
 198 }
 199
 200 /* SYNTAX: SERVER REMOVE <address> [<port>] [<network>] */
 201 static void cmd_server_remove(const char *data)
 202 {
 203         SERVER_SETUP_REC *rec;
 204         char *addr, *port, *chatnet;
 205         void *free_arg;
 206
 207         if (!cmd_get_params(data, &free_arg, 3, &addr, &port, &chatnet))
 208                 return;
 209         if (*addr == '\0') cmd_param_error(CMDERR_NOT_ENOUGH_PARAMS);
 210
 211         if (*port == '\0') {
 212                 if (*chatnet == '\0')
 213                         rec = server_setup_find(addr, -1, NULL);
 214                 else
 215                         rec = server_setup_find(addr, -1, chatnet);
 216         }
 217         else
 218         {
 219                 if (*chatnet == '\0')
 220                         rec = server_setup_find(addr, atoi(port), NULL);
 221                 else
 222                         rec = server_setup_find(addr, atoi(port), chatnet);
 223         }
 224
 225         if (rec == NULL)
 226                 printformat(NULL, NULL, MSGLEVEL_CLIENTNOTICE, TXT_SETUPSERVER_NOT_FOUND, addr, port);
 227         else {
 228                 server_setup_remove(rec);
 229                 printformat(NULL, NULL, MSGLEVEL_CLIENTNOTICE, TXT_SETUPSERVER_REMOVED, addr, port);
 230         }
 231
 232         cmd_params_free(free_arg);
 233 }
 234
 235 static void cmd_server(const char *data)
 236 {
 237         if (*data != '\0')
 238                 return;
 239
 240         if (servers == NULL && lookup_servers == NULL &&
 241             reconnects == NULL) {
 242                 printformat(NULL, NULL, MSGLEVEL_CLIENTNOTICE,
 243                             TXT_NO_CONNECTED_SERVERS);
 244         } else {
 245                 print_servers();
 246                 print_lookup_servers();
 247                 print_reconnects();
 248         }
 249
 250         signal_stop();
 251 }
 252
 253 static void cmd_server_connect(const char *data)
 254 {
 255         GHashTable *optlist;
 256         char *addr;
 257         void *free_arg;
 258
 259         if (!cmd_get_params(data, &free_arg, 1 | PARAM_FLAG_OPTIONS,
 260                             "connect", &optlist, &addr))
 261                 return;
 262
 263         if (*addr == '\0' || strcmp(addr, "+") == 0)
 264                 cmd_param_error(CMDERR_NOT_ENOUGH_PARAMS);
 265         if (*addr == '+') window_create(NULL, FALSE);
 266
 267         cmd_params_free(free_arg);
 268 }
 269
 270 static void server_command(const char *data, SERVER_REC *server,
 271                            WI_ITEM_REC *item)
 272 {
 273         if (server == NULL) {
 274                 /* this command accepts non-connected server too */
 275                 server = active_win->connect_server;
 276         }
 277
 278         signal_continue(3, data, server, item);
 279 }
 280
 281 static void sig_server_looking(SERVER_REC *server)
 282 {
 283         g_return_if_fail(server != NULL);
 284
 285         printformat(server, NULL, MSGLEVEL_CLIENTNOTICE, TXT_LOOKING_UP, server->connrec->address);
 286 }
 287
 288 static void sig_server_connecting(SERVER_REC *server, IPADDR *ip)
 289 {
 290         char ipaddr[MAX_IP_LEN];
 291
 292         g_return_if_fail(server != NULL);
 293
 294         if (ip == NULL)
 295                 ipaddr[0] = '\0';
 296         else
 297                 net_ip2host(ip, ipaddr);
 298
 299         printformat(server, NULL, MSGLEVEL_CLIENTNOTICE,
 300                     !server->connrec->reconnecting ?
 301                     TXT_CONNECTING : TXT_RECONNECTING,
 302                     server->connrec->address, ipaddr, server->connrec->port);
 303 }
 304
 305 static void sig_server_connected(SERVER_REC *server)
 306 {
 307         g_return_if_fail(server != NULL);
 308
 309         printformat(server, NULL, MSGLEVEL_CLIENTNOTICE,
 310                     TXT_CONNECTION_ESTABLISHED, server->connrec->address);
 311 }
 312
 313 static void sig_connect_failed(SERVER_REC *server, gchar *msg)
 314 {
 315         g_return_if_fail(server != NULL);
 316
 317         if (msg == NULL) {
 318                 /* no message so this wasn't unexpected fail - send
 319                    connection_lost message instead */
 320                 printformat(server, NULL, MSGLEVEL_CLIENTNOTICE,
 321                             TXT_CONNECTION_LOST, server->connrec->address);
 322         } else {
 323                 printformat(server, NULL, MSGLEVEL_CLIENTERROR,
 324                             TXT_CANT_CONNECT, server->connrec->address, server->connrec->port, msg);
 325         }
 326 }
 327
 328 static void sig_server_disconnected(SERVER_REC *server)
 329 {
 330         g_return_if_fail(server != NULL);
 331
 332         printformat(server, NULL, MSGLEVEL_CLIENTNOTICE,
 333                     TXT_CONNECTION_LOST, server->connrec->address);
 334 }
 335
 336 static void sig_server_quit(SERVER_REC *server, const char *msg)
 337 {
 338         g_return_if_fail(server != NULL);
 339
 340         printformat(server, NULL, MSGLEVEL_CLIENTNOTICE,
 341                     TXT_SERVER_QUIT, server->connrec->address, msg);
 342 }
 343
 344 static void sig_server_lag_disconnected(SERVER_REC *server)
 345 {
 346         g_return_if_fail(server != NULL);
 347
 348         printformat(server, NULL, MSGLEVEL_CLIENTNOTICE,
 349                     TXT_LAG_DISCONNECTED, server->connrec->address,
 350                     time(NULL)-server->lag_sent.tv_sec);
 351 }
 352
 353 static void sig_server_reconnect_removed(RECONNECT_REC *reconnect)
 354 {
 355         g_return_if_fail(reconnect != NULL);
 356
 357         printformat(NULL, NULL, MSGLEVEL_CLIENTNOTICE,
 358                     TXT_RECONNECT_REMOVED, reconnect->conn->address, reconnect->conn->port,
 359                     reconnect->conn->chatnet == NULL ? "" : reconnect->conn->chatnet);
 360 }
 361
 362 static void sig_server_reconnect_not_found(const char *tag)
 363 {
 364         g_return_if_fail(tag != NULL);
 365
 366         printformat(NULL, NULL, MSGLEVEL_CLIENTNOTICE,
 367                     TXT_RECONNECT_NOT_FOUND, tag);
 368 }
 369
 370 static void sig_chat_protocol_unknown(const char *protocol)
 371 {
 372         g_return_if_fail(protocol != NULL);
 373
 374         printformat(NULL, NULL, MSGLEVEL_CLIENTERROR,
 375                     TXT_UNKNOWN_CHAT_PROTOCOL, protocol);
 376 }
 377
 378 void fe_server_init(void)
 379 {
 380         command_bind("server", NULL, (SIGNAL_FUNC) cmd_server);
 381         command_bind("server connect", NULL, (SIGNAL_FUNC) cmd_server_connect);
 382         command_bind("server add", NULL, (SIGNAL_FUNC) cmd_server_add);
 383         command_bind("server remove", NULL, (SIGNAL_FUNC) cmd_server_remove);
 384         command_bind_first("server", NULL, (SIGNAL_FUNC) server_command);
 385         command_bind_first("disconnect", NULL, (SIGNAL_FUNC) server_command);
 386         command_set_options("server add", "4 6 ssl +ssl_cert +ssl_pkey ssl_verify +ssl_cafile +ssl_capath auto noauto proxy noproxy -host -port");
 387
 388         signal_add("server looking", (SIGNAL_FUNC) sig_server_looking);
 389         signal_add("server connecting", (SIGNAL_FUNC) sig_server_connecting);
 390         signal_add("server connected", (SIGNAL_FUNC) sig_server_connected);
 391         signal_add("server connect failed", (SIGNAL_FUNC) sig_connect_failed);
 392         signal_add("server disconnected", (SIGNAL_FUNC) sig_server_disconnected);
 393         signal_add("server quit", (SIGNAL_FUNC) sig_server_quit);
 394
 395         signal_add("server lag disconnect", (SIGNAL_FUNC) sig_server_lag_disconnected);
 396         signal_add("server reconnect remove", (SIGNAL_FUNC) sig_server_reconnect_removed);
 397         signal_add("server reconnect not found", (SIGNAL_FUNC) sig_server_reconnect_not_found);
 398
 399         signal_add("chat protocol unknown", (SIGNAL_FUNC) sig_chat_protocol_unknown);
 400 }
 401
 402 void fe_server_deinit(void)
 403 {
 404         command_unbind("server", (SIGNAL_FUNC) cmd_server);
 405         command_unbind("server connect", (SIGNAL_FUNC) cmd_server_connect);
 406         command_unbind("server add", (SIGNAL_FUNC) cmd_server_add);
 407         command_unbind("server remove", (SIGNAL_FUNC) cmd_server_remove);
 408         command_unbind("server", (SIGNAL_FUNC) server_command);
 409         command_unbind("disconnect", (SIGNAL_FUNC) server_command);
 410
 411         signal_remove("server looking", (SIGNAL_FUNC) sig_server_looking);
 412         signal_remove("server connecting", (SIGNAL_FUNC) sig_server_connecting);
 413         signal_remove("server connected", (SIGNAL_FUNC) sig_server_connected);
 414         signal_remove("server connect failed", (SIGNAL_FUNC) sig_connect_failed);
 415         signal_remove("server disconnected", (SIGNAL_FUNC) sig_server_disconnected);
 416         signal_remove("server quit", (SIGNAL_FUNC) sig_server_quit);
 417
 418         signal_remove("server lag disconnect", (SIGNAL_FUNC) sig_server_lag_disconnected);
 419         signal_remove("server reconnect remove", (SIGNAL_FUNC) sig_server_reconnect_removed);
 420         signal_remove("server reconnect not found", (SIGNAL_FUNC) sig_server_reconnect_not_found);
 421
 422         signal_remove("chat protocol unknown", (SIGNAL_FUNC) sig_chat_protocol_unknown);
 423 }