more tests

Author: limenet

tests/Feature/CommandTest.php

@@ -0,0 +1,30 @@
+<?php
+
+namespace Limenet\LaravelElasticaBridge\Tests\Feature;
+
+use Limenet\LaravelElasticaBridge\Index\IndexInterface;
+
+class CommandTest extends TestCase
+{
+    /** @test */
+    public function status()
+    {
+        $this->assertSame(0, $this->artisan('elastica-bridge:status')->run());
+    }
+    /** @test */
+    public function index_command_creates_index()
+    {
+        $this->assertFalse($this->productIndex->getElasticaIndex()->exists());
+        $this->assertSame(0, $this->index($this->productIndex));
+        $this->assertSame(0, $this->artisan('elastica-bridge:status')->run());
+        $this->assertTrue($this->productIndex->getElasticaIndex()->exists());
+    }
+    /** @test */
+    public function index_command_swtiches_blue_green()
+    {
+        $this->index($this->productIndex);
+        $activeOld = $this->productIndex->getBlueGreenActiveElasticaIndex()->getName();
+        $this->index($this->productIndex);
+        $this->assertNotSame($activeOld, $this->productIndex->getBlueGreenActiveElasticaIndex()->getName());
+    }
+}

tests/Feature/FeatureTest.php

@@ -0,0 +1,33 @@
+<?php
+
+namespace Limenet\LaravelElasticaBridge\Tests\Feature;
+
+use Elastica\Query\BoolQuery;
+use Elastica\Query\MatchQuery;
+use Limenet\LaravelElasticaBridge\Index\IndexInterface;
+
+class QueryTest extends TestCase
+{
+    /** @test */
+    public function get_by_id()
+    {
+        $id=17;
+        $this->index($this->productIndex);
+        $elements=$this->productIndex->searchForElements(new MatchQuery(IndexInterface::DOCUMENT_MODEL_ID, $id));
+
+        $this->assertCount(1, $elements);
+        $this->assertSame(17, $elements[0]->id);
+    }
+    /** @test */
+    public function size_and_from()
+    {
+        $this->index($this->productIndex);
+
+        $elements1=$this->productIndex->searchForElements(new BoolQuery(),5,0);
+        $this->assertCount(5, $elements1);
+
+        $elements2=$this->productIndex->searchForElements(new BoolQuery(),5,5);
+        $this->assertCount(5, $elements2);
+        $this->assertEmpty(collect($elements1)->map->id->intersect(collect($elements2)->map->id)->toArray());
+    }
+}

tests/Feature/QueryTest.php

@@ -2,6 +2,10 @@
 
 namespace Limenet\LaravelElasticaBridge\Tests\Feature;
 
+use Elastica\Exception\ResponseException;
+use Limenet\LaravelElasticaBridge\Client\ElasticaClient;
+use Limenet\LaravelElasticaBridge\Exception\BaseException;
+use Limenet\LaravelElasticaBridge\Index\IndexInterface;
 use Limenet\LaravelElasticaBridge\Repository\IndexRepository;
 use Limenet\LaravelElasticaBridge\Tests\App\Elasticsearch\CustomerIndex;
 use Limenet\LaravelElasticaBridge\Tests\App\Elasticsearch\ProductIndex;
@@ -12,12 +16,47 @@ class TestCase extends TestsTestCase
     protected CustomerIndex $customerIndex;
     protected ProductIndex $productIndex;
     protected IndexRepository $indexRepository;
+    protected ElasticaClient $elasticaClient;
     public function setUp(): void
     {
         parent::setUp();
 
         $this->customerIndex = $this->app->make(CustomerIndex::class);
         $this->productIndex = $this->app->make(ProductIndex::class);
         $this->indexRepository = $this->app->make(IndexRepository::class);
+        $this->elasticaClient=$this->app->make(ElasticaClient::class);
+
+        $this->cleanupIndices();
+    }
+    public function tearDown(): void
+    {
+        parent::tearDown();
+
+
+        $this->cleanupIndices();
+    }
+    protected function cleanupIndices(){
+
+        foreach([$this->customerIndex, $this->productIndex] as $index){
+            try{
+            if($index->getElasticaIndex()->hasAlias($index->getName())){
+                $index->getElasticaIndex()->removeAlias($index->getName());
+            }
+            $active=$index->getBlueGreenActiveElasticaIndex();
+            $inactive=$index->getBlueGreenInactiveElasticaIndex();
+            if($active->exists()){
+                $active->delete();
+            }
+            if($inactive->exists()){
+                $inactive->delete();
+            }
+        }catch(BaseException|ResponseException){
+
+        }
+        }
+    }
+
+    protected function index(IndexInterface $index):int{
+        return $this->artisan('elastica-bridge:index', ['index' => [$index->getName()]])->run();
     }
 }

tests/Feature/TestCase.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace Limenet\LaravelElasticaBridge\Tests\Unit;
+
+use Elastica\Client;
+use Limenet\LaravelElasticaBridge\Client\ElasticaClient;
+use Limenet\LaravelElasticaBridge\LaravelElasticaBridgeFacade;
+
+class FacadeTest extends TestCase
+{
+    /** @test */
+    public function facade()
+    {
+       $this->assertInstanceOf(Client::class, LaravelElasticaBridgeFacade::getClient());
+    }
+}

tests/Unit/FacadeTest.php

@@ -21,5 +21,38 @@ public function up():void
             $table->string('name');
             $table->timestamps();
         });
+
+        Schema::create('failed_jobs', function (Blueprint $table): void {
+            $table->id();
+            $table->string('uuid')->unique();
+            $table->text('connection');
+            $table->text('queue');
+            $table->longText('payload');
+            $table->longText('exception');
+            $table->timestamp('failed_at')->useCurrent();
+        });
+
+        Schema::create('jobs', function (Blueprint $table): void {
+            $table->bigIncrements('id');
+            $table->string('queue')->index();
+            $table->longText('payload');
+            $table->unsignedTinyInteger('attempts');
+            $table->unsignedInteger('reserved_at')->nullable();
+            $table->unsignedInteger('available_at');
+            $table->unsignedInteger('created_at');
+        });
+
+        Schema::create('job_batches', function (Blueprint $table): void {
+            $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->text('options')->nullable();
+            $table->integer('cancelled_at')->nullable();
+            $table->integer('created_at');
+            $table->integer('finished_at')->nullable();
+        });
     }
 };