Homec4science
Diffusion Genome Privacy - SHCS App (mobile_app) Browse

genopri-shcs/project/PPPCommons/src/io/ClientConnection.java
da652ed24928mobile_app

Last Change
Raw File

ClientConnection.java
View Options

package io;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.logging.Level;
import java.util.logging.Logger;
import framework.Type;
import framework.TypeString;
public class ClientConnection {
private static final Logger LOGGER = Logger.getLogger(ClientConnection.class.getName());
private BufferedReader in = null;
private PrintWriter out = null;
private Socket socket = null;
private String ip;
private int port;
public ClientConnection(String ip, int port) {
this.ip = ip;
this.port = port;
}
public String sendReceive(Type type, String request) {
connect();
send(type, request);
String answer;
try {
answer = receive();
} catch (IOException e) {
LOGGER.log(Level.SEVERE, null, e);
return null;
} finally {
close();
}
return answer;
}
private void connect() {
try {
socket = new Socket(ip, port);
in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
out = new PrintWriter(socket.getOutputStream());
} catch (UnknownHostException e) {
LOGGER.log(Level.SEVERE, null, e);
} catch (IOException e) {
LOGGER.log(Level.SEVERE, null, e);
}
}
private void send(Type type, String request) {
switch (type) {
case MATERIAL:
out.println(TypeString.MATERIAL);
break;
case DECRYPT:
out.println(TypeString.DECRYPT);
break;
default:
throw new IllegalStateException("Type not identified");
}
out.println(request);
out.flush();
}
private String receive() throws IOException {
String res = "";
String currentLine = null;
boolean first = true;
while ((currentLine = in.readLine()) != null) {
if (first) {
first = false;
} else {
res += "\n";
}
res += currentLine;
}
return res;
}
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 {
socket.close();
} catch (IOException e) {
LOGGER.log(Level.SEVERE, null, e);
socket = null;
}
}
}
c4science · Help