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, 1017 insertions, 0 deletions

diff --git a/icqj_mod/fam_01service.c b/icqj_mod/fam_01service.c
new file mode 100644
index 0000000..2356f68
--- /dev/null
+++ b/icqj_mod/fam_01service.c
@@ -0,0 +1,1017 @@
+// ---------------------------------------------------------------------------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/fam_01service.c,v $

+// Revision       : $Revision: 3316 $

+// Last change on : $Date: 2006-07-12 20:26:25 +0400 (Ср, 12 июл 2006) $

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

+//

+// DESCRIPTION:

+//

+//  Describe me here please...

+//

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

+

+#include "icqoscar.h"

+

+

+extern int gbIdleAllow;

+extern int icqGoingOnlineStatus;

+extern BYTE gbOverRate;

+extern int pendingAvatarsStart;

+extern DWORD dwLocalInternalIP;

+extern WORD wListenPort;

+extern DWORD dwLocalDirectConnCookie;

+extern CRITICAL_SECTION modeMsgsMutex;

+

+extern const capstr capXStatus[];

+

+void setUserInfo();

+

+char* calcMD5Hash(char* szFile);

+

+

+void handleServiceFam(unsigned char* pBuffer, WORD wBufferLength, snac_header* pSnacHeader, serverthread_info *info)

