Comodojo\Extender\Socket\Commands\Queue\AddBulk::execute()

Complexity

Conditions	3
Paths	3

Size

Total Lines	23
Code Lines	13

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	12

Importance

Changes

0

<?php namespace Comodojo\Extender\Socket\Commands\Queue;
    public static function execute(Parameters $params, Daemon $daemon) {

        $messages = $params->get('requests');

        $requests = [];

        try {
            foreach ($messages as $message) {
                $requests[] = 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->addBulk($requests);