pullmanager.php

<?php
 
namespace Bitrix\Sale\PaySystem;
 
use Bitrix\Main;
use Bitrix\Sale;
use Bitrix\Pull;
 
class PullManager
{
    public const MODULE_ID = 'sale';
    public const PAYMENT_COMMAND = 'PAYMENT';
 
    public const SUCCESSFUL_PAYMENT = 'SUCCESSFUL_PAYMENT';
    public const FAILURE_PAYMENT = 'FAILURE_PAYMENT';
 
    public static function subscribeOnPayment(int $userId): void
    {
        if ($userId <= 0)
        {
            return;
        }
 
        if (self::includePullModule())
        {
            \CPullWatch::Add($userId, self::PAYMENT_COMMAND);
        }
    }
 
    public static function onSuccessfulPayment(Sale\Payment $payment): void
    {
        if (!self::includePullModule())
        {
            return;
        }
 
        self::sendEvent(
            self::SUCCESSFUL_PAYMENT,
            $payment->getId()
        );
    }
 
    public static function onFailurePayment(Sale\Payment $payment): void
    {
        if (!self::includePullModule())
        {
            return;
        }
 
        self::sendEvent(
            self::FAILURE_PAYMENT,
            $payment->getId()
        );
    }
 
    private static function sendEvent(string $eventName, int $id): void
    {
        $userIds = self::getSubscribedUserIds();
        if (empty($userIds))
        {
            return;
        }
 
        Pull\Event::add(
            $userIds,
            [
                'module_id' => self::MODULE_ID,
                'command' => self::PAYMENT_COMMAND,
                'params' => [
                    'eventName' => $eventName,
                    'paymentId' => $id,
                ],
            ]
        );
    }
 
    private static function getSubscribedUserIds(): array
    {
        return Pull\Model\WatchTable::getUserIdsByTag(
            self::PAYMENT_COMMAND
        );
    }
 
    private static function includePullModule(): bool
    {
        return Main\Loader::includeModule('pull');
    }
}