+{

+  icq_packet packet;

+

+  switch (pSnacHeader->wSubtype)

+  {

+

+  case ICQ_SERVER_READY:

+#ifdef _DEBUG

+    NetLog_Server("Server is ready and is requesting my Family versions");

+    NetLog_Server("Sending my Families");

+#endif

+

+    // This packet is a response to SRV_FAMILIES SNAC(1,3).

+    // This tells the server which SNAC families and their corresponding

+    // versions which the client understands. This also seems to identify

+    // the client as an ICQ vice AIM client to the server.

+    // Miranda mimics the behaviour of icq5 (haven't changed since at least 2002a)

+    serverPacketInit(&packet, 50);

+    packFNACHeader(&packet, ICQ_SERVICE_FAMILY, ICQ_CLIENT_FAMILIES);

+    packDWord(&packet, 0x00010004);

+    packDWord(&packet, 0x00130004);

+    packDWord(&packet, 0x00020001);

+    packDWord(&packet, 0x00030001);

+    packDWord(&packet, 0x00150001);

+    packDWord(&packet, 0x00040001);

+    packDWord(&packet, 0x00060001);

+    packDWord(&packet, 0x00090001);

+    packDWord(&packet, 0x000a0001);

+    packDWord(&packet, 0x000b0001);

+    sendServPacket(&packet);

+    break;

+

+  case ICQ_SERVER_FAMILIES2:

+    /* This is a reply to CLI_FAMILIES and it tells the client which families and their versions that this server understands.

+     * We send a rate request packet */

+#ifdef _DEBUG

+    NetLog_Server("Server told me his Family versions");

+    NetLog_Server("Requesting Rate Information");

+#endif

+    serverPacketInit(&packet, 10);

+    packFNACHeader(&packet, ICQ_SERVICE_FAMILY, ICQ_CLIENT_REQ_RATE_INFO);

+    sendServPacket(&packet);

+    break;

+

+  case ICQ_SERVER_RATE_INFO:

+#ifdef _DEBUG

+    NetLog_Server("Server sent Rate Info");

+    NetLog_Server("Sending Rate Info Ack");

+#endif

+    /* Don't really care about this now, just send the ack */

+    serverPacketInit(&packet, 20);

+    packFNACHeader(&packet, ICQ_SERVICE_FAMILY, ICQ_CLIENT_RATE_ACK);

+    packDWord(&packet, 0x00010002);

+    packDWord(&packet, 0x00030004);

+    packWord(&packet, 0x0005);

+    sendServPacket(&packet);

+

+    /* CLI_REQINFO - This command requests from the server certain information about the client that is stored on the server. */

+#ifdef _DEBUG

+    NetLog_Server("Sending CLI_REQINFO");

+#endif

+    serverPacketInit(&packet, 10);

+    packFNACHeader(&packet, ICQ_SERVICE_FAMILY, ICQ_CLIENT_REQINFO);

+    sendServPacket(&packet);

+

+    if (gbSsiEnabled)

+    {

+      DWORD dwLastUpdate;

+      WORD wRecordCount;

+      servlistcookie* ack;

+      DWORD dwCookie;

+

+      dwLastUpdate = ICQGetContactSettingDword(NULL, "SrvLastUpdate", 0);

+      wRecordCount = ICQGetContactSettingWord(NULL, "SrvRecordCount", 0);

+

+      // CLI_REQLISTS - we want to use SSI

+#ifdef _DEBUG

+      NetLog_Server("Requesting roster rights");

+#endif

+      serverPacketInit(&packet, 10);

+      packFNACHeader(&packet, ICQ_LISTS_FAMILY, ICQ_LISTS_CLI_REQLISTS);

+      sendServPacket(&packet);

+

+      if (!wRecordCount) // CLI_REQROSTER

+      { // we do not have any data - request full list

+#ifdef _DEBUG

+        NetLog_Server("Requesting full roster");

+#endif

+        serverPacketInit(&packet, 10);

+        ack = (servlistcookie*)SAFE_MALLOC(sizeof(servlistcookie));

+        if (ack)

+        { // we try to use standalone cookie if available

+          ack->dwAction = SSA_CHECK_ROSTER; // loading list

+          dwCookie = AllocateCookie(CKT_SERVERLIST, ICQ_LISTS_CLI_REQUEST, 0, ack);

+        }

+        else // if not use that old fake

+          dwCookie = ICQ_LISTS_CLI_REQUEST<<0x10;

+

+        packFNACHeaderFull(&packet, ICQ_LISTS_FAMILY, ICQ_LISTS_CLI_REQUEST, 0, dwCookie);

+        sendServPacket(&packet);

+      }

+      else // CLI_CHECKROSTER

+      {

+#ifdef _DEBUG

+        NetLog_Server("Requesting roster check");

+#endif

+        serverPacketInit(&packet, 16);

+        ack = (servlistcookie*)SAFE_MALLOC(sizeof(servlistcookie));

+        if (ack)  // TODO: rewrite - use get list service for empty list

+        { // we try to use standalone cookie if available

+          ack->dwAction = SSA_CHECK_ROSTER; // loading list

+          dwCookie = AllocateCookie(CKT_SERVERLIST, ICQ_LISTS_CLI_CHECK, 0, ack);

+        }

+        else // if not use that old fake

+          dwCookie = ICQ_LISTS_CLI_CHECK<<0x10;

+

+        packFNACHeaderFull(&packet, ICQ_LISTS_FAMILY, ICQ_LISTS_CLI_CHECK, 0, dwCookie);

+        // check if it was not changed elsewhere (force reload, set that setting to zero)

+        if (IsServerGroupsDefined())

+        {

+          packDWord(&packet, dwLastUpdate);  // last saved time

+          packWord(&packet, wRecordCount);   // number of records saved

+        }

+        else

+        { // we need to get groups info into DB, force receive list

+          packDWord(&packet, 0);  // last saved time

+          packWord(&packet, 0);   // number of records saved

+        }

+        sendServPacket(&packet);

+      }

+    }

+

+    // CLI_REQLOCATION

+#ifdef _DEBUG

+    NetLog_Server("Requesting Location rights");

+#endif

+    serverPacketInit(&packet, 10);

+    packFNACHeader(&packet, ICQ_LOCATION_FAMILY, ICQ_LOCATION_CLI_REQ_RIGHTS);

+    sendServPacket(&packet);

+

+    // CLI_REQBUDDY

+#ifdef _DEBUG

+    NetLog_Server("Requesting Client-side contactlist rights");

+#endif

+    serverPacketInit(&packet, 10);

+    packFNACHeader(&packet, ICQ_BUDDY_FAMILY, ICQ_USER_CLI_REQBUDDY);

+    sendServPacket(&packet);

+

+    // CLI_REQICBM

+#ifdef _DEBUG

+    NetLog_Server("Sending CLI_REQICBM");

+#endif

+    serverPacketInit(&packet, 10);

+    packFNACHeader(&packet, ICQ_MSG_FAMILY, ICQ_MSG_CLI_REQICBM);

+    sendServPacket(&packet);

+

+    // CLI_REQBOS

+#ifdef _DEBUG

+    NetLog_Server("Sending CLI_REQBOS");

+#endif

+    serverPacketInit(&packet, 10);

+    packFNACHeader(&packet, ICQ_BOS_FAMILY, ICQ_PRIVACY_REQ_RIGHTS);

+    sendServPacket(&packet);

+    break;

+

+  case ICQ_SERVER_PAUSE:

+    NetLog_Server("Server is going down in a few seconds... (Flags: %u)", pSnacHeader->wFlags);

+    // This is the list of groups that we want to have on the next server

+    serverPacketInit(&packet, 30);

+    packFNACHeader(&packet, ICQ_SERVICE_FAMILY, ICQ_CLIENT_PAUSE_ACK);

+    packWord(&packet,ICQ_SERVICE_FAMILY);

+    packWord(&packet,ICQ_LISTS_FAMILY);

+    packWord(&packet,ICQ_LOCATION_FAMILY);

+    packWord(&packet,ICQ_BUDDY_FAMILY);

+    packWord(&packet,ICQ_EXTENSIONS_FAMILY);

+    packWord(&packet,ICQ_MSG_FAMILY);

+    packWord(&packet,0x06);

+    packWord(&packet,ICQ_BOS_FAMILY);

+    packWord(&packet,ICQ_LOOKUP_FAMILY);

+    packWord(&packet,ICQ_STATS_FAMILY);

+    sendServPacket(&packet);

+#ifdef _DEBUG

+    NetLog_Server("Sent server pause ack");

+#endif

+    break;

+

+  case ICQ_SERVER_MIGRATIONREQ:

+    {

+      oscar_tlv_chain *chain = NULL;

+

+#ifdef _DEBUG

+      NetLog_Server("Server migration requested (Flags: %u)", pSnacHeader->wFlags);

+#endif

+      pBuffer += 2; // Unknown, seen: 0

+      wBufferLength -= 2;

+      chain = readIntoTLVChain(&pBuffer, wBufferLength, 0);

+

+      if (info->cookieDataLen > 0)

+        SAFE_FREE(&info->cookieData);

+

+      info->newServer = getStrFromChain(chain, 0x05, 1);

+      info->cookieData = getStrFromChain(chain, 0x06, 1);

+      info->cookieDataLen = getLenFromChain(chain, 0x06, 1);

+

+      if (!info->newServer || !info->cookieData)

+      {

+        icq_LogMessage(LOG_FATAL, "A server migration has failed because the server returned invalid data. You must reconnect manually.");

+        SAFE_FREE(&info->newServer);

+        SAFE_FREE(&info->cookieData);

+        info->cookieDataLen = 0;

+        info->newServerReady = 0;

+        return;

+      }

+

+      disposeChain(&chain);

+      NetLog_Server("Migration has started. New server will be %s", info->newServer);

+

+      icqGoingOnlineStatus = gnCurrentStatus;

+      SetCurrentStatus(ID_STATUS_CONNECTING); // revert to connecting state

+

+      info->newServerReady = 1;

+      info->isMigrating = 1;

+    }

+    break;

+

+  case ICQ_SERVER_NAME_INFO: // This is the reply to CLI_REQINFO

+    {

+      BYTE bUinLen;

+      oscar_tlv_chain *chain;

+

+      unpackByte(&pBuffer, &bUinLen);

+      pBuffer += bUinLen;

+      pBuffer += 4;      /* warning level & user class */

+      wBufferLength -= 5 + bUinLen;

+

+      if (pSnacHeader->dwRef == ICQ_CLIENT_REQINFO<<0x10)

+      { // This is during the login sequence

+        DWORD dwValue;

+

+        // TLV(x01) User type?

+        // TLV(x0C) Empty CLI2CLI Direct connection info

+        // TLV(x0A) External IP

+        // TLV(x0F) Number of seconds that user has been online

+        // TLV(x03) The online since time.

+        // TLV(x0A) External IP again

+        // TLV(x22) Unknown

+        // TLV(x1E) Unknown: empty.

+        // TLV(x05) Member of ICQ since.

+        // TLV(x14) Unknown

+        chain = readIntoTLVChain(&pBuffer, wBufferLength, 0);

+

+        // Save external IP

+        dwValue = getDWordFromChain(chain, 10, 1); 

+        ICQWriteContactSettingDword(NULL, "IP", dwValue);

+		ICQWriteContactSettingDword(NULL, "OldIP", dwValue);

+

+        // Save member since timestamp

+        dwValue = getDWordFromChain(chain, 5, 1); 

+        if (dwValue) ICQWriteContactSettingDword(NULL, "MemberTS", dwValue);

+

+        ICQWriteContactSettingDword(NULL, "LogonTS", time(NULL));

+

+        disposeChain(&chain);

+

+        // If we are in SSI mode, this is sent after the list is acked instead

+        // to make sure that we don't set status before seing the visibility code

+        if (!gbSsiEnabled || info->isMigrating)

+          handleServUINSettings(wListenPort, info);

+      }

+    }

+    break;

+

+  case ICQ_SERVER_RATE_CHANGE:

+

+    if (wBufferLength >= 2)

+    {

+      WORD wStatus;

+      WORD wClass;

+      // This is a horrible simplification, but the only

+      // area where we have rate control is in the user info

+      // auto request part.

+      unpackWord(&pBuffer, &wStatus);

+      unpackWord(&pBuffer, &wClass);

+

+      if (wStatus == 2 || wStatus == 3)

+      { // this is only the simplest solution, needs rate management to every section

+        ICQBroadcastAck(NULL, ICQACKTYPE_RATEWARNING, ACKRESULT_STATUS, (HANDLE)wClass, wStatus);

+        gbOverRate = 1; // block user requests (user info, status messages, etc.)

+        icq_PauseUserLookup(); // pause auto-info update thread

+      }

+      else if (wStatus == 4)

+      {

+        ICQBroadcastAck(NULL, ICQACKTYPE_RATEWARNING, ACKRESULT_STATUS, (HANDLE)wClass, wStatus);

+        gbOverRate = 0; // enable user requests

+        icq_EnableUserLookup(TRUE);

+      }

+    }

+

+    break;

+

+  case ICQ_SERVER_REDIRECT_SERVICE: // reply to family request, got new connection point

+  {

+     oscar_tlv_chain* pChain = NULL;

+     WORD wFamily;

+     familyrequest_rec* reqdata;

+

+    if (!(pChain = readIntoTLVChain(&pBuffer, wBufferLength, 0)))

+    {

+      NetLog_Server("Received Broken Redirect Service SNAC(1,5).");

+      break;

+    }

+    wFamily = getWordFromChain(pChain, 0x0D, 1);

+

+    // pick request data

+    if ((!FindCookie(pSnacHeader->dwRef, NULL, &reqdata)) || (reqdata->wFamily != wFamily))

+    {

+      disposeChain(&pChain);

+      NetLog_Server("Received unexpected SNAC(1,5), skipping.");

+      break;

+    }

+

+    FreeCookie(pSnacHeader->dwRef);

+

+    { // new family entry point received

+      char* pServer;

+      WORD wPort;

+      char* pCookie;

+      WORD wCookieLen;

+      NETLIBOPENCONNECTION nloc = {0};

+      HANDLE hConnection;

+

+      pServer = getStrFromChain(pChain, 0x05, 1);

+      pCookie = getStrFromChain(pChain, 0x06, 1);

+      wCookieLen = getLenFromChain(pChain, 0x06, 1);

+

+      if (!pServer || !pCookie)

+      {

+        NetLog_Server("Server returned invalid data, family unavailable.");

+

+        SAFE_FREE(&pServer);

+        SAFE_FREE(&pCookie);

+        break;

+      }

+

+      // Get new family server ip and port

+      parseServerAddress(pServer, &wPort);

+

+      nloc.cbSize = sizeof(nloc); // establish connection

+      nloc.flags = 0;

+      nloc.szHost = pServer; 

+      nloc.wPort = wPort;

+

+      hConnection = NetLib_OpenConnection(ghServerNetlibUser, &nloc);

+      

+      if (hConnection == NULL)

+      {

+        NetLog_Server("Unable to connect to ICQ new family server.");

+      } // we want the handler to be called even if the connecting failed

+      reqdata->familyhandler(hConnection, pCookie, wCookieLen);

+

+      // Free allocated memory

+      // NOTE: "cookie" will get freed when we have connected to the avatar server.

+      disposeChain(&pChain);

+      SAFE_FREE(&pServer);

+      SAFE_FREE(&reqdata);

+    }

+

+    break;

+  }

+

+  case ICQ_SERVER_EXTSTATUS: // our avatar

+  {

+    NetLog_Server("Received our avatar hash & status.");

+

+    if ((wBufferLength >= 0x14) && gbAvatarsEnabled)

+    {

+      switch (pBuffer[2])

+      {

+        case 1: // our avatar is on the server

+        {

+          char* file;

+          char* hash;

+

+          ICQWriteContactSettingBlob(NULL, "AvatarHash", pBuffer, 0x14);

+          

+          setUserInfo();

+          // here we need to find a file, check its hash, if invalid get avatar from server

+          file = loadMyAvatarFileName();

+          if (!file)

+          { // we have no avatar file, download from server

+            char szFile[MAX_PATH + 4];

+#ifdef _DEBUG

+            NetLog_Server("We have no avatar, requesting from server.");

+#endif

+            GetAvatarFileName(0, NULL, szFile, MAX_PATH);

+            GetAvatarData(NULL, dwLocalUIN, NULL, pBuffer, 0x14, szFile);

+          }

+          else

+          { // we know avatar filename

+            hash = calcMD5Hash(file);

+            if (!hash)

+            { // hash could not be calculated - probably missing file, get avatar from server

+              char szFile[MAX_PATH + 4];

+#ifdef _DEBUG

+              NetLog_Server("We have no avatar, requesting from server.");

+#endif

+              GetAvatarFileName(0, NULL, szFile, MAX_PATH);

+              GetAvatarData(NULL, dwLocalUIN, NULL, pBuffer, 0x14, szFile);

+            } // check if we had set any avatar if yes set our, if not download from server

+            else if (memcmp(hash, pBuffer+4, 0x10))

+            { // we have different avatar, sync that

+              if (ICQGetContactSettingByte(NULL, "ForceOurAvatar", 1))

+              { // we want our avatar, update hash

+                DWORD dwPaFormat = DetectAvatarFormat(file);

+                char* pHash = _alloca(0x14);

+

+                NetLog_Server("Our avatar is different, set our new hash.");

+

+                pHash[0] = 0;

+                pHash[1] = dwPaFormat == PA_FORMAT_XML ? 8 : 1;

+				pHash[2] = 1; // state of the hash

+                pHash[3] = 0x10; // len of the hash

+                memcpy(pHash + 4, hash, 0x10);

+                updateServAvatarHash(pHash, 0x14);

+              }

+              else

+              { // get avatar from server

+                char szFile[MAX_PATH + 4];

+#ifdef _DEBUG

+                NetLog_Server("We have different avatar, requesting new from server.");

+#endif

+                GetAvatarFileName(0, NULL, szFile, MAX_PATH);

+                GetAvatarData(NULL, dwLocalUIN, NULL, pBuffer, 0x14, szFile);

+              }

+            }

+            SAFE_FREE(&hash);

+            SAFE_FREE(&file);

+          }

+          break;

+        }

+        case 0x41: // request to upload avatar data

+        case 0x81:

+        { // request to re-upload avatar data

+          char* file;

+          char* hash;

+          DWORD dwPaFormat;

+

+          if (!gbSsiEnabled) break; // we could not change serv-list if it is disabled...

+

+          file = loadMyAvatarFileName();

+          if (!file)

+          { // we have no file to upload, remove hash from server

+            NetLog_Server("We do not have avatar, removing hash.");

+            IcqSetMyAvatar(0, 0);

+            LinkContactPhotoToFile(NULL, NULL);

+            break;

+          }

+          dwPaFormat = DetectAvatarFormat(file);

+          hash = calcMD5Hash(file);

+          if (!hash)

+          { // the hash could not be calculated, remove from server

+            NetLog_Server("We could not obtain hash, removing hash.");

+            IcqSetMyAvatar(0, 0);

+            LinkContactPhotoToFile(NULL, NULL);

+          }

+          else if (!memcmp(hash, pBuffer+4, 0x10))

+          { // we have the right file

+            HANDLE hFile = NULL, hMap = NULL;

+            BYTE* ppMap = NULL;

+            long cbFileSize = 0;

+

+            NetLog_Server("Uploading our avatar data.");

+

+            if ((hFile = CreateFile(file, GENERIC_READ, FILE_SHARE_READ, NULL, OPEN_EXISTING, 0, NULL )) != INVALID_HANDLE_VALUE)

+              if ((hMap = CreateFileMapping(hFile, NULL, PAGE_READONLY, 0, 0, NULL)) != NULL)

+                if ((ppMap = (BYTE*)MapViewOfFile(hMap, FILE_MAP_READ, 0, 0, 0)) != NULL)

+                  cbFileSize = GetFileSize( hFile, NULL );

+

+            if (cbFileSize != 0)

+            {

+              SetAvatarData(NULL, (WORD)(dwPaFormat == PA_FORMAT_XML ? 8 : 1), ppMap, cbFileSize);

+              LinkContactPhotoToFile(NULL, file);

+            }

+

+            if (ppMap != NULL) UnmapViewOfFile(ppMap);

+            if (hMap  != NULL) CloseHandle(hMap);

+            if (hFile != NULL) CloseHandle(hFile);

+            SAFE_FREE(&hash);

+          }

+          else

+          {

+            char* pHash = _alloca(0x14);

+

+            NetLog_Server("Our file is different, set our new hash.");

+

+            pHash[0] = 0; 

+            pHash[1] = dwPaFormat == PA_FORMAT_XML ? 8 : 1;

+			pHash[2] = 1; // state of the hash

+            pHash[3] = 0x10; // len of the hash

+            memcpy(pHash + 4, hash, 0x10);

+            updateServAvatarHash(pHash, 0x14);

+

+            SAFE_FREE(&hash);

+          }

+

+          SAFE_FREE(&file);

+          break;

+        default:

+          NetLog_Server("Reiceived UNKNOWN Avatar Status.");

+        }

+      }

+    }

+    break;

+  }

+

+  case ICQ_ERROR:

+  { // Something went wrong, probably the request for avatar family failed

+    WORD wError;

+

+    if (wBufferLength >= 2)

+      unpackWord(&pBuffer, &wError);

+    else 

+      wError = 0;

+

+    LogFamilyError(ICQ_SERVICE_FAMILY, wError);

+    break;

+  }

+

+    // Stuff we don't care about

+  case ICQ_SERVER_MOTD:

+#ifdef _DEBUG

+    NetLog_Server("Server message of the day");

+#endif

+    break;

+

+  default:

+    NetLog_Server("Warning: Ignoring SNAC(x%02x,x%02x) - Unknown SNAC (Flags: %u, Ref: %u)", ICQ_SERVICE_FAMILY, pSnacHeader->wSubtype, pSnacHeader->wFlags, pSnacHeader->dwRef);

+    break;

+

+  }

+}

