Modify SocketProducer to generate key rather than accept one.

DataINCITE · Sep 16, 2022 · c6c4af8 · c6c4af8
1 parent b857ae4
commit c6c4af8
Show file tree

Hide file tree

Showing 5 changed files with 8 additions and 16 deletions.
diff --git a/DeFi-Data-Engine/DeFi Data Engine/src/main/java/org/out/destinations/SocketDestination.java b/DeFi-Data-Engine/DeFi Data Engine/src/main/java/org/out/destinations/SocketDestination.java
@@ -19,7 +19,7 @@ public SocketDestination(String key, DataOutputStream out) {
 
 	public final synchronized boolean send(Packet packet) {
 		try {
-			out.writeUTF(packet.getData());
+			out.write(packet.getData().getBytes());
 		} catch (JSONException | IOException e) {
 			e.printStackTrace();
 			return false;

diff --git a/DeFi-Data-Engine/DeFi Data Engine/src/main/java/org/out/handler/OutputHandler.java b/DeFi-Data-Engine/DeFi Data Engine/src/main/java/org/out/handler/OutputHandler.java
@@ -36,18 +36,12 @@ public Response processSTRT(Packet packet) {
 	}
 
 	public Response processEDAT(Packet packet) {
-<<<<<<< HEAD
-
-		//manager.send();
-		return ResponseFactory.response0();
-=======
 		if(!manager.containsDestination(packet.getSubData()))
 			return ResponseFactory.response471(packet.getSubData());
 
 		if(!manager.send(packet.getSubData(), packet))
 			return ResponseFactory.response472(packet.getSubData());
 
 		return ResponseFactory.response200("");
->>>>>>> branch 'main' of https://github.rpi.edu/DataINCITE/IDEA-DeFi-CRAFT
 	}
 }
diff --git a/DeFi-Data-Engine/DeFi Data Engine/src/main/java/org/out/handler/OutputManager.java b/DeFi-Data-Engine/DeFi Data Engine/src/main/java/org/out/handler/OutputManager.java
@@ -121,7 +121,7 @@ protected final Response send(String tag, String sub_tag, String data, String su
 
 	public final synchronized void add(OutputDestination destination) {
 		destinations.put(destination.getKey(), destination);
-		destination.send(Packet.packet(handler, "", "", "Connected: " + destination.getKey()));
+		//destination.send(Packet.packet(handler, "", "", "Connected: " + destination.getKey()));
 	}
 
 	public final synchronized void remove(String key) {

diff --git a/DeFi-Data-Engine/DeFi Data Engine/src/main/java/org/out/socket/SocketManager.java b/DeFi-Data-Engine/DeFi Data Engine/src/main/java/org/out/socket/SocketManager.java
@@ -5,8 +5,10 @@
 import java.io.IOException;
 import java.net.ServerSocket;
 import java.net.Socket;
+import java.nio.charset.StandardCharsets;
 import java.util.HashMap;
 import java.util.HashSet;
+import java.util.UUID;
 
 public class SocketManager {
 
@@ -47,7 +49,9 @@ public synchronized static String accept(int port) {
 
 			// validate new connection:
 			DataInputStream in = new DataInputStream(connection.getInputStream());
-			String key = in.readUTF();
+			DataOutputStream out = new DataOutputStream(connection.getOutputStream());
+			String key = UUID.randomUUID().toString();
+			out.write(key.getBytes());
 
 			if(connections.containsKey(key))
 				connections.get(key).close();
@@ -78,6 +82,7 @@ public synchronized static boolean accept(int port, String required_key) {
 			Socket connection = servers.get(port).accept();
 			// validate new connection:
 			DataInputStream in = new DataInputStream(connection.getInputStream());
+
 			String key = in.readUTF();
 
 			if(!required_key.equals(key)) {

diff --git a/DeFi-Data-Engine/Rest Application/src/main/java/org/rest/application/Endpoint.java b/DeFi-Data-Engine/Rest Application/src/main/java/org/rest/application/Endpoint.java
@@ -34,16 +34,9 @@ public class Endpoint {
 		System.exit(1);
 	}
 }
-
-<<<<<<< HEAD
-	// sample testing url: http://localhost:8080/defi/v1/rest/json?key=test&protocol=source_exists&data=amber_data
-	@GetMapping(path="/defi/v1/rest/json")
-	public String getRest(@RequestParam String key, @RequestParam String protocol, @RequestParam String data) throws InterruptedException {
-=======
 	// sample testing url: http://localhost:8080/defi/v1/rest/live?key=TEST-KEY&protocol=request&data=key,external
 	@GetMapping(path="/defi/v1/rest/live")
 	public String getRestLive(@RequestParam String key, @RequestParam String protocol, @RequestParam String data) throws InterruptedException {
->>>>>>> branch 'main' of https://github.rpi.edu/DataINCITE/IDEA-DeFi-CRAFT
 		String response = request(key, protocol, data);
 		if(response == null)
 			return new JSONObject()