Homec4science
Diffusion Genome Privacy - SHCS App (ms_access_migration) Browse

genopri-shcs/project/PPPServer/src/framework/WorkerStandalone.java
9270d993aa95ms_access_migration

Last Change
Raw File

WorkerStandalone.java
View Options

package framework;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.sql.SQLException;
import java.util.logging.Level;
import java.util.logging.Logger;
import org.json.JSONException;
import utils.ConfigProperties;
import utils.ServerProperties;
import database.DBconnectorServer;
import database.DBconnectorServerStandalone;
public class WorkerStandalone implements Runnable {
private static final Logger LOGGER = Logger.getLogger(WorkerStandalone.class.getName());
private Socket client;
private BufferedReader in = null;
private PrintWriter out = null;
private RequestHandler handler;
private DBconnectorServerStandalone connectStandalone;
public WorkerStandalone(ServerProperties props, Socket client) {
this.client = client;
String curveName = props.getProperty(ConfigProperties.KEY_CURVE);
DBconnectorServer connectServer = new DBconnectorServer(props.getConfigSPU());
this.connectStandalone = new DBconnectorServerStandalone(props.getConfigSPU());
this.handler = new RequestHandler(connectServer, curveName);
}
@Override
public void run() {
// create streams
try {
in = new BufferedReader(new InputStreamReader(client.getInputStream()));
out = new PrintWriter(client.getOutputStream());
Type requestType = parseRequestType(in.readLine());
String requestLine = in.readLine();
switch (requestType) {
case MATERIAL:
LOGGER.log(Level.FINE, "Material request");
String replyMaterial = handler.handleMaterialRequest(requestLine);
writeToStream(replyMaterial);
break;
case DECRYPT:
LOGGER.log(Level.INFO, "Decrypt request");
String replyDecrypt = handler.handleDecryptionStandalone(requestLine, connectStandalone);
writeToStream(replyDecrypt);
break;
default:
LOGGER.log(Level.WARNING, "Unhandled request of type " + requestType);
break;
}
} catch (IOException | JSONException | SQLException | InterruptedException e) {
LOGGER.log(Level.SEVERE, null, e);
LOGGER.log(Level.SEVERE, "Worker will exit now!");
} finally {
close();
}
}
private void writeToStream(String reply) {
out.println(reply);
out.flush();
}
private void close() {
// close reader
try {
in.close();
} catch (IOException e) {
LOGGER.log(Level.SEVERE, null, e);
in = null;
}
// close writer
out.close();
out = null;
// close socket
try {
client.close();
} catch (IOException e) {
LOGGER.log(Level.SEVERE, null, e);
client = null;
}
}
private Type parseRequestType(String line) {
switch(line) {
case TypeString.MATERIAL:
return Type.MATERIAL;
case TypeString.DECRYPT:
return Type.DECRYPT;
default:
throw new IllegalArgumentException("Request type does not exist: " + line);
}
}
}
c4science · Help