integrated SPARQL Query; addresses SPARQL-issue#1

src/SparqlLua.php

@@ -4,27 +4,31 @@
 
 namespace ProfessionalWiki\SPARQL;
 
+use InvalidArgumentException;
+use MediaWiki\MediaWikiServices;
 use Scribunto_LuaLibraryBase;
 
 class SparqlLua extends Scribunto_LuaLibraryBase {
 
-	/**
-	 * @return mixed[]
-	 */
-	public function register(): array {
+	public function register() {
 		return $this->getEngine()->registerInterface(
 			__DIR__ . '/Sparql.lua',
 			[
-				'runQuery' => fn( string $subjectId ): array => [ $this->runQuery( $subjectId ) ],
+				'runQuery' => fn ( string $subjectId ): array => [ $this->runSparqlQuery( $subjectId ) ],
 			]
 		);
 	}
 
-	/**
-	 * @return mixed[]
-	 */
-	private function runQuery( string $sparql ): array {
-		return [ $sparql ]; // TODO
+	private function runSparqlQuery( string $sparql ): string|null {
+		$sparqlEndpoint = MediaWikiServices::getInstance()->getMainConfig()->get( 'SPARQLEndpoint' );
+
+		if ( !is_string( $sparqlEndpoint ) ) {
+			throw new InvalidArgumentException( 'SPARQLEndpoint must be configured properly' );
+		}
+
+		$requestFactory = MediaWikiServices::getInstance()->getHttpRequestFactory();
+		$queryRunner = new SparqlLuaQueryRunner( $requestFactory, $sparqlEndpoint );
+		return $queryRunner->runQuery( $sparql );
 	}
 
 }

src/SparqlLuaQueryRunner.php

@@ -0,0 +1,28 @@
+<?php
+
+declare( strict_types = 1 );
+
+namespace ProfessionalWiki\SPARQL;
+
+use MediaWiki\Http\HttpRequestFactory;
+
+class SparqlLuaQueryRunner {
+
+	public function __construct(
+		private readonly HttpRequestFactory $requestFactory,
+		private readonly string $sparqlEndpoint
+	) {
+	}
+
+	public function runQuery( string $sparql ): string|null {
+		$options = [
+			'postData' => [
+				'query' => $sparql,
+				'format' => 'json'
+			],
+		];
+
+		return $this->requestFactory->request( 'POST', $this->sparqlEndpoint, $options );
+	}
+
+}

tests/SparqlLuaQueryRunnerTest.php

@@ -0,0 +1,40 @@
+<?php
+
+declare( strict_types = 1 );
+
+namespace ProfessionalWiki\SPARQL\Tests;
+
+use MediaWiki\Http\HttpRequestFactory;
+use PHPUnit\Framework\TestCase;
+use ProfessionalWiki\SPARQL\SparqlLuaQueryRunner;
+
+/**
+ * @covers SparqlLuaQueryRunner::runQuery
+ */
+class SparqlLuaQueryRunnerTest extends TestCase {
+
+	public function testRunQuery() {
+		$SPARQLEndpoint = 'https://www.example.com';
+		$httpRequestFactory = $this->createMock( HttpRequestFactory::class );
+		$sparqlLua = new SparqlLuaQueryRunner( $httpRequestFactory, $SPARQLEndpoint );
+
+		$sparql = 'SELECT * WHERE { ?s ?p ?o }';
+		$expectedResponse = 'mocking response';
+
+		$httpRequestFactory
+			->expects( $this->once() )
+			->method( 'request' )
+			->with(
+				'POST',
+				$SPARQLEndpoint,
+				[
+					'postData' => [ 'query' => $sparql, 'format' => 'json' ]
+				]
+			)
+			->willReturn( $expectedResponse );
+
+		$response = $sparqlLua->runQuery( $sparql );
+		$this->assertSame( $expectedResponse, $response );
+	}
+
+}

tests/parser/lua.txt

@@ -11,7 +11,7 @@ local sparql = require('SPARQL')
 
 local p = {}
 function p.runQuery(frame)
-	return sparql.runQuery(frame.args[1])[0]
+	return sparql.runQuery(frame.args[1])
 end
 
 return p