connection.php

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

<?php
 
namespace Bitrix\Calendar\Core\Mappers;
 
use Bitrix\Calendar\Core;
use Bitrix\Calendar\Sync;
use Bitrix\Dav\Internals\DavConnectionTable;
use Bitrix\Dav\Internals\EO_DavConnection;
use Bitrix\Main\ArgumentException;
use Bitrix\Main\Loader;
use Bitrix\Main\LoaderException;
use Bitrix\Main\ObjectPropertyException;
use Bitrix\Main\ORM\Query\Result;
use Bitrix\Main\SystemException;
use Bitrix\Main\Type\DateTime;
use Bitrix\Report\VisualConstructor\Controller\Base;
use Exception;

class Connection extends Mapper implements BaseMapperInterface
{
    public function patch(Sync\Connection\Connection $connection, array $fields): Sync\Connection\Connection
    {
        Loader::includeModule('dav');
        DavConnectionTable::update($connection->getId(), $fields);
 
        return $connection;
    }

    public function getByName(string $name): ?Sync\Connection\Connection
    {
        return $this->getOneEntityByFilter(['=NAME' => $name]);
    }

    protected function getOneEntityByFilter(array $filter): ?object
    {
        if (!Loader::includeModule('dav'))
        {
            return null;
        }
 
        $connection = DavConnectionTable::query()
            ->setFilter($filter)
            ->setSelect(['*'])
            ->exec()
            ->fetchObject()
        ;
 
        if ($connection)
        {
            return $this->convertToObject($connection);
        }
 
        return null;
    }

    protected function convertToObject($objectEO): Core\Base\EntityInterface
    {
        return (new Sync\Builders\BuilderConnectionFromDM($objectEO))->build();
    }

    protected function getEntityName(): string
    {
        return 'Dav connection';
    }

    protected function createEntity($entity, array $params = []): ?Core\Base\EntityInterface
    {
        Loader::includeModule('dav');
        $data = $this->convertToArray($entity);
 
        $result = DavConnectionTable::add($data);
        if ($result->isSuccess())
        {
            return $entity->setId($result->getId());
        }
 
        throw new Core\Base\BaseException('Error of create Dav connection', 400);
    }

    protected function updateEntity($entity, array $params = []): ?Core\Base\EntityInterface
    {
        Loader::includeModule('dav');
        $data = $this->convertToArray($entity);
        unset($data['CREATED']);
 
        $result = DavConnectionTable::update($entity->getId(), $data);
        if ($result->isSuccess())
        {
            return $entity;
        }
 
        throw new Core\Base\BaseException('Error of update Dav connection', 400);
    }
 
    private function convertToArray($connection): array
    {
        return [
            'SYNC_TOKEN' => $connection->getToken(),
            'NAME' => $connection->getName(),
            'ENTITY_TYPE' => $connection->getOwner()->getType(),
            'ENTITY_ID' => $connection->getOwner()->getId(),
            'SERVER_SCHEME' => $connection->getServer()->getScheme(),
            'SERVER_HOST' => $connection->getServer()->getHost(),
            'SERVER_PORT' => $connection->getServer()->getPort(),
            'SERVER_USERNAME' => $connection->getServer()->getUserName(),
            'SERVER_PASSWORD' => $connection->getServer()->getPassword(),
            'SERVER_PATH' => $connection->getServer()->getBasePath(),
            'LAST_RESULT' => $connection->getStatus(),
            'IS_DELETED' => $connection->isDeleted() ? 'Y' : 'N',
            'SYNCHRONIZED' => ($lastSyncTime = $connection->getLastSyncTime())
                ? $lastSyncTime->getDate()
                : new DateTime()
            ,
            'CREATED' => new DateTime(),
            'MODIFIED' => new DateTime(),
            'ACCOUNT_TYPE' => $connection->getAccountType(),
            'NEXT_SYNC_TRY' => ($nextSyncTry = $connection->getNextSyncTry())
                ? $nextSyncTry->getDate()
                : new DateTime(),
        ];
    }

    protected function getMapClass(): string
    {
        return Sync\Connection\ConnectionMap::class;
    }

    protected function deleteEntity(
        Core\Base\EntityInterface $entity,
        array $params = ['softDelete' => true]
    ): ?Core\Base\EntityInterface
    {
        if (!Loader::includeModule('dav'))
        {
            return null;
        }
 
        if (!empty($params['softDelete']))
        {
            $entity->setIsActive(true);
 
            return $this->updateEntity($entity, $params);
        }
 
        // TODO: change it to SectionTable::delete() after implementation all logic
        $result = DavConnectionTable::delete($entity->getId());
        if ($result->isSuccess())
        {
            $entity->setDeleted(true);
 
            return null;
        }
 
        throw new Core\Base\BaseException('Error of delete Dav connection');
    }

    protected function getDataManagerResult(array $params): Result
    {
        Loader::includeModule('dav');
 
        return DavConnectionTable::getList($params);
    }

    protected function getEntityClass(): string
    {
        return Sync\Connection\Connection::class;
    }
}