Listener.php

<?php
 
namespace Bitrix\Bizproc\Debugger;
 
use Bitrix\Bizproc\Automation\Engine\Template;
use Bitrix\Main\Loader;
use Bitrix\Main\Engine\CurrentUser;
 
class Listener
{
    private static self $instance;
 
    public function onDocumentStatusChanged(string $status)
    {
        $this->pushEvent('documentStatus', ['status' => $status]);
    }
 
    public function onWorkflowStatusChanged(string $workflowId, int $status)
    {
        $this->pushEvent('workflowStatus', [
            'workflowId' => $workflowId,
            'status' => $status,
        ]);
    }
 
    public function onWorkflowEventAdded(string $workflowId, string $eventName)
    {
        $session = Session\Manager::getActiveSession();
        $template = null;
        foreach ($session->getWorkflowContexts() as $workflowContext)
        {
            if ($workflowContext->getWorkflowId() === $workflowId)
            {
                $template = Template::createByTpl($workflowContext->fillTemplateShards()->fillTemplate());
                break;
            }
        }
 
        $robotId = null;
        if ($template)
        {
            foreach ($template->getRobots() as $robot)
            {
                if ($robot->getDelayName() === $eventName)
                {
                    $robotId = $robot->getName();
                    break;
                }
            }
        }
 
        $this->pushEvent('workflowEventAdd', [
            'workflowId' => $workflowId,
            'eventName' => $eventName,
            'sourceId' => $robotId,
        ]);
    }
 
    public function onWorkflowEventRemoved(string $workflowId, string $eventName)
    {
        $this->pushEvent('workflowEventRemove', [
            'workflowId' => $workflowId,
            'eventName' => $eventName,
        ]);
    }
 
    public function onDocumentUpdated(array $changedFields)
    {
        $documentId = Session\Manager::getActiveSession()->getFixedDocument()->getParameterDocumentId();
        $documentType = Session\Manager::getActiveSession()->getParameterDocumentType();
 
        $documentService = \CBPRuntime::GetRuntime(true)->getDocumentService();
        $documentFields = $documentService->getDocumentFields($documentType);
        $lazyList = $documentService->GetDocument($documentId);
 
        $rawValues = [];
        $values = [];
        $changedFields[] = 'DATE_MODIFY';
 
        //TODO - temporary
        if (in_array('ASSIGNED_BY_ID', $changedFields))
        {
            $changedFields[] = 'ASSIGNED_BY_EMAIL';
            $changedFields[] = 'ASSIGNED_BY_WORK_PHONE';
            $changedFields[] = 'ASSIGNED_BY_PERSONAL_MOBILE';
        }
 
        foreach ($changedFields as $fieldId)
        {
            $property = $documentFields[$fieldId] ?? null;
 
            if (!$property)
            {
                continue;
            }
 
            $fieldType = $documentService->getFieldTypeObject($documentType, $property);
 
            if (!$fieldType)
            {
                continue;
            }
 
            $fieldType->setDocumentId($documentId);
 
            $rawValues[$fieldId] = $lazyList[$fieldId];
            $values[$fieldId] = $fieldType->formatValue($rawValues[$fieldId]);
        }
 
        $this->pushEvent(
            'documentValues',
            [
                'values' => $values,
                'rawValues' => $rawValues,
            ]
        );
    }
 
    public function onDocumentDeleted()
    {
        $this->pushEvent('documentDelete', []);
    }
 
    public function onTrackWrite($row)
    {
        $this->pushEvent('trackRow', ['row' => $row]);
    }
 
    public function onSessionFinished(string $sessionId)
    {
        $this->pushEvent('sessionFinish', ['sessionId' => $sessionId]);
    }
 
    private function canPush()
    {
        return Loader::includeModule('pull');
    }
 
    private function pushEvent(string $command, array $params)
    {
        if ($this->canPush())
        {
            \Bitrix\Pull\Event::add(
                CurrentUser::get()->getId(),
                [
                    'module_id' => 'bizproc',
                    'command' => $command,
                    'params' => $params,
                ]
            );
        }
    }
 
    public static function getInstance(): self
    {
        if (!isset(self::$instance))
        {
            self::$instance = new self();
        }
        return self::$instance;
    }
    private function __construct()
    {
    }
    private function __clone()
    {
    }
}