initial commit of code

Author: limenet

README.md

@@ -19,13 +19,13 @@ composer require limenet/laravel-elastica-bridge
 You can publish and run the migrations with:
 
 ```bash
-php artisan vendor:publish --provider="Limenet\LaravelElasticaBridge\LaravelElasticaBridgeServiceProvider" --tag="laravel-elastica-bridge-migrations"
+php artisan vendor:publish --provider="Limenet\LaravelElasticaBridge\LaravelElasticaBridgeServiceProvider" --tag="elastica-bridge-migrations"
 php artisan migrate
 ```
 
 You can publish the config file with:
 ```bash
-php artisan vendor:publish --provider="Limenet\LaravelElasticaBridge\LaravelElasticaBridgeServiceProvider" --tag="laravel-elastica-bridge-config"
+php artisan vendor:publish --provider="Limenet\LaravelElasticaBridge\LaravelElasticaBridgeServiceProvider" --tag="elastica-bridge-config"
 ```
 
 This is the contents of the published config file:

composer.json

@@ -17,8 +17,9 @@
     ],
     "require": {
         "php": "^8.0",
-        "spatie/laravel-package-tools": "^1.4.3",
-        "illuminate/contracts": "^8.37"
+        "illuminate/contracts": "^8.37",
+        "ruflin/elastica": "^7.1",
+        "spatie/laravel-package-tools": "^1.4.3"
     },
     "require-dev": {
         "brianium/paratest": "^6.2",

config/elastica-bridge.php

@@ -1,5 +1,9 @@
 <?php
-// config for Limenet/ClassName
-return [
 
+return [
+    'elasticsearch' => [
+        'host' => env('ELASTICSEARCH_HOST', 'localhost'),
+        'port' => env('ELASTICSEARCH_PORT', '9200'),
+    ],
+    'indices' => [],
 ];

database/factories/.gitkeep

@@ -0,0 +1,31 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Limenet\LaravelElasticaBridge\Client;
+
+use Elastica\Client;
+use Elastica\Index;
+
+class ElasticaClient
+{
+    protected Client $client;
+
+    public function __construct()
+    {
+        $this->client = new Client([
+            'host' => config('elastica-bridge.elasticsearch.host'),
+            'port' => config('elastica-bridge.elasticsearch.port'),
+        ]);
+    }
+
+    public function getClient(): Client
+    {
+        return $this->client;
+    }
+
+    public function getIndex(string $name): Index
+    {
+        return $this->client->getIndex($name);
+    }
+}

database/factories/ModelFactory.php

@@ -0,0 +1,73 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Limenet\LaravelElasticaBridge\Commands;
+
+use Illuminate\Bus\Batch;
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\Bus;
+use Limenet\LaravelElasticaBridge\Client\ElasticaClient;
+use Limenet\LaravelElasticaBridge\Jobs\ActivateIndex;
+use Limenet\LaravelElasticaBridge\Jobs\PopulateIndex;
+use Limenet\LaravelElasticaBridge\Jobs\SetupIndex;
+use Limenet\LaravelElasticaBridge\Repository\IndexRepository;
+
+class IndexCommand extends Command
+{
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'elasticsearch:index {index?*} {--delete}';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = 'Re-create the ES index and populate with data';
+
+    /**
+     * Create a new command instance.
+     *
+     * @return void
+     */
+    public function __construct(protected ElasticaClient $elastica, protected IndexRepository $indexRepository)
+    {
+        parent::__construct();
+    }
+
+    /**
+     * Execute the console command.
+     *
+     * @return int
+     */
+    public function handle()
+    {
+        foreach ($this->indexRepository->all() as $indexConfig) {
+            if (
+                !empty($this->argument('index'))
+                && !in_array($indexConfig->getName(), $this->argument('index'), true)
+            ) {
+                continue;
+            }
+
+            $this->info(sprintf('Indexing %s', $indexConfig->getName()));
+
+            dispatch(new SetupIndex($indexConfig, (bool) $this->option('delete')));
+
+            Bus::batch([
+                [new PopulateIndex($indexConfig)],
+            ])
+                ->then(function (Batch $batch) use ($indexConfig): void {
+                    dispatch(new ActivateIndex($indexConfig));
+                })
+                ->name('ES index: '.$indexConfig->getName())
+                ->dispatch();
+        }
+
+        return 0;
+    }
+}