<?php

namespace App\Console\Commands;

use App\Auditor\Helper\LoanManagementAuditService;
use App\AuditQueue;
use App\Events\V1\EventAuditorService;
use App\Listeners\V1\ListenerAuditService;
use Illuminate\Console\Command;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;

class SystemAuditor extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'command:systemAuditor {--audit_service=} {--data=*}';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'command description';
    /**
     * @var AuditQueue
     */
    private $auditQueue;

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

    /**
     * Execute the console command.
     *
     * @return mixed
     */
    public function handle()
    {
        $data = json_decode($this->option('data')[0]);
        $audit_service = $this->option('audit_service');
        if (!filter_var($audit_service, FILTER_VALIDATE_BOOLEAN)){
            $this->start();
        }else{
            event(new EventAuditorService(LoanManagementAuditService::doubleDueDate, $data));
            event(new EventAuditorService(LoanManagementAuditService::duplicateEMIInEMICalculation, $data));
            event(new EventAuditorService(LoanManagementAuditService::emiDateAnomaliesInEMIPayments, $data));
        }
    }

    public function start(){

        $this->auditQueue = new AuditQueue();
        $auditLogs = $this->getJobs();
        foreach ($auditLogs as $auditLog) {
            try {
                $this->updateJob($auditLog, ListenerAuditService::QUEUE);
                $this->runCommand($auditLog);
            }catch (\Exception $e){
                $this->updateJob($auditLog, ListenerAuditService::FAILED, ['error' => [
                    'message' => $e->getMessage(),
                    'file' => $e->getFile(),
                    'line' => $e->getLine()
                ]]);
            }
        }
    }

    public function runCommand($auditLog){
        $handler =  json_decode($auditLog->input);
        $function = $handler->initiator[0];
        $className = $handler->initiator[1];
        if (class_exists($className)) {
            if (method_exists($className, $function)) {
                $classObject = new $className(new Request((array)$handler));
                $output = $classObject->$function();
                $this->updateJob($auditLog, ListenerAuditService::COMPLETED, $output);
            }
        }
    }

    private function getJobs(){
        return $this->auditQueue::where('status', ListenerAuditService::PENDING)->orderBy('created_at','desc')->limit(20)->get();
    }

    private function updateJob($auditLog, $status, $output = null){
        $this->auditQueue::where('id', $auditLog->id)->update(['status' => $status, 'attempt_count' => DB::raw('attempt_count+1'), 'output' => json_encode($output)]);
    }
}