pushmanager.php

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

<?php
 
namespace Bitrix\Calendar\Sync\Office365;
 
use Bitrix\Calendar\Core\Base\BaseException;
use Bitrix\Calendar\Core\Base\Date;
use Bitrix\Calendar\Sync\Connection\Connection;
use Bitrix\Calendar\Sync\Connection\SectionConnection;
use Bitrix\Calendar\Sync\Exceptions\ApiException;
use Bitrix\Calendar\Sync\Exceptions\AuthException;
use Bitrix\Calendar\Sync\Exceptions\ConflictException;
use Bitrix\Calendar\Sync\Exceptions\NotFoundException;
use Bitrix\Calendar\Sync\Exceptions\RemoteAccountException;
use Bitrix\Calendar\Sync\Internals\HasContextTrait;
use Bitrix\Calendar\Sync\Managers\PushManagerInterface;
use Bitrix\Calendar\Sync\Push\Push;
use Bitrix\Calendar\Sync\Util\Result;
use Bitrix\Main\ArgumentException;
use Bitrix\Main\ArgumentNullException;
use Bitrix\Main\Error;
use Bitrix\Main\LoaderException;
use Bitrix\Main\ObjectException;
use Bitrix\Main\Type\DateTime;
use Exception;
 
class PushManager extends AbstractManager implements PushManagerInterface
{
    use HasContextTrait;
 
    public function __construct(Office365Context $context)
    {
        $this->context = $context;
        parent::__construct($context->getConnection());
    }

    public function renewPush(Push $pushChannel): Result
    {
        $result = new Result();
        try
        {
            if ($data = $this->context->getVendorSyncService()->resubscribe($pushChannel->getResourceId()))
            {
                if (empty($data['expirationDateTime']))
                {
                    $time = time() + 70 * 60 * 60;
                    $data['expirationDateTime'] = date('c', $time);
                }
 
                $pushChannel->setExpireDate(new Date($this->convertToDateTime($data['expirationDateTime'])));
                $result->setData([
                    'CHANNEL_ID'  => $pushChannel->getChannelId(),
                    'RESOURCE_ID' => $data['id'],
                    'EXPIRES'     => $this->convertToDateTime($data['expirationDateTime']),
                ]);
            }
            else
            {
                $result->addError(new Error('Error of renew push channel'));
            }
        }
        catch (ApiException $e)
        {
            $result->addError(new Error('Error of MS Graph API', $e->getCode(), $e->getMessage()));
        }
 
        return $result;
    }

    private function convertToDateTime(string $time): DateTime
    {
        $phpDateTime = new \DateTime($time);
 
        return DateTime::createFromPhp($phpDateTime);
    }

    public function addSectionPush(SectionConnection $link): Result
    {
        $result = new Result();
        try
        {
            $data = $this->context->getVendorSyncService()->subscribeSection($link);
 
            if ($data && !empty($data['channelId']))
            {
                $result->setData([
                    'CHANNEL_ID' => $data['channelId'],
                    'RESOURCE_ID' => $data['id'],
                    'EXPIRES' => $this->convertToDateTime($data['expirationDateTime'] ?? date('c')),
                ]);
            }
            else
            {
                $result->addError(new Error('Error of create subscription.'));
            }
        }
        catch (ApiException $e)
        {
            $result->addError(new Error('Error of Push subscribing. Vendor returned error.', $e->getCode()));
        }
        catch (AuthException $e)
        {
            $result->addError(new Error('No authentication data', $e->getCode()));
        }
 
        return $result;
    }

    public function deletePush(Push $pushChannel): Result
    {
        $result = new Result();
 
        try
        {
            if ($data = $this->context->getVendorSyncService()->unsubscribe($pushChannel->getResourceId()))
            {
                $result->setData($data);
            }
 
            return $result;
        }
        catch (RemoteAccountException|AuthException $exception)
        {
            return $result;
        }
    }

    public function clearAllSubscriptions(): void
    {
        $apiResponse = $this->context->getApiClient()->get('subscriptions');
        if (!empty($apiResponse['value']))
        {
            foreach ($apiResponse['value'] as $subscription)
            {
                $this->context->getApiClient()->delete('subscriptions/' . $subscription['id']);
            }
        }
    }

    public function addConnectionPush(Connection $connection): Result
    {
        return (new Result())->addError(new Error('Connection push unavailable for this service', 503));
    }
}