RequestMultiple.php

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

<?php
declare(strict_types=1);
 
namespace Bitrix\Landing\Copilot\Generation\Step;
 
use Bitrix\Landing\Copilot\Connector\AI\Prompt;
use Bitrix\Landing\Copilot\Generation;
use Bitrix\Landing\Copilot\Generation\Request;
use Bitrix\Landing\Copilot\Generation\Type\RequestEntityDto;
 
abstract class RequestMultiple extends AIStep
{
    public function __construct()
    {
        parent::__construct();
    }

    protected array $entities = [];

    protected array $requests = [];
 
    abstract public static function getConnectorClass(): string;

    protected function initialize(): void
    {
        $this->requests = Request::getByGeneration($this->generation->getId(), $this->stepId);
    }

    public function execute(): bool
    {
        if (!parent::execute())
        {
            return false;
        }
 
        if (!isset($this->siteData))
        {
            return false;
        }
 
        if (
            $this->isStarted()
            && $this->applyResponses()
        )
        {
            $this->changed = true;
        }
 
        if (!$this->isFinished())
        {
            $this->sendRequests();
        }
 
        return true;
    }

    public function isAsync(): bool
    {
        return true;
    }

    public function isStarted(): bool
    {
        foreach ($this->getEntitiesToRequest() as $entity)
        {
            if (
                isset($entity->requestId)
                && isset($this->requests[$entity->requestId])
            )
            {
                return true;
            }
        }
 
        return false;
    }

    public function isFinished(): bool
    {
        if (empty($this->getEntitiesToRequest()))
        {
            return true;
        }
 
        if (empty($this->requests))
        {
            return false;
        }
 
        foreach ($this->requests as $request)
        {
            if (!$request->isApplied())
            {
                return false;
            }
        }
 
        return true;
    }

    public function clearErrors(): void
    {
        foreach ($this->requests as $request)
        {
            if (
                $request
                && $request->getError()
            )
            {
                $request->setDeleted();
                unset($this->requests[$request->getId()]);
            }
        }
    }

    abstract protected function getEntitiesToRequest(): array;

    abstract protected function sendRequests(): bool;

    abstract protected function applyResponses(): bool;
}