src/protocols/icq/icqlib.c

   1 /* -*- Mode: C; tab-width: 2; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
   2
   3 /*
   4  * $Id: icqlib.c 2096 2001-07-31 01:00:39Z warmenhoven $
   5  *
   6  * Copyright (C) 1998-2001, Denis V. Dmitrienko <denis@null.net> and
   7  *                          Bill Soudan <soudan@kde.org>
   8  *
   9  * This program is free software; you can redistribute it and/or modify
  10  * it under the terms of the GNU General Public License as published by
  11  * the Free Software Foundation; either version 2 of the License, or
  12  * (at your option) any later version.
  13  *
  14  * This program is distributed in the hope that it will be useful,
  15  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  16  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  17  * GNU General Public License for more details.
  18  *
  19  * You should have received a copy of the GNU General Public License
  20  * along with this program; if not, write to the Free Software
  21  * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  22  *
  23  */
  24
  25 #include "icqlib.h"
  26
  27 #include <stdlib.h>
  28
  29 #ifdef _WIN32
  30 #include <winsock.h>
  31 #else
  32 #include <netdb.h>
  33 #include <sys/socket.h>
  34 #endif
  35
  36 #include <sys/stat.h>
  37
  38 #include "util.h"
  39 #include "icq.h"
  40 #include "udp.h"
  41 #include "tcp.h"
  42 #include "queue.h"
  43 #include "socketmanager.h"
  44 #include "contacts.h"
  45
  46 int icq_Russian = FALSE;
  47 BYTE icq_LogLevel = 0;
  48
  49 DWORD icq_SendMessage(icq_Link *icqlink, DWORD uin, const char *text,
  50   BYTE thruSrv)
  51 {
  52   if(thruSrv==ICQ_SEND_THRUSERVER)
  53     return icq_UDPSendMessage(icqlink, uin, text);
  54   else if(thruSrv==ICQ_SEND_DIRECT)
  55     return icq_TCPSendMessage(icqlink, uin, text);
  56   else if(thruSrv==ICQ_SEND_BESTWAY)
  57   {
  58     icq_ContactItem *pcontact=icq_ContactFind(icqlink, uin);
  59     if(pcontact)
  60     {
  61       if(pcontact->tcp_flag == 0x04)
  62         return icq_TCPSendMessage(icqlink, uin, text);
  63       else
  64         return icq_UDPSendMessage(icqlink, uin, text);
  65     }
  66     else
  67     {
  68       return icq_UDPSendMessage(icqlink, uin, text);
  69     }
  70   }
  71   return 0;
  72 }
  73
  74 DWORD icq_SendURL(icq_Link *icqlink, DWORD uin, const char *url,
  75   const char *descr, BYTE thruSrv)
  76 {
  77   if(thruSrv==ICQ_SEND_THRUSERVER)
  78     return icq_UDPSendURL(icqlink, uin, url, descr);
  79   else if(thruSrv==ICQ_SEND_DIRECT)
  80     return icq_TCPSendURL(icqlink, uin, descr, url);
  81   else if(thruSrv==ICQ_SEND_BESTWAY)
  82   {
  83     icq_ContactItem *pcontact=icq_ContactFind(icqlink, uin);
  84     if(pcontact)
  85     {
  86       if(pcontact->tcp_flag == 0x04)
  87         return icq_TCPSendURL(icqlink, uin, descr, url);
  88       else
  89         return icq_UDPSendURL(icqlink, uin, url, descr);
  90     }
  91     else
  92     {
  93       return icq_UDPSendURL(icqlink, uin, url, descr);
  94     }
  95   }
  96   return 0;
  97 }
  98
  99 static int icqlib_initialized = 0;
 100
 101 void icq_LibInit()
 102 {
 103   srand(time(0L));
 104
 105   /* initialize internal lists, if necessary */
 106   if (!icq_SocketList)
 107     icq_SocketList = icq_ListNew();
 108
 109   if (!icq_TimeoutList)
 110   {
 111     icq_TimeoutList = icq_ListNew();
 112     icq_TimeoutList->compare_function =
 113       (icq_ListCompareFunc)icq_TimeoutCompare;
 114   }
 115
 116   icqlib_initialized = 1;
 117 }
 118
 119 icq_Link *icq_LinkNew(DWORD uin, const char *password, const char *nick,
 120                         unsigned char useTCP)
 121 {
 122   icq_Link *icqlink = (icq_Link *)malloc(sizeof(icq_Link));
 123
 124   icq_LinkInit(icqlink, uin, password, nick, useTCP);
 125
 126   return icqlink;
 127 }
 128
 129 void icq_LinkInit(icq_Link *icqlink, DWORD uin, const char *password,
 130   const char *nick, unsigned char useTCP)
 131 {
 132   icqlink->d = (icq_LinkPrivate *)malloc(sizeof(icq_LinkPrivate));
 133
 134   if (!icqlib_initialized)
 135     icq_LibInit();
 136
 137   /* Initialize all callbacks */
 138   icqlink->icq_Logged = 0L;
 139   icqlink->icq_Disconnected = 0L;
 140   icqlink->icq_RecvMessage = 0L;
 141   icqlink->icq_RecvURL = 0L;
 142   icqlink->icq_RecvContactList = 0L;
 143   icqlink->icq_RecvWebPager = 0L;
 144   icqlink->icq_RecvMailExpress = 0L;
 145   icqlink->icq_RecvChatReq = 0L;
 146   icqlink->icq_RecvFileReq = 0L;
 147   icqlink->icq_RecvAdded = 0L;
 148   icqlink->icq_RecvAuthReq = 0L;
 149   icqlink->icq_UserFound = 0L;
 150   icqlink->icq_SearchDone = 0L;
 151   icqlink->icq_UpdateSuccess = 0L;
 152   icqlink->icq_UpdateFailure = 0L;
 153   icqlink->icq_UserOnline = 0L;
 154   icqlink->icq_UserOffline = 0L;
 155   icqlink->icq_UserStatusUpdate = 0L;
 156   icqlink->icq_InfoReply = 0L;
 157   icqlink->icq_ExtInfoReply = 0L;
 158   icqlink->icq_WrongPassword = 0L;
 159   icqlink->icq_InvalidUIN = 0L;
 160   icqlink->icq_Log = 0L;
 161   icqlink->icq_SrvAck = 0L;
 162   icqlink->icq_RequestNotify = 0L;
 163   icqlink->icq_NewUIN = 0L;
 164   icqlink->icq_MetaUserFound = 0L;
 165   icqlink->icq_MetaUserInfo = 0L;
 166   icqlink->icq_MetaUserWork = 0L;
 167   icqlink->icq_MetaUserMore = 0L;
 168   icqlink->icq_MetaUserAbout = 0L;
 169   icqlink->icq_MetaUserInterests = 0L;
 170   icqlink->icq_MetaUserAffiliations = 0L;
 171   icqlink->icq_MetaUserHomePageCategory = 0L;
 172
 173   /* General stuff */
 174   icqlink->icq_Uin = uin;
 175   icqlink->icq_Password = strdup(password);
 176   icqlink->icq_Nick = strdup(nick);
 177   icqlink->icq_OurIP = -1;
 178   icqlink->icq_OurPort = 0;
 179   icqlink->d->icq_ContactList = icq_ListNew();
 180   icqlink->icq_Status = -1;
 181   icqlink->icq_UserData = 0L;
 182
 183   /* UDP stuff */
 184   icqlink->icq_UDPSok = -1;
 185   memset(icqlink->d->icq_UDPServMess, FALSE,
 186     sizeof(icqlink->d->icq_UDPServMess));
 187   icqlink->d->icq_UDPSeqNum1 = 0;
 188   icqlink->d->icq_UDPSeqNum2 = 0;
 189   icqlink->d->icq_UDPSession = 0;
 190   icq_UDPQueueNew(icqlink);
 191
 192   /* TCP stuff */
 193   icqlink->icq_UseTCP = useTCP;
 194   if (useTCP)
 195     icq_TCPInit(icqlink);
 196
 197   /* Proxy stuff */
 198   icqlink->icq_UseProxy = 0;
 199   icqlink->icq_ProxyHost = 0L;
 200   icqlink->icq_ProxyIP = -1;
 201   icqlink->icq_ProxyPort = 0;
 202   icqlink->icq_ProxyAuth = 0;
 203   icqlink->icq_ProxyName = 0L;
 204   icqlink->icq_ProxyPass = 0L;
 205   icqlink->icq_ProxySok = -1;
 206   icqlink->icq_ProxyOurPort = 0;
 207   icqlink->icq_ProxyDestIP = -1;
 208   icqlink->icq_ProxyDestPort = 0;
 209 }
 210
 211 void icq_LinkDestroy(icq_Link *icqlink)
 212 {
 213   if(icqlink->icq_UseTCP)
 214     icq_TCPDone(icqlink);
 215   if(icqlink->icq_Password)
 216     free(icqlink->icq_Password);
 217   if(icqlink->icq_Nick)
 218     free(icqlink->icq_Nick);
 219   if(icqlink->d->icq_ContactList)
 220     icq_ListDelete(icqlink->d->icq_ContactList, icq_ContactDelete);
 221   icq_UDPQueueDelete(icqlink);
 222   free(icqlink->d);
 223 }
 224
 225 void icq_LinkDelete(icq_Link *icqlink)
 226 {
 227   icq_LinkDestroy(icqlink);
 228   free(icqlink);
 229 }
 230
 231 /******************************
 232 Main function connects gets icq_Uin
 233 and icq_Password and logins in and sits
 234 in a loop waiting for server responses.
 235 *******************************/
 236 void icq_Main()
 237 {
 238   icq_SocketPoll();
 239 }
 240
 241 /**********************************
 242 Connects to hostname on port port
 243 hostname can be DNS or nnn.nnn.nnn.nnn
 244 write out messages to the FD aux
 245 ***********************************/
 246 int icq_Connect(icq_Link *icqlink, const char *hostname, int port)
 247 {
 248   char buf[1024]; /*, un = 1;*/
 249 /*  char tmpbuf[256], our_host[256]*/
 250   int conct, res;
 251   unsigned int length;
 252   struct sockaddr_in saddr, prsin;  /* used to store inet addr stuff */
 253   struct hostent *host_struct; /* used in DNS llokup */
 254
 255   /* create the unconnected socket*/
 256   icqlink->icq_UDPSok = icq_SocketNew(AF_INET, SOCK_DGRAM, 0);
 257
 258   if(icqlink->icq_UDPSok == -1)
 259   {
 260     icq_FmtLog(icqlink, ICQ_LOG_FATAL, "Socket creation failed\n");
 261     return -1;
 262   }
 263   icq_FmtLog(icqlink, ICQ_LOG_MESSAGE, "Socket created attempting to connect\n");
 264   saddr.sin_addr.s_addr = INADDR_ANY;
 265   saddr.sin_family = AF_INET; /* we're using the inet not appletalk*/
 266   saddr.sin_port = 0;
 267   if(bind(icqlink->icq_UDPSok, (struct sockaddr*)&saddr, sizeof(struct sockaddr))<0)
 268   {
 269     icq_FmtLog(icqlink, ICQ_LOG_FATAL, "Can't bind socket to free port\n");
 270     icq_SocketDelete(icqlink->icq_UDPSok);
 271     icqlink->icq_UDPSok = -1;
 272     return -1;
 273   }
 274   length = sizeof(saddr);
 275   getsockname(icqlink->icq_UDPSok, (struct sockaddr*)&saddr, &length);
 276   icqlink->icq_ProxyOurPort = ntohs(saddr.sin_port);
 277   if(icqlink->icq_UseProxy)
 278   {
 279     int hasName = icqlink->icq_ProxyName && strlen(icqlink->icq_ProxyName);
 280     int hasPass = icqlink->icq_ProxyPass && strlen(icqlink->icq_ProxyPass);
 281     int authEnabled = icqlink->icq_ProxyAuth && hasName && hasPass;
 282
 283     icq_FmtLog(icqlink, ICQ_LOG_MESSAGE, "[SOCKS] Trying to use SOCKS5 proxy\n");
 284     prsin.sin_addr.s_addr = inet_addr(icqlink->icq_ProxyHost);
 285     if(prsin.sin_addr.s_addr  == (unsigned long)-1) /* name isn't n.n.n.n so must be DNS */
 286     {
 287       host_struct = gethostbyname(icqlink->icq_ProxyHost);
 288       if(host_struct == 0L)
 289       {
 290         icq_FmtLog(icqlink, ICQ_LOG_FATAL, "[SOCKS] Can't find hostname: %s\n", icqlink->icq_ProxyHost);
 291         return -1;
 292       }
 293       prsin.sin_addr = *((struct in_addr*)host_struct->h_addr);
 294     }
 295     icqlink->icq_ProxyIP = ntohl(prsin.sin_addr.s_addr);
 296     prsin.sin_family = AF_INET; /* we're using the inet not appletalk*/
 297     prsin.sin_port = htons(icqlink->icq_ProxyPort); /* port */
 298
 299     /* create the unconnected socket*/
 300     icqlink->icq_ProxySok = icq_SocketNew(AF_INET, SOCK_STREAM, 0);
 301
 302     if(icqlink->icq_ProxySok == -1)
 303     {
 304       icq_FmtLog(icqlink, ICQ_LOG_FATAL, "[SOCKS] Socket creation failed\n");
 305       return -1;
 306     }
 307     icq_FmtLog(icqlink, ICQ_LOG_MESSAGE, "[SOCKS] Socket created attempting to connect\n");
 308     conct = connect(icqlink->icq_ProxySok, (struct sockaddr *) &prsin, sizeof(prsin));
 309     if(conct == -1) /* did we connect ?*/
 310     {
 311       icq_FmtLog(icqlink, ICQ_LOG_FATAL, "[SOCKS] Connection refused\n");
 312       return -1;
 313     }
 314     buf[0] = 5; /* protocol version */
 315     buf[1] = 1; /* number of methods */
 316     buf[2] = authEnabled ? 2 : 0; /* authentication method */
 317
 318 #ifdef _WIN32
 319     send(icqlink->icq_ProxySok, buf, 3, 0);
 320     res = recv(icqlink->icq_ProxySok, buf, 2, 0);
 321 #else
 322     write(icqlink->icq_ProxySok, buf, 3);
 323     res = read(icqlink->icq_ProxySok, buf, 2);
 324 #endif
 325
 326     if(authEnabled)
 327     {
 328       if(res != 2 || buf[0] != 5 || buf[1] != 2) /* username/password authentication*/
 329       {
 330         icq_FmtLog(icqlink, ICQ_LOG_FATAL, "[SOCKS] Authentication method incorrect\n");
 331         icq_SocketDelete(icqlink->icq_ProxySok);
 332         return -1;
 333       }
 334       buf[0] = 1; /* version of subnegotiation */
 335       buf[1] = strlen(icqlink->icq_ProxyName);
 336       memcpy(&buf[2], icqlink->icq_ProxyName, buf[1]);
 337       buf[2+buf[1]] = strlen(icqlink->icq_ProxyPass);
 338       memcpy(&buf[3+buf[1]], icqlink->icq_ProxyPass, buf[2+buf[1]]);
 339 #ifdef _WIN32
 340       send(icqlink->icq_ProxySok, buf, buf[1]+buf[2+buf[1]]+3, 0);
 341       res = recv(icqlink->icq_ProxySok, buf, 2, 0);
 342 #else
 343       write(icqlink->icq_ProxySok, buf, buf[1]+buf[2+buf[1]]+3);
 344       res = read(icqlink->icq_ProxySok, buf, 2);
 345 #endif
 346       if(res != 2 || buf[0] != 1 || buf[1] != 0)
 347       {
 348         icq_FmtLog(icqlink, ICQ_LOG_FATAL, "[SOCKS] Authorization failure\n");
 349         icq_SocketDelete(icqlink->icq_ProxySok);
 350         return -1;
 351       }
 352     }
 353     else
 354     {
 355       if(res != 2 || buf[0] != 5 || buf[1] != 0) /* no authentication required */
 356       {
 357         icq_FmtLog(icqlink, ICQ_LOG_FATAL, "[SOCKS] Authentication method incorrect\n");
 358         icq_SocketDelete(icqlink->icq_ProxySok);
 359         return -1;
 360       }
 361     }
 362     buf[0] = 5; /* protocol version */
 363     buf[1] = 3; /* command UDP associate */
 364     buf[2] = 0; /* reserved */
 365     buf[3] = 1; /* address type IP v4 */
 366     buf[4] = (char)0;
 367     buf[5] = (char)0;
 368     buf[6] = (char)0;
 369     buf[7] = (char)0;
 370     *(unsigned short*)&buf[8] = htons(icqlink->icq_ProxyOurPort);
 371 /*     memcpy(&buf[8], &icqlink->icq_ProxyOurPort, 2); */
 372 #ifdef _WIN32
 373     send(icqlink->icq_ProxySok, buf, 10, 0);
 374     res = recv(icqlink->icq_ProxySok, buf, 10, 0);
 375 #else
 376     write(icqlink->icq_ProxySok, buf, 10);
 377     res = read(icqlink->icq_ProxySok, buf, 10);
 378 #endif
 379     if(res != 10 || buf[0] != 5 || buf[1] != 0)
 380     {
 381       switch(buf[1])
 382       {
 383         case 1:
 384           icq_FmtLog(icqlink, ICQ_LOG_FATAL, "[SOCKS] General SOCKS server failure\n");
 385           break;
 386         case 2:
 387           icq_FmtLog(icqlink, ICQ_LOG_FATAL, "[SOCKS] Connection not allowed by ruleset\n");
 388           break;
 389         case 3:
 390           icq_FmtLog(icqlink, ICQ_LOG_FATAL, "[SOCKS] Network unreachable\n");
 391           break;
 392         case 4:
 393           icq_FmtLog(icqlink, ICQ_LOG_FATAL, "[SOCKS] Host unreachable\n");
 394           break;
 395         case 5:
 396           icq_FmtLog(icqlink, ICQ_LOG_FATAL, "[SOCKS] Connection refused\n");
 397           break;
 398         case 6:
 399           icq_FmtLog(icqlink, ICQ_LOG_FATAL, "[SOCKS] TTL expired\n");
 400           break;
 401         case 7:
 402           icq_FmtLog(icqlink, ICQ_LOG_FATAL, "[SOCKS] Command not supported\n");
 403           break;
 404         case 8:
 405           icq_FmtLog(icqlink, ICQ_LOG_FATAL, "[SOCKS] Address type not supported\n");
 406           break;
 407         default:
 408           icq_FmtLog(icqlink, ICQ_LOG_FATAL, "[SOCKS] Unknown SOCKS server failure\n");
 409           break;
 410       }
 411       icq_SocketDelete(icqlink->icq_ProxySok);
 412       icqlink->icq_ProxySok = -1;
 413       return -1;
 414     }
 415   }
 416   saddr.sin_addr.s_addr = inet_addr(hostname); /* checks for n.n.n.n notation */
 417   if(saddr.sin_addr.s_addr == (unsigned long)-1) /* name isn't n.n.n.n so must be DNS */
 418   {
 419     host_struct = gethostbyname(hostname);
 420     if(host_struct == 0L)
 421     {
 422       icq_FmtLog(icqlink, ICQ_LOG_FATAL, "Can't find hostname: %s\n", hostname);
 423       if(icqlink->icq_UseProxy)
 424       {
 425         icq_SocketDelete(icqlink->icq_ProxySok);
 426       }
 427       return -1;
 428     }
 429     saddr.sin_addr = *((struct in_addr *)host_struct->h_addr);
 430   }
 431   if(icqlink->icq_UseProxy)
 432   {
 433     icqlink->icq_ProxyDestIP = ntohl(saddr.sin_addr.s_addr);
 434     memcpy(&saddr.sin_addr.s_addr, &buf[4], 4);
 435   }
 436   saddr.sin_family = AF_INET; /* we're using the inet not appletalk*/
 437   saddr.sin_port = htons(port); /* port */
 438   if(icqlink->icq_UseProxy)
 439   {
 440     icqlink->icq_ProxyDestPort = port;
 441     memcpy(&saddr.sin_port, &buf[8], 2);
 442   }
 443   conct = connect(icqlink->icq_UDPSok, (struct sockaddr*)&saddr, sizeof(saddr));
 444   if(conct == -1) /* did we connect ?*/
 445   {
 446     icq_FmtLog(icqlink, ICQ_LOG_FATAL, "Connection refused\n");
 447     if(icqlink->icq_UseProxy)
 448     {
 449       icq_SocketDelete(icqlink->icq_ProxySok);
 450     }
 451     return -1;
 452   }
 453   length = sizeof(saddr) ;
 454   getsockname(icqlink->icq_UDPSok, (struct sockaddr*)&saddr, &length);
 455   icqlink->icq_OurIP = ntohl(saddr.sin_addr.s_addr);
 456   icqlink->icq_OurPort = ntohs(saddr.sin_port);
 457
 458   /* sockets are ready to receive data - install handlers */
 459   icq_SocketSetHandler(icqlink->icq_UDPSok, ICQ_SOCKET_READ,
 460     (icq_SocketHandler)icq_HandleServerResponse, icqlink);
 461   if (icqlink->icq_UseProxy)
 462     icq_SocketSetHandler(icqlink->icq_ProxySok, ICQ_SOCKET_READ,
 463       (icq_SocketHandler)icq_HandleProxyResponse, icqlink);
 464   return icqlink->icq_UDPSok;
 465 }
 466
 467 void icq_Disconnect(icq_Link *icqlink)
 468 {
 469   icq_SocketDelete(icqlink->icq_UDPSok);
 470   if(icqlink->icq_UseProxy)
 471     icq_SocketDelete(icqlink->icq_ProxySok);
 472   icq_UDPQueueFree(icqlink);
 473 }
 474
 475 /*
 476 void icq_InitNewUser(const char *hostname, DWORD port)
 477 {
 478   srv_net_icq_pak pak;
 479   int s;
 480   struct timeval tv;
 481   fd_set readfds;
 482
 483   icq_Connect(hostname, port);
 484   if((icq_UDPSok == -1) || (icq_UDPSok == 0))
 485   {
 486     printf("Couldn't establish connection\n");
 487     exit(1);
 488   }
 489   icq_RegNewUser(icq_Password);
 490   for(;;)
 491   {
 492     tv.tv_sec = 2;
 493     tv.tv_usec = 500000;
 494
 495     FD_ZERO(&readfds);
 496     FD_SET(icq_UDPSok, &readfds);
 497
 498     select(icq_UDPSok+1, &readfds, 0L, 0L, &tv);
 499
 500     if(FD_ISSET(icq_UDPSok, &readfds))
 501     {
 502       s = icq_UDPSockRead(icq_UDPSok, &pak.head, sizeof(pak));
 503       if(icqtohs(pak.head.cmd) == SRV_NEW_UIN)
 504       {
 505         icq_Uin = icqtohl(&pak.data[2]);
 506         return;
 507       }
 508     }
 509   }
 510 }
 511 */
 512
 513 /************************
 514 icq_UDPServMess functions
 515 *************************/
 516 BOOL icq_GetServMess(icq_Link *icqlink, WORD num)
 517 {
 518   return ((icqlink->d->icq_UDPServMess[num/8] & (1 << (num%8))) >> (num%8));
 519 }
 520
 521 void icq_SetServMess(icq_Link *icqlink, WORD num)
 522 {
 523   icqlink->d->icq_UDPServMess[num/8] |= (1 << (num%8));
 524 }
 525
 526 int icq_GetSok(icq_Link *icqlink)
 527 {
 528   return icqlink->icq_UDPSok;
 529 }