<?php

namespace Blomstra\Search\Observe;

use Elasticsearch\Client;
use Illuminate\Contracts\Container\Container;
use Illuminate\Database\Eloquent\Model;

class SavingJob extends Job
{
    public function handle(Container $container)
    {
        if ($this->models->isEmpty()) return;

        /** @var Client $client */
        $client = $container->make('blomstra.search.elastic');

        // Preparing body for storing.
        $body = $this->models->map(function (Model $model) {
            $document = $this->seeder->toDocument($model);

            return [
                ['index' => ['_index' => $this->index, '_id' => $document->id]],
                $document->toArray()
            ];
        })
        ->flatten(1);

        $response = $client->bulk([
            'index' => $this->index,
            'body' => $body->toArray(),
            'refresh' => true
        ]);
    }
}