perf(AirportImport): AirportImport now runs on queue

-

Author: daveroverts

app/Http/Controllers/Airport/AirportAdminController.php

@@ -4,13 +4,12 @@
 
 use App\Models\Airport;
 use Illuminate\View\View;
-use App\Imports\AirportsImport;
 use App\Policies\AirportPolicy;
 use Illuminate\Http\RedirectResponse;
-use Illuminate\Support\Facades\Storage;
 use App\Http\Controllers\AdminController;
 use App\Http\Requests\Airport\Admin\StoreAirport;
 use App\Http\Requests\Airport\Admin\UpdateAirport;
+use App\Jobs\ImportAirportsJob;
 
 class AirportAdminController extends AdminController
 {
@@ -75,14 +74,8 @@ public function destroy(Airport $airport): RedirectResponse
 
     public function import(): RedirectResponse
     {
-        $file = 'import.csv';
-        Storage::disk('local')->put(
-            $file,
-            file_get_contents('https://raw.githubusercontent.com/mborsetti/airportsdata/main/airportsdata/airports.csv')
-        );
-        (new AirportsImport())->import($file);
-        Storage::delete($file);
-        flashMessage('success', __('Done'), __('Airports have been added'));
+        ImportAirportsJob::dispatch();
+        flashMessage('success', __('Done'), __('Import has been started.'));
         return redirect(route('admin.airports.index'));
     }
 

app/Imports/AirportsImport.php

@@ -3,6 +3,7 @@
 namespace App\Imports;
 
 use App\Models\Airport;
+use Illuminate\Contracts\Queue\ShouldQueue;
 use Illuminate\Validation\Rule;
 use Maatwebsite\Excel\Concerns\Importable;
 use Maatwebsite\Excel\Concerns\SkipsFailures;
@@ -14,7 +15,7 @@
 use Maatwebsite\Excel\Concerns\WithUpserts;
 use Maatwebsite\Excel\Concerns\WithValidation;
 
-class AirportsImport implements ToModel, WithBatchInserts, WithChunkReading, WithHeadingRow, WithUpserts, WithValidation, SkipsOnFailure
+class AirportsImport implements ShouldQueue, ToModel, WithBatchInserts, WithChunkReading, WithHeadingRow, WithUpserts, WithValidation, SkipsOnFailure
 {
     use Importable;
     use SkipsFailures;

app/Jobs/ImportAirportsJob.php

@@ -0,0 +1,47 @@
+<?php
+
+namespace App\Jobs;
+
+use Illuminate\Bus\Queueable;
+use App\Imports\AirportsImport;
+use Illuminate\Support\Facades\Bus;
+use Illuminate\Queue\SerializesModels;
+use Illuminate\Support\Facades\Storage;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Contracts\Queue\ShouldBeUnique;
+
+class ImportAirportsJob implements ShouldQueue, ShouldBeUnique
+{
+    use Dispatchable;
+    use InteractsWithQueue;
+    use Queueable;
+    use SerializesModels;
+
+    /**
+     * Create a new job instance.
+     *
+     * @return void
+     */
+    public function __construct()
+    {
+        //
+    }
+
+    /**
+     * Execute the job.
+     *
+     * @return void
+     */
+    public function handle()
+    {
+        $file = 'import_' . time() . '.csv';
+        Storage::disk('local')->put(
+            $file,
+            file_get_contents('https://raw.githubusercontent.com/mborsetti/airportsdata/main/airportsdata/airports.csv')
+        );
+        (new AirportsImport())->queue($file);
+        Storage::delete($file);
+    }
+}