Homec4science
Diffusion Genome Privacy - SHCS App (master) Browse

genopri-shcs/project/GenomicPrivacy(android)/GenomicPrivacy/src/FrameWork/User.java
89c2e8c655e6master

Last Change
Raw File

User.java
View Options

package FrameWork;
import java.io.BufferedInputStream;
import java.io.DataInputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutput;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.ArrayList;
import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;
import org.json.JSONWriter;
import com.cedarsoftware.util.io.JsonReader;
import com.cedarsoftware.util.io.JsonWriter;
/**
* @author Serrano Kevin
* @author Weber Jeremy
*
*/
public class User {
/**
* Output Stream for sending JSONObject to the server
*/
private JsonWriter jswSPU;
/**
* Input Stream for reading JSONObject from the server
*/
private JsonReader jsrSPU;
/**
* Output Stream for sending JSONObject to the MU
*/
private JsonWriter jswMU;
/**
* Input Stream for reading JSONObject from the MU
*/
private JsonReader jsrMU;
/**
* name of the user
*/
private String name;
/**
* id of the user
*/
private int id;
/**
* properties for the connection
*/
private ReadProperties prop = new ReadProperties();
/**
* Instantiates a new user.
*/
public User() {
}
/**
* Instantiates a new user.
*
* @param id
* @param name
* @param jsrSPU
* @param jswSPU
*/
public User(int id, String name, JsonReader jsrSPU, JsonWriter jswSPU) {
this.jsrSPU = jsrSPU;
this.jswSPU = jswSPU;
this.name = name;
this.id = id;
}
/**
* connecting to the server
*/
public void connexionToSPU() {
jswSPU = null;
jsrSPU = null;
// SOCKET WITHOUT SSL >>>>>>>>>>>>>>>>>>>>>>>>>
Socket socket = null;
try {
socket = new Socket(prop.readPropertiesXML("IP_adress_server"),
Integer.parseInt(prop.readPropertiesXML("port_server")));
} catch (NumberFormatException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
} catch (UnknownHostException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
} catch (IOException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
// <<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<
// SSL CONNECTION ====>>>>>>>>>>>>>>>>>>
// System.setProperty("javax.net.ssl.trustStore", "server.jks");
// System.setProperty("javax.net.ssl.trustStorePassword", "password");
// System.setProperty("java.protocol.handler.pkgs",
// "com.sun.net.ssl.internal.www.protocol");
// // Connect to server
// SSLSocketFactory factory = (SSLSocketFactory) SSLSocketFactory
// .getDefault();
// SSLSocket sslSocket = null;
// try {
// sslSocket = (SSLSocket) factory.createSocket(
// prop.readPropertiesXML("IP_adress_server"),
// Integer.parseInt(prop.readPropertiesXML("port_server")));
// System.out.println("Connected to server");
// } catch (IOException e1) {
// // TODO Auto-generated catch block
// e1.printStackTrace();
// }
// <<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<======
// create the reader and writer
try {
jswSPU = new JsonWriter(socket.getOutputStream());
jsrSPU = new JsonReader(new BufferedInputStream(
socket.getInputStream()));
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
/**
* connecting to the medical unit
*/
public void connexionToMU() {
jswMU = null;
jsrMU = null;
// SOCKET WITHOUT SSL >>>>>>>>>>>>>>>>>>>>>>>>>
Socket socket = null;
try {
System.out.println("IP adresse: "
+ prop.readPropertiesXML("IP_adress_mu") + "AND PORT: "
+ Integer.parseInt(prop.readPropertiesXML("port_mu")));
socket = new Socket(prop.readPropertiesXML("IP_adress_mu"),
Integer.parseInt(prop.readPropertiesXML("port_mu")));
System.out.println(socket.toString());
} catch (NumberFormatException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
} catch (UnknownHostException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
} catch (IOException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
try {
jswMU = new JsonWriter(socket.getOutputStream());
jsrMU = new JsonReader(socket.getInputStream());
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
/**
* send the JSONObject to the server
*
* @param json
*/
public void sendToSPU(JSONObject json) {
try {
json.put("string", "string");
System.out.println(json.toString());
jswSPU.flush();
jswSPU.write(json.toString());
jswSPU.flush();
System.out.println("JSON SEND SPU " + json.toString());
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (JSONException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
/**
* send the JSONObject to the medical unit
*
* @param json
*/
public void sentToMU(JSONObject json) {
try {
jswMU.write("JSON SEND MU " + json.toString());
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
/**
* wait on JSONObject from the server
*
* @return JSONObject
*/
public JSONObject receiveFromSPU() {
JSONObject json = null;
String jsonString = null;
Type type = null;
try {
jsonString = (String) jsrSPU.readObject();
json = new JSONObject(jsonString);
type = Type.valueOf(json.getString("type"));
json.put("type", type);
System.out.println("JSON RECEIVE " + json.toString());
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (JSONException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return json;
}
/**
* Get the profile depends on the type (patient or medical)
*
* @param type
* @return user
*/
public User getProfil(Type t) {
JSONObject profil = null;
profil = receiveFromSPU();
// if patient then
Patient patient = null;
MedUnit medUnit = null;
switch (t) {
case PATIENT:
try {
patient = new Patient(profil.getInt("id"), null, jsrSPU,
jswSPU, null, null, null, null);
} catch (JSONException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return patient;
// if MU then
case MEDICAL:
try {
medUnit = new MedUnit(profil.getInt("id"),
profil.getString("name"), jsrSPU,jswSPU,
profil.getString("location"));
} catch (JSONException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return medUnit;
}
return medUnit;
}
/**
* @param name
*/
public void setName(String n) {
name = n;
}
/**
* @param id
*/
public void setID(String id) {
name = id;
}
/**
* @return name
*/
public String getName() {
return name;
}
/**
* @return id
*/
public int getID() {
return id;
}
/**
* @return JSONWriter SPU
*/
public JsonWriter getJswSPU() {
return jswSPU;
}
/**
* @return
*/
public JsonReader getJsrSPU() {
return jsrSPU;
}
/**
* @return
*/
public ArrayList<RequestPatient> checkNewRequest() {
JSONObject json = new JSONObject();
ArrayList<RequestPatient> newrp = new ArrayList<RequestPatient>();
// check if there are new Request from MU to PATIENT id (can use
// patient.checkNewRequest() instead)
Type type = null;
try {
json.put("type", type.CHECK_REQUEST_P);
json.put("id", getID());
} catch (JSONException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
this.sendToSPU(json);
// this.sendToSPU(json);
// wait the response
json = this.receiveFromSPU();
try {
type = (Type) json.get("type");
} catch (JSONException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
switch (type) {
case CHECK_REQUEST_P:
// NEED TO HAVE A RP ARRAY, NOT A BOOLEAN
// try {
// rpArray = (ArrayList<RequestPatient>) json.get("rpArray");
// } catch (JSONException e) {
// // TODO Auto-generated catch block
// e.printStackTrace();
// }
try {
System.out.println(json.get("newrp").toString());
JSONArray jarray = json.getJSONArray("newrp");
JSONObject json2 = null;
if (jarray != null) { // In this case jsonArray is your JSON
// array
for (int i = 0; i < jarray.length(); i++) {
json2 = (JSONObject) jarray.get(i);
int id_r = json2.getInt("id_r");
int id_p = json2.getInt("id_p");
int id_mu = json2.getInt("id_mu");
int id_t = json2.getInt("id_t");
int flag = json2.getInt("flag");
String testName = json2.getString("nameTest");
newrp.add(new RequestPatient(id_r, id_p, id_mu, id_t,testName,
flag));
}
}
// System.out.println(jArray.toString());
System.out.println(json.toString());
// for(int i=0 ;i<jArray.length();i++){
// newrp.addAll((RequestPatient>) jArray.getJSONObject(i));
// newrp = (ArrayList<RequestPatient>) jArray.get(0);
} catch (JSONException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
break;
}
return newrp;
}
}
c4science · Help