+

+

+

+char* calcMD5Hash(char* szFile)

+{

+  md5_state_t state;

+  md5_byte_t digest[16];

+

+  if (szFile)

+  {

+    HANDLE hFile = NULL, hMap = NULL;

+    BYTE* ppMap = NULL;

+    long cbFileSize = 0;

+    char* res;

+

+    if ((hFile = CreateFile(szFile, GENERIC_READ, FILE_SHARE_READ, NULL, OPEN_EXISTING, 0, NULL )) != INVALID_HANDLE_VALUE)

+      if ((hMap = CreateFileMapping(hFile, NULL, PAGE_READONLY, 0, 0, NULL)) != NULL)

+        if ((ppMap = (BYTE*)MapViewOfFile(hMap, FILE_MAP_READ, 0, 0, 0)) != NULL)

+          cbFileSize = GetFileSize( hFile, NULL );

+

+    res = (char*)SAFE_MALLOC(16*sizeof(char));

+    if (cbFileSize != 0 && res)

+    {

+      md5_init(&state);

+      md5_append(&state, (const md5_byte_t *)ppMap, cbFileSize);

+      md5_finish(&state, digest);

+      memcpy(res, digest, 16);

+    }

+

+    if (ppMap != NULL) UnmapViewOfFile(ppMap);

+    if (hMap  != NULL) CloseHandle(hMap);

+    if (hFile != NULL) CloseHandle(hFile);

+

+    if (res) return res;

+  }

+  

+  return NULL;

+}

