mateusjatenee/crypto-tracker

use App\Models\Asset;
use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use App\MarketInformationProviders\Coinbase;
use Illuminate\Contracts\Queue\ShouldBeUnique;

class UpdateCryptoAssetPrice implements ShouldQueue
{
    use Dispatchable;
    use InteractsWithQueue;
    use Queueable;
    use SerializesModels;

    public function __construct(public Asset $asset)
    {
        //
    }

    public function handle()
    {
        $freshAsset = resolve(Coinbase::class)->fetchAsset($this->asset);

        if ($freshAsset->price == 0) {
            return;
        }

        $this->asset->updateFromFreshAsset($freshAsset);
    }
}

use App\Jobs\UpdateCryptoAssetPrice;
use App\Models\Asset;
use Illuminate\Console\Command;

class FetchCoinsPrices extends Command
{
    protected $signature = 'coins:fetch-price';

    protected $description = 'Command description';

    protected $shouldQuit = false;

    public function __construct()
    {
        parent::__construct();
    }

    public function handle()
    {
        $this->info('Fetching coin prices.');

        $this->listenForSignals();

        while (true) {
            if ($this->shouldQuit) {
                return false;
            }

            $this->fetchPrices();
            sleep(20);
        }
    }

    public function listenForSignals()
    {
        pcntl_signal(SIGTERM, function () {
            $this->shouldQuit = true;
        });
    }

    protected function fetchPrices()
    {
        $this->info('Fetching...');
        Asset::crypto()->get()->each(function (Asset $asset) {
            UpdateCryptoAssetPrice::dispatch($asset);
        });
    }
}