Gewaer\Cli\Tasks\QueueTask::notificationAction()

Complexity

Conditions	5
Paths	2

Size

Total Lines	76
Code Lines	41

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	30

Importance

Changes

0

<?php
    public function notificationAction()
    {
        $channel = $this->queue->channel();

        // Create the queue if it doesnt already exist.
        $channel->queue_declare(
            $queue = "notifications",
            $passive = false,
            $durable = true,
            $exclusive = false,
            $auto_delete = false,
            $nowait = false,
            $arguments = null,
            $ticket = null
        );

        echo ' [*] Waiting for notifications. To exit press CTRL+C', "\n";

        $callback = function ($msg) {
            $msgObject = json_decode($msg->body);



            echo ' [x] Received from system module: ',$msgObject->system_module, "\n";


            /**
             * Lets determine what type of notification we are dealing with
             */
            switch ($msgObject->notification_type_id) {
                 case 1:
                      $notification = new AppsPushNotifications((array)$msgObject->user, $msgObject->content, $msgObject->system_module);
                     break;
                 case 2:
                    $notification = new UsersPushNotifications((array)$msgObject->user, $msgObject->content, $msgObject->system_module);
                     break;

                 case 3:
                    $notification = new SystemPushNotifications((array)$msgObject->user, $msgObject->content, $msgObject->system_module);
                     break;
                 
                 default:
                     # code...
                     break;
             }

Closing brace indented incorrectly; expected 12 spaces, found 13

            /**
             * Trigger Event Manager
             */
            Di::getDefault()->getManager()->trigger($notification);

The variable $notification does not seem to be defined for all execution paths leading up to this point.

            /**
             * Log the delivery info
             */
            $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
        };

        $channel->basic_qos(null, 1, null);

        $channel->basic_consume(
            $queue = "notifications",
            $consumer_tag = '',
            $no_local = false,
            $no_ack = false,
            $exclusive = false,
            $nowait = false,
            $callback
        );

        while (count($channel->callbacks)) {
            $channel->wait();
        }

        $channel->close();
        $this->queue->close();
    }