<?php

namespace App\Listeners\V1;

use App\AuditQueue;
use App\Events\V1\EventABFLWebhook;
use App\Events\V1\EventAuditorService;
use App\Events\V1\EventJobs;
use App\Lib\Common\RabbitMQ;
use App\QueueLog;
use Carbon\Carbon;
use PhpAmqpLib\Exchange\AMQPExchangeType;

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

    const PENDING = 'PENDING';
    const QUEUE = 'QUEUE';
    const FAILED = 'FAILED';
    const COMPLETED = 'COMPLETED';

    /**
     * Handle the event.
     *
     * @param  object  $event
     * @return void
     */
    public function handle(EventAuditorService $event)
    {
        try {
             $queue = new AuditQueue();
             $queue->fill([
                     'status' => self::PENDING,
                     'cmd' => 'command:systemAuditor',
                     'service_name' => $event->initiator[0],
                     'input' => json_encode($event),
                     'available_at' => Carbon::now()->toDateTimeString(),
                     'created_at' => Carbon::now()->toDateTimeString()
            ]);
            $queue->save();

        } catch (\Exception $e) {

        }
    }
}