Просмотр файла includes/functions_icq.php

Конкурс дизайнеров на 15000 рублей
Милый пушистый сайт !!!!
Размер файла: 13.76Kb 
  1. <?php
  2. /***************************************************************************
  3.  *                                mides.ru
  4.  *                            -------------------
  5.  ***************************************************************************/
  6. /*WebIcqLite: ICQ messages sender. v3.2b
  7. * (C) 2006 Sergey Akudovich, http://intrigue.ru
  8.  ***************************************************************************/
  9.  
  10. class WebIcqLite_TLV {
  11.     var $type;
  12.     var $size;
  13.     var $error;
  14.     
  15.     var $types = array
  16.     (
  17.         'UIN'                 =>  1, // 0x01
  18.         'DATA'                =>  2, // 0x02
  19.         'CLIENT'            =>  3, // 0x03
  20.         'ERROR_URL'            =>  4, // 0x04
  21.         'RECONECT_HERE'        =>  5, // 0x05
  22.         'COOKIE'            =>  6, // 0x06
  23.         'SNAC_VERSION'        =>  7, // 0x07
  24.         'ERROR_SUBCODE'        =>  8, // 0x08
  25.         'DISCONECT_REASON'    =>  9, // 0x09
  26.         'RECONECT_HOST'        => 10, // 0x0A
  27.         'URL'                => 11, // 0x0B
  28.         'DEBUG_DATA'        => 12, // 0x0C
  29.         'SERVICE'            => 13, // 0x0D
  30.         'CLIENT_COUNTRY'    => 14, // 0x0E
  31.         'CLIENT_LNG'        => 15, // 0x0F
  32.         'SCRIPT'            => 16, // 0x10
  33.         'USER_EMAIL'        => 17, // 0x11
  34.         'OLD_PASSWORD'        => 18, // 0x12
  35.         'REG_STATUS'        => 19, // 0x13
  36.         'DISTRIB_NUMBER'    => 20, // 0x14
  37.         'PERSONAL_TEXT'        => 21, // 0x15
  38.         'CLIENT_ID'            => 22, // 0x16
  39.         'CLI_MAJOR_VER'     => 23, // 0x17
  40.         'CLI_MINOR_VER'     => 24, // 0x18
  41.         'CLI_LESSER_VER'     => 25, // 0x19
  42.         'CLI_BUILD_NUMBER'    => 26, // 0x1A
  43. //        'PASSWORD'            => 37
  44.     );
  45.     
  46.     function setTLV($type, $value, $length = false)
  47.     {
  48.         switch ($length) 
  49.         {
  50.             case 1:
  51.                 $format = 'c';
  52.                 break;
  53.             case 2:
  54.                 $format = 'n';
  55.                 break;
  56.             case 4:
  57.                 $format = 'N';
  58.                 break;
  59.             default:
  60.                 $format = 'a*';
  61.                 break;
  62.         }
  63.         if ($length === false) 
  64.         {
  65.             $length = strlen($value);
  66.         }
  67.         return pack('nn'.$format, $this->types[$type], $length, $value);
  68.     }
  69.     
  70.     function getTLV($data)
  71.     {
  72.         $arr = unpack('n2', substr($data, 0, 4));
  73.         $this->type = $arr[1];
  74.         $this->size = $arr[2];
  75.         return substr($data, 4, $this->size);
  76.     }
  77.  
  78.     function getTLVFragment($data)
  79.     {
  80.         $frg = unpack('cid/cversion/nsize', substr($data, 0, 4));
  81.         $frg['data'] = substr($data, 4, $frg['size']);
  82.         return $frg;
  83.     }
  84. }
  85.  
  86. class WebIcqLite_SNAC extends WebIcqLite_TLV {
  87.     
  88.     var $request_id = 0;
  89.     var $uin;
  90.     
  91.     function setSNAC0102()
  92.     {
  93.         $this->request_id++;
  94.         $out = pack('nnnN', 1, 2, 0, $this->request_id);
  95.         $out .= pack('n*', 1, 3, 272, 650);
  96.         $out .= pack('n*', 2, 1, 272, 650);
  97.         $out .= pack('n*', 3, 1, 272, 650);
  98.         $out .= pack('n*', 21, 1, 272, 650);
  99.         $out .= pack('n*', 4, 1, 272, 650);
  100.         $out .= pack('n*', 6, 1, 272, 650);
  101.         $out .= pack('n*', 9, 1, 272, 650);
  102.         $out .= pack('n*', 10, 1, 272, 650);
  103.         
  104.         return $out;
  105.     }
  106.     
  107.     function setSNAC0406($uin, $message)
  108.     {
  109.         $this->request_id++;
  110.         $cookie = microtime();
  111.         $out = pack('nnnNdnca*', 4, 6, 0, $this->request_id, $cookie, 2, strlen($uin), $uin);
  112.         
  113.         $capabilities = pack('H*', '094613494C7F11D18222444553540000'); // utf-8 support
  114.         // '97B12751243C4334AD22D6ABF73F1492' rtf support
  115.         
  116.         $data = pack('nd', 0, $cookie).$capabilities;
  117.         $data .= pack('nnn', 10, 2, 1);
  118.         $data .= pack('nn', 15, 0);
  119.         $data .= pack('nnvvddnVn', 10001, strlen($message)+62, 27, 8, 0, 0, 0, 3, $this->request_id);
  120.         $data .= pack('nndnn', 14, $this->request_id, 0, 0, 0); //45
  121.         $data .= pack('ncvnva*', 1, 0, 0, 1, (strlen($message)+1), $message);
  122.         $data .= pack('H*', '0000000000FFFFFF00');
  123.         $out .= $this->setTLV('RECONECT_HERE', $data);
  124.         $out .= $this->setTLV('CLIENT', '');
  125.         return $out;
  126.     }
  127.     
  128.     function setSNAC0406offline($uin, $message)
  129.     {
  130.         $this->request_id++;
  131.         $cookie = microtime();
  132.         $out = pack('nnnNdnca*', 4, 6, 0, $this->request_id, $cookie, 1, strlen($uin), $uin);
  133.         
  134.         $data = pack('ccnc', 5, 1, 1, 1);
  135.         $data .= pack('ccnnna*', 1, 1, strlen($message)+4, 3, 0, $message);
  136.         $out .= $this->setTLV('DATA', $data);
  137.         $out .= $this->setTLV('CLIENT', '');
  138.         $out .= $this->setTLV('COOKIE', '');
  139.         return $out;
  140.     }
  141.     
  142.     function getSNAC0407($body)
  143.     {
  144.         if (strlen($body)) 
  145.         {
  146.             $msg = unpack('nfamily/nsubtype/nflags/Nrequestid/N2msgid/nchannel/cnamesize', $body);
  147.             if ($msg['family'] == 4 && $msg['subtype'] == 7) 
  148.             {
  149.                 $body = substr($body, 21);
  150.                 $from = substr($body, 0, $msg['namesize']);
  151.                 $channel = $msg['channel'];
  152.                 $body = substr($body, $msg['namesize']);
  153.                 $msg = unpack('nwarnlevel/nTLVnumber', $body);
  154.                 $body = substr($body, 4);
  155.                 for ($i = 0; $i <= $msg['TLVnumber']; $i++)
  156.                 {
  157.                     $part = $this->getTLV($body);
  158.                     $body = substr($body, 4 + $this->size);
  159.                     if ($channel == 1 && $this->type == 2) 
  160.                     {
  161.                         while (strlen($part)) 
  162.                         {
  163.                             $frg = $this->getTLVFragment($part);
  164.                             if ($frg['id'] == 1 && $frg['version'] == 1) 
  165.                             {
  166.                                 return array('from' => $from, 'message' => substr($frg['data'], 4));
  167.                             }
  168.                             $part = substr($part, 4+$frg['size']);
  169.                         }
  170.                         return false;
  171.                     }
  172.                 }
  173.             }
  174.         }
  175.         return false;
  176.     }
  177.     function dump($str)
  178.     {
  179.         $f = fopen('dump', 'a');
  180.         fwrite($f, $str);
  181.         fclose($f);
  182.     }
  183.     
  184. }
  185.  
  186. class WebIcqLite_FLAP extends WebIcqLite_SNAC{
  187.     
  188.     var $socet;
  189.     var $command = 0x2A;
  190.     var $channel;
  191.     var $sequence;
  192.     var $body;
  193.     var $info = array();
  194.  
  195.     function WebIcqLite_FLAP() {
  196.         $this->sequence = rand(1, 30000);
  197.     }
  198.     
  199.     function getFLAP()
  200.     {
  201.         if($this->socet && !socket_last_error($this->socet))
  202.         {
  203.             $header = socket_read($this->socet, 6);
  204.             if ($header) 
  205.             {
  206.                 $header = unpack('c2channel/n2size', $header);
  207.                 $this->channel = $header['channel2'];
  208.                 $this->body = socket_read($this->socet, $header['size2']);
  209.                 return true;
  210.             }
  211.             else 
  212.             {
  213.                 return false;
  214.             }
  215.         }
  216.     }
  217.     
  218.     function parseCookieFLAP()
  219.     {
  220.         $this->getFLAP();
  221.         $this->info = array();
  222.         while($this->body != '')
  223.         {
  224.             $info = $this->getTLV($this->body);
  225.             $key = array_search($this->type, $this->types);
  226.             if($key)
  227.             {
  228.                 $this->info[$key] = $info;
  229.             }
  230.             $this->body = substr($this->body, ($this->size+4));
  231.         }
  232.     }
  233.     
  234.     function parseAnswerFLAP()
  235.     {
  236.         $this->getFLAP();
  237.         $array = unpack('n3int/Nint', $this->body);
  238.         while ($array['int'] != $this->request_id) 
  239.         {
  240.             $this->getFLAP();
  241.             $array = unpack('n3int/Nint', $this->body);
  242.         }
  243.  
  244.         $this->error = 'ОҐйЁўжІІој© піўжІ ж±ўж± ';
  245.         if ($array['int1'] == 4) 
  246.         {
  247.             switch ($array['int2']) 
  248.             {
  249.                 case 1:
  250.                         $this->error = 'Ү殨塭塮ౠ㬥;
  251.                         return false;
  252.                     break;
  253.                 case 0x0c:
  254.                         return true;
  255.                     break;
  256.             }
  257.         }
  258.  
  259.         $this->error = 'ОҐйЁўжІІој© піўжІ ж±ўж± ';
  260.         return false;
  261.     }
  262.     
  263.     function prepare()
  264.     {
  265.         $this->sequence++;
  266.         $out = pack('ccnn', $this->command, $this->channel, $this->sequence, strlen($this->body)).$this->body;
  267.         return $out;
  268.     }
  269.     
  270.     function login($uin, $password)
  271.     {
  272.         $this->getFLAP();
  273.         $this->uin = $uin;
  274.         $this->body .= $this->setTLV('UIN',                 "$uin");
  275.         $this->body .= $this->setTLV('DATA',                 $this->xorpass($password));
  276.         $this->body .= $this->setTLV('CLIENT',                 'ICQBasic');
  277.         $this->body .= $this->setTLV('CLIENT_ID',             266, 2);
  278.         $this->body .= $this->setTLV('CLI_MAJOR_VER',         20, 2);
  279.         $this->body .= $this->setTLV('CLI_MINOR_VER',         34, 2);
  280.         $this->body .= $this->setTLV('CLI_LESSER_VER',         0, 2);
  281.         $this->body .= $this->setTLV('CLI_BUILD_NUMBER',     2321, 2);
  282.         $this->body .= $this->setTLV('DISTRIB_NUMBER',         1085, 4);
  283.         $this->body .= $this->setTLV('CLIENT_LNG',             'en');
  284.         $this->body .= $this->setTLV('CLIENT_COUNTRY',         'us');
  285.         
  286.         
  287.         $this->channel = 1;
  288.         $pack = $this->prepare();
  289.         socket_write($this->socet, $pack, strlen($pack));
  290.         $this->parseCookieFLAP();
  291.         
  292.         $this->body = 0x0000;
  293.         $pack = $this->prepare();
  294.         socket_write($this->socet, $pack, strlen($pack));
  295.         $this->close();
  296.         
  297.         if(isset($this->info['RECONECT_HERE']))
  298.         {
  299.             $url = explode(':', $this->info['RECONECT_HERE']);
  300.             if(!$this->open($url))
  301.             {
  302.                 $this->error = isset($this->info['DISCONECT_REASON']) ? $this->info['DISCONECT_REASON'] : 'ОҐгЇ§нЇ¦о® п¦¤й®Ё';
  303.                 return false;
  304.             }
  305.         }
  306.         else
  307.         {
  308.             $this->error = isset($this->info['DISCONECT_REASON']) ? $this->info['DISCONECT_REASON'] : 'UIN п±ін  иЎЎмЇЄй±®гЎ­. Ю硫겲ଠ௯곥 汥砲0 н©­';
  309.             return false;
  310.         }
  311.  
  312.         $this->getFLAP();
  313.         $this->body .= $this->setTLV('COOKIE', $this->info['COOKIE']);
  314.         $pack = $this->prepare();
  315.         if (!socket_write($this->socet, $pack, strlen($pack)))
  316.         {
  317.             $this->error = 'Cookie ﳯᣫ殻, 捻鮥 衪汢汮짻
  318.             return false;
  319.         }
  320.         $this->getFLAP();
  321.         $this->body = $this->setSNAC0102();
  322.         $pack = $this->prepare();
  323.         if (!socket_write($this->socet, $pack, strlen($pack)))
  324.         {
  325.             $this->error = 'ТЁд® лЎ­еЎ®а± г¬Ґн¬ п¦¤й®Ґо©Ґ 衪汢汮짻
  326.             return false;
  327.         }
  328.         return true;
  329.     }
  330.     
  331.     function write_message($uin, $message)
  332.     {
  333.         $this->body = $this->setSNAC0406($uin, $message);
  334.         $pack = $this->prepare();
  335.         if (!socket_write($this->socet, $pack, strlen($pack)))
  336.         {
  337.             $this->error = 'Ү殨塭塮ౠ㬥 捻鮥 衪汢汮짻
  338.             return false;
  339.         }
  340.         if (! $this->parseAnswerFLAP()) {
  341.             // try to send offline message
  342.             
  343.             $this->body = $this->setSNAC0406offline($uin, $message);
  344.             $pack = $this->prepare();
  345.             if (!socket_write($this->socet, $pack, strlen($pack)))
  346.             {
  347.                 $this->error = 'ОҐгЇ§нЇ¦о® піЇбЈЁ пЇЎж®ЁеЎў offline, 捻鮥 衪汢汮짻
  348.                 return false;
  349.             }
  350.             if (! $this->parseAnswerFLAP()) 
  351.             {
  352.                 return false;
  353.             }
  354.             else
  355.             {
  356.                 $this->error = 'Ю콧欼 offline. Ү殨塮ౠ㬥汢氧;
  357.                 return false;
  358.             }
  359.         }
  360.         
  361.         return true;
  362.     }
  363.     
  364.     function read_message()
  365.     {
  366.         while($this->getFLAP())
  367.         {
  368.             $message = $this->getSNAC0407($this->body);
  369.             if($message){
  370.                 return $message;
  371.             }
  372.         }
  373.         return false;
  374.     }
  375.  
  376.     function xorpass($pass)
  377.     {
  378.         $roast = array(0xF3, 0x26, 0x81, 0xC4, 0x39, 0x86, 0xDB, 0x92, 0x71, 0xA3, 0xB9, 0xE6, 0x53, 0x7A, 0x95, 0x7c);
  379.         $roasting_pass = '';
  380.         for ($i=0; $i<strlen($pass); $i++) 
  381.         {
  382.             $roasting_pass .= chr($roast[$i] ^ ord($pass{$i}));
  383.         }
  384.         return($roasting_pass);
  385.     }
  386.     
  387.     function open($url = array('login.icq.com', 5190))
  388.     {
  389.         $this->socet = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
  390.         if ($this->socet < 0 || $this->socet === false) 
  391.         {
  392.             $this->error = "socket_create() failed: reason: " . socket_strerror($this->socet);
  393.             return false;
  394.         }
  395.         $result = socket_connect($this->socet, gethostbyname($url[0]), $url[1]);
  396.         if ($result < 0 || $result === false) 
  397.         {
  398.             $this->error = "socket_connect() failed.\nReason: ($result) " . socket_strerror(socket_last_error($socket));
  399.             return false;
  400.         }
  401.         return true;
  402.     }
  403.  
  404.     function close()
  405.     {
  406.         return socket_close($this->socet);
  407.     }
  408. }
  409.  
  410. class WebIcqLite extends WebIcqLite_FLAP {
  411.  
  412.     function WebIcqLite ()
  413.     {
  414.         $this->WebIcqLite_FLAP();
  415.     }
  416.     
  417.     function is_connected()
  418.     {
  419.         if(!$this->socet || socket_last_error($this->socet))
  420.         {
  421.             $this->error = socket_strerror(socket_last_error($socket));
  422.             return false;
  423.         }
  424.         return true;
  425.     }
  426.     
  427.     function connect($uin, $pass)
  428.     {
  429.         if (!$this->open()) 
  430.         {
  431.             return false;
  432.         }
  433.         
  434.         return $this->login($uin, $pass);
  435.     }
  436.  
  437.     function disconnect()
  438.     {
  439.         return $this->close();
  440.     }
  441.  
  442.     function get_message()
  443.     {
  444.         return $this->read_message();
  445.     }
  446.     
  447.     function send_message($uin, $message)
  448.     {
  449.         return $this->write_message($uin, $message);
  450.     }
  451. }
  452. ?>