Comodojo\Extender\Socket\Commands\Queue\Add

Complexity

Total Complexity

2

Size/Duplication

Total Lines	21
Duplicated Lines	0 %

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	execute()	0	19	2

<?php namespace Comodojo\Extender\Socket\Commands\Queue;

use \Comodojo\Extender\Queue\Manager;
use \Comodojo\Daemon\Daemon;
use \Comodojo\RpcServer\Request\Parameters;
use \Comodojo\Extender\Socket\Messages\Task\Request as TaskRequestMessage;
use \Comodojo\Extender\Task\Request as TaskRequest;
use \Comodojo\Exception\RpcException;
use \Exception;

class Add {

    public static function execute(Parameters $params, Daemon $daemon) {

        $message = $params->get('request');

        try {
            $request = TaskRequest::createFromMessage(
                TaskRequestMessage::createFromExport($message)
            );
        } catch (Exception $e) {
            throw new RpcException("Invalid message payload in request", -32600);
        }

        $manager = new Manager(
            $daemon->getConfiguration(),

The method getConfiguration() does not exist on Comodojo\Daemon\Daemon. It seems like you code against a sub-type of Comodojo\Daemon\Daemon such as Comodojo\Extender\ExtenderDaemon.

            $daemon->getLogger(),
            $daemon->getEvents()
        );

        return $manager->add($request);

    }

}