<?php

namespace App\Listeners\V1;

use App\Events\V1\EventAvanseNoc;
use App\Lib\Common\RabbitMQ;
use App\QueueLog;
use PhpAmqpLib\Exchange\AMQPExchangeType;

class ListenerAvanseNoc
{
    /**
     * Create the event listener.
     *
     * @return void
     */
    public function __construct()
    {
        //
    }

    /**
     * Handle the event.
     *
     * @param  object  $event
     * @return void
     */
    public function handle(EventAvanseNoc $event)
    {
        try {
            $job_handler_cmd = \Config::get('constants.rabbitmq.es_handler').'@'.
                \Config::get('constants.rabbitmq.method_run_cmd');
            $request_data = [
                'cmd' => 'command:AvanseNocCommand',
                'con' => 'jobs'
            ];
            $request_data['job_handler'] = $job_handler_cmd;
            $queueLog = QueueLog::create([
                //'uid' => $event->uid,
                'exchange' => \Config::get('constants.rabbitmq.job_exch'),
                'route_key' => \Config::get('constants.rabbitmq.exch_rout_key_job'),
                'job_handler' => $job_handler_cmd,
                'input' => json_encode($request_data),
            ]);
            $request_data['job_id'] = $queueLog->job_id;

            $QueueLog = QueueLog::find($request_data['job_id']);
            $QueueLog->input = json_encode($request_data);
            $QueueLog->save();

        } catch (\Exception $e) {
            report($e);
            dd($e->getFiles()." ".$e->getLines());
        }
    }
}