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
  17     along with this program; if not, write to the Free Software
  18     Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  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;
 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         rec = server_setup_find_port(addr, port);
 123         if (rec == NULL) {
 124                 rec = create_server_setup(optlist);
 125                 if (rec == NULL) {
 126                         cmd_params_free(free_arg);
 127                         return;
 128                 }
 129                 rec->address = g_strdup(addr);
 130                 rec->port = port;
 131         } else {
 132                 value = g_hash_table_lookup(optlist, "port");
 133                 if (value != NULL && *value != '\0') rec->port = atoi(value);
 134
 135                 if (*password != '\0') g_free_and_null(rec->password);
 136                 if (g_hash_table_lookup(optlist, "host")) {
 137                         g_free_and_null(rec->own_host);
 138                         rec->own_ip4 = rec->own_ip6 = NULL;
 139                 }
 140         }
 141
 142         if (g_hash_table_lookup(optlist, "6"))
 143                 rec->family = AF_INET6;
 144         else if (g_hash_table_lookup(optlist, "4"))
 145                 rec->family = AF_INET;
 146
 147         if (g_hash_table_lookup(optlist, "ssl"))
 148                 rec->use_ssl = TRUE;
 149
 150         value = g_hash_table_lookup(optlist, "ssl_cert");
 151         if (value != NULL && *value != '\0')
 152                 rec->ssl_cert = g_strdup(value);
 153
 154         value = g_hash_table_lookup(optlist, "ssl_pkey");
 155         if (value != NULL && *value != '\0')
 156                 rec->ssl_pkey = g_strdup(value);
 157
 158         if (g_hash_table_lookup(optlist, "ssl_verify"))
 159                 rec->ssl_verify = TRUE;
 160
 161         value = g_hash_table_lookup(optlist, "ssl_cafile");
 162         if (value != NULL && *value != '\0')
 163                 rec->ssl_cafile = g_strdup(value);
 164
 165         value = g_hash_table_lookup(optlist, "ssl_capath");
 166         if (value != NULL && *value != '\0')
 167                 rec->ssl_capath = g_strdup(value);
 168
 169         if ((rec->ssl_cafile != NULL && rec->ssl_cafile[0] != '\0')
 170         ||  (rec->ssl_capath != NULL && rec->ssl_capath[0] != '\0'))
 171                 rec->ssl_verify = TRUE;
 172
 173         if ((rec->ssl_cert != NULL && rec->ssl_cert[0] != '\0') || rec->ssl_verify == TRUE)
 174                 rec->use_ssl = TRUE;
 175
 176         if (g_hash_table_lookup(optlist, "auto")) rec->autoconnect = TRUE;
 177         if (g_hash_table_lookup(optlist, "noauto")) rec->autoconnect = FALSE;
 178         if (g_hash_table_lookup(optlist, "proxy")) rec->no_proxy = FALSE;
 179         if (g_hash_table_lookup(optlist, "noproxy")) rec->no_proxy = TRUE;
 180
 181         if (*password != '\0' && strcmp(password, "-") != 0) rec->password = g_strdup(password);
 182         value = g_hash_table_lookup(optlist, "host");
 183         if (value != NULL && *value != '\0') {
 184                 rec->own_host = g_strdup(value);
 185                 rec->own_ip4 = rec->own_ip6 = NULL;
 186         }
 187
 188         signal_emit("server add fill", 2, rec, optlist);
 189
 190         server_setup_add(rec);
 191         printformat(NULL, NULL, MSGLEVEL_CLIENTNOTICE,
 192                     TXT_SETUPSERVER_ADDED, addr, port);
 193
 194         cmd_params_free(free_arg);
 195 }
 196
 197 /* SYNTAX: SERVER REMOVE <address> [<port>] */
 198 static void cmd_server_remove(const char *data)
 199 {
 200         SERVER_SETUP_REC *rec;
 201         char *addr, *port;
 202         void *free_arg;
 203
 204         if (!cmd_get_params(data, &free_arg, 2, &addr, &port))
 205                 return;
 206         if (*addr == '\0') cmd_param_error(CMDERR_NOT_ENOUGH_PARAMS);
 207
 208         if (*port == '\0')
 209                 rec = server_setup_find(addr, -1, NULL);
 210         else
 211                 rec = server_setup_find_port(addr, atoi(port));
 212
 213         if (rec == NULL)
 214                 printformat(NULL, NULL, MSGLEVEL_CLIENTNOTICE, TXT_SETUPSERVER_NOT_FOUND, addr, port);
 215         else {
 216                 server_setup_remove(rec);
 217                 printformat(NULL, NULL, MSGLEVEL_CLIENTNOTICE, TXT_SETUPSERVER_REMOVED, addr, port);
 218         }
 219
 220         cmd_params_free(free_arg);
 221 }
 222
 223 static void cmd_server(const char *data)
 224 {
 225         if (*data != '\0')
 226                 return;
 227
 228         if (servers == NULL && lookup_servers == NULL &&
 229             reconnects == NULL) {
 230                 printformat(NULL, NULL, MSGLEVEL_CLIENTNOTICE,
 231                             TXT_NO_CONNECTED_SERVERS);
 232         } else {
 233                 print_servers();
 234                 print_lookup_servers();
 235                 print_reconnects();
 236         }
 237
 238         signal_stop();
 239 }
 240
 241 static void cmd_server_connect(const char *data)
 242 {
 243         GHashTable *optlist;
 244         char *addr;
 245         void *free_arg;
 246
 247         if (!cmd_get_params(data, &free_arg, 1 | PARAM_FLAG_OPTIONS,
 248                             "connect", &optlist, &addr))
 249                 return;
 250
 251         if (*addr == '\0' || strcmp(addr, "+") == 0)
 252                 cmd_param_error(CMDERR_NOT_ENOUGH_PARAMS);
 253         if (*addr == '+') window_create(NULL, FALSE);
 254
 255         cmd_params_free(free_arg);
 256 }
 257
 258 static void server_command(const char *data, SERVER_REC *server,
 259                            WI_ITEM_REC *item)
 260 {
 261         if (server == NULL) {
 262                 /* this command accepts non-connected server too */
 263                 server = active_win->connect_server;
 264         }
 265
 266         signal_continue(3, data, server, item);
 267 }
 268
 269 static void sig_server_looking(SERVER_REC *server)
 270 {
 271         g_return_if_fail(server != NULL);
 272
 273         printformat(server, NULL, MSGLEVEL_CLIENTNOTICE, TXT_LOOKING_UP, server->connrec->address);
 274 }
 275
 276 static void sig_server_connecting(SERVER_REC *server, IPADDR *ip)
 277 {
 278         char ipaddr[MAX_IP_LEN];
 279
 280         g_return_if_fail(server != NULL);
 281
 282         if (ip == NULL)
 283                 ipaddr[0] = '\0';
 284         else
 285                 net_ip2host(ip, ipaddr);
 286
 287         printformat(server, NULL, MSGLEVEL_CLIENTNOTICE,
 288                     !server->connrec->reconnecting ?
 289                     TXT_CONNECTING : TXT_RECONNECTING,
 290                     server->connrec->address, ipaddr, server->connrec->port);
 291 }
 292
 293 static void sig_server_connected(SERVER_REC *server)
 294 {
 295         g_return_if_fail(server != NULL);
 296
 297         printformat(server, NULL, MSGLEVEL_CLIENTNOTICE,
 298                     TXT_CONNECTION_ESTABLISHED, server->connrec->address);
 299 }
 300
 301 static void sig_connect_failed(SERVER_REC *server, gchar *msg)
 302 {
 303         g_return_if_fail(server != NULL);
 304
 305         if (msg == NULL) {
 306                 /* no message so this wasn't unexpected fail - send
 307                    connection_lost message instead */
 308                 printformat(server, NULL, MSGLEVEL_CLIENTNOTICE,
 309                             TXT_CONNECTION_LOST, server->connrec->address);
 310         } else {
 311                 printformat(server, NULL, MSGLEVEL_CLIENTERROR,
 312                             TXT_CANT_CONNECT, server->connrec->address, server->connrec->port, msg);
 313         }
 314 }
 315
 316 static void sig_server_disconnected(SERVER_REC *server)
 317 {
 318         g_return_if_fail(server != NULL);
 319
 320         printformat(server, NULL, MSGLEVEL_CLIENTNOTICE,
 321                     TXT_CONNECTION_LOST, server->connrec->address);
 322 }
 323
 324 static void sig_server_quit(SERVER_REC *server, const char *msg)
 325 {
 326         g_return_if_fail(server != NULL);
 327
 328         printformat(server, NULL, MSGLEVEL_CLIENTNOTICE,
 329                     TXT_SERVER_QUIT, server->connrec->address, msg);
 330 }
 331
 332 static void sig_server_lag_disconnected(SERVER_REC *server)
 333 {
 334         g_return_if_fail(server != NULL);
 335
 336         printformat(server, NULL, MSGLEVEL_CLIENTNOTICE,
 337                     TXT_LAG_DISCONNECTED, server->connrec->address,
 338                     time(NULL)-server->lag_sent.tv_sec);
 339 }
 340
 341 static void sig_server_reconnect_removed(RECONNECT_REC *reconnect)
 342 {
 343         g_return_if_fail(reconnect != NULL);
 344
 345         printformat(NULL, NULL, MSGLEVEL_CLIENTNOTICE,
 346                     TXT_RECONNECT_REMOVED, reconnect->conn->address, reconnect->conn->port,
 347                     reconnect->conn->chatnet == NULL ? "" : reconnect->conn->chatnet);
 348 }
 349
 350 static void sig_server_reconnect_not_found(const char *tag)
 351 {
 352         g_return_if_fail(tag != NULL);
 353
 354         printformat(NULL, NULL, MSGLEVEL_CLIENTNOTICE,
 355                     TXT_RECONNECT_NOT_FOUND, tag);
 356 }
 357
 358 static void sig_chat_protocol_unknown(const char *protocol)
 359 {
 360         g_return_if_fail(protocol != NULL);
 361
 362         printformat(NULL, NULL, MSGLEVEL_CLIENTERROR,
 363                     TXT_UNKNOWN_CHAT_PROTOCOL, protocol);
 364 }
 365
 366 void fe_server_init(void)
 367 {
 368         command_bind("server", NULL, (SIGNAL_FUNC) cmd_server);
 369         command_bind("server connect", NULL, (SIGNAL_FUNC) cmd_server_connect);
 370         command_bind("server add", NULL, (SIGNAL_FUNC) cmd_server_add);
 371         command_bind("server remove", NULL, (SIGNAL_FUNC) cmd_server_remove);
 372         command_bind_first("server", NULL, (SIGNAL_FUNC) server_command);
 373         command_bind_first("disconnect", NULL, (SIGNAL_FUNC) server_command);
 374         command_set_options("server add", "4 6 ssl +ssl_cert +ssl_pkey ssl_verify +ssl_cafile +ssl_capath auto noauto proxy noproxy -host -port");
 375
 376         signal_add("server looking", (SIGNAL_FUNC) sig_server_looking);
 377         signal_add("server connecting", (SIGNAL_FUNC) sig_server_connecting);
 378         signal_add("server connected", (SIGNAL_FUNC) sig_server_connected);
 379         signal_add("server connect failed", (SIGNAL_FUNC) sig_connect_failed);
 380         signal_add("server disconnected", (SIGNAL_FUNC) sig_server_disconnected);
 381         signal_add("server quit", (SIGNAL_FUNC) sig_server_quit);
 382
 383         signal_add("server lag disconnect", (SIGNAL_FUNC) sig_server_lag_disconnected);
 384         signal_add("server reconnect remove", (SIGNAL_FUNC) sig_server_reconnect_removed);
 385         signal_add("server reconnect not found", (SIGNAL_FUNC) sig_server_reconnect_not_found);
 386
 387         signal_add("chat protocol unknown", (SIGNAL_FUNC) sig_chat_protocol_unknown);
 388 }
 389
 390 void fe_server_deinit(void)
 391 {
 392         command_unbind("server", (SIGNAL_FUNC) cmd_server);
 393         command_unbind("server connect", (SIGNAL_FUNC) cmd_server_connect);
 394         command_unbind("server add", (SIGNAL_FUNC) cmd_server_add);
 395         command_unbind("server remove", (SIGNAL_FUNC) cmd_server_remove);
 396         command_unbind("server", (SIGNAL_FUNC) server_command);
 397         command_unbind("disconnect", (SIGNAL_FUNC) server_command);
 398
 399         signal_remove("server looking", (SIGNAL_FUNC) sig_server_looking);
 400         signal_remove("server connecting", (SIGNAL_FUNC) sig_server_connecting);
 401         signal_remove("server connected", (SIGNAL_FUNC) sig_server_connected);
 402         signal_remove("server connect failed", (SIGNAL_FUNC) sig_connect_failed);
 403         signal_remove("server disconnected", (SIGNAL_FUNC) sig_server_disconnected);
 404         signal_remove("server quit", (SIGNAL_FUNC) sig_server_quit);
 405
 406         signal_remove("server lag disconnect", (SIGNAL_FUNC) sig_server_lag_disconnected);
 407         signal_remove("server reconnect remove", (SIGNAL_FUNC) sig_server_reconnect_removed);
 408         signal_remove("server reconnect not found", (SIGNAL_FUNC) sig_server_reconnect_not_found);
 409
 410         signal_remove("chat protocol unknown", (SIGNAL_FUNC) sig_chat_protocol_unknown);
 411 }