TheAentMachine\Aent\Event\Orchestrator\AbstractOrchestratorAddEvent

Complexity

Total Complexity

10

Size/Duplication

Total Lines	118
Duplicated Lines	0 %

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	registerCI()	0	8	1
A	registerDockerfileBuilder()	0	8	1
A	getEventName()	0	3	1
A	beforeExecute()	0	9	1
A	shouldRegisterEvents()	0	3	1
A	finish()	0	4	1
A	executeJsonEvent()	0	13	3
A	afterExecute()	0	9	1

<?php

namespace TheAentMachine\Aent\Event\Orchestrator;

use Safe\Exceptions\StringsException;
use TheAentMachine\Aent\Context\BaseOrchestratorContext;
use TheAentMachine\Aent\Context\Context;
use TheAentMachine\Aent\Context\ContextInterface;
use TheAentMachine\Aent\Event\AbstractJsonEvent;
use TheAentMachine\Aent\Payload\Bootstrap\BootstrapPayload;
use TheAentMachine\Aent\Registry\ColonyRegistry;
use TheAentMachine\Aent\Registry\Exception\ColonyRegistryException;
use TheAentMachine\Aenthill\Aenthill;
use function Safe\sprintf;

abstract class AbstractOrchestratorAddEvent extends AbstractJsonEvent
{
    /**
     * @return ContextInterface
     */
    abstract protected function setup(): ContextInterface;

    /**
     * @param ContextInterface $context
     * @return ContextInterface
     */
    abstract protected function addDeployJobInCI(ContextInterface $context): ContextInterface;

    /**
     * @return string
     */
    protected function getEventName(): string
    {
        return 'ADD_ORCHESTRATOR';
    }

    /**
     * @return bool
     */
    protected function shouldRegisterEvents(): bool
    {
        return true;
    }

    /**
     * @return void
     * @throws StringsException
     */
    protected function beforeExecute(): void
    {
        /** @var Context $context */
        $context = Context::fromMetadata();
        $this->output->writeln(sprintf(
            "\n👋 Hello! I'm the aent <info>%s</info> and I'm going to setup myself as orchestrator for <info>%s</info> environment <info>%s</info>.",
            $this->getAentName(),
            $context->getEnvironmentType(),
            $context->getEnvironmentName()
        ));
    }

    /**
     * @param mixed[] $payload
     * @return mixed[]|null
     * @throws ColonyRegistryException
     * @throws StringsException
     */
    protected function executeJsonEvent(array $payload): ?array
    {
        $orchestratorContext = $this->setup();
        $this->registerDockerfileBuilder();
        /** @var Context $context */
        $context = Context::fromMetadata();
        if (!$context->isDevelopment() && !empty($payload)) {
            $payload = BootstrapPayload::fromArray($payload);
            $this->registerCI($payload);
            $orchestratorContext = $this->addDeployJobInCI($orchestratorContext);
        }
        $this->finish($orchestratorContext);
        return null;
    }

    /**
     * @return void
     * @throws ColonyRegistryException
     * @throws StringsException
     */
    private function registerDockerfileBuilder(): void
    {
        $this->prompt->printAltBlock(sprintf("%s: registering Dockerfile builder...", $this->getAentName()));
        $registry = ColonyRegistry::builderRegistry();
        $aent = $registry->getAent(ColonyRegistry::DOCKERFILE);
        /** @var Context $context */
        $context = Context::fromMetadata();
        Aenthill::register($aent->getImage(), BaseOrchestratorContext::BUILDER_DEPENDENCY_KEY, $context->toArray());
    }

    /**
     * @param BootstrapPayload $payload
     * @throws StringsException
     */
    private function registerCI(BootstrapPayload $payload): void
    {
        $this->prompt->printAltBlock(sprintf("%s: registering CI/CD provider...", $this->getAentName()));
        $aent = $payload->getCIAent();
        /** @var Context $context */
        $context = Context::fromMetadata();
        $metadata = \array_merge($context->toArray(), $payload->getCIMetadata());
        Aenthill::register($aent->getImage(), BaseOrchestratorContext::CI_DEPENDENCY_KEY, $metadata);
    }

    /**
     * @param ContextInterface $context
     * @throws StringsException
     */
    private function finish(ContextInterface $context): void
    {
        $this->prompt->printAltBlock(sprintf("%s: finishing...", $this->getAentName()));
        $context->toMetadata();
    }

    /**
     * @return void
     * @throws StringsException
     */
    protected function afterExecute(): void
    {
        /** @var Context $context */
        $context = Context::fromMetadata();
        $this->output->writeln(
            sprintf(
                "\nI've finished my setup for your <info>%s</info> environment <info>%s</info>. See you later!",
                $context->getEnvironmentType(),
                $context->getEnvironmentName()
            )
        );
    }
}