plugins/Msn/extlib/phpmsnclass/msn.class.php

   1 <?php\r
   2 /*\r
   3 \r
   4 phpmsnclass ver 2.0s\r
   5 Luke Fitzgerald <lw.fitzgerald@googlemail.com>\r
   6 \r
   7 Based on MSN class ver 2.0 by Tommy Wu, Ricky Su\r
   8 License: GPL\r
   9 \r
  10 Documentation on the MSN protocol can be found at: http://msnpiki.msnfanatic.com/index.php/Main_Page\r
  11 \r
  12 This class uses MSNP15.\r
  13 \r
  14 In addition to PHP5, the additional php modules required are:\r
  15 curl pcre mhash mcrypt bcmath\r
  16 \r
  17 */\r
  18 \r
  19 class MSN {\r
  20     const PROTOCOL = 'MSNP15';\r
  21     const PASSPORT_URL = 'https://login.live.com/RST.srf';\r
  22     const BUILDVER = '8.1.0178';\r
  23     const PROD_KEY = 'PK}_A_0N_K%O?A9S';\r
  24     const PROD_ID = 'PROD0114ES4Z%Q5W';\r
  25     const LOGIN_METHOD = 'SSO';\r
  26 \r
  27     const OIM_SEND_URL = 'https://ows.messenger.msn.com/OimWS/oim.asmx';\r
  28     const OIM_SEND_SOAP = 'http://messenger.live.com/ws/2006/09/oim/Store2';\r
  29 \r
  30     const OIM_MAILDATA_URL = 'https://rsi.hotmail.com/rsi/rsi.asmx';\r
  31     const OIM_MAILDATA_SOAP = 'http://www.hotmail.msn.com/ws/2004/09/oim/rsi/GetMetadata';\r
  32     const OIM_READ_URL = 'https://rsi.hotmail.com/rsi/rsi.asmx';\r
  33     const OIM_READ_SOAP = 'http://www.hotmail.msn.com/ws/2004/09/oim/rsi/GetMessage';\r
  34     const OIM_DEL_URL = 'https://rsi.hotmail.com/rsi/rsi.asmx';\r
  35     const OIM_DEL_SOAP = 'http://www.hotmail.msn.com/ws/2004/09/oim/rsi/DeleteMessages';\r
  36 \r
  37     const MEMBERSHIP_URL = 'https://contacts.msn.com/abservice/SharingService.asmx';\r
  38     const MEMBERSHIP_SOAP = 'http://www.msn.com/webservices/AddressBook/FindMembership';\r
  39 \r
  40     const ADDMEMBER_URL = 'https://contacts.msn.com/abservice/SharingService.asmx';\r
  41     const ADDMEMBER_SOAP = 'http://www.msn.com/webservices/AddressBook/AddMember';\r
  42 \r
  43     const DELMEMBER_URL = 'https://contacts.msn.com/abservice/SharingService.asmx';\r
  44     const DELMEMBER_SOAP = 'http://www.msn.com/webservices/AddressBook/DeleteMember';\r
  45 \r
  46     // the message length (include header) is limited (maybe since WLM 8.5 released)\r
  47     // for WLM: 1664 bytes\r
  48     // for YIM: 518 bytes\r
  49     const MAX_MSN_MESSAGE_LEN = 1664;\r
  50     const MAX_YAHOO_MESSAGE_LEN = 518;\r
  51 \r
  52     private $debug;\r
  53     private $timeout;\r
  54 \r
  55     private $id;\r
  56     private $ticket;\r
  57     private $user = '';\r
  58     private $password = '';\r
  59     private $NSfp = false;\r
  60     private $passport_policy = '';\r
  61     private $alias;\r
  62     private $psm;\r
  63     private $retry_wait;\r
  64     private $update_pending;\r
  65     private $PhotoStickerFile = false;\r
  66     private $Emotions = false;\r
  67     private $XFRReqTimeout = 60;\r
  68     private $SBStreamTimeout = 2;\r
  69     private $MsnObjArray = array();\r
  70     private $MsnObjMap = array();\r
  71     private $ABAuthHeader;\r
  72     private $ABService;\r
  73     private $Contacts;\r
  74 \r
  75     private $server = 'messenger.hotmail.com';\r
  76     private $port = 1863;\r
  77 \r
  78     private $clientid = '';\r
  79 \r
  80     private $error = '';\r
  81 \r
  82     private $authed = false;\r
  83 \r
  84     private $oim_try = 3;\r
  85 \r
  86     private $font_fn = 'Arial';\r
  87     private $font_co = '333333';\r
  88     private $font_ef = '';\r
  89 \r
  90     // Begin added for StatusNet\r
  91 \r
  92     private $aContactList = array();\r
  93     private $aADL = array();\r
  94 \r
  95     /**\r
  96     * Holds session information indexed by screenname if\r
  97     * session has no socket or socket if socket present\r
  98     *\r
  99     * @var array\r
 100     */\r
 101     private $switchBoardSessions = array();\r
 102 \r
 103     /**\r
 104     * Holds sockets indexed by screenname\r
 105     *\r
 106     * @var array\r
 107     */\r
 108     private $switchBoardSessionLookup = array();\r
 109 \r
 110     /**\r
 111     * Holds references to sessions waiting for XFR\r
 112     *\r
 113     * @var array\r
 114     */\r
 115     private $waitingForXFR = array();\r
 116 \r
 117     /**\r
 118     * Event Handler Functions\r
 119     */\r
 120     private $myEventHandlers = array();\r
 121 \r
 122     // End added for StatusNet\r
 123 \r
 124     /**\r
 125     * Constructor method\r
 126     *\r
 127     * @param array $Configs Array of configuration options\r
 128     *                       'user'           - Username\r
 129     *                       'password'       - Password\r
 130     *                       'alias'          - Bot nickname\r
 131     *                       'psm'            - Bot personal status message\r
 132     *                       'retry_wait'     - Time to wait before trying to reconnect\r
 133     *                       'update_pending' - Whether to update pending contacts\r
 134     *                       'PhotoSticker'   - Photo file to use (?)\r
 135     *                       'debug'          - Enable/Disable debugging mode\r
 136     * @param integer $timeout Connection timeout\r
 137     * @param integer $client_id Client id (hexadecimal)\r
 138     * @return MSN\r
 139     */\r
 140     public function __construct ($Configs = array(), $timeout = 15, $client_id = 0x7000800C) {\r
 141         $this->user = $Configs['user'];\r
 142         $this->password = $Configs['password'];\r
 143         $this->alias = isset($Configs['alias']) ? $Configs['alias'] : '';\r
 144         $this->psm = isset($Configs['psm']) ? $Configs['psm'] : '';\r
 145         $this->retry_wait = isset($Configs['retry_wait']) ? $Configs['retry_wait'] : 30;\r
 146         $this->update_pending = isset($Configs['update_pending']) ? $Configs['update_pending'] : true;\r
 147         $this->PhotoStickerFile=isset($Configs['PhotoSticker']) ? $Configs['PhotoSticker'] : false;\r
 148 \r
 149         if ($this->Emotions = isset($Configs['Emotions']) ? $Configs['Emotions']:false) {\r
 150             foreach($this->Emotions as $EmotionFilePath)\r
 151                 $this->MsnObj($EmotionFilePath,$Type=2);\r
 152         }\r
 153         $this->debug = isset($Configs['debug']) ? $Configs['debug'] : false;\r
 154         $this->timeout = $timeout;\r
 155 \r
 156         // Check support\r
 157         if (!function_exists('curl_init')) throw new Exception("curl module not found!\n");\r
 158         if (!function_exists('preg_match')) throw new Exception("pcre module not found!\n");\r
 159         if (!function_exists('mhash')) throw new Exception("mhash module not found!\n");\r
 160         if (!function_exists('mcrypt_cbc')) throw new Exception("mcrypt module not found!\n");\r
 161         if (!function_exists('bcmod')) throw new Exception("bcmath module not found!\n");\r
 162 \r
 163         /*\r
 164          http://msnpiki.msnfanatic.com/index.php/Client_ID\r
 165          Client ID for MSN:\r
 166          normal MSN 8.1 clientid is:\r
 167          01110110 01001100 11000000 00101100\r
 168          = 0x764CC02C\r
 169 \r
 170          we just use following:\r
 171          * 0x04: Your client can send/receive Ink (GIF format)\r
 172          * 0x08: Your client can send/recieve Ink (ISF format)\r
 173          * 0x8000: This means you support Winks receiving (If not set the official Client will warn with 'contact has an older client and is not capable of receiving Winks')\r
 174          * 0x70000000: This is the value for MSNC7 (WL Msgr 8.1)\r
 175          = 0x7000800C;\r
 176          */\r
 177         $this->clientid = $client_id;\r
 178         $this->ABService = new SoapClient(realpath(dirname(__FILE__)).'/soap/msnab_sharingservice.wsdl', array('trace' => 1));\r
 179     }\r
 180 \r
 181     /**\r
 182      * Signon methods\r
 183      */\r
 184 \r
 185     /**\r
 186      * Connect to the NS server\r
 187      *\r
 188      * @param String $user Username\r
 189      * @param String $password Password\r
 190      * @param String $redirect_server Redirect server\r
 191      * @param Integer $redirect_port Redirect port\r
 192      * @return Boolean Returns true if successful\r
 193      */\r
 194     private function connect($user, $password, $redirect_server = '', $redirect_port = 1863) {\r
 195         $this->id = 1;\r
 196         if ($redirect_server === '') {\r
 197             $this->NSfp = @fsockopen($this->server, $this->port, $errno, $errstr, $this->timeout);\r
 198             if (!$this->NSfp) {\r
 199                 $this->error = "!!! Could not connect to $this->server:$this->port, error => $errno, $errstr";\r
 200                 return false;\r
 201             }\r
 202         }\r
 203         else {\r
 204             $this->NSfp = @fsockopen($redirect_server, $redirect_port, $errno, $errstr, $this->timeout);\r
 205             if (!$this->NSfp) {\r
 206                 $this->error = "!!! Could not connect to $redirect_server:$redirect_port, error => $errno, $errstr";\r
 207                 return false;\r
 208             }\r
 209         }\r
 210         $this->authed = false;\r
 211         // MSNP9\r
 212         // NS: >> VER {id} MSNP9 CVR0\r
 213         // MSNP15\r
 214         // NS: >>> VER {id} MSNP15 CVR0\r
 215         $this->ns_writeln("VER $this->id ".self::PROTOCOL.' CVR0');\r
 216 \r
 217         $start_tm = time();\r
 218         while (!self::socketcheck($this->NSfp)) {\r
 219             $data = $this->ns_readln();\r
 220             // no data?\r
 221             if ($data === false) {\r
 222                 // logout now\r
 223                 // NS: >>> OUT\r
 224                 $this->ns_writeln("OUT");\r
 225                 @fclose($this->NSfp);\r
 226                 $this->error = 'Timeout, maybe protocol changed!';\r
 227                 return false;\r
 228             }\r
 229 \r
 230             $code = substr($data, 0, 3);\r
 231             $start_tm = time();\r
 232 \r
 233             switch ($code) {\r
 234                 case 'VER':\r
 235                     // MSNP9\r
 236                     // NS: <<< VER {id} MSNP9 CVR0\r
 237                     // NS: >>> CVR {id} 0x0409 winnt 5.1 i386 MSMSGS 6.0.0602 msmsgs {user}\r
 238                     // MSNP15\r
 239                     // NS: <<< VER {id} MSNP15 CVR0\r
 240                     // NS: >>> CVR {id} 0x0409 winnt 5.1 i386 MSMSGS 8.1.0178 msmsgs {user}\r
 241                     $this->ns_writeln("CVR $this->id 0x0409 winnt 5.1 i386 MSMSGS ".self::BUILDVER." msmsgs $user");\r
 242                     break;\r
 243 \r
 244                 case 'CVR':\r
 245                     // MSNP9\r
 246                     // NS: <<< CVR {id} {ver_list} {download_serve} ....\r
 247                     // NS: >>> USR {id} TWN I {user}\r
 248                     // MSNP15\r
 249                     // NS: <<< CVR {id} {ver_list} {download_serve} ....\r
 250                     // NS: >>> USR {id} SSO I {user}\r
 251                     $this->ns_writeln("USR $this->id ".self::LOGIN_METHOD." I $user");\r
 252                     break;\r
 253 \r
 254                 case 'USR':\r
 255                     // already login for passport site, finish the login process now.\r
 256                     // NS: <<< USR {id} OK {user} {verify} 0\r
 257                     if ($this->authed) return true;\r
 258                     // max. 16 digits for password\r
 259                     if (strlen($password) > 16)\r
 260                     $password = substr($password, 0, 16);\r
 261 \r
 262                     $this->user = $user;\r
 263                     $this->password = $password;\r
 264                     // NS: <<< USR {id} SSO S {policy} {nonce}\r
 265                     @list(/* USR */, /* id */, /* SSO */, /* S */, $policy, $nonce) = @explode(' ', $data);\r
 266 \r
 267                     $this->passport_policy = $policy;\r
 268                     $aTickets = $this->get_passport_ticket();\r
 269                     if (!$aTickets || !is_array($aTickets)) {\r
 270                         // logout now\r
 271                         // NS: >>> OUT\r
 272                         $this->ns_writeln("OUT");\r
 273                         @fclose($this->NSfp);\r
 274                         $this->error = 'Passport authentication failed!';\r
 275                         return false;\r
 276                     }\r
 277 \r
 278                     $ticket = $aTickets['ticket'];\r
 279                     $secret = $aTickets['secret'];\r
 280                     $this->ticket = $aTickets;\r
 281                     $login_code = $this->generateLoginBLOB($secret, $nonce);\r
 282 \r
 283                     // NS: >>> USR {id} SSO S {ticket} {login_code}\r
 284                     $this->ns_writeln("USR $this->id ".self::LOGIN_METHOD." S $ticket $login_code");\r
 285                     $this->authed = true;\r
 286                     break;\r
 287 \r
 288                 case 'XFR':\r
 289                     // main login server will redirect to anther NS after USR command\r
 290                     // MSNP9\r
 291                     // NS: <<< XFR {id} NS {server} 0 {server}\r
 292                     // MSNP15\r
 293                     // NS: <<< XFR {id} NS {server} U D\r
 294                     @list(/* XFR */, /* id */, $Type, $server) = @explode(' ', $data);\r
 295                     if ($Type!='NS') break;\r
 296                     @list($ip, $port) = @explode(':', $server);\r
 297                     // this connection will close after XFR\r
 298                     @fclose($this->NSfp);\r
 299 \r
 300                     $this->NSfp = @fsockopen($ip, $port, $errno, $errstr, $this->timeout);\r
 301                     if (!$this->NSfp) {\r
 302                         $this->error = "Can't connect to $ip:$port, error => $errno, $errstr";\r
 303                         return false;\r
 304                     }\r
 305 \r
 306                     // MSNP9\r
 307                     // NS: >> VER {id} MSNP9 CVR0\r
 308                     // MSNP15\r
 309                     // NS: >>> VER {id} MSNP15 CVR0\r
 310                     $this->ns_writeln("VER $this->id ".self::PROTOCOL.' CVR0');\r
 311                     break;\r
 312 \r
 313                 case 'GCF':\r
 314                     // return some policy data after 'USR {id} SSO I {user}' command\r
 315                     // NS: <<< GCF 0 {size}\r
 316                     @list(/* GCF */, /* 0 */, $size) = @explode(' ', $data);\r
 317                     // we don't need the data, just read it and drop\r
 318                     if (is_numeric($size) && $size > 0)\r
 319                         $this->ns_readdata($size);\r
 320                     break;\r
 321 \r
 322                 default:\r
 323                     // we'll quit if got any error\r
 324                     if (is_numeric($code)) {\r
 325                         // logout now\r
 326                         // NS: >>> OUT\r
 327                         $this->ns_writeln("OUT");\r
 328                         @fclose($this->NSfp);\r
 329                         $this->error = "Error code: $code, please check the detail information from: http://msnpiki.msnfanatic.com/index.php/Reference:Error_List";\r
 330                         return false;\r
 331                     }\r
 332                     // unknown response from server, just ignore it\r
 333                     break;\r
 334             }\r
 335         }\r
 336         // never goto here\r
 337     }\r
 338 \r
 339     /**\r
 340      * Sign onto the NS server and retrieve the address book\r
 341      *\r
 342      * @return void\r
 343      */\r
 344     public function signon() {\r
 345         /* FIXME Don't implement the signon as a loop or we could hang\r
 346         *        the queue handler! */\r
 347         $this->debug_message('*** Trying to connect to MSN network');\r
 348 \r
 349         // Remove any remaining switchboard sessions\r
 350         $this->switchBoardSessions = array();\r
 351         $this->switchBoardSessionLookup = array();\r
 352 \r
 353         while (true) {\r
 354             // Connect\r
 355             if (!$this->connect($this->user, $this->password)) {\r
 356                 $this->signonFailure("!!! Could not connect to server: $this->error");\r
 357                 continue;\r
 358             }\r
 359 \r
 360             // Update contacts\r
 361             if ($this->UpdateContacts() === false) {\r
 362                 $this->signonFailure('');\r
 363                 continue;\r
 364             }\r
 365 \r
 366             // Get membership lists\r
 367             if (($this->aContactList = $this->getMembershipList()) === false) {\r
 368                 $this->signonFailure('!!! Get membership list failed');\r
 369                 continue;\r
 370             }\r
 371 \r
 372             if ($this->update_pending) {\r
 373                 if (is_array($this->aContactList)) {\r
 374                     $pending = 'Pending';\r
 375                     foreach ($this->aContactList as $u_domain => $aUserList) {\r
 376                         foreach ($aUserList as $u_name => $aNetworks) {\r
 377                             foreach ($aNetworks as $network => $aData) {\r
 378                                 if (isset($aData[$pending])) {\r
 379                                     // pending list\r
 380                                     $cnt = 0;\r
 381                                     foreach (array('Allow', 'Reverse') as $list) {\r
 382                                         if (isset($aData[$list]))\r
 383                                             $cnt++;\r
 384                                         else {\r
 385                                             if ($this->addMemberToList($u_name.'@'.$u_domain, $network, $list)) {\r
 386                                                 $this->aContactList[$u_domain][$u_name][$network][$list] = false;\r
 387                                                 $cnt++;\r
 388                                             }\r
 389                                         }\r
 390                                     }\r
 391                                     if ($cnt >= 2) {\r
 392                                         $id = $aData[$pending];\r
 393                                         // we can delete it from pending now\r
 394                                         if ($this->delMemberFromList($id, $u_name.'@'.$u_domain, $network, $pending))\r
 395                                             unset($this->aContactList[$u_domain][$u_name][$network][$pending]);\r
 396                                     }\r
 397                                 }\r
 398                                 else {\r
 399                                     // sync list\r
 400                                     foreach (array('Allow', 'Reverse') as $list) {\r
 401                                         if (!isset($aData[$list])) {\r
 402                                             if ($this->addMemberToList($u_name.'@'.$u_domain, $network, $list))\r
 403                                                 $this->aContactList[$u_domain][$u_name][$network][$list] = false;\r
 404                                         }\r
 405                                     }\r
 406                                 }\r
 407                             }\r
 408                         }\r
 409                     }\r
 410                 }\r
 411             }\r
 412             $n = 0;\r
 413             $sList = '';\r
 414             $len = 0;\r
 415             if (is_array($this->aContactList)) {\r
 416                 foreach ($this->aContactList as $u_domain => $aUserList) {\r
 417                     $str = '<d n="'.$u_domain.'">';\r
 418                     $len += strlen($str);\r
 419                     if ($len > 7400) {\r
 420                         $this->aADL[$n] = '<ml l="1">'.$sList.'</ml>';\r
 421                         $n++;\r
 422                         $sList = '';\r
 423                         $len = strlen($str);\r
 424                     }\r
 425                     $sList .= $str;\r
 426                     foreach ($aUserList as $u_name => $aNetworks) {\r
 427                         foreach ($aNetworks as $network => $status) {\r
 428                             $str = '<c n="'.$u_name.'" l="3" t="'.$network.'" />';\r
 429                             $len += strlen($str);\r
 430                             // max: 7500, but <ml l="1"></d></ml> is 19,\r
 431                             // so we use 7475\r
 432                             if ($len > 7475) {\r
 433                                 $sList .= '</d>';\r
 434                                 $this->aADL[$n] = '<ml l="1">'.$sList.'</ml>';\r
 435                                 $n++;\r
 436                                 $sList = '<d n="'.$u_domain.'">'.$str;\r
 437                                 $len = strlen($sList);\r
 438                             }\r
 439                             else\r
 440                                 $sList .= $str;\r
 441                         }\r
 442                     }\r
 443                     $sList .= '</d>';\r
 444                 }\r
 445             }\r
 446             $this->aADL[$n] = '<ml l="1">'.$sList.'</ml>';\r
 447             // NS: >>> BLP {id} BL\r
 448             $this->ns_writeln("BLP $this->id BL");\r
 449             foreach ($this->aADL as $str) {\r
 450                 $len = strlen($str);\r
 451                 // NS: >>> ADL {id} {size}\r
 452                 $this->ns_writeln("ADL $this->id $len");\r
 453                 $this->ns_writedata($str);\r
 454             }\r
 455             // NS: >>> PRP {id} MFN name\r
 456             if ($this->alias == '') $this->alias = $user;\r
 457             $aliasname = rawurlencode($this->alias);\r
 458             $this->ns_writeln("PRP $this->id MFN $aliasname");\r
 459             //設定個人大頭貼\r
 460             //$MsnObj=$this->PhotoStckObj();\r
 461             // NS: >>> CHG {id} {status} {clientid} {msnobj}\r
 462             $this->ns_writeln("CHG $this->id NLN $this->clientid");\r
 463             if ($this->PhotoStickerFile !== false)\r
 464                 $this->ns_writeln("CHG $this->id NLN $this->clientid ".rawurlencode($this->MsnObj($this->PhotoStickerFile)));\r
 465             // NS: >>> UUX {id} length\r
 466             $str = '<Data><PSM>'.htmlspecialchars($this->psm).'</PSM><CurrentMedia></CurrentMedia><MachineGuid></MachineGuid></Data>';\r
 467             $len = strlen($str);\r
 468             $this->ns_writeln("UUX $this->id $len");\r
 469             $this->ns_writedata($str);\r
 470             if (!self::socketcheck($this->NSfp)) {\r
 471                 $this->debug_message('*** Connected, waiting for commands');\r
 472                 break;\r
 473             } else {\r
 474                 $this->NSRetryWait($this->retry_wait);\r
 475             }\r
 476         }\r
 477     }\r
 478 \r
 479     /**\r
 480     * Called if there is an error during signon\r
 481     *\r
 482     * @param string $message Error message to log\r
 483     * @return void\r
 484     */\r
 485     private function signonFailure($message) {\r
 486         if(!empty($message)) {\r
 487             $this->debug_message($message);\r
 488         }\r
 489         $this->callHandler('ConnectFailed');\r
 490         $this->NSRetryWait($this->retry_wait);\r
 491     }\r
 492 \r
 493     /**\r
 494     * Log out and close the NS connection\r
 495     *\r
 496     * @return void\r
 497     */\r
 498     private function nsLogout() {\r
 499         if (is_resource($this->NSfp) && !feof($this->NSfp)) {\r
 500             // logout now\r
 501             // NS: >>> OUT\r
 502             $this->ns_writeln("OUT");\r
 503             fclose($this->NSfp);\r
 504             $this->NSfp = false;\r
 505             $this->debug_message("*** Logged out");\r
 506         }\r
 507     }\r
 508 \r
 509     /**\r
 510      * NS and SB command handling methods\r
 511      */\r
 512 \r
 513     /**\r
 514      * Read and handle incoming command from NS\r
 515      *\r
 516      * @return void\r
 517      */\r
 518     private function nsReceive() {\r
 519         // Sign in again if not signed in or socket failed\r
 520         if (!is_resource($this->NSfp) || self::socketcheck($this->NSfp)) {\r
 521             $this->callHandler('Reconnect');\r
 522             $this->NSRetryWait($this->retry_wait);\r
 523             $this->signon();\r
 524             return;\r
 525         }\r
 526 \r
 527         $data = $this->ns_readln();\r
 528         if ($data === false) {\r
 529             // There was no data / an error when reading from the socket so reconnect\r
 530             $this->callHandler('Reconnect');\r
 531             $this->NSRetryWait($this->retry_wait);\r
 532             $this->signon();\r
 533             return;\r
 534         }\r
 535 \r
 536         switch (substr($data, 0, 3)) {\r
 537             case 'SBS':\r
 538                 // after 'USR {id} OK {user} {verify} 0' response, the server will send SBS and profile to us\r
 539                 // NS: <<< SBS 0 null\r
 540                 break;\r
 541 \r
 542             case 'RFS':\r
 543                 // FIXME:\r
 544                 // NS: <<< RFS ???\r
 545                 // refresh ADL, so we re-send it again\r
 546                 if (is_array($this->aADL)) {\r
 547                     foreach ($this->aADL as $str) {\r
 548                         $len = strlen($str);\r
 549                         // NS: >>> ADL {id} {size}\r
 550                         $this->ns_writeln("ADL $this->id $len");\r
 551                         $this->ns_writedata($str);\r
 552                     }\r
 553                 }\r
 554                 break;\r
 555 \r
 556             case 'LST':\r
 557                 // NS: <<< LST {email} {alias} 11 0\r
 558                 @list(/* LST */, $email) = @explode(' ', $data);\r
 559                 @list($u_name, $u_domain) = @explode('@', $email);\r
 560                 if (!isset($this->aContactList[$u_domain][$u_name][1])) {\r
 561                     $this->aContactList[$u_domain][$u_name][1]['Allow'] = 'Allow';\r
 562                     $this->debug_message("*** Added to contact list: $u_name@$u_domain");\r
 563                 }\r
 564                 break;\r
 565 \r
 566             case 'ADL':\r
 567                 // randomly, we get ADL command, someone add us to their contact list for MSNP15\r
 568                 // NS: <<< ADL 0 {size}\r
 569                 @list(/* ADL */, /* 0 */, $size) = @explode(' ', $data);\r
 570                 if (is_numeric($size) && $size > 0) {\r
 571                     $data = $this->ns_readdata($size);\r
 572                     preg_match('#<ml><d n="([^"]+)"><c n="([^"]+)"(.*) t="(\d*)"(.*) /></d></ml>#', $data, $matches);\r
 573                     if (is_array($matches) && count($matches) > 0) {\r
 574                         $u_domain = $matches[1];\r
 575                         $u_name = $matches[2];\r
 576                         $network = $matches[4];\r
 577                         if (isset($this->aContactList[$u_domain][$u_name][$network]))\r
 578                             $this->debug_message("*** Someone (network: $network) added us to their list (but already in our list): $u_name@$u_domain");\r
 579                         else {\r
 580                             $re_login = false;\r
 581                             $cnt = 0;\r
 582                             foreach (array('Allow', 'Reverse') as $list) {\r
 583                                 if (!$this->addMemberToList($u_name.'@'.$u_domain, $network, $list)) {\r
 584                                     if ($re_login) {\r
 585                                         $this->debug_message("*** Could not add $u_name@$u_domain (network: $network) to $list list");\r
 586                                         continue;\r
 587                                     }\r
 588                                     $aTickets = $this->get_passport_ticket();\r
 589                                     if (!$aTickets || !is_array($aTickets)) {\r
 590                                         // failed to login? ignore it\r
 591                                         $this->debug_message("*** Could not re-login, something wrong here");\r
 592                                         $this->debug_message("*** Could not add $u_name@$u_domain (network: $network) to $list list");\r
 593                                         continue;\r
 594                                     }\r
 595                                     $re_login = true;\r
 596                                     $this->ticket = $aTickets;\r
 597                                     $this->debug_message("**** Got new ticket, trying again");\r
 598                                     if (!$this->addMemberToList($u_name.'@'.$u_domain, $network, $list)) {\r
 599                                         $this->debug_message("*** Could not add $u_name@$u_domain (network: $network) to $list list");\r
 600                                         continue;\r
 601                                     }\r
 602                                 }\r
 603                                 $this->aContactList[$u_domain][$u_name][$network][$list] = false;\r
 604                                 $cnt++;\r
 605                             }\r
 606                             $this->debug_message("*** Someone (network: $network) added us to their list: $u_name@$u_domain");\r
 607                         }\r
 608                         $str = '<ml l="1"><d n="'.$u_domain.'"><c n="'.$u_name.'" l="3" t="'.$network.'" /></d></ml>';\r
 609                         $len = strlen($str);\r
 610 \r
 611                         $this->callHandler('AddedToList', array('screenname' => $u_name.'@'.$u_domain, 'network' => $network));\r
 612                     }\r
 613                     else\r
 614                         $this->debug_message("*** Someone added us to their list: $data");\r
 615                 }\r
 616                 break;\r
 617 \r
 618             case 'RML':\r
 619                 // randomly, we get RML command, someome remove us to their contact list for MSNP15\r
 620                 // NS: <<< RML 0 {size}\r
 621                 @list(/* RML */, /* 0 */, $size) = @explode(' ', $data);\r
 622                 if (is_numeric($size) && $size > 0) {\r
 623                     $data = $this->ns_readdata($size);\r
 624                     preg_match('#<ml><d n="([^"]+)"><c n="([^"]+)"(.*) t="(\d*)"(.*) /></d></ml>#', $data, $matches);\r
 625                     if (is_array($matches) && count($matches) > 0) {\r
 626                         $u_domain = $matches[1];\r
 627                         $u_name = $matches[2];\r
 628                         $network = $matches[4];\r
 629                         if (isset($this->aContactList[$u_domain][$u_name][$network])) {\r
 630                             $aData = $this->aContactList[$u_domain][$u_name][$network];\r
 631 \r
 632                             foreach ($aData as $list => $id)\r
 633                                 $this->delMemberFromList($id, $u_name.'@'.$u_domain, $network, $list);\r
 634 \r
 635                             unset($this->aContactList[$u_domain][$u_name][$network]);\r
 636                             $this->debug_message("*** Someone (network: $network) removed us from their list: $u_name@$u_domain");\r
 637                         }\r
 638                         else\r
 639                             $this->debug_message("*** Someone (network: $network) removed us from their list (but not in our list): $u_name@$u_domain");\r
 640 \r
 641                         $this->callHandler('RemovedFromList', array('screenname' => $u_name.'@'.$u_domain, 'network' => $network));\r
 642                     }\r
 643                     else\r
 644                         $this->debug_message("*** Someone removed us from their list: $data");\r
 645                 }\r
 646                 break;\r
 647 \r
 648             case 'MSG':\r
 649                 // randomly, we get MSG notification from server\r
 650                 // NS: <<< MSG Hotmail Hotmail {size}\r
 651                 @list(/* MSG */, /* Hotmail */, /* Hotmail */, $size) = @explode(' ', $data);\r
 652                 if (is_numeric($size) && $size > 0) {\r
 653                     $data = $this->ns_readdata($size);\r
 654                     $aLines = @explode("\n", $data);\r
 655                     $header = true;\r
 656                     $ignore = false;\r
 657                     $maildata = '';\r
 658                     foreach ($aLines as $line) {\r
 659                         $line = rtrim($line);\r
 660                         if ($header) {\r
 661                             if ($line === '') {\r
 662                                 $header = false;\r
 663                                 continue;\r
 664                             }\r
 665                             if (strncasecmp($line, 'Content-Type:', 13) == 0) {\r
 666                                 if (strpos($line, 'text/x-msmsgsinitialmdatanotification') === false && strpos($line, 'text/x-msmsgsoimnotification') === false) {\r
 667                                     // we just need text/x-msmsgsinitialmdatanotification\r
 668                                     // or text/x-msmsgsoimnotification\r
 669                                     $ignore = true;\r
 670                                     break;\r
 671                                 }\r
 672                             }\r
 673                             continue;\r
 674                         }\r
 675                         if (strncasecmp($line, 'Mail-Data:', 10) == 0) {\r
 676                             $maildata = trim(substr($line, 10));\r
 677                             break;\r
 678                         }\r
 679                     }\r
 680                     if ($ignore) {\r
 681                         $this->debug_message("*** Ignoring MSG for: $line");\r
 682                         break;\r
 683                     }\r
 684                     if ($maildata == '') {\r
 685                         $this->debug_message("*** Ignoring MSG not for OIM");\r
 686                         break;\r
 687                     }\r
 688                     $re_login = false;\r
 689                     if (strcasecmp($maildata, 'too-large') == 0) {\r
 690                         $this->debug_message("*** Large mail-data, need to get the data via SOAP");\r
 691                         $maildata = $this->getOIM_maildata();\r
 692                         if ($maildata === false) {\r
 693                             $this->debug_message("*** Could not get mail-data via SOAP");\r
 694 \r
 695                             // maybe we need to re-login again\r
 696                             $aTickets = $this->get_passport_ticket();\r
 697                             if (!$aTickets || !is_array($aTickets)) {\r
 698                                 // failed to login? ignore it\r
 699                                 $this->debug_message("*** Could not re-login, something wrong here, ignoring this OIM");\r
 700                                 break;\r
 701                             }\r
 702                             $re_login = true;\r
 703                             $this->ticket = $aTickets;\r
 704                             $this->debug_message("*** Got new ticket, trying again");\r
 705                             $maildata = $this->getOIM_maildata();\r
 706                             if ($maildata === false) {\r
 707                                 $this->debug_message("*** Could not get mail-data via SOAP, and re-login already attempted, ignoring this OIM");\r
 708                                 break;\r
 709                             }\r
 710                         }\r
 711                     }\r
 712                     // could be a lots of <M>...</M>, so we can't use preg_match here\r
 713                     $p = $maildata;\r
 714                     $aOIMs = array();\r
 715                     while (1) {\r
 716                         $start = strpos($p, '<M>');\r
 717                         $end = strpos($p, '</M>');\r
 718                         if ($start === false || $end === false || $start > $end) break;\r
 719                         $end += 4;\r
 720                         $sOIM = substr($p, $start, $end - $start);\r
 721                         $aOIMs[] = $sOIM;\r
 722                         $p = substr($p, $end);\r
 723                     }\r
 724                     if (count($aOIMs) == 0) {\r
 725                         $this->debug_message("*** Ignoring empty OIM");\r
 726                         break;\r
 727                     }\r
 728                     foreach ($aOIMs as $maildata) {\r
 729                         // T: 11 for MSN, 13 for Yahoo\r
 730                         // S: 6 for MSN, 7 for Yahoo\r
 731                         // RT: the datetime received by server\r
 732                         // RS: already read or not\r
 733                         // SZ: size of message\r
 734                         // E: sender\r
 735                         // I: msgid\r
 736                         // F: always 00000000-0000-0000-0000-000000000009\r
 737                         // N: sender alias\r
 738                         preg_match('#<T>(.*)</T>#', $maildata, $matches);\r
 739                         if (count($matches) == 0) {\r
 740                             $this->debug_message("*** Ignoring OIM maildata without <T>type</T>");\r
 741                             continue;\r
 742                         }\r
 743                         $oim_type = $matches[1];\r
 744                         if ($oim_type = 13)\r
 745                             $network = 32;\r
 746                         else\r
 747                             $network = 1;\r
 748                         preg_match('#<E>(.*)</E>#', $maildata, $matches);\r
 749                         if (count($matches) == 0) {\r
 750                             $this->debug_message("*** Ignoring OIM maildata without <E>sender</E>");\r
 751                             continue;\r
 752                         }\r
 753                         $oim_sender = $matches[1];\r
 754                         preg_match('#<I>(.*)</I>#', $maildata, $matches);\r
 755                         if (count($matches) == 0) {\r
 756                             $this->debug_message("*** Ignoring OIM maildata without <I>msgid</I>");\r
 757                             continue;\r
 758                         }\r
 759                         $oim_msgid = $matches[1];\r
 760                         preg_match('#<SZ>(.*)</SZ>#', $maildata, $matches);\r
 761                         $oim_size = (count($matches) == 0) ? 0 : $matches[1];\r
 762                         preg_match('#<RT>(.*)</RT>#', $maildata, $matches);\r
 763                         $oim_time = (count($matches) == 0) ? 0 : $matches[1];\r
 764                         $this->debug_message("*** OIM received from $oim_sender, Time: $oim_time, MSGID: $oim_msgid, size: $oim_size");\r
 765                         $sMsg = $this->getOIM_message($oim_msgid);\r
 766                         if ($sMsg === false) {\r
 767                             $this->debug_message("*** Could not get OIM, msgid = $oim_msgid");\r
 768                             if ($re_login) {\r
 769                                 $this->debug_message("*** Could not get OIM via SOAP, and re-login already attempted, ignoring this OIM");\r
 770                                 continue;\r
 771                             }\r
 772                             $aTickets = $this->get_passport_ticket();\r
 773                             if (!$aTickets || !is_array($aTickets)) {\r
 774                                 // failed to login? ignore it\r
 775                                 $this->debug_message("*** Could not re-login, something wrong here, ignoring this OIM");\r
 776                                 continue;\r
 777                             }\r
 778                             $re_login = true;\r
 779                             $this->ticket = $aTickets;\r
 780                             $this->debug_message("*** get new ticket, try it again");\r
 781                             $sMsg = $this->getOIM_message($oim_msgid);\r
 782                             if ($sMsg === false) {\r
 783                                 $this->debug_message("*** Could not get OIM via SOAP, and re-login already attempted, ignoring this OIM");\r
 784                                 continue;\r
 785                             }\r
 786                         }\r
 787                         $this->debug_message("*** MSG (Offline) from $oim_sender (network: $network): $sMsg");\r
 788                         $this->callHandler('IMin', array('sender' => $oim_sender, 'message' => $sMsg, 'network' => $network, 'offline' => true));\r
 789                     }\r
 790                 }\r
 791                 break;\r
 792 \r
 793             case 'UBM':\r
 794                 // randomly, we get UBM, this is the message from other network, like Yahoo!\r
 795                 // NS: <<< UBM {email} $network $type {size}\r
 796                 @list(/* UBM */, $from_email, $network, $type, $size) = @explode(' ', $data);\r
 797                 if (is_numeric($size) && $size > 0) {\r
 798                     $data = $this->ns_readdata($size);\r
 799                     $aLines = @explode("\n", $data);\r
 800                     $header = true;\r
 801                     $ignore = false;\r
 802                     $sMsg = '';\r
 803                     foreach ($aLines as $line) {\r
 804                         $line = rtrim($line);\r
 805                         if ($header) {\r
 806                             if ($line === '') {\r
 807                                 $header = false;\r
 808                                 continue;\r
 809                             }\r
 810                             if (strncasecmp($line, 'TypingUser:', 11) == 0) {\r
 811                                 $ignore = true;\r
 812                                 break;\r
 813                             }\r
 814                             continue;\r
 815                         }\r
 816                         $aSubLines = @explode("\r", $line);\r
 817                         foreach ($aSubLines as $str) {\r
 818                             if ($sMsg !== '')\r
 819                             $sMsg .= "\n";\r
 820                             $sMsg .= $str;\r
 821                         }\r
 822                     }\r
 823                     if ($ignore) {\r
 824                         $this->debug_message("*** Ignoring message from $from_email: $line");\r
 825                         break;\r
 826                     }\r
 827                     $this->debug_message("*** MSG from $from_email (network: $network): $sMsg");\r
 828                     $this->callHandler('IMin', array('sender' => $from_email, 'message' => $sMsg, 'network' => $network, 'offline' => false));\r
 829                 }\r
 830                 break;\r
 831 \r
 832             case 'UBX':\r
 833                 // randomly, we get UBX notification from server\r
 834                 // NS: <<< UBX email {network} {size}\r
 835                 @list(/* UBX */, /* email */, /* network */, $size) = @explode(' ', $data);\r
 836                 // we don't need the notification data, so just ignore it\r
 837                 if (is_numeric($size) && $size > 0)\r
 838                     $this->ns_readdata($size);\r
 839                 break;\r
 840 \r
 841             case 'CHL':\r
 842                 // randomly, we'll get challenge from server\r
 843                 // NS: <<< CHL 0 {code}\r
 844                 @list(/* CHL */, /* 0 */, $chl_code) = @explode(' ', $data);\r
 845                 $fingerprint = $this->getChallenge($chl_code);\r
 846                 // NS: >>> QRY {id} {product_id} 32\r
 847                 // NS: >>> fingerprint\r
 848                 $this->ns_writeln("QRY $this->id ".self::PROD_ID.' 32');\r
 849                 $this->ns_writedata($fingerprint);\r
 850                 $this->ns_writeln("CHG $this->id NLN $this->clientid");\r
 851                 if ($this->PhotoStickerFile !== false)\r
 852                     $this->ns_writeln("CHG $this->id NLN $this->clientid ".rawurlencode($this->MsnObj($this->PhotoStickerFile)));\r
 853                 break;\r
 854             case 'CHG':\r
 855                 // NS: <<< CHG {id} {status} {code}\r
 856                 // ignore it\r
 857                 // change our status to online first\r
 858                 break;\r
 859 \r
 860             case 'XFR':\r
 861                 // sometimes, NS will redirect to another NS\r
 862                 // MSNP9\r
 863                 // NS: <<< XFR {id} NS {server} 0 {server}\r
 864                 // MSNP15\r
 865                 // NS: <<< XFR {id} NS {server} U D\r
 866                 // for normal switchboard XFR\r
 867                 // NS: <<< XFR {id} SB {server} CKI {cki} U messenger.msn.com 0\r
 868                 @list(/* XFR */, /* {id} */, $server_type, $server, /* CKI */, $cki_code) = @explode(' ', $data);\r
 869                 @list($ip, $port) = @explode(':', $server);\r
 870                 if ($server_type != 'SB') {\r
 871                     // maybe exit?\r
 872                     // this connection will close after XFR\r
 873                     $this->nsLogout();\r
 874                     continue;\r
 875                 }\r
 876 \r
 877                 $this->debug_message("NS: <<< XFR SB");\r
 878                 $session = array_shift($this->waitingForXFR);\r
 879                 $this->connectToSBSession('Active', $ip, $port, $session['to'], array('cki' => $cki_code));\r
 880                 break;\r
 881             case 'QNG':\r
 882                 // NS: <<< QNG {time}\r
 883                 @list(/* QNG */, $ping_wait) = @explode(' ', $data);\r
 884                 $this->callHandler('Pong', $ping_wait);\r
 885                 break;\r
 886 \r
 887             case 'RNG':\r
 888                 if ($this->PhotoStickerFile !== false)\r
 889                     $this->ns_writeln("CHG $this->id NLN $this->clientid ".rawurlencode($this->MsnObj($this->PhotoStickerFile)));\r
 890                 else\r
 891                     $this->ns_writeln("CHG $this->id NLN $this->clientid");\r
 892                 // someone is trying to talk to us\r
 893                 // NS: <<< RNG {session_id} {server} {auth_type} {ticket} {email} {alias} U {client} 0\r
 894                 $this->debug_message("NS: <<< RNG $data");\r
 895                 @list(/* RNG */, $sid, $server, /* auth_type */, $ticket, $email, $name) = @explode(' ', $data);\r
 896                 @list($sb_ip, $sb_port) = @explode(':', $server);\r
 897                 $this->debug_message("*** RING from $email, $sb_ip:$sb_port");\r
 898                 $this->addContact($email, 1, $email, true);\r
 899                 $this->connectToSBSession('Passive', $sb_ip, $sb_port, $email, array('sid' => $sid, 'ticket' => $ticket));\r
 900                 break;\r
 901 \r
 902             case 'NLN':\r
 903                 // NS: <<< NLN {status} {email} {networkid} {nickname} {clientid} {dpobj}\r
 904                 @list(/* NLN */, $status, $email, $network, $nickname) = @explode(' ', $data);\r
 905                 $this->callHandler('StatusChange', array('screenname' => $email, 'status' => $status, 'network' => $network, 'nickname' => $nickname));\r
 906                 break;\r
 907 \r
 908             case 'OUT':\r
 909                 // force logout from NS\r
 910                 // NS: <<< OUT xxx\r
 911                 $this->debug_message("*** LOGOUT from NS");\r
 912                 return $this->nsLogout();\r
 913 \r
 914             default:\r
 915                 $code = substr($data,0,3);\r
 916                 if (is_numeric($code)) {\r
 917                     $this->error = "Error code: $code, please check the detail information from: http://msnpiki.msnfanatic.com/index.php/Reference:Error_List";\r
 918                     $this->debug_message("*** NS: $this->error");\r
 919 \r
 920                     return $this->nsLogout();\r
 921                 }\r
 922                 break;\r
 923         }\r
 924     }\r
 925 \r
 926     /**\r
 927      * Read and handle incoming command/message from\r
 928      * a switchboard session socket\r
 929      */\r
 930     private function sbReceive($socket) {\r
 931         $intsocket = (int) $socket;\r
 932         $session = &$this->switchBoardSessions[$intsocket];\r
 933 \r
 934         if (feof($socket)) {\r
 935             // Unset session lookup value\r
 936             unset($this->switchBoardSessionLookup[$session['to']]);\r
 937 \r
 938             // Unset session itself\r
 939             unset($this->switchBoardSessions[$intsocket]);\r
 940             return;\r
 941         }\r
 942 \r
 943         $id = &$session['id'];\r
 944 \r
 945         $data = $this->sb_readln($socket);\r
 946         $code = substr($data, 0, 3);\r
 947         switch($code) {\r
 948             case 'IRO':\r
 949                 // SB: <<< IRO {id} {rooster} {roostercount} {email} {alias} {clientid}\r
 950                 @list(/* IRO */, /* id */, $cur_num, $total, $email, $alias, $clientid) = @explode(' ', $data);\r
 951                 $this->debug_message("*** $email joined session");\r
 952                 if ($email == $session['to']) {\r
 953                     $session['joined'] = true;\r
 954                     $this->callHandler('SessionReady', array('to' => $email));\r
 955                 }\r
 956                 break;\r
 957             case 'BYE':\r
 958                 $this->debug_message("*** Quit for BYE");\r
 959                 $this->endSBSession($socket);\r
 960                 break;\r
 961             case 'USR':\r
 962                 // SB: <<< USR {id} OK {user} {alias}\r
 963                 // we don't need the data, just ignore it\r
 964                 // request user to join this switchboard\r
 965                 // SB: >>> CAL {id} {user}\r
 966                 $this->sb_writeln($socket, $id, "CAL $id ".$session['to']);\r
 967                 break;\r
 968             case 'CAL':\r
 969                 // SB: <<< CAL {id} RINGING {?}\r
 970                 // we don't need this, just ignore, and wait for other response\r
 971                 $session['id']++;\r
 972                 break;\r
 973             case 'JOI':\r
 974                 // SB: <<< JOI {user} {alias} {clientid?}\r
 975                 // someone join us\r
 976                 @list(/* JOI */, $email) = @explode(' ', $data);\r
 977                 if ($email == $session['to']) {\r
 978                     $session['joined'] = true;\r
 979                     $this->callHandler('SessionReady', array('to' => $email));\r
 980                 }\r
 981                 break;\r
 982             case 'MSG':\r
 983                 // SB: <<< MSG {email} {alias} {len}\r
 984                 @list(/* MSG */, $from_email, /* alias */, $len) = @explode(' ', $data);\r
 985                 $len = trim($len);\r
 986                 $data = $this->sb_readdata($socket, $len);\r
 987                 $aLines = @explode("\n", $data);\r
 988                 $header = true;\r
 989                 $ignore = false;\r
 990                 $is_p2p = false;\r
 991                 $sMsg = '';\r
 992                 foreach ($aLines as $line) {\r
 993                     $line = rtrim($line);\r
 994                     if ($header) {\r
 995                         if ($line === '') {\r
 996                             $header = false;\r
 997                             continue;\r
 998                         }\r
 999                         if (strncasecmp($line, 'TypingUser:', 11) == 0) {\r
1000                             // typing notification, just ignore\r
1001                             $ignore = true;\r
1002                             break;\r
1003                         }\r
1004                         if (strncasecmp($line, 'Chunk:', 6) == 0) {\r
1005                             // we don't handle any split message, just ignore\r
1006                             $ignore = true;\r
1007                             break;\r
1008                         }\r
1009                         if (strncasecmp($line, 'Content-Type: application/x-msnmsgrp2p', 38) == 0) {\r
1010                             // p2p message, ignore it, but we need to send acknowledgement for it...\r
1011                             $is_p2p = true;\r
1012                             $p = strstr($data, "\n\n");\r
1013                             $sMsg = '';\r
1014                             if ($p === false) {\r
1015                                 $p = strstr($data, "\r\n\r\n");\r
1016                                 if ($p !== false)\r
1017                                 $sMsg = substr($p, 4);\r
1018                             }\r
1019                             else\r
1020                             $sMsg = substr($p, 2);\r
1021                             break;\r
1022                         }\r
1023                         if (strncasecmp($line, 'Content-Type: application/x-', 28) == 0) {\r
1024                             // ignore all application/x-... message\r
1025                             // for example:\r
1026                             //      application/x-ms-ink        => ink message\r
1027                             $ignore = true;\r
1028                             break;\r
1029                         }\r
1030                         if (strncasecmp($line, 'Content-Type: text/x-', 21) == 0) {\r
1031                             // ignore all text/x-... message\r
1032                             // for example:\r
1033                             //      text/x-msnmsgr-datacast         => nudge, voice clip....\r
1034                             //      text/x-mms-animemoticon         => customized animemotion word\r
1035                             $ignore = true;\r
1036                             break;\r
1037                         }\r
1038                         continue;\r
1039                     }\r
1040                     if ($sMsg !== '')\r
1041                         $sMsg .= "\n";\r
1042                     $sMsg .= $line;\r
1043                 }\r
1044                 if ($ignore) {\r
1045                     $this->debug_message("*** Ignoring SB data from $from_email: $line");\r
1046                     break;\r
1047                 }\r
1048                 if ($is_p2p) {\r
1049                     // we will ignore any p2p message after sending acknowledgement\r
1050                     $ignore = true;\r
1051                     $len = strlen($sMsg);\r
1052                     $this->debug_message("*** p2p message from $from_email, size $len");\r
1053                     // header = 48 bytes\r
1054                     // content >= 0 bytes\r
1055                     // footer = 4 bytes\r
1056                     // so it need to >= 52 bytes\r
1057                     /*if ($len < 52) {\r
1058                         $this->debug_message("*** p2p: size error, less than 52!");\r
1059                         break;\r
1060                     }*/\r
1061                     $aDwords = @unpack("V12dword", $sMsg);\r
1062                     if (!is_array($aDwords)) {\r
1063                         $this->debug_message("*** p2p: header unpack error!");\r
1064                         break;\r
1065                     }\r
1066                     $this->debug_message("*** p2p: dump received message:\n".$this->dump_binary($sMsg));\r
1067                     $hdr_SessionID = $aDwords['dword1'];\r
1068                     $hdr_Identifier = $aDwords['dword2'];\r
1069                     $hdr_DataOffsetLow = $aDwords['dword3'];\r
1070                     $hdr_DataOffsetHigh = $aDwords['dword4'];\r
1071                     $hdr_TotalDataSizeLow = $aDwords['dword5'];\r
1072                     $hdr_TotalDataSizeHigh = $aDwords['dword6'];\r
1073                     $hdr_MessageLength = $aDwords['dword7'];\r
1074                     $hdr_Flag = $aDwords['dword8'];\r
1075                     $hdr_AckID = $aDwords['dword9'];\r
1076                     $hdr_AckUID = $aDwords['dword10'];\r
1077                     $hdr_AckSizeLow = $aDwords['dword11'];\r
1078                     $hdr_AckSizeHigh = $aDwords['dword12'];\r
1079                     $this->debug_message("*** p2p: header SessionID = $hdr_SessionID");\r
1080                     $this->debug_message("*** p2p: header Inentifier = $hdr_Identifier");\r
1081                     $this->debug_message("*** p2p: header Data Offset Low = $hdr_DataOffsetLow");\r
1082                     $this->debug_message("*** p2p: header Data Offset High = $hdr_DataOffsetHigh");\r
1083                     $this->debug_message("*** p2p: header Total Data Size Low = $hdr_TotalDataSizeLow");\r
1084                     $this->debug_message("*** p2p: header Total Data Size High = $hdr_TotalDataSizeHigh");\r
1085                     $this->debug_message("*** p2p: header MessageLength = $hdr_MessageLength");\r
1086                     $this->debug_message("*** p2p: header Flag = $hdr_Flag");\r
1087                     $this->debug_message("*** p2p: header AckID = $hdr_AckID");\r
1088                     $this->debug_message("*** p2p: header AckUID = $hdr_AckUID");\r
1089                     $this->debug_message("*** p2p: header AckSize Low = $hdr_AckSizeLow");\r
1090                     $this->debug_message("*** p2p: header AckSize High = $hdr_AckSizeHigh");\r
1091                     if ($hdr_Flag == 2) {\r
1092                         //This is an ACK from SB ignore....\r
1093                         $this->debug_message("*** p2p: //This is an ACK from SB ignore....:\n");\r
1094                         break;\r
1095                     }\r
1096                     $MsgBody = $this->linetoArray(substr($sMsg, 48, -4));\r
1097                     $this->debug_message("*** p2p: body".print_r($MsgBody, true));\r
1098                     if (($MsgBody['EUF-GUID']=='{A4268EEC-FEC5-49E5-95C3-F126696BDBF6}')&&($PictureFilePath=$this->GetPictureFilePath($MsgBody['Context']))) {\r
1099                         while (true) {\r
1100                             if ($this->sb_readln($socket) === false) break;\r
1101                         }\r
1102                         $this->debug_message("*** p2p: Inv hdr:\n".$this->dump_binary(substr($sMsg, 0, 48)));\r
1103                         preg_match('/{([0-9A-F\-]*)}/i', $MsgBody['Via'], $Matches);\r
1104                         $BranchGUID = $Matches[1];\r
1105                         //it's an invite to send a display picture.\r
1106                         $new_id = ~$hdr_Identifier;\r
1107                         $hdr = pack(\r
1108                             "LLLLLLLLLLLL", $hdr_SessionID,\r
1109                             $new_id,\r
1110                             0, 0,\r
1111                             $hdr_TotalDataSizeLow, $hdr_TotalDataSizeHigh,\r
1112                             0,\r
1113                             2,\r
1114                             $hdr_Identifier,\r
1115                             $hdr_AckID,\r
1116                             $hdr_TotalDataSizeLow, $hdr_TotalDataSizeHigh\r
1117                         );\r
1118                         $footer = pack("L", 0);\r
1119                         $message = "MIME-Version: 1.0\r\nContent-Type: application/x-msnmsgrp2p\r\nP2P-Dest: $from_email\r\n\r\n$hdr$footer";\r
1120                         $len = strlen($message);\r
1121                         $this->sb_writeln($socket, $id, "MSG $id D $len");\r
1122                         $this->sb_writedata($socket, $message);\r
1123                         $this->debug_message("*** p2p: send display picture acknowledgement for $hdr_SessionID");\r
1124                         $this->debug_message("*** p2p: Invite ACK message:\n".$this->dump_binary($message));\r
1125                         $this->sb_readln($socket); // Read ACK;\r
1126                         $this->debug_message("*** p2p: Invite ACK Hdr:\n".$this->dump_binary($hdr));\r
1127                         $new_id -= 3;\r
1128                         //Send 200 OK message\r
1129                         $MessageContent="SessionID: ".$MsgBody['SessionID']."\r\n\r\n".pack("C", 0);\r
1130                         $MessagePayload=\r
1131                             "MSNSLP/1.0 200 OK\r\n".\r
1132                             "To: <msnmsgr:".$from_email.">\r\n".\r
1133                             "From: <msnmsgr:".$this->user.">\r\n".\r
1134                             "Via: ".$MsgBody['Via']."\r\n".\r
1135                             "CSeq: ".($MsgBody['CSeq']+1)."\r\n".\r
1136                             "Call-ID: ".$MsgBody['Call-ID']."\r\n".\r
1137                             "Max-Forwards: 0\r\n".\r
1138                             "Content-Type: application/x-msnmsgr-sessionreqbody\r\n".\r
1139                             "Content-Length: ".strlen($MessageContent)."\r\n\r\n".\r
1140                         $MessageContent;\r
1141                         $hdr_TotalDataSizeLow=strlen($MessagePayload);\r
1142                         $hdr_TotalDataSizeHigh=0;\r
1143                         $hdr = pack(\r
1144                             "LLLLLLLLLLLL", $hdr_SessionID,\r
1145                             $new_id,\r
1146                             0, 0,\r
1147                             $hdr_TotalDataSizeLow, $hdr_TotalDataSizeHigh,\r
1148                             strlen($MessagePayload),\r
1149                             0,\r
1150                             rand(),\r
1151                             0,\r
1152                             0, 0\r
1153                         );\r
1154 \r
1155                         $message =\r
1156                             "MIME-Version: 1.0\r\n".\r
1157                             "Content-Type: application/x-msnmsgrp2p\r\n".\r
1158                             "P2P-Dest: $from_email\r\n\r\n$hdr$MessagePayload$footer";\r
1159                         $this->sb_writeln($socket, $id, "MSG $id D ".strlen($message));\r
1160                         $this->sb_writedata($socket, $message);\r
1161                         $this->debug_message("*** p2p: dump 200 ok message:\n".$this->dump_binary($message));\r
1162                         $this->sb_readln($socket); // Read ACK;\r
1163 \r
1164                         $this->debug_message("*** p2p: 200 ok:\n".$this->dump_binary($hdr));\r
1165                         // send data preparation message\r
1166                         // send 4 null bytes as data\r
1167                         $hdr_TotalDataSizeLow = 4;\r
1168                         $hdr_TotalDataSizeHigh = 0 ;\r
1169                         $new_id++;\r
1170                         $hdr = pack(\r
1171                             "LLLLLLLLLLLL",\r
1172                             $MsgBody['SessionID'],\r
1173                             $new_id,\r
1174                             0, 0,\r
1175                             $hdr_TotalDataSizeLow, $hdr_TotalDataSizeHigh,\r
1176                             $hdr_TotalDataSizeLow,\r
1177                             0,\r
1178                             rand(),\r
1179                             0,\r
1180                             0, 0\r
1181                         );\r
1182                         $message =\r
1183                             "MIME-Version: 1.0\r\n".\r
1184                             "Content-Type: application/x-msnmsgrp2p\r\n".\r
1185                             "P2P-Dest: $from_email\r\n\r\n$hdr".pack('L', 0)."$footer";\r
1186                         $this->sb_writeln($socket, $id, "MSG $id D ".strlen($message));\r
1187                         $this->sb_writedata($socket, $message);\r
1188                         $this->debug_message("*** p2p: dump send Data preparation message:\n".$this->dump_binary($message));\r
1189                         $this->debug_message("*** p2p: Data Prepare Hdr:\n".$this->dump_binary($hdr));\r
1190                         $this->sb_readln($socket); // Read ACK;\r
1191 \r
1192                         // send Data Content..\r
1193                         $footer=pack('N',1);\r
1194                         $new_id++;\r
1195                         $FileSize=filesize($PictureFilePath);\r
1196                         if ($hTitle=fopen($PictureFilePath,'rb')) {\r
1197                             $Offset = 0;\r
1198                             //$new_id++;\r
1199                             while (!feof($hTitle)) {\r
1200                                 $FileContent = fread($hTitle, 1024);\r
1201                                 $FileContentSize = strlen($FileContent);\r
1202                                 $hdr = pack(\r
1203                                     "LLLLLLLLLLLL",\r
1204                                     $MsgBody['SessionID'],\r
1205                                     $new_id,\r
1206                                     $Offset, 0,\r
1207                                     $FileSize, 0,\r
1208                                     $FileContentSize,\r
1209                                     0x20,\r
1210                                     rand(),\r
1211                                     0,\r
1212                                     0, 0\r
1213                                 );\r
1214                                 $message =\r
1215                                     "MIME-Version: 1.0\r\n".\r
1216                                     "Content-Type: application/x-msnmsgrp2p\r\n".\r
1217                                     "P2P-Dest: $from_email\r\n\r\n$hdr$FileContent$footer";\r
1218                                 $this->sb_writeln($socket, $id, "MSG $id D ".strlen($message));\r
1219                                 $this->sb_writedata($socket, $message);\r
1220                                 $this->debug_message("*** p2p: dump send Data Content message  $Offset / $FileSize :\n".$this->dump_binary($message));\r
1221                                 $this->debug_message("*** p2p: Data Content Hdr:\n".$this->dump_binary($hdr));\r
1222                                 //$this->SB_readln($socket);//Read ACK;\r
1223                                 $Offset += $FileContentSize;\r
1224                             }\r
1225                         }\r
1226                         //Send Bye\r
1227                         /*\r
1228                         $MessageContent="\r\n".pack("C", 0);\r
1229                         $MessagePayload=\r
1230                             "BYE MSNMSGR:MSNSLP/1.0\r\n".\r
1231                             "To: <msnmsgr:$from_email>\r\n".\r
1232                             "From: <msnmsgr:".$this->user.">\r\n".\r
1233                             "Via: MSNSLP/1.0/TLP ;branch={".$BranchGUID."}\r\n".\r
1234                             "CSeq: 0\r\n".\r
1235                             "Call-ID: ".$MsgBody['Call-ID']."\r\n".\r
1236                             "Max-Forwards: 0\r\n".\r
1237                             "Content-Type: application/x-msnmsgr-sessionclosebody\r\n".\r
1238                             "Content-Length: ".strlen($MessageContent)."\r\n\r\n".$MessageContent;\r
1239                         $footer=pack('N',0);\r
1240                         $hdr_TotalDataSizeLow=strlen($MessagePayload);\r
1241                         $hdr_TotalDataSizeHigh=0;\r
1242                         $new_id++;\r
1243                         $hdr = pack("LLLLLLLLLLLL",\r
1244                         0,\r
1245                         $new_id,\r
1246                         0, 0,\r
1247                         $hdr_TotalDataSizeLow, $hdr_TotalDataSizeHigh,\r
1248                         0,\r
1249                         0,\r
1250                         rand(),\r
1251                         0,\r
1252                         0,0);\r
1253                         $message =\r
1254                                     "MIME-Version: 1.0\r\n".\r
1255                                     "Content-Type: application/x-msnmsgrp2p\r\n".\r
1256                                     "P2P-Dest: $from_email\r\n\r\n$hdr$MessagePayload$footer";\r
1257                         $this->sb_writeln($socket, $id, "MSG $id D ".strlen($message));\r
1258                         $id++;\r
1259                         $this->sb_writedata($socket, $message);\r
1260                         $this->debug_message("*** p2p: dump send BYE message :\n".$this->dump_binary($message));\r
1261                         */\r
1262                         break;\r
1263                     }\r
1264                     //TODO:\r
1265                     //if ($hdr_Flag == 2) {\r
1266                     // just send ACK...\r
1267                     //    $this->sb_writeln($socket, $id, "ACK $id");\r
1268                     //    break;\r
1269                     //}\r
1270                     if ($hdr_SessionID == 4) {\r
1271                         // ignore?\r
1272                         $this->debug_message("*** p2p: ignore flag 4");\r
1273                         break;\r
1274                     }\r
1275                     $finished = false;\r
1276                     if ($hdr_TotalDataSizeHigh == 0) {\r
1277                         // only 32 bites size\r
1278                         if (($hdr_MessageLength + $hdr_DataOffsetLow) == $hdr_TotalDataSizeLow)\r
1279                         $finished = true;\r
1280                     }\r
1281                     else {\r
1282                         // we won't accept any file transfer\r
1283                         // so I think we won't get any message size need to use 64 bits\r
1284                         // 64 bits size here, can't count directly...\r
1285                         $totalsize = base_convert(sprintf("%X%08X", $hdr_TotalDataSizeHigh, $hdr_TotalDataSizeLow), 16, 10);\r
1286                         $dataoffset = base_convert(sprintf("%X%08X", $hdr_DataOffsetHigh, $hdr_DataOffsetLow), 16, 10);\r
1287                         $messagelength = base_convert(sprintf("%X", $hdr_MessageLength), 16, 10);\r
1288                         $now_size = bcadd($dataoffset, $messagelength);\r
1289                         if (bccomp($now_size, $totalsize) >= 0)\r
1290                         $finished = true;\r
1291                     }\r
1292                     if (!$finished) {\r
1293                         // ignore not finished split packet\r
1294                         $this->debug_message("*** p2p: ignore split packet, not finished");\r
1295                         break;\r
1296                     }\r
1297                     //$new_id = ~$hdr_Identifier;\r
1298                     /*\r
1299                      $new_id++;\r
1300                      $hdr = pack("LLLLLLLLLLLL", $hdr_SessionID,\r
1301                      $new_id,\r
1302                      0, 0,\r
1303                      $hdr_TotalDataSizeLow, $hdr_TotalDataSizeHigh,\r
1304                      0,\r
1305                      2,\r
1306                      $hdr_Identifier,\r
1307                      $hdr_AckID,\r
1308                      $hdr_TotalDataSizeLow, $hdr_TotalDataSizeHigh);\r
1309                      $footer = pack("L", 0);\r
1310                      $message = "MIME-Version: 1.0\r\nContent-Type: application/x-msnmsgrp2p\r\nP2P-Dest: $from_email\r\n\r\n$hdr$footer";\r
1311                      $len = strlen($message);\r
1312                      $this->sb_writeln($socket, $id, "MSG $id D $len");\r
1313                      $id++;\r
1314                      $this->sb_writedata($socket, $message);\r
1315                      $this->debug_message("*** p2p: send acknowledgement for $hdr_SessionID");\r
1316                      $this->debug_message("*** p2p: dump sent message:\n".$this->dump_binary($hdr.$footer));\r
1317                      */\r
1318                     break;\r
1319                 }\r
1320                 $this->debug_message("*** MSG from $from_email: $sMsg");\r
1321                 $this->callHandler('IMin', array('sender' => $from_email, 'message' => $sMsg, 'network' => 1, 'offline' => false));\r
1322                 break;\r
1323             case '217':\r
1324                 $this->debug_message('*** User '.$session['to'].' is offline. Trying OIM.');\r
1325                 $session['offline'] = true;\r
1326                 break;\r
1327             default:\r
1328                 if (is_numeric($code)) {\r
1329                     $this->error = "Error code: $code, please check the detail information from: http://msnpiki.msnfanatic.com/index.php/Reference:Error_List";\r
1330                     $this->debug_message("*** SB: $this->error");\r
1331                 }\r
1332                 break;\r
1333         }\r
1334     }\r
1335 \r
1336     /**\r
1337      * Checks for new data and calls appropriate methods\r
1338      *\r
1339      * This method is usually called in an infinite loop to keep checking for new data\r
1340      *\r
1341      * @return void\r
1342      */\r
1343     public function receive() {\r
1344         // First, get an array of sockets that have data that is ready to be read\r
1345         $ready = array();\r
1346         $ready = $this->getSockets();\r
1347         $numrdy = stream_select($ready, $w = NULL, $x = NULL, NULL);\r
1348 \r
1349         // Now that we've waited for something, go through the $ready\r
1350         // array and read appropriately\r
1351 \r
1352         foreach ($ready as $socket) {\r
1353             if ($socket == $this->NSfp) {\r
1354                 $this->nsReceive();\r
1355             } else {\r
1356                 $this->sbReceive($socket);\r
1357             }\r
1358         }\r
1359     }\r
1360 \r
1361     /**\r
1362      * Switchboard related methods\r
1363      */\r
1364 \r
1365     /**\r
1366      * Send a request for a switchboard session\r
1367      *\r
1368      * @param string $to Target email for switchboard session\r
1369      */\r
1370     private function reqSBSession($to) {\r
1371         $this->debug_message("*** Request SB for $to");\r
1372         $this->ns_writeln("XFR $this->id SB");\r
1373 \r
1374         // Add to the queue of those waiting for a switchboard session reponse\r
1375         $this->switchBoardSessions[$to] = array(\r
1376             'to' => $to,\r
1377             'socket' => NULL,\r
1378             'id' => 1,\r
1379             'joined' => false,\r
1380             'offline' => false,\r
1381             'XFRReqTime' => time()\r
1382         );\r
1383         $this->waitingForXFR[$to] = &$this->switchBoardSessions[$to];\r
1384     }\r
1385 \r
1386     /**\r
1387      * Following an XFR or RNG, connect to the switchboard session\r
1388      *\r
1389      * @param string $mode Mode, either 'Active' (in the case of XFR) or 'Passive' (in the case of RNG)\r
1390      * @param string $ip IP of Switchboard\r
1391      * @param integer $port Port of Switchboard\r
1392      * @param string $to User on other end of Switchboard\r
1393      * @param array $param Array of parameters - 'cki', 'ticket', 'sid'\r
1394      * @return boolean true if successful\r
1395      */\r
1396     private function connectToSBSession($mode, $ip, $port, $to, $param) {\r
1397         $this->debug_message("*** SB: Trying to connect to switchboard server $ip:$port");\r
1398 \r
1399         $socket = @fsockopen($ip, $port, $errno, $errstr, $this->timeout);\r
1400         if (!$socket) {\r
1401             $this->debug_message("*** SB: Can't connect to $ip:$port, error => $errno, $errstr");\r
1402             return false;\r
1403         }\r
1404 \r
1405         // Store the socket in the lookup array\r
1406         $this->switchBoardSessionLookup[$to] = $socket;\r
1407 \r
1408         // Store the socket in the sessions array\r
1409         $this->switchBoardSessions[$to] = array(\r
1410             'to' => $to,\r
1411             'socket' => $socket,\r
1412             'id' => 1,\r
1413             'joined' => false,\r
1414             'offline' => false,\r
1415             'XFRReqTime' => time()\r
1416         );\r
1417 \r
1418         // Change the index of the session to the socket\r
1419         $intsocket = (int) $socket;\r
1420         $this->switchBoardSessions[$intsocket] = $this->switchBoardSessions[$to];\r
1421         unset($this->switchBoardSessions[$to]);\r
1422 \r
1423         $id = &$this->switchBoardSessions[$intsocket]['id'];\r
1424 \r
1425         if ($mode == 'Active') {\r
1426             $cki_code = $param['cki'];\r
1427 \r
1428             // SB: >>> USR {id} {user} {cki}\r
1429             $this->sb_writeln($socket, $id, "USR $id $this->user $cki_code");\r
1430         } else {\r
1431             // Passive\r
1432             $ticket = $param['ticket'];\r
1433             $sid = $param['sid'];\r
1434 \r
1435             // SB: >>> ANS {id} {user} {ticket} {session_id}\r
1436             $this->sb_writeln($socket, $id, "ANS $id $this->user $ticket $sid");\r
1437         }\r
1438     }\r
1439 \r
1440     /**\r
1441     * Called when we want to end a switchboard session\r
1442     * or a switchboard session ends\r
1443     *\r
1444     * @param resource $socket Socket\r
1445     * @param boolean $killsession Whether to delete the session\r
1446     * @return void\r
1447     */\r
1448     private function endSBSession($socket) {\r
1449         if (!self::socketcheck($socket)) {\r
1450             $this->sb_writeln($socket, $fake = 0, 'OUT');\r
1451         }\r
1452         @fclose($socket);\r
1453 \r
1454         // Unset session lookup value\r
1455         $intsocket = (int) $socket;\r
1456         unset($this->switchBoardSessionLookup[$this->switchBoardSessions[$intsocket]['to']]);\r
1457 \r
1458         // Unset session itself\r
1459         unset($this->switchBoardSessions[$intsocket]);\r
1460     }\r
1461 \r
1462     /**\r
1463      * Send a message via an existing SB session\r
1464      *\r
1465      * @param string $to Recipient for message\r
1466      * @param string $message Message\r
1467      * @return boolean true on success\r
1468      */\r
1469     private function sendMessageViaSB($to, $message) {\r
1470         $socket = $this->switchBoardSessionLookup[$to];\r
1471         if (self::socketcheck($socket)) {\r
1472             return false;\r
1473         }\r
1474 \r
1475         $id = &$this->switchBoardSessions[(int) $socket]['id'];\r
1476 \r
1477         $aMessage = $this->getMessage($message);\r
1478         // CheckEmotion...\r
1479         $MsnObjDefine = $this->GetMsnObjDefine($aMessage);\r
1480         if ($MsnObjDefine !== '') {\r
1481             $SendString = "MIME-Version: 1.0\r\nContent-Type: text/x-mms-emoticon\r\n\r\n$MsnObjDefine";\r
1482             $len = strlen($SendString);\r
1483 \r
1484             if ($this->sb_writeln($socket, $id, "MSG $id N $len") === false ||\r
1485                 $this->sb_writedata($socket, $SendString) === false) {\r
1486                     $this->endSBSession($socket);\r
1487                     return false;\r
1488                 }\r
1489         }\r
1490         $len = strlen($aMessage);\r
1491 \r
1492         if ($this->sb_writeln($socket, $id, "MSG $id N $len") === false ||\r
1493             $this->sb_writedata($socket, $aMessage) === false) {\r
1494                 $this->endSBSession($socket);\r
1495                 return false;\r
1496             }\r
1497 \r
1498         // Don't close the SB session, we might as well leave it open\r
1499         return true;\r
1500     }\r
1501 \r
1502     /**\r
1503      * Send a message to a user on another network\r
1504      *\r
1505      * @param string $to Intended recipient\r
1506      * @param string $message Message\r
1507      * @param integer $network Network\r
1508      * @return void\r
1509      */\r
1510     private function sendOtherNetworkMessage($to, $message, $network) {\r
1511         $message = $this->getMessage($message, $network);\r
1512         $len = strlen($message);\r
1513         if ($this->ns_writeln("UUM $this->id $to $network 1 $len") === false ||\r
1514             $this->ns_writedata($Message) === false) {\r
1515             return false;\r
1516         }\r
1517         $this->debug_message("*** Sent to $to (network: $network):\n$Message");\r
1518         return true;\r
1519     }\r
1520 \r
1521     /**\r
1522      * Send a message\r
1523      *\r
1524      * @param string $to To address in form user@host.com(@network)\r
1525      *                   where network is 1 for MSN, 32 for Yahoo\r
1526      *                   and 'Offline' for offline messages\r
1527      * @param string $message Message\r
1528      * @param boolean &$waitForSession Boolean passed by reference,\r
1529      *                                 if set to true on return, message\r
1530      *                                 did not fail to send but is\r
1531      *                                 waiting for a valid session\r
1532      *\r
1533      * @return boolean true on success\r
1534      */\r
1535     public function sendMessage($to, $message, &$waitForSession) {\r
1536         if ($message != '') {\r
1537             $toParts = explode('@', $to);\r
1538             if(count($toParts) < 3) {\r
1539                 list($name, $host) = $toParts;\r
1540                 $network = 1;\r
1541             } else {\r
1542                 list($name, $host, $network) = $toParts;\r
1543             }\r
1544 \r
1545             $recipient = $name.'@'.$host;\r
1546 \r
1547             if ($network === 1) {\r
1548                 if (!isset($this->switchBoardSessionLookup[$recipient])) {\r
1549                     if (!isset($this->switchBoardSessions[$recipient]) || time() - $this->switchBoardSessions[$recipient]['XFRReqTime'] > $this->XFRReqTimeout) {\r
1550                         $this->debug_message("*** No existing SB session or request has timed out");\r
1551                         $this->reqSBSession($recipient);\r
1552                     }\r
1553 \r
1554                     $waitForSession = true;\r
1555                     return false;\r
1556                 } else {\r
1557                     $socket = $this->switchBoardSessionLookup[$recipient];\r
1558                     $intsocket = (int) $socket;\r
1559                     if ($this->switchBoardSessions[$intsocket]['offline']) {\r
1560                         $this->debug_message("*** Contact ($recipient) offline, sending OIM");\r
1561                         $this->endSBSession($socket);\r
1562                         $waitForSession = false;\r
1563                         return $this->sendMessage($recipient.'@Offline', $message);\r
1564                     } else {\r
1565                         if ($this->switchBoardSessions[$intsocket]['joined'] !== true) {\r
1566                             $this->debug_message("*** Recipient has not joined session, returning false");\r
1567                             $waitForSession = true;\r
1568                             return false;\r
1569                         }\r
1570 \r
1571                         $this->debug_message("*** Attempting to send message to $recipient using existing SB session");\r
1572 \r
1573                         if ($this->sendMessageViaSB($recipient, $message)) {\r
1574                             $this->debug_message('*** Message sent successfully');\r
1575                             return true;\r
1576                         }\r
1577 \r
1578                         $waitForSession = false;\r
1579                         return false;\r
1580                     }\r
1581                 }\r
1582             } elseif ($network == 'Offline') {\r
1583                 //Send OIM\r
1584                 //FIXME: 修正Send OIM\r
1585                 $lockkey = '';\r
1586                 $re_login = false;\r
1587                 for ($i = 0; $i < $this->oim_try; $i++) {\r
1588                     if (($oim_result = $this->sendOIM($recipient, $message, $lockkey)) === true) break;\r
1589                     if (is_array($oim_result) && $oim_result['challenge'] !== false) {\r
1590                         // need challenge lockkey\r
1591                         $this->debug_message("*** Need challenge code for ".$oim_result['challenge']);\r
1592                         $lockkey = $this->getChallenge($oim_result['challenge']);\r
1593                         continue;\r
1594                     }\r
1595                     if ($oim_result === false || $oim_result['auth_policy'] !== false) {\r
1596                         if ($re_login) {\r
1597                             $this->debug_message("*** Can't send OIM, but we already re-logged-in again, so returning false");\r
1598                             return false;\r
1599                         }\r
1600                         $this->debug_message("*** Can't send OIM, maybe ticket expired, trying to login again");\r
1601 \r
1602                         // Maybe we need to re-login again\r
1603                         if (!$this->get_passport_ticket()) {\r
1604                             $this->debug_message("*** Can't re-login, something went wrong here, returning false");\r
1605                             return false;\r
1606                         }\r
1607                         $this->debug_message("*** Getting new ticket and trying again");\r
1608                         continue;\r
1609                     }\r
1610                 }\r
1611                 return true;\r
1612             } else {\r
1613                 // Other network\r
1614                 return $this->sendOtherNetworkMessage($recipient, $message, $network);\r
1615             }\r
1616         }\r
1617         return true;\r
1618     }\r
1619 \r
1620     /**\r
1621      * OIM methods\r
1622      */\r
1623 \r
1624     /**\r
1625     * Get OIM mail data\r
1626     *\r
1627     * @return string mail data or false on failure\r
1628     */\r
1629     function getOIM_maildata() {\r
1630         preg_match('#t=(.*)&p=(.*)#', $this->ticket['web_ticket'], $matches);\r
1631         if (count($matches) == 0) {\r
1632             $this->debug_message('*** No web ticket?');\r
1633             return false;\r
1634         }\r
1635         $t = htmlspecialchars($matches[1]);\r
1636         $p = htmlspecialchars($matches[2]);\r
1637         $XML = '<?xml version="1.0" encoding="utf-8"?>\r
1638 <soap:Envelope xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"\r
1639                xmlns:xsd="http://www.w3.org/2001/XMLSchema"\r
1640                xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/">\r
1641 <soap:Header>\r
1642   <PassportCookie xmlns="http://www.hotmail.msn.com/ws/2004/09/oim/rsi">\r
1643     <t>'.$t.'</t>\r
1644     <p>'.$p.'</p>\r
1645   </PassportCookie>\r
1646 </soap:Header>\r
1647 <soap:Body>\r
1648   <GetMetadata xmlns="http://www.hotmail.msn.com/ws/2004/09/oim/rsi" />\r
1649 </soap:Body>\r
1650 </soap:Envelope>';\r
1651 \r
1652         $header_array = array(\r
1653             'SOAPAction: '.self::OIM_MAILDATA_SOAP,\r
1654             'Content-Type: text/xml; charset=utf-8',\r
1655             'User-Agent: Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1; Messenger '.self::BUILDVER.')'\r
1656         );\r
1657 \r
1658         $this->debug_message('*** URL: '.self::OIM_MAILDATA_URL);\r
1659         $this->debug_message("*** Sending SOAP:\n$XML");\r
1660         $curl = curl_init();\r
1661         curl_setopt($curl, CURLOPT_URL, self::OIM_MAILDATA_URL);\r
1662         curl_setopt($curl, CURLOPT_HTTPHEADER, $header_array);\r
1663         curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);\r
1664         curl_setopt($curl, CURLOPT_FOLLOWLOCATION, 1);\r
1665         curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, 0);\r
1666         if ($this->debug) curl_setopt($curl, CURLOPT_HEADER, 1);\r
1667         curl_setopt($curl, CURLOPT_POST, 1);\r
1668         curl_setopt($curl, CURLOPT_POSTFIELDS, $XML);\r
1669         $data = curl_exec($curl);\r
1670         $http_code = curl_getinfo($curl, CURLINFO_HTTP_CODE);\r
1671         curl_close($curl);\r
1672         $this->debug_message("*** Get Result:\n$data");\r
1673 \r
1674         if ($http_code != 200) {\r
1675             $this->debug_message("*** Could not get OIM maildata! http code: $http_code");\r
1676             return false;\r
1677         }\r
1678 \r
1679         // <GetMetadataResponse xmlns="http://www.hotmail.msn.com/ws/2004/09/oim/rsi">See #XML_Data</GetMetadataResponse>\r
1680         preg_match('#<GetMetadataResponse([^>]*)>(.*)</GetMetadataResponse>#', $data, $matches);\r
1681         if (count($matches) == 0) {\r
1682             $this->debug_message('*** Could not get OIM maildata');\r
1683             return false;\r
1684         }\r
1685         return $matches[2];\r
1686     }\r
1687 \r
1688     /**\r
1689     * Fetch OIM message with given id\r
1690     *\r
1691     * @param string $msgid\r
1692     * @return string Message or false on failure\r
1693     */\r
1694     function getOIM_message($msgid) {\r
1695         preg_match('#t=(.*)&p=(.*)#', $this->ticket['web_ticket'], $matches);\r
1696         if (count($matches) == 0) {\r
1697             $this->debug_message('*** No web ticket?');\r
1698             return false;\r
1699         }\r
1700         $t = htmlspecialchars($matches[1]);\r
1701         $p = htmlspecialchars($matches[2]);\r
1702 \r
1703         // read OIM\r
1704         $XML = '<?xml version="1.0" encoding="utf-8"?>\r
1705 <soap:Envelope xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"\r
1706                xmlns:xsd="http://www.w3.org/2001/XMLSchema"\r
1707                xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/">\r
1708 <soap:Header>\r
1709   <PassportCookie xmlns="http://www.hotmail.msn.com/ws/2004/09/oim/rsi">\r
1710     <t>'.$t.'</t>\r
1711     <p>'.$p.'</p>\r
1712   </PassportCookie>\r
1713 </soap:Header>\r
1714 <soap:Body>\r
1715   <GetMessage xmlns="http://www.hotmail.msn.com/ws/2004/09/oim/rsi">\r
1716     <messageId>'.$msgid.'</messageId>\r
1717     <alsoMarkAsRead>false</alsoMarkAsRead>\r
1718   </GetMessage>\r
1719 </soap:Body>\r
1720 </soap:Envelope>';\r
1721 \r
1722         $header_array = array(\r
1723             'SOAPAction: '.self::OIM_READ_SOAP,\r
1724             'Content-Type: text/xml; charset=utf-8',\r
1725             'User-Agent: Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1; Messenger '.self::BUILDVER.')'\r
1726         );\r
1727 \r
1728         $this->debug_message('*** URL: '.self::OIM_READ_URL);\r
1729         $this->debug_message("*** Sending SOAP:\n$XML");\r
1730         $curl = curl_init();\r
1731         curl_setopt($curl, CURLOPT_URL, self::OIM_READ_URL);\r
1732         curl_setopt($curl, CURLOPT_HTTPHEADER, $header_array);\r
1733         curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);\r
1734         curl_setopt($curl, CURLOPT_FOLLOWLOCATION, 1);\r
1735         curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, 0);\r
1736         if ($this->debug) curl_setopt($curl, CURLOPT_HEADER, 1);\r
1737         curl_setopt($curl, CURLOPT_POST, 1);\r
1738         curl_setopt($curl, CURLOPT_POSTFIELDS, $XML);\r
1739         $data = curl_exec($curl);\r
1740         $http_code = curl_getinfo($curl, CURLINFO_HTTP_CODE);\r
1741         curl_close($curl);\r
1742         $this->debug_message("*** Get Result:\n$data");\r
1743 \r
1744         if ($http_code != 200) {\r
1745             $this->debug_message("*** Can't get OIM: $msgid, http code = $http_code");\r
1746             return false;\r
1747         }\r
1748 \r
1749         // why can't use preg_match('#<GetMessageResult>(.*)</GetMessageResult>#', $data, $matches)?\r
1750         // multi-lines?\r
1751         $start = strpos($data, '<GetMessageResult>');\r
1752         $end = strpos($data, '</GetMessageResult>');\r
1753         if ($start === false || $end === false || $start > $end) {\r
1754             $this->debug_message("*** Can't get OIM: $msgid");\r
1755             return false;\r
1756         }\r
1757         $lines = substr($data, $start + 18, $end - $start);\r
1758         $aLines = @explode("\n", $lines);\r
1759         $header = true;\r
1760         $ignore = false;\r
1761         $sOIM = '';\r
1762         foreach ($aLines as $line) {\r
1763             $line = rtrim($line);\r
1764             if ($header) {\r
1765                 if ($line === '') {\r
1766                     $header = false;\r
1767                     continue;\r
1768                 }\r
1769                 continue;\r
1770             }\r
1771             // stop at empty lines\r
1772             if ($line === '') break;\r
1773             $sOIM .= $line;\r
1774         }\r
1775         $sMsg = base64_decode($sOIM);\r
1776         //$this->debug_message("*** we get OIM ($msgid): $sMsg");\r
1777 \r
1778         // delete OIM\r
1779         $XML = '<?xml version="1.0" encoding="utf-8"?>\r
1780 <soap:Envelope xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"\r
1781                xmlns:xsd="http://www.w3.org/2001/XMLSchema"\r
1782                xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/">\r
1783 <soap:Header>\r
1784   <PassportCookie xmlns="http://www.hotmail.msn.com/ws/2004/09/oim/rsi">\r
1785     <t>'.$t.'</t>\r
1786     <p>'.$p.'</p>\r
1787   </PassportCookie>\r
1788 </soap:Header>\r
1789 <soap:Body>\r
1790   <DeleteMessages xmlns="http://www.hotmail.msn.com/ws/2004/09/oim/rsi">\r
1791     <messageIds>\r
1792       <messageId>'.$msgid.'</messageId>\r
1793     </messageIds>\r
1794   </DeleteMessages>\r
1795 </soap:Body>\r
1796 </soap:Envelope>';\r
1797 \r
1798         $header_array = array(\r
1799             'SOAPAction: '.self::OIM_DEL_SOAP,\r
1800             'Content-Type: text/xml; charset=utf-8',\r
1801             'User-Agent: Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1; Messenger '.self::BUILDVER.')'\r
1802         );\r
1803 \r
1804         $this->debug_message('*** URL: '.self::OIM_DEL_URL);\r
1805         $this->debug_message("*** Sending SOAP:\n$XML");\r
1806         $curl = curl_init();\r
1807         curl_setopt($curl, CURLOPT_URL, self::OIM_DEL_URL);\r
1808         curl_setopt($curl, CURLOPT_HTTPHEADER, $header_array);\r
1809         curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);\r
1810         curl_setopt($curl, CURLOPT_FOLLOWLOCATION, 1);\r
1811         curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, 0);\r
1812         if ($this->debug) curl_setopt($curl, CURLOPT_HEADER, 1);\r
1813         curl_setopt($curl, CURLOPT_POST, 1);\r
1814         curl_setopt($curl, CURLOPT_POSTFIELDS, $XML);\r
1815         $data = curl_exec($curl);\r
1816         $http_code = curl_getinfo($curl, CURLINFO_HTTP_CODE);\r
1817         curl_close($curl);\r
1818         $this->debug_message("*** Get Result:\n$data");\r
1819 \r
1820         if ($http_code != 200)\r
1821             $this->debug_message("*** Could not delete OIM: $msgid, http code = $http_code");\r
1822         else\r
1823             $this->debug_message("*** OIM ($msgid) deleted");\r
1824         return $sMsg;\r
1825     }\r
1826 \r
1827     /**\r
1828      * Send offline message\r
1829      *\r
1830      * @param string $to Intended recipient\r
1831      * @param string $sMessage Message\r
1832      * @param string $lockkey Lock key\r
1833      * @return mixed true on success or error data\r
1834      */\r
1835     private function sendOIM($to, $sMessage, $lockkey) {\r
1836         $XML = '<?xml version="1.0" encoding="utf-8"?>\r
1837 <soap:Envelope xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"\r
1838                xmlns:xsd="http://www.w3.org/2001/XMLSchema"\r
1839                xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/">\r
1840 <soap:Header>\r
1841   <From memberName="'.$this->user.'"\r
1842         friendlyName="=?utf-8?B?'.base64_encode($this->user).'?="\r
1843         xml:lang="zh-TW"\r
1844         proxy="MSNMSGR"\r
1845         xmlns="http://messenger.msn.com/ws/2004/09/oim/"\r
1846         msnpVer="'.self::PROTOCOL.'"\r
1847         buildVer="'.self::BUILDVER.'"/>\r
1848   <To memberName="'.$to.'" xmlns="http://messenger.msn.com/ws/2004/09/oim/"/>\r
1849   <Ticket passport="'.htmlspecialchars($this->ticket['oim_ticket']).'"\r
1850           appid="'.self::PROD_ID.'"\r
1851           lockkey="'.$lockkey.'"\r
1852           xmlns="http://messenger.msn.com/ws/2004/09/oim/"/>\r
1853   <Sequence xmlns="http://schemas.xmlsoap.org/ws/2003/03/rm">\r
1854     <Identifier xmlns="http://schemas.xmlsoap.org/ws/2002/07/utility">http://messenger.msn.com</Identifier>\r
1855     <MessageNumber>1</MessageNumber>\r
1856   </Sequence>\r
1857 </soap:Header>\r
1858 <soap:Body>\r
1859   <MessageType xmlns="http://messenger.msn.com/ws/2004/09/oim/">text</MessageType>\r
1860   <Content xmlns="http://messenger.msn.com/ws/2004/09/oim/">MIME-Version: 1.0\r
1861 Content-Type: text/plain; charset=UTF-8\r
1862 Content-Transfer-Encoding: base64\r
1863 X-OIM-Message-Type: OfflineMessage\r
1864 X-OIM-Run-Id: {DAB68CFA-38C9-449B-945E-38AFA51E50A7}\r
1865 X-OIM-Sequence-Num: 1\r
1866 \r
1867 '.chunk_split(base64_encode($sMessage)).'\r
1868   </Content>\r
1869 </soap:Body>\r
1870 </soap:Envelope>';\r
1871 \r
1872         $header_array = array(\r
1873             'SOAPAction: '.self::OIM_SEND_SOAP,\r
1874             'Content-Type: text/xml',\r
1875             'User-Agent: Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1; Messenger '.self::BUILDVER.')'\r
1876         );\r
1877 \r
1878         $this->debug_message('*** URL: '.self::OIM_SEND_URL);\r
1879         $this->debug_message("*** Sending SOAP:\n$XML");\r
1880         $curl = curl_init();\r
1881         curl_setopt($curl, CURLOPT_URL, self::OIM_SEND_URL);\r
1882         curl_setopt($curl, CURLOPT_HTTPHEADER, $header_array);\r
1883         curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);\r
1884         curl_setopt($curl, CURLOPT_FOLLOWLOCATION, 1);\r
1885         curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, 0);\r
1886         if ($this->debug) curl_setopt($curl, CURLOPT_HEADER, 1);\r
1887         curl_setopt($curl, CURLOPT_POST, 1);\r
1888         curl_setopt($curl, CURLOPT_POSTFIELDS, $XML);\r
1889         $data = curl_exec($curl);\r
1890         $http_code = curl_getinfo($curl, CURLINFO_HTTP_CODE);\r
1891         curl_close($curl);\r
1892         $this->debug_message("*** Get Result:\n$data");\r
1893 \r
1894         if ($http_code == 200) {\r
1895             $this->debug_message("*** OIM sent for $to");\r
1896             return true;\r
1897         }\r
1898 \r
1899         $challenge = false;\r
1900         $auth_policy = false;\r
1901         // the lockkey is invalid, authenticated fail, we need challenge it again\r
1902         // <LockKeyChallenge xmlns="http://messenger.msn.com/ws/2004/09/oim/">364763969</LockKeyChallenge>\r
1903         preg_match("#<LockKeyChallenge (.*)>(.*)</LockKeyChallenge>#", $data, $matches);\r
1904         if (count($matches) != 0) {\r
1905             // yes, we get new LockKeyChallenge\r
1906             $challenge = $matches[2];\r
1907             $this->debug_message("*** OIM need new challenge ($challenge) for $to");\r
1908         }\r
1909         // auth policy error\r
1910         // <RequiredAuthPolicy xmlns="http://messenger.msn.com/ws/2004/09/oim/">MBI_SSL</RequiredAuthPolicy>\r
1911         preg_match("#<RequiredAuthPolicy (.*)>(.*)</RequiredAuthPolicy>#", $data, $matches);\r
1912         if (count($matches) != 0) {\r
1913             $auth_policy = $matches[2];\r
1914             $this->debug_message("*** OIM need new auth policy ($auth_policy) for $to");\r
1915         }\r
1916         if ($auth_policy === false && $challenge === false) {\r
1917             //<faultcode xmlns:q0="http://messenger.msn.com/ws/2004/09/oim/">q0:AuthenticationFailed</faultcode>\r
1918             preg_match("#<faultcode (.*)>(.*)</faultcode>#", $data, $matches);\r
1919             if (count($matches) == 0) {\r
1920                 // no error, we assume the OIM is sent\r
1921                 $this->debug_message("*** OIM sent for $to");\r
1922                 return true;\r
1923             }\r
1924             $err_code = $matches[2];\r
1925             //<faultstring>Exception of type 'System.Web.Services.Protocols.SoapException' was thrown.</faultstring>\r
1926             preg_match("#<faultstring>(.*)</faultstring>#", $data, $matches);\r
1927             if (count($matches) > 0)\r
1928                 $err_msg = $matches[1];\r
1929             else\r
1930                 $err_msg = '';\r
1931             $this->debug_message("*** OIM failed for $to");\r
1932             $this->debug_message("*** OIM Error code: $err_code");\r
1933             $this->debug_message("*** OIM Error Message: $err_msg");\r
1934             return false;\r
1935         }\r
1936         return array('challenge' => $challenge, 'auth_policy' => $auth_policy);\r
1937     }\r
1938 \r
1939     /**\r
1940      * Contact / Membership list methods\r
1941      */\r
1942 \r
1943     /**\r
1944     * Fetch contact list\r
1945     *\r
1946     * @return boolean true on success\r
1947     */\r
1948     private function UpdateContacts() {\r
1949         $ABApplicationHeaderArray = array(\r
1950             'ABApplicationHeader' => array(\r
1951                 ':' => array('xmlns' => 'http://www.msn.com/webservices/AddressBook'),\r
1952                 'ApplicationId' => 'CFE80F9D-180F-4399-82AB-413F33A1FA11',\r
1953                 'IsMigration' => false,\r
1954                 'PartnerScenario' => 'ContactSave'\r
1955              )\r
1956         );\r
1957 \r
1958         $ABApplicationHeader = new SoapHeader('http://www.msn.com/webservices/AddressBook', 'ABApplicationHeader', $this->Array2SoapVar($ABApplicationHeaderArray));\r
1959         $ABFindAllArray = array(\r
1960             'ABFindAll' => array(\r
1961                 ':' => array('xmlns'=>'http://www.msn.com/webservices/AddressBook'),\r
1962                 'abId' => '00000000-0000-0000-0000-000000000000',\r
1963                 'abView' => 'Full',\r
1964                 'lastChange' => '0001-01-01T00:00:00.0000000-08:00',\r
1965             )\r
1966         );\r
1967         $ABFindAll = new SoapParam($this->Array2SoapVar($ABFindAllArray), 'ABFindAll');\r
1968         $this->ABService->__setSoapHeaders(array($ABApplicationHeader, $this->ABAuthHeader));\r
1969         $this->Contacts = array();\r
1970         try {\r
1971             $this->debug_message('*** Updating Contacts...');\r
1972             $Result = $this->ABService->ABFindAll($ABFindAll);\r
1973             $this->debug_message("*** Result:\n".print_r($Result, true)."\n".$this->ABService->__getLastResponse());\r
1974             foreach($Result->ABFindAllResult->contacts->Contact as $Contact)\r
1975                 $this->Contacts[$Contact->contactInfo->passportName] = $Contact;\r
1976         } catch(Exception $e) {\r
1977             $this->debug_message("*** Update Contacts Error \nRequest:".$this->ABService->__getLastRequest()."\nError:".$e->getMessage());\r
1978             return false;\r
1979         }\r
1980         return true;\r
1981     }\r
1982 \r
1983     /**\r
1984     * Add contact\r
1985     *\r
1986     * @param string $email\r
1987     * @param integer $network\r
1988     * @param string $display\r
1989     * @param boolean $sendADL\r
1990     * @return boolean true on success\r
1991     */\r
1992     private function addContact($email, $network, $display = '', $sendADL = false) {\r
1993         if ($network != 1) return true;\r
1994         if (isset($this->Contacts[$email])) return true;\r
1995 \r
1996         $ABContactAddArray = array(\r
1997             'ABContactAdd' => array(\r
1998                 ':' => array('xmlns' => 'http://www.msn.com/webservices/AddressBook'),\r
1999                 'abId' => '00000000-0000-0000-0000-000000000000',\r
2000                 'contacts' => array(\r
2001                     'Contact' => array(\r
2002                         ':' => array('xmlns' => 'http://www.msn.com/webservices/AddressBook'),\r
2003                         'contactInfo' => array(\r
2004                             'contactType' => 'LivePending',\r
2005                             'passportName' => $email,\r
2006                             'isMessengerUser' => true,\r
2007                             'MessengerMemberInfo' => array(\r
2008                                 'DisplayName' => $email\r
2009                             )\r
2010                         )\r
2011                     )\r
2012                 ),\r
2013                 'options' => array(\r
2014                     'EnableAllowListManagement' => true\r
2015                 )\r
2016             )\r
2017         );\r
2018         $ABContactAdd = new SoapParam($this->Array2SoapVar($ABContactAddArray), 'ABContactAdd');\r
2019         try {\r
2020             $this->debug_message("*** Adding Contact $email...");\r
2021             $this->ABService->ABContactAdd($ABContactAdd);\r
2022         } catch(Exception $e) {\r
2023             $this->debug_message("*** Add Contact Error \nRequest:".$this->ABService->__getLastRequest()."\nError:".$e->getMessage());\r
2024             return false;\r
2025         }\r
2026         if ($sendADL && !feof($this->NSfp)) {\r
2027             @list($u_name, $u_domain) = @explode('@', $email);\r
2028             foreach (array('1', '2') as $l) {\r
2029                 $str = '<ml l="1"><d n="'.$u_domain.'"><c n="'.$u_name.'" l="'.$l.'" t="'.$network.'" /></d></ml>';\r
2030                 $len = strlen($str);\r
2031                 // NS: >>> ADL {id} {size}\r
2032                 $this->ns_writeln("ADL $this->id $len");\r
2033                 $this->ns_writedata($str);\r
2034             }\r
2035         }\r
2036         $this->UpdateContacts();\r
2037         return true;\r
2038     }\r
2039 \r
2040     /**\r
2041     * Remove contact from list\r
2042     *\r
2043     * @param integer $memberID\r
2044     * @param string $email\r
2045     * @param integer $network\r
2046     * @param string $list\r
2047     */\r
2048     function delMemberFromList($memberID, $email, $network, $list) {\r
2049         if ($network != 1 && $network != 32) return true;\r
2050         if ($memberID === false) return true;\r
2051         $user = $email;\r
2052         $ticket = htmlspecialchars($this->ticket['contact_ticket']);\r
2053         if ($network == 1)\r
2054             $XML = '<?xml version="1.0" encoding="utf-8"?>\r
2055 <soap:Envelope xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/"\r
2056                xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"\r
2057                xmlns:xsd="http://www.w3.org/2001/XMLSchema"\r
2058                xmlns:soapenc="http://schemas.xmlsoap.org/soap/encoding/">\r
2059 <soap:Header>\r
2060     <ABApplicationHeader xmlns="http://www.msn.com/webservices/AddressBook">\r
2061         <ApplicationId>996CDE1E-AA53-4477-B943-2BE802EA6166</ApplicationId>\r
2062         <IsMigration>false</IsMigration>\r
2063         <PartnerScenario>ContactMsgrAPI</PartnerScenario>\r
2064     </ABApplicationHeader>\r
2065     <ABAuthHeader xmlns="http://www.msn.com/webservices/AddressBook">\r
2066         <ManagedGroupRequest>false</ManagedGroupRequest>\r
2067         <TicketToken>'.$ticket.'</TicketToken>\r
2068     </ABAuthHeader>\r
2069 </soap:Header>\r
2070 <soap:Body>\r
2071     <DeleteMember xmlns="http://www.msn.com/webservices/AddressBook">\r
2072         <serviceHandle>\r
2073             <Id>0</Id>\r
2074             <Type>Messenger</Type>\r
2075             <ForeignId></ForeignId>\r
2076         </serviceHandle>\r
2077         <memberships>\r
2078             <Membership>\r
2079                 <MemberRole>'.$list.'</MemberRole>\r
2080                 <Members>\r
2081                     <Member xsi:type="PassportMember" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">\r
2082                         <Type>Passport</Type>\r
2083                         <MembershipId>'.$memberID.'</MembershipId>\r
2084                         <State>Accepted</State>\r
2085                     </Member>\r
2086                 </Members>\r
2087             </Membership>\r
2088         </memberships>\r
2089     </DeleteMember>\r
2090 </soap:Body>\r
2091 </soap:Envelope>';\r
2092         else\r
2093             $XML = '<?xml version="1.0" encoding="utf-8"?>\r
2094 <soap:Envelope xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/"\r
2095                xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"\r
2096                xmlns:xsd="http://www.w3.org/2001/XMLSchema"\r
2097                xmlns:soapenc="http://schemas.xmlsoap.org/soap/encoding/">\r
2098 <soap:Header>\r
2099     <ABApplicationHeader xmlns="http://www.msn.com/webservices/AddressBook">\r
2100         <ApplicationId>996CDE1E-AA53-4477-B943-2BE802EA6166</ApplicationId>\r
2101         <IsMigration>false</IsMigration>\r
2102         <PartnerScenario>ContactMsgrAPI</PartnerScenario>\r
2103     </ABApplicationHeader>\r
2104     <ABAuthHeader xmlns="http://www.msn.com/webservices/AddressBook">\r
2105         <ManagedGroupRequest>false</ManagedGroupRequest>\r
2106         <TicketToken>'.$ticket.'</TicketToken>\r
2107     </ABAuthHeader>\r
2108 </soap:Header>\r
2109 <soap:Body>\r
2110     <DeleteMember xmlns="http://www.msn.com/webservices/AddressBook">\r
2111         <serviceHandle>\r
2112             <Id>0</Id>\r
2113             <Type>Messenger</Type>\r
2114             <ForeignId></ForeignId>\r
2115         </serviceHandle>\r
2116         <memberships>\r
2117             <Membership>\r
2118                 <MemberRole>'.$list.'</MemberRole>\r
2119                 <Members>\r
2120                     <Member xsi:type="EmailMember" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">\r
2121                         <Type>Email</Type>\r
2122                         <MembershipId>'.$memberID.'</MembershipId>\r
2123                         <State>Accepted</State>\r
2124                     </Member>\r
2125                 </Members>\r
2126             </Membership>\r
2127         </memberships>\r
2128     </DeleteMember>\r
2129 </soap:Body>\r
2130 </soap:Envelope>';\r
2131 \r
2132         $header_array = array(\r
2133             'SOAPAction: '.self::DELMEMBER_SOAP,\r
2134             'Content-Type: text/xml; charset=utf-8',\r
2135             'User-Agent: MSN Explorer/9.0 (MSN 8.0; TmstmpExt)'\r
2136         );\r
2137 \r
2138         $this->debug_message('*** URL: '.self::DELMEMBER_URL);\r
2139         $this->debug_message("*** Sending SOAP:\n$XML");\r
2140         $curl = curl_init();\r
2141         curl_setopt($curl, CURLOPT_URL, self::DELMEMBER_URL);\r
2142         curl_setopt($curl, CURLOPT_HTTPHEADER, $header_array);\r
2143         curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);\r
2144         curl_setopt($curl, CURLOPT_FOLLOWLOCATION, 1);\r
2145         curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, 0);\r
2146         if ($this->debug) curl_setopt($curl, CURLOPT_HEADER, 1);\r
2147         curl_setopt($curl, CURLOPT_POST, 1);\r
2148         curl_setopt($curl, CURLOPT_POSTFIELDS, $XML);\r
2149         $data = curl_exec($curl);\r
2150         $http_code = curl_getinfo($curl, CURLINFO_HTTP_CODE);\r
2151         curl_close($curl);\r
2152         $this->debug_message("*** Get Result:\n$data");\r
2153 \r
2154         if ($http_code != 200) {\r
2155             preg_match('#<faultcode>(.*)</faultcode><faultstring>(.*)</faultstring>#', $data, $matches);\r
2156             if (count($matches) == 0) {\r
2157                 $this->debug_message("*** Could not delete member (network: $network) $email ($memberID) from $list list");\r
2158                 return false;\r
2159             }\r
2160             $faultcode = trim($matches[1]);\r
2161             $faultstring = trim($matches[2]);\r
2162             if (strcasecmp($faultcode, 'soap:Client') || stripos($faultstring, 'Member does not exist') === false) {\r
2163                 $this->debug_message("*** Could not delete member (network: $network) $email ($memberID) from $list list, error code: $faultcode, $faultstring");\r
2164                 return false;\r
2165             }\r
2166             $this->debug_message("*** Could not delete member (network: $network) $email ($memberID) from $list list, not present in list");\r
2167             return true;\r
2168         }\r
2169         $this->debug_message("*** Member successfully deleted (network: $network) $email ($memberID) from $list list");\r
2170         return true;\r
2171     }\r
2172 \r
2173     /**\r
2174     * Add contact to list\r
2175     *\r
2176     * @param string $email\r
2177     * @param integer $network\r
2178     * @param string $list\r
2179     */\r
2180     function addMemberToList($email, $network, $list) {\r
2181         if ($network != 1 && $network != 32) return true;\r
2182         $ticket = htmlspecialchars($this->ticket['contact_ticket']);\r
2183         $user = $email;\r
2184 \r
2185         if ($network == 1)\r
2186             $XML = '<?xml version="1.0" encoding="utf-8"?>\r
2187 <soap:Envelope xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/"\r
2188                xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"\r
2189                xmlns:xsd="http://www.w3.org/2001/XMLSchema"\r
2190                xmlns:soapenc="http://schemas.xmlsoap.org/soap/encoding/">\r
2191 <soap:Header>\r
2192     <ABApplicationHeader xmlns="http://www.msn.com/webservices/AddressBook">\r
2193         <ApplicationId>996CDE1E-AA53-4477-B943-2BE802EA6166</ApplicationId>\r
2194         <IsMigration>false</IsMigration>\r
2195         <PartnerScenario>ContactMsgrAPI</PartnerScenario>\r
2196     </ABApplicationHeader>\r
2197     <ABAuthHeader xmlns="http://www.msn.com/webservices/AddressBook">\r
2198         <ManagedGroupRequest>false</ManagedGroupRequest>\r
2199         <TicketToken>'.$ticket.'</TicketToken>\r
2200     </ABAuthHeader>\r
2201 </soap:Header>\r
2202 <soap:Body>\r
2203     <AddMember xmlns="http://www.msn.com/webservices/AddressBook">\r
2204         <serviceHandle>\r
2205             <Id>0</Id>\r
2206             <Type>Messenger</Type>\r
2207             <ForeignId></ForeignId>\r
2208         </serviceHandle>\r
2209         <memberships>\r
2210             <Membership>\r
2211                 <MemberRole>'.$list.'</MemberRole>\r
2212                 <Members>\r
2213                     <Member xsi:type="PassportMember" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">\r
2214                         <Type>Passport</Type>\r
2215                         <State>Accepted</State>\r
2216                         <PassportName>'.$user.'</PassportName>\r
2217                     </Member>\r
2218                 </Members>\r
2219             </Membership>\r
2220         </memberships>\r
2221     </AddMember>\r
2222 </soap:Body>\r
2223 </soap:Envelope>';\r
2224         else\r
2225             $XML = '<?xml version="1.0" encoding="utf-8"?>\r
2226 <soap:Envelope xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/"\r
2227                xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"\r
2228                xmlns:xsd="http://www.w3.org/2001/XMLSchema"\r
2229                xmlns:soapenc="http://schemas.xmlsoap.org/soap/encoding/">\r
2230 <soap:Header>\r
2231     <ABApplicationHeader xmlns="http://www.msn.com/webservices/AddressBook">\r
2232         <ApplicationId>996CDE1E-AA53-4477-B943-2BE802EA6166</ApplicationId>\r
2233         <IsMigration>false</IsMigration>\r
2234         <PartnerScenario>ContactMsgrAPI</PartnerScenario>\r
2235     </ABApplicationHeader>\r
2236     <ABAuthHeader xmlns="http://www.msn.com/webservices/AddressBook">\r
2237         <ManagedGroupRequest>false</ManagedGroupRequest>\r
2238         <TicketToken>'.$ticket.'</TicketToken>\r
2239     </ABAuthHeader>\r
2240 </soap:Header>\r
2241 <soap:Body>\r
2242     <AddMember xmlns="http://www.msn.com/webservices/AddressBook">\r
2243         <serviceHandle>\r
2244             <Id>0</Id>\r
2245             <Type>Messenger</Type>\r
2246             <ForeignId></ForeignId>\r
2247         </serviceHandle>\r
2248         <memberships>\r
2249             <Membership>\r
2250                 <MemberRole>'.$list.'</MemberRole>\r
2251                 <Members>\r
2252                     <Member xsi:type="EmailMember" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">\r
2253                         <Type>Email</Type>\r
2254                         <State>Accepted</State>\r
2255                         <Email>'.$user.'</Email>\r
2256                         <Annotations>\r
2257                             <Annotation>\r
2258                                 <Name>MSN.IM.BuddyType</Name>\r
2259                                 <Value>32:YAHOO</Value>\r
2260                             </Annotation>\r
2261                         </Annotations>\r
2262                     </Member>\r
2263                 </Members>\r
2264             </Membership>\r
2265         </memberships>\r
2266     </AddMember>\r
2267 </soap:Body>\r
2268 </soap:Envelope>';\r
2269         $header_array = array(\r
2270             'SOAPAction: '.self::ADDMEMBER_SOAP,\r
2271             'Content-Type: text/xml; charset=utf-8',\r
2272             'User-Agent: MSN Explorer/9.0 (MSN 8.0; TmstmpExt)'\r
2273         );\r
2274 \r
2275         $this->debug_message('*** URL: '.self::ADDMEMBER_URL);\r
2276         $this->debug_message("*** Sending SOAP:\n$XML");\r
2277         $curl = curl_init();\r
2278         curl_setopt($curl, CURLOPT_URL, self::ADDMEMBER_URL);\r
2279         curl_setopt($curl, CURLOPT_HTTPHEADER, $header_array);\r
2280         curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);\r
2281         curl_setopt($curl, CURLOPT_FOLLOWLOCATION, 1);\r
2282         curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, 0);\r
2283         if ($this->debug) curl_setopt($curl, CURLOPT_HEADER, 1);\r
2284         curl_setopt($curl, CURLOPT_POST, 1);\r
2285         curl_setopt($curl, CURLOPT_POSTFIELDS, $XML);\r
2286         $data = curl_exec($curl);\r
2287         $http_code = curl_getinfo($curl, CURLINFO_HTTP_CODE);\r
2288         curl_close($curl);\r
2289         $this->debug_message("*** Get Result:\n$data");\r
2290 \r
2291         if ($http_code != 200) {\r
2292             preg_match('#<faultcode>(.*)</faultcode><faultstring>(.*)</faultstring>#', $data, $matches);\r
2293             if (count($matches) == 0) {\r
2294                 $this->debug_message("*** Could not add member (network: $network) $email to $list list");\r
2295                 return false;\r
2296             }\r
2297             $faultcode = trim($matches[1]);\r
2298             $faultstring = trim($matches[2]);\r
2299             if (strcasecmp($faultcode, 'soap:Client') || stripos($faultstring, 'Member already exists') === false) {\r
2300                 $this->debug_message("*** Could not add member (network: $network) $email to $list list, error code: $faultcode, $faultstring");\r
2301                 return false;\r
2302             }\r
2303             $this->debug_message("*** Could not add member (network: $network) $email to $list list, already present");\r
2304             return true;\r
2305         }\r
2306         $this->debug_message("*** Member successfully added (network: $network) $email to $list list");\r
2307         return true;\r
2308     }\r
2309 \r
2310     /**\r
2311     * Get membership lists\r
2312     *\r
2313     * @param mixed $returnData Membership list or false on failure\r
2314     */\r
2315     function getMembershipList($returnData = false) {\r
2316         $ticket = htmlspecialchars($this->ticket['contact_ticket']);\r
2317         $XML = '<?xml version="1.0" encoding="utf-8"?>\r
2318 <soap:Envelope xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/"\r
2319                xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"\r
2320                xmlns:xsd="http://www.w3.org/2001/XMLSchema"\r
2321                xmlns:soapenc="http://schemas.xmlsoap.org/soap/encoding/">\r
2322 <soap:Header>\r
2323     <ABApplicationHeader xmlns="http://www.msn.com/webservices/AddressBook">\r
2324         <ApplicationId>996CDE1E-AA53-4477-B943-2BE802EA6166</ApplicationId>\r
2325         <IsMigration>false</IsMigration>\r
2326         <PartnerScenario>Initial</PartnerScenario>\r
2327     </ABApplicationHeader>\r
2328     <ABAuthHeader xmlns="http://www.msn.com/webservices/AddressBook">\r
2329         <ManagedGroupRequest>false</ManagedGroupRequest>\r
2330         <TicketToken>'.$ticket.'</TicketToken>\r
2331     </ABAuthHeader>\r
2332 </soap:Header>\r
2333 <soap:Body>\r
2334     <FindMembership xmlns="http://www.msn.com/webservices/AddressBook">\r
2335         <serviceFilter>\r
2336             <Types>\r
2337                 <ServiceType>Messenger</ServiceType>\r
2338                 <ServiceType>Invitation</ServiceType>\r
2339                 <ServiceType>SocialNetwork</ServiceType>\r
2340                 <ServiceType>Space</ServiceType>\r
2341                 <ServiceType>Profile</ServiceType>\r
2342             </Types>\r
2343         </serviceFilter>\r
2344     </FindMembership>\r
2345 </soap:Body>\r
2346 </soap:Envelope>';\r
2347         $header_array = array(\r
2348             'SOAPAction: '.self::MEMBERSHIP_SOAP,\r
2349             'Content-Type: text/xml; charset=utf-8',\r
2350             'User-Agent: MSN Explorer/9.0 (MSN 8.0; TmstmpExt)'\r
2351         );\r
2352         $this->debug_message('*** URL: '.self::MEMBERSHIP_URL);\r
2353         $this->debug_message("*** Sending SOAP:\n$XML");\r
2354         $curl = curl_init();\r
2355         curl_setopt($curl, CURLOPT_URL, self::MEMBERSHIP_URL);\r
2356         curl_setopt($curl, CURLOPT_HTTPHEADER, $header_array);\r
2357         curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);\r
2358         curl_setopt($curl, CURLOPT_FOLLOWLOCATION, 1);\r
2359         curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, 0);\r
2360         if ($this->debug) curl_setopt($curl, CURLOPT_HEADER, 1);\r
2361         curl_setopt($curl, CURLOPT_POST, 1);\r
2362         curl_setopt($curl, CURLOPT_POSTFIELDS, $XML);\r
2363         $data = curl_exec($curl);\r
2364         $http_code = curl_getinfo($curl, CURLINFO_HTTP_CODE);\r
2365         curl_close($curl);\r
2366         $this->debug_message("*** Get Result:\n$data");\r
2367 \r
2368         if ($http_code != 200) return false;\r
2369         $p = $data;\r
2370         $aMemberships = array();\r
2371         while (1) {\r
2372             //$this->debug_message("search p = $p");\r
2373             $start = strpos($p, '<Membership>');\r
2374             $end = strpos($p, '</Membership>');\r
2375             if ($start === false || $end === false || $start > $end) break;\r
2376             //$this->debug_message("start = $start, end = $end");\r
2377             $end += 13;\r
2378             $sMembership = substr($p, $start, $end - $start);\r
2379             $aMemberships[] = $sMembership;\r
2380             //$this->debug_message("add sMembership = $sMembership");\r
2381             $p = substr($p, $end);\r
2382         }\r
2383         //$this->debug_message("aMemberships = ".var_export($aMemberships, true));\r
2384 \r
2385         $aContactList = array();\r
2386         foreach ($aMemberships as $sMembership) {\r
2387             //$this->debug_message("sMembership = $sMembership");\r
2388             if (isset($matches)) unset($matches);\r
2389             preg_match('#<MemberRole>(.*)</MemberRole>#', $sMembership, $matches);\r
2390             if (count($matches) == 0) continue;\r
2391             $sMemberRole = $matches[1];\r
2392             //$this->debug_message("MemberRole = $sMemberRole");\r
2393             if ($sMemberRole != 'Allow' && $sMemberRole != 'Reverse' && $sMemberRole != 'Pending') continue;\r
2394             $p = $sMembership;\r
2395             if (isset($aMembers)) unset($aMembers);\r
2396             $aMembers = array();\r
2397             while (1) {\r
2398                 //$this->debug_message("search p = $p");\r
2399                 $start = strpos($p, '<Member xsi:type="');\r
2400                 $end = strpos($p, '</Member>');\r
2401                 if ($start === false || $end === false || $start > $end) break;\r
2402                 //$this->debug_message("start = $start, end = $end");\r
2403                 $end += 9;\r
2404                 $sMember = substr($p, $start, $end - $start);\r
2405                 $aMembers[] = $sMember;\r
2406                 //$this->debug_message("add sMember = $sMember");\r
2407                 $p = substr($p, $end);\r
2408             }\r
2409             //$this->debug_message("aMembers = ".var_export($aMembers, true));\r
2410             foreach ($aMembers as $sMember) {\r
2411                 //$this->debug_message("sMember = $sMember");\r
2412                 if (isset($matches)) unset($matches);\r
2413                 preg_match('#<Member xsi\:type="([^"]*)">#', $sMember, $matches);\r
2414                 if (count($matches) == 0) continue;\r
2415                 $sMemberType = $matches[1];\r
2416                 //$this->debug_message("MemberType = $sMemberType");\r
2417                 $network = -1;\r
2418                 preg_match('#<MembershipId>(.*)</MembershipId>#', $sMember, $matches);\r
2419                 if (count($matches) == 0) continue;\r
2420                 $id = $matches[1];\r
2421                 if ($sMemberType == 'PassportMember') {\r
2422                     if (strpos($sMember, '<Type>Passport</Type>') === false) continue;\r
2423                     $network = 1;\r
2424                     preg_match('#<PassportName>(.*)</PassportName>#', $sMember, $matches);\r
2425                 }\r
2426                 else if ($sMemberType == 'EmailMember') {\r
2427                     if (strpos($sMember, '<Type>Email</Type>') === false) continue;\r
2428                     // Value is 32: or 32:YAHOO\r
2429                     preg_match('#<Annotation><Name>MSN.IM.BuddyType</Name><Value>(.*):(.*)</Value></Annotation>#', $sMember, $matches);\r
2430                     if (count($matches) == 0) continue;\r
2431                     if ($matches[1] != 32) continue;\r
2432                     $network = 32;\r
2433                     preg_match('#<Email>(.*)</Email>#', $sMember, $matches);\r
2434                 }\r
2435                 if ($network == -1) continue;\r
2436                 if (count($matches) > 0) {\r
2437                     $email = $matches[1];\r
2438                     @list($u_name, $u_domain) = @explode('@', $email);\r
2439                     if ($u_domain == NULL) continue;\r
2440                     $aContactList[$u_domain][$u_name][$network][$sMemberRole] = $id;\r
2441                     $this->debug_message("*** Adding new contact (network: $network, status: $sMemberRole): $u_name@$u_domain ($id)");\r
2442                 }\r
2443             }\r
2444         }\r
2445         return $aContactList;\r
2446     }\r
2447 \r
2448     /**\r
2449      * MsnObj related methods\r
2450      */\r
2451 \r
2452     /**\r
2453      *\r
2454      * @param $FilePath 圖檔路徑\r
2455      * @param $Type     檔案類型 3=>大頭貼,2表情圖案\r
2456      * @return array\r
2457      */\r
2458     private function MsnObj($FilePath, $Type = 3) {\r
2459         if (!($FileSize=filesize($FilePath))) return '';\r
2460         $Location = md5($FilePath);\r
2461         $Friendly = md5($FilePath.$Type);\r
2462         if (isset($this->MsnObjMap[$Location])) return $this->MsnObjMap[$Location];\r
2463         $sha1d = base64_encode(sha1(file_get_contents($FilePath), true));\r
2464         $sha1c = base64_encode(sha1("Creator".$this->user."Size$FileSize"."Type$Type"."Location$Location"."Friendly".$Friendly."SHA1D$sha1d", true));\r
2465         $this->MsnObjArray[$Location] = $FilePath;\r
2466         $MsnObj = '<msnobj Creator="'.$this->user.'" Size="'.$FileSize.'" Type="'.$Type.'" Location="'.$Location.'" Friendly="'.$Friendly.'" SHA1D="'.$sha1d.'" SHA1C="'.$sha1c.'"/>';\r
2467         $this->MsnObjMap[$Location] = $MsnObj;\r
2468         $this->debug_message("*** p2p: addMsnObj $FilePath::$MsnObj\n");\r
2469         return $MsnObj;\r
2470     }\r
2471 \r
2472     private function GetPictureFilePath($Context) {\r
2473         $MsnObj = base64_decode($Context);\r
2474         if (preg_match('/location="(.*?)"/i', $MsnObj, $Match))\r
2475             $location = $Match[1];\r
2476         $this->debug_message("*** p2p: PictureFile[$location] ::All".print_r($this->MsnObjArray,true)."\n");\r
2477         if ($location && isset($this->MsnObjArray[$location]))\r
2478             return $this->MsnObjArray[$location];\r
2479         return false;\r
2480     }\r
2481 \r
2482     private function GetMsnObjDefine($Message) {\r
2483         $DefineString = '';\r
2484         if (is_array($this->Emotions))\r
2485             foreach ($this->Emotions as $Pattern => $FilePath) {\r
2486                 if (strpos($Message, $Pattern) !== false)\r
2487                 $DefineString .= "$Pattern\t".$this->MsnObj($FilePath, 2)."\t";\r
2488             }\r
2489         return $DefineString;\r
2490     }\r
2491 \r
2492     /**\r
2493      * Socket methods\r
2494      */\r
2495 \r
2496     /**\r
2497      * Read data of specified size from NS socket\r
2498      *\r
2499      * @param integer $size Size to read\r
2500      * @return string Data read\r
2501      */\r
2502     private function ns_readdata($size) {\r
2503         $data = '';\r
2504         $count = 0;\r
2505         while (!feof($this->NSfp)) {\r
2506             $buf = @fread($this->NSfp, $size - $count);\r
2507             $data .= $buf;\r
2508             $count += strlen($buf);\r
2509             if ($count >= $size) break;\r
2510         }\r
2511         $this->debug_message("NS: data ($size/$count) <<<\n$data");\r
2512         return $data;\r
2513     }\r
2514 \r
2515     /**\r
2516      * Read line from the NS socket\r
2517      *\r
2518      * @return string Data read\r
2519      */\r
2520     private function ns_readln() {\r
2521         $data = @fgets($this->NSfp, 4096);\r
2522         if ($data !== false) {\r
2523             $data = trim($data);\r
2524             $this->debug_message("NS: <<< $data");\r
2525         }\r
2526         return $data;\r
2527     }\r
2528 \r
2529     /**\r
2530      * Write line to NS socket\r
2531      *\r
2532      * Also increments id\r
2533      *\r
2534      * @param string $data Line to write to socket\r
2535      * @return mixed Bytes written or false on failure\r
2536      */\r
2537     private function ns_writeln($data) {\r
2538         $result = @fwrite($this->NSfp, $data."\r\n");\r
2539         if ($result !== false) {\r
2540             $this->debug_message("NS: >>> $data");\r
2541             $this->id++;\r
2542         }\r
2543         return $result;\r
2544     }\r
2545 \r
2546     /**\r
2547      * Write data to NS socket\r
2548      *\r
2549      * @param string $data Data to write to socket\r
2550      * @return mixed Bytes written or false on failure\r
2551      */\r
2552     private function ns_writedata($data) {\r
2553         $result = @fwrite($this->NSfp, $data);\r
2554         if ($result !== false) {\r
2555             $this->debug_message("NS: >>> $data");\r
2556         }\r
2557         return $result;\r
2558     }\r
2559 \r
2560     /**\r
2561      * Read data of specified size from given SB socket\r
2562      *\r
2563      * @param resource $socket SB socket\r
2564      * @param integer $size Size to read\r
2565      * @return string Data read\r
2566      */\r
2567     private function sb_readdata($socket, $size) {\r
2568         $data = '';\r
2569         $count = 0;\r
2570         while (!feof($socket)) {\r
2571             $buf = @fread($socket, $size - $count);\r
2572             $data .= $buf;\r
2573             $count += strlen($buf);\r
2574             if ($count >= $size) break;\r
2575         }\r
2576         $this->debug_message("SB: data ($size/$count) <<<\n$data");\r
2577         return $data;\r
2578     }\r
2579 \r
2580     /**\r
2581      * Read line from given SB socket\r
2582      *\r
2583      * @param resource $socket SB Socket\r
2584      * @return string Line read\r
2585      */\r
2586     private function sb_readln($socket) {\r
2587         $data = @fgets($socket, 4096);\r
2588         if ($data !== false) {\r
2589             $data = trim($data);\r
2590             $this->debug_message("SB: <<< $data");\r
2591         }\r
2592         return $data;\r
2593     }\r
2594 \r
2595     /**\r
2596      * Write line to given SB socket\r
2597      *\r
2598      * Also increments id\r
2599      *\r
2600      * @param resource $socket SB socket\r
2601      * @param integer $id Reference to SB id\r
2602      * @param string $data Line to write\r
2603      * @return mixed Bytes written or false on error\r
2604      */\r
2605     private function sb_writeln($socket, &$id, $data) {\r
2606         $result = @fwrite($socket, $data."\r\n");\r
2607         if ($result !== false) {\r
2608             $this->debug_message("SB: >>> $data");\r
2609             $id++;\r
2610         }\r
2611         return $result;\r
2612     }\r
2613 \r
2614     /**\r
2615      * Write data to given SB socket\r
2616      *\r
2617      * @param resource $socket SB socket\r
2618      * @param $data Data to write to socket\r
2619      * @return mixed Bytes written or false on error\r
2620      */\r
2621     private function sb_writedata($socket, $data) {\r
2622         $result = @fwrite($socket, $data);\r
2623         if ($result !== false) {\r
2624             $this->debug_message("SB: >>> $data");\r
2625         }\r
2626         return $result;\r
2627     }\r
2628 \r
2629     /**\r
2630      * Get all the sockets currently in use\r
2631      *\r
2632      * @return array Array of socket resources\r
2633      */\r
2634     public function getSockets() {\r
2635         return array_merge(array($this->NSfp), $this->switchBoardSessionLookup);\r
2636     }\r
2637 \r
2638     /**\r
2639      * Checks socket for end of file\r
2640      *\r
2641      * @param resource $socket Socket to check\r
2642      * @return boolean true if end of file (socket)\r
2643      */\r
2644     private static function socketcheck($socket){\r
2645         $info = stream_get_meta_data($socket);\r
2646         return $info['eof'];\r
2647     }\r
2648 \r
2649     /**\r
2650      * Key generation methods\r
2651      */\r
2652 \r
2653     private function derive_key($key, $magic) {\r
2654         $hash1 = mhash(MHASH_SHA1, $magic, $key);\r
2655         $hash2 = mhash(MHASH_SHA1, $hash1.$magic, $key);\r
2656         $hash3 = mhash(MHASH_SHA1, $hash1, $key);\r
2657         $hash4 = mhash(MHASH_SHA1, $hash3.$magic, $key);\r
2658         return $hash2.substr($hash4, 0, 4);\r
2659     }\r
2660 \r
2661     private function generateLoginBLOB($key, $challenge) {\r
2662         $key1 = base64_decode($key);\r
2663         $key2 = $this->derive_key($key1, 'WS-SecureConversationSESSION KEY HASH');\r
2664         $key3 = $this->derive_key($key1, 'WS-SecureConversationSESSION KEY ENCRYPTION');\r
2665 \r
2666         // get hash of challenge using key2\r
2667         $hash = mhash(MHASH_SHA1, $challenge, $key2);\r
2668 \r
2669         // get 8 bytes random data\r
2670         $iv = substr(base64_encode(rand(1000,9999).rand(1000,9999)), 2, 8);\r
2671 \r
2672         $cipher = mcrypt_cbc(MCRYPT_3DES, $key3, $challenge."\x08\x08\x08\x08\x08\x08\x08\x08", MCRYPT_ENCRYPT, $iv);\r
2673 \r
2674         $blob = pack('LLLLLLL', 28, 1, 0x6603, 0x8004, 8, 20, 72);\r
2675         $blob .= $iv;\r
2676         $blob .= $hash;\r
2677         $blob .= $cipher;\r
2678 \r
2679         return base64_encode($blob);\r
2680     }\r
2681 \r
2682     /**\r
2683     * Generate challenge response\r
2684     *\r
2685     * @param string $code\r
2686     * @return string challenge response code\r
2687     */\r
2688     private function getChallenge($code) {\r
2689         // MSNP15\r
2690         // http://msnpiki.msnfanatic.com/index.php/MSNP11:Challenges\r
2691         // Step 1: The MD5 Hash\r
2692         $md5Hash = md5($code.self::PROD_KEY);\r
2693         $aMD5 = @explode("\0", chunk_split($md5Hash, 8, "\0"));\r
2694         for ($i = 0; $i < 4; $i++) {\r
2695             $aMD5[$i] = implode('', array_reverse(@explode("\0", chunk_split($aMD5[$i], 2, "\0"))));\r
2696             $aMD5[$i] = (0 + base_convert($aMD5[$i], 16, 10)) & 0x7FFFFFFF;\r
2697         }\r
2698 \r
2699         // Step 2: A new string\r
2700         $chl_id = $code.self::PROD_ID;\r
2701         $chl_id .= str_repeat('0', 8 - (strlen($chl_id) % 8));\r
2702 \r
2703         $aID = @explode("\0", substr(chunk_split($chl_id, 4, "\0"), 0, -1));\r
2704         for ($i = 0; $i < count($aID); $i++) {\r
2705             $aID[$i] = implode('', array_reverse(@explode("\0", chunk_split($aID[$i], 1, "\0"))));\r
2706             $aID[$i] = 0 + base_convert(bin2hex($aID[$i]), 16, 10);\r
2707         }\r
2708 \r
2709         // Step 3: The 64 bit key\r
2710         $magic_num = 0x0E79A9C1;\r
2711         $str7f = 0x7FFFFFFF;\r
2712         $high = 0;\r
2713         $low = 0;\r
2714         for ($i = 0; $i < count($aID); $i += 2) {\r
2715             $temp = $aID[$i];\r
2716             $temp = bcmod(bcmul($magic_num, $temp), $str7f);\r
2717             $temp = bcadd($temp, $high);\r
2718             $temp = bcadd(bcmul($aMD5[0], $temp), $aMD5[1]);\r
2719             $temp = bcmod($temp, $str7f);\r
2720 \r
2721             $high = $aID[$i+1];\r
2722             $high = bcmod(bcadd($high, $temp), $str7f);\r
2723             $high = bcadd(bcmul($aMD5[2], $high), $aMD5[3]);\r
2724             $high = bcmod($high, $str7f);\r
2725 \r
2726             $low = bcadd(bcadd($low, $high), $temp);\r
2727         }\r
2728 \r
2729         $high = bcmod(bcadd($high, $aMD5[1]), $str7f);\r
2730         $low = bcmod(bcadd($low, $aMD5[3]), $str7f);\r
2731 \r
2732         $new_high = bcmul($high & 0xFF, 0x1000000);\r
2733         $new_high = bcadd($new_high, bcmul($high & 0xFF00, 0x100));\r
2734         $new_high = bcadd($new_high, bcdiv($high & 0xFF0000, 0x100));\r
2735         $new_high = bcadd($new_high, bcdiv($high & 0xFF000000, 0x1000000));\r
2736         // we need integer here\r
2737         $high = 0+$new_high;\r
2738 \r
2739         $new_low = bcmul($low & 0xFF, 0x1000000);\r
2740         $new_low = bcadd($new_low, bcmul($low & 0xFF00, 0x100));\r
2741         $new_low = bcadd($new_low, bcdiv($low & 0xFF0000, 0x100));\r
2742         $new_low = bcadd($new_low, bcdiv($low & 0xFF000000, 0x1000000));\r
2743         // we need integer here\r
2744         $low = 0+$new_low;\r
2745 \r
2746         // we just use 32 bits integer, don't need the key, just high/low\r
2747         // $key = bcadd(bcmul($high, 0x100000000), $low);\r
2748 \r
2749         // Step 4: Using the key\r
2750         $md5Hash = md5($code.self::PROD_KEY);\r
2751         $aHash = @explode("\0", chunk_split($md5Hash, 8, "\0"));\r
2752 \r
2753         $hash = '';\r
2754         $hash .= sprintf("%08x", (0 + base_convert($aHash[0], 16, 10)) ^ $high);\r
2755         $hash .= sprintf("%08x", (0 + base_convert($aHash[1], 16, 10)) ^ $low);\r
2756         $hash .= sprintf("%08x", (0 + base_convert($aHash[2], 16, 10)) ^ $high);\r
2757         $hash .= sprintf("%08x", (0 + base_convert($aHash[3], 16, 10)) ^ $low);\r
2758 \r
2759         return $hash;\r
2760     }\r
2761 \r
2762     /**\r
2763      * Utility methods\r
2764      */\r
2765 \r
2766     private function Array2SoapVar($Array, $ReturnSoapVarObj = true, $TypeName = null, $TypeNameSpace = null) {\r
2767         $ArrayString = '';\r
2768         foreach($Array as $Key => $Val) {\r
2769             if ($Key{0} == ':') continue;\r
2770             $Attrib = '';\r
2771             if (is_array($Val[':'])) {\r
2772                 foreach ($Val[':'] as $AttribName => $AttribVal)\r
2773                     $Attrib .= " $AttribName = '$AttribVal'";\r
2774             }\r
2775             if ($Key{0} == '!') {\r
2776                 //List Type Define\r
2777                 $Key = substr($Key,1);\r
2778                 foreach ($Val as $ListKey => $ListVal) {\r
2779                     if ($ListKey{0} == ':') continue;\r
2780                     if (is_array($ListVal)) $ListVal = $this->Array2SoapVar($ListVal, false);\r
2781                     elseif (is_bool($ListVal)) $ListVal = $ListVal ? 'true' : 'false';\r
2782                     $ArrayString .= "<$Key$Attrib>$ListVal</$Key>";\r
2783                 }\r
2784                 continue;\r
2785             }\r
2786             if (is_array($Val)) $Val = $this->Array2SoapVar($Val, false);\r
2787             elseif (is_bool($Val)) $Val = $Val ? 'true' : 'false';\r
2788             $ArrayString .= "<$Key$Attrib>$Val</$Key>";\r
2789         }\r
2790         if ($ReturnSoapVarObj) return new SoapVar($ArrayString, XSD_ANYXML, $TypeName, $TypeNameSpace);\r
2791         return $ArrayString;\r
2792     }\r
2793 \r
2794     private function linetoArray($lines) {\r
2795         $lines = str_replace("\r", '', $lines);\r
2796         $lines = explode("\n", $lines);\r
2797         foreach ($lines as $line) {\r
2798             if (!isset($line{3})) continue;\r
2799             list($Key, $Val) = explode(':', $line);\r
2800             $Data[trim($Key)] = trim($Val);\r
2801         }\r
2802         return $Data;\r
2803     }\r
2804 \r
2805     /**\r
2806     * Get Passport ticket\r
2807     *\r
2808     * @param string $url URL string (Optional)\r
2809     * @return mixed Array of tickets or false on failure\r
2810     */\r
2811     private function get_passport_ticket($url = '') {\r
2812         $user = $this->user;\r
2813         $password = htmlspecialchars($this->password);\r
2814 \r
2815         if ($url === '')\r
2816             $passport_url = self::PASSPORT_URL;\r
2817         else\r
2818             $passport_url = $url;\r
2819 \r
2820         $XML = '<?xml version="1.0" encoding="UTF-8"?>\r
2821 <Envelope xmlns="http://schemas.xmlsoap.org/soap/envelope/"\r
2822           xmlns:wsse="http://schemas.xmlsoap.org/ws/2003/06/secext"\r
2823           xmlns:saml="urn:oasis:names:tc:SAML:1.0:assertion"\r
2824           xmlns:wsp="http://schemas.xmlsoap.org/ws/2002/12/policy"\r
2825           xmlns:wsu="http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-utility-1.0.xsd"\r
2826           xmlns:wsa="http://schemas.xmlsoap.org/ws/2004/03/addressing"\r
2827           xmlns:wssc="http://schemas.xmlsoap.org/ws/2004/04/sc"\r
2828           xmlns:wst="http://schemas.xmlsoap.org/ws/2004/04/trust">\r
2829 <Header>\r
2830   <ps:AuthInfo xmlns:ps="http://schemas.microsoft.com/Passport/SoapServices/PPCRL" Id="PPAuthInfo">\r
2831     <ps:HostingApp>{7108E71A-9926-4FCB-BCC9-9A9D3F32E423}</ps:HostingApp>\r
2832     <ps:BinaryVersion>4</ps:BinaryVersion>\r
2833     <ps:UIVersion>1</ps:UIVersion>\r
2834     <ps:Cookies></ps:Cookies>\r
2835     <ps:RequestParams>AQAAAAIAAABsYwQAAAAxMDMz</ps:RequestParams>\r
2836   </ps:AuthInfo>\r
2837   <wsse:Security>\r
2838     <wsse:UsernameToken Id="user">\r
2839       <wsse:Username>'.$user.'</wsse:Username>\r
2840       <wsse:Password>'.$password.'</wsse:Password>\r
2841     </wsse:UsernameToken>\r
2842   </wsse:Security>\r
2843 </Header>\r
2844 <Body>\r
2845   <ps:RequestMultipleSecurityTokens xmlns:ps="http://schemas.microsoft.com/Passport/SoapServices/PPCRL" Id="RSTS">\r
2846     <wst:RequestSecurityToken Id="RST0">\r
2847       <wst:RequestType>http://schemas.xmlsoap.org/ws/2004/04/security/trust/Issue</wst:RequestType>\r
2848       <wsp:AppliesTo>\r
2849         <wsa:EndpointReference>\r
2850           <wsa:Address>http://Passport.NET/tb</wsa:Address>\r
2851         </wsa:EndpointReference>\r
2852       </wsp:AppliesTo>\r
2853     </wst:RequestSecurityToken>\r
2854     <wst:RequestSecurityToken Id="RST1">\r
2855       <wst:RequestType>http://schemas.xmlsoap.org/ws/2004/04/security/trust/Issue</wst:RequestType>\r
2856       <wsp:AppliesTo>\r
2857         <wsa:EndpointReference>\r
2858           <wsa:Address>messengerclear.live.com</wsa:Address>\r
2859         </wsa:EndpointReference>\r
2860       </wsp:AppliesTo>\r
2861       <wsse:PolicyReference URI="'.$this->passport_policy.'"></wsse:PolicyReference>\r
2862     </wst:RequestSecurityToken>\r
2863     <wst:RequestSecurityToken Id="RST2">\r
2864       <wst:RequestType>http://schemas.xmlsoap.org/ws/2004/04/security/trust/Issue</wst:RequestType>\r
2865       <wsp:AppliesTo>\r
2866         <wsa:EndpointReference>\r
2867           <wsa:Address>messenger.msn.com</wsa:Address>\r
2868         </wsa:EndpointReference>\r
2869       </wsp:AppliesTo>\r
2870       <wsse:PolicyReference URI="?id=507"></wsse:PolicyReference>\r
2871     </wst:RequestSecurityToken>\r
2872     <wst:RequestSecurityToken Id="RST3">\r
2873       <wst:RequestType>http://schemas.xmlsoap.org/ws/2004/04/security/trust/Issue</wst:RequestType>\r
2874       <wsp:AppliesTo>\r
2875         <wsa:EndpointReference>\r
2876           <wsa:Address>contacts.msn.com</wsa:Address>\r
2877         </wsa:EndpointReference>\r
2878       </wsp:AppliesTo>\r
2879       <wsse:PolicyReference URI="MBI"></wsse:PolicyReference>\r
2880     </wst:RequestSecurityToken>\r
2881     <wst:RequestSecurityToken Id="RST4">\r
2882       <wst:RequestType>http://schemas.xmlsoap.org/ws/2004/04/security/trust/Issue</wst:RequestType>\r
2883       <wsp:AppliesTo>\r
2884         <wsa:EndpointReference>\r
2885           <wsa:Address>messengersecure.live.com</wsa:Address>\r
2886         </wsa:EndpointReference>\r
2887       </wsp:AppliesTo>\r
2888       <wsse:PolicyReference URI="MBI_SSL"></wsse:PolicyReference>\r
2889     </wst:RequestSecurityToken>\r
2890     <wst:RequestSecurityToken Id="RST5">\r
2891       <wst:RequestType>http://schemas.xmlsoap.org/ws/2004/04/security/trust/Issue</wst:RequestType>\r
2892       <wsp:AppliesTo>\r
2893         <wsa:EndpointReference>\r
2894           <wsa:Address>spaces.live.com</wsa:Address>\r
2895         </wsa:EndpointReference>\r
2896       </wsp:AppliesTo>\r
2897       <wsse:PolicyReference URI="MBI"></wsse:PolicyReference>\r
2898     </wst:RequestSecurityToken>\r
2899     <wst:RequestSecurityToken Id="RST6">\r
2900       <wst:RequestType>http://schemas.xmlsoap.org/ws/2004/04/security/trust/Issue</wst:RequestType>\r
2901       <wsp:AppliesTo>\r
2902         <wsa:EndpointReference>\r
2903           <wsa:Address>storage.msn.com</wsa:Address>\r
2904         </wsa:EndpointReference>\r
2905       </wsp:AppliesTo>\r
2906       <wsse:PolicyReference URI="MBI"></wsse:PolicyReference>\r
2907     </wst:RequestSecurityToken>\r
2908   </ps:RequestMultipleSecurityTokens>\r
2909 </Body>\r
2910 </Envelope>';\r
2911 \r
2912         $this->debug_message("*** URL: $passport_url");\r
2913         $this->debug_message("*** Sending SOAP:\n$XML");\r
2914         $curl = curl_init();\r
2915         curl_setopt($curl, CURLOPT_URL, $passport_url);\r
2916         if ($this->debug) curl_setopt($curl, CURLOPT_HEADER, 1);\r
2917         curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);\r
2918         curl_setopt($curl, CURLOPT_FOLLOWLOCATION, 1);\r
2919         curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, 0);\r
2920         curl_setopt($curl, CURLOPT_POST, 1);\r
2921         curl_setopt($curl, CURLOPT_POSTFIELDS, $XML);\r
2922         $data = curl_exec($curl);\r
2923         $http_code = curl_getinfo($curl, CURLINFO_HTTP_CODE);\r
2924         curl_close($curl);\r
2925         $this->debug_message("*** Get Result:\n$data");\r
2926 \r
2927         if ($http_code != 200) {\r
2928             // sometimes, redirect to another URL\r
2929             // MSNP15\r
2930             //<faultcode>psf:Redirect</faultcode>\r
2931             //<psf:redirectUrl>https://msnia.login.live.com/pp450/RST.srf</psf:redirectUrl>\r
2932             //<faultstring>Authentication Failure</faultstring>\r
2933             if (strpos($data, '<faultcode>psf:Redirect</faultcode>') === false) {\r
2934                 $this->debug_message("*** Could not get passport ticket! http code = $http_code");\r
2935                 return false;\r
2936             }\r
2937             preg_match("#<psf\:redirectUrl>(.*)</psf\:redirectUrl>#", $data, $matches);\r
2938             if (count($matches) == 0) {\r
2939                 $this->debug_message('*** Redirected, but could not get redirect URL!');\r
2940                 return false;\r
2941             }\r
2942             $redirect_url = $matches[1];\r
2943             if ($redirect_url == $passport_url) {\r
2944                 $this->debug_message('*** Redirected, but to same URL!');\r
2945                 return false;\r
2946             }\r
2947             $this->debug_message("*** Redirected to $redirect_url");\r
2948             return $this->get_passport_ticket($redirect_url);\r
2949         }\r
2950 \r
2951         // sometimes, redirect to another URL, also return 200\r
2952         // MSNP15\r
2953         //<faultcode>psf:Redirect</faultcode>\r
2954         //<psf:redirectUrl>https://msnia.login.live.com/pp450/RST.srf</psf:redirectUrl>\r
2955         //<faultstring>Authentication Failure</faultstring>\r
2956         if (strpos($data, '<faultcode>psf:Redirect</faultcode>') !== false) {\r
2957             preg_match("#<psf\:redirectUrl>(.*)</psf\:redirectUrl>#", $data, $matches);\r
2958             if (count($matches) != 0) {\r
2959                 $redirect_url = $matches[1];\r
2960                 if ($redirect_url == $passport_url) {\r
2961                     $this->debug_message('*** Redirected, but to same URL!');\r
2962                     return false;\r
2963                 }\r
2964                 $this->debug_message("*** Redirected to $redirect_url");\r
2965                 return $this->get_passport_ticket($redirect_url);\r
2966             }\r
2967         }\r
2968 \r
2969         // no Redurect faultcode or URL\r
2970         // we should get the ticket here\r
2971 \r
2972         // we need ticket and secret code\r
2973         // RST1: messengerclear.live.com\r
2974         // <wsse:BinarySecurityToken Id="Compact1">t=tick&p=</wsse:BinarySecurityToken>\r
2975         // <wst:BinarySecret>binary secret</wst:BinarySecret>\r
2976         // RST2: messenger.msn.com\r
2977         // <wsse:BinarySecurityToken Id="PPToken2">t=tick</wsse:BinarySecurityToken>\r
2978         // RST3: contacts.msn.com\r
2979         // <wsse:BinarySecurityToken Id="Compact3">t=tick&p=</wsse:BinarySecurityToken>\r
2980         // RST4: messengersecure.live.com\r
2981         // <wsse:BinarySecurityToken Id="Compact4">t=tick&p=</wsse:BinarySecurityToken>\r
2982         // RST5: spaces.live.com\r
2983         // <wsse:BinarySecurityToken Id="Compact5">t=tick&p=</wsse:BinarySecurityToken>\r
2984         // RST6: storage.msn.com\r
2985         // <wsse:BinarySecurityToken Id="Compact6">t=tick&p=</wsse:BinarySecurityToken>\r
2986         preg_match("#".\r
2987             "<wsse\:BinarySecurityToken Id=\"Compact1\">(.*)</wsse\:BinarySecurityToken>(.*)".\r
2988             "<wst\:BinarySecret>(.*)</wst\:BinarySecret>(.*)".\r
2989             "<wsse\:BinarySecurityToken Id=\"PPToken2\">(.*)</wsse\:BinarySecurityToken>(.*)".\r
2990             "<wsse\:BinarySecurityToken Id=\"Compact3\">(.*)</wsse\:BinarySecurityToken>(.*)".\r
2991             "<wsse\:BinarySecurityToken Id=\"Compact4\">(.*)</wsse\:BinarySecurityToken>(.*)".\r
2992             "<wsse\:BinarySecurityToken Id=\"Compact5\">(.*)</wsse\:BinarySecurityToken>(.*)".\r
2993             "<wsse\:BinarySecurityToken Id=\"Compact6\">(.*)</wsse\:BinarySecurityToken>(.*)".\r
2994             "#",\r
2995         $data, $matches);\r
2996 \r
2997         // no ticket found!\r
2998         if (count($matches) == 0) {\r
2999             $this->debug_message('*** Could not get passport ticket!');\r
3000             return false;\r
3001         }\r
3002 \r
3003         //$this->debug_message(var_export($matches, true));\r
3004         // matches[0]: all data\r
3005         // matches[1]: RST1 (messengerclear.live.com) ticket\r
3006         // matches[2]: ...\r
3007         // matches[3]: RST1 (messengerclear.live.com) binary secret\r
3008         // matches[4]: ...\r
3009         // matches[5]: RST2 (messenger.msn.com) ticket\r
3010         // matches[6]: ...\r
3011         // matches[7]: RST3 (contacts.msn.com) ticket\r
3012         // matches[8]: ...\r
3013         // matches[9]: RST4 (messengersecure.live.com) ticket\r
3014         // matches[10]: ...\r
3015         // matches[11]: RST5 (spaces.live.com) ticket\r
3016         // matches[12]: ...\r
3017         // matches[13]: RST6 (storage.live.com) ticket\r
3018         // matches[14]: ...\r
3019 \r
3020         // so\r
3021         // ticket => $matches[1]\r
3022         // secret => $matches[3]\r
3023         // web_ticket => $matches[5]\r
3024         // contact_ticket => $matches[7]\r
3025         // oim_ticket => $matches[9]\r
3026         // space_ticket => $matches[11]\r
3027         // storage_ticket => $matches[13]\r
3028 \r
3029         // yes, we get ticket\r
3030         $aTickets = array(\r
3031             'ticket' => html_entity_decode($matches[1]),\r
3032             'secret' => html_entity_decode($matches[3]),\r
3033             'web_ticket' => html_entity_decode($matches[5]),\r
3034             'contact_ticket' => html_entity_decode($matches[7]),\r
3035             'oim_ticket' => html_entity_decode($matches[9]),\r
3036             'space_ticket' => html_entity_decode($matches[11]),\r
3037             'storage_ticket' => html_entity_decode($matches[13])\r
3038         );\r
3039         $this->ticket = $aTickets;\r
3040         //$this->debug_message(var_export($aTickets, true));\r
3041         $ABAuthHeaderArray = array(\r
3042             'ABAuthHeader' => array(\r
3043                 ':' => array('xmlns' => 'http://www.msn.com/webservices/AddressBook'),\r
3044                 'ManagedGroupRequest' => false,\r
3045                 'TicketToken' => htmlspecialchars($this->ticket['contact_ticket']),\r
3046             )\r
3047         );\r
3048         $this->ABAuthHeader = new SoapHeader('http://www.msn.com/webservices/AddressBook', 'ABAuthHeader', $this->Array2SoapVar($ABAuthHeaderArray));\r
3049         return $aTickets;\r
3050     }\r
3051 \r
3052     /**\r
3053     * Generate the data to send a message\r
3054     *\r
3055     * @param string $sMessage Message\r
3056     * @param integer $network Network\r
3057     * @return string Message data\r
3058     */\r
3059     private function getMessage($sMessage, $network = 1) {\r
3060         $msg_header = "MIME-Version: 1.0\r\nContent-Type: text/plain; charset=UTF-8\r\nX-MMS-IM-Format: FN=$this->font_fn; EF=$this->font_ef; CO=$this->font_co; CS=0; PF=22\r\n\r\n";\r
3061         $msg_header_len = strlen($msg_header);\r
3062         if ($network == 1)\r
3063             $maxlen = self::MAX_MSN_MESSAGE_LEN - $msg_header_len;\r
3064         else\r
3065             $maxlen = self::MAX_YAHOO_MESSAGE_LEN - $msg_header_len;\r
3066         $sMessage = str_replace("\r", '', $sMessage);\r
3067         $msg = substr($sMessage, 0, $maxlen);\r
3068         return $msg_header.$msg;\r
3069     }\r
3070 \r
3071     /**\r
3072     * Sleep for the given number of seconds\r
3073     *\r
3074     * @param integer $wait Number of seconds to sleep for\r
3075     */\r
3076     private function NSRetryWait($wait) {\r
3077         $this->debug_message("*** Sleeping for $wait seconds before retrying");\r
3078         sleep($wait);\r
3079     }\r
3080 \r
3081     /**\r
3082      * Sends a ping command\r
3083      *\r
3084      * Should be called about every 50 seconds\r
3085      *\r
3086      * @return void\r
3087      */\r
3088     public function sendPing() {\r
3089         // NS: >>> PNG\r
3090         $this->ns_writeln("PNG");\r
3091     }\r
3092 \r
3093     /**\r
3094     * Methods to add / call callbacks\r
3095     */\r
3096 \r
3097     /**\r
3098      * Calls User Handler\r
3099      *\r
3100      * Calls registered handler for a specific event.\r
3101      *\r
3102      * @param string $event Command (event) name (Rvous etc)\r
3103      * @param array $data Data\r
3104      * @see registerHandler\r
3105      * @return void\r
3106      */\r
3107     private function callHandler($event, $data = NULL) {\r
3108         if (isset($this->myEventHandlers[$event])) {\r
3109             if ($data !== NULL) {\r
3110                 call_user_func($this->myEventHandlers[$event], $data);\r
3111             } else {\r
3112                 call_user_func($this->myEventHandlers[$event]);\r
3113             }\r
3114         }\r
3115     }\r
3116 \r
3117     /**\r
3118      * Registers a user handler\r
3119      *\r
3120      * Handler List\r
3121      * IMIn, SessionReady, Pong, ConnectFailed, Reconnect,\r
3122      * AddedToList, RemovedFromList, StatusChange\r
3123      *\r
3124      * @param string $event Event name\r
3125      * @param string $handler User function to call\r
3126      * @see callHandler\r
3127      * @return boolean true if successful\r
3128      */\r
3129     public function registerHandler($event, $handler) {\r
3130         if (is_callable($handler)) {\r
3131             $this->myEventHandlers[$event] = $handler;\r
3132             return true;\r
3133         } else {\r
3134             return false;\r
3135         }\r
3136     }\r
3137 \r
3138     /**\r
3139      * Debugging methods\r
3140      */\r
3141 \r
3142     /**\r
3143      * Print message if debugging is enabled\r
3144      *\r
3145      * @param string $str Message to print\r
3146      */\r
3147     private function debug_message($str) {\r
3148         if (!$this->debug) return;\r
3149         echo $str."\n";\r
3150     }\r
3151 \r
3152     /**\r
3153      * Dump binary data\r
3154      *\r
3155      * @param string $str Data string\r
3156      * @return Binary data\r
3157      */\r
3158     private function dump_binary($str) {\r
3159         $buf = '';\r
3160         $a_str = '';\r
3161         $h_str = '';\r
3162         $len = strlen($str);\r
3163         for ($i = 0; $i < $len; $i++) {\r
3164             if (($i % 16) == 0) {\r
3165                 if ($buf !== '') {\r
3166                     $buf .= "$h_str $a_str\n";\r
3167                 }\r
3168                 $buf .= sprintf("%04X:", $i);\r
3169                 $a_str = '';\r
3170                 $h_str = '';\r
3171             }\r
3172             $ch = ord($str[$i]);\r
3173             if ($ch < 32)\r
3174             $a_str .= '.';\r
3175             else\r
3176             $a_str .= chr($ch);\r
3177             $h_str .= sprintf(" %02X", $ch);\r
3178         }\r
3179         if ($h_str !== '')\r
3180         $buf .= "$h_str $a_str\n";\r
3181         return $buf;\r
3182     }\r
3183 }\r