+

+

+

+static char* buildUinList(int subtype, WORD wMaxLen, HANDLE* hContactResume)

+{

+  char* szList;

+  HANDLE hContact;

+  WORD wCurrentLen = 0;

+  DWORD dwUIN;

+  uid_str szUID;

+  char szLen[2];

+  int add;

+

+

+  szList = (char*)SAFE_MALLOC(CallService(MS_DB_CONTACT_GETCOUNT, 0, 0) * UINMAXLEN);

+  szLen[1] = '\0';

+

+  if (*hContactResume)

+    hContact = *hContactResume;

+  else

+    hContact = ICQFindFirstContact();

+

+  while (hContact != NULL)

+  {

+    if (!ICQGetContactSettingUID(hContact, &dwUIN, &szUID))

+    {

+      szLen[0] = strlennull(strUID(dwUIN, szUID));

+

+      switch (subtype)

+      {

+

+      case BUL_VISIBLE:

+        add = ID_STATUS_ONLINE == ICQGetContactSettingWord(hContact, "ApparentMode", 0);

+        break;

+

+      case BUL_INVISIBLE:

+        add = ID_STATUS_OFFLINE == ICQGetContactSettingWord(hContact, "ApparentMode", 0);

+        break;

+

+      case BUL_TEMPVISIBLE:

+        add = ICQGetContactSettingByte(hContact, "TemporaryVisible", 0);

+        // clear temporary flag

+        // Here we assume that all temporary contacts will be in one packet

+        ICQDeleteContactSetting(hContact, "TemporaryVisible");

+        break;

+

+      default:

+        add = 1;

+

+        // If we are in SS mode, we only add those contacts that are

+        // not in our SS list, or are awaiting authorization, to our

+        // client side list

+        if (gbSsiEnabled && ICQGetContactSettingWord(hContact, "ServerId", 0) &&

+          !ICQGetContactSettingByte(hContact, "Auth", 0))

+          add = 0;

+

+        // Never add hidden contacts to CS list

+        if (DBGetContactSettingByte(hContact, "CList", "Hidden", 0))

+          add = 0;

+

+        break;

+      }

+

+      if (add)

+      {

+        wCurrentLen += szLen[0] + 1;

+        if (wCurrentLen > wMaxLen)

+        {

+          *hContactResume = hContact;

+          return szList;

+        }

+

+        strcat(szList, szLen);

+        strcat(szList, szUID);

+      }

+    }

+

+    hContact = ICQFindNextContact(hContact);

+  }

+  *hContactResume = NULL;

+

+

+  return szList;

+}

