svn.miranda.im is moving to a new home!

git-svn-id: http://miranda-plugins.googlecode.com/svn/trunk@7 e753b5eb-9565-29b2-b5c5-2cc6f99dfbcb

1 files changed, 213 insertions, 0 deletions

diff --git a/icqj_mod/icq_http.c b/icqj_mod/icq_http.c
new file mode 100644
index 0000000..8afe50b
--- /dev/null
+++ b/icqj_mod/icq_http.c
@@ -0,0 +1,213 @@
+// ---------------------------------------------------------------------------80

+//                ICQ plugin for Miranda Instant Messenger

+//                ________________________________________

+// 

+// Copyright © 2000,2001 Richard Hughes, Roland Rabien, Tristan Van de Vreede

+// Copyright © 2001,2002 Jon Keating, Richard Hughes

+// Copyright © 2002,2003,2004 Martin Öberg, Sam Kothari, Robert Rainwater

+// Copyright © 2004,2005,2006 Joe Kucera

+// 

+// 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

+// GNU General Public License for more details.

+// 

+// You should have received a copy of the GNU General Public License

+// along with this program; if not, write to the Free Software

+// Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.

+//

+// -----------------------------------------------------------------------------

+//

+// File name      : $Source: /cvsroot/miranda/miranda/protocols/IcqOscarJ/icq_http.c,v $

+// Revision       : $Revision: 2874 $

+// Last change on : $Date: 2006-05-16 23:38:00 +0200 (Tue, 16 May 2006) $

+// Last change by : $Author: ghazan $

+//

+// DESCRIPTION:

+//

+//  Describe me here please...

+//

+// -----------------------------------------------------------------------------

+

+#include "icqoscar.h"

+

+

+

+int icq_httpGatewayInit(HANDLE hConn, NETLIBOPENCONNECTION *nloc, NETLIBHTTPREQUEST *nlhr)

+{

+  WORD wLen, wVersion, wType;

+  WORD wIpLen;

+  DWORD dwSid1, dwSid2, dwSid3, dwSid4;

+  BYTE response[300], *buf;

+  int responseBytes, recvResult;

+  char szSid[33], szHttpServer[256], szHttpGetUrl[300], szHttpPostUrl[300];

+  NETLIBHTTPPROXYINFO nlhpi = {0};

+

+  

+  for (responseBytes = 0; ; )

+  {

+    recvResult = Netlib_Recv(hConn, response + responseBytes, sizeof(response) - responseBytes, MSG_DUMPPROXY);

+    if(recvResult<=0) break;

+    responseBytes += recvResult;

+    if(responseBytes == sizeof(response))

+      break;

+  }

+

+  if (responseBytes < 31)

+  {

+    SetLastError(ERROR_INVALID_DATA);

+    return 0;

+  }

+

+  buf = response;

+  unpackWord(&buf, &wLen);

+  unpackWord(&buf, &wVersion);    /* always 0x0443 */

+  unpackWord(&buf, &wType);       /* hello reply */

+  buf += 6;  /* dunno */

+  unpackDWord(&buf, &dwSid1);

+  unpackDWord(&buf, &dwSid2);

+  unpackDWord(&buf, &dwSid3);

+  unpackDWord(&buf, &dwSid4);

+  null_snprintf(szSid, 33, "%08x%08x%08x%08x", dwSid1, dwSid2, dwSid3, dwSid4);

+  unpackWord(&buf, &wIpLen);

+

+  if(responseBytes < 30 + wIpLen || wIpLen == 0 || wIpLen > sizeof(szHttpServer) - 1)

+  {

+    SetLastError(ERROR_INVALID_DATA);

+    return 0;

+  }

+

+  SetGatewayIndex(hConn, 1); // new master connection begins here

+

+  memcpy(szHttpServer, buf, wIpLen);

+  szHttpServer[wIpLen] = '\0';

+

+  nlhpi.cbSize = sizeof(nlhpi);

+  nlhpi.flags = NLHPIF_USEPOSTSEQUENCE;

+  nlhpi.szHttpGetUrl = szHttpGetUrl;

+  nlhpi.szHttpPostUrl = szHttpPostUrl;

+  nlhpi.firstPostSequence = 1;

+  null_snprintf(szHttpGetUrl, 300, "http://%s/monitor?sid=%s", szHttpServer, szSid);

+  null_snprintf(szHttpPostUrl, 300, "http://%s/data?sid=%s&seq=", szHttpServer, szSid);

+

+  return CallService(MS_NETLIB_SETHTTPPROXYINFO, (WPARAM)hConn, (LPARAM)&nlhpi);

+}

