Diffusion Genome Privacy - SHCS App (mobile_app) Browse

MedUnit.java
89c2e8c655e6mobile_app

MedUnit.java
View Options

			package FrameWork;

			import java.io.File;
			import java.io.ObjectInputStream;
			import java.io.ObjectOutputStream;
			import java.math.BigInteger;
			import java.sql.SQLException;
			import java.util.ArrayList;
			import java.util.ListIterator;
			import java.util.logging.Level;
			import java.util.logging.Logger;

			import org.json.JSONArray;
			import org.json.JSONException;
			import org.json.JSONObject;

			import android.os.Environment;

			import com.cedarsoftware.util.io.JsonReader;
			import com.cedarsoftware.util.io.JsonWriter;

			import crypto.CryptoException;
			import crypto.DGK_key_generator;
			import crypto.DGK_scheme;
			import crypto.Scheme;

			public class MedUnit extends User {
			/** The id. */
			private int id;

			/** The name. */
			private String name;

			/** The location. */
			private String location;

			/** The jsr. */
			private JsonReader jsr;

			/** The jsw. */
			private JsonWriter jsw;

			/** The prk. */
			private BigInteger prk;

			/** The pbk. */
			private BigInteger[] pbk;

			/** The id_p. */
			private int id_p;

			/** The l. */
			private int l = 16;

			/** The t. */
			private int t = 160;

			/** The k. */
			private int k = 1024;

			/** The dgk_pk. */
			private BigInteger[] dgk_pk;

			/** The dgk_sk. */
			private BigInteger[] dgk_sk;

			/** The dgk_scheme. */
			private DGK_scheme dgk_scheme;
			/**
			* Instantiates a new med unit.
			*
			* @param id
			* the id
			* @param name
			* the name
			* @param jsr
			* the json reader
			* @param jsw
			* the json writer
			* @param location
			* the location
			*/
			public MedUnit(int id, String name,JsonReader jsr, JsonWriter jsw,
			String location) {
			super(id, name, jsr, jsw);
			// TODO Auto-generated constructor stub
			this.location = location;
			DGK_key_generator kg = new DGK_key_generator(k, t, l);
			kg.generateKeys();

			BigInteger[] pk = { kg.getN(), kg.getG(), kg.getH(), kg.getU() };
			BigInteger[] sk = { kg.getP(), kg.getQ(), kg.getVpvq(), kg.getPp_inv(),
			kg.getQq_inv() };
			this.dgk_pk = pk;
			this.dgk_sk = sk;
			}

			/**
			* Run test
			*
			* @param r
			* @return the result
			*/
			public double[] runTest(Request r) {

			double[] result = new double[2];
			try {
			int id_dis = r.getId_t();
			id_p = r.getId_p();

			prk = DBconnector_mu.getPrivateKey(id_p);

			pbk = DBconnector_mu.getPublicKey(id_p);
			// particular case if the test is ID_t = 2 or ID_t = 8
			JSONObject json = new JSONObject();
			ArrayList[] markers = null;
			if (id_dis == 2) {
			markers = DBconnector_mu.getMarkers(1);

			// Ask for the test to Server

			json.put("type", Type.TEST);
			json.put("request", r);
			json.put("id_p", r.getId_p());
			json.put("id_mu", r.getId_mu());
			json.put("id_r", r.getId_r());
			json.put("id_t", r.getId_t());
			JSONArray jsonArrIdMarker = new JSONArray();
			JSONArray jsonArrWeightMarkers = new JSONArray();
			JSONArray jsonArrIDCf = new JSONArray();
			JSONArray jsonArrWieghtCF = new JSONArray();

			for (int i = 0; i < r.getMarkers()[0].size(); i++) {
			jsonArrIdMarker.put(r.getMarkers()[0].get(i));
			}
			for (int i = 0; i < r.getMarkers()[1].size(); i++) {
			jsonArrWeightMarkers.put(r.getMarkers()[1].get(i));
			}
			for (int i = 0; i < r.getCfs()[0].size(); i++) {
			jsonArrIDCf.put(r.getCfs()[0].get(i));
			}
			for (int i = 0; i < r.getCfs()[1].size(); i++) {
			jsonArrWieghtCF.put(r.getCfs()[1].get(i));
			}
			json.put("ID_cf", jsonArrIDCf);
			json.put("weightCF", jsonArrWieghtCF);
			json.put("IdMarkers", jsonArrIdMarker);
			json.put("weightMarkers", jsonArrWeightMarkers);
			sendToSPU(json);
			// wait encrypted result

			json = receiveFromSPU(); // receive result directly
			JSONArray resultEncArr = (JSONArray) json.get("result");
			BigInteger[] enc_result_1 = new BigInteger[resultEncArr
			.length()];
			for (int i = 0; i < resultEncArr.length(); i++) {
			enc_result_1[i] = (BigInteger) resultEncArr.get(i);
			}
			double result_1 = decryption(enc_result_1);

			if (result_1 == 2) {
			result[0] = 0;
			} else {
			markers = DBconnector_mu.getMarkers(201);

			// Ask for the test to Server

			json.put("type", Type.TEST);
			json.put("request", r);
			json.put("id_p", r.getId_p());
			json.put("id_mu", r.getId_mu());
			json.put("id_r", r.getId_r());
			json.put("id_t", r.getId_t());
			jsonArrIdMarker = new JSONArray();
			jsonArrWeightMarkers = new JSONArray();
			jsonArrIDCf = new JSONArray();
			jsonArrWieghtCF = new JSONArray();
			for (int i = 0; i < r.getMarkers()[0].size(); i++) {
			jsonArrIdMarker.put(r.getMarkers()[0].get(i));
			}
			for (int i = 0; i < r.getMarkers()[1].size(); i++) {
			jsonArrWeightMarkers.put(r.getMarkers()[1].get(i));
			}
			for (int i = 0; i < r.getCfs()[0].size(); i++) {
			jsonArrIDCf.put(r.getCfs()[0].get(i));
			}
			for (int i = 0; i < r.getCfs()[1].size(); i++) {
			jsonArrWieghtCF.put(r.getCfs()[1].get(i));
			}
			json.put("ID_cf", jsonArrIDCf);
			json.put("weightCF", jsonArrWieghtCF);
			json.put("IdMarkers", jsonArrIdMarker);
			json.put("weightMarkers", jsonArrWeightMarkers);
			sendToSPU(json);
			// wait encrypted result
			json = receiveFromSPU();
			resultEncArr = (JSONArray) json.get("result");
			BigInteger[] enc_result_2 = new BigInteger[resultEncArr
			.length()];
			for (int i = 0; i < resultEncArr.length(); i++) {
			enc_result_2[i] = new BigInteger(resultEncArr.get(i)
			.toString());
			}
			double result_2 = decryption(enc_result_2);

			if (result_2 >= 1) {
			result[0] = 2;
			} else {
			markers = DBconnector_mu.getMarkers(id_dis);
			// Ask for the test to Server

			json.put("type", Type.TEST);
			json.put("request", r);
			json.put("id_p", r.getId_p());
			json.put("id_mu", r.getId_mu());
			json.put("id_r", r.getId_r());
			json.put("id_t", r.getId_t());
			jsonArrIdMarker = new JSONArray();
			jsonArrWeightMarkers = new JSONArray();
			jsonArrIDCf = new JSONArray();
			jsonArrWieghtCF = new JSONArray();
			for (int i = 0; i < r.getMarkers()[0].size(); i++) {
			jsonArrIdMarker.put(r.getMarkers()[0].get(i));
			}
			for (int i = 0; i < r.getMarkers()[1].size(); i++) {
			jsonArrWeightMarkers.put(r.getMarkers()[1].get(i));
			}
			for (int i = 0; i < r.getCfs()[0].size(); i++) {
			jsonArrIDCf.put(r.getCfs()[0].get(i));
			}
			for (int i = 0; i < r.getCfs()[1].size(); i++) {
			jsonArrWieghtCF.put(r.getCfs()[1].get(i));
			}
			json.put("ID_cf", jsonArrIDCf);
			json.put("weightCF", jsonArrWieghtCF);
			json.put("IdMarkers", jsonArrIdMarker);
			json.put("weightMarkers", jsonArrWeightMarkers);
			sendToSPU(json);
			// wait encrypted result
			json = receiveFromSPU();
			resultEncArr = (JSONArray) json.get("result");
			BigInteger[] enc_result = new BigInteger[resultEncArr
			.length()];
			for (int i = 0; i < resultEncArr.length(); i++) {
			enc_result[i] = new BigInteger(resultEncArr.get(i)
			.toString());
			}

			result[0] = decryption(enc_result);
			}
			}

			} else if (id_dis == 8) {

			markers = DBconnector_mu.getMarkers(id_dis);

			// Ask for the test to Server

			json.put("type", Type.TEST);
			json.put("request", r);
			json.put("id_p", r.getId_p());
			json.put("id_mu", r.getId_mu());
			json.put("id_r", r.getId_r());
			json.put("id_t", r.getId_t());
			JSONArray jsonArrIdMarker = new JSONArray();
			JSONArray jsonArrWeightMarkers = new JSONArray();
			JSONArray jsonArrIDCf = new JSONArray();
			JSONArray jsonArrWieghtCF = new JSONArray();
			for (int i = 0; i < r.getMarkers()[0].size(); i++) {
			jsonArrIdMarker.put(r.getMarkers()[0].get(i));
			}
			for (int i = 0; i < r.getMarkers()[1].size(); i++) {
			jsonArrWeightMarkers.put(r.getMarkers()[1].get(i));
			}
			for (int i = 0; i < r.getCfs()[0].size(); i++) {
			jsonArrIDCf.put(r.getCfs()[0].get(i));
			}
			for (int i = 0; i < r.getCfs()[1].size(); i++) {
			jsonArrWieghtCF.put(r.getCfs()[1].get(i));
			}
			json.put("ID_cf", jsonArrIDCf);
			json.put("weightCF", jsonArrWieghtCF);
			json.put("IdMarkers", jsonArrIdMarker);
			json.put("weightMarkers", jsonArrWeightMarkers);
			sendToSPU(json);
			// wait encrypted result
			json = receiveFromSPU();
			JSONArray resultEncArr = (JSONArray) json.get("result");
			BigInteger[] enc_result_8 = new BigInteger[resultEncArr
			.length()];
			for (int i = 0; i < resultEncArr.length(); i++) {
			enc_result_8[i] = new BigInteger(resultEncArr.get(i)
			.toString());
			}
			double result_8 = decryption(enc_result_8);

			if (result_8 >= 2) {
			markers = DBconnector_mu.getMarkers(801);
			// Ask for the test to Server

			json.put("type", Type.TEST);
			json.put("request", r);
			json.put("id_p", r.getId_p());
			json.put("id_mu", r.getId_mu());
			json.put("id_r", r.getId_r());
			json.put("id_t", r.getId_t());
			jsonArrIdMarker = new JSONArray();
			jsonArrWeightMarkers = new JSONArray();
			jsonArrIDCf = new JSONArray();
			jsonArrWieghtCF = new JSONArray();
			for (int i = 0; i < r.getMarkers()[0].size(); i++) {
			jsonArrIdMarker.put(r.getMarkers()[0].get(i));
			}
			for (int i = 0; i < r.getMarkers()[1].size(); i++) {
			jsonArrWeightMarkers.put(r.getMarkers()[1].get(i));
			}
			for (int i = 0; i < r.getCfs()[0].size(); i++) {
			jsonArrIDCf.put(r.getCfs()[0].get(i));
			}
			for (int i = 0; i < r.getCfs()[1].size(); i++) {
			jsonArrWieghtCF.put(r.getCfs()[1].get(i));
			}
			json.put("ID_cf", jsonArrIDCf);
			json.put("weightCF", jsonArrWieghtCF);
			json.put("IdMarkers", jsonArrIdMarker);
			json.put("weightMarkers", jsonArrWeightMarkers);
			sendToSPU(json);
			// wait encrypted result
			json = receiveFromSPU();
			resultEncArr = (JSONArray) json.get("result");
			BigInteger[] enc_result_801 = new BigInteger[resultEncArr
			.length()];
			for (int i = 0; i < resultEncArr.length(); i++) {
			enc_result_801[i] = new BigInteger(resultEncArr.get(i)
			.toString());
			}
			double result_801 = decryption(enc_result_801);

			if (result_801 >= 1) {
			result[0] = 21;
			} else {
			result[0] = result_8;
			}
			} else {
			result[0] = result_8;
			}

			} else {
			markers = DBconnector_mu.getMarkers(id_dis);
			// Ask for the test to Server

			json.put("type", Type.TEST);
			json.put("request", r);
			json.put("id_p", r.getId_p());
			json.put("id_mu", r.getId_mu());
			json.put("id_r", r.getId_r());
			json.put("id_t", r.getId_t());
			JSONArray jsonArrIdMarker = new JSONArray();
			JSONArray jsonArrWeightMarkers = new JSONArray();
			JSONArray jsonArrIDCf = new JSONArray();
			JSONArray jsonArrWieghtCF = new JSONArray();
			for (int i = 0; i < r.getMarkers()[0].size(); i++) {
			jsonArrIdMarker.put(r.getMarkers()[0].get(i));
			}
			for (int i = 0; i < r.getMarkers()[1].size(); i++) {
			jsonArrWeightMarkers.put(r.getMarkers()[1].get(i));
			}
			for (int i = 0; i < r.getCfs()[0].size(); i++) {
			jsonArrIDCf.put(r.getCfs()[0].get(i));
			}
			for (int i = 0; i < r.getCfs()[1].size(); i++) {
			jsonArrWieghtCF.put(r.getCfs()[1].get(i));
			}
			json.put("ID_cf", jsonArrIDCf);
			json.put("weightCF", jsonArrWieghtCF);
			json.put("IdMarkers", jsonArrIdMarker);
			json.put("weightMarkers", jsonArrWeightMarkers);
			sendToSPU(json);
			// wait encrypted result
			if (r.getCfs()[0].isEmpty()) {
			// receive result directly
			} else {

			JSONObject jsonQuartiles = new JSONObject();
			double[] quartiles = DBconnector_mu.getQuartiles(r
			.getId_t());
			JSONArray jsonArrQuartile = new JSONArray();
			for (int i = 0; i < quartiles.length; i++) {
			jsonArrQuartile.put(quartiles[i]);
			}
			double quartile1 = quartiles[0];
			double quartile2 = quartiles[1];
			double quartile3 = quartiles[2];


			jsonQuartiles.put("quartile1", quartile1);
			jsonQuartiles.put("quartile2", quartile2);
			jsonQuartiles.put("quartile3", quartile3);
			sendToSPU(jsonQuartiles);
			for (int m = 0; m < 3; m++) {

			JSONObject jsonCipherD = new JSONObject();
			jsonCipherD = receiveFromSPU();

			String s1 = jsonCipherD.getString("cipherDproxy1");
			String s2 = jsonCipherD.getString("cipherDproxy2");

			BigInteger[] cipherD_proxy = new BigInteger[] {
			new BigInteger(s1), new BigInteger(s2) };
			ArrayList compro = comparisonProtocol(cipherD_proxy);
			BigInteger[] cipherDmod = (BigInteger[]) compro.get(0);
			BigInteger[] pk = (BigInteger[]) compro.get(1);
			ArrayList<BigInteger> cipherDitmpArray = (ArrayList<BigInteger>) compro
			.get(2);
			BigInteger[] cipherDiTmp = new BigInteger[cipherDitmpArray
			.size()];
			for (int i = 0; i < cipherDiTmp.length; i++) {
			cipherDiTmp[i] = cipherDitmpArray.get(i);
			}

			JSONArray cipherDmodArr = new JSONArray();
			JSONArray pkArr = new JSONArray();
			JSONArray cipherDiArra = new JSONArray();

			for (int j = 0; j < pk.length; j++) {
			pkArr.put(pk[j].toString());
			}

			for (int j = 0; j < cipherDiTmp.length; j++) {
			cipherDiArra.put(cipherDiTmp[j].toString());
			}
			for (int j = 0; j < cipherDmod.length; j++) {
			cipherDmodArr.put(cipherDmod[j].toString());

			}

			jsonCipherD.put("cipherDmod", cipherDmodArr);
			jsonCipherD.put("pk", pkArr);
			jsonCipherD.put("cipherDi", cipherDiArra);
			sendToSPU(jsonCipherD);

			JSONObject jsoncipherci = receiveFromSPU();
			JSONArray jsonArrcipherCiarray = (JSONArray) jsoncipherci
			.get("cipherCi");
			ArrayList<BigInteger> cipherCi = new ArrayList<BigInteger>();
			for (int j = 0; j < jsonArrcipherCiarray.length(); j++) {
			cipherCi.add(new BigInteger(
			(String) jsonArrcipherCiarray.get(j)));
			}

			BigInteger[] cipherLambda = computeCipherLamda(cipherCi);

			JSONObject jsonCipherLambda = new JSONObject();
			JSONArray jsonArrCipherLambda = new JSONArray();
			for (int j = 0; j < cipherLambda.length; j++) {
			jsonArrCipherLambda.put(cipherLambda[j].toString());
			}

			jsonCipherLambda.put("cipherLambda",
			jsonArrCipherLambda);
			sendToSPU(jsonCipherLambda);


			}
			}
			JSONObject jsonResult = receiveFromSPU();
			BigInteger[] enc_result = new BigInteger[] {
			new BigInteger(jsonResult.getString("res1")),
			new BigInteger(jsonResult.getString("res3")) };

			result[0] = decryption(enc_result);
			if (!r.getCfs()[0].isEmpty()) {
			result[1] = susceptibilityDecryption(enc_result);
			DBconnector_mu.putResult(id_p, r.getId_t(), result[1]);
			} else {
			DBconnector_mu.putResult(id_p, r.getId_t(), result[0]);
			}
			}

			} catch (CryptoException ex) {
			Logger.getLogger(MedUnit.class.getName()).log(Level.SEVERE, null,
			ex);

			} catch (SQLException ex) {
			Logger.getLogger(MedUnit.class.getName()).log(Level.SEVERE, null,
			ex);
			} catch (JSONException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			}
			return result;
			}

			public double susceptibilityDecryption(BigInteger[] cipher)
			throws CryptoException {
			BigInteger[] susc_enc_result = new BigInteger[] { cipher[2], cipher[3] };
			Scheme s = new Scheme(pbk[0], pbk[1], pbk[2], prk);
			double beta0 = -2.5046;
			double logit = beta0 + s.decrypt(susc_enc_result).doubleValue()
			/ (100 * Math.pow(2, l));
			double diseaseSusceptibility = Math.round(10000 * Math.exp(logit)
			/ (1 + Math.exp(logit))) / 100;
			System.out.println("Susceptibility: " + diseaseSusceptibility);
			return diseaseSusceptibility;
			}

			/**
			* Send a RequestPatient to the patient. This request is sent for asking the
			* consent
			*
			* @param rp
			*/
			public void sendToPatient(RequestPatient rp) { // actually this will send to
			// the server and the
			// patient
			// will retrieve it later
			JSONObject jsonRequestPatient = new JSONObject();
			try {
			jsonRequestPatient.put("type", Type.REQUEST_PATIENT);
			jsonRequestPatient.put("rp", rp);
			jsonRequestPatient.put("string", new String("string"));
			jsonRequestPatient.put("nameTest", rp.getNameTest());
			jsonRequestPatient.put("id_r", rp.getId_r());
			jsonRequestPatient.put("id_p", rp.getId_p());
			jsonRequestPatient.put("id_t", rp.getId_t());
			jsonRequestPatient.put("flag", rp.getFlag());
			jsonRequestPatient.put("id_mu", rp.getId_mu());

			} catch (JSONException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			}
			this.sendToSPU(jsonRequestPatient);
			System.out.println("Request Patient " + rp.getId_r() + " sent");
			}

			public User seeProfil(int id) {
			// return the profil of the patient id
			JSONObject json = new JSONObject();
			Patient p = null;
			try {

			json.put("id", id);
			} catch (JSONException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			}
			this.sendToSPU(json);
			// now wait the response
			json = this.receiveFromSPU();
			Type type = null;
			try {
			type = (Type) json.get("type");
			} catch (JSONException e1) {
			// TODO Auto-generated catch block
			e1.printStackTrace();
			}
			switch (type) {
			case PATIENT:
			try {
			p = new Patient(json.getInt("id"), (String) json.get("name"),
			null, null, (String) json.get("firstName"),
			(String) json.get("birth"), null, null);
			} catch (JSONException e) {
			e.printStackTrace();
			}
			break;

			default:

			break;
			}
			return p;

			}

			public void updateRequestPatient() {
			// show if some patients had fullfill the request and consent
			}

			/**
			* Decrypts the encrypted susceptibility computed by the TTP
			*
			* @param N
			* @param G
			* @param H
			* @param X
			* @param cipher
			* @throws CryptoException
			*/
			public double decryption(BigInteger[] cipher) throws CryptoException {

			BigInteger N = pbk[0];
			BigInteger G = pbk[1];
			BigInteger H = pbk[2];

			Scheme scheme = new Scheme(N, G, H, prk);
			long start = System.currentTimeMillis();
			double testResult = scheme.decrypt(cipher)
			.subtract(BigInteger.valueOf(1000000)).doubleValue() / 100;
			long end = System.currentTimeMillis();

			System.out.println("Decryption time = " + (end - start) + " ms");
			return testResult;

			}

			/**
			* Creates the pdf report.
			*
			* @param results
			*
			* @param traits
			*
			* @param group
			*
			* @param IDs_t
			*
			*/
			public void createReport(double[] results, String[] traits, String[] group,
			int[] IDs_t) {
			Writer w = null;
			try {
			String[] predictions = new String[results.length];
			File myFile = new File(Environment.getExternalStorageDirectory()
			.getPath()
			+ "/GenomicPrivacy/PDFReports/SHCS_"
			+ id_p
			+ ".pdf");
			myFile.createNewFile();
			w = new Writer(Environment.getExternalStorageDirectory().getPath()
			+ "/GenomicPrivacy/PDFReports/SHCS_" + id_p + ".pdf");
			for (int i = 0; i < predictions.length; i++) {
			Interpreter interpreter = new Interpreter();
			predictions[i] = interpreter.runInterpretation(IDs_t[i],
			results[i]);
			}

			w.generatePDFreport(predictions, traits, group, id_p);

			} catch (Exception ex) {
			ex.printStackTrace();
			System.out.println("Something went wrong");

			}
			}

			public ArrayList<RequestPatient> checkRequests() {
			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);
			// 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:
			try {
			System.out.println(json.get("newrp").getClass());
			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_t = json2.getInt("id_t");
			int flag = json2.getInt("flag");
			String testName = json2.getString("nameTest");
			newrp.add(new RequestPatient(id_r, id_p, id, id_t,
			testName, flag));
			}
			}
			System.out.println(json.toString());
			} catch (JSONException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			}

			break;

			}
			return newrp;
			}

			/**
			* Comparison protocol.
			*
			* @param cipherD_proxy
			* the cipher d_proxy
			* @return the array list
			* @throws CryptoException
			* the crypto exception
			* @throws SQLException
			* the sQL exception
			*/
			public ArrayList comparisonProtocol(BigInteger[] cipherD_proxy)
			throws CryptoException, SQLException {

			ArrayList results = new ArrayList();
			BigInteger[] publicKey = DBconnector_mu.getPublicKey(id_p);
			// initiate values
			BigInteger n = publicKey[0];
			BigInteger g = publicKey[1];
			BigInteger h = publicKey[2];
			BigInteger nsqr = n.multiply(n);

			// number of bits for the max value of a or b in plaintext
			BigInteger twoPowL = BigInteger.valueOf(2).pow(l);

			DGK_key_generator kg = new DGK_key_generator(k, t, l);
			kg.generateKeys();

			BigInteger[] pk = dgk_pk;
			BigInteger[] sk = dgk_sk;

			DGK_scheme dgk_s = new DGK_scheme(pk, sk, k, t, l);
			dgk_scheme = dgk_s;

			// generate the encryption scheme for homomorphic operations
			Scheme s = new Scheme(n, g, h, prk);

			// decryption of cipherD_proxy
			BigInteger D = s.decrypt(cipherD_proxy);

			// reduction of D in mod 2^L
			BigInteger Dmod = D.mod(twoPowL);

			// encryption of Dmod's bits using the DGK scheme
			ArrayList<BigInteger> cipherDi = new ArrayList<BigInteger>();
			int numBit_Dmod = Dmod.bitLength();
			for (int i = 0; i < numBit_Dmod; i++) {

			BigInteger bitvalue;
			boolean bol = Dmod.testBit(i);
			if (bol)
			bitvalue = BigInteger.ONE;
			else
			bitvalue = BigInteger.ZERO;
			cipherDi.add(dgk_s.encryption(bitvalue));
			}

			// encryption of Dmod
			BigInteger[] cipherDmod = s.encrypt(Dmod);

			results.add(cipherDmod);
			results.add(pk);
			results.add(cipherDi);

			return results;

			}

			/**
			*
			* @param cipherCi
			* @return
			* @throws CryptoException
			*/
			public BigInteger[] computeCipherLamda(ArrayList<BigInteger> cipherCi)
			throws CryptoException, SQLException {

			BigInteger lamda = null;

			ListIterator<BigInteger> iterator = cipherCi.listIterator();
			while (iterator.hasNext()) {
			boolean zero_test = dgk_scheme.decryptionZero(iterator.next());
			System.out.println("c = " + zero_test);
			if (zero_test) {
			lamda = BigInteger.ONE;
			break;
			} else {
			lamda = BigInteger.ZERO;
			}

			}
			// initiate values

			BigInteger[] publicKey = DBconnector_mu.getPublicKey(id_p);
			BigInteger n = publicKey[0];
			BigInteger g = publicKey[1];
			BigInteger h = publicKey[2];
			BigInteger nsqr = n.multiply(n);
			Scheme s = new Scheme(n, g, h, prk);
			System.out.println("lamda = " + lamda);
			BigInteger[] cipherLamda = s.encrypt(lamda);

			return cipherLamda;

			}

			}

genopri-shcs/project/GenomicPrivacy(android)/GenomicPrivacy/src/FrameWork/MedUnit.java89c2e8c655e6mobile_app

MedUnit.javaView Options

genopri-shcs/project/GenomicPrivacy(android)/GenomicPrivacy/src/FrameWork/MedUnit.java
89c2e8c655e6mobile_app

MedUnit.java
View Options