+

+

+

+void sendEntireListServ(WORD wFamily, WORD wSubtype, int listType)

+{

+  HANDLE hResumeContact;

+  char* szList;

+  int nListLen;

+  icq_packet packet;

+

+

+  hResumeContact = NULL;

+

+  do

+  { // server doesn't seem to be able to cope with packets larger than 8k

+    // send only about 100contacts per packet

+    szList = buildUinList(listType, 0x3E8, &hResumeContact);

+    nListLen = strlennull(szList);

+

+    if (nListLen)

+    {

+      serverPacketInit(&packet, (WORD)(nListLen + 10));

+      packFNACHeader(&packet, wFamily, wSubtype);

+      packBuffer(&packet, szList, (WORD)nListLen);

+      sendServPacket(&packet);

+    }

+

+    SAFE_FREE(&szList);

+  }

+  while (hResumeContact);

+}

+

+

+

+static void packNewCap(icq_packet* packet, WORD wNewCap)

+{ // pack standard capability

+  DWORD dwQ1 = 0x09460000 | wNewCap;

+

+  packDWord(packet, dwQ1); 

+  packDWord(packet, 0x4c7f11d1);

+  packDWord(packet, 0x82224445);

+  packDWord(packet, 0x53540000);

+}

+

+

+

+void setUserInfo()

