caneara/lumeno

use Exception;
use App\Types\Job;
use Illuminate\Support\Arr;
use Illuminate\Support\Str;
use Illuminate\Support\Facades\DB;
use App\Services\CurrencyLayerService;
 
class FetchExchangeRatesJob extends Job
{
    protected array $response = [];
 
    public int $tries = 1;
 
    public function handle() : void
    {
        $this->retrieveExchangeRates()
            ->checkForErrors()
            ->updateLocalRates();
    }
 
    protected function checkForErrors() : static
    {
        $success = Arr::get($this->response, 'success', false);
        $message = Arr::get($this->response, 'error.info', 'Unknown Error');
 
        throw_unless($success, Exception::class, "Cannot fetch exchange rates: {$message}");
 
        return $this;
    }
 
    protected function prepareQuery(string $code, float $rate) : string
    {
        $rate = round(1 / $rate, 3);
        $code = Str::after($code, 'USD');
 
        return "UPDATE `currencies` SET `rate` = '{$rate}' WHERE `code` = '{$code}'";
    }
 
    protected function retrieveExchangeRates() : static
    {
        $this->response = CurrencyLayerService::retrieveExchangeRates();
 
        return $this;
    }
 
    protected function updateLocalRates() : void
    {
        $sql = collect(Arr::get($this->response, 'quotes', []))
            ->map(fn($rate, $code) => $this->prepareQuery($code, $rate))
            ->implode(';');
 
        $sql ? attempt(fn() => DB::unprepared($sql)) : null;
    }
}

use Illuminate\Console\Command;
use App\Jobs\FetchExchangeRatesJob;
 
class FetchExchangeRatesCommand extends Command
{
    protected $signature = 'system:fetch-exchange-rates';
 
    protected $description = 'Retrieve the latest exchange rates for the US Dollar';
 
    public function handle() : void
    {
        FetchExchangeRatesJob::dispatch();
 
        $this->info('The exchange rates have been retrieved');
    }
}