File manager

File manager - Edit - /home/c14075/dragmet-ural.ru/www/bitrix/modules/calendar/lib/sync/managers/pushwatchingmanager.php

Back
<?php namespace Bitrix\Calendar\Sync\Managers; use Bitrix\Calendar\Core\Base\BaseException; use Bitrix\Calendar\Core\Mappers\Factory; use Bitrix\Calendar\Internals\PushTable; use Bitrix\Calendar\Internals\SectionConnectionTable; use Bitrix\Calendar\Sync\Builders\BuilderPushFromDM; use Bitrix\Calendar\Sync\Connection\Connection; use Bitrix\Calendar\Sync\Connection\SectionConnection; use Bitrix\Calendar\Sync\Dictionary; use Bitrix\Calendar\Sync\Exceptions\ApiException; use Bitrix\Calendar\Sync\Exceptions\SyncException; use Bitrix\Calendar\Sync\Factories\FactoryBuilder; use Bitrix\Calendar\Sync\Factories\SectionConnectionFactory; use Bitrix\Calendar\Sync\Factories\FactoryInterface; use Bitrix\Calendar\Sync\Push\Push; use Bitrix\Calendar\Sync\Util\Context; use Bitrix\Calendar\Sync\Util\Result; use Bitrix\Dav\Internals\DavConnectionTable; use Bitrix\Main\ArgumentException; use Bitrix\Main\DI\ServiceLocator; use Bitrix\Main\Entity\ReferenceField; use Bitrix\Main\Error; use Bitrix\Main\Loader; use Bitrix\Main\LoaderException; use Bitrix\Main\ObjectException; use Bitrix\Main\ObjectNotFoundException; use Bitrix\Main\ObjectPropertyException; use Bitrix\Main\ORM\Query\Join; use Bitrix\Main\SystemException; use Bitrix\Main\Type\Date; use Bitrix\Main\Type\DateTime; use CAgent; use Exception; class PushWatchingManager { private const RENEW_LIMIT = 5; private const FIX_LIMIT = 5; private const RENEW_INTERVAL_CHANNEL = 14400;//60604 private const PAUSE_INTERVAL_CHANNEL = 72000; // 606020 private const TYPE_LINK = 'SECTION_CONNECTION'; private const TYPE_CONNECTION = 'CONNECTION'; private const GOOGLE_CONNECTION = 'google_api_oauth'; private const OFFICE365_CONNECTION = 'office365'; private const RESULT_STATUS = [ 'done' => 'done', // nothing left to process 'next' => 'next', // something left to process ]; /** @var Factory / private $mapperFactory; private SectionConnectionFactory $linkFactory; private static array $outgoingManagersCache = []; /* * @throws LoaderException * @throws ObjectNotFoundException * @throws SystemException / public function __construct() { if (!Loader::includeModule('dav')) { throw new SystemException('Module dav not found'); } $this->mapperFactory = ServiceLocator::getInstance()->get('calendar.service.mappers.factory'); } /* * @return false\|string * * @throws ArgumentException * @throws LoaderException * @throws ObjectException * @throws ObjectNotFoundException * @throws ObjectPropertyException * @throws SystemException * @throws Exception / public static function renewWatchChannels() { if (!Loader::includeModule('dav') \|\| !Loader::includeModule('calendar')) { return false; } $agentName = __METHOD__ . '();'; $manager = new static(); $status = $manager->doRenewWatchChannels(); $manager->doFixWatchSectionChannels(); $manager->doFixWatchConnectionChannels(); if ($status === self::RESULT_STATUS['done']) { $nextAgentDate = DateTime::createFromTimestamp( time() + self::PAUSE_INTERVAL_CHANNEL)->format(Date::convertFormatToPhp(FORMAT_DATETIME) ); CAgent::removeAgent($agentName, "calendar"); CAgent::addAgent($agentName, "calendar", "N", self::RENEW_INTERVAL_CHANNEL,"", "Y", $nextAgentDate); return false; } return $agentName; } /* * @return string * * @throws ArgumentException * @throws ObjectException * @throws ObjectPropertyException * @throws SystemException * @throws Exception / private function doRenewWatchChannels(): string { $pushChannels = PushTable::getList([ 'filter' => [ 'ENTITY_TYPE' => [self::TYPE_LINK, self::TYPE_CONNECTION], '<=EXPIRES' => (new DateTime())->add('+1 day'), ], 'order' => [ 'EXPIRES' => 'ASC', ], 'limit' => self::RENEW_LIMIT, ])->fetchCollection(); foreach ($pushChannels as $pushChannelEO) { $pushChannel = (new BuilderPushFromDM($pushChannelEO))->build(); if ($pushChannel->getEntityType() === self::TYPE_LINK) { $this->renewSectionPush($pushChannel); } elseif ($pushChannel->getEntityType() === self::TYPE_CONNECTION) { $this->renewConnectionPush($pushChannel); } } if ($pushChannels->count() < self::RENEW_LIMIT) { return self::RESULT_STATUS['done']; } return self::RESULT_STATUS['next']; } /* * @param Push $pushChannel * * @return void * * @throws Exception / private function deleteChannel(Push $pushChannel): void { (new PushManager())->deletePush($pushChannel); } /* * @param Push $pushChannel * * @return void * * @throws Exception / private function savePushChannel(Push $pushChannel): void { (new PushManager())->updatePush($pushChannel); } /* * @param Connection $connection * * @return FactoryInterface\|null / private function getFactoryByConnection(Connection $connection): ?FactoryInterface { $context = new Context([ 'connection' => $connection, ]); return FactoryBuilder::create($connection->getVendor()->getCode(), $connection, $context); } /* * @param PushManagerInterface $vendorPushManager * @param Push $pushChannel * * @return Result * * @throws Exception / private function renewPushChannel(PushManagerInterface $vendorPushManager, Push $pushChannel): Result { try { $result = $vendorPushManager->renewPush($pushChannel); if ($result->isSuccess()) { $this->savePushChannel($pushChannel); } else { $result->addError(new Error('Error of renew push channel.')); } } catch(SyncException $e) { $result = (new Result())->addError(new Error('Error of renew push channel.', $e->getCode())); } return $result; } /* * @param PushManagerInterface $vendorPushManager * @param Push $pushChannel * @param SectionConnection $sectionLink * * @return Result * * @throws ApiException * @throws ObjectException / private function recreateSectionPushChannel( PushManagerInterface $vendorPushManager, Push $pushChannel, SectionConnection $sectionLink ): Result { $result = new Result(); try { $vendorPushManager->deletePush($pushChannel); $result = $vendorPushManager->addSectionPush($sectionLink); if ($result->isSuccess()) { $data = $result->getData(); $pushChannel ->setChannelId($data['CHANNEL_ID']) ->setResourceId($data['RESOURCE_ID']) ->setExpireDate(new \Bitrix\Calendar\Core\Base\Date($data['EXPIRES'])); $this->savePushChannel($pushChannel); } else { $result->addError(new Error('Error of create push channel.')); } } catch(ApiException $e) { $result->addError(new Error('ApiException during creation of push channel.')); if ($e->getMessage() === 'ExtensionError') { $this->deleteChannel($pushChannel); } else { throw $e; } } return $result; } /* * @param Result $result * * @return bool / private function isError405(Result $result): bool { $errors = $result->getErrors(); if (empty($errors)) { return false; } foreach ($errors as $error) { if ((int)$error->getCode() === 405) { return true; } } return false; } /* * @return SectionConnectionFactory / private function getLinkFactory(): SectionConnectionFactory { if (empty($this->linkFactory)) { $this->linkFactory = new SectionConnectionFactory(); } return $this->linkFactory; } /* * @param Push $pushChannel * * @return void * @throws ArgumentException * @throws ObjectException * @throws ObjectPropertyException * @throws SystemException * @throws BaseException * @throws Exception / private function renewSectionPush(Push $pushChannel): void { $sectionLink = $this->getLinkFactory()->getSectionConnection([ 'filter' => [ '=ID' => $pushChannel->getEntityId(), ] ]); if ( $sectionLink !== null && $sectionLink->isActive() && ($sectionLink->getConnection() !== null) && !$sectionLink->getConnection()->isDeleted() ) { /* @var FactoryInterface $vendorFactory / $vendorFactory = $this->getFactoryByConnection($sectionLink->getConnection()); /* @var PushManagerInterface $vendorPushManager / if ($vendorPushManager = $vendorFactory->getPushManager()) { $now = new DateTime(); if ($pushChannel->getExpireDate()->getDate() > $now) { $result = $this->renewPushChannel($vendorPushManager, $pushChannel); if ($result->isSuccess()) { return; } elseif ($result->getErrorCollection()->getErrorByCode(405)) { $result = $this->recreateSectionPushChannel($vendorPushManager, $pushChannel, $sectionLink); if ($result->isSuccess()) { return; } } elseif ($result->getErrorCollection()->getErrorByCode(401)) { return; } } else { $result = $this->recreateSectionPushChannel($vendorPushManager, $pushChannel, $sectionLink); if ($result->isSuccess()) { return; } } } } $this->deleteChannel($pushChannel); } /* * @param Push $pushChannel * * @return void * * @throws ArgumentException * @throws ObjectException * @throws ObjectPropertyException * @throws SystemException * @throws Exception / private function renewConnectionPush(Push $pushChannel): void { /* @var Connection $connection / $connection = $this->getConnectionMapper()->getById($pushChannel->getEntityId()); if ($connection !== null && !$connection->isDeleted()) { /* @var FactoryInterface $vendorFactory / $vendorFactory = $this->getFactoryByConnection($connection); /* @var PushManagerInterface $vendorPushManager / if ($vendorPushManager = $vendorFactory->getPushManager()) { $result = $this->recreateConnectionPushChannel($vendorPushManager, $pushChannel, $connection); if ($result->isSuccess()) { return; } } } $this->deleteChannel($pushChannel); } /* * @return \Bitrix\Calendar\Core\Mappers\Connection / private function getConnectionMapper(): \Bitrix\Calendar\Core\Mappers\Connection { return $this->mapperFactory->getConnection(); } /* * @param PushManagerInterface $vendorPushManager * @param Push $pushChannel * @param Connection $connection * * @return Result * * @throws ObjectException / private function recreateConnectionPushChannel( PushManagerInterface $vendorPushManager, Push $pushChannel, Connection $connection ): Result { $vendorPushManager->deletePush($pushChannel); $result = $vendorPushManager->addConnectionPush($connection); if ($result->isSuccess()) { $data = $result->getData(); $pushChannel ->setResourceId($data['RESOURCE_ID']) ->setExpireDate(new \Bitrix\Calendar\Core\Base\Date($data['EXPIRES'])); $this->savePushChannel($pushChannel); } else { $result->addError(new Error('Error of create push channel.')); } return $result; } /* * @return void * @throws ArgumentException * @throws BaseException * @throws ObjectNotFoundException * @throws ObjectPropertyException * @throws SystemException / private function doFixWatchSectionChannels(): void { $query = SectionConnectionTable::query() ->setSelect(['ID', 'CONNECTION_ID', 'SECTION_ID']) ->registerRuntimeField('CONNECTION', new ReferenceField( 'CONNECTION', DavConnectionTable::getEntity(), [ '=this.CONNECTION_ID' => 'ref.ID', ], ['join_type' => Join::TYPE_INNER] ) ) ->registerRuntimeField('PUSH', new ReferenceField( 'PUSH', PushTable::getEntity(), [ '=this.ID' => 'ref.ENTITY_ID', 'ref.ENTITY_TYPE' => ['?', self::TYPE_LINK] ], ['join_type' => Join::TYPE_LEFT] ) ) ->where('ACTIVE', 'Y') ->where('LAST_SYNC_STATUS', 'success') ->where('CONNECTION.IS_DELETED', 'N') ->whereIn('CONNECTION.ACCOUNT_TYPE', [self::GOOGLE_CONNECTION, self::OFFICE365_CONNECTION]) ->whereNull('PUSH.ENTITY_TYPE') ->setLimit(self::FIX_LIMIT) ->exec() ; while ($row = $query->Fetch()) { $manager = $this->getOutgoingManager($row['CONNECTION_ID']); /* @var SectionConnection $link / $link = $this->mapperFactory->getSectionConnection()->getById($row['ID']); try { $manager->subscribeSection($link); } catch (Exception $e) { $link->setLastSyncStatus(Dictionary::SYNC_STATUS['failed']); $this->mapperFactory->getSectionConnection()->update($link); } } } /* * @return void * @throws ArgumentException * @throws ObjectPropertyException * @throws SystemException / private function doFixWatchConnectionChannels(): void { $query = DavConnectionTable::query() ->setSelect(['ID']) ->registerRuntimeField('PUSH', new ReferenceField( 'PUSH', PushTable::getEntity(), [ '=this.ID' => 'ref.ENTITY_ID', 'ref.ENTITY_TYPE' => ['?', self::TYPE_CONNECTION] ], ['join_type' => Join::TYPE_LEFT] ) ) ->where('IS_DELETED', 'N') ->where('ACCOUNT_TYPE', self::GOOGLE_CONNECTION) ->whereIn('LAST_RESULT', ['success', '[200] OK']) ->whereNull('PUSH.ENTITY_TYPE') ->setLimit(self::FIX_LIMIT) ->exec() ; while ($row = $query->fetch()) { try { $manager = $this->getOutgoingManager($row['ID']); $manager->subscribeConnection(); } catch (Exception $e) { DavConnectionTable::update($row['ID'], [ 'LAST_RESULT' => '['. $e->getCode() .'] ERR' ]); } } } /* * @param $connectionId * * @return OutgoingManager * * @throws ArgumentException * @throws ObjectNotFoundException */ private function getOutgoingManager($connectionId): OutgoingManager { if (empty(static::$outgoingManagersCache[$connectionId])) { $connection = $this->mapperFactory->getConnection()->getById($connectionId); static::$outgoingManagersCache[$connectionId] = new OutgoingManager($connection); } return static::$outgoingManagersCache[$connectionId]; } }

| ver. 1.4 | Github | . | PHP 7.4.33 | Generation time: 0.28 | proxy | phpinfo | Settings