mailservices.php

<?php
 
namespace Bitrix\Mail;
 
use Bitrix\Main\Entity;
use Bitrix\Main\Localization;
use Bitrix\Main\ORM;
 
Localization\Loc::loadMessages(__FILE__);
 
class MailServicesTable extends Entity\DataManager
{
 
    public static function getFilePath()
    {
        return __FILE__;
    }
 
    public static function getTableName()
    {
        return 'b_mail_mailservices';
    }
 
    public static function checkFields(Entity\Result $result, $primary, array $data)
    {
        parent::checkFields($result, $primary, $data);
 
        if (isset($data['SITE_ID']))
        {
            $selectResult = \Bitrix\Main\SiteTable::getByPrimary($data['SITE_ID']);
            if (!$selectResult->fetch())
            {
                $field = static::getEntity()->getField('SITE_ID');
                $result->addError(new Entity\FieldError(
                    $field,
                    Localization\Loc::getMessage('MAIN_ENTITY_FIELD_INVALID', array('#FIELD_TITLE#' => $field->getTitle())),
                    Entity\FieldError::INVALID_VALUE
                ));
            }
        }
 
        if (!empty($data['ICON']))
        {
            if (!is_scalar($data['ICON']) || !preg_match('/[0-9]+/', $data['ICON']))
            {
                $field = static::getEntity()->getField('ICON');
                $result->addError(new Entity\FieldError(
                    $field,
                    Localization\Loc::getMessage('MAIN_ENTITY_FIELD_INVALID', array('#FIELD_TITLE#' => $field->getTitle())),
                    Entity\FieldError::INVALID_VALUE
                ));
            }
        }
 
        return $result;
    }
 
    public static function add(array $data)
    {
        if (isset($data['ICON']) && is_array($data['ICON']))
        {
            $iconError = $data['ICON']['name'] ? \CFile::checkImageFile($data['ICON']) : null;
            if (is_null($iconError))
            {
                $data['ICON']['MODULE_ID'] = 'mail';
 
                \CFile::saveForDB($data, 'ICON', 'mail/mailservices/icon');
            }
        }
 
        return parent::add($data);
    }
 
    public static function update($primary, array $data): Entity\UpdateResult
    {
        if (empty($data))
            return new Entity\UpdateResult();
 
        $serviceForUpdate = static::getByPrimary(
            $primary,
            array(
                'select' => array(
                    'ID', 'SITE_ID', 'ACTIVE', 'SERVICE_TYPE',
                ),
            )
        )->fetch();
        if (!$serviceForUpdate)
        {
            $updateResult = new Entity\UpdateResult();
            $updateResult->addError(new Entity\EntityError(Localization\Loc::getMessage('mail_mailservice_not_found')));
 
            return $updateResult;
        }
 
        if (isset($data['ICON']) && is_array($data['ICON']))
        {
            $iconError = $data['ICON']['name'] ? \CFile::checkImageFile($data['ICON']) : null;
            if (is_null($iconError))
            {
                $data['ICON']['MODULE_ID'] = 'mail';
 
                \CFile::saveForDB($data, 'ICON', 'mail/mailservices/icon');
            }
        }
 
        $updateResult = parent::update($primary, $data);
 
        if ($updateResult->isSuccess())
        {
            $serviceId = is_array($primary) ? $primary['ID'] : $primary;
 
            $isSiteChanged = isset($data['SITE_ID']) && $data['SITE_ID'] != $serviceForUpdate['SITE_ID'];
            $isDeactivated = isset($data['ACTIVE']) && $data['ACTIVE'] == 'N' && $serviceForUpdate['ACTIVE'] == 'Y';
            if (($isSiteChanged || $isDeactivated) && $serviceForUpdate['SERVICE_TYPE'] == 'imap')
            {
                $emptyService = static::getList(array(
                    'select' => array('ID'),
                    'filter' => array(
                        '=SITE_ID' => $serviceForUpdate['SITE_ID'],
                        'ACTIVE' => 'Y',
                        '=SERVICE_TYPE' => 'imap',
                        '=SERVER' => '',
                        '=PORT' => '',
                        '=ENCRYPTION' => '',
                        '=LINK' => '',
                    ),
                    'limit' => 1,
                ))->fetch();
            }
 
            if ($isSiteChanged || $isDeactivated && $emptyService)
            {
                $mbData = $emptyService
                    ? array('SERVICE_ID' => $emptyService['ID'])
                    : array('ACTIVE' => 'N', 'SERVICE_ID' => 0);
            }
            else
            {
                $mbData = array();
                foreach ($data as $key => $value)
                {
                    if (empty($value))
                        continue;
 
                    switch ($key)
                    {
                        case 'ACTIVE':
                        case 'NAME':
                        case 'SERVER':
                        case 'PORT':
                        case 'LINK':
                            $mbData[$key] = $value;
                            break;
                        case 'ENCRYPTION':
                            $mbData['USE_TLS'] = $value;
                            break;
                    }
                }
            }
 
            $selectResult = \CMailbox::getList(array(), array('SERVICE_ID' => $serviceId));
            while ($mailbox = $selectResult->fetch())
                \CMailbox::update($mailbox['ID'], $mbData);
        }
 
        return $updateResult;
    }
 