+

+

+

+int icq_httpGatewayBegin(HANDLE hConn, NETLIBOPENCONNECTION* nloc)

+{

+  icq_packet packet;

+  int serverNameLen;

+

+  serverNameLen = strlennull(nloc->szHost);

+

+  packet.wLen = (WORD)(serverNameLen + 4);

+  write_httphdr(&packet, HTTP_PACKETTYPE_LOGIN, GetGatewayIndex(hConn));

+  packWord(&packet, (WORD)serverNameLen);

+  packBuffer(&packet, nloc->szHost, (WORD)serverNameLen);

+  packWord(&packet, nloc->wPort);

+  Netlib_Send(hConn, packet.pData, packet.wLen, MSG_DUMPPROXY|MSG_NOHTTPGATEWAYWRAP);

+  SAFE_FREE(&packet.pData);

+

+  return 1;

+}

+

+

+

+int icq_httpGatewayWrapSend(HANDLE hConn, PBYTE buf, int len, int flags, MIRANDASERVICE pfnNetlibSend)

+{

+  icq_packet packet;

+  int sendResult;

+

+  packet.wLen = len;

+  write_httphdr(&packet, HTTP_PACKETTYPE_FLAP, GetGatewayIndex(hConn));

+  packBuffer(&packet, buf, (WORD)len);

+  sendResult = Netlib_Send(hConn, packet.pData, packet.wLen, flags);

+  SAFE_FREE(&packet.pData);

+

+  if(sendResult <= 0)

+    return sendResult;

+

+  if(sendResult < 14)

+    return 0;

+

+  return sendResult - 14;

+}

+

+

+

+PBYTE icq_httpGatewayUnwrapRecv(NETLIBHTTPREQUEST* nlhr, PBYTE buf, int len, int* outBufLen, void *(*NetlibRealloc)(void *, size_t))

+{

+  WORD wLen, wType;

+  DWORD dwPackSeq;

+  PBYTE tbuf;

+  int i, copyBytes;

+

+  

+  tbuf = buf;

+  for(i = 0;;)

+  {

+    if (tbuf - buf + 2 > len)

+      break;

+    unpackWord(&tbuf, &wLen);

+    if (wLen < 12)

+      break;

+    if (tbuf - buf + wLen > len)

+      break;

+    tbuf += 2;    /* version */

+    unpackWord(&tbuf, &wType);

+    tbuf += 4;    /* flags */

+    unpackDWord(&tbuf, &dwPackSeq);

+    if (wType == HTTP_PACKETTYPE_FLAP)

+    {

+      copyBytes = wLen - 12;

+      if (copyBytes > len - i)

+      {

+        /* invalid data - do our best to get something out of it */

+        copyBytes = len - i;

+      }

+      memcpy(buf + i, tbuf, copyBytes);

+      i += copyBytes;

+    }

+    else if (wType == HTTP_PACKETTYPE_LOGINREPLY)

+    {

+      BYTE bRes;

+

+      unpackByte(&tbuf, &bRes);

+      wLen -= 1;

+      if (!bRes)

+        NetLog_Server("Gateway Connection #%d Established.", dwPackSeq);

+      else

+        NetLog_Server("Gateway Connection #%d Failed, error: %d", dwPackSeq, bRes);

+    }

+    else if (wType == HTTP_PACKETTYPE_CLOSEREPLY)

+    {

+      NetLog_Server("Gateway Connection #%d Closed.", dwPackSeq);

+    }

+    tbuf += wLen - 12;

+  }

+  *outBufLen = i;

+

+  return buf;

+}

+

+

+int icq_httpGatewayWalkTo(HANDLE hConn, NETLIBOPENCONNECTION* nloc)

+{

+  icq_packet packet;

+  DWORD dwGatewaySeq = GetGatewayIndex(hConn);

+

+  packet.wLen = 0;

+  write_httphdr(&packet, HTTP_PACKETTYPE_CLOSE, dwGatewaySeq);

+  Netlib_Send(hConn, packet.pData, packet.wLen, MSG_DUMPPROXY|MSG_NOHTTPGATEWAYWRAP);

+  // we closed virtual connection, open new one

+  dwGatewaySeq++;

+  SetGatewayIndex(hConn, dwGatewaySeq);

+  return icq_httpGatewayBegin(hConn, nloc);

+}