basepush.php

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

<?php
 
namespace Bitrix\Bizproc\Integration\Push;
 
abstract class BasePush
{
    public const EVENT_ADDED = 'ADDED';
    public const EVENT_UPDATED = 'UPDATED';
    public const EVENT_DELETED = 'DELETED';
 
    abstract protected static function getCommand(): string;
 
    public static function subscribeUser(int $userId): void
    {
        (new PushWorker())->subscribe($userId, static::getCommand());
    }
 
    public static function pushAdded(mixed $itemId, ...$userIds): void
    {
        static::pushLastEvent(static::EVENT_ADDED, $itemId, $userIds);
    }
 
    public static function pushUpdated(mixed $itemId, ...$userIds): void
    {
        static::pushLastEvent(static::EVENT_UPDATED, $itemId, $userIds);
    }
 
    public static function pushDeleted(mixed $itemId, ...$userIds): void
    {
        static::pushLastEvent(static::EVENT_DELETED, $itemId, $userIds);
    }
 
    public static function pushLastEvent(string $eventName, mixed $itemId, array $userIds): void
    {
        $userIds = array_unique(\CBPHelper::flatten($userIds));
        if (empty($userIds))
        {
            return;
        }
 
        $command = static::getCommand();
 
        $push = new PushWorker();
        $push->sendLast(
            "{$command}-{$itemId}-{$eventName}",
            $command,
            [
                'eventName' => $eventName,
                'items' => [
                    [
                        'id' => $itemId,
                    ],
                ],
            ],
            $userIds,
        );
    }
}