<?php

namespace CorpusParole\Libraries\Sparql;

use EasyRdf\Graph;

use CorpusParole\Libraries\CorpusParoleException;

use Config;

use Log;

use GuzzleHttp\Psr7\Request;

/**

 *

 */

class SparqlClient {

    private $currentTransactionUrl = null;

    function __construct($httpClient, $sparqlClient) {

        $this->sparqlClient = $sparqlClient;

        $this->httpClient = $httpClient;

    }

    private function getHttpClient() {

        return $this->httpClient;

    }

    public function getCurrentTransactionUrl() {

        return $this->currentTransactionUrl;

    }

    /**

     * Start transaction.

     * @return boolean true if a transaction was started, false otherwise

     * @throws CorpusParoleException if the  transaction could not be stared

     */

    public function startTransaction() {

        if(!is_null($this->currentTransactionUrl)) {

            // We just continue the current transaction

            return false;

        }

        //Log::debug('http_client base uri: ' . $this->getHttpClient()->getConfig('base_uri'));

        $rdf4jRepository = config('corpusparole.rdf4j_repository');

        $resp = $this->getHttpClient()->post("$rdf4jRepository/transactions", ['query' => ['isolation-level' => 'http://www.openrdf.org/schema/sesame#SNAPSHOT_READ']]);

        //$resp = $this->getHttpClient()->post('transactions');

        //TODO check errors

        if($resp->getStatusCode() != 201) {

            throw new CorpusParoleException("Error when starting transaction : "

                . $resp->getStatusCode() . " - "

                . $resp->getReasonPhrase() . " : " . $resp->getBody(), 1);

        }

        $this->currentTransactionUrl = $resp->getHeader('Location')[0];

        return true;

    }

    /**

     * Rollback transaction.

     * @return boolean true if a transaction was started, false otherwise

     * @throws CorpusParoleException if the  transaction could not be rollbacked

     */

    public function rollback() {

        if(is_null($this->currentTransactionUrl)) {

            // We just continue the current transaction

            return false;

        }

        $resp = $this->getHttpClient()->delete($this->currentTransactionUrl);

        if($resp->getStatusCode() != 204) {

            throw new CorpusParoleException("Could not cancel transaction : "

                . $resp->getStatusCode() . " - "

                . $resp->getReasonPhrase() . " : " . $resp->getBody(), 1);

        }

        $this->currentTransactionUrl = null;

        return true;

    }

    /**

     * Commit transaction.

     * @return boolean true if a transaction was started, false otherwise

     * @throws CorpusParoleException if the  transaction could not be commited

     */

    public function commit() {

        if(is_null($this->currentTransactionUrl)) {

            // We just continue the current transaction

            return false;

        }

        $resp = $this->getHttpClient()->put($this->currentTransactionUrl, ['query' => ['action' => 'COMMIT']]);

        if($resp->getStatusCode() != 200) {

            throw new CorpusParoleException("Could not commit transaction : "

                . $resp->getStatusCode() . " - "

                . $resp->getReasonPhrase() . " : " . $resp->getBody(), 1);

        }

        $this->currentTransactionUrl = null;

        return true;

    }

    protected function updateData($operation, Graph $graph)

    {

        $graphUri = $graph->getUri();

        $query = $graph->serialise('ntriples');

        if ($graphUri) {

            $query = "GRAPH <$graphUri> { $query }";

        }

        $query = "$operation DATA { $query }";

        // doc : http://rdf4j.org/doc/4/articles/REST-API/transaction-operations.docbook?view

        // cf. bug : https://openrdf.atlassian.net/browse/SES-2295

        // and PR https://bitbucket.org/openrdf/rdf4j/commits/62b680d8650caca7bc1673f6aaac48a5b6e85d23?at=2.8.x

        // The put form has been chosen over the post, because it seems that this is the form choosed in the rdf4j http client

        $resp = $this->getHttpClient()->put(

            $this->currentTransactionUrl, [

                'headers' => ["Content-Type" => "application/sparql-update; charset=utf-8"],

                'query' => ['action' => 'UPDATE'],

                'body' => $query,

            ]

        );

    }

    public function add(Graph $graph) {

        return $this->updateData('INSERT', $graph);

    }

    public function delete(Graph $graph) {

        return $this->updateData('DELETE', $graph);

    }

    public function deleteWhere($whereClauses, $graphUri = null) {

        if(empty($whereClauses)) {

            return;

        }

        if(is_array($whereClauses)) {

            $whereClauses = implode(" .", $whereClauses);

        }

        $query = "DELETE { ?s ?p ?o } WHERE { $whereClauses }";

        if($graphUri) {

            $query = "WITH <$graphUri> $query";

        }

        // doc : http://rdf4j.org/doc/4/articles/REST-API/transaction-operations.docbook?view

        // cf. bug : https://openrdf.atlassian.net/browse/SES-2295

        // and PR https://bitbucket.org/openrdf/rdf4j/commits/62b680d8650caca7bc1673f6aaac48a5b6e85d23?at=2.8.x

        // The put form has been chosen over the post, because it seems that this is the form choosed in the rdf4j http client

        $resp = $this->getHttpClient()->put(

            $this->currentTransactionUrl, [

                'headers' => ["Content-Type" => "application/sparql-update; charset=utf-8"],

                'query' => ['action' => 'UPDATE'],

                'body' => $query,

            ]

        );

        return $resp;

    }

    /** Make a query to the SPARQL endpoint

     *

     * Just call and return EasyRdf\Sparql\Client::query

     *

     * @param string $query The query string to be executed

     * @return object EasyRdf\Sparql\Result|EasyRdf\Graph Result of the query.

     */

    public function query($query, $timeout=0) {

        return $this->sparqlClient->query($query, $timeout);

    }

}