| // +----------------------------------------------------------------------+ require_once 'Net/Socket.php'; /** * Provides an implementation of the IMAP protocol using PEAR's * Net_Socket:: class. * * @package Net_IMAP/Protocol * @author Damian Alejandro Fernandez Sosa */ class Net_IMAPProtocol { /** * The auth methods this class support * @var array */ var $supportedAuthMethods=array('DIGEST-MD5', 'CRAM-MD5', 'LOGIN', 'PLAIN'); /** * The auth methods this class support * @var array */ var $supportedSASLAuthMethods=array('DIGEST-MD5', 'CRAM-MD5'); /** * _serverAuthMethods * @var boolean */ var $_serverAuthMethods = null; /** * The the current mailbox * @var string */ var $currentMailbox = "INBOX" ; /** * The socket resource being used to connect to the IMAP server. * @var resource */ var $_socket = null; /** * The timeout for the connection to the IMAP server. * @var int */ var $_timeout = null; /** * The options for SSL/TLS connection * (see documentation for stream_context_create) * @var array */ var $_streamContextOptions = null; /** * To allow class debuging * @var boolean */ var $_debug = false; var $dbgDialog = ''; /** * Print error messages * @var boolean */ var $_printErrors = false; /** * Command Number * @var int */ var $_cmd_counter = 1; /** * Command Number for IMAP commands * @var int */ var $_lastCmdID = 1; /** * Command Number * @var boolean */ var $_unParsedReturn = false; /** * _connected: checks if there is a connection made to a imap server or not * @var boolean */ var $_connected = false; /** * Capabilities * @var boolean */ var $_serverSupportedCapabilities = null; /** * Use UTF-7 funcionallity * @var boolean */ var $_useUTF_7 = true; /** * Constructor * * Instantiates a new Net_IMAP object. * * @since 1.0 */ function Net_IMAPProtocol() { $this->_socket = new Net_Socket(); /* * Include the Auth_SASL package. If the package is not available, * we disable the authentication methods that depend upon it. */ if ((@include_once 'Auth/SASL.php') == false) { foreach($this->supportedSASLAuthMethods as $SASLMethod){ $pos = array_search( $SASLMethod , $this->supportedAuthMethods); unset($this->supportedAuthMethods[$pos]); } } } /** * Attempt to connect to the IMAP server. * * @return mixed Returns a PEAR_Error with an error message on any * kind of failure, or true on success. * @access public * @since 1.0 */ function cmdConnect($host= "localhost" , $port = 143) { if( $this->_connected ){ return new PEAR_Error( 'already connected, logout first!' ); } if (PEAR::isError($error = $this->_socket->connect($host, $port, null, $this->_timeout, $this->_streamContextOptions))) { return $error; } if ( PEAR::isError( $this->_getRawResponse() ) ) { return new PEAR_Error( 'unable to open socket' ); } $this->_connected = true; return true; } /** * get the cmd ID * * @return string Returns the CmdID and increment the counter * * @access private * @since 1.0 */ function _getCmdId() { $this->_lastCmdID = "A000" . $this->_cmd_counter ; $this->_cmd_counter++; return $this->_lastCmdID; } /** * get the last cmd ID * * @return string Returns the last cmdId * * @access public * @since 1.0 */ function getLastCmdId() { return $this->_lastCmdID; } /** * get current mailbox name * * @return string Returns the current mailbox * * @access public * @since 1.0 */ function getCurrentMailbox() { return $this->currentMailbox; } /** * Sets the debuging information on or off * * @param boolean True or false * * @return nothing * @access public * @since 1.0 */ function setDebug($debug = true) { $this->_debug = $debug; } function getDebugDialog() { return $this->dbgDialog; } /** * Sets printed output of errors on or of * * @param boolean true or false * * @return nothing * @access public * @since 1.1 */ function setPrintErrors($printErrors = true) { $this->_printErrors = $printErrors; } /** * Send the given string of data to the server. * * @param string $data The string of data to send. * * @return mixed True on success or a PEAR_Error object on failure. * * @access private * @since 1.0 */ function _send($data) { if($this->_socket->eof() ){ return new PEAR_Error( 'Failed to write to socket: (connection lost!) ' ); } if ( PEAR::isError( $error = $this->_socket->write( $data ) ) ) { return new PEAR_Error( 'Failed to write to socket: ' . $error->getMessage() ); } if( $this->_debug ){ // C: means this data was sent by the client (this class) echo "C: $data"; $this->dbgDialog.="C: $data"; } return true; } /** * Receive the given string of data from the server. * * @return mixed a line of response on success or a PEAR_Error object on failure. * * @access private * @since 1.0 */ function _recvLn() { $this->lastline = $this->_socket->gets( 8192 ); if ( $this->lastline instanceof PEAR_Error ) { return new PEAR_Error('Failed to write to socket: ' . $this->lastline->getMessage() ); } if($this->_debug){ // S: means this data was sent by the IMAP Server echo "S: " . $this->lastline . "" ; $this->dbgDialog.="S: " . $this->lastline . "" ; } if( $this->lastline == '' ){ return new PEAR_Error('Failed to receive from the socket: ' ); } return $this->lastline; } /** * Send a command to the server with an optional string of arguments. * A carriage return / linefeed (CRLF) sequence will be appended to each * command string before it is sent to the IMAP server. * * @param string $commandId The IMAP cmdID to send to the server. * @param string $command The IMAP command to send to the server. * @param string $args A string of optional arguments to append * to the command. * * @return mixed The result of the _send() call. * * @access private * @since 1.0 */ function _putCMD($commandId , $command, $args = '') { if ( !empty( $args ) ) { return $this->_send( $commandId . " " . $command . " " . $args . "\r\n" ); } return $this->_send( $commandId . " " . $command . "\r\n" ); } /** * Get a response from the server with an optional string of commandID. * A carriage return / linefeed (CRLF) sequence will be appended to each * command string before it is sent to the IMAP server. * * @param string $commandid The IMAP commandid retrive from the server. * * @return string The result response. * * @access private */ function _getRawResponse($commandId = '*') { $arguments = ''; while ( $a = $this->_recvLn() ) { if ($a instanceof PEAR_Error) return $arguments; if (PEAR::isError( $this->lastline)) { error_log(__METHOD__.__LINE__.$this->lastline->message); } $reply_code = strtok( $this->lastline , ' ' ); $arguments.= $this->lastline; if ( !(strcmp( $commandId , $reply_code ) ) ) { return $arguments; } } return $arguments; } /** * get the "returning of the unparsed response" feature status * * @return boolean return if the unparsed response is returned or not * * @access public * @since 1.0 * */ function getUnparsedResponse() { return $this->_unParsedReturn; } /** * set the options for a SSL/TLS connection * (see documentation for stream_context_create) * * @param array $options the options for the SSL/TLS connection * @return nothing * * @access public * @since 1.1 */ function setStreamContextOptions($options) { $this->_streamContextOptions = $options; } /** * set the the timeout for the connection to the IMAP server. * * @param int $timeout the timeout * @return nothing * * @access public * @since 1.1 */ function setTimeout($timeout) { $this->_timeout = $timeout; } /** * set the "returning of the unparsed response" feature on or off * * @param boolean $status: true: feature is on * @return nothing * * @access public * @since 1.0 */ function setUnparsedResponse($status) { $this->_unParsedReturn = $status; } /** * Attempt to login to the iMAP server. * * @param string The userid to authenticate as. * @param string The password to authenticate with. * * @return array Returns an array containing the response * * @access public * @since 1.0 */ function cmdLogin($uid , $pwd) { $param="\"$uid\" \"$pwd\""; return $this->_genericCommand('LOGIN', $param); } /** * Attempt to authenticate to the iMAP server. * @param string The userid to authenticate as. * @param string The password to authenticate with. * @param string The cmdID. * * @return array Returns an array containing the response * * @access public * @since 1.0 */ function cmdAuthenticate($uid , $pwd , $userMethod = null) { if( !$this->_connected ){ return new PEAR_Error('not connected!'); } $cmdid = $this->_getCmdId(); if ( PEAR::isError( $method = $this->_getBestAuthMethod($userMethod) ) ) { return $method; } switch ($method) { case 'DIGEST-MD5': $result = $this->_authDigest_MD5( $uid , $pwd , $cmdid ); break; case 'CRAM-MD5': $result = $this->_authCRAM_MD5( $uid , $pwd ,$cmdid ); break; case 'LOGIN': $result = $this->_authLOGIN( $uid , $pwd , $cmdid ); break; case 'PLAIN': $result = $this->_authPLAIN( $uid , $pwd , $cmdid ); break; default : $result = new PEAR_Error( "$method is not a supported authentication method" ); break; } $args = $this->_getRawResponse( $cmdid ); return $this->_genericImapResponseParser( $args , $cmdid ); } /* Authenticates the user using the DIGEST-MD5 method. * * @param string The userid to authenticate as. * @param string The password to authenticate with. * @param string The cmdID. * * @return array Returns an array containing the response * * @access private * @since 1.0 */ function _authDigest_MD5($uid , $pwd , $cmdid) { class_exists('Auth_SASL') || require_once 'Auth/SASL.php'; if ( PEAR::isError($error = $this->_putCMD( $cmdid ,"AUTHENTICATE" , "DIGEST-MD5") ) ) { return $error; } if (PEAR::isError( $args = $this->_recvLn() ) ) { return $args; } $this->_getNextToken( $args , $plus ); $this->_getNextToken( $args , $space ); $this->_getNextToken( $args , $challenge ); $challenge = base64_decode( $challenge ); $digest = &Auth_SASL::factory('digestmd5'); $auth_str = base64_encode($digest->getResponse($uid, $pwd, $challenge,"localhost", "imap")); if ( PEAR::isError( $error = $this->_send("$auth_str\r\n"))) { return $error; } if ( PEAR::isError( $args = $this->_recvLn() )) { return $args; } /* * We don't use the protocol's third step because IMAP doesn't allow * subsequent authentication, so we just silently ignore it. */ if ( PEAR::isError( $error = $this->_send( "\r\n" ) ) ) { return $error; } } /* Authenticates the user using the CRAM-MD5 method. * * @param string The userid to authenticate as. * @param string The password to authenticate with. * @param string The cmdID. * * @return array Returns an array containing the response * * @access private * @since 1.0 */ function _authCRAM_MD5($uid, $pwd, $cmdid) { class_exists('Auth_SASL') || require_once 'Auth/SASL.php'; if ( PEAR::isError($error = $this->_putCMD( $cmdid ,"AUTHENTICATE" , "CRAM-MD5") ) ) { return $error; } if ( PEAR::isError( $args = $this->_recvLn() ) ) { return $args; } $this->_getNextToken( $args , $plus ); $this->_getNextToken( $args , $space ); $this->_getNextToken( $args , $challenge ); $challenge = base64_decode( $challenge ); $cram = &Auth_SASL::factory('crammd5'); $auth_str = base64_encode( $cram->getResponse( $uid , $pwd , $challenge ) ); if ( PEAR::isError( $error = $this->_send( $auth_str."\r\n" ) ) ) { return $error; } } /* Authenticates the user using the LOGIN method. * * @param string The userid to authenticate as. * @param string The password to authenticate with. * @param string The cmdID. * * @return array Returns an array containing the response * * @access private * @since 1.0 */ function _authLOGIN($uid, $pwd, $cmdid) { if (PEAR::isError($error = $this->_putCMD($cmdid,"AUTHENTICATE", "LOGIN"))) { return $error; } if (PEAR::isError($args = $this->_recvLn() )) { return $args; } $this->_getNextToken( $args , $plus ); $this->_getNextToken( $args , $space ); $this->_getNextToken( $args , $challenge ); $challenge = base64_decode( $challenge ); $auth_str = base64_encode( "$uid" ); if ( PEAR::isError( $error = $this->_send( $auth_str."\r\n" ) ) ) { return $error; } if (PEAR::isError( $args = $this->_recvLn() ) ) { return $args; } $auth_str = base64_encode( "$pwd" ); if ( PEAR::isError($error = $this->_send( $auth_str."\r\n" ) ) ) { return $error; } } /* Authenticates the user using the PLAIN method. * * @param string The userid to authenticate as. * @param string The password to authenticate with. * @param string The cmdID. * * @return array Returns an array containing the response * * @access private * @since 1.0 */ function _authPLAIN($uid, $pwd, $cmdid) { if (PEAR::isError($error = $this->_putCMD($cmdid,"AUTHENTICATE", "PLAIN"))) { return $error; } if (PEAR::isError($args = $this->_recvLn() )) { return $args; } $this->_getNextToken( $args , $plus ); $this->_getNextToken( $args , $space ); $this->_getNextToken( $args , $challenge ); $challenge = base64_decode( $challenge ); $auth_str = base64_encode(chr(0).$uid.chr(0).$pwd ); if ( PEAR::isError( $error = $this->_send( $auth_str."\r\n" ) ) ) { return $error; } } /** * Returns the name of the best authentication method that the server * has advertised. * * @param string if !=null,authenticate with this method ($userMethod). * * @return mixed Returns a string containing the name of the best * supported authentication method or a PEAR_Error object * if a failure condition is encountered. * @access private * @since 1.0 */ function _getBestAuthMethod($userMethod = null) { $this->cmdCapability(); if($userMethod != null ){ $methods = array(); $methods[] = $userMethod; }else{ $methods = $this->supportedAuthMethods; } //error_log(__METHOD__.' Supported Methods:'.array2string($methods).' Server methods:'.array2string($this->_serverAuthMethods)); if( ($methods != null) && ($this->_serverAuthMethods != null)){ foreach ( $methods as $method ) { if ( in_array( $method , $this->_serverAuthMethods ) ) { //error_log(__METHOD__.' choose:'.$method); return $method; } } $serverMethods=implode(',' ,$this->_serverAuthMethods); $myMethods=implode(',' ,$this->supportedAuthMethods); if (!empty($userMethod) && !in_array($userMethod,$this->_serverAuthMethods)) { foreach ( $this->supportedAuthMethods as $method ) { if ( in_array( $method , $this->_serverAuthMethods ) ) { if ($this->_debug) error_log(__METHOD__." UserMethod $userMethod not supported by server; trying best ServerMethod $method"); return $method; } } } return new PEAR_Error("$method NOT supported authentication method!. This IMAP server " . "supports these methods: $serverMethods, but I support $myMethods"); }else{ return new PEAR_Error("This IMAP server don't support any Auth methods"); } } /** * Attempt to disconnect from the iMAP server. * * @return array Returns an array containing the response * * @access public * @since 1.0 */ function cmdLogout() { if( !$this->_connected ){ return new PEAR_Error( 'not connected!' ); } if ( PEAR::isError( $args = $this->_genericCommand( 'LOGOUT' ) ) ) { error_log(__METHOD__.$args->message); return $args; } if (PEAR::isError( $reval = $this->_socket->disconnect() ) ) { error_log(__METHOD__.$reval->message); return new PEAR_Error('socket disconnect failed'); } return $args; // not for now //return $this->_genericImapResponseParser($args,$cmdid); } /** * Send the NOOP command. * * @return array Returns an array containing the response * * @access public * @since 1.0 */ function cmdNoop() { return $this->_genericCommand('NOOP'); } /** * Send the CHECK command. * * @return array Returns an array containing the response * * @access public * @since 1.0 */ function cmdCheck() { return $this->_genericCommand('CHECK'); } /** * Send the Select Mailbox Command * * @param string The mailbox to select. * * @return array Returns an array containing the response * * @access public * @since 1.0 */ function cmdSelect($mailbox) { $mailbox_name=$this->_createQuotedString($mailbox); if( !PEAR::isError( $ret= $this->_genericCommand('SELECT', $mailbox_name) ) ){ $this->currentMailbox = $mailbox; } return $ret; } /** * Send the EXAMINE Mailbox Command * * @param string The mailbox to examine. * @return array Returns an array containing the response * * @access public * @since 1.0 */ function cmdExamine($mailbox) { $mailbox_name=$this->_createQuotedString($mailbox); $ret=$this->_genericCommand('EXAMINE', $mailbox_name); $parsed=''; if ( PEAR::isError( $ret ) ) { error_log(__METHOD__.__LINE__.$ret->message); return new PEAR_Error( 'unable to examine '.$mailbox.':'.$ret->message ); } if(isset( $ret["PARSED"] ) ){ for($i=0;$i$parsed,"RESPONSE"=>$ret["RESPONSE"]); } /** * Send the CREATE Mailbox Command * * @param string $mailbox The mailbox to create. * @param array $options options to pass to create * @return array Returns an array containing the response * * @access public * @since 1.0 */ function cmdCreate($mailbox, $options = null) { $args = ""; $mailbox_name=$this->_createQuotedString($mailbox); $args = $this->_getCreateParams($options); return $this->_genericCommand('CREATE', $mailbox_name.$args); } /** * Send the RENAME Mailbox Command * * @param string $mailbox The old mailbox name. * @param string $new_mailbox The new (renamed) mailbox name. * @param array $options options to pass to create * * @return array Returns an array containing the response * * @access public * @since 1.0 */ function cmdRename($mailbox, $new_mailbox, $options = null) { $mailbox_name=$this->_createQuotedString($mailbox); $new_mailbox_name=$this->_createQuotedString($new_mailbox); $args = $this->_getCreateParams($options); return $this->_genericCommand('RENAME', "$mailbox_name $new_mailbox_name".$args ); } /** * Send the DELETE Mailbox Command * * @param string The mailbox name to delete. * * @return array Returns an array containing the response * * @access public * @since 1.0 */ function cmdDelete($mailbox) { $mailbox_name=$this->_createQuotedString($mailbox); return $this->_genericCommand('DELETE', $mailbox_name); } /** * Send the SUSCRIBE Mailbox Command * * @param string The mailbox name to suscribe. * * @return array Returns an array containing the response * * @access public * @since 1.0 */ function cmdSubscribe($mailbox) { $mailbox_name=$this->_createQuotedString($mailbox); return $this->_genericCommand('SUBSCRIBE', $mailbox_name ); } /** * Send the UNSUSCRIBE Mailbox Command * * @return mixed Returns a PEAR_Error with an error message on any * kind of failure, or true on success. * @access public * @since 1.0 */ function cmdUnsubscribe($mailbox) { $mailbox_name=$this->_createQuotedString($mailbox); return $this->_genericCommand('UNSUBSCRIBE', $mailbox_name ); } /** * Send the FETCH Command * * @return mixed Returns a PEAR_Error with an error message on any * kind of failure, or true on success. * @access public * @since 1.0 */ function cmdFetch($msgset, $fetchparam) { return $this->_genericCommand('FETCH' , "$msgset $fetchparam" ); } /** * Send the CAPABILITY Command * * @return mixed Returns a PEAR_Error with an error message on any * kind of failure, or true on success. * @access public * @since 1.0 */ function cmdCapability() { $ret = $this->_genericCommand( 'CAPABILITY' ); if(isset( $ret["PARSED"] ) ){ foreach($ret["PARSED"] as $substruct) { if ($substruct["COMMAND"] == "CAPABILITY") { $subrv=$substruct["EXT"]["CAPABILITY"]; break; } } $ret["PARSED"]=$subrv; //fill the $this->_serverAuthMethods and $this->_serverSupportedCapabilities arrays foreach( (array)$ret["PARSED"]["CAPABILITIES"] as $auth_method ){ if( strtoupper( substr( $auth_method , 0 ,5 ) ) == "AUTH=" ) $this->_serverAuthMethods[] = substr( $auth_method , 5 ); } // Keep the capabilities response to use ir later $this->_serverSupportedCapabilities = $ret["PARSED"]["CAPABILITIES"]; } return $ret; } /** * Send the CAPABILITY Command * * @return mixed Returns a PEAR_Error with an error message on any * kind of failure, or true on success. * @access public * @since 1.0 */ function cmdNamespace() { $ret = $this->_genericCommand( 'NAMESPACE' ); if(isset( $ret["PARSED"] ) ){ $ret["PARSED"]=$ret["PARSED"][0]["EXT"]["NAMESPACE"]; // Keep the namespace response for later use $this->_namespace = $ret["PARSED"]["NAMESPACES"]; } return $ret; } /** * Send the STATUS Mailbox Command * * @param string $mailbox the mailbox name * @param mixed $request the request status * it could be an array or space separated string of * MESSAGES | RECENT | UIDNEXT * UIDVALIDITY | UNSEEN * @return array Returns a Parsed Response * * @access public * @since 1.0 */ function cmdStatus($mailbox, $request) { $mailbox_name=$this->_createQuotedString($mailbox); // make array from $request if it is none if (!is_array($request)) { $request = explode(' ', $request); } // see RFC 3501 $valid_status_data = array('MESSAGES', 'RECENT', 'UIDNEXT', 'UIDVALIDITY', 'UNSEEN'); foreach ($request as $status_data) { if (!in_array($status_data, $valid_status_data)) { $this->_prot_error("request '$status_data' is invalid! see RFC 3501!!!!" , __LINE__ , __FILE__); } } // back to space separated string $request = implode(' ', $request); $ret = $this->_genericCommand('STATUS', $mailbox_name.' ('.$request.')'); if (isset($ret['PARSED'])) { foreach ($ret['PARSED'] as &$parsed) { if (!empty($parsed['EXT'])) { if(empty($ret['RESPONSE']['CODE'])) $ret['RESPONSE']['CODE'] ='OK'; $ret['PARSED'] = $parsed['EXT']; break; } } } return $ret; } /** * Send the LIST Command * * @return mixed Returns a PEAR_Error with an error message on any * kind of failure, or true on success. * @access public * @since 1.0 */ function cmdList($mailbox_base, $mailbox) { $mailbox_name=$this->_createQuotedString($mailbox); $mailbox_base=$this->_createQuotedString($mailbox_base); return $this->_genericCommand('LIST', "$mailbox_base $mailbox_name" ); } /** * Send the LSUB Command * * @return mixed Returns a PEAR_Error with an error message on any * kind of failure, or true on success. * @access public * @since 1.0 */ function cmdLsub($mailbox_base, $mailbox) { $mailbox_name=$this->_createQuotedString($mailbox); $mailbox_base=$this->_createQuotedString($mailbox_base); return $this->_genericCommand('LSUB', "$mailbox_base $mailbox_name" ); } /** * Send the APPEND Command * * @return mixed Returns a PEAR_Error with an error message on any * kind of failure, or true on success. * @access public * @since 1.0 */ function cmdAppend($mailbox, $msg , $flags_list = '' ,$time = '') { if(!$this->_connected){ return new PEAR_Error('not connected!'); } $cmdid=$this->_getCmdId(); $msg_size=$this->_getLineLength($msg); $mailbox_name=$this->_createQuotedString($mailbox); if($flags_list != '') { $flags_list = " ($flags_list)"; } // TODO: // Falta el codigo para que flags list y time hagan algo!! if( $this->hasCapability( "LITERAL+" ) == true ){ $param=sprintf("%s%s%s {%s+}\r\n%s",$mailbox_name,$flags_list,$time,$msg_size,$msg); if (PEAR::isError($error = $this->_putCMD($cmdid , 'APPEND' , $param ) ) ) { return $error; } }else{ $param=sprintf("%s%s%s {%s}",$mailbox_name,$flags_list,$time,$msg_size); if (PEAR::isError($error = $this->_putCMD($cmdid , 'APPEND' , $param ) ) ) { return $error; } if (PEAR::isError($error = $this->_recvLn() ) ) { return $error; } if (PEAR::isError($error = $this->_send( $msg."\r\n" ) ) ) { return $error; } } $args=$this->_getRawResponse($cmdid); $ret = $this->_genericImapResponseParser($args,$cmdid); return $ret; } /** * Send the CLOSE command. * * @return mixed Returns a PEAR_Error with an error message on any * kind of failure, or true on success. * @access public * @since 1.0 */ function cmdClose() { return $this->_genericCommand('CLOSE'); } /** * Send the EXPUNGE command. * * @return mixed Returns a PEAR_Error with an error message on any * kind of failure, or true on success. * @access public * @since 1.0 */ function cmdExpunge() { $ret=$this->_genericCommand('EXPUNGE'); if (PEAR::isError($ret)) return new PEAR_Error('could not Expunge!'); if(isset( $ret["PARSED"] ) ){ $parsed=$ret["PARSED"]; unset($ret["PARSED"]); foreach($parsed as $command){ if( strtoupper($command["COMMAND"]) == 'EXPUNGE' ){ $ret["PARSED"][$command["COMMAND"]][]=$command["NRO"]; }else{ $ret["PARSED"][$command["COMMAND"]]=$command["NRO"]; } } } return $ret; } /** * Send the SEARCH command. * * @return mixed Returns a PEAR_Error with an error message on any * kind of failure, or true on success. * @access public * @since 1.0 */ function cmdSearch($search_cmd) { /* if($_charset != '' ) $_charset = "[$_charset] "; $param=sprintf("%s%s",$charset,$search_cmd); */ $ret = $this->_genericCommand('SEARCH', $search_cmd ); if(isset( $ret["PARSED"] ) ){ $ret["PARSED"]=$ret["PARSED"][0]["EXT"]; } return $ret; } /** * Send the SORT command. * * @return mixed Returns a PEAR_Error with an error message on any * kind of failure, or true on success. * @access public * @since 1.1 */ function cmdSort($sort_cmd) { /* if ($_charset != '' ) $_charset = "[$_charset] "; $param = sprintf("%s%s",$charset,$search_cmd); */ $ret = $this->_genericCommand('SORT', $sort_cmd); if (isset($ret['PARSED'])) { $ret['PARSED'] = $ret['PARSED'][0]['EXT']; } return $ret; } /** * Send the STORE command. * * @param string $message_set the sessage_set * @param string $dataitem: the way we store the flags * FLAGS: replace the flags whith $value * FLAGS.SILENT: replace the flags whith $value but don't return untagged responses * * +FLAGS: Add the flags whith $value * +FLAGS.SILENT: Add the flags whith $value but don't return untagged responses * * -FLAGS: Remove the flags whith $value * -FLAGS.SILENT: Remove the flags whith $value but don't return untagged responses * * @param string $value * @return mixed Returns a PEAR_Error with an error message on any * kind of failure, or true on success. * @access public * @since 1.0 */ function cmdStore($message_set, $dataitem, $value) { /* As said in RFC2060... C: A003 STORE 2:4 +FLAGS (\Deleted) S: * 2 FETCH FLAGS (\Deleted \Seen) S: * 3 FETCH FLAGS (\Deleted) S: * 4 FETCH FLAGS (\Deleted \Flagged \Seen) S: A003 OK STORE completed */ if( $dataitem!="FLAGS" && $dataitem!="FLAGS.SILENT" && $dataitem!="+FLAGS" && $dataitem!="+FLAGS.SILENT" && $dataitem!="-FLAGS" && $dataitem!="-FLAGS.SILENT" ){ $this->_prot_error("dataitem '$dataitem' is invalid! see RFC2060!!!!" , __LINE__ , __FILE__ ); } $param=sprintf("%s %s (%s)",$message_set,$dataitem,$value); return $this->_genericCommand('STORE', $param ); } /** * Send the COPY command. * * @return mixed Returns a PEAR_Error with an error message on any * kind of failure, or true on success. * @access public * @since 1.0 */ function cmdCopy($message_set, $mailbox) { $mailbox_name=$this->_createQuotedString($mailbox); return $this->_genericCommand('COPY', sprintf("%s %s",$message_set,$mailbox_name) ); } function cmdUidFetch($msgset, $fetchparam) { return $this->_genericCommand('UID FETCH', sprintf("%s %s",$msgset,$fetchparam) ); } function cmdUidCopy($message_set, $mailbox) { $mailbox_name=$this->_createQuotedString($mailbox); return $this->_genericCommand('UID COPY', sprintf("%s %s",$message_set,$mailbox_name) ); } /** * Send the UID STORE command. * * @param string $message_set the sessage_set * @param string $dataitem: the way we store the flags * FLAGS: replace the flags whith $value * FLAGS.SILENT: replace the flags whith $value but don't return untagged responses * * +FLAGS: Add the flags whith $value * +FLAGS.SILENT: Add the flags whith $value but don't return untagged responses * * -FLAGS: Remove the flags whith $value * -FLAGS.SILENT: Remove the flags whith $value but don't return untagged responses * * @param string $value * @return mixed Returns a PEAR_Error with an error message on any * kind of failure, or true on success. * @access public * @since 1.0 */ function cmdUidStore($message_set, $dataitem, $value) { /* As said in RFC2060... C: A003 STORE 2:4 +FLAGS (\Deleted) S: * 2 FETCH FLAGS (\Deleted \Seen) S: * 3 FETCH FLAGS (\Deleted) S: * 4 FETCH FLAGS (\Deleted \Flagged \Seen) S: A003 OK STORE completed */ if( $dataitem!="FLAGS" && $dataitem!="FLAGS.SILENT" && $dataitem!="+FLAGS" && $dataitem!="+FLAGS.SILENT" && $dataitem!="-FLAGS" && $dataitem!="-FLAGS.SILENT" ){ $this->_prot_error("dataitem '$dataitem' is invalid! see RFC2060!!!!" , __LINE__ , __FILE__ ); } return $this->_genericCommand('UID STORE', sprintf("%s %s (%s)",$message_set,$dataitem,$value) ); } /** * Send the SEARCH command. * * @return mixed Returns a PEAR_Error with an error message on any * kind of failure, or true on success. * @access public * @since 1.0 */ function cmdUidSearch($search_cmd) { $ret=$this->_genericCommand('UID SEARCH', sprintf("%s",$search_cmd) ); if(isset( $ret["PARSED"] ) ){ $ret["PARSED"]=$ret["PARSED"][0]["EXT"]; } return $ret; } /** * Send the UID SORT command. * * @return mixed Returns a PEAR_Error with an error message on any * kind of failure, or true on success. * @access public * @since 1.1 */ function cmdUidSort($sort_cmd) { $ret=$this->_genericCommand('UID SORT', sprintf("%s",$sort_cmd)); if (isset($ret['PARSED'])) { $ret["PARSED"]=$ret["PARSED"][0]["EXT"]; } return $ret; } /** * Send the X command. * * @return mixed Returns a PEAR_Error with an error message on any * kind of failure, or true on success. * @access public * @since 1.0 */ function cmdX($atom, $parameters) { return $this->_genericCommand("X$atom", $parameters ); } /******************************************************************** *** *** HERE ENDS the RFC2060 IMAPS FUNCTIONS *** AND BEGIN THE EXTENSIONS FUNCTIONS *** ********************************************************************/ /******************************************************************** *** RFC2087 IMAP4 QUOTA extension BEGINS HERE ********************************************************************/ /** * Send the GETQUOTA command. * * @param string $mailbox_name the mailbox name to query for quota data * @return mixed Returns a PEAR_Error with an error message on any * kind of failure, or quota data on success * @access public * @since 1.0 */ function cmdGetQuota($mailbox_name) { //Check if the IMAP server has QUOTA support if( ! $this->hasQuotaSupport() ){ return new PEAR_Error("This IMAP server does not support QUOTA's! "); } $mailbox_name=sprintf("%s",$this->utf_7_encode($mailbox_name) ); $ret = $this->_genericCommand('GETQUOTA', $mailbox_name ); if(!is_object($ret) && isset( $ret["PARSED"] ) ){ // remove the array index because the quota response returns only 1 line of output $ret['PARSED']=$ret["PARSED"][0]; } return $ret; } /** * Send the GETQUOTAROOT command. * * @param string $mailbox_name the mailbox name to query for quota data * @return mixed Returns a PEAR_Error with an error message on any * kind of failure, or quota data on success * @access public * @since 1.0 */ function cmdGetQuotaRoot($mailbox_name) { //Check if the IMAP server has QUOTA support if( ! $this->hasQuotaSupport() ){ return new PEAR_Error("This IMAP server does not support QUOTA's! "); } $mailbox_name=sprintf("%s",$this->utf_7_encode($mailbox_name) ); $ret = $this->_genericCommand('GETQUOTAROOT', $mailbox_name ); if(!is_object($ret) && isset( $ret["PARSED"] ) ){ // remove the array index because the quota response returns only 1 line of output $ret['PARSED']=$ret["PARSED"][1]; } return $ret; } /** * Send the SETQUOTA command. * * @param string $mailbox_name the mailbox name to query for quota data * @param string $storageQuota sets the max number of bytes this mailbox can handle * @param string $messagesQuota sets the max number of messages this mailbox can handle * @return mixed Returns a PEAR_Error with an error message on any * kind of failure, or quota data on success * @access public * @since 1.0 */ // TODO: implement the quota by number of emails!! function cmdSetQuota($mailbox_name, $storageQuota = null ,$messagesQuota = null ) { //Check if the IMAP server has QUOTA support if( ! $this->hasQuotaSupport() ){ return new PEAR_Error("This IMAP server does not support QUOTA's! "); } if( ($messagesQuota == null) && ( $storageQuota == null) ){ return new PEAR_Error('$storageQuota and $messagesQuota parameters can\'t be both null if you want to use quota'); } $mailbox_name=$this->_createQuotedString($mailbox_name); //Make the command request $param=sprintf("%s (",$mailbox_name); if($storageQuota != null ){ if ($storageQuota == -1) { // set -1 to remove a quota $param = sprintf("%s", $param); } elseif ($storageQuota == strtolower('remove')) { // this is a cyrus rmquota specific feature // see http://email.uoa.gr/projects/cyrus/quota-patches/rmquota/ $param = sprintf("%sREMOVE 1", $param); } else { $param = sprintf("%sSTORAGE %s", $param, $storageQuota); } if( $messagesQuota != null ){ //if we have both types of quota on the same call we must append an space between // those parameters $param=sprintf("%s ",$param); } } if($messagesQuota != null ){ $param=sprintf("%sMESSAGES %s",$param,$messagesQuota); } $param=sprintf("%s)",$param); return $this->_genericCommand('SETQUOTA', $param ); } /** * Send the SETQUOTAROOT command. * * @param string $mailbox_name the mailbox name to query for quota data * @param string $storageQuota sets the max number of bytes this mailbox can handle * @param string $messagesQuota sets the max number of messages this mailbox can handle * @return mixed Returns a PEAR_Error with an error message on any * kind of failure, or quota data on success * @access public * @since 1.0 */ function cmdSetQuotaRoot($mailbox_name, $storageQuota = null ,$messagesQuota = null) { //Check if the IMAP server has QUOTA support if( ! $this->hasQuotaSupport() ){ return new PEAR_Error("This IMAP server does not support QUOTA's! "); } if( ($messagesQuota == null) && ( $storageQuota == null) ){ return new PEAR_Error('$storageQuota and $messagesQuota parameters can\'t be both null if you want to use quota'); } $mailbox_name=$this->_createQuotedString($mailbox_name); //Make the command request $param=sprintf("%s (",$mailbox_name); if($storageQuota != null ){ $param=sprintf("%sSTORAGE %s",$param,$storageQuota); if( $messagesQuota != null ){ //if we have both types of quota on the same call we must append an space between // those parameters $param=sprintf("%s ",$param); } } if($messagesQuota != null ){ $param=sprintf("%sMESSAGES %s",$param,$messagesQuota); } $param=sprintf("%s)",$param); return $this->_genericCommand('SETQUOTAROOT', $param ); } /******************************************************************** *** RFC2087 IMAP4 QUOTA extension ENDS HERE ********************************************************************/ /******************************************************************** *** RFC2086 IMAP4 ACL extension BEGINS HERE ********************************************************************/ function cmdSetACL($mailbox_name, $user, $acl) { //Check if the IMAP server has ACL support if( ! $this->hasAclSupport() ){ return new PEAR_Error("This IMAP server does not support ACL's! "); } $mailbox_name=$this->_createQuotedString($mailbox_name); $user_name=$this->_createQuotedString($user); if(is_array($acl)){ $acl=implode('',$acl); } return $this->_genericCommand('SETACL', sprintf("%s %s \"%s\"",$mailbox_name,$user_name,$acl) ); } function cmdDeleteACL($mailbox_name, $user) { //Check if the IMAP server has ACL support if( ! $this->hasAclSupport() ){ return new PEAR_Error("This IMAP server does not support ACL's! "); } $mailbox_name=$this->_createQuotedString($mailbox_name); return $this->_genericCommand('DELETEACL', sprintf("%s \"%s\"",$mailbox_name,$user) ); } function cmdGetACL($mailbox_name) { //Check if the IMAP server has ACL support if( ! $this->hasAclSupport() ){ return new PEAR_Error("This IMAP server does not support ACL's! "); } $mailbox_name=$this->_createQuotedString($mailbox_name); $ret = $this->_genericCommand('GETACL', sprintf("%s",$mailbox_name) ); if(isset( $ret["PARSED"] ) ){ $ret['PARSED']=$ret["PARSED"][0]["EXT"]; } return $ret; } function cmdListRights($mailbox_name, $user) { //Check if the IMAP server has ACL support if( ! $this->hasAclSupport() ){ return new PEAR_Error("This IMAP server does not support ACL's! "); } $mailbox_name=$this->_createQuotedString($mailbox_name); $ret = $this->_genericCommand('LISTRIGHTS', sprintf("%s \"%s\"",$mailbox_name,$user) ); if(isset( $ret["PARSED"] ) ){ $ret["PARSED"]=$ret["PARSED"][0]["EXT"]; } return $ret; } function cmdMyRights($mailbox_name) { //Check if the IMAP server has ACL support if( ! $this->hasAclSupport() ){ return new PEAR_Error("This IMAP server does not support ACL's! "); } $mailbox_name=$this->_createQuotedString($mailbox_name); $ret = $this->_genericCommand('MYRIGHTS', sprintf("%s",$mailbox_name) ); if(isset( $ret["PARSED"] ) ){ $ret["PARSED"]=$ret["PARSED"][0]["EXT"]; } return $ret; } /******************************************************************** *** RFC2086 IMAP4 ACL extension ENDs HERE ********************************************************************/ /******************************************************************************* *** draft-daboo-imap-annotatemore-05 IMAP4 ANNOTATEMORE extension BEGINS HERE ********************************************************************************/ function cmdSetAnnotation($mailbox_name, $entry, $values) { // Check if the IMAP server has ANNOTATEMORE support if(!$this->hasAnnotateMoreSupport()) { return new PEAR_Error('This IMAP server does not support the ANNOTATEMORE extension!'); } if (!is_array($values)) { return new PEAR_Error('Invalid $values argument passed to cmdSetAnnotation'); } $vallist = ''; foreach ($values as $name => $value) { $vallist .= "\"$name\" \"$value\" "; } $vallist = rtrim($vallist); return $this->_genericCommand('SETANNOTATION', sprintf('"%s" "%s" (%s)', $mailbox_name, $entry, $vallist)); } function cmdDeleteAnnotation($mailbox_name, $entry, $values) { // Check if the IMAP server has ANNOTATEMORE support if(!$this->hasAnnotateMoreSupport()) { return new PEAR_Error('This IMAP server does not support the ANNOTATEMORE extension!'); } if (!is_array($values)) { return new PEAR_Error('Invalid $values argument passed to cmdDeleteAnnotation'); } $vallist = ''; foreach ($values as $name) { $vallist .= "\"$name\" NIL "; } $vallist = rtrim($vallist); return $this->_genericCommand('SETANNOTATION', sprintf('"%s" "%s" (%s)', $mailbox_name, $entry, $vallist)); } function cmdGetAnnotation($mailbox_name, $entries, $values) { // Check if the IMAP server has ANNOTATEMORE support if(!$this->hasAnnotateMoreSupport()) { return new PEAR_Error('This IMAP server does not support the ANNOTATEMORE extension!'); } $entlist = ''; if (!is_array($entries)) { $entries = array($entries); } foreach ($entries as $name) { $entlist .= "\"$name\" "; } $entlist = rtrim($entlist); if (count($entries) > 1) { $entlist = "($entlist)"; } $vallist = ''; if (!is_array($values)) { $values = array($values); } foreach ($values as $name) { $vallist .= "\"$name\" "; } $vallist = rtrim($vallist); if (count($values) > 1) { $vallist = "($vallist)"; } return $this->_genericCommand('GETANNOTATION', sprintf('"%s" %s %s', $mailbox_name, $entlist, $vallist)); } /***************************************************************************** *** draft-daboo-imap-annotatemore-05 IMAP4 ANNOTATEMORE extension ENDs HERE ******************************************************************************/ /******************************************************************** *** *** HERE ENDS THE EXTENSIONS FUNCTIONS *** AND BEGIN THE AUXILIARY FUNCTIONS *** ********************************************************************/ /** * tell if the server has capability $capability * * @return true or false * * @access public * @since 1.0 */ function getServerAuthMethods() { if( $this->_serverAuthMethods == null ){ $this->cmdCapability(); return $this->_serverAuthMethods; } return false; } /** * tell if the server has capability $capability * * @return true or false * * @access public * @since 1.0 */ function hasCapability($capability) { if( $this->_serverSupportedCapabilities == null ){ $this->cmdCapability(); } if($this->_serverSupportedCapabilities != null ){ if( in_array( $capability , $this->_serverSupportedCapabilities ) ){ return true; } } return false; } /** * tell if the server has Quota support * * @return true or false * * @access public * @since 1.0 */ function hasQuotaSupport() { return $this->hasCapability('QUOTA'); } /** * tell if the server has Quota support * * @return true or false * * @access public * @since 1.0 */ function hasAclSupport() { return $this->hasCapability('ACL'); } /** * tell if the server has support for the ANNOTATEMORE extension * * @return true or false * * @access public * @since 1.0 */ function hasAnnotateMoreSupport() { return $this->hasCapability('ANNOTATEMORE'); } function _createQuotedString($mailbox) { $search = array('\\', '"'); $replace = array('\\\\', '\\"'); $mailbox_name = str_replace($search, $replace, $mailbox); $mailbox_name=sprintf("\"%s\"",$this->utf_7_encode($mailbox_name) ); return $mailbox_name; } /** * Parses the responses like RFC822.SIZE and INTERNALDATE * * @param string the IMAP's server response * * @return string containing the parsed response * @access private * @since 1.0 */ function _parseOneStringResponse(&$str, $line,$file) { $this->_parseSpace($str , $line , $file ); $size = $this->_getNextToken($str,$uid); return $uid; } /** * Parses the FLAG response * * @param string the IMAP's server response * * @return Array containing the parsed response * @access private * @since 1.0 */ function _parseFLAGSresponse(&$str) { $this->_parseSpace($str , __LINE__ , __FILE__ ); $params_arr[] = $this->_arrayfy_content($str); $flags_arr=array(); for( $i = 0 ; $i < count($params_arr[0]) ; $i++ ){ $flags_arr[] = $params_arr[0][$i]; } return $flags_arr; } /** * Parses the BODY response * * @param string the IMAP's server response * * @return Array containing the parsed response * @access private * @since 1.0 */ function _parseBodyResponse(&$str, $command) { $this->_parseSpace($str , __LINE__ , __FILE__ ); while($str[0] != ')' && $str!=''){ $params_arr[] = $this->_arrayfy_content($str); } return $params_arr; } /** * Makes the content an Array * * @param string the IMAP's server response * * @return Array containing the parsed response * @access private * @since 1.0 */ function _arrayfy_content(&$str) { $params_arr=array(); $this->_getNextToken($str,$params); if($params != '(' ){ return $params; } $this->_getNextToken($str,$params,false,false); while ( $str != '' && $params != ')'){ if($params != '' ){ if($params[0] == '(' ){ $params=$this->_arrayfy_content( $params ); } if($params != ' ' ){ //I don't remove the colons (") to handle the case of retriving " " // If I remove the colons the parser will interpret this field as an imap separator (space) // instead of a valid field so I remove the colons here if($params=='""'){ $params=''; }else{ if($params[0]=='"'){ $params=$this->_getSubstr($params,1,$this->_getLineLength($params)-2); } } $params_arr[]=$params; } }else{ //if params if empty (for example i'm parsing 2 quotes ("") // I'll append an array entry to mantain compatibility $params_arr[]=$params; } $this->_getNextToken($str,$params,false,false); } $this->arrayfy_content_level--; return $params_arr; } /** * Parses the BODY[],BODY[TEXT],.... responses * * @param string the IMAP's server response * * @return Array containing the parsed response * @access private * @since 1.0 */ function _parseContentresponse(&$str, $command) { $content = ''; $this->_parseSpace($str , __LINE__ , __FILE__ ); $size =$this->_getNextToken($str,$content); return array( "CONTENT"=> $content , "CONTENT_SIZE" =>$size ); } /** * Parses the ENVELOPE response * * @param string the IMAP's server response * * @return Array containing the parsed response * @access private * @since 1.0 */ function _parseENVELOPEresponse(&$str) { $content = ''; $this->_parseSpace($str , __LINE__ , __FILE__ ); $this->_getNextToken($str,$parenthesis); if( $parenthesis != '(' ){ $this->_prot_error("must be a '(' but is a '$parenthesis' !!!!" , __LINE__ , __FILE__ ); } // Get the email's Date $this->_getNextToken($str,$date); $this->_parseSpace($str , __LINE__ , __FILE__ ); // Get the email's Subject: $this->_getNextToken($str,$subject); //$subject=$this->decode($subject); $this->_parseSpace($str , __LINE__ , __FILE__ ); //FROM LIST; $from_arr = $this->_getAddressList($str); $this->_parseSpace($str , __LINE__ , __FILE__ ); //"SENDER LIST\n"; $sender_arr = $this->_getAddressList($str); $this->_parseSpace($str , __LINE__ , __FILE__ ); //"REPLY-TO LIST\n"; $reply_to_arr=$this->_getAddressList($str); $this->_parseSpace($str , __LINE__ , __FILE__ ); //"TO LIST\n"; $to_arr = $this->_getAddressList($str); $this->_parseSpace($str , __LINE__ , __FILE__ ); //"CC LIST\n"; $cc_arr = $this->_getAddressList($str); $this->_parseSpace($str , __LINE__ , __FILE__ ); //"BCC LIST|$str|\n"; $bcc_arr = $this->_getAddressList($str); $this->_parseSpace($str , __LINE__ , __FILE__ ); $this->_getNextToken($str,$in_reply_to); $this->_parseSpace($str , __LINE__ , __FILE__ ); $this->_getNextToken($str,$message_id); $this->_getNextToken($str,$parenthesis); if( $parenthesis != ')' ){ $this->_prot_error("must be a ')' but is a '$parenthesis' !!!!" , __LINE__ , __FILE__ ); } return array( "DATE"=> $date , "SUBJECT" => $subject,"FROM" => $from_arr, "SENDER" => $sender_arr , "REPLY_TO" => $reply_to_arr, "TO" => $to_arr, "CC" =>$cc_arr, "BCC"=> $bcc_arr, "IN_REPLY_TO" =>$in_reply_to, "MESSAGE_ID"=>$message_id ); } /** * Parses the ARRDLIST as defined in RFC * * @param string the IMAP's server response * * @return Array containing the parsed response * @access private * @since 1.0 */ function _getAddressList(&$str) { $params_arr = $this->_arrayfy_content($str); if( !isset( $params_arr ) ){ return $params_arr; } if( is_array($params_arr) ){ foreach ($params_arr as $index => $address_arr) { $personal_name = $address_arr[0]; $at_domain_list = $address_arr[1]; $mailbox_name = $address_arr[2]; $host_name = $address_arr[3]; if( $mailbox_name!='' && $host_name!='' ){ $email=$mailbox_name . "@" . $host_name; }else{ $email=false; } if($email==false){ $rfc822_email=false; }else{ if(!isset($personal_name)){ $rfc822_email= "<". $email . ">"; }else{ $rfc822_email= "\"". $personal_name ."\" <". $email . ">"; } } $email_arr[] = array ( "PERSONAL_NAME"=> $personal_name , "AT_DOMAIN_LIST"=>$at_domain_list , "MAILBOX_NAME"=> $this->utf_7_decode($mailbox_name), "HOST_NAME"=> $host_name, "EMAIL"=>$email , "RFC822_EMAIL" => $rfc822_email ); } return $email_arr; } return array(); } /** * Utility funcion to find the closing parenthesis ")" Position it takes care of quoted ones * * @param string the IMAP's server response * * @return int containing the pos of the closing parenthesis ")" * @access private * @since 1.0 */ function _getClosingBracesPos($str_line, $startDelim ='(', $stopDelim = ')' ) { $len = $this->_getLineLength( $str_line ); $pos = 0; // ignore all extra characters // If inside of a string, skip string -- Boundary IDs and other // things can have ) in them. if ( $str_line[$pos] != $startDelim ) { $this->_prot_error("_getClosingParenthesisPos: must start with a '".$startDelim."' but is a '". $str_line[$pos] ."'!!!!\n" . "STR_LINE:$str_line|size:$len|POS: $pos\n" , __LINE__ , __FILE__ ); return( $len ); } for( $pos = 1 ; $pos < $len ; $pos++ ){ if ($str_line[$pos] == $stopDelim ) { break; } if ($str_line[$pos] == '"') { $this->_advanceOverStr($str_line,$pos,$len,$startDelim,$stopDelim); } if ( $str_line[$pos] == $startDelim ) { #$str_line_aux = substr( $str_line , $pos ); $str_line_aux = $this->_getSubstr( $str_line , $pos ); $pos_aux = $this->_getClosingBracesPos( $str_line_aux ); $pos+=$pos_aux; if ($pos == $len-1) break; } } if( $str_line[$pos] != $stopDelim ){ $this->_prot_error("_getClosingBracesPos: must be a $stopDelim but is a '". $str_line[$pos] ."'|POS:$pos|STR_LINE:$str_line!!!!" , __LINE__ , __FILE__ ); } if( $pos >= $len ) return false; return $pos; } /** * Advances the position $pos in $str over an correcty escaped string * * Examples: $str='"\\\"First Last\\\""', $pos=0 * --> returns true and $pos=strlen($str)-1 * * @param string $str * @param int &$pos current position in $str pointing to a double quote ("), on return pointing on the closing double quote * @param int $len length of $str in bytes(!) * @return boolean true if we advanced over a correct string, false otherwise */ function _advanceOverStr($str,&$pos,$len,$startDelim ='(', $stopDelim = ')' ) { #error_log(__METHOD__. $len . "#".$str."\n"); $startingpos = $pos; if ($str[$pos] !== '"') return false; // start condition failed $pos++; $delimCount=0; while($str[$pos] !== '"' && $pos < $len) { // this is a fix to stop before the delimiter, in broken string messages containing an odd number of double quotes // the idea is to check for a stopDelimited followed by eiter a new startDelimiter or an other stopDelimiter // that allows to have something like '"Name (Nick)" ' containing one delimiter // if you have something like "Name ((something))" we must count the delimiters (and hope that they are not unbalanced too) // and check if we have a negative amount of delimiters or no delimiters to meet the stop condition, before we run into a closing double quote if ($str[$pos] === $startDelim) $delimCount++; if ($str[$pos] === $stopDelim) $delimCount--; if ($str[$pos] === $stopDelim && ($str[$pos+1] === $startDelim || ($str[$pos+1] === $stopDelim && $delimCount<=0))) { $encoding =mb_internal_encoding(); //if (mb_check_encoding($str)) { // error_log(__METHOD__.' Encoding used:'.mb_internal_encoding().' Detected:'.mb_detect_encoding($str)); // $encoding = mb_detect_encoding($str); //} // beware as mb_substr_count does not support the offset parameter. $numOfQuotes = substr_count(substr($str,$startingpos),'"'); $numOfMaskedQuotes = substr_count(substr($str,$startingpos),'\"'); if ((($numOfQuotes - $numOfMaskedQuotes) % 2 ) == 0) { // quotes are balanced, so its unlikely that we meet a stop condition here as strings may contain )( //error_log(__METHOD__. "->Length: $len; NumOfQuotes: $numOfQuotes - NumofMaskedQuotes:$numOfMaskedQuotes #".$str."\n"); if ($_debug) error_log(__METHOD__." problem at $pos with:".$str[$pos]."(last character) Numberof delimiters ('".$startDelim."','".$stopDelim."') found:".$delimCount.' String:'.substr($str,$startingpos,$pos).' called from:'.function_backtrace()); //return false; } else { $pos--; // stopDelimited need to be parsed outside! return false; } } if ($str[$pos] === '\\') $pos++; // all escaped chars are overread (eg. \\, \", \x) $pos++; } return $pos < $len && $str[$pos] === '"'; } /** * Utility funcion to get from here to the end of the line * * @param string the IMAP's server response * * @return string containing the string to the end of the line * @access private * @since 1.0 */ function _getToEOL(&$str , $including = true) { $len = $this->_getLineLength( $str ); if( $including ){ for($i=0;$i<$len;$i++){ if( $str[$i] =="\n" ) break; } $content=$this->_getSubstr($str,0,$i + 1); $str=$this->_getSubstr($str,$i + 1); return $content; }else{ for( $i = 0 ; $i < $len ; $i++ ){ if( $str[$i] =="\n" || $str[$i] == "\r") break; } $content = $this->_getSubstr( $str ,0 , $i ); $str = $this->_getSubstr( $str , $i ); return $content; } } /** * Fetches the next IMAP token or parenthesis * * @param string the IMAP's server response * @param string the next token * @param boolean true: the parenthesis IS a token, false: I consider * all the response in parenthesis as a token * * @return int containing the content size * @access private * @since 1.0 */ function _getNextToken(&$str, &$content, $parenthesisIsToken=true,$colonIsToken=true){ $len = $this->_getLineLength($str); $pos = 0; $content_size = false; $content = false; if($str == '' || $len < 2 ){ $content=$str; return $len; } switch( $str[0] ){ case '{': if( ($posClosingBraces = $this->_getClosingBracesPos($str, '{' , '}' )) == false ){ $this->_prot_error("_getClosingBracesPos() error!!!" , __LINE__ , __FILE__ ); } if(! is_numeric( ( $strBytes = $this->_getSubstr( $str , 1 , $posClosingBraces - 1) ) ) ){ $this->_prot_error("must be a number but is a '" . $strBytes ."'!!!!" , __LINE__ , __FILE__ ); } if( $str[$posClosingBraces] != '}' ){ $this->_prot_error("must be a '}' but is a '" . $str[$posClosingBraces] ."'!!!!" , __LINE__ , __FILE__ ); } if( $str[$posClosingBraces + 1] != "\r" ){ $this->_prot_error("must be a '\\r' but is a '" . $str[$posClosingBraces + 1] ."'!!!!" , __LINE__ , __FILE__ ); } if( $str[$posClosingBraces + 2] != "\n" ){ $this->_prot_error("must be a '\\n' but is a '" . $str[$posClosingBraces + 2] ."'!!!!" , __LINE__ , __FILE__ ); } $content = $this->_getSubstr( $str , $posClosingBraces + 3 , $strBytes ); if( $this->_getLineLength( $content ) != $strBytes ){ $this->_prot_error("content size is ". $this->_getLineLength($content) . " but the string reports a size of $strBytes!!!\n" , __LINE__ , __FILE__ ); } $content_size = $strBytes; //Advance the string $str = $this->_getSubstr( $str , $posClosingBraces + $strBytes + 3 ); break; case '"': if($colonIsToken){ for($pos=1;$pos<$len;$pos++){ if ( $str[$pos] == "\"" ) { break; } if ($str[$pos] == "\\" && $str[$pos + 1 ] == "\"" ) $pos++; if ($str[$pos] == "\\" && $str[$pos + 1 ] == "\\" ) $pos++; } if($str[$pos] != '"' ){ $this->_prot_error("must be a '\"' but is a '" . $str[$pos] ."'!!!!" , __LINE__ , __FILE__ ); } $content_size = $pos; $content = $this->_getSubstr( $str , 1 , $pos - 1 ); //Advance the string $str = $this->_getSubstr( $str , $pos + 1 ); }else{ for($pos=1;$pos<$len;$pos++){ if ( $str[$pos] == "\"" ) { break; } if ($str[$pos] == "\\" && $str[$pos + 1 ] == "\"" ) $pos++; if ($str[$pos] == "\\" && $str[$pos + 1 ] == "\\" ) $pos++; } if($str[$pos] != '"' ){ $this->_prot_error("must be a '\"' but is a '" . $str[$pos] ."'!!!!" , __LINE__ , __FILE__ ); } $content_size = $pos; $content = $this->_getSubstr( $str , 0 , $pos + 1 ); //Advance the string $str = $this->_getSubstr( $str , $pos + 1 ); } # we need to strip slashes for a quoted string $content = stripslashes($content); break; case "\r": $pos = 1; if( $str[1] == "\n") $pos++; $content_size = $pos; $content = $this->_getSubstr( $str , 0 , $pos ); $str = $this->_getSubstr( $str , $pos ); break; case "\n": $pos = 1; $content_size = $pos; $content = $this->_getSubstr( $str , 0 , $pos ); $str = $this->_getSubstr( $str , $pos ); break; case '(': if( $parenthesisIsToken == false ){ $pos = $this->_getClosingBracesPos( $str ); $content_size = $pos + 1; $content = $this->_getSubstr( $str , 0 , $pos + 1 ); $str = $this->_getSubstr( $str , $pos + 1 ); }else{ $pos = 1; $content_size = $pos; $content = $this->_getSubstr( $str , 0 , $pos ); $str = $this->_getSubstr( $str , $pos ); } break; case ')': $pos = 1; $content_size = $pos; $content = $this->_getSubstr( $str , 0 , $pos ); $str = $this->_getSubstr( $str , $pos ); break; case ' ': $pos = 1; $content_size = $pos; $content = $this->_getSubstr( $str , 0 , $pos ); $str = $this->_getSubstr( $str , $pos ); break; default: for( $pos = 0 ; $pos < $len ; $pos++ ){ if($this->_getSubstr( $str , 0 , 5 ) == 'BODY[' || $this->_getSubstr( $str , 0 , 5 ) == 'BODY.') { if($str[$pos] == ']') { $pos++; break; } } elseif ( $str[$pos] == ' ' || $str[$pos] == "\r" || $str[$pos] == ')' || $str[$pos] == '(' || $str[$pos] == "\n" ) { break; } if ( $str[$pos] == "\\" && $str[$pos + 1 ] == ' ' ) $pos++; if ( $str[$pos] == "\\" && $str[$pos + 1 ] == "\\" ) $pos++; } //Advance the string if( $pos == 0 ){ $content_size = 1; $content = $this->_getSubstr( $str , 0 , 1 ); $str = $this->_getSubstr( $str , 1 ); }else{ $content_size = $pos; $content = $this->_getSubstr( $str , 0 , $pos ); if($pos < $len){ $str = $this->_getSubstr( $str , $pos ); }else{ //if this is the end of the string... exit the switch break; } } break; } #error_log("egw-pear::NET::IMAPProtocoll:_getNextToken:".$str); return $content_size; } // ToDo: all real errors should be returned as PEAR error, others hidden by default // NO extra output from this class! /** * Utility funcion to display to console the protocol errors * printErrors() additionally has to be set to true * * @param string $str the error message * @param int $line the line producing the error * @param string $file file where the error was produced * * @return nothing * @access private * @since 1.0 */ function _prot_error($str , $line , $file, $printError = true) { if ($this->_printErrors && $printError) { echo "$line,$file,PROTOCOL ERROR!:$str\n"; } } function _getEXTarray(&$str , $startDelim = '(' , $stopDelim = ')'){ /* I let choose the $startDelim and $stopDelim to allow parsing the OK response so I also can parse a response like this * OK [UIDNEXT 150] Predicted next UID */ $this->_getNextToken( $str , $parenthesis ); if( $parenthesis != $startDelim ){ $this->_prot_error("must be a '$startDelim' but is a '$parenthesis' !!!!" , __LINE__ , __FILE__ ); } $parenthesis = ''; $struct_arr = array(); while( $parenthesis != $stopDelim && $str != '' ){ // The command $this->_getNextToken( $str , $token ); $token = strtoupper( $token ); if( ( $ret = $this->_retrParsedResponse( $str , $token ) ) != false ){ //$struct_arr[$token] = $ret; $struct_arr=array_merge($struct_arr, $ret); } $parenthesis=$token; }//While if( $parenthesis != $stopDelim ){ $this->_prot_error("1_must be a '$stopDelim' but is a '$parenthesis' !!!!" , __LINE__ , __FILE__ ); } return $struct_arr; } function _retrParsedResponse( &$str , $token, $previousToken = null) { //echo "\n\nTOKEN:$token\r\n"; $token = strtoupper($token); switch( $token ){ case "RFC822.SIZE" : return array($token=>$this->_parseOneStringResponse( $str,__LINE__ , __FILE__ )); break; // case "RFC822.TEXT" : // case "RFC822.HEADER" : case "RFC822" : return array($token=>$this->_parseContentresponse( $str , $token )); break; case "FLAGS" : case "PERMANENTFLAGS" : return array($token=>$this->_parseFLAGSresponse( $str )); break; case "ENVELOPE" : return array($token=>$this->_parseENVELOPEresponse( $str )); break; case "EXPUNGE" : return false; break; case 'NOMODSEQ': // ToDo: implement RFC 4551 return array($token=>''); break; case "UID" : case "UIDNEXT" : case "UIDVALIDITY" : case "UNSEEN" : case "MESSAGES" : case "UIDNEXT" : case "UIDVALIDITY" : case "UNSEEN" : case "INTERNALDATE" : return array($token=>$this->_parseOneStringResponse( $str,__LINE__ , __FILE__ )); break; case "BODY" : case "BODYSTRUCTURE" : return array($token=>$this->_parseBodyResponse( $str , $token )); break; case "RECENT" : if( $previousToken != null ){ $aux["RECENT"]=$previousToken; return $aux; }else{ return array($token=>$this->_parseOneStringResponse( $str,__LINE__ , __FILE__ )); } break; case "EXISTS" : return array($token=>$previousToken); break; case "READ-WRITE" : case "READ-ONLY" : return array($token=>$token); break; case "QUOTA" : /* A tipical GETQUOTA DIALOG IS AS FOLLOWS C: A0004 GETQUOTA user.damian S: * QUOTA user.damian (STORAGE 1781460 4000000) S: A0004 OK Completed another example of QUOTA response from GETQUOTAROOT: C: A0008 GETQUOTAROOT INBOX S: * QUOTAROOT INBOX "" S: * QUOTA "" (STORAGE 0 1024000 MESSAGE 0 40000) S: A0008 OK GETQUOTAROOT finished. RFC 2087 section 5.1 says the list could be empty: C: A0004 GETQUOTA user.damian S: * QUOTA user.damian () S: A0004 OK Completed quota_list ::= "(" #quota_resource ")" quota_resource ::= atom SP number SP number quota_response ::= "QUOTA" SP astring SP quota_list */ $mailbox = $this->_parseOneStringResponse( $str,__LINE__ , __FILE__ ); $ret_aux = array('MAILBOX'=>$this->utf_7_decode($mailbox)); // courier fix if ($str[0].$str[1] == "\r\n") { return array($token => $ret_aux); } // end courier fix $this->_parseSpace( $str , __LINE__ , __FILE__ ); $this->_parseString( $str , '(' , __LINE__ , __FILE__ ); // fetching quota resources ( BNF ::= #quota_resource but spce separated instead of comma) $this->_getNextToken($str, $quota_resp ); while ($quota_resp != ')') { if (($ext = $this->_retrParsedResponse($str, $quota_resp)) == false) { $this->_prot_error("bogus response!!!!" , __LINE__ , __FILE__ ); } $ret_aux=array_merge($ret_aux,$ext); $this->_getNextToken($str, $quota_resp); if ($quota_resp == ' ') { $this->_getNextToken($str, $quota_resp); } } // if empty list, apparently no STORAGE or MESSAGE quota set return array($token=>$ret_aux); break; case "QUOTAROOT" : /* A tipical GETQUOTA DIALOG IS AS FOLLOWS C: A0004 GETQUOTA user.damian S: * QUOTA user.damian (STORAGE 1781460 4000000) S: A0004 OK Completed */ $mailbox = $this->utf_7_decode($this->_parseOneStringResponse( $str,__LINE__ , __FILE__ )); $str_line = rtrim( substr( $this->_getToEOL( $str , false ) , 0 ) ); if(empty($str_line)) { $ret = @array( "MAILBOX"=>$this->utf_7_decode($mailbox)); } else { $quotaroot = $this->_parseOneStringResponse( $str_line,__LINE__ , __FILE__ ); $ret = @array( "MAILBOX"=>$this->utf_7_decode($mailbox) , $token=>$quotaroot ); } return array($token=>$ret); break; case "STORAGE" : $used = $this->_parseOneStringResponse( $str,__LINE__ , __FILE__ ); $qmax = $this->_parseOneStringResponse( $str,__LINE__ , __FILE__ ); return array($token=>array("USED"=> $used, "QMAX" => $qmax)); break; case "MESSAGE" : $mused = $this->_parseOneStringResponse( $str,__LINE__ , __FILE__ ); $mmax = $this->_parseOneStringResponse( $str,__LINE__ , __FILE__ ); return array($token=>array("MUSED"=> $mused, "MMAX" => $mmax)); break; case "LEVEL" : $lused = $this->_parseOneStringResponse( $str,__LINE__ , __FILE__ ); $lmax = $this->_parseOneStringResponse( $str,__LINE__ , __FILE__ ); return array($token=>array("LUSED"=> $lused, "LMAX" => $lmax)); break; case "MAILBOX" : $mbused = $this->_parseOneStringResponse( $str,__LINE__ , __FILE__ ); $mbmax = $this->_parseOneStringResponse( $str,__LINE__ , __FILE__ ); return array(); //throw away this information as this info seems quite useless with a QUOTA Response, AND we use the KEYWORD otherwise break; case "EXPIRATION" : $expused = $this->_parseOneStringResponse( $str,__LINE__ , __FILE__ ); $expmax = $this->_parseOneStringResponse( $str,__LINE__ , __FILE__ ); return array(); //throw away this information as this info seems quite useless break; case "FETCH" : $this->_parseSpace( $str ,__LINE__ ,__FILE__ ); // Get the parsed pathenthesis $struct_arr = $this->_getEXTarray( $str ); return $struct_arr; break; case "NAMESPACE" : $this->_parseSpace( $str , __LINE__ , __FILE__ ); $this->_getNextToken($str , $personal, false); $struct_arr['NAMESPACES']['personal'] = $this->_arrayfy_content($personal); $this->_parseSpace( $str , __LINE__ , __FILE__ ); $this->_getNextToken($str , $others, false); $struct_arr['NAMESPACES']['others'] = $this->_arrayfy_content($others); $this->_parseSpace( $str , __LINE__ , __FILE__ ); $this->_getNextToken($str , $shared, false); $struct_arr['NAMESPACES']['shared'] = $this->_arrayfy_content($shared); return array($token=>$struct_arr); break; case "CAPABILITY" : $this->_parseSpace( $str , __LINE__ , __FILE__ ); $str_line = rtrim( substr( $this->_getToEOL( $str , false ) , 0 ) ); $struct_arr["CAPABILITIES"] = explode( ' ' , $str_line ); return array($token=>$struct_arr); break; case "STATUS" : $mailbox = $this->_parseOneStringResponse( $str,__LINE__ , __FILE__ ); $this->_parseSpace( $str , __LINE__ , __FILE__ ); $ext = $this->_getEXTarray( $str ); $struct_arr["MAILBOX"] = $this->utf_7_decode($mailbox); $struct_arr["ATTRIBUTES"] = $ext; return array($token=>$struct_arr); break; case "LIST" : $this->_parseSpace( $str , __LINE__ , __FILE__ ); $params_arr = $this->_arrayfy_content( $str ); $this->_parseSpace( $str , __LINE__ , __FILE__ ); $this->_getNextToken( $str , $hierarchydelim ); $this->_parseSpace( $str,__LINE__ , __FILE__); $this->_getNextToken( $str , $mailbox_name ); $result_array = array( "NAME_ATTRIBUTES"=>$params_arr , "HIERACHY_DELIMITER"=>$hierarchydelim , "MAILBOX_NAME"=> $this->utf_7_decode($mailbox_name) ); return array($token=>$result_array); break; case "LSUB" : $this->_parseSpace( $str , __LINE__ , __FILE__ ); $params_arr = $this->_arrayfy_content( $str ); $this->_parseSpace( $str , __LINE__ , __FILE__ ); $this->_getNextToken( $str , $hierarchydelim ); $this->_parseSpace( $str,__LINE__ , __FILE__); $this->_getNextToken( $str , $mailbox_name ); $result_array = array( "NAME_ATTRIBUTES"=>$params_arr , "HIERACHY_DELIMITER"=>$hierarchydelim , "MAILBOX_NAME"=> $this->utf_7_decode($mailbox_name) ); return array($token=>$result_array); break; case "SEARCH" : case 'SORT': $str_line = rtrim( substr( $this->_getToEOL( $str , false ) , 1) ); $struct_arr[$token.'_LIST'] = explode(' ', $str_line); if (count($struct_arr[$token.'_LIST']) == 1 && $struct_arr[$token.'_LIST'][0]=='') { $struct_arr[$token.'_LIST'] = null; } return array($token=>$struct_arr); break; case "OK" : /* TODO: parse the [ .... ] part of the response, use the method _getEXTarray(&$str,'[',$stopDelim=']') */ $str_line = rtrim( substr( $this->_getToEOL( $str , false ) , 1 ) ); if($str_line[0] == '[' ){ $braceLen=$this->_getClosingBracesPos($str_line, '[', ']' ); $str_aux='('. substr($str_line,1,$braceLen -1). ')'; $ext_arr=$this->_getEXTarray($str_aux); //$ext_arr=array($token=>$this->_getEXTarray($str_aux)); }else{ //$ext_arr=$str_line; $ext_arr=array($token=>$str_line); } $result_array = $ext_arr; return $result_array; break; case "NO" : /* TODO: parse the [ .... ] part of the response, use the method _getEXTarray(&$str,'[',$stopDelim=']') */ $str_line = rtrim( substr( $this->_getToEOL( $str , false ) , 1 ) ); $result_array[] = @array( "COMMAND"=>$token , "EXT"=>$str_line ); return $result_array; break; case "BAD" : /* TODO: parse the [ .... ] part of the response, use the method _getEXTarray(&$str,'[',$stopDelim=']') */ $str_line = rtrim( substr( $this->_getToEOL( $str , false ) , 1 ) ); $result_array[] = array( "COMMAND"=>$token , "EXT"=>$str_line ); return $result_array; break; case "BYE" : /* TODO: parse the [ .... ] part of the response, use the method _getEXTarray(&$str,'[',$stopDelim=']') */ $str_line = rtrim( substr( $this->_getToEOL( $str , false ) , 1 ) ); $result_array[] = array( "COMMAND"=>$token , "EXT"=> $str_line ); return $result_array; break; case "LISTRIGHTS" : $this->_parseSpace( $str ,__LINE__ , __FILE__ ); $this->_getNextToken( $str , $mailbox ); $this->_parseSpace( $str , __LINE__ , __FILE__ ); $this->_getNextToken( $str , $user ); $this->_parseSpace( $str , __LINE__ , __FILE__ ); $this->_getNextToken( $str , $granted ); $ungranted = explode( ' ' , rtrim( substr( $this->_getToEOL( $str , false ) , 1 ) ) ); $result_array = @array( "MAILBOX"=>$this->utf_7_decode($mailbox) , "USER"=>$user , "GRANTED"=>$granted , "UNGRANTED"=>$ungranted ); return $result_array; break; case "MYRIGHTS" : $this->_parseSpace( $str , __LINE__ , __FILE__ ); $this->_getNextToken( $str ,$mailbox ); // Patch to handle the alternate MYRIGHTS response from Courier-IMAP if ($str==')'){ $granted = $mailbox; $mailbox = $this->currentMailbox; }else{ $this->_parseSpace( $str , __LINE__ , __FILE__ ); $this->_getNextToken( $str , $granted ); } // End Patch $result_array = array( "MAILBOX"=>$this->utf_7_decode($mailbox) , "GRANTED"=>$granted ); return $result_array; break; case 'ACL': /* RFC 4314: acl-data = "ACL" SP mailbox *(SP identifier SP rights) identifier = astring rights = astring ;; only lowercase ASCII letters and digits are allowed. */ //$str = " INBOX\r\nA0006 OK Completed\r\n"; $this->_parseSpace($str, __LINE__, __FILE__); $this->_getNextToken($str, $mailbox); $arr = array(); while (substr($str, 0, 2) != "\r\n") { $this->_parseSpace($str, __LINE__, __FILE__); $this->_getNextToken($str, $acl_user); $this->_parseSpace($str, __LINE__, __FILE__); $this->_getNextToken($str, $acl_rights); $arr[] = array('USER'=>$acl_user, 'RIGHTS'=>$acl_rights); } $result_array = array('MAILBOX'=>$this->utf_7_decode($mailbox), 'USERS'=>$arr); return $result_array; break; case "ANNOTATION" : $this->_parseSpace($str, __LINE__, __FILE__); $this->_getNextToken($str, $mailbox); $this->_parseSpace($str, __LINE__, __FILE__); $this->_getNextToken($str, $entry); $this->_parseSpace($str, __LINE__, __FILE__); $attrs = $this->_arrayfy_content($str); $result_array = array('MAILBOX' => $mailbox, 'ENTRY' => $entry , 'ATTRIBUTES' => $attrs); return $result_array; break; case "": $this->_prot_error( "PROTOCOL ERROR!:str empty!!" , __LINE__ , __FILE__ ); break; case "(": $this->_prot_error("OPENING PARENTHESIS ERROR!!!!!!!!!!!!!!!!!" , __LINE__ , __FILE__ ); break; case ")": //"CLOSING PARENTHESIS BREAK!!!!!!!" break; case "\r\n": $this->_prot_error("BREAK!!!!!!!!!!!!!!!!!" , __LINE__ , __FILE__ ); break; case ' ': // this can happen and we just ignore it // This happens when - for example - fetch returns more than 1 parammeter // for example you ask to get RFC822.SIZE and UID //$this->_prot_error("SPACE BREAK!!!!!!!!!!!!!!!!!" , __LINE__ , __FILE__ ); break; default: $body_token=strtoupper(substr($token,0,5)); $rfc822_token=strtoupper(substr($token,0,7)); if( $body_token == 'BODY[' || $body_token == 'BODY.' || $rfc822_token == 'RFC822.' ) { //echo "TOKEN:$token\n"; //$this->_getNextToken( $str , $mailbox ); return array($token=>$this->_parseContentresponse( $str , $token )); }else{ $this->_prot_error( "UNIMPLEMMENTED! I don't know the parameter '$token' !!!" , __LINE__ , __FILE__ ); } break; } return false; } /* * Verifies that the next character IS a space */ function _parseSpace(&$str, $line, $file, $printError = true) { /* This code repeats a lot in this class so i make it a function to make all the code shorter */ $this->_getNextToken( $str , $space ); if( $space != ' ' ){ $this->_prot_error("must be a ' ' but is a '$space' !!!!" , $line , $file,$printError ); } return $space; } function _parseString( &$str , $char , $line , $file ) { /* This code repeats a lot in this class so i make it a function to make all the code shorter */ $this->_getNextToken( $str , $char_aux ); if( strtoupper($char_aux) != strtoupper( $char ) ){ $this->_prot_error("must be a $char but is a '$char_aux' !!!!", $line , $file ); } return $char_aux; } function _genericImapResponseParser( &$str , $cmdid = null ) { $result_array=array(); if( $this->_unParsedReturn ){ $unparsed_str = $str; } $this->_getNextToken($str, $token); #error_log(" egw-pear::NET::IMAPProtocoll:_genericIMAPResponseParser: After retrieving the first token:".$token); while ($token != $cmdid && $str != '') { if ($token == '+' ) { //if the token is + ignore the line // TODO: verify that this is correct!!! $this->_getToEOL($str); $this->_getNextToken($str, $token); } $this->_parseString($str, ' ', __LINE__, __FILE__); $this->_getNextToken($str, $token); if ($token == '+') { $this->_getToEOL($str); $this->_getNextToken($str, $token); } else { if (is_numeric($token)) { // The token is a NUMBER so I store it $msg_nro = $token; $this->_parseSpace($str, __LINE__, __FILE__); // I get the command $this->_getNextToken($str, $command); if (($ext_arr = $this->_retrParsedResponse($str, $command, $msg_nro)) == false) { // if this bogus response cis a FLAGS () or EXPUNGE response // the ignore it if ($command != 'FLAGS' && $command != 'EXPUNGE') { $this->_prot_error("bogus response!!!!" , __LINE__ , __FILE__, false); } } $result_array[] = array('COMMAND'=>$command, 'NRO'=>$msg_nro, 'EXT'=>$ext_arr); } else { // OK the token is not a NUMBER so it MUST be a COMMAND $command = $token; /* Call the parser return the array take care of bogus responses! */ if (($ext_arr = $this->_retrParsedResponse($str, $command)) == false) { $this->_prot_error("bogus response!!!! (COMMAND:$command)", __LINE__, __FILE__); } $result_array[] = array('COMMAND'=>$command, 'EXT'=>$ext_arr); } } $this->_getNextToken($str, $token); $token = strtoupper($token); if( $token != "\r\n" && $token != '' ){ $this->_prot_error("PARSE ERROR!!! must be a '\\r\\n' here but is a '$token'!!!! (getting the next line)|STR:|$str|" , __LINE__ , __FILE__ ); } $this->_getNextToken( $str , $token ); if($token == "+" ){ //if the token is + ignore the line // TODO: verify that this is correct!!! $this->_getToEOL( $str ); $this->_getNextToken( $str , $token ); } }//While // OK we finish the UNTAGGED Response now we must parse the FINAL TAGGED RESPONSE //TODO: make this a litle more elegant! $this->_parseSpace( $str , __LINE__ , __FILE__, false ); $this->_getNextToken( $str , $cmd_status ); $str_line = rtrim (substr( $this->_getToEOL( $str ) , 1 ) ); $response["RESPONSE"]=array( "CODE"=>$cmd_status , "STR_CODE"=>$str_line , "CMDID"=>$cmdid ); $ret=$response; if( !empty($result_array)){ $ret=array_merge($ret,array("PARSED"=>$result_array) ); } if( $this->_unParsedReturn ){ $unparsed["UNPARSED"]=$unparsed_str; $ret=array_merge($ret,$unparsed); } if( isset($status_arr) ){ $status["STATUS"]=$status_arr; $ret=array_merge($ret,$status); } return $ret; } function _genericCommand($command, $params = '') { if( !$this->_connected ){ return new PEAR_Error( "not connected! (CMD:$command)" ); } $cmdid = $this->_getCmdId(); $this->_putCMD( $cmdid , $command , $params ); $args=$this->_getRawResponse( $cmdid ); #error_log("egw-pear::NET::IMAPProtocoll:_genericCommand:".$command." result:".print_r($args,TRUE)); return $this->_genericImapResponseParser( $args , $cmdid ); } function utf_7_encode($str) { if($this->_useUTF_7 == false ){ return $str; } if(function_exists('mb_convert_encoding')) { return mb_convert_encoding($str, "UTF7-IMAP", "ISO-8859-1"); } $encoded_utf7 = ''; $base64_part = ''; if(is_array($str)){ return new PEAR_Error('error'); } for ($i = 0; $i < $this->_getLineLength($str); $i++) { //those chars should be base64 encoded if ( ((ord($str[$i]) >= 39 ) and (ord($str[$i]) <= 126 )) or ((ord($str[$i]) >= 32 ) and (ord($str[$i]) <= 37 )) ) { if ($base64_part) { $encoded_utf7 = sprintf("%s&%s-", $encoded_utf7, str_replace('=', '',base64_encode($base64_part)) ); $base64_part = ''; } $encoded_utf7 = sprintf("%s%s",$encoded_utf7 , $str[$i]); } else { //handle & if (ord($str[$i]) == 38 ) { if ($base64_part) { $encoded_utf7 = sprintf("%s&%s-", $encoded_utf7, str_replace('=', '',base64_encode($base64_part)) ); $base64_part = ''; } $encoded_utf7 = sprintf("%s&-", $encoded_utf7 ); } else { $base64_part = sprintf("%s%s",$base64_part , $str[$i]); //$base64_part = sprintf("%s%s%s",$base64_part , chr(0) , $str[$i]); } } } if ($base64_part) { $encoded_utf7 = sprintf("%s&%s-", $encoded_utf7, str_replace('=', '',base64_encode($base64_part)) ); $base64_part = ''; } return $encoded_utf7; } function utf_7_decode($str) { if($this->_useUTF_7 == false ){ return $str; } //return imap_utf7_decode($str); if(function_exists('mb_convert_encoding')) { return mb_convert_encoding($str, "ISO-8859-1", "UTF7-IMAP"); } $base64_part = ''; $decoded_utf7 = ''; for ($i = 0; $i < $this->_getLineLength($str); $i++) { if ( $this->_getLineLength($base64_part) > 0 ) { if ($str[$i] == '-') { if ($base64_part == '&') { $decoded_utf7 = sprintf("%s&" , $decoded_utf7 ); } else { $next_part_decoded= base64_decode( substr( $base64_part, 1 ) ) ; $decoded_utf7 = sprintf("%s%s", $decoded_utf7 , $next_part_decoded ); } $base64_part = ''; } else { $base64_part = sprintf("%s%s", $base64_part , $str[$i] ); } } else { if ($str[$i] == '&') { $base64_part = '&'; } else { $decoded_utf7 = sprintf("%s%s", $decoded_utf7 , $str[$i] ); } } } return $decoded_utf7; } /** * Make CREATE/RENAME compatible option params * * @param array $options options to format * @return string Returns a string for formatted parameters * * @access private * @since 1.1 */ function _getCreateParams($options) { $args = ""; if(is_null($options) === false && is_array($options) === true) { foreach($options as $opt => $data) { switch(strtoupper($opt)) { case "PARTITION": $args .= sprintf(" %s",$this->utf_7_encode($data)); break; default: // ignore any unknown options break; } } } return $args; } /** * Return true if the TLS negotiation was successful * * @access public * @return mixed true on success, PEAR_Error on failure */ function cmdStartTLS() { if (PEAR::isError($res = $this->_genericCommand("STARTTLS"))) { return $res; } if(stream_socket_enable_crypto($this->_socket->fp, true, STREAM_CRYPTO_METHOD_TLS_CLIENT) == false) { $msg = 'Failed to establish TLS connection'; return new PEAR_Error($msg); } if($this->_debug === true) { echo "STARTTLS Negotiation Successful\n"; } // RFC says we need to query the server capabilities again if(PEAR::isError($res = $this->cmdCapability() )) { $msg = 'Failed to connect, server said: ' . $res->getMessage(); return new PEAR_Error($msg); } return true; } function _getLineLength($string) { if (extension_loaded('mbstring')) { return mb_strlen($string,'latin1'); } else { return strlen($string); } } function _getSubstr($string, $start, $length = false) { if (extension_loaded('mbstring')) { if($length !== false) { return mb_substr($string, $start, $length, 'latin1'); } else { $strlen = mb_strlen($string,'latin1'); return mb_substr($string, $start, $strlen, 'latin1'); } } else { if($length !== false) { return substr($string, $start, $length); } else { return substr($string, $start); } } } }//Class ?>