StateMachineFactory

Complexity

Total Complexity

7

Size/Duplication

Total Lines	78
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	4

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	forDNDeployment()	0	49	1
B	addHandlers()	0	22	6

<?php

use Finite\State\StateInterface;

class StateMachineFactory extends Object {

	private static $handlers = [];

	public function forDNDeployment(DNDeployment $obj) {
		$loader = new Finite\Loader\ArrayLoader([
			'class'   => 'DNDeployment',
			'states'  => [
				DNDeployment::STATE_NEW => ['type' => StateInterface::TYPE_INITIAL],
				DNDeployment::STATE_SUBMITTED => ['type' => StateInterface::TYPE_NORMAL],
				DNDeployment::STATE_INVALID => ['type' => StateInterface::TYPE_NORMAL],
				DNDeployment::STATE_QUEUED => ['type' => StateInterface::TYPE_NORMAL],
				DNDeployment::STATE_DEPLOYING => ['type' => StateInterface::TYPE_NORMAL],
				DNDeployment::STATE_ABORTING => ['type' => StateInterface::TYPE_NORMAL],
				DNDeployment::STATE_COMPLETED => ['type' => StateInterface::TYPE_FINAL],
				DNDeployment::STATE_FAILED => ['type' => StateInterface::TYPE_FINAL],
			],
			'transitions' => [
				DNDeployment::TR_SUBMIT => ['from' => [DNDeployment::STATE_NEW], 'to' => DNDeployment::STATE_SUBMITTED],
				DNDeployment::TR_QUEUE => ['from' => [DNDeployment::STATE_SUBMITTED], 'to' => DNDeployment::STATE_QUEUED],
				DNDeployment::TR_INVALIDATE  => [
					'from' => [DNDeployment::STATE_NEW, DNDeployment::STATE_SUBMITTED],
					'to' => DNDeployment::STATE_INVALID
				],
				DNDeployment::TR_DEPLOY  => ['from' => [DNDeployment::STATE_QUEUED], 'to' => DNDeployment::STATE_DEPLOYING],
				DNDeployment::TR_ABORT => [
					'from' => [
						DNDeployment::STATE_QUEUED,
						DNDeployment::STATE_DEPLOYING,
						DNDeployment::STATE_ABORTING
					],
					'to' => DNDeployment::STATE_ABORTING
				],
				DNDeployment::TR_COMPLETE => ['from' => [DNDeployment::STATE_DEPLOYING], 'to' => DNDeployment::STATE_COMPLETED],
				DNDeployment::TR_FAIL  => [
					'from' => [
						DNDeployment::STATE_NEW,
						DNDeployment::STATE_SUBMITTED,
						DNDeployment::STATE_QUEUED,
						DNDeployment::STATE_INVALID,
						DNDeployment::STATE_DEPLOYING,
						DNDeployment::STATE_ABORTING
					],
					'to' => DNDeployment::STATE_FAILED
				],
			]
		]);
		$stateMachine = new Finite\StateMachine\StateMachine($obj);
		$loader->load($stateMachine);
		$stateMachine->initialize();
		$this->addHandlers($stateMachine);
		return $stateMachine;
	}

	protected function addHandlers($machine) {
		$class = get_class($machine->getObject());
		if (empty($this->config()->handlers[$class])) return;

		$transitions = $this->config()->handlers[$class];
		foreach ($transitions as $transName => $handlers) {
			if (!is_array($handlers)) {
				throw new Exception(sprintf('Transition %s must be configured as an assoc array.', $transName));
			}

			foreach ($handlers as $handlerClass => $handlerMethod) {
				$handlerObj = Injector::inst()->get($handlerClass);
				if (!is_callable([$handlerObj, $handlerMethod])) {
					throw new Exception(sprintf('Handler %s is not callable on %s.', $handlerMethod, $handlerClass));
				}
				$machine->getDispatcher()->addListener(
					sprintf('finite.post_transition.%s', $transName),
					[$handlerObj, $handlerMethod]
				);
			}
		}
	}

}