+{ // CLI_SETUSERINFO

+  icq_packet packet;

+  WORD wAdditionalData = 0;

+  BYTE bXStatus = gbXStatusEnabled?ICQGetContactSettingByte(NULL, DBSETTING_XSTATUSID, 0):0;

+

+  if (gbAimEnabled)

+    wAdditionalData += 16;

+#ifdef DBG_CAPMTN

+  wAdditionalData += 16;

+#endif

+#ifdef DBG_CAPCH2

+  wAdditionalData += 16;

+#endif

+#ifdef DBG_CAPRTF

+  wAdditionalData += 16;

+#endif

+  if (gbUtfEnabled)

+    wAdditionalData += 16;

+#ifdef DBG_NEWCAPS

+  wAdditionalData += 16;

+#endif

+#ifdef DBG_CAPXTRAZ

+  wAdditionalData += 16;

+#endif

+#ifdef DBG_XTRAZ_MUC

+  wAdditionalData += 16;

+#endif

+  if (bXStatus)

+    wAdditionalData += 16;

+  if (gbAvatarsEnabled)

+  	wAdditionalData += 16;

+

+  serverPacketInit(&packet, (WORD)(46 + wAdditionalData));

+  packFNACHeader(&packet, ICQ_LOCATION_FAMILY, ICQ_LOCATION_SET_USER_INFO);

+

+  /* TLV(5): capability data */

+  packWord(&packet, 0x0005);

+  packWord(&packet, (WORD)(32 + wAdditionalData));

+

+

+#ifdef DBG_CAPMTN

+  {

+    packDWord(&packet, 0x563FC809); // CAP_TYPING

+    packDWord(&packet, 0x0B6F41BD);

+    packDWord(&packet, 0x9F794226);

+    packDWord(&packet, 0x09DFA2F3);

+  }

+#endif

+#ifdef DBG_CAPCH2

+  {

+    packNewCap(&packet, 0x1349);    // AIM_CAPS_ICQSERVERRELAY

+  }

+#endif

+#ifdef DBG_CAPRTF

+  {

+    packDWord(&packet, 0x97B12751); // AIM_CAPS_ICQRTF

+    packDWord(&packet, 0x243C4334); // Broadcasts the capability to receive

+    packDWord(&packet, 0xAD22D6AB); // RTF messages

+    packDWord(&packet, 0xF73F1492);

+  }

+#endif

+  if (gbUtfEnabled)

+  {

+    packNewCap(&packet, 0x134E);    // CAP_UTF8MSGS

+  } // Broadcasts the capability to receive UTF8 encoded messages

+#ifdef DBG_NEWCAPS

+  {

+    packNewCap(&packet, 0x0000);    // CAP_NEWCAPS

+  } // Tells server we understand to new format of caps

+#endif

+#ifdef DBG_CAPXTRAZ

+  {

+    packDWord(&packet, 0x1a093c6c); // CAP_XTRAZ

+    packDWord(&packet, 0xd7fd4ec5); // Broadcasts the capability to handle

+    packDWord(&packet, 0x9d51a647); // Xtraz

+    packDWord(&packet, 0x4e34f5a0);

+  }

+#endif

+#ifdef DBG_CAPXTRAZ_MUC

+  {

+    packNewCap(&packet, 0x134C);    // CAP_XTRAZ_MUC

+  } // Broadcasts the capability handle Xtraz multi-user chat

+#endif

+  if (gbAimEnabled)

+  {

+    packNewCap(&packet, 0x134D);    // Tells the server we can speak to AIM

+  }

+  if (bXStatus)

+  {

+    packBuffer(&packet, capXStatus[bXStatus-1], 0x10);

+  }

+  if (gbAvatarsEnabled)

+  {

+  	BYTE Cap[16] = {CAP_ICQ_DEVIL};

+	packBuffer(&packet, Cap, 0x10); // ICQ Devils

+  }

+  

+  packNewCap(&packet, 0x1344);      // AIM_CAPS_ICQ

+

+  packDWord(&packet, 0x4D697261);   // Miranda Signature

+  packDWord(&packet, 0x6E64614D);

+  packDWord(&packet, MIRANDA_VERSION);

+  packDWord(&packet, ICQ_PLUG_VERSION);

+

+  sendServPacket(&packet);

+}

