feedgarbagecollector.php

<?php
namespace Bitrix\Socialnetwork\Update;
 
use Bitrix\Main\Loader;
use Bitrix\Socialnetwork\LogTable;
 
class FeedGarbageCollector
{
    public const LIMIT = 1000;
 
    private static $processing = false;
 
    public static function execute()
    {
        if (self::$processing)
        {
            return self::getAgentName();
        }
 
        self::$processing = true;
 
        $agent = new self();
        $res = $agent->run();
 
        self::$processing = false;
 
        return $res;
    }
 
    private static function getAgentName(): string
    {
        return self::class . "::execute();";
    }
 
    private function __construct()
    {
 
    }
 
    private function run(): string
    {
        $types = $this->getTypes();
        if (empty($types))
        {
            return '';
        }
 
        $logIds = $this->getLogIds($types);
        if (empty($logIds))
        {
            return '';
        }
 
        foreach ($logIds as $logId)
        {
            \CSocNetLog::Delete($logId);
        }
 
        return self::getAgentName();
    }
 
    private function getLogIds(array $types): array
    {
        $logIds = LogTable::getList([
            'select' => ['ID'],
            'filter' => [
                '@ENTITY_TYPE' => $types,
            ],
            'limit' => self::LIMIT,
            'order' => ['ID' => 'ASC'],
        ])->fetchAll();
        if (empty($logIds))
        {
            return [];
        }
 
        return array_column($logIds, 'ID');
    }
 
    private function getTypes(): array
    {
        if (!Loader::includeModule('crm'))
        {
            return [];
        }
 
        return [
            SONET_CRM_LEAD_ENTITY,
            SONET_CRM_CONTACT_ENTITY,
            SONET_CRM_COMPANY_ENTITY,
            SONET_CRM_DEAL_ENTITY,
            SONET_CRM_ACTIVITY_ENTITY,
            SONET_CRM_INVOICE_ENTITY,
            SONET_CRM_ORDER_ENTITY,
            SONET_CRM_SUSPENDED_LEAD_ENTITY,
            SONET_SUSPENDED_CRM_CONTACT_ENTITY,
            SONET_SUSPENDED_CRM_COMPANY_ENTITY,
            SONET_CRM_SUSPENDED_DEAL_ENTITY,
            SONET_CRM_SUSPENDED_ACTIVITY_ENTITY,
        ];
    }
}