#!/usr/bin/php
<?php

require_once 'Endpoint.php';
//require_once 'Test.php';

//List of servers available that you can test with this script

$usage = "
USAGE : query [-r|-w][-e URL|--endpointQueryAndUpdate=URL]
		[--file=FILE|-f FILE]
        [-v|-verbose]

    -r                                  READ ONLY
    -w                                  WRITE ONLY
    -e, --endpointQueryAndUpdate=URL    Put url of endpoint to do query or 
                                        update :
                                            URL/sparql/?query=...
                                            URL/update/?update=... (POST)
    -q, --endpointQueryOnly=URL         Put url of endpoint to do query :
                                            URL?query=...
    -u, --endpointUpdateOnly=URL        Put url of endpoint to do query :
                                            URL?update=... (POST)
    --nameParameterQuery=PARAMETER      Change the name of parameter in 
                                        the request http to read.
                                        (by default : query)
    --nameParameterUpdate=PARAMETER     Change the name of parameter in 
                                        the request http to write.
                                        (by default : update)
    -f,--file=File                      File of the query.
	-t, --typeOutput=TYPE               Type of response: txt,csv,tsv,ttl,srx,srj
                                        (by default : txt)
    -v, --verbose                       Mode verbose
    -d, --debug                         Mode debug

EXAMPLE : Virtuoso
./query -w -e http://localhost/tests/ -f ./example/queryWrite1.rq

./query -r -e http://localhost/tests/ -f ./example/queryRead1.rq

EXAMPLE : 4Store
./query -w -e http://localhost/ -f ./example/queryWrite1.rq

./query -r -e http://localhost/ -f ./example/queryRead1.rq

EXAMPLE : Sesame
./query -w -q http://localhost/openrdf-sesame/repositories/tests \
 -u http://localhost/openrdf-sesame/repositories/tests/statements \
-f ./example/queryWrite1.rq

./query -r -q http://localhost/openrdf-sesame/repositories/tests \
 -u http://localhost/openrdf-sesame/repositories/tests/statements \
-f ./example/queryRead1.rq

EXAMPLE : Fuseki
./query -w -q http://localhost/tests/query \
-u http://localhost/tests/update \
-f ./example/queryWrite1.rq

./query -r -q http://localhost/tests/query \
-u http://localhost/tests/update \
-f ./example/queryRead1.rq

EXAMPLE : Allegrograph
./query -w -q http://localhost/repositories/tests \
-u http://localhost/repositories/tests \
--nameParameterUpdate=query \
-f ./example/queryWrite1.rq

./query -r -q http://localhost/repositories/tests \
-u http://localhost/repositories/tests \
--nameParameterUpdate=query \
-f ./example/queryRead1.rq

";

// Variables - inputs
$modeVerbose = false;
$modeDebug = false;
$modeRead = false;
$modeWrite = false;

$triplestore = "standard";
$endpointQueryAndUpdate = "";
$endpointQueryOnly = "";
$endpointUpdateOnly = "";
$nameParameterQuery = "query";
$nameParameterUpdate = "update";

$modeRead = false;
$modeWrite = false;

$filename= "";
$typeOutput="txt";
$type="";

//Client web
$CURL = new Curl($modeDebug);

if(count($argv) < 2){
	echo $usage;
	exit();
}

