Carno\Config\Chips\Watching

Complexity

Total Complexity

10

Size/Duplication

Total Lines	77
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	wkChanged()	0	8	3
A	unwatch()	0	7	2
A	cbPerforming()	0	5	2
A	watching()	0	16	3

<?php
/**
 * Config watching
 * User: moyo
 * Date: 18/10/2017
 * Time: 3:30 PM
 */

namespace Carno\Config\Chips;

use Closure;
use Throwable;

trait Watching
{
    /**
     * @var array
     */
    private $observer = [];

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

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

    /**
     * @param string $key
     * @param Closure $observer
     * @return string
     */
    public function watching(string $key, Closure $observer) : string
    {
        $wid = spl_object_hash($observer);

        if ($key === '*') {
            $this->replicator[$wid] = $observer;
        } else {
            $this->observer[$key][$wid] = $observer;
            $this->watching[$wid][] = $key;
            // trigger notify immediate if value already exists
            if ($this->has($key)) {

It seems like has() must be provided by classes using this trait. How about adding it as abstract method to this trait?

                $this->cbPerforming($observer, $key, $this->get($key));

It seems like get() must be provided by classes using this trait. How about adding it as abstract method to this trait?

            }
        }

        return $wid;
    }

    /**
     * @param string $wid
     */
    public function unwatch(string $wid) : void
    {
        foreach ($this->watching[$wid] ?? [] as $key) {
            unset($this->observer[$key][$wid]);
        }
        unset($this->watching[$wid]);
        unset($this->replicator[$wid]);
    }

    /**
     * @param string $key
     * @param $new
     */
    protected function wkChanged(string $key, $new) : void
    {
        foreach ($this->observer[$key] ?? [] as $watcher) {
            $this->cbPerforming($watcher, $key, $new);
        }

        foreach ($this->replicator as $receiver) {
            $this->cbPerforming($receiver, $key, $new);
        }
    }

    /**
     * @param Closure $program
     * @param string $key
     * @param $value
     */
    private function cbPerforming(Closure $program, string $key, $value) : void
    {
        try {
            call_user_func_array($program, [$value, $key]);
        } catch (Throwable $e) {
            // do some thing
        }
    }
}