sender.php

См. документацию.

<?php
 
namespace Bitrix\Main\Controller\Mail;
 
use Bitrix\Main\Engine\Controller;
use Bitrix\Main\Engine\CurrentUser;
use Bitrix\Main\Localization\Loc;
use Bitrix\Main\Mail;
use Bitrix\Main;
use Bitrix\Main\Error;
 
class Sender extends Controller
{
    public function getSenderDataAction(int $senderId): ?array
    {
        $sender = \Bitrix\Main\Mail\Internal\SenderTable::getById($senderId)->fetch();
 
        if (!$sender)
        {
            return null;
        }
 
        $smtp = $sender['OPTIONS']['smtp'] ?? [];
 
        if (!empty($smtp))
        {
            $response['smtp'] = [
                'server' => $smtp['server'] ?? null,
                'port' => $smtp['port'] ?? null,
                'protocol' => $smtp['protocol'] ?? null,
                'login' => $smtp['login'] ?? null,
                'limit' => $smtp['limit'] ?? null,
            ];
        }
 
        return array_merge(
            $response['smtp'] ?? [],
            [
                'email' => $sender['EMAIL'],
                'name' => !empty($sender['NAME']) ? $sender['NAME'] : Mail\Sender\UserSenderDataProvider::getUserFormattedName((int)$sender['USER_ID']),
                'isPublic' => (int)$sender['IS_PUBLIC'] === 1,
            ]
        );
    }
 
    public function getAvailableSendersAction(): array
    {
        return Main\Mail\Sender::prepareUserMailboxes();
    }
 
    public function getSenderTransitionalDataAction(int $senderId): ?array
    {
        return Mail\Sender\UserSenderDataProvider::getSenderTransitionalData($senderId);
    }
 
    public function getSenderByMailboxIdAction(int $mailboxId, bool $getSenderWithoutSmtp = false): ?array
    {
        return Mail\Sender\UserSenderDataProvider::getSenderNameByMailboxId($mailboxId, $getSenderWithoutSmtp);
    }
 
    public function getDefaultSenderNameAction(): string
    {
        return Mail\Sender\UserSenderDataProvider::getUserFormattedName() ?? '';
    }
 
    public function submitSenderAction(array $data): ?array
    {
        $name = trim((string)($data['name'] ?? ''));
        $public = $data['public'] === 'Y';
        $userId = (int)CurrentUser::get()->getId();
 
        $email = mb_strtolower(trim((string)($data['email'] ?? '')));
        if (!check_email($email, true))
        {
            $errorCode = empty($email) ? 'MAIN_CONTROLLER_MAIL_SENDER_EMPTY_EMAIL' : 'MAIN_CONTROLLER_MAIL_SENDER_INVALID_EMAIL';
            $this->addError(new Error(Loc::getMessage($errorCode), 'ERR_INVALID_EMAIL'));
 
            return null;
        }
 
        $senderId = (int)($data['id'] ?? null);
        if (!$senderId && Mail\Sender::hasUserSenderWithEmail($email))
        {
            $this->addError(new Error(Loc::getMessage('MAIN_CONTROLLER_MAIL_SENDER_EXISTS_SENDER'), 'ERR_EXISTS_SENDER'));
 
            return null;
        }
 
        $smtp = $data['smtp'] ?? [];
 
        if ($senderId)
        {
            $checkResult = Main\Mail\Sender::canEditSender($senderId);
            if (!$checkResult->isSuccess())
            {
                $this->addErrors($checkResult->getErrors());
 
                return null;
            }
 
            $sender = Mail\Internal\SenderTable::getById($senderId)->fetch();
            $userId = (int)$sender['USER_ID'];
            if (!empty($smtp) && empty($smtp['password']) && $sender['OPTIONS']['smtp'])
            {
                $smtp['password'] = $sender['OPTIONS']['smtp']['password'];
            }
        }
 
        if (!empty($smtp))
        {
            if (!is_array($smtp))
            {
                $this->addError(new Error(Loc::getMessage('MAIN_CONTROLLER_MAIL_SENDER_AJAX_ERROR'), 'ERR_EMAIL'));
 
                return null;
            }
 
            $result = Mail\Sender::prepareSmtpConfigForSender($smtp);
 
            if (!$result->isSuccess())
            {
                $error = $result->getErrors()[0];
                $this->addError(new Error($error->getMessage(), 'ERR_SMTP_CONFIG'));
 
                return null;
            }
        }
 
        $fields = [
            'NAME' => $name,
            'EMAIL' => $email,
            'USER_ID' => $userId,
            'IS_CONFIRMED' => true,
            'IS_PUBLIC' => $public,
            'OPTIONS' => [],
        ];
 
        if (!empty($smtp))
        {
            $fields['OPTIONS']['smtp'] = $smtp;
        }
 
        if (!$senderId)
        {
            $result = Main\Mail\Sender::add($fields);
 
            if (!empty($result['error']))
            {
                $this->addError($result['error']);
 
                return null;
            }
 
            if (!empty($result['errors']))
            {
                $this->addError($result['errors'][0]);
 
                return null;
            }
 
            $senderId = $result['senderId'] ?? null;
        }
        else
        {
            $updateResult = Mail\Internal\SenderTable::update($senderId, $fields);
 
            if(!$updateResult->isSuccess())
            {
                $this->addError($updateResult->getErrors()[0]);
 
                return null;
            }
        }
 
        if ($smtp && $smtp['limit'] !== null)
        {
            Main\Mail\Sender::setEmailLimit($email, $smtp['limit']);
        }
        elseif ($smtp && !isset($smtp['limit']))
        {
            Main\Mail\Sender::removeEmailLimit($email);
        }
 
        return [
            'senderId' => $senderId ?? null,
            'name' => !empty($name) ? $name : Mail\Sender\UserSenderDataProvider::getUserFormattedName($userId),
        ];
    }

    public function addAliasAction(string $name, string $email): ?array
    {
        $userId = (int)CurrentUser::get()->getId();
 
        if (!$userId)
        {
            return null;
        }
 
        if (!Main\Mail\Sender::hasUserAvailableSmtpSenderByEmail($email, $userId))
        {
            return null;
        }
 
        $result = Main\Mail\Sender::add([
            'NAME' => $name,
            'EMAIL' => $email,
            'IS_CONFIRMED' => true,
            'USER_ID' => $userId,
        ]);
 
        if (!empty($result['error']))
        {
            $this->addError(new Error($result['error'], 'ERR_ADD_SENDER'));
 
            return null;
        }
 
        $userData = Mail\Sender\UserSenderDataProvider::getUserInfo($userId);
        $result['avatar'] = $userData['userAvatar'] ?? null;
        $result['userUrl'] = $userData['userUrl'] ?? null;
 
        return $result;
    }
 
    public function deleteSenderAction(int $senderId): void
    {
        $checkResult = Main\Mail\Sender::canEditSender($senderId);
        if (!$checkResult->isSuccess())
        {
            $this->addErrors($checkResult->getErrors());
 
            return;
        }
 
        Main\Mail\Sender::delete([$senderId]);
    }
 
    public function updateSenderNameAction(int $senderId, string $name): void
    {
        $result = Main\Mail\Sender::updateSender($senderId, ['NAME' => $name]);
        if (!$result->isSuccess())
        {
            $this->addErrors($result->getErrors());
        }
    }
}