PHP 获取MSN好友列表组信息发送离线消息 (一)

雨点打透心脏的1/2处 2022-09-19 10:44 31阅读 0赞

`<?php /** * 基于 http://code.google.com/p/phpmsnclass/ 1.8版 * 去除大段注释，以及无用代码 * 仅使用发消息及获取好友列表功能 * 2008-12-15 李勇 */ class MSN{     //dispatch服务器地址及端口     private $server = 'messenger.hotmail.com';     private $port = 1863;     private $passport_url = 'https://login.live.com/RST.srf';     private $prod_key = 'PK}_A_0N_K%O?A9S';     private $prod_id = 'PROD0114ES4Z%Q5W';     private $clientid = '0x7000800C';     private $id;     private $fp = false;     private $error = '';     private $authed = false;     private $user = '';     private $password = '';     private $passport_policy = '';     private $oim_try = 3;     private $oim_ticket = '';     private $contact_ticket = '';     private $debug = true;     private $timeout = 15;     private $stream_timeout = 2;     private $sb;     private $font_fn = 'Arial';     private $font_co = '333333';     private $font_ef = '';     private $max_msn_message_len = 1664;     private $max_yahoo_message_len = 518;     /**      * 构造函数，需要以下PHP扩展的支持curl,prece,mhash,mcrypt,bcmath      *      * @return MSN      */     public function MSN(){         if (!function_exists('curl_init')) die("We need curl module!\n");         if (!function_exists('preg_match')) die("We need pcre module!\n");         if (!function_exists('mhash'))die("We need mhash module  !\n");         if (!function_exists('mcrypt_cbc')) die("We need mcrypt module !\n");         if (!function_exists('bcmod'))die("We need bcmath module !\n");         return;     }     /**      * 登录指定MSN账号      *      * @param string $user      * @param string $password      * @return bool      * @uses      *      var      *          id      *          fp      *          =>error      *          =>authed      *          timeout      *          =>passport_policy      *          =>oim_ticket      *          =>contact_ticket      *          =>user      *          =>password      *      function      *          readln      *          writeln      *          readdata      *          debug_message      *          get_passport_ticket      *          generateLoginBLOB      */     public function connect($user, $password){         $this->id = 1;         $server='messenger.hotmail.com';         $port=1863;         $errno=0;         $errstr='';         $stream_timeout = 2;         $this->fp = @fsockopen($server, $port, $errno, $errstr, 5);         if (!$this->fp) {             $this->error = "Can't connect to $server:$port, error => $errno, $errstr";             return false;         }         stream_set_timeout($this->fp, $stream_timeout);         $this->authed = false;         $this->writeln("VER $this->id MSNP15 CVR0");         $start_tm = time();         while (!feof($this->fp)) {             $data = $this->readln();             // no data?             if ($data === false) {                 if ($this->timeout > 0) {                     $now_tm = time();                     $used_time = ($now_tm >= $start_tm) ? $now_tm - $start_tm : $now_tm;                     if ($used_time > $this->timeout) {                         // logout now                         // NS: >>> OUT                         $this->writeln("OUT");                         fclose($this->fp);                         $this->error = 'Timeout, maybe protocol changed!';                         $this->debug_message("*** $this->error");                         return false;                     }                 }                 continue;             }             $code = substr($data, 0, 3);             $start_tm = time();             switch ($code) {                 case 'VER':                     $this->writeln("CVR $this->id 0x0409 winnt 5.1 i386 MSMSGS 8.1.0178 msmsgs $user");                     break;                 case 'CVR':                     $this->writeln("USR $this->id SSO I $user");                     break;                 case 'USR':                     if ($this->authed) return true;                     // max. 16 digits for password                     if (strlen($password) > 16)                     $password = substr($password, 0, 16);                     $this->user = $user;                     $this->password = $password;                     // NS: <<< USR {id} SSO S {policy} {nonce}                     @list(/* USR */, /* id */, /* SSO */, /* S */, $policy, $nonce,) = @explode(' ', $data);                     $this->passport_policy = $policy;                     $aTickets = $this->get_passport_ticket();                     if (!$aTickets || !is_array($aTickets)) {                         // logout now                         // NS: >>> OUT                         $this->writeln("OUT");                         fclose($this->fp);                         $this->error = 'Passport authenticated fail!';                         $this->debug_message("*** $this->error");                         return false;                     }                     $this->oim_ticket = $aTickets['oim_ticket'];                     $this->contact_ticket = $aTickets['contact_ticket'];                     // NS: >>> USR {id} SSO S {ticket} {login_code}                     $this->writeln("USR $this->id SSO S ".$aTickets['ticket']." ".$this->generateLoginBLOB($aTickets['secret'], $nonce));                     $this->authed = true;                     break;                 case 'XFR':                     @list(/* XFR */, /* id */, /* NS */, $server, /* ... */) = @explode(' ', $data);                     @list($ip, $port) = @explode(':', $server);                     // this connection will close after XFR                     fclose($this->fp);                     $errno=0;                     $errstr='';                     $this->fp = @fsockopen($ip, $port, $errno, $errstr, 5);                     if (!$this->fp) {                         $this->error = "Can't connect to $ip:$port, error => $errno, $errstr";                         $this->debug_message("*** $this->error");                         return false;                     }                     stream_set_timeout($this->fp, $this->stream_timeout);                     $this->writeln("VER $this->id MSNP15 CVR0");                     break;                 case 'GCF':                     // return some policy data after 'USR {id} SSO I {user}' command                     // NS: <<< GCF 0 {size}                     @list(/* GCF */, /* 0 */, $size,) = @explode(' ', $data);                     // we don't need the data, just read it and drop                     if (is_numeric($size) && $size > 0)                     $this->readdata($size);                     break;                 default:                     // we'll quit if got any error                     if (is_numeric($code)) {                         // logout now                         // NS: >>> OUT                         $this->writeln("OUT");                         fclose($this->fp);                         $this->error = "Error code: $code, please check the detail information from: http://msnpiki.msnfanatic.com/index.php/Reference:Error_List";                         $this->debug_message("*** $this->error");                         return false;                     }                     // unknown response from server, just ignore it                     break;             }         }         // never goto here         return false;     }     /**      * 获取通行证的令牌      *      * @param string $url      * @return string      * @uses      *      var      *          user<=      *          password<=      *          passport_url<=      *          passport_policy<=      *      function      */     private function get_passport_ticket($url = ''){         $user = $this->user;         $password = htmlspecialchars($this->password);         if ($url === '')         $passport_url = $this->passport_url;         else         $passport_url = $url;         $XML = '<?xml version="1.0" encoding="UTF-8"?> <Envelope xmlns="http://schemas.xmlsoap.org/soap/envelope/"           xmlns:wsse="http://schemas.xmlsoap.org/ws/2003/06/secext"           xmlns:saml="urn:oasis:names:tc:SAML:1.0:assertion"           xmlns:wsp="http://schemas.xmlsoap.org/ws/2002/12/policy"           xmlns:wsu="http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-utility-1.0.xsd"           xmlns:wsa="http://schemas.xmlsoap.org/ws/2004/03/addressing"           xmlns:wssc="http://schemas.xmlsoap.org/ws/2004/04/sc"           xmlns:wst="http://schemas.xmlsoap.org/ws/2004/04/trust"> <Header>   <ps:AuthInfo xmlns:ps="http://schemas.microsoft.com/Passport/SoapServices/PPCRL" Id="PPAuthInfo">     <ps:HostingApp>{7108E71A-9926-4FCB-BCC9-9A9D3F32E423}</ps:HostingApp>     <ps:BinaryVersion>4</ps:BinaryVersion>     <ps:UIVersion>1</ps:UIVersion>     <ps:Cookies></ps:Cookies>     <ps:RequestParams>AQAAAAIAAABsYwQAAAAxMDMz</ps:RequestParams>   </ps:AuthInfo>   <wsse:Security>     <wsse:UsernameToken Id="user">       <wsse:Username>'.$user.'</wsse:Username>       <wsse:Password>'.$password.'</wsse:Password>     </wsse:UsernameToken>   </wsse:Security> </Header> <Body>   <ps:RequestMultipleSecurityTokens xmlns:ps="http://schemas.microsoft.com/Passport/SoapServices/PPCRL" Id="RSTS">     <wst:RequestSecurityToken Id="RST0">       <wst:RequestType>http://schemas.xmlsoap.org/ws/2004/04/security/trust/Issue</wst:RequestType>       <wsp:AppliesTo>         <wsa:EndpointReference>           <wsa:Address>http://Passport.NET/tb</wsa:Address>         </wsa:EndpointReference>       </wsp:AppliesTo>     </wst:RequestSecurityToken>     <wst:RequestSecurityToken Id="RST1">       <wst:RequestType>http://schemas.xmlsoap.org/ws/2004/04/security/trust/Issue</wst:RequestType>       <wsp:AppliesTo>         <wsa:EndpointReference>           <wsa:Address>messengerclear.live.com</wsa:Address>         </wsa:EndpointReference>       </wsp:AppliesTo>       <wsse:PolicyReference URI="'.$this->passport_policy.'"></wsse:PolicyReference>     </wst:RequestSecurityToken>     <wst:RequestSecurityToken Id="RST2">       <wst:RequestType>http://schemas.xmlsoap.org/ws/2004/04/security/trust/Issue</wst:RequestType>       <wsp:AppliesTo>         <wsa:EndpointReference>           <wsa:Address>messenger.msn.com</wsa:Address>         </wsa:EndpointReference>       </wsp:AppliesTo>       <wsse:PolicyReference URI="?id=507"></wsse:PolicyReference>     </wst:RequestSecurityToken>     <wst:RequestSecurityToken Id="RST3">       <wst:RequestType>http://schemas.xmlsoap.org/ws/2004/04/security/trust/Issue</wst:RequestType>       <wsp:AppliesTo>         <wsa:EndpointReference>           <wsa:Address>contacts.msn.com</wsa:Address>         </wsa:EndpointReference>       </wsp:AppliesTo>       <wsse:PolicyReference URI="MBI"></wsse:PolicyReference>     </wst:RequestSecurityToken>     <wst:RequestSecurityToken Id="RST4">       <wst:RequestType>http://schemas.xmlsoap.org/ws/2004/04/security/trust/Issue</wst:RequestType>       <wsp:AppliesTo>         <wsa:EndpointReference>           <wsa:Address>messengersecure.live.com</wsa:Address>         </wsa:EndpointReference>       </wsp:AppliesTo>       <wsse:PolicyReference URI="MBI_SSL"></wsse:PolicyReference>     </wst:RequestSecurityToken>     <wst:RequestSecurityToken Id="RST5">       <wst:RequestType>http://schemas.xmlsoap.org/ws/2004/04/security/trust/Issue</wst:RequestType>       <wsp:AppliesTo>         <wsa:EndpointReference>           <wsa:Address>spaces.live.com</wsa:Address>         </wsa:EndpointReference>       </wsp:AppliesTo>       <wsse:PolicyReference URI="MBI"></wsse:PolicyReference>     </wst:RequestSecurityToken>     <wst:RequestSecurityToken Id="RST6">       <wst:RequestType>http://schemas.xmlsoap.org/ws/2004/04/security/trust/Issue</wst:RequestType>       <wsp:AppliesTo>         <wsa:EndpointReference>           <wsa:Address>storage.msn.com</wsa:Address>         </wsa:EndpointReference>       </wsp:AppliesTo>       <wsse:PolicyReference URI="MBI"></wsse:PolicyReference>     </wst:RequestSecurityToken>   </ps:RequestMultipleSecurityTokens> </Body> </Envelope>';         $curl = curl_init();         curl_setopt($curl, CURLOPT_URL, $passport_url);         if ($this->debug) curl_setopt($curl, CURLOPT_HEADER, 1);         curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);         curl_setopt($curl, CURLOPT_FOLLOWLOCATION, 1);         curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, 0);         curl_setopt($curl, CURLOPT_POST, 1);         curl_setopt($curl, CURLOPT_POSTFIELDS, $XML);         $data = curl_exec($curl);         $http_code = curl_getinfo($curl, CURLINFO_HTTP_CODE);         curl_close($curl);         if ($http_code != 200) {             // sometimes, redirect to another URL             // MSNP15             //<faultcode>psf:Redirect</faultcode>             //<psf:redirectUrl>https://msnia.login.live.com/pp450/RST.srf</psf:redirectUrl>             //<faultstring>Authentication Failure</faultstring>             if (strpos($data, '<faultcode>psf:Redirect</faultcode>') === false) {                 $this->debug_message("*** Can't get passport ticket! http code = $http_code");                 return false;             }             preg_match("#<psf\:redirectUrl>(.*)</psf\:redirectUrl>#", $data, $matches);             if (count($matches) == 0) {                 $this->debug_message("*** redirect, but can't get redirect URL!");                 return false;             }             $redirect_url = $matches[1];             if ($redirect_url == $passport_url) {                 $this->debug_message("*** redirect, but redirect to same URL!");                 return false;             }             $this->debug_message("*** redirect to $redirect_url");             return $this->get_passport_ticket($redirect_url);         }         // sometimes, rediret to another URL, also return 200         // MSNP15         //<faultcode>psf:Redirect</faultcode>         //<psf:redirectUrl>https://msnia.login.live.com/pp450/RST.srf</psf:redirectUrl>         //<faultstring>Authentication Failure</faultstring>         if (strpos($data, '<faultcode>psf:Redirect</faultcode>') !== false) {             preg_match("#<psf\:redirectUrl>(.*)</psf\:redirectUrl>#", $data, $matches);             if (count($matches) != 0) {                 $redirect_url = $matches[1];                 if ($redirect_url == $passport_url) {                     $this->debug_message("*** redirect, but redirect to same URL!");                     return false;                 }                 $this->debug_message("*** redirect to $redirect_url");                 return $this->get_passport_ticket($redirect_url);             }         }         preg_match("#".         "<wsse\:BinarySecurityToken Id=\"Compact1\">(.*)</wsse\:BinarySecurityToken>(.*)".         "<wst\:BinarySecret>(.*)</wst\:BinarySecret>(.*)".         "<wsse\:BinarySecurityToken Id=\"PPToken2\">(.*)</wsse\:BinarySecurityToken>(.*)".         "<wsse\:BinarySecurityToken Id=\"Compact3\">(.*)</wsse\:BinarySecurityToken>(.*)".         "<wsse\:BinarySecurityToken Id=\"Compact4\">(.*)</wsse\:BinarySecurityToken>(.*)".         "<wsse\:BinarySecurityToken Id=\"Compact5\">(.*)</wsse\:BinarySecurityToken>(.*)".         "<wsse\:BinarySecurityToken Id=\"Compact6\">(.*)</wsse\:BinarySecurityToken>(.*)".         "#",         $data, $matches);         // no ticket found!         if (count($matches) == 0) {             $this->debug_message("*** Can't get passport ticket!");             return false;         }         // yes, we get ticket         $aTickets = array(         'ticket' => html_entity_decode($matches[1]),         'secret' => html_entity_decode($matches[3]),         'contact_ticket' => html_entity_decode($matches[7]),         'oim_ticket' => html_entity_decode($matches[9]),         );         return $aTickets;     }`

阅读(594) | 评论(0) | 转发(0) |

上一篇：关于新版一起网平台的一些想法

下一篇：PHP 获取MSN好友列表 组信息 发送离线消息 (二)