+

+

+

+void handleServUINSettings(int nPort, serverthread_info *info)

+{

+  icq_packet packet;

+

+  setUserInfo();

+

+  /* SNAC 3,4: Tell server who's on our list */

+  sendEntireListServ(ICQ_BUDDY_FAMILY, ICQ_USER_ADDTOLIST, BUL_ALLCONTACTS);

+

+	if (icqGoingOnlineStatus == ID_STATUS_INVISIBLE)

+	{

+    /* Tell server who's on our visible list */

+    if (!gbSsiEnabled)

+      sendEntireListServ(ICQ_BOS_FAMILY, ICQ_CLI_ADDVISIBLE, BUL_VISIBLE);

+    else

+      updateServVisibilityCode(3);

+  }

+

+  if (icqGoingOnlineStatus != ID_STATUS_INVISIBLE)

+  {

+    /* Tell server who's on our invisible list */

+    if (!gbSsiEnabled)

+      sendEntireListServ(ICQ_BOS_FAMILY, ICQ_CLI_ADDINVISIBLE, BUL_INVISIBLE);

+    else

+      updateServVisibilityCode(4);

+  }

+

+

+  // SNAC 1,1E: Set status

+  {

+    WORD wStatus;

+

+    // Get status

+    wStatus = MirandaStatusToIcq(icqGoingOnlineStatus);

+			//icq_setstatus_ex(wStatus, ICQGetContactSettingDword(NULL, "RealIP", 0), nPort);

+

+

+    serverPacketInit(&packet, 71);

+    packFNACHeader(&packet, ICQ_SERVICE_FAMILY, ICQ_CLIENT_SET_STATUS);

+    packDWord(&packet, 0x00060004);             // TLV 6: Status mode and security flags

+    packWord(&packet, GetMyStatusFlags());      // Status flags

+    packWord(&packet, wStatus);                 // Status

+    packTLVWord(&packet, 0x0008, 0x0000);       // TLV 8: Error code

+    packDWord(&packet, 0x000c0025);             // TLV C: Direct connection info

+    packDWord(&packet, ICQGetContactSettingDword(NULL, "RealIP", 0));

+    packDWord(&packet, nPort);

+    packByte(&packet, DC_TYPE);                 // TCP/FLAG firewall settings

+    packWord(&packet, ICQ_VERSION);

+    packDWord(&packet, dwLocalDirectConnCookie);// DC Cookie

+    packDWord(&packet, WEBFRONTPORT);           // Web front port

+    packDWord(&packet, CLIENTFEATURES);         // Client features

+    packDWord(&packet, gdwFP1);             // Abused timestamp

+    packDWord(&packet, gdwFP2);       // Abused timestamp

+    packDWord(&packet, gdwFP3);             // Timestamp

+    packWord(&packet, 0x0000);                  // Unknown

+    packTLVWord(&packet, 0x001F, 0x0000);

+

+    sendServPacket(&packet);

+  }

+

+  /* SNAC 1,11 */

+  serverPacketInit(&packet, 14);

+  packFNACHeader(&packet, ICQ_SERVICE_FAMILY, ICQ_CLIENT_SET_IDLE);

+  packDWord(&packet, 0x00000000);

+

+  sendServPacket(&packet);

+  gbIdleAllow = 0;

+

+  // Change status

+  SetCurrentStatus(icqGoingOnlineStatus);

+

+  // Finish Login sequence

+  serverPacketInit(&packet, 90);

+  packFNACHeader(&packet, ICQ_SERVICE_FAMILY, ICQ_CLIENT_READY);

+  packDWord(&packet, 0x00010004); // imitate icq5 behaviour

+  packDWord(&packet, 0x011008E4);

+  packDWord(&packet, 0x00130004);

+  packDWord(&packet, 0x011008E4);

+  packDWord(&packet, 0x00020001);

+  packDWord(&packet, 0x011008E4);

+  packDWord(&packet, 0x00030001);

+  packDWord(&packet, 0x011008E4);

+  packDWord(&packet, 0x00150001);

+  packDWord(&packet, 0x011008E4);

+  packDWord(&packet, 0x00040001);

+  packDWord(&packet, 0x011008E4);

+  packDWord(&packet, 0x00060001);

+  packDWord(&packet, 0x011008E4);

+  packDWord(&packet, 0x00090001);

+  packDWord(&packet, 0x011008E4);

+  packDWord(&packet, 0x000A0001);

+  packDWord(&packet, 0x011008E4);

+  packDWord(&packet, 0x000B0001);

+  packDWord(&packet, 0x011008E4);

+

+  sendServPacket(&packet);

+

+  NetLog_Server(" *** Yeehah, login sequence complete");

+

+  // login sequence is complete enter logged-in mode

+  info->bLoggedIn = 1;

+

+  if (!info->isMigrating)

+  { /* Get Offline Messages Reqeust */

+    serverPacketInit(&packet, 24);

+    packFNACHeaderFull(&packet, ICQ_EXTENSIONS_FAMILY, ICQ_META_CLI_REQ, 0, 0x00020001);

+    packDWord(&packet, 0x0001000a);    /* TLV */

+    packLEWord(&packet, 8);            /* bytes remaining */

+    packLEDWord(&packet, dwLocalUIN);

+    packDWord(&packet, 0x3c000200);    /* get offline msgs */

+

+    sendServPacket(&packet);

+

+    // Update our information from the server

+    sendOwnerInfoRequest();

+

+    // Request info updates on all contacts

+    icq_RescanInfoUpdate();

+

+    // Start sending Keep-Alive packets

+    StartKeepAlive();

+  

+    if (gbAvatarsEnabled)

+    { // Send SNAC 1,4 - request avatar family 0x10 connection

+      icq_requestnewfamily(ICQ_AVATAR_FAMILY, StartAvatarThread);

+

+      pendingAvatarsStart = 1;

+      NetLog_Server("Requesting Avatar family entry point.");

+    }

+  }

+  info->isMigrating = 0;

+

+  if (gbAimEnabled)

+  {

+    char** szMsg = MirandaStatusToAwayMsg(gnCurrentStatus);

+

+    EnterCriticalSection(&modeMsgsMutex);

+    if (szMsg)

+      icq_sendSetAimAwayMsgServ(*szMsg);

+    LeaveCriticalSection(&modeMsgsMutex);

+  }

+}