RunOpenCode\Backup\Workflow\Workflow

Complexity

Total Complexity

6

Size/Duplication

Total Lines	69
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	8

Test Coverage

Coverage

20.83%

Importance

Changes	5
Bugs	0	Features	3

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
B	execute()	0	44	5

<?php
/*
 * This file is part of the Backup package, an RunOpenCode project.
 *
 * (c) 2015 RunOpenCode
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 *
 * This project is fork of "kbond/php-backup", for full credits info, please
 * view CREDITS file that was distributed with this source code.
 */
namespace RunOpenCode\Backup\Workflow;

use Psr\Log\LoggerInterface;
use RunOpenCode\Backup\Backup\Backup;
use RunOpenCode\Backup\Contract\EventDispatcherAwareInterface;
use RunOpenCode\Backup\Contract\LoggerAwareInterface;
use RunOpenCode\Backup\Contract\ProfileInterface;
use RunOpenCode\Backup\Contract\WorkflowActivityInterface;
use RunOpenCode\Backup\Contract\WorkflowInterface;
use RunOpenCode\Backup\Event\BackupEvent;
use RunOpenCode\Backup\Event\BackupEvents;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;

/**
 * Class Workflow
 *
 * Workflow is entry point of backup workflow that executes workflow activities in given sequence.
 *
 * @package RunOpenCode\Backup\Workflow
 */
class Workflow implements WorkflowInterface
{
    /**
     * @var WorkflowActivityInterface[]
     */
    private $activities;

    /**
     * @var EventDispatcherInterface
     */
    private $eventDispatcher;

    /**
     * @var LoggerInterface
     */
    private $logger;

    public function __construct(EventDispatcherInterface $eventDispatcher, LoggerInterface $logger, array $activities)
    {
        $this->eventDispatcher = $eventDispatcher;
        $this->logger = $logger;
        $this->activities = $activities;
    }

    public function execute(ProfileInterface $profile)
    {
        $backup = new Backup($profile->getName());

        $this->logger->info(sprintf('About to execute backup for profile: "%s".', $profile->getName()));
        $this->eventDispatcher->dispatch(BackupEvents::BEGIN, new BackupEvent($this, $profile, $backup));

        /**
         * @var WorkflowActivityInterface $activity
         */
        foreach ($this->activities as $activity) {

            $activity
                ->setBackup($backup)
                ->setProfile($profile);

            /**
             * @var LoggerAwareInterface $activity
             */
            if ($activity instanceof LoggerAwareInterface) {
                $activity->setLogger($this->logger);
            }

            /**
             * @var EventDispatcherAwareInterface $activity
             */
            if ($activity instanceof EventDispatcherAwareInterface) {
                $activity->setEventDispatcher($this->eventDispatcher);
            }

            try {
                /**
                 * @var WorkflowActivityInterface $activity
                 */
                $activity->execute();

            } catch (\Exception $e) {

                $this->eventDispatcher->dispatch(BackupEvents::ERROR, new BackupEvent($this, $profile, $backup, $activity));

                throw $e;
            }
        }
    }
}