Jenner\LogMonitor\MonitorTask

Complexity

Total Complexity

7

Size/Duplication

Total Lines	67
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes	4
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	13	1
A	run()	0	15	4
A	signalHandler()	0	11	2

<?php
/**
 * Created by PhpStorm.
 * User: Jenner
 * Date: 2015/10/14
 * Time: 9:34
 */

namespace Jenner\LogMonitor;


use Jenner\LogMonitor\Filter\FilterInterface;
use Jenner\LogMonitor\Notification\NotificationInterface;
use Jenner\LogMonitor\Reader\ReaderInterface;
use Jenner\SimpleFork\Process;

class MonitorTask extends Process
{
    /**
     * @var ReaderInterface
     */
    protected $reader;

    /**
     * @var FilterInterface
     */
    protected $filter;

    /**
     * @var NotificationInterface
     */
    protected $notify;

    /**
     * @param ReaderInterface $reader
     * @param FilterInterface $filter
     * @param NotificationInterface $notify
     */
    public function __construct(
        ReaderInterface $reader,
        FilterInterface $filter,
        NotificationInterface $notify
    )
    {
        parent::__construct();
        $this->reader = $reader;
        $this->filter = $filter;
        $this->notify = $notify;

        $this->registerSignalHandler(SIGTERM, array($this, 'signalHandler'));
    }

    /**
     * sub process run
     */
    public function run()
    {
        $this->reader->open();
        while (true) {
            $line = $this->reader->read();
            if ($line === false) {
                usleep(200);
                continue;
            }
            if ($this->filter->filter($line)) {
                $message = $this->filter->getErrorMessage($line, $this->reader);
                $this->notify->send($this->reader->info(), $message);
            }
        }
    }

    protected function signalHandler($signal)
    {
        switch ($signal) {
            case SIGTERM :

There must be no space before the colon in a CASE statement

                $this->reader->close();
                unset($this->reader);
                unset($this->filter);
                unset($this->notify);
                exit(0);

The method signalHandler() contains an exit expression.

        }
    }
}