Skip to content

Commit

Permalink
feat: changing JSAP to load from URL
Browse files Browse the repository at this point in the history
  • Loading branch information
@lroffia
lroffia committed Oct 31, 2023
1 parent 7d39cf5 commit 206fc0d
Show file tree
Hide file tree
Showing 9 changed files with 420 additions and 283 deletions.
188 changes: 159 additions & 29 deletions client-api/src/main/java/it/unibo/arces/wot/sepa/commons/properties/SPARQL11Properties.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,10 @@
package it.unibo.arces.wot.sepa.commons.properties;

import java.io.*;
import java.net.MalformedURLException;
import java.net.URL;
import java.util.Map;
import java.util.Objects;
import java.util.Set;

import com.google.gson.Gson;
Expand Down Expand Up @@ -83,13 +87,8 @@ public class SPARQL11Properties {
protected String host;
protected SPARQL11ProtocolProperties sparql11protocol;
protected GraphsProperties graphs = null;

/** The defaults file name. */
protected String defaultsFileName = "endpoint.jpar";

/** The properties file. */
protected String propertiesFile = defaultsFileName;

protected String filename = null;

/**
* The Enum SPARQLPrimitive (QUERY, UPDATE).
Expand Down Expand Up @@ -123,57 +122,188 @@ public String getProtocolScheme() {
}
};


public SPARQL11Properties() {
this.host = "localhost";
this.sparql11protocol = new SPARQL11ProtocolProperties();
this.sparql11protocol.protocol = ProtocolScheme.http;

override(null);
}

public SPARQL11Properties(String args[]) {
this();

override(args);
}

public SPARQL11Properties(String jsapFile,String[] args) throws SEPAPropertiesException {
this();

Reader in = getReaderFromUrl(jsapFile);
parseJSAP(in);
try {
in.close();
} catch (IOException e) {
throw new SEPAPropertiesException(e);
}

override(args);

filename = jsapFile;
}

public SPARQL11Properties(String jsapFile) throws SEPAPropertiesException {
this();

Reader in = getReaderFromUrl(jsapFile);
parseJSAP(in);
try {
in.close();
} catch (IOException e) {
throw new SEPAPropertiesException(e);
}

override(null);

filename = jsapFile;
}

public SPARQL11Properties(String host,ProtocolScheme scheme) {
this.host = host;
this.sparql11protocol = new SPARQL11ProtocolProperties();
this.sparql11protocol.protocol = scheme;

override(null);
}

public SPARQL11Properties(Reader in,String[] args) throws SEPAPropertiesException {
this();

parseJSAP(in);

override(args);
}

public SPARQL11Properties(Reader in) throws SEPAPropertiesException {
this(in,null);
}

public SPARQL11Properties(String jsapFile) throws SEPAPropertiesException {
protected void override(String[] args) {
Map<String, String> envs = System.getenv();
for(String var : envs.keySet()) {
Logging.logger.debug("Environmental variable "+var+" : "+envs.get(var));
setParameter("-"+var, envs.get(var));
}

if (args != null)
for (int i = 0; i < args.length; i = i + 2) {
Logging.logger.debug("Argument "+args[i]+" : "+args[i+1]);
setParameter(args[i], args[i+1]);
}
}

private void parseJSAP(Reader in) throws SEPAPropertiesException {
SPARQL11Properties jsap = null;
if (jsapFile == null) throw new SEPAPropertiesException("File is null");
try {
FileReader reader = new FileReader(jsapFile);
jsap = new Gson().fromJson(reader, SPARQL11Properties.class);
} catch (JsonSyntaxException | JsonIOException | FileNotFoundException e) {
jsap = new Gson().fromJson(in, SPARQL11Properties.class);
} catch (JsonSyntaxException | JsonIOException e) {
Logging.logger.error(e.getMessage());
e.printStackTrace();
throw new SEPAPropertiesException(e);
}

this.host = jsap.host;
this.sparql11protocol = jsap.sparql11protocol;
this.graphs = jsap.graphs;

propertiesFile = jsapFile;
}

public String getJSAPFilename() {
return propertiesFile;
/*
* Applications working with file paths and file URIs should take great care
* to use the appropriate methods to convert between the two.
* The Path.of(URI) factory method and the File.File(URI) constructor
* can be used to create Path or File objects from a file URI.
* Path.toUri() and File.toURI() can be used to create a URI from a file path,
* which can be converted to URL using URI.toURL(). Applications should never
* try to construct or parse a URL from the direct string representation
* of a File or Path instance
* */
protected Reader getReaderFromUrl(String url) throws SEPAPropertiesException {
Reader in = null;
URL jsap = null;

Logging.logger.info("Get reader from URL: "+url);
try {
jsap = new URL(url);
try {
in = new BufferedReader(
new InputStreamReader(jsap.openStream()));
} catch (IOException e) {
Logging.logger.warn("Failed to read input stream: "+e.getMessage());
try {
in = new FileReader(jsap.getFile());
} catch (FileNotFoundException ex) {
Logging.logger.warn("Failed to read file: "+e.getMessage());
in = new InputStreamReader(Objects.requireNonNull(getClass().getClassLoader().getResourceAsStream(jsap.getFile())));
}
}
} catch (MalformedURLException e) {
Logging.logger.error(e.getMessage());
throw new SEPAPropertiesException(e);
}

return in;
}

protected void setParameter(String key,String value) {
switch (key) {
case "-host" :
this.host = value;
break;
case "-sparql11protocol.port":
this.sparql11protocol.port = Integer.valueOf(value);
break;
case "-sparql11protocol.host":
this.sparql11protocol.host = host;
break;
case "-sparql11protocol.protocol":
this.sparql11protocol.protocol = (value == "http" ? ProtocolScheme.http : ProtocolScheme.https);
break;
case "-sparql11protocol.update.method":
this.sparql11protocol.update.method = (value == "post" ? UpdateHTTPMethod.POST : UpdateHTTPMethod.URL_ENCODED_POST);
break;
case "-sparql11protocol.update.format":
this.sparql11protocol.update.format = (value == "json" ? UpdateResultsFormat.JSON : UpdateResultsFormat.HTML);
break;
case "-sparql11protocol.update.path":
this.sparql11protocol.update.path = value;
break;
case "-sparql11protocol.query.method":
this.sparql11protocol.query.method = (value == "get" ? QueryHTTPMethod.GET : (value == "post" ? QueryHTTPMethod.POST : QueryHTTPMethod.URL_ENCODED_POST));
break;
case "-sparql11protocol.query.format":
this.sparql11protocol.query.format = (value == "json" ? QueryResultsFormat.JSON : (value == "xml" ? QueryResultsFormat.XML : QueryResultsFormat.CSV));
break;
case "-sparql11protocol.query.path":
this.sparql11protocol.query.path = value;
break;
}
}

public String toString() {
return new Gson().toJson(this);
}

/**
* Store properties.
*
* @param propertiesFile the properties file
* @throws SEPAPropertiesException
* @throws IOException Signals that an I/O exception has occurred.
*/
protected void storeProperties(String propertiesFile) throws SEPAPropertiesException {
public void write() throws SEPAPropertiesException {
FileWriter out;
try {
out = new FileWriter(propertiesFile);
out = new FileWriter(filename);
out.write(this.toString());
out.close();
} catch (Exception e) {
throw new SEPAPropertiesException(e);
} catch (IOException e) {
if (Logging.logger.isTraceEnabled())
e.printStackTrace();
throw new SEPAPropertiesException(e.getMessage());
}

}

/**
Expand Down
131 changes: 104 additions & 27 deletions ...nt-api/src/main/java/it/unibo/arces/wot/sepa/commons/properties/SPARQL11SEProperties.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -18,8 +18,8 @@

package it.unibo.arces.wot.sepa.commons.properties;

import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.io.Reader;

import com.google.gson.Gson;
import com.google.gson.JsonIOException;
Expand Down Expand Up @@ -81,47 +81,124 @@ public enum SPARQL11SEPrimitive {
// Members
protected SPARQL11SEProtocolProperties sparql11seprotocol;

public SPARQL11SEProperties() {
sparql11seprotocol = new SPARQL11SEProtocolProperties();

override(null);
}

/**
* Instantiates a new SPARQL 11 SE properties.
*
* @param propertiesFile the properties file
* @param in where to read the JSAP from
* @throws SEPAPropertiesException
*/
public SPARQL11SEProperties(Reader in) throws SEPAPropertiesException {
super(in);

parseJSAP(in);

override(null);
}

public SPARQL11SEProperties(Reader in,String[] args) throws SEPAPropertiesException {
super(in,args);

parseJSAP(in);

override(args);
}

public SPARQL11SEProperties(String propertiesFile,String[] args) throws SEPAPropertiesException {
super(propertiesFile);

Reader in = getReaderFromUrl(propertiesFile);
parseJSAP(in);
try {
in.close();
} catch (IOException e) {
throw new SEPAPropertiesException(e);
}

override(args);
}

public SPARQL11SEProperties(String propertiesFile) throws SEPAPropertiesException {
super(propertiesFile);

Reader in = getReaderFromUrl(propertiesFile);
parseJSAP(in);
try {
in.close();
} catch (IOException e) {
throw new SEPAPropertiesException(e);
}

override(null);
}

private void parseJSAP(Reader in) throws SEPAPropertiesException {
SPARQL11SEProperties jsap;
try {
jsap = new Gson().fromJson(new FileReader(propertiesFile), SPARQL11SEProperties.class);
jsap = new Gson().fromJson(in, SPARQL11SEProperties.class);
sparql11seprotocol = jsap.sparql11seprotocol;
} catch (JsonSyntaxException | JsonIOException | FileNotFoundException e2) {
} catch (JsonSyntaxException | JsonIOException e2) {
Logging.logger.error(e2.getMessage());
e2.printStackTrace();
throw new SEPAPropertiesException(e2);
}
}

// try {
// jsap = new Gson().fromJson(new FileReader(propertiesFile), SPARQL11SEProperties.class);
// } catch (Exception e) {
// Logging.logger.warn("Create from file: " + propertiesFile);
// Logging.logger.warn(e.getMessage());
// jsap = new SPARQL11SEProperties();
// Logging.logger.warn("USING DEFAULTS. Edit \"" + defaultsFileName + "\" (if needed) and run again the broker");
// try {
// jsap.storeProperties(defaultsFileName);
// } catch (SEPAPropertiesException e1) {
// Logging.logger.error(e1.getMessage());
// }
//
// }


}

// public SPARQL11SEProperties() {
// super();
// sparql11seprotocol = new SPARQL11SEProtocol();
// }
protected final void setParameter(String key,String value) {
switch (key) {
case "-host" :
this.host = value;
break;
case "-sparql11protocol.port":
this.sparql11protocol.port = Integer.valueOf(value);
break;
case "-sparql11protocol.host":
this.sparql11protocol.host = host;
break;
case "-sparql11protocol.protocol":
this.sparql11protocol.protocol = (value == "http" ? ProtocolScheme.http : ProtocolScheme.https);
break;
case "-sparql11protocol.update.method":
this.sparql11protocol.update.method = (value == "post" ? UpdateProperties.UpdateHTTPMethod.POST : UpdateProperties.UpdateHTTPMethod.URL_ENCODED_POST);
break;
case "-sparql11protocol.update.format":
this.sparql11protocol.update.format = (value == "json" ? UpdateProperties.UpdateResultsFormat.JSON : UpdateProperties.UpdateResultsFormat.HTML);
break;
case "-sparql11protocol.update.path":
this.sparql11protocol.update.path = value;
break;
case "-sparql11protocol.query.method":
this.sparql11protocol.query.method = (value == "get" ? QueryProperties.QueryHTTPMethod.GET : (value == "post" ? QueryProperties.QueryHTTPMethod.POST : QueryProperties.QueryHTTPMethod.URL_ENCODED_POST));
break;
case "-sparql11protocol.query.format":
this.sparql11protocol.query.format = (value == "json" ? QueryProperties.QueryResultsFormat.JSON : (value == "xml" ? QueryProperties.QueryResultsFormat.XML : QueryProperties.QueryResultsFormat.CSV));
break;
case "-sparql11protocol.query.path":
this.sparql11protocol.query.path = value;
break;
case "-sparql11seprotocol.host":
this.sparql11seprotocol.host = value;
break;
case "-sparql11seprotocol.protocol":
this.sparql11seprotocol.protocol = value;
break;
case "-sparql11seprotocol.reconnect":
this.sparql11seprotocol.reconnect = Boolean.valueOf(value);
break;
default:
if (key.startsWith("-sparql11seprotocol.availableProtocols")) {
String[] token = key.split(".");
if (token[3] == "path") this.sparql11seprotocol.availableProtocols.get(token[2]).path = value;
else if (token[3] == "port") this.sparql11seprotocol.availableProtocols.get(token[2]).port = Integer.valueOf(value);
else if (token[3] == "scheme") this.sparql11seprotocol.availableProtocols.get(token[2]).scheme = value;
}
}
}

public String toString() {
return new Gson().toJson(this);
Expand Down
Loading

0 comments on commit 206fc0d

Please sign in to comment.