syncinternalmanager.php

<?php
 
namespace Bitrix\Mail\ImapCommands;
 
use Bitrix\Mail\Helper\Mailbox;
use Bitrix\Mail\Internals\MailboxDirectoryTable;
use Bitrix\Main;
use Bitrix\Main\Localization\Loc;
 
Loc::loadMessages(__FILE__);
 
class SyncInternalManager
{
    const FLAG_UNSEEN = 'unseen';
    const FLAG_SEEN = 'seen';
 
    protected $userId;
    protected $mailbox;
    protected $mailboxId;
    protected $mailboxUserId;
    protected $messagesIds;
    protected $messages;
    private $isInit;
    protected $repository;
    protected $mailboxHelper;
 
    public function __construct($mailboxId, $messagesIds, $userId = null)
    {
        $this->mailboxId = $mailboxId;
        if (!is_array($messagesIds))
        {
            $messagesIds = [$messagesIds];
        }
        $this->messagesIds = $messagesIds;
        $this->userId = $userId;
        $this->repository = $this->getRepository();
        $this->mailboxHelper = $this->getMailClientHelper();
    }
 
    public function setUserId($userId)
    {
        $this->userId = $userId;
    }
 
    protected function getRepository()
    {
        return new Repository($this->mailboxId, $this->messagesIds);
    }
 
    protected function getMailClientHelper($throwExceptions = true)
    {
        return Mailbox::createInstance($this->mailboxId, $throwExceptions);
    }
 
    protected function initData($folderType = null)
    {
        if ($this->isInit)
        {
            return new Main\Result();
        }
        $this->isInit = true;
        $result = new Main\Result();
 
        $this->mailbox = $this->repository->getMailbox($this->mailboxUserId);
        if (!$this->mailbox)
        {
            return $result->addError(new Main\Error(Loc::getMessage('MAIL_CLIENT_MAILBOX_NOT_FOUND'),
                'MAIL_CLIENT_MAILBOX_NOT_FOUND'));
        }
 
        if ($folderType)
        {
            $folder = $this->getDirPathByType($folderType);
            if (!$folder)
            {
                $errorCode = 'MAIL_CLIENT_' . ($folderType == MailboxDirectoryTable::TYPE_TRASH ? 'TRASH' : 'SPAM') . '_FOLDER_NOT_SELECTED_ERROR';
                return $result->addError(new Main\Error(
                    Loc::getMessage($errorCode),
                    $errorCode));
            }
        }
        if (is_null($this->messages))
        {
            $this->messages = $this->repository->getMessages();
        }
 
        if (empty($this->messages))
        {
            return $result->addError(new Main\Error(Loc::getMessage('MAIL_CLIENT_MESSAGES_NOT_FOUND'),
                'MAIL_CLIENT_MESSAGES_NOT_FOUND'));
        }
        $this->fillMessagesEmails();
 
        $folders = [];
        foreach ($this->messages as $index => $message)
        {
            if (in_array($message['ID'], $this->messagesIds, true))
            {
                $folders[$message['DIR_MD5']] = $message['DIR_MD5'];
            }
        }
        if (count($folders) > 1)
        {
            return $result->addError(new Main\Error(Loc::getMessage('MAIL_CLIENT_MESSAGES_MULTIPLE_FOLDERS'),
                'MAIL_CLIENT_MESSAGES_MULTIPLE_FOLDERS'));
        }
        return $result;
    }
 
    protected function getDirPathByType($dirType)
    {
        return $this->mailboxHelper->getDirsHelper()->getDirPathByType($dirType);
    }
 
    protected function getDirByPath($path)
    {
        return $this->mailboxHelper->getDirsHelper()->getDirByPath($path);
    }
 
    protected function fillMessagesEmails()
    {
        foreach ($this->messages as $index => $message)
        {
            $address = new Main\Mail\Address($message['FIELD_FROM']);
            $this->messages[$index]['EMAIL'] = $address->getEmail();
        }
    }
}