update tests

Author: ousid

src/Http/Livewire/CsvImporter.php

@@ -18,7 +18,7 @@ class CsvImporter extends Component
     use Concerns\HasCsvProperties;
 
     /** @var string */
-    public string $model;
+    public $model;
 
     /** @var object */
     public $file;
@@ -134,6 +134,7 @@ protected function importCsv()
                     );
 
         Bus::batch($jobs)
+                    ->name('import-csv')
                     ->finally(
                         fn () => $import->touch('compoleted_at')
                     )->dispatch();

tests/CsvImporterTest.php

@@ -1,9 +1,12 @@
 <?php
 
 use Coderflex\LaravelCsv\Http\Livewire\CsvImporter;
+use Coderflex\LaravelCsv\Jobs\ImportCsv;
 use Coderflex\LaravelCsv\Models\Import;
 use Coderflex\LaravelCsv\Tests\Models\Customer;
+use Illuminate\Bus\PendingBatch;
 use Illuminate\Http\UploadedFile;
+use Illuminate\Support\Facades\Bus;
 use Illuminate\Support\Facades\Storage;
 use function Pest\Livewire\livewire;
 
@@ -220,8 +223,16 @@
     ->assertHasErrors(['columnsToMap.name', 'columnsToMap.email']);
 });
 
-it('creates a new import records', function () {
+it('ensures the imports is batched', function () {
     Storage::fake('documents');
+    Bus::fake();
+
+    $columnsToMap = [
+        'id',
+        'first_name',
+        'last_name',
+        'email',
+    ];
 
     $file = UploadedFile::fake()
         ->createWithContent(
@@ -233,11 +244,23 @@
 
     livewire(CsvImporter::class, [
         'model' => $model,
+        'columnsToMap' => $columnsToMap,
     ])
     ->set('file', $file)
+    ->set('columnsToMap', [
+        'id' => 'id',
+        'fist_name' => 'fist_name',
+        'last_name' => 'last_name',
+        'email' => 'email',
+    ])
     ->call('import')
     ->assertHasNoErrors();
 
+    Bus::assertBatched(function (PendingBatch $batch) {
+        return $batch->name == 'import-csv' &&
+               $batch->jobs->count() === 100;
+    });
+
     $this->assertEquals(Import::count(), 1);
     $this->assertEquals(Import::forModel(Customer::class)->count(), 1);
 });

tests/Database/Migrations/create_customers_table.php

@@ -8,11 +8,14 @@
 {
     public function up()
     {
-        Schema::create('users', function (Blueprint $table) {
+        Schema::create('customers', function (Blueprint $table) {
             $table->id();
             $table->string('first_name');
             $table->string('last_name');
             $table->string('email')->unique();
+            $table->string('company')->nullable();
+            $table->boolean('vip')->default(false);
+            $table->date('birthday')->nullable();
             $table->timestamps();
         });
     }

tests/Database/Migrations/create_job_batches_table.php

@@ -0,0 +1,39 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    /**
+     * Run the migrations.
+     *
+     * @return void
+     */
+    public function up()
+    {
+        Schema::create('job_batches', function (Blueprint $table) {
+            $table->string('id')->primary();
+            $table->string('name');
+            $table->integer('total_jobs');
+            $table->integer('pending_jobs');
+            $table->integer('failed_jobs');
+            $table->text('failed_job_ids');
+            $table->mediumText('options')->nullable();
+            $table->integer('cancelled_at')->nullable();
+            $table->integer('created_at');
+            $table->integer('finished_at')->nullable();
+        });
+    }
+
+    /**
+     * Reverse the migrations.
+     *
+     * @return void
+     */
+    public function down()
+    {
+        Schema::dropIfExists('job_batches');
+    }
+};

tests/TestCase.php

@@ -42,6 +42,9 @@ public function getEnvironmentSetUp($app)
 
         $migration = include __DIR__.'/Database/Migrations/create_customers_table.php';
         $migration->up();
+
+        $migration = include __DIR__. '/Database/Migrations/create_job_batches_table.php';
+        $migration->up();
     }
 
     public function registerLivewireComponents()