CouchDB\Util\BatchUpdater

Complexity

Total Complexity

4

Size/Duplication

Total Lines	75
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	update()	0	6	1
A	delete()	0	6	1
A	execute()	0	9	1

<?php

namespace CouchDB\Util;

use CouchDB\Database;
use CouchDB\Encoder\JSONEncoder;
use GuzzleHttp\ClientInterface;

/**
 * @author Markus Bachmann <markus.bachmann@bachi.biz>
 */
class BatchUpdater
{
    /**
     * @var ClientInterface
     */
    private $client;

    /**
     * @var Database
     */
    private $database;

    /**
     * @var array
     */
    private $data;

    /**
     * Constructor.
     *
     * @param ClientInterface $client
     * @param Database        $db
     */
    public function __construct(ClientInterface $client, Database $db)
    {
        $this->client = $client;
        $this->database = $db;

        $this->data = ['docs' => []];
    }

    /**
     * Enqueue the document for a update.
     *
     * @param array $doc
     *
     * @return BatchUpdater
     */
    public function update(array $doc)
    {
        $this->data['docs'][] = $doc;

        return $this;
    }

    /**
     * Enqueue a document for deletion.
     *
     * @param string $id
     * @param string $rev
     *
     * @return BatchUpdater
     */
    public function delete($id, $rev)
    {
        $this->data['docs'][] = ['_id' => $id, '_rev' => $rev, '_deleted' => true];

        return $this;
    }

    /**
     * Execute the queue.
     *
     * @return array
     */
    public function execute()
    {
        $response = $this->client->request('POST', "/{$this->database->getName()}/_bulk_docs", [
            'body'    => JSONEncoder::encode($this->data),
            'headers' => ['Content-Type' => 'application/json'],
        ]);

        return JSONEncoder::decode((string) $response->getBody());
    }
}