diff -r 95dfb40ff3d2 -r dd6b3adde73b server/src/tests/Libraries/Sparql/SparqlClientTest.php --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/server/src/tests/Libraries/Sparql/SparqlClientTest.php Wed Apr 13 13:38:40 2016 +0200 @@ -0,0 +1,224 @@ + "dialogue"^^ . + "drama"^^ . +EOT; + + const TEST_DOC_DELETE = << "dialogue"^^ . +EOT; + + + private $container; + private $sparqlClients; + private $transactionUrl; + + private $responsesArray; + + function __construct(string $name = null) { + parent::__construct($name); + } + + private function getSparqlClient($responses, &$container, $sparqlClient) { + $mock = new MockHandler($responses); + $handler = HandlerStack::create($mock); + $history = Middleware::history($container); + $handler->push($history); + $httpClient = new Client(['handler' => $handler, 'http_errors' => false]); + + return new SparqlClient($httpClient, $sparqlClient); + } + + public function setUp() { + parent::setUp(); + $this->sesameRepository = config('corpusparole.sesame_repository'); + $this->transactionUrl = config('corpusparole.sesame_query_url').'/transactions/64a5937f-c112-d014-a044-f0123b93'; + + $this->addGraph = new EasyRdf\Graph("http://purl.org/poi/crdo.vjf.cnrs.fr/crdo-ALA_608", SparqlClientTest::TEST_DOC_ADD); + $this->deleteGraph = new EasyRdf\Graph("http://purl.org/poi/crdo.vjf.cnrs.fr/crdo-ALA_608", SparqlClientTest::TEST_DOC_DELETE); + + } + + public function tearDown() { + m::close(); + parent::tearDown(); + } + + public function testCreateTransaction() { + $responses = [ + new Response(201, ['Location' => "$this->transactionUrl"]), + ]; + $container = []; + $sparqlClientMock = m::mock('EasyRdf\Sparql\Client'); + + $documentRepository = $this->getSparqlClient($responses, $container, $sparqlClientMock); + + $documentRepository->startTransaction(); + + $this->assertEquals($this->transactionUrl, $documentRepository->getCurrentTransactionUrl(), 'Must have correct transaction url'); + } + + public function testCreateTransactionHistory() { + $responses = [ + new Response(201, ['Location' => "$this->transactionUrl"]), + ]; + $container = []; + $sparqlClientMock = m::mock('EasyRdf\Sparql\Client'); + + $documentRepository = $this->getSparqlClient($responses, $container, $sparqlClientMock); + + $documentRepository->startTransaction(); + + $this->assertCount(1, $container, 'One request'); + $req = $container[0]['request']; + $this->assertEquals("$this->sesameRepository/transactions?isolation-level=http%3A%2F%2Fwww.openrdf.org%2Fschema%2Fsesame%23SNAPSHOT_READ", (string)$req->getUri(), "url must be ok"); + $this->assertEquals('POST', $container[0]['request']->getMethod(), "methos is POST"); + } + + public function testRollbackTransaction() { + $responses = [ + new Response(201, ['Location' => "$this->transactionUrl"]), + new Response(204) + ]; + $container = []; + $sparqlClientMock = m::mock('EasyRdf\Sparql\Client'); + + $documentRepository = $this->getSparqlClient($responses, $container, $sparqlClientMock); + + $documentRepository->startTransaction(); + $documentRepository->rollback(); + + $this->assertCount(2, $container, '2 requests'); + + $this->assertNull($documentRepository->getCurrentTransactionUrl(), "Current Transaction url must be null"); + + $req = $container[1]['request']; + + $this->assertEquals($this->transactionUrl, (string)$req->getUri(), "uri must be the transaction url"); + $this->assertEquals('DELETE', $req->getMethod(), "Method must be DELETE"); + + } + + public function testCommitTransaction() { + $responses = [ + new Response(201, ['Location' => "$this->transactionUrl"]), + new Response(200) + ]; + $container = []; + $sparqlClientMock = m::mock('EasyRdf\Sparql\Client'); + + $documentRepository = $this->getSparqlClient($responses, $container, $sparqlClientMock); + + $documentRepository->startTransaction(); + $documentRepository->commit(); + + + $this->assertCount(2, $container, '2 requests'); + + $this->assertNull($documentRepository->getCurrentTransactionUrl(), "Current Transaction url must be null"); + + $req = $container[1]['request']; + + $this->assertEquals($this->transactionUrl."?action=COMMIT", (string)$req->getUri(), "uri must be the transaction url"); + $this->assertEquals('PUT', $req->getMethod(), "Method must be PUT"); + + } + + /** + * @expectedException CorpusParole\Libraries\CorpusParoleException + */ + public function testCommitTransactionFail() { + $responses = [ + new Response(201, ['Location' => "$this->transactionUrl"]), + new Response(404, [], "Not found") + ]; + $container = []; + $sparqlClientMock = m::mock('EasyRdf\Sparql\Client'); + + $documentRepository = $this->getSparqlClient($responses, $container, $sparqlClientMock); + + $documentRepository->startTransaction(); + $documentRepository->commit(); + + } + + + public function testAdd() { + + $responses = [ + new Response(201, ['Location' => "$this->transactionUrl"]), + new Response(204) + ]; + $container = []; + $sparqlClientMock = m::mock('EasyRdf\Sparql\Client'); + + $documentRepository = $this->getSparqlClient($responses, $container, $sparqlClientMock); + + $documentRepository->startTransaction(); + $documentRepository->add($this->addGraph); + + $this->assertCount(2, $container, '2 requests'); + + $this->assertNotNull($documentRepository->getCurrentTransactionUrl(), "Current Transaction url must be not null"); + + $req = $container[1]['request']; + + $this->assertEquals($this->transactionUrl."?action=UPDATE", (string)$req->getUri(), "uri must be the transaction url"); + $this->assertEquals('PUT', $req->getMethod(), "Method must be PUT"); + $this->assertEquals(['application/sparql-update; charset=utf-8'], $req->getHeader('Content-type'), "content type must be form urlencoded"); + + $body = (string)$req->getBody(); + + $this->assertContains('INSERT DATA {', $body, 'update parameter must contain INSERT'); + $this->assertContains('GRAPH <'.$this->addGraph->getUri().'> {', $body, 'update parameter must contain GRAPH id'); + $this->assertContains(' "dialogue"^^', $body, 'update parameter must contain dialogue'); + $this->assertContains(' "drama"^^ .', $body, 'update parameter must contain drama'); + } + + public function testDelete() { + $responses = [ + new Response(201, ['Location' => "$this->transactionUrl"]), + new Response(204) + ]; + $container = []; + $sparqlClientMock = m::mock('EasyRdf\Sparql\Client'); + + $documentRepository = $this->getSparqlClient($responses, $container, $sparqlClientMock); + + $documentRepository->startTransaction(); + $documentRepository->delete($this->deleteGraph); + + $this->assertCount(2, $container, '2 requests'); + + $this->assertNotNull($documentRepository->getCurrentTransactionUrl(), "Current Transaction url must be not null"); + + $req = $container[1]['request']; + + $this->assertEquals($this->transactionUrl."?action=UPDATE", (string)$req->getUri(), "uri must be the transaction url"); + $this->assertEquals('PUT', $req->getMethod(), "Method must be PUT"); + $this->assertEquals(['application/sparql-update; charset=utf-8'], $req->getHeader('Content-type'), "content type must be form urlencoded"); + + $body = (string)$req->getBody(); + + $this->assertContains('DELETE DATA {', $body, 'update parameter must contain DELETE'); + $this->assertContains('GRAPH <'.$this->addGraph->getUri().'> {', $body, 'update parameter must contain GRAPH id'); + $this->assertContains(' "dialogue"^^', $body, 'update parameter must contain GRAPH id'); + + } + +}