Comodojo\Extender\ExtenderDaemon

Complexity

Total Complexity

9

Size/Duplication

Total Lines	95
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	getRunPath()	0	2	1
A	__construct()	0	31	6
A	installWorkers()	0	22	1
A	setup()	0	14	1

<?php namespace Comodojo\Extender;

use \Comodojo\Foundation\Base\ConfigurationTrait;
use \Comodojo\Foundation\Events\Manager as EventsManager;
use \Comodojo\Foundation\Base\Configuration;
use \Comodojo\Foundation\Logging\Manager as LogManager;
use \Comodojo\Foundation\Utils\ArrayOps;
use \Comodojo\Daemon\Daemon as AbstractDaemon;
use \Comodojo\Extender\Workers\ScheduleWorker;
use \Comodojo\Extender\Workers\QueueWorker;
use \Comodojo\Extender\Task\Table as TasksTable;
use \Comodojo\Extender\Components\Database;
use \Comodojo\Extender\Traits\TasksTableTrait;
use \Comodojo\Extender\Socket\SocketInjector;
use \Comodojo\Extender\Traits\CacheTrait;
use \Comodojo\SimpleCache\Manager as SimpleCacheManager;
use \Psr\Log\LoggerInterface;
use \Exception;

/**
 * @package     Comodojo Extender
 * @author      Marco Giovinazzi <marco.giovinazzi@comodojo.org>
 * @license     MIT
 *
 * LICENSE:
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 * THE SOFTWARE.
 */

class ExtenderDaemon extends AbstractDaemon {

    use ConfigurationTrait;
    use CacheTrait;
    use TasksTableTrait;

    protected static $default_properties = array(
        'pidfile' => '',
        'sockethandler' => '',
        'socketbuffer' => 1024,
        'sockettimeout' => 2,
        'socketmaxconnections' => 100,
        'niceness' => 0,
        'arguments' => '\\Comodojo\\Daemon\\Console\\DaemonArguments',
        'description' => 'Extender Daemon'
    );

    public function __construct(
        array $configuration,
        array $tasks,
        EventsManager $events = null,
        SimpleCacheManager $cache = null,
        LoggerInterface $logger = null
    ) {

        $this->configuration = new Configuration(self::$default_properties);
        $this->configuration->merge($configuration);

        $run_path = $this->getRunPath();

        if ( empty($this->configuration->get('sockethandler')) ) {
            $this->configuration->set('sockethandler', "unix://$run_path/extender.sock");
        }

        if ( empty($this->configuration->get('pidfile')) ) {
            $this->configuration->set('pidfile', "$run_path/extender.pid");
        }

        $logger = is_null($logger) ? LogManager::createFromConfiguration($this->configuration, "extender-log")->getLogger() : $logger;
        $events = is_null($events) ? EventsManager::create($logger) : $events;

        parent::__construct(ArrayOps::replaceStrict(self::$default_properties, $this->configuration->get()), $logger, $events);

        $table = new TasksTable($this->configuration, $this->getLogger(), $this->getEvents());
        $table->addBulk($tasks);
        $this->setTasksTable($table);

        $this->setCache(is_null($cache) ? SimpleCacheManager::createFromConfiguration($this->configuration, $this->logger) : $cache);

    }

    public function setup() {

        // try {

50% of this comment could be valid code. Did you maybe forget this after debugging?

        //     if ( Database::validate($this->configuration) === false ){

50% of this comment could be valid code. Did you maybe forget this after debugging?

        //         printf("\nWARNING: %s\n\n", "database seems to be not in sync!");

67% of this comment could be valid code. Did you maybe forget this after debugging?

        //     }

50% of this comment could be valid code. Did you maybe forget this after debugging?

        // } catch (Exception $e) {

50% of this comment could be valid code. Did you maybe forget this after debugging?

        //     printf("\nFATAL ERROR: %s\n\n", $e->getMessage());

70% of this comment could be valid code. Did you maybe forget this after debugging?

        //     $this->end(1);

72% of this comment could be valid code. Did you maybe forget this after debugging?

        // }

50% of this comment could be valid code. Did you maybe forget this after debugging?

        $this->installWorkers();

        SocketInjector::inject($this);

    }

    protected function installWorkers() {

        // add workers
        $manager = $this->getWorkers();

        $schedule_worker = new ScheduleWorker("scheduler");
        $schedule_worker
            ->setConfiguration($this->getConfiguration())
            ->setLogger($this->getLogger())
            ->setEvents($this->getEvents())
            ->setTasksTable($this->getTasksTable());

        $queue_worker = new QueueWorker("queue");
        $queue_worker
            ->setConfiguration($this->getConfiguration())
            ->setLogger($this->getLogger())
            ->setEvents($this->getEvents())
            ->setTasksTable($this->getTasksTable());

        $manager
            ->install($schedule_worker, 1, true)
            ->install($queue_worker, 1, true);

    }

    private function getRunPath() {
        return $this->configuration->get('base-path')."/".$this->configuration->get('run-path');
    }

}