cleanconnectionagent.php

<?php
 
namespace Bitrix\Calendar\Sync\Util;
 
use Bitrix\Dav\Internals\DavConnectionTable;
use Bitrix\Main\Entity\ReferenceField;
use Bitrix\Main\Loader;
use Bitrix\Main\SystemException;
use Bitrix\Main\Type\Date;
use Bitrix\Main\UserTable;
 
final class CleanConnectionAgent
{
    private const WEEK_TIME_SLICE = 650000;
    private const SYNC_CONNECTIONS = [
        'icloud',
        'office365',
        'google_api_oauth',
        'caldav',
        'yandex',
        'caldav_google_oauth'
    ];
 
    public static function cleanAgent(): string
    {
        (new self())->cleanConnections();
 
        return "\\Bitrix\\Calendar\\Sync\\Util\\CleanConnectionAgent::cleanAgent();";
    }
 
    private function cleanConnections(): void
    {
        if (!Loader::includeModule('dav') || !Loader::includeModule('calendar'))
        {
            return;
        }
 
        $deletedUsersConnections = $this->getDeletedUsersConnection();
 
        $deletedUsersConnectionsIds = array_map(static function($deletedConnection){
            return (int)$deletedConnection['ID'];
        }, $deletedUsersConnections);
 
        if ($deletedUsersConnectionsIds)
        {
            $this->cleanTables($deletedUsersConnectionsIds);
        }
    }
 
    private function getDeletedConnections(): array
    {
        return DavConnectionTable::query()
            ->setSelect(['ID', 'ACCOUNT_TYPE'])
            ->where('IS_DELETED', 'Y')
            ->where('SYNCHRONIZED', '<', new Date(\CCalendar::Date(time() - self::WEEK_TIME_SLICE)))
            ->whereIn('ACCOUNT_TYPE', self::SYNC_CONNECTIONS)
            ->exec()->fetchAll()
        ;
    }
 
    private function getDeletedUsersConnection(): array
    {
        return DavConnectionTable::query()
            ->setSelect(['ID', 'ACCOUNT_TYPE'])
            ->registerRuntimeField(
                new ReferenceField(
                    'USER',
                    UserTable::class,
                    ['=this.ENTITY_ID' => 'ref.ID'],
                    ['join_type' => 'INNER']
                )
            )
            ->where('USER.ACTIVE', 'N')
            ->whereIn('ACCOUNT_TYPE', self::SYNC_CONNECTIONS)
            ->exec()->fetchAll()
        ;
    }
 
    private function cleanTables(array $id): void
    {
        global $DB;
        $id = implode(',', $id);
        $DB->Query("
            DELETE FROM b_calendar_event_connection
            WHERE CONNECTION_ID IN ( " . $id . ");"
        );
 
        $DB->Query("
            DELETE FROM b_calendar_section_connection
            WHERE CONNECTION_ID IN (" . $id . ");"
        );
 
        $DB->Query("
            DELETE FROM b_dav_connections 
            WHERE ID IN (" . $id . ");"
        );
    }
}