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' ? 6667 : 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, "auto")) rec->autoconnect = TRUE;
 148         if (g_hash_table_lookup(optlist, "noauto")) rec->autoconnect = FALSE;
 149         if (g_hash_table_lookup(optlist, "proxy")) rec->no_proxy = FALSE;
 150         if (g_hash_table_lookup(optlist, "noproxy")) rec->no_proxy = TRUE;
 151
 152         if (*password != '\0' && strcmp(password, "-") != 0) rec->password = g_strdup(password);
 153         value = g_hash_table_lookup(optlist, "host");
 154         if (value != NULL && *value != '\0') {
 155                 rec->own_host = g_strdup(value);
 156                 rec->own_ip4 = rec->own_ip6 = NULL;
 157         }
 158
 159         signal_emit("server add fill", 2, rec, optlist);
 160
 161         server_setup_add(rec);
 162         printformat(NULL, NULL, MSGLEVEL_CLIENTNOTICE,
 163                     TXT_SETUPSERVER_ADDED, addr, port);
 164
 165         cmd_params_free(free_arg);
 166 }
 167
 168 /* SYNTAX: SERVER REMOVE <address> [<port>] */
 169 static void cmd_server_remove(const char *data)
 170 {
 171         SERVER_SETUP_REC *rec;
 172         char *addr, *port;
 173         void *free_arg;
 174
 175         if (!cmd_get_params(data, &free_arg, 2, &addr, &port))
 176                 return;
 177         if (*addr == '\0') cmd_param_error(CMDERR_NOT_ENOUGH_PARAMS);
 178
 179         if (*port == '\0')
 180                 rec = server_setup_find(addr, -1, NULL);
 181         else
 182                 rec = server_setup_find_port(addr, atoi(port));
 183
 184         if (rec == NULL)
 185                 printformat(NULL, NULL, MSGLEVEL_CLIENTNOTICE, TXT_SETUPSERVER_NOT_FOUND, addr, port);
 186         else {
 187                 server_setup_remove(rec);
 188                 printformat(NULL, NULL, MSGLEVEL_CLIENTNOTICE, TXT_SETUPSERVER_REMOVED, addr, port);
 189         }
 190
 191         cmd_params_free(free_arg);
 192 }
 193
 194 static void cmd_server(const char *data)
 195 {
 196         if (*data != '\0')
 197                 return;
 198
 199         if (servers == NULL && lookup_servers == NULL &&
 200             reconnects == NULL) {
 201                 printformat(NULL, NULL, MSGLEVEL_CLIENTNOTICE,
 202                             TXT_NO_CONNECTED_SERVERS);
 203         } else {
 204                 print_servers();
 205                 print_lookup_servers();
 206                 print_reconnects();
 207         }
 208
 209         signal_stop();
 210 }
 211
 212 static void cmd_server_connect(const char *data)
 213 {
 214         GHashTable *optlist;
 215         char *addr;
 216         void *free_arg;
 217
 218         if (!cmd_get_params(data, &free_arg, 1 | PARAM_FLAG_OPTIONS,
 219                             "connect", &optlist, &addr))
 220                 return;
 221
 222         if (*addr == '\0' || strcmp(addr, "+") == 0)
 223                 cmd_param_error(CMDERR_NOT_ENOUGH_PARAMS);
 224         if (*addr == '+') window_create(NULL, FALSE);
 225
 226         cmd_params_free(free_arg);
 227 }
 228
 229 static void sig_server_looking(SERVER_REC *server)
 230 {
 231         g_return_if_fail(server != NULL);
 232
 233         printformat(server, NULL, MSGLEVEL_CLIENTNOTICE, TXT_LOOKING_UP, server->connrec->address);
 234 }
 235
 236 static void sig_server_connecting(SERVER_REC *server, IPADDR *ip)
 237 {
 238         char ipaddr[MAX_IP_LEN];
 239
 240         g_return_if_fail(server != NULL);
 241         g_return_if_fail(ip != NULL);
 242
 243         net_ip2host(ip, ipaddr);
 244         printformat(server, NULL, MSGLEVEL_CLIENTNOTICE, TXT_CONNECTING,
 245                     server->connrec->address, ipaddr, server->connrec->port);
 246 }
 247
 248 static void sig_server_connected(SERVER_REC *server)
 249 {
 250         g_return_if_fail(server != NULL);
 251
 252         printformat(server, NULL, MSGLEVEL_CLIENTNOTICE,
 253                     TXT_CONNECTION_ESTABLISHED, server->connrec->address);
 254 }
 255
 256 static void sig_connect_failed(SERVER_REC *server, gchar *msg)
 257 {
 258         g_return_if_fail(server != NULL);
 259
 260         if (msg == NULL) {
 261                 /* no message so this wasn't unexpected fail - send
 262                    connection_lost message instead */
 263                 printformat(server, NULL, MSGLEVEL_CLIENTNOTICE,
 264                             TXT_CONNECTION_LOST, server->connrec->address);
 265         } else {
 266                 printformat(server, NULL, MSGLEVEL_CLIENTERROR,
 267                             TXT_CANT_CONNECT, server->connrec->address, server->connrec->port, msg);
 268         }
 269 }
 270
 271 static void sig_server_disconnected(SERVER_REC *server)
 272 {
 273         g_return_if_fail(server != NULL);
 274
 275         printformat(server, NULL, MSGLEVEL_CLIENTNOTICE,
 276                     TXT_CONNECTION_LOST, server->connrec->address);
 277 }
 278
 279 static void sig_server_quit(SERVER_REC *server, const char *msg)
 280 {
 281         g_return_if_fail(server != NULL);
 282
 283         printformat(server, NULL, MSGLEVEL_CLIENTNOTICE,
 284                     TXT_SERVER_QUIT, server->connrec->address, msg);
 285 }
 286
 287 static void sig_server_lag_disconnected(SERVER_REC *server)
 288 {
 289         g_return_if_fail(server != NULL);
 290
 291         printformat(server, NULL, MSGLEVEL_CLIENTNOTICE,
 292                     TXT_LAG_DISCONNECTED, server->connrec->address,
 293                     time(NULL)-server->lag_sent.tv_sec);
 294 }
 295
 296 static void sig_server_reconnect_removed(RECONNECT_REC *reconnect)
 297 {
 298         g_return_if_fail(reconnect != NULL);
 299
 300         printformat(NULL, NULL, MSGLEVEL_CLIENTNOTICE,
 301                     TXT_RECONNECT_REMOVED, reconnect->conn->address, reconnect->conn->port,
 302                     reconnect->conn->chatnet == NULL ? "" : reconnect->conn->chatnet);
 303 }
 304
 305 static void sig_server_reconnect_not_found(const char *tag)
 306 {
 307         g_return_if_fail(tag != NULL);
 308
 309         printformat(NULL, NULL, MSGLEVEL_CLIENTNOTICE,
 310                     TXT_RECONNECT_NOT_FOUND, tag);
 311 }
 312
 313 static void sig_chat_protocol_unknown(const char *protocol)
 314 {
 315         g_return_if_fail(protocol != NULL);
 316
 317         printformat(NULL, NULL, MSGLEVEL_CLIENTERROR,
 318                     TXT_UNKNOWN_CHAT_PROTOCOL, protocol);
 319 }
 320
 321 void fe_server_init(void)
 322 {
 323         command_bind("server", NULL, (SIGNAL_FUNC) cmd_server);
 324         command_bind("server connect", NULL, (SIGNAL_FUNC) cmd_server_connect);
 325         command_bind("server add", NULL, (SIGNAL_FUNC) cmd_server_add);
 326         command_bind("server remove", NULL, (SIGNAL_FUNC) cmd_server_remove);
 327         command_set_options("server add", "4 6 auto noauto proxy noproxy -host -port");
 328
 329         signal_add("server looking", (SIGNAL_FUNC) sig_server_looking);
 330         signal_add("server connecting", (SIGNAL_FUNC) sig_server_connecting);
 331         signal_add("server connected", (SIGNAL_FUNC) sig_server_connected);
 332         signal_add("server connect failed", (SIGNAL_FUNC) sig_connect_failed);
 333         signal_add("server disconnected", (SIGNAL_FUNC) sig_server_disconnected);
 334         signal_add("server quit", (SIGNAL_FUNC) sig_server_quit);
 335
 336         signal_add("server lag disconnect", (SIGNAL_FUNC) sig_server_lag_disconnected);
 337         signal_add("server reconnect remove", (SIGNAL_FUNC) sig_server_reconnect_removed);
 338         signal_add("server reconnect not found", (SIGNAL_FUNC) sig_server_reconnect_not_found);
 339
 340         signal_add("chat protocol unknown", (SIGNAL_FUNC) sig_chat_protocol_unknown);
 341 }
 342
 343 void fe_server_deinit(void)
 344 {
 345         command_unbind("server", (SIGNAL_FUNC) cmd_server);
 346         command_unbind("server connect", (SIGNAL_FUNC) cmd_server_connect);
 347         command_unbind("server add", (SIGNAL_FUNC) cmd_server_add);
 348         command_unbind("server remove", (SIGNAL_FUNC) cmd_server_remove);
 349
 350         signal_remove("server looking", (SIGNAL_FUNC) sig_server_looking);
 351         signal_remove("server connecting", (SIGNAL_FUNC) sig_server_connecting);
 352         signal_remove("server connected", (SIGNAL_FUNC) sig_server_connected);
 353         signal_remove("server connect failed", (SIGNAL_FUNC) sig_connect_failed);
 354         signal_remove("server disconnected", (SIGNAL_FUNC) sig_server_disconnected);
 355         signal_remove("server quit", (SIGNAL_FUNC) sig_server_quit);
 356
 357         signal_remove("server lag disconnect", (SIGNAL_FUNC) sig_server_lag_disconnected);
 358         signal_remove("server reconnect remove", (SIGNAL_FUNC) sig_server_reconnect_removed);
 359         signal_remove("server reconnect not found", (SIGNAL_FUNC) sig_server_reconnect_not_found);
 360
 361         signal_remove("chat protocol unknown", (SIGNAL_FUNC) sig_chat_protocol_unknown);
 362 }