    public static function getIconSrc($serviceName, $iconId = null)
    {
        if ($iconId)
        {
            $icon = \CFile::getFileArray($iconId);
 
            return $icon['SRC'];
        }
        else
        {
            $icons = array(
                'bitrix24'  => '/bitrix/images/mail/mailservice-icon/' . Localization\Loc::getMessage('mail_mailservice_bitrix24_icon'),
                'gmail' => '/bitrix/images/mail/mailservice-icon/post-gmail-icon.svg',
                'icloud'    => '/bitrix/images/mail/mailservice-icon/post-icloud-icon.svg',
                'outlook.com'   => '/bitrix/images/mail/mailservice-icon/post-outlook-icon.svg',
                'office365' => '/bitrix/images/mail/mailservice-icon/post-office360-icon.svg',
                'yahoo' => '/bitrix/images/mail/mailservice-icon/post-yahoo-icon.svg',
                'aol'   => '/bitrix/images/mail/mailservice-icon/post-aol-icon.svg',
                'yandex'    => '/bitrix/images/mail/mailservice-icon/post-yandex-icon.svg',
                'mail.ru'   => '/bitrix/images/mail/mailservice-icon/post-mail-icon.svg',
                'ukr.net'   => '/bitrix/images/mail/mailservice-icon/post-ukrnet-icon.png',
                'exchange'  => '/bitrix/images/mail/mailservice-icon/post-imap-icon.svg',
                'exchangeOnline'    => '/bitrix/images/mail/mailservice-icon/post-exchange-icon.svg',
                'other' => '/bitrix/images/mail/mailservice-icon/post-imap-icon.svg',
            );
 
            if ($icons[$serviceName])
                return $icons[$serviceName];
        }
    }
 
    public static function getOAuthHelper($data)
    {
        switch ($data['NAME'])
        {
            case 'gmail':
                return Helper\OAuth\Google::getInstance();
            case 'yandex':
                return Helper\OAuth\Yandex::getInstance();
            case 'mail.ru':
                return Helper\OAuth\Mailru::getInstance();
            case 'office365':
            case 'outlook.com':
            case 'exchangeOnline':
                return Helper\OAuth\Office365::getInstance();
        }
    }
 
    public static function delete($primary): Entity\DeleteResult
    {
        $serviceForDelete = static::getByPrimary($primary)->fetch();
        if (!$serviceForDelete)
        {
            $deleteResult = new Entity\DeleteResult();
            $deleteResult->addError(new Entity\EntityError(Localization\Loc::getMessage('mail_mailservice_not_found')));
 
            return $deleteResult;
        }
 
        $deleteResult = parent::delete($primary);
 
        if ($deleteResult->isSuccess())
        {
            $serviceId = is_array($primary) ? $primary['ID'] : $primary;
 
            if (in_array($serviceForDelete['SERVICE_TYPE'], array('controller', 'domain', 'crdomain')))
            {
                $mbData = array('ACTIVE' => 'N', 'SERVICE_ID' => 0);
            }
            else
            {
                $emptyService = static::getList(array(
                    'filter' => array(
                        '=SITE_ID'    => $serviceForDelete['SITE_ID'],
                        'ACTIVE'      => 'Y',
                        '=SERVER'     => '',
                        '=PORT'       => '',
                        '=ENCRYPTION' => '',
                        '=LINK'       => ''
                    ),
                    'limit' => 1
                ))->fetch();
 
                $mbData = $emptyService
                    ? array('SERVICE_ID' => $emptyService['ID'], 'NAME' => $emptyService['NAME'])
                    : array('ACTIVE' => 'N', 'SERVICE_ID' => 0);
            }
 
            $selectResult = \CMailbox::getList(array(), array('SERVICE_ID' => $serviceId));
            while ($mailbox = $selectResult->fetch())
                \CMailbox::update($mailbox['ID'], $mbData);
        }
 
        return $deleteResult;
    }
 
