adding csv importer job

Author: ousid

src/Http/Livewire/ImportCsv.php src/Http/Livewire/CsvImporter.phpsrc/Http/Livewire/ImportCsv.php renamed to src/Http/Livewire/CsvImporter.php

@@ -3,13 +3,15 @@
 namespace Coderflex\LaravelCsv\Http\Livewire;
 
 use Coderflex\LaravelCsv\Concerns;
+use Coderflex\LaravelCsv\Jobs\ImportCsv;
 use Coderflex\LaravelCsv\Utilities\ChunkIterator;
+use Illuminate\Support\Facades\Bus;
 use Illuminate\Support\MessageBag;
 use Illuminate\Validation\Validator;
 use Livewire\Component;
 use Livewire\WithFileUploads;
 
-class ImportCsv extends Component
+class CsvImporter extends Component
 {
     use WithFileUploads;
     use Concerns\InteractsWithColumns;
@@ -36,6 +38,12 @@ class ImportCsv extends Component
     /** @var int */
     public int $fileRowCount = 0;
 
+    /** @var array */
+    protected $exception = [
+        'mode', 'columnsToMap', 'open',
+        'columnLabels', 'requiredColumns',
+    ];
+
     public function mount()
     {
         // map and coverts the columnsToMap property into an associative array
@@ -61,9 +69,11 @@ public function import()
     {
         $this->validate();
 
-        $import = $this->createNewImport();
+        $this->importCsv();
 
-        $chunks = (new ChunkIterator($this->csvRecords->getIterator(), 10))->get();
+        $this->resetExcept($this->exceptions);
+
+        $this->emitTo('csv-imports', 'imports.refresh');
     }
 
     public function render()
@@ -107,4 +117,25 @@ protected function createNewImport()
             'total_rows' => $this->fileRowCount,
         ]);
     }
+
+    protected function importCsv()
+    {
+        $import = $this->createNewImport();
+        $chunks = (new ChunkIterator($this->csvRecords->getIterator(), 10))->get();
+
+        $jobs = collect($chunks)
+                    ->map(
+                        fn ($chunk) => new ImportCsv(
+                            $import,
+                            $this->model,
+                            $chunk,
+                            $this->columnsToMap
+                        )
+                    );
+
+        Bus::batch($jobs)
+                    ->finally(
+                        fn () => $import->touch('compoleted_at')
+                    )->dispatch();
+    }
 }

src/Jobs/ImportCsv.php

@@ -0,0 +1,46 @@
+<?php
+
+namespace Coderflex\LaravelCsv\Jobs;
+
+use Coderflex\LaravelCsv\Models\Import;
+use Illuminate\Bus\Batchable;
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Queue\SerializesModels;
+
+class ImportCsv implements ShouldQueue
+{
+    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+
+    use Batchable;
+
+    /**
+     * Create a new job instance.
+     *
+     * @return void
+     */
+    public function __construct(
+        public Import $import,
+        public string $model,
+        public array $chunk,
+        public array $columns,
+    ) { /** */}
+
+    /**
+     * Execute the job.
+     *
+     * @return void
+     */
+    public function handle()
+    {
+        $affectedRows = $this->model::upsert(
+            $this->chunk,
+            ['id'],
+            collect($this->columns)->diff('id')->keys()->toArray(),
+        );
+
+        $this->import->increment('processed_rows', $affectedRows);
+    }
+}