| Server IP : 37.220.80.31 / Your IP : 3.137.167.86 Web Server : Apache/2.4.52 (Ubuntu) System : Linux 3051455-guretool.twc1.net 5.15.0-107-generic #117-Ubuntu SMP Fri Apr 26 12:26:49 UTC 2024 x86_64 User : www-root ( 1010) PHP Version : 7.4.33 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority, MySQL : OFF | cURL : ON | WGET : OFF | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /var/www/www-root/data/www/dev.artlot24.ru/bitrix/modules/esol.importexportexcel/lib/mail/ |
Upload File : |
<?php
namespace Bitrix\KdaImportexcel;
use Bitrix\Main\Text\Encoding;
use Bitrix\Main\Localization\Loc;
Loc::loadMessages(__FILE__);
class Imap
{
const ERR_CONNECT = 101;
const ERR_REJECTED = 102;
const ERR_COMMUNICATE = 103;
const ERR_EMPTY_RESPONSE = 104;
const ERR_BAD_SERVER = 105;
const ERR_STARTTLS = 201;
const ERR_COMMAND_REJECTED = 202;
const ERR_CAPABILITY = 203;
const ERR_AUTH = 204;
const ERR_AUTH_MECH = 205;
const ERR_LIST = 206;
const ERR_SELECT = 207;
const ERR_SEARCH = 208;
const ERR_FETCH = 209;
const ERR_APPEND = 210;
const ERR_STORE = 211;
protected $stream;
protected $options = array();
protected $sessState;
protected $sessCounter = 0;
protected $sessCapability;
protected $sessUntagged = array();
protected $sessMailbox = array(
'name' => null,
'exists' => null,
'uidvalidity' => null,
);
protected static $atomRegex = '[^\x00-\x20\x22\x25\x28-\x2a\x5c\x5d\x7b\x7f-\xff]+';
protected static $qcharRegex = '[^\x00\x0a\x0d\x22\x5c\x80-\xff]|\x5c[\x5c\x22]';
protected static $astringRegex = '[^\x00-\x20\x22\x25\x28-\x2a\x5c\x7b\x7f-\xff]+';
public function __construct($host, $port, $tls, $strict, $login, $password, $encoding)
{
$strict = PHP_VERSION_ID < 50600 ? false : (bool) $strict;
$this->options = array(
'host' => $host,
'port' => $port,
'tls' => $tls,
'socket' => sprintf('%s://%s:%s', ($tls ? 'tls' : 'tcp'), $host, $port),
'timeout' => 10,
'context' => stream_context_create(array(
'ssl' => array(
'verify_peer' => $strict,
'verify_peer_name' => $strict
)
)),
'login' => $login,
'password' => $password,
'encoding' => $encoding,
);
}
public function getState()
{
return $this->sessState;
}
protected function connect(&$error)
{
$error = null;
if ($this->sessState)
return true;
$resource = @stream_socket_client(
$this->options['socket'], $errno, $errstr, $this->options['timeout'],
STREAM_CLIENT_CONNECT, $this->options['context']
);
if ($resource === false)
{
$error = static::errorMessage(Imap::ERR_CONNECT, $errno ?: null);
return false;
}
$this->stream = $resource;
stream_set_timeout($this->stream, $this->options['timeout']);
$prompt = $this->readLine();
if ($prompt !== false && preg_match('/^\* (OK|PREAUTH)/i', $prompt, $matches))
{
if ($matches[1] == 'OK')
$this->sessState = 'no_auth';
elseif ($matches[1] == 'PREAUTH')
$this->sessState = 'auth';
}
else
{
fclose($this->stream);
unset($this->stream);
if ($prompt === false)
$error = Imap::ERR_EMPTY_RESPONSE;
elseif (preg_match('/^\* BYE/i', $prompt))
$error = Imap::ERR_REJECTED;
else
$error = Imap::ERR_BAD_SERVER;
$error = static::errorMessage(array(Imap::ERR_CONNECT, $error));
return false;
}
if (!$this->capability($error))
return false;
if (!$this->options['tls'] && preg_match('/ \x20 STARTTLS ( \x20 | \r\n ) /ix', $this->sessCapability))
{
if (!$this->starttls($error))
return false;
}
return true;
}
protected function starttls(&$error)
{
$error = null;
if (!$this->sessState)
{
$error = static::errorMessage(Imap::ERR_STARTTLS);
return false;
}
$this->executeCommand('STARTTLS', $error);
if (!$error)
{
if (stream_socket_enable_crypto($this->stream, true, STREAM_CRYPTO_METHOD_TLS_CLIENT))
{
if (!$this->capability($error))
return false;
}
else
{
fclose($this->stream);
unset($this->stream);
$error = static::errorMessage(Imap::ERR_STARTTLS);
return false;
}
}
return true;
}
protected function capability(&$error)
{
$error = null;
if (!$this->sessState)
{
$error = static::errorMessage(Imap::ERR_CAPABILITY);
return false;
}
$response = $this->executeCommand('CAPABILITY', $error);
if ($error)
{
$error = $error == Imap::ERR_COMMAND_REJECTED ? null : $error;
$error = static::errorMessage(array(Imap::ERR_CAPABILITY, $error), $response);
return false;
}
$regex = '/^ \* \x20 CAPABILITY /ix';
foreach ($this->getUntagged($regex, true) as $item)
$this->sessCapability = $item[0];
return true;
}
protected function authenticate(&$error)
{
$error = null;
if (!$this->connect($error))
return false;
if (in_array($this->sessState, array('auth', 'select')))
return true;
$mech = false;
if (preg_match('/ \x20 AUTH=PLAIN ( \x20 | \r\n ) /ix', $this->sessCapability))
$mech = 'plain';
elseif (!preg_match('/ \x20 LOGINDISABLED ( \x20 | \r\n ) /ix', $this->sessCapability))
$mech = 'login';
if (!$mech)
{
$error = static::errorMessage(array(Imap::ERR_AUTH, Imap::ERR_AUTH_MECH));
return false;
}
if ($mech == 'plain')
{
$response = $this->executeCommand('AUTHENTICATE PLAIN', $error);
if (strpos($response, '+') !== 0)
{
$error = $error == Imap::ERR_COMMAND_REJECTED ? Imap::ERR_AUTH_MECH : $error;
$error = static::errorMessage(array(Imap::ERR_AUTH, $error), $response);
return false;
}
$response = $this->exchange(base64_encode(sprintf(
"\x00%s\x00%s", $this->options['login'], $this->options['password']
)), $error);
}
else // if ($mech == 'login')
{
$response = $this->executeCommand(sprintf(
'LOGIN %s %s',
static::prepareString($this->options['login']),
static::prepareString($this->options['password'])
), $error);
}
if ($error)
{
$error = $error == Imap::ERR_COMMAND_REJECTED ? null : $error;
$error = static::errorMessage(array(Imap::ERR_AUTH, $error), $response);
return false;
}
$this->sessState = 'auth';
if (!$this->capability($error))
return false;
return true;
}
protected function select($mailbox, &$error)
{
$error = null;
if (!$this->authenticate($error))
return false;
if ($this->sessState == 'select' && $mailbox == $this->sessMailbox['name'])
return true;
$response = $this->executeCommand(sprintf(
'SELECT "%s"', /*$this->encodeUtf7Imap($mailbox)*/ $mailbox
), $error);
if ($error)
{
$error = $error == Imap::ERR_COMMAND_REJECTED ? null : $error;
$error = static::errorMessage(array(Imap::ERR_SELECT, $error), $response);
return false;
}
$this->sessState = 'select';
$this->sessMailbox['name'] = $mailbox;
$regex = '/^ \* \x20 ( \d+ ) \x20 EXISTS /ix';
foreach ($this->getUntagged($regex, true) as $item)
$this->sessMailbox['exists'] = $item[1][1];
$regex = '/^ \* \x20 OK \x20 \[ UIDVALIDITY \x20 ( \d+ ) \] /ix';
foreach ($this->getUntagged($regex, true) as $item)
$this->sessMailbox['uidvalidity'] = $item[1][1];
if (!$this->capability($error))
return false;
return true;
}
/**
* Connects to server and authenticate client
*
* @param string &$error Error message.
* @return boolean
*/
public function singin(&$error)
{
$error = null;
return $this->authenticate($error);
}
/**
* Returns unseen messages count
*
* @param string $mailbox Mailbox name.
* @param string &$error Error message.
* @return int|false
*/
public function getUnseen($mailbox, &$error)
{
$error = null;
if (!$this->select($mailbox, $error))
return false;
$unseen = 0;
$response = $this->executeCommand('SEARCH UNSEEN', $error);
if ($error)
{
$error = $error == Imap::ERR_COMMAND_REJECTED ? null : $error;
$error = static::errorMessage(array(Imap::ERR_SEARCH, $error), $response);
return false;
}
$regex = '/^ \* \x20 SEARCH ( (?: \x20 \d+ )* ) /ix';
foreach ($this->getUntagged($regex, true) as $item)
$unseen = preg_match_all('/\d+/', $item[1][1], $dummy);
return $unseen;
}
/**
* Returns unseen messages count
*
* @param string $mailbox Mailbox name.
* @param string &$error Error message.
* @return int|false
*/
public function getSearch($mailbox, $arCriterias, &$error)
{
$error = null;
if (!$this->select($mailbox, $error))
return false;
$command = 'SEARCH CHARSET '.$this->options['encoding'];
$endCommand = '';
if($arCriterias['UNSEEN']=='Y') $command .= ' UNSEEN';
if($arCriterias['SINCE']) $command .= sprintf(' SINCE "%s"', $arCriterias['SINCE']);
//if($this->SupportExtCriteria() && $arCriterias['FROM']) $command .= sprintf(' FROM "%s"', $arCriterias['FROM']);
if($this->SupportExtCriteria() && $arCriterias['FROM'])
{
if(strpos($arCriterias['FROM'], ',')!==false)
{
$arEmail = array_map('trim', explode(',', $arCriterias['FROM']));
$subcommand = '';
foreach($arEmail as $k=>$email)
{
if($k==0) $subcommand = sprintf('FROM "%s"', $email);
else $subcommand = 'OR '.$subcommand.sprintf(' FROM "%s"', $email);
}
$command .= ' '.$subcommand;
}
else $command .= sprintf(' FROM "%s"', $arCriterias['FROM']);
}
if($this->SupportExtCriteria() && $arCriterias['SUBJECT'])
{
if(!function_exists('mb_strlen'))
{
$command .= sprintf(' SUBJECT "%s"', $arCriterias['SUBJECT']);
}
else
{
$command .= ' SUBJECT {'.mb_strlen($arCriterias['SUBJECT'], 'CP1251').'}';
$endCommand .= "\x00".$arCriterias['SUBJECT'];
}
}
if($this->SupportExtCriteria() && $arCriterias['BODY']) $command .= sprintf(' BODY "%s"', $arCriterias['BODY']);
$response = $this->executeCommand($command.$endCommand, $error);
if ($error)
{
$error = $error == Imap::ERR_COMMAND_REJECTED ? null : $error;
$error = static::errorMessage(array(Imap::ERR_SEARCH, $error), $response);
return false;
}
$arUids = array();
$regex = '/^ \* \x20 SEARCH ( (?: \x20 \d+ )* ) /ix';
foreach ($this->getUntaggedSearch(true) as $item)
$arUids = array_values(array_diff(array_map('intval', explode(' ', $item[1][1])), array(0)));
if(!$this->SupportExtCriteria() && (strlen($arCriterias['FROM']) > 0 || strlen($arCriterias['SUBJECT']) > 0))
{
$i = count($arUids) - 1;
while($i>=0)
{
$uid = $arUids[$i];
$header = $this->getMessage($mailbox, $uid, 'HEADER', $error);
if($header!==false
&& (strlen($arCriterias['FROM'])==0 || strpos(ToLower($header->GetHeader('FROM')), ToLower($arCriterias['FROM']))!==false || (strpos($arCriterias['FROM'], ',')!==false && ($arEmail = array_map('ToLower', array_map('trim', explode(',', $arCriterias['FROM'])))) && in_array(ToLower($header->GetHeader('FROM')), $arEmail)))
&& (strlen($arCriterias['SUBJECT'])==0 || strpos(ToLower($header->GetHeader('SUBJECT')), ToLower($arCriterias['SUBJECT']))!==false)
&& (strlen($arCriterias['FILENAME'])==0 || $arCriterias['FILENAME_REGEXP']=='Y' || $this->getMessageFile($mailbox, $uid, $arCriterias, array('txt', 'csv', 'xls', 'xlsx', 'xlsm', 'zip', 'gz', 'tgz', 'rar'), $error)!==false))
{
return array($uid);
}
$i--;
}
return array();
}
return $arUids;
}
public function SupportExtCriteria()
{
$support = true;
if(ToLower($this->options['host'])=='imap.mail.ru')
{
$support = false;
}
return $support;
}
/**
* Returns mailboxes list
*
* @param string $mailbox Mailbox name pattern.
* @param string &$error Error message.
* @return array|false
*/
public function listMailboxes($mailbox, &$error)
{
$error = null;
if (!$this->authenticate($error))
return false;
$mailbox = str_replace('*', '%', $mailbox, $recursive);
$response = $this->executeCommand(sprintf(
'LIST "" "%s"', $this->encodeUtf7Imap($mailbox)
), $error);
if ($error)
{
$error = $error == Imap::ERR_COMMAND_REJECTED ? null : $error;
$error = static::errorMessage(array(Imap::ERR_LIST, $error), $response);
return false;
}
$list = array();
$regex = sprintf(
'/^ \* \x20 LIST \x20
\( (?<flags> ( \x5c? %1$s ( \x20 \x5c? %1$s )* )? ) \) \x20
(?<delim> NIL | " ( %2$s ) " ) \x20
(?<name> \{ \d+ \} | " ( %2$s )* " | %3$s ) \r\n
/ix',
self::$atomRegex, self::$qcharRegex, self::$astringRegex
);
foreach ($this->getUntagged($regex, true) as $item)
{
list($item, $matches) = $item;
$sflags = $matches['flags'];
$sdelim = $matches['delim'];
$sname = $matches['name'];
if (preg_match('/^ " ( .+ ) " $/ix', $sdelim, $quoted))
$sdelim = static::unescapeQuoted($quoted[1]);
if (preg_match('/^ \{ ( \d+ ) \} $/ix', $sname, $literal))
$sname = \CUtil::binSubstr($item, \CUtil::binStrlen($matches[0]), $literal[1]);
elseif (preg_match('/^ " ( .* ) " $/ix', $sname, $quoted))
$sname = static::unescapeQuoted($quoted[1]);
$list[] = array(
'flags' => $sflags,
'delim' => strtoupper($sdelim) == 'NIL' ? null : $sdelim,
'name' => $this->decodeUtf7Imap($sname),
'key' => $sname,
);
}
if ($recursive > 0)
{
foreach ($list as $i => $item)
{
if (!preg_match('/ ( ^ | \x20 ) \x5c ( Noinferiors | HasNoChildren ) ( \x20 | $ ) /ix', $item['flags']))
{
$children = $this->listMailboxes(sprintf('%s%s*', $item['name'], $item['delim']), $error);
if ($children === false)
return false;
if (!empty($children))
$list[$i]['children'] = $children;
}
}
}
return $list;
}
public function listMessages($mailbox, &$uidtoken, &$error)
{
$error = null;
if (!$this->select($mailbox, $error))
return false;
$uidtoken = $this->sessMailbox['uidvalidity'];
$list = array();
if ($this->sessMailbox['exists'] > 0)
{
$response = $this->executeCommand(
$this->sessMailbox['uidvalidity'] > 0
? 'FETCH 1:* (UID INTERNALDATE RFC822.SIZE FLAGS)'
: 'FETCH 1:* (INTERNALDATE RFC822.SIZE FLAGS)',
$error
);
if ($error)
{
$error = $error == Imap::ERR_COMMAND_REJECTED ? null : $error;
$error = static::errorMessage(array(Imap::ERR_FETCH, $error), $response);
return false;
}
$regex = '/^ \* \x20 (?<id> \d+ ) \x20 FETCH \x20 \( (?<data> .+ ) \) \r\n $/isx';
foreach ($this->getUntagged($regex, true) as $item)
{
$data = array(
'id' => $item[1]['id'],
'uid' => null,
'date' => null,
'size' => null,
);
$regex = '/ ( ^ | \x20 ) UID \x20 (?<uid> \d+ ) ( \x20 | $ ) /ix';
if (preg_match($regex, $item[1]['data'], $matches))
$data['uid'] = $matches['uid'];
$regex = sprintf(
'/ ( ^ | \x20 ) INTERNALDATE \x20 " (?<date> ( %s )+ ) " ( \x20 | $ ) /ix',
self::$qcharRegex
);
if (preg_match($regex, $item[1]['data'], $matches))
$data['date'] = $matches['date'];
$regex = '/ ( ^ | \x20 ) RFC822\.SIZE \x20 (?<size> \d+ ) ( \x20 | $ ) /ix';
if (preg_match($regex, $item[1]['data'], $matches))
$data['size'] = $matches['size'];
$regex = sprintf(
'/ ( ^ | \x20 ) FLAGS \x20 \( (?<flags> ( \x5c? %1$s ( \x20 \x5c? %1$s )* )? ) \) ( \x20 | $ ) /ix',
self::$atomRegex
);
if (preg_match($regex, $item[1]['data'], $matches))
$data['flags'] = $matches['flags'];
$list[] = $data;
}
}
return $list;
}
/**
* Adds message
*
* @param string $mailbox Mailbox name.
* @param string $data Message.
* @param string &$error Error message.
* @return string|false
*/
public function addMessage($mailbox, $data, &$error)
{
$error = null;
if (!$this->authenticate($error))
return false;
$response = $this->executeCommand(sprintf(
'APPEND "%s" (\Seen) %s',
$this->encodeUtf7Imap($mailbox),
static::prepareString($data)
), $error);
if ($error)
{
$error = $error == Imap::ERR_COMMAND_REJECTED ? null : $error;
$error = static::errorMessage(array(Imap::ERR_APPEND, $error), $response);
return false;
}
$regex = sprintf('/^ OK \x20 \[ APPENDUID \x20 ( \d+ ) \x20 ( \d+ ) \] /ix', $this->getTag());
if (preg_match($regex, $response, $matches))
return sprintf('%u:%u', $matches[1], $matches[2]);
return true;
}
public function moveMessageToFolder($mailbox, $newMailbox, $id, &$error)
{
$error = null;
if (!$this->select($mailbox, $error))
return false;
$response = $this->executeCommand(sprintf('MOVE %u "%s"', $id, $newMailbox), $error);
if(stripos(trim($response), 'OK')===0) return true;
return false;
}
public function updateMessageFlags($mailbox, $id, $flags, &$error)
{
$error = null;
if (!$this->select($mailbox, $error))
return false;
$addFlags = array();
$delFlags = array();
foreach ($flags as $name => $value)
{
if (preg_match(sprintf('/ ^ \x5c? %s $ /ix', self::$atomRegex), $name))
{
if ($value)
$addFlags[] = $name;
else
$delFlags[] = $name;
}
}
if ($addFlags)
$response = $this->executeCommand(sprintf('STORE %u +FLAGS (%s)', $id, join(' ', $addFlags)), $error);
if (!$error && $delFlags)
$response = $this->executeCommand(sprintf('STORE %u -FLAGS (%s)', $id, join(' ', $delFlags)), $error);
if ($error)
{
$error = $error == Imap::ERR_COMMAND_REJECTED ? null : $error;
$error = static::errorMessage(array(Imap::ERR_STORE, $error), $response);
return false;
}
$this->getUntagged(sprintf('/^ \* \x20 %u \x20 FETCH \x20 \( .+ \) \r\n $/isx', $id), true);
return true;
}
/**
* Returns message
*
* @param string $mailbox Mailbox name.
* @param int $id Message ID.
* @param string $section Message section.
* @param string &$error Error message.
* @return string|false
*/
public function getMessage($mailbox, $id, $section, &$error)
{
$error = null;
if (!$this->select($mailbox, $error))
return false;
$fullData = false;
if($section=='DATA')
{
$section=='TEXT';
$fullData = true;
}
if (!in_array(strtoupper($section), array('HEADER', 'TEXT')))
$section = '';
$response = $this->executeCommand(sprintf('FETCH %u (BODY.PEEK[%s])', $id, $section), $error);
if ($error)
{
$error = $error == Imap::ERR_COMMAND_REJECTED ? null : $error;
$error = static::errorMessage(array(Imap::ERR_FETCH, $error), $response);
return false;
}
$sbody = false;
$regex = sprintf('/^ \* \x20 %u \x20 FETCH \x20 \( (?<data> .+ ) \) \r\n $/isx', $id);
foreach ($this->getUntagged($regex, true) as $item)
{
$data = $item[1]['data'];
$sbody = false;
$regex = sprintf('/ ( ^ | \x20 ) BODY \[%s\] \x20 NIL ( \x20 | $ ) /ix', $section);
if (preg_match($regex, $data))
{
$sbody = null;
continue;
}
$regex = sprintf(
'/ ( ^ | \x20 ) BODY \[%s\] \x20 " (?<body> ( %s )* ) " ( \x20 | $ ) /ix',
$section, self::$qcharRegex
);
if (preg_match($regex, $data, $quoted))
{
$sbody = static::unescapeQuoted($quoted['body']);
continue;
}
$regex = sprintf('/ ( ^ | \x20 ) BODY \[%s\] \x20 \{ (?<size> \d+ ) \} \r\n /ix', $section);
if (preg_match($regex, $data, $literal, PREG_OFFSET_CAPTURE))
{
$sbody = \CUtil::binSubstr($data, $literal[0][1]+\CUtil::binStrlen($literal[0][0]), $literal['size'][0]);
continue;
}
}
if($section=='HEADER')
{
list($header, $htmlBody, $textBody, $parts) = \Bitrix\KdaImportexcel\MailMessage::parseMessage($sbody, $this->options['encoding']);
return $header;
}
if($fullData)
{
list($header, $htmlBody, $textBody, $parts) = \Bitrix\KdaImportexcel\MailMessage::parseMessage($sbody, $this->options['encoding']);
$htmlBody = (strlen($htmlBody) > 0 ? $htmlBody : $textBody);
if(strlen(trim($htmlBody))==0) $htmlBody = \Bitrix\Main\Text\Encoding::convertEncoding(base64_decode($sbody), $this->options['encoding'], \CKDAImportUtils::getSiteEncoding());
return array(
'TEXT' => $htmlBody,
'DATE' => $header->GetHeader('DATE')
);
}
return $sbody;
}
public function getMessageFile($mailbox, $id, $arCriterias, $arExtensions, &$error)
{
$error = null;
if (!$this->select($mailbox, $error))
return false;
/*if (!in_array(strtoupper($section), array('HEADER', 'TEXT')))
$section = '';*/
$section = '';
$response = $this->executeCommand(sprintf('FETCH %u (BODY.PEEK[%s])', $id, $section), $error);
if ($error)
{
$error = $error == Imap::ERR_COMMAND_REJECTED ? null : $error;
$error = static::errorMessage(array(Imap::ERR_FETCH, $error), $response);
return false;
}
$sbody = false;
$regex = sprintf('/^ \* \x20 %u \x20 FETCH \x20 \( (?<data> .+ ) \) \r\n $/isx', $id);
foreach ($this->getUntagged($regex, true) as $item)
{
$data = $item[1]['data'];
$sbody = false;
$regex = sprintf('/ ( ^ | \x20 ) BODY \[%s\] \x20 NIL ( \x20 | $ ) /ix', $section);
if (preg_match($regex, $data))
{
$sbody = null;
continue;
}
$regex = sprintf(
'/ ( ^ | \x20 ) BODY \[%s\] \x20 " (?<body> ( %s )* ) " ( \x20 | $ ) /ix',
$section, self::$qcharRegex
);
if (preg_match($regex, $data, $quoted))
{
$sbody = static::unescapeQuoted($quoted['body']);
continue;
}
$regex = sprintf('/ ( ^ | \x20 ) BODY \[%s\] \x20 \{ (?<size> \d+ ) \} \r\n /ix', $section);
if (preg_match($regex, $data, $literal, PREG_OFFSET_CAPTURE))
{
$sbody = \CUtil::binSubstr($data, $literal[0][1]+\CUtil::binStrlen($literal[0][0]), $literal['size'][0]);
continue;
}
}
list($header, $htmlBody, $textBody, $parts) = \Bitrix\KdaImportexcel\MailMessage::parseMessage($sbody, $this->options['encoding']);
$this->messageFiles = array();
foreach($parts as $part)
{
if($part['FILENAME'] &&
(strlen($arCriterias['FILENAME'])==0 ||
($arCriterias['FILENAME_REGEXP']!='Y' && strpos(ToLower($part['FILENAME']), ToLower($arCriterias['FILENAME']))!==false) ||
($arCriterias['FILENAME_REGEXP']=='Y' && preg_match('/'.ToLower($arCriterias['FILENAME']).'/i', ToLower($part['FILENAME'])))
)
&& in_array(ToLower(GetFileExtension($part['FILENAME'])), $arExtensions))
{
$part['DATE'] = $header->GetHeader('DATE');
return $part;
}
}
return false;
}
protected function getUntagged($regex, $unset = false)
{
$result = array();
for ($i = 0; $i < count($this->sessUntagged); $i++)
{
if (!preg_match($regex, $this->sessUntagged[$i], $matches))
continue;
$result[] = array($this->sessUntagged[$i], $matches);
if ($unset)
{
array_splice($this->sessUntagged, $i, 1);
$i--;
}
}
return $result;
}
protected function getUntaggedSearch($unset = false)
{
$regex = '/^ \* \x20 SEARCH ( (?: \x20 \d+ ){0,10} ) /ix';
$result = array();
for ($i = 0; $i < count($this->sessUntagged); $i++)
{
if (!preg_match($regex, $this->sessUntagged[$i], $matches))
continue;
$matches[0] = $this->sessUntagged[$i];
$matches[1] = substr($this->sessUntagged[$i], stripos($this->sessUntagged[$i], 'SEARCH') + 6);
$result[] = array($this->sessUntagged[$i], $matches);
if ($unset)
{
array_splice($this->sessUntagged, $i, 1);
$i--;
}
}
return $result;
}
protected function getTag($next = false)
{
if ($next)
$this->sessCounter++;
return sprintf('A%03u', $this->sessCounter);
}
protected function executeCommand($command, &$error)
{
$error = null;
$chunks = explode("\x00", sprintf('%s %s', $this->getTag(true), $command));
$k = count($chunks);
foreach ($chunks as $chunk)
{
$k--;
$response = $this->exchange($chunk, $error);
if ($k > 0 && strpos($response, '+') !== 0)
break;
}
return $response;
}
protected function exchange($data, &$error)
{
$error = null;
if ($this->sendData(sprintf("%s\r\n", $data)) === false)
{
$error = Imap::ERR_COMMUNICATE;
return false;
}
$response = $this->readResponse();
if ($response === false)
{
$error = Imap::ERR_EMPTY_RESPONSE;
return false;
}
$response = trim($response);
if (!preg_match(sprintf('/^ %s \x20 OK /ix', $this->getTag()), $response))
{
if (preg_match(sprintf('/^ %s \x20 ( NO | BAD ) /ix', $this->getTag()), $response))
$error = Imap::ERR_COMMAND_REJECTED;
else
$error = Imap::ERR_BAD_SERVER;
}
return preg_replace(sprintf('/^ %s \x20 /ix', $this->getTag()), '', $response);
return $response;
}
protected function sendData($data)
{
//echo '> ', $data;
$bytes = fputs($this->stream, $data);
if ($bytes < strlen($data))
return false;
return true;
}
protected function readBytes($bytes)
{
$data = '';
while ($bytes > 0)
{
$buffer = fread($this->stream, $bytes);
if ($buffer === false)
return false;
$data .= $buffer;
$bytes -= \CUtil::binStrlen($buffer);
}
return $data;
}
protected function readLine()
{
$line = '';
do
{
$buffer = fgets($this->stream, 4096);
if ($buffer === false)
return false;
$line .= $buffer;
if ($literal = preg_match('/\{(?<bytes>\d+)\}\r\n$/', $line, $matches))
{
$data = $this->readBytes($matches['bytes']);
if ($data === false)
return false;
$line .= $data;
}
}
while ($literal || !preg_match('/\r\n$/', $line));
//echo '< ', $line;
return $line;
}
protected function readResponse()
{
do
{
$line = $this->readLine();
if ($line === false)
return false;
if (strpos($line, '*') === 0)
$this->sessUntagged[] = $line;
}
while (strpos($line, '*') === 0);
return $line;
}
protected static function prepareString($data)
{
if (preg_match('/^[^\x00\x0a\x0d\x80-\xff]*$/', $data))
return sprintf('"%s"', static::escapeQuoted($data));
else
return sprintf("{%u}\x00%s", \CUtil::binStrlen($data), $data);
}
protected static function escapeQuoted($data)
{
return str_replace(array('\\', '"'), array('\\\\', '\\"'), $data);
}
protected static function unescapeQuoted($data)
{
return str_replace(array('\\\\', '\\"'), array('\\', '"'), $data);
}
protected function encodeUtf7Imap($data)
{
if (!$data)
return $data;
$result = Encoding::convertEncoding($data, $this->options['encoding'], 'UTF7-IMAP');
if ($result === false)
{
$result = $data;
$result = Encoding::convertEncoding($result, $this->options['encoding'], 'UTF-8');
$result = str_replace('&', '&-', $result);
$result = preg_replace_callback('/[\x00-\x1f\x7f-\xff]+/', function($matches)
{
$result = $matches[0];
$result = Encoding::convertEncoding($result, 'UTF-8', 'UTF-16BE');
$result = base64_encode($result);
$result = str_replace('/', ',', $result);
$result = str_replace('=', '', $result);
$result = '&' . $result . '-';
return $result;
}, $result);
}
return $result;
}
protected function decodeUtf7Imap($data)
{
if (!$data)
return $data;
$result = Encoding::convertEncoding($data, 'UTF7-IMAP', $this->options['encoding']);
if ($result === false)
{
$result = $data;
$result = preg_replace_callback('/&([\x2b\x2c\x30-\x39\x41-\x5a\x61-\x7a]+)-/', function($matches)
{
$result = $matches[1];
$result = str_replace(',', '/', $result);
$result = base64_decode($result);
$result = Encoding::convertEncoding($result, 'UTF-16BE', 'UTF-8');
return $result;
}, $result);
$result = str_replace('&-', '&', $result);
$result = Encoding::convertEncoding($result, 'UTF-8', $this->options['encoding']);
}
return $result;
}
protected static function errorMessage($errors, $details = null)
{
$errors = array_filter((array) $errors);
$details = array_filter((array) $details);
foreach ($errors as $i => $error)
$errors[$i] = static::decodeError($error);
$error = join(': ', $errors);
if ($details)
$error .= sprintf(' (%s)', join(': ', $details));
return $error;
}
/**
* Returns error message
*
* @param int $code Error code.
* @return string
*/
public static function decodeError($code)
{
switch ($code)
{
case self::ERR_CONNECT:
return Loc::getMessage('KDA_IE_IMAP_ERR_CONNECT');
case self::ERR_REJECTED:
return Loc::getMessage('KDA_IE_IMAP_ERR_REJECTED');
case self::ERR_COMMUNICATE:
return Loc::getMessage('KDA_IE_IMAP_ERR_COMMUNICATE');
case self::ERR_EMPTY_RESPONSE:
return Loc::getMessage('KDA_IE_IMAP_ERR_EMPTY_RESPONSE');
case self::ERR_BAD_SERVER:
return Loc::getMessage('KDA_IE_IMAP_ERR_BAD_SERVER');
case self::ERR_STARTTLS:
return Loc::getMessage('KDA_IE_IMAP_ERR_STARTTLS');
case self::ERR_COMMAND_REJECTED:
return Loc::getMessage('KDA_IE_IMAP_ERR_COMMAND_REJECTED');
case self::ERR_CAPABILITY:
return Loc::getMessage('KDA_IE_IMAP_ERR_CAPABILITY');
case self::ERR_AUTH:
return Loc::getMessage('KDA_IE_IMAP_ERR_AUTH');
case self::ERR_AUTH_MECH:
return Loc::getMessage('KDA_IE_IMAP_ERR_AUTH_MECH');
case self::ERR_LIST:
return Loc::getMessage('KDA_IE_IMAP_ERR_LIST');
case self::ERR_SELECT:
return Loc::getMessage('KDA_IE_IMAP_ERR_SELECT');
case self::ERR_SEARCH:
return Loc::getMessage('KDA_IE_IMAP_ERR_SEARCH');
case self::ERR_FETCH:
return Loc::getMessage('KDA_IE_IMAP_ERR_FETCH');
case self::ERR_APPEND:
return Loc::getMessage('KDA_IE_IMAP_ERR_APPEND');
case self::ERR_STORE:
return Loc::getMessage('KDA_IE_IMAP_ERR_STORE');
default:
return Loc::getMessage('KDA_IE_IMAP_ERR_DEFAULT');
}
}
}