Isswp101\Persimmon\Helpers\Bulk::index()

Complexity

Conditions	5
Paths	10

Size

Total Lines	29
Code Lines	21

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public static function index(Client $client, array $models, int $chunk = 1000): void
    {
        $i = 1;
        $params = ['body' => []];
        foreach ($models as $model) {
            try {
                $id = $model->getPrimaryKey();
            } catch (Exception $e) {
                $id = $i++;
            }
            $collection = new ElasticsearchCollectionParser($model::getCollection());
            $params['body'][] = [
                'index' => [
                    '_index' => $collection->getIndex(),
                    '_type' => $collection->getType(),
                    '_id' => $id
                ]
            ];
            $params['body'][] = $model->toArray();
            if ($i % $chunk == 0) {
                $responses = $client->bulk($params);
                $params = ['body' => []];
                unset($responses);
            }
        }
        if (!empty($params['body'])) {
            $client->bulk($params);
        }
    }
}