TheAentMachine\Aent\Event\Service\AbstractServiceAddEvent

Complexity

Total Complexity

16

Size/Duplication

Total Lines	116
Duplicated Lines	0 %

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	beforeExecute()	0	5	1
A	getEventName()	0	3	1
A	byebye()	0	4	1
A	executeEvent()	0	12	2
A	afterExecute()	0	3	1
A	fetchEnvironments()	0	18	5
A	shouldRegisterEvents()	0	3	1
A	dispatch()	0	13	4

<?php

namespace TheAentMachine\Aent\Event\Service;

use Safe\Exceptions\StringsException;
use TheAentMachine\Aent\Context\Context;
use TheAentMachine\Aent\Event\AbstractEvent;
use TheAentMachine\Aent\Event\Service\Model\Environments;
use TheAentMachine\Aent\Event\Service\Model\ServiceState;
use TheAentMachine\Aenthill\Aenthill;
use TheAentMachine\Service\Service;
use function Safe\sprintf;

abstract class AbstractServiceAddEvent extends AbstractEvent
{
    /**
     * @param Environments $environments
     * @return ServiceState[]
     */
    abstract protected function createServices(Environments $environments): array;

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

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

    /**
     * @return void
     * @throws StringsException
     */
    protected function beforeExecute(): void
    {
        $this->output->writeln(sprintf(
            "👋 Hello! I'm the aent <info>%s</info> and I'm going to setup myself!",
            $this->getAentName()
        ));
    }

    /**
     * @param null|string $payload
     * @return null|string
     * @throws StringsException
     */
    protected function executeEvent(?string $payload): ?string
    {
        $environments = $this->fetchEnvironments();
        $this->prompt->printAltBlock(sprintf("%s: configuring service(s)...", $this->getAentName()));
        $servicesStates = $this->createServices($environments);
        foreach ($servicesStates as $serviceState) {
            $this->dispatch($environments->getDevelopmentEnvironments(), $serviceState->getDevelopmentVersion());
            $this->dispatch($environments->getTestEnvironments(), $serviceState->getTestVersion());
            $this->dispatch($environments->getProductionEnvironments(), $serviceState->getProductionVersion());
        }
        $this->prompt->printBlock("Dispatch done.");
        return null;
    }

    /**
     * @return void
     * @throws StringsException
     */
    protected function afterExecute(): void
    {
        $this->output->writeln(sprintf("\n👋 Hello again! This is the aent <info>%s</info> and we have finished my setup.", $this->getAentName()));
    }

    /**
     * @return Environments
     * @throws StringsException
     */
    private function fetchEnvironments(): Environments
    {
        $this->prompt->printAltBlock(sprintf("%s: fetching environments...", $this->getAentName()));
        $responses = Aenthill::dispatchJson('CHOOSE_ENVIRONMENT', []);
        if (empty($responses)) {
            $this->byebye();
        }
        $environments = new Environments();
        foreach ($responses as $response) {
            if (!empty($response)) {
                $context = Context::fromArray($response);
                $environments->add($context);
            }
        }
        if ($environments->isEmpty()) {
            $this->byebye();
        }
        return $environments;
    }

    /**
     * @return void
     * @throws StringsException
     */
    private function byebye(): void
    {
        $this->output->writeln(sprintf("\n👋 Hello again! This is the aent <info>%s</info> and you have not selected any environment! Bye!", $this->getAentName()));
        exit(0);

Using exit here is not recommended.

    }

    /**
     * @param Context[] $environments
     * @param null|Service $service
     * @throws StringsException
     */
    private function dispatch(array $environments, ?Service $service): void
    {
        if (empty($environments || empty($service))) {

The expression $environments of type TheAentMachine\Aent\Context\Context[] is implicitly converted to a boolean; are you sure this is intended? If so, consider using ! empty($expr) instead to make it clear that you intend to check for an array without elements.

            return;
        }
        foreach ($environments as $environment) {
            $this->prompt->printBlock(sprintf(
                "Dispatching service %s for %s environment %s.",
                $service->getServiceName(),

The method getServiceName() does not exist on null.

                $environment->getEnvironmentType(),
                $environment->getEnvironmentName()
            ));
            Aenthill::dispatchJson('NEW_SERVICE', $service, sprintf('"ENVIRONMENT_NAME" in Metadata and Metadata["ENVIRONMENT_NAME"] == "%s"', $environment->getEnvironmentName()));
        }
    }
}