App\EventObserver

Complexity

Total Complexity

17

Size/Duplication

Total Lines	116
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	update()	0	4	2
A	validate()	0	14	5
A	__construct()	0	6	1
A	getResults()	0	3	1
B	handleEvent()	0	32	8

<?php

namespace App;

use SplSubject;
use SplObserver;
use Symfony\Component\Process\Process;

/**
 * @see https://www.php.net/manual/zh/class.splobserver.php
 */
class EventObserver implements SplObserver
{
    /**
     * @var array Event config
     */
    private $config;

    /**
     * @var array
     */
    private $results = [];

    /**
     * Construct a new event observer
     * 
     * @param  array  $config
     * @return void
     */
    public function __construct(array $config)
    {
        $this->config = $config + [
            'type' => '*',
            'conditions' => [],
            'commands' => []
        ];
    }

    /**
     * Receive update from subject
     * 
     * @param  \SplSubject $subject
     * @return void
     */
    public function update(SplSubject $subject): void
    {
        if ($subject instanceof EventSubject) {
            $this->handleEvent($subject);
        }
    }

    /**
     * Handle event.
     * 
     * @param  \App\EventSubject $subject
     * @return void
     * 
     * @throws \App\EventException
     */
    private function handleEvent(EventSubject $subject): void
    {
        $this->results = [];
        $this->config['conditions']['object_kind'] = $this->config['type'];
        foreach ($this->config['conditions'] as $key => $expected) {
            if (strpos($key, '.') !== false) {
                list($attr, $subkey) = explode('.', $key);
                $value = $subject[$attr][$subkey];
            } else {
                $value = $subject[$key];
            }
            if (self::validate($value, $expected) === false) {
                $this->results[] = ['debug', '{event} event ignored, expected: {expected}, actual: {actual}.', [
                    'event' => $this->config['name'],
                    'expected' => (is_array($expected) ? json_encode($expected) : $expected),
                    'actual' => $value,
                ]];
                return;
            }
        }
        foreach ($this->config['commands'] as $command) {
            $process = new Process($command, null, $subject->getEnv());
            $process->run();
            $output = $process->getOutput();
            $this->results[] = [
                ($process->isSuccessful() ? 'notice' : 'error'),
                '{event}: {command} (return:{code}){output}',
                [
                    'event' => $this->config['name'],
                    'command' => implode(' ', $command),
                    'code' => $process->getExitCode(),
                    'output' => ($output ? PHP_EOL.$output : '')
                ]
            ];
        }
    }

    /**
     * Get results
     * 
     * @return array
     */
    public function getResults(): array
    {
        return $this->results;
    }

    /**
     * Validate
     * 
     * @param mixed  $tested
     * @param mixed  $expected
     * @return bool
     */
    public static function validate($tested, $expected): bool
    {
        if (is_array($expected)) {
            $result = false;
            foreach ($expected as $item) {
                if ($result = self::validate($tested, $item)) {
                    break;
                }
            }
            return $result;
        } else if (strpos($expected, '*') !== false) {
            return preg_match('#^'.str_replace('*', '.*', $expected).'$#', $tested) > 0;
        } else {
            return $tested == $expected;
        }
    }
}