    public static function getMap()
    {
        return array(
            'ID' => array(
                'data_type' => 'integer',
                'primary' => true,
                'autocomplete' => true,
            ),
            'SITE_ID' => array(
                'data_type' => 'string',
                'title'     => Localization\Loc::getMessage('mail_mailservice_entity_site_field'),
                'required'  => true
            ),
            'ACTIVE' => array(
                'data_type' => 'boolean',
                'title'     => Localization\Loc::getMessage('mail_mailservice_entity_active_field'),
                'values'    => array('N', 'Y'),
                'required'  => true
            ),
            'SORT' => array(
                'data_type' => 'integer',
                'title'     => Localization\Loc::getMessage('mail_mailservice_entity_sort_field')
            ),
            'SERVICE_TYPE' => array(
                'data_type' => 'enum',
                'title'     => Localization\Loc::getMessage('mail_mailservice_entity_type_field'),
                'values'    => array('imap', 'controller', 'domain', 'crdomain'),
                'required'  => true
            ),
            'NAME' => array(
                'data_type' => 'string',
                'title'     => Localization\Loc::getMessage('mail_mailservice_entity_name_field'),
                'required'  => true
            ),
            'SERVER' => array(
                'data_type' => 'string',
                'title'     => Localization\Loc::getMessage('mail_mailservice_entity_server_field'),
                'save_data_modification' => function()
                {
                    return array(
                        function ($value)
                        {
                            return mb_strtolower($value);
                        }
                    );
                },
                'fetch_data_modification' => function()
                {
                    return array(
                        function ($value)
                        {
                            return mb_strtolower($value);
                        }
                    );
                },
            ),
            'PORT' => array(
                'data_type' => 'integer',
                'title'     => Localization\Loc::getMessage('mail_mailservice_entity_port_field'),
            ),
            'ENCRYPTION' => array(
                'data_type' => 'boolean',
                'title'     => Localization\Loc::getMessage('mail_mailservice_entity_encryption_field'),
                'values'    => array('N', 'Y'),
            ),
            'LINK' => array(
                'data_type' => 'string',
                'title'     => Localization\Loc::getMessage('mail_mailservice_entity_link_field'),
            ),
            'ICON' => array(
                'data_type' => 'integer',
                'title'     => Localization\Loc::getMessage('mail_mailservice_entity_icon_field'),
            ),
            'TOKEN' => array(
                'data_type' => 'string',
                'title'     => Localization\Loc::getMessage('mail_mailservice_entity_token_field'),
            ),
            'FLAGS' => array(
                'data_type' => 'integer',
                'title'     => Localization\Loc::getMessage('mail_mailservice_entity_flags_field'),
            ),
            'SITE' => array(
                'data_type' => 'Bitrix\Main\Site',
                'reference' => array('=this.SITE_ID' => 'ref.LID'),
            ),
            new Entity\StringField('SMTP_SERVER'),
            new Entity\IntegerField('SMTP_PORT'),
            new Entity\BooleanField('SMTP_LOGIN_AS_IMAP', [
                'values' => array('N', 'Y'),
                'default_value' => 'N',
            ]),
            new Entity\BooleanField('SMTP_PASSWORD_AS_IMAP', [
                'values' => array('N', 'Y'),
                'default_value' => 'N',
            ]),
            new ORM\Fields\BooleanField(
                'SMTP_ENCRYPTION',
                array(
                    'values' => array('N', 'Y'),
                )
            ),
            new ORM\Fields\BooleanField(
                'UPLOAD_OUTGOING',
                array(
                    'values' => array('N', 'Y'),
                )
            ),
        );
    }
 
}