kalanis\EmailApi\Sending

Complexity

Total Complexity

15

Size/Duplication

Total Lines	74
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	2
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	canUseService()	0	3	1
A	systemServiceId()	0	3	1
A	isAllowed()	0	3	2
B	sendEmail()	0	31	10

<?php

namespace kalanis\EmailApi;


/**
 * Class Sending
 * Send mails by correct service
 * Select the only one - first successful one
 */
class Sending implements Interfaces\ISending
{
    const CALL_UNKNOWN = 590;
    const CALL_RUN_DIED = 591;
    const CALL_EXCEPTION = 592;

    protected LocalInfo\ServicesOrdering $servicesIterator;
    protected Interfaces\ILocalInfo $info;

    public function __construct(Interfaces\ILocalInfo $info, LocalInfo\ServicesOrdering $ordering)
    {
        $this->info = $info;
        $this->servicesIterator = $ordering;
    }

    public function canUseService(): bool
    {
        return $this->servicesIterator->canUseService();
    }

    public function systemServiceId(): int
    {
        return static::SERVICE_SYSTEM;
    }

    /**
     * @param Interfaces\IContent $content
     * @param Interfaces\IEmailUser $to
     * @param Interfaces\IEmailUser|null $from
     * @param Interfaces\IEmailUser|null $replyTo
     * @param bool $toDisabled
     * @throws Exceptions\EmailException
     * @return Basics\Result
     */
    public function sendEmail(Interfaces\IContent $content, Interfaces\IEmailUser $to, ?Interfaces\IEmailUser $from = null, ?Interfaces\IEmailUser $replyTo = null, $toDisabled = false): Basics\Result
    {
        $this->info->beforeProcess($content, $to, $from);

        if ($this->canUseService()) {
            foreach ($this->servicesIterator as $index => $lib) {
                if ($lib && is_object($lib) && ($lib instanceof Interfaces\ISending)) {
                    if (!$this->isAllowed($lib)) {
                        continue;
                    }
                    $this->info->beforeSend($lib, $content);
                    try {
                        $result = $lib->sendEmail($content, $to, $from, $replyTo, $toDisabled);
                        if ($result->getStatus()) {
                            $this->info->whenResultIsSuccessful($lib, $result);
                            return $result;
                        } else {
                            $this->info->whenResultIsNotSuccessful($lib, $result);
                            $this->servicesIterator->removeService($lib); // throw it out, if we send more mail, then it won't be bothered anymore on this run
                            if ($this->servicesIterator->isReturningAfterFirstUnsuccessful()) {
                                return $result;
                            }
                        }
                    } catch (Exceptions\EmailException $ex) {
                        $this->info->whenSendFails($lib, $ex);
                    }
                }
            }
        }
        $this->info->whenNoDefinitionIsUsable();
        return new Basics\Result(false, $this->info->getLangSendingFailed());
    }

    /**
     * @param mixed $lib
     * @return bool
     */
    protected function isAllowed($lib): bool
    {
        return (($lib instanceof Interfaces\ISending) && $lib->canUseService());
    }
}