From ea47b82d7553012b39f6ab6a836a1832da40ca4e Mon Sep 17 00:00:00 2001 From: Marcin Chrzanowski Date: Fri, 15 Nov 2019 14:04:03 +0100 Subject: Add fetcher skeleton --- .../pl/edu/mimuw/cloudatlas/fetcher/Fetcher.java | 75 ++++++++++++++++++++++ 1 file changed, 75 insertions(+) create mode 100644 src/main/java/pl/edu/mimuw/cloudatlas/fetcher/Fetcher.java (limited to 'src/main/java/pl/edu/mimuw/cloudatlas') diff --git a/src/main/java/pl/edu/mimuw/cloudatlas/fetcher/Fetcher.java b/src/main/java/pl/edu/mimuw/cloudatlas/fetcher/Fetcher.java new file mode 100644 index 0000000..67d7165 --- /dev/null +++ b/src/main/java/pl/edu/mimuw/cloudatlas/fetcher/Fetcher.java @@ -0,0 +1,75 @@ +package pl.edu.mimuw.cloudatlas.fetcher; + +import pl.edu.mimuw.cloudatlas.agent.Api; + +import java.rmi.registry.LocateRegistry; +import java.rmi.registry.Registry; +import java.io.*; +import java.util.ArrayList; +import java.util.List; + +import com.google.gson.Gson; + +public class Fetcher { + +// private static String processAttribs(String jsonAttribs) { +// Serializer serializer = new Serializer(); +// return +// } + + // https://jj09.net/interprocess-communication-python-java/ + private static void fetchData() { + try { + Registry registry = LocateRegistry.getRegistry("localhost"); + Api stub = (Api) registry.lookup("Api"); + System.out.println("Fetcher runs with registry"); // TODO + + String pythonScript = Fetcher.class.getResource("data_fetcher.py").getFile(); + String pythonCmd = "/usr/bin/python3 " + pythonScript; + System.out.println("cmd: " + pythonCmd); + Process p = Runtime.getRuntime().exec(pythonCmd); + BufferedReader bufferRead = new BufferedReader( new InputStreamReader(p.getInputStream())); + BufferedReader errorRead = new BufferedReader( new InputStreamReader(p.getErrorStream())); + + + System.out.println("Gonna read some attribs"); + String jsonAttribs = bufferRead.readLine(); + String serializedAttribs; + + System.out.println("Read some attribs"); + System.out.println(jsonAttribs); + System.out.println("Got some attribs"); + + ArrayList aa = deserializeAttribs(jsonAttribs); + System.out.println(aa); + + // TODO different condition + while(!jsonAttribs.equals("x")) { + System.out.println(jsonAttribs); + System.out.flush(); + serializedAttribs = "1"; + // stub.setAttributeValue(serializedAttribs); + jsonAttribs = bufferRead.readLine(); + } + + bufferRead.close(); + + } catch(IOException e) { + e.printStackTrace(); + } catch (Exception e) { + System.err.println("Fetcher exception:"); + e.printStackTrace(); + } + } + + + public static void main(String[] args) { + fetchData(); + } + + public static ArrayList deserializeAttribs(String serializedAttribs) { + Gson g = new Gson(); + + return g.fromJson(serializedAttribs, ArrayList.class); + } +} -- cgit v1.2.3