for($i = 1; $i < count($argv); $i++)  {
	$param=explode("=",$argv[$i]);
	
	switch($param[0]){
		case "-h":
		case "--help":
			echo $usage; 
			exit();
		case "-v":
		case "--verbose":
			$modeVerbose = true;
			break;
		case "-r":
		case "--read":
			$modeRead = true;
			break;
		case "-w":
		case "--write":
			$modeWrite = true;
			break;
		case "-d":
		case "--debug":
			$modeDebug = true;
			$modeVerbose = true;
			break;
//////////////////////////////////////////////////////////////////////////////////
		case "-e":
			if(! array_key_exists($i + 1, $argv)){
				echo "ERROR : forget parameter after -e (see --help)\n";
				exit();
			}
			$endpointQueryAndUpdate = $argv[$i + 1];
			if(! filter_var($endpointQueryAndUpdate, FILTER_VALIDATE_URL)){	
				echo "ERROR : The URL of endpoint is not valid\n";
				exit();
			}
			$i++;
			break;
		case "--endpointQueryAndUpdate":
			if(! array_key_exists(1, $param)){
				echo "ERROR : forget parameter after --endpointQueryAndUpdate (see --help)\n";
				exit();
			}
			$endpointQueryAndUpdate = $param[1];
			if(! filter_var($endpointQueryAndUpdate, FILTER_VALIDATE_URL)){	
				echo "ERROR : The URL of endpoint is not valid\n";
				exit();
			}
			break;	
		case "-q":
			if(! array_key_exists($i + 1, $argv)){
				echo "ERROR : forget parameter after -q (see --help)\n";
				exit();
			}
			$endpointQueryOnly = $argv[$i + 1];
			if(! filter_var($endpointQueryOnly, FILTER_VALIDATE_URL)){	
				echo "ERROR : The URL of endpoint is not valid\n";
				exit();
			}
			$i++;
			break;
		case "--endpointQueryOnly":
			if(! array_key_exists(1, $param)){
				echo "ERROR : forget parameter after --endpointQueryOnly (see --help)\n";
				exit();
			}
			$endpointQueryOnly = $param[1];
			if(! filter_var($endpointQueryOnly, FILTER_VALIDATE_URL)){	
				echo "ERROR : The URL of endpoint is not valid\n";
				exit();
			}
			break;	
		case "-u":
			if(! array_key_exists($i + 1, $argv)){
				echo "ERROR : forget parameter after -u (see --help)\n";
				exit();
			}
			$endpointUpdateOnly = $argv[$i + 1];
			if(! filter_var($endpointUpdateOnly, FILTER_VALIDATE_URL)){	
				echo "ERROR : The URL of endpoint is not valid\n";
				exit();
			}
			$i++;
			break;
		case "--endpointUpdateOnly":
			if(! array_key_exists(1, $param)){	
				echo "ERROR : forget parameter after --endpointUpdateOnly (see --help)\n";
				exit();
			}
			$endpointUpdateOnly = $param[1];
			if(! filter_var($endpointUpdateOnly, FILTER_VALIDATE_URL)){	
				echo "ERROR : The URL of endpoint is not valid\n";
				exit();
			}
			break;
		case "--nameParameterQuery":
			if(! array_key_exists(1, $param)){
				echo "ERROR : forget parameter after --nameParameterQuery (see --help)\n";
				exit();
			}
			$nameParameterQuery  = $param[1];
			break;
		case "--nameParameterUpdate":
			if(! array_key_exists(1, $param)){
				echo "ERROR : forget parameter after --nameParameterUpdate (see --help)\n";
				exit();
			}
			$nameParameterUpdate  = $param[1];
			break;
		case "-f":
			if(! array_key_exists($i + 1, $argv)){
				echo "ERROR : forget parameter after -f (see --help)\n";
				exit();
			}
			$filename = $argv[$i + 1];
			if(! file_exists($filename)){
				echo "The file $filename does not exist";
				exit();
			}
			$i++;
			break;
		case "--file":
			if(! array_key_exists(1, $param)){	
				echo "ERROR : forget parameter after --endpointQueryOnly (see --help)\n";
				exit();
			}
			$filename = $param[1];
			if(! file_exists($filename)){
				echo "The file $filename does not exist";
				exit();
			}
			break;
		case "-t":
			if(! array_key_exists($i + 1, $argv)){
				echo "ERROR : forget parameter after -f (see --help)\n";
				exit();
			}
			$typeOutput = $argv[$i + 1];
			$i++;
		case "--typeOutput":
			if(! array_key_exists(1, $param)){	
				echo "ERROR : forget parameter after --endpointQueryOnly (see --help)\n";
				exit();
			}
			$typeOutput = $param[1];
			break;			
		default:
			//echo $usage; exit();
			echo "ERROR usage ! (".$param[0]."?)";
			echo $usage; exit();
	}
}

if($modeDebug){
	ini_set('display_errors','On');
}else{
    ini_set('error_log','/dev/null');
	ini_set('display_errors','Off');
}

/////////////// INIT ENDPOINT
$ENDPOINT = null;
if($endpointQueryOnly == "" && $endpointUpdateOnly == "" && $endpointQueryAndUpdate == ""){	
	echo "ERROR : The endpoint didn't find\n"; exit();
}elseif($endpointQueryAndUpdate != ""){
	$ENDPOINT = new Endpoint($endpointQueryAndUpdate,$modeRead,$modeDebug);
}elseif($endpointQueryOnly == "" || $endpointUpdateOnly == ""){	
	echo "ERROR : The endpoint SPARQL query or update didn't find\n"; exit();
}else{
	$ENDPOINT = new Endpoint($endpointQueryOnly,$modeRead,$modeDebug);
	$ENDPOINT->setEndpointQuery($endpointQueryOnly);
	$ENDPOINT->setEndpointUpdate($endpointUpdateOnly);
	$ENDPOINT->setNameParameterQueryRead($nameParameterQuery);
	$ENDPOINT->setNameParameterQueryWrite($nameParameterUpdate);
}

switch($typeOutput){
	case "txt":				
		$type  =  "text/plain";
	case "csv":
		$type =  "text/csv; charset=utf-8";
		break;
	case "tsv":
		$type =  "text/tab-separated-values; charset=utf-8";
		break;
	case "ttl":
		$type =  "text/turtle";
		break;
	case "srx":
		$type = "application/sparql-results+xml";
		break;
	case "srj":
		$type = "application/sparql-results+json";
		break;
	default :
		$type = $typeOutput;	
}

if($modeVerbose){
echo "
Configuration :
- Endpoint query       : ".$ENDPOINT->getEndpointQuery()."
- Endpoint update      : ".$ENDPOINT->getEndpointUpdate()."
- Mode verbose         : ".($modeVerbose?"ON":"OFF")."
- Mode debug           : ".($modeDebug?"ON":"OFF")."
- Type output           : ".$type."
";
}

/////////

$ENDPOINT->ResetErrors();

//queryRead
/*
$rows = $ENDPOINT->query( file_get_contents($filename), 'rows');
$err = $ENDPOINT->getErrors();

 if ($err) {
	echo "ERROR \n";
	print_r($err,true);
	exit();
 }
 
foreach($rows["result"]["variables"] as $variable){
	printf("%-20.20s",$variable);
	echo '|';
}
echo "\n";

foreach ($rows["result"]["rows"] as $row){
	foreach($rows["result"]["variables"] as $variable){
		printf("%-20.20s",$row[$variable]);
	echo '|';
	}
	echo "\n";
}
*/

if($modeRead)
	$response = $ENDPOINT->queryRead( file_get_contents($filename),$type);
elseif ($modeWrite)	
	$response = $ENDPOINT->queryUpdate( file_get_contents($filename),$type);
else{
	echo "ERROR : forget parameter after -r or -w (see --help)\n";
	exit();
}
	
$err = $ENDPOINT->getErrors();

 if ($err) {
	echo "ERROR \n";
	print_r($err,true);
	exit();
 }
 
 echo $response;