<?php

namespace App\Console\Commands;

use App\Avanse\Services\AvanseServices;
use App\Lib\Common\RabbitMQ;
use App\QueueLog;
use App\Slack;
use Illuminate\Console\Command;
use Illuminate\Http\Request;
use Illuminate\Queue\Queue;
use Illuminate\Support\Arr;
use Symfony\Component\Console\Input\InputArgument;


class RQConsumerListener extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'command:RQConsumerListener {q_name} {q_tag?} {q_bind?} {exchange?} {route_key?}';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'RabbitMQ queue consumer';

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
    }

    /**
     * Get the console command arguments.
     *
     * @return array
     */
    protected function getArguments() {
        return array (
            array (
                'q_name',
                InputArgument::REQUIRED,
                'Queue name is required'
            ),
            array (
                'q_tag',
                InputArgument::OPTIONAL,
                'Queue tag is optional'
            ),
            array (
                'q_bind',
                InputArgument::OPTIONAL,
                'Queue bind is optional possible values either 1  or 0'
            ),
            array (
                'exchange',
                InputArgument::OPTIONAL,
                'Exchange is optional'
            ),
            array (
                'route_key',
                InputArgument::OPTIONAL,
                'Route key is optional'
            )

        );
    }

    /**
     * Execute the console command.
     *
     * @return mixed
     */
    public function handle($id=null, $automation=false)
    {

        try {
            if ($id) {
                $jobs = QueueLog::where('job_id', $id)->get();
            } else {
                $jobs = QueueLog::where('status','!=', 'com')->where('input', 'not like', '%TableOfOffer%')->where('attempt_count', 0)->whereNull('job_status')->limit(20)->get();
                $this->comment('Queue Log '. count($jobs));
            }
            $rabbitMqObj = new RabbitMQ();
            foreach ($jobs as $job) {
                QueueLog::where('job_id', $job->job_id)->update(['job_status' => 1]);
                if (!$id) {
                    $this->comment('Job Id '. $job->job_id);
                }
                $bodyObj = new \stdClass();
                $bodyObj->body = $job;
                $rabbitMqObj->callMeBack($bodyObj, $this, $automation);
                if (!$id) {
                    $this->comment('Executed '. $job->job_id);
                } else {
                    return true;
                }
            }
        } catch (\Exception $e) {
            $this->comment('Exception '.$e->getMessage());
            //(new Slack(new Request(['title' => 'RabbitMQ Lis ex', 'fields' => ['m' => $e->getMessage(), 'l' => $e->getLine(), 'f' => $e->getFile()], 'group' => Slack::$STAGE_TESTING])))->send();
            //$this->error($e->getMessage());
        }
    }
}