vendorsyncmanager.php

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

<?php
 
namespace Bitrix\Calendar\Sync\Icloud;
 
use Bitrix\Calendar\Core;
use Bitrix\Calendar\Integration\Pull\PushCommand;
use Bitrix\Calendar\Sync\Builders\BuilderConnectionFromArray;
use Bitrix\Calendar\Sync\Builders\BuilderConnectionFromDM;
use Bitrix\Calendar\Sync\Managers;
use Bitrix\Calendar\Util;
use Bitrix\Main\ArgumentException;
use Bitrix\Main\DI\ServiceLocator;
use Bitrix\Calendar\Sync\Managers\NotificationManager;
use Bitrix\Main\ObjectPropertyException;
use Bitrix\Main\SystemException;
 
class VendorSyncManager
{
    private const STATUS_ERROR = 'error';
    private const STATUS_SUCCESS = 'success';
    protected Helper $helper;
    protected ?string $error = null;
    protected ?Context $context = null;
    protected ?VendorSyncService $syncService = null;
    private Core\Mappers\Factory $mapperFactory;
 
    public function __construct()
    {
        $this->helper = new Helper();
        $this->mapperFactory = ServiceLocator::getInstance()->get('calendar.service.mappers.factory');
    }

    public function syncIcloudConnection(int $connectionId): array
    {
        $userId = \CCalendar::GetUserId();
        $connection = $this->mapperFactory->getConnection()->getById($connectionId);
 
        if (!$connection)
        {
            return [
                'status' => self::STATUS_ERROR,
                'message' => 'Connection not found',
            ];
        }
 
        if ($connection->getOwner()->getId() !== $userId)
        {
            return [
                'status' => self::STATUS_ERROR,
                'message' => 'Access Denied',
            ];
        }
 
        $result = Managers\DataSyncManager::createInstance()->dataSync($userId);
        if (!$result)
        {
            return [
                'status' => self::STATUS_ERROR,
                'message' => 'Error while trying to import events',
            ];
        }
 
        Util::addPullEvent(
            PushCommand::ProcessSyncConnection,
            $userId,
            [
                'vendorName' => $this->helper::ACCOUNT_TYPE,
                'stage' => 'import_finished',
                'accountName' => $connection->getServer()->getUserName(),
            ]
        );
 
        $result = (new Managers\OutgoingManager($connection))->export();
        if (!$result->isSuccess())
        {
            return [
                'status' => self::STATUS_ERROR,
                'message' => 'Error while trying to export events',
            ];
        }
 
        Util::addPullEvent(
            PushCommand::ProcessSyncConnection,
            $userId,
            [
                'vendorName' => $this->helper::ACCOUNT_TYPE,
                'stage' => 'export_finished',
                'accountName' => $connection->getServer()->getUserName(),
            ]
        );
 
        NotificationManager::addFinishedSyncNotificationAgent(
            $userId,
            $this->helper::ACCOUNT_TYPE
        );
 
        return [
            'status' => self::STATUS_SUCCESS
        ];
    }

    public function initConnection(string $appleId, string $appPassword): ?int
    {
        $params = [
            'ENTITY_ID' => \CCalendar::GetCurUserId(),
            'ENTITY_TYPE' => Core\Role\User::TYPE,
            'SERVER_HOST' => $this->helper::SERVER_PATH,
            'SERVER_USERNAME' => $appleId,
            'SERVER_PASSWORD' => $appPassword,
            'NAME' => str_replace('#NAME#', $appleId, $this->helper::CONNECTION_NAME)
        ];
 
        $connection = null;
        $calendarPath = $this->getSyncService()->getCalendarServerPath($params);
        if (!$calendarPath)
        {
            $this->error = 'Error while trying to get calendars path';
 
            return null;
        }
        $owner = Core\Role\Helper::getRole(\CCalendar::GetUserId(), Core\Role\User::TYPE);
        $connectionManager = new Managers\ConnectionManager();
        $connections = $connectionManager->getConnectionsData($owner, [Helper::ACCOUNT_TYPE]);
        $connectionManager->deactivateConnections($connections);
        foreach ($connections as $con)
        {
            $existPath = $con->getServerScheme()
                . '://'
                . $con->getServerHost()
                . ':'
                . $con->getServerPort()
                . $con->getServerPath()
            ;
            if ($existPath === $calendarPath)
            {
                $connection = (new BuilderConnectionFromDM($con))->build();
                break;
            }
        }
 
        if ($connection)
        {
            $connection->setDeleted(false);
            $connection->getServer()->setPassword($appPassword);
            $connectionManager->update($connection);
 
            return $connection->getId();
        }
 
        return $this->addConnection($params, $calendarPath);
    }

    public function addConnection(array $connection, string $calendarPath): ?int
    {
        $connection['SERVER_HOST'] = $calendarPath;
        $fields = [
            'ENTITY_TYPE' => $connection['ENTITY_TYPE'],
            'ENTITY_ID' => $connection['ENTITY_ID'],
            'ACCOUNT_TYPE' => $this->helper::ACCOUNT_TYPE,
            'NAME' => $connection['NAME'],
            'SERVER' => $connection['SERVER_HOST'],
            'SERVER_USERNAME' => $connection['SERVER_USERNAME'],
            'SERVER_PASSWORD' => $connection['SERVER_PASSWORD']
        ];
 
        $connectionId = \CDavConnection::Add($fields);
 
        if ($connectionId)
        {
            return $connectionId;
        }
 
        $this->error = 'Error while trying to save connection';
 
        return null;
    }
 
    private function getSyncService(): VendorSyncService
    {
        if (!$this->syncService)
        {
            $this->syncService = new VendorSyncService();
        }
 
        return $this->syncService;
    }
 
    public function getError(): string
    {
        return $this->error;
    }
}