diff --git a/DeFi-Data-Engine/Testing Environment/.classpath b/DeFi-Data-Engine/Testing Environment/.classpath deleted file mode 100644 index 58cbceb6..00000000 --- a/DeFi-Data-Engine/Testing Environment/.classpath +++ /dev/null @@ -1,36 +0,0 @@ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - diff --git a/DeFi-Data-Engine/Testing Environment/.gitignore b/DeFi-Data-Engine/Testing Environment/.gitignore deleted file mode 100644 index 09e3bc9b..00000000 --- a/DeFi-Data-Engine/Testing Environment/.gitignore +++ /dev/null @@ -1,2 +0,0 @@ -/bin/ -/target/ diff --git a/DeFi-Data-Engine/Testing Environment/.project b/DeFi-Data-Engine/Testing Environment/.project deleted file mode 100644 index eb3c9cb3..00000000 --- a/DeFi-Data-Engine/Testing Environment/.project +++ /dev/null @@ -1,23 +0,0 @@ - - - Testing-Environment - - - - - - org.eclipse.jdt.core.javabuilder - - - - - org.eclipse.m2e.core.maven2Builder - - - - - - org.eclipse.m2e.core.maven2Nature - org.eclipse.jdt.core.javanature - - diff --git a/DeFi-Data-Engine/Testing Environment/.settings/org.eclipse.jdt.apt.core.prefs b/DeFi-Data-Engine/Testing Environment/.settings/org.eclipse.jdt.apt.core.prefs deleted file mode 100644 index d4313d4b..00000000 --- a/DeFi-Data-Engine/Testing Environment/.settings/org.eclipse.jdt.apt.core.prefs +++ /dev/null @@ -1,2 +0,0 @@ -eclipse.preferences.version=1 -org.eclipse.jdt.apt.aptEnabled=false diff --git a/DeFi-Data-Engine/Testing Environment/.settings/org.eclipse.jdt.core.prefs b/DeFi-Data-Engine/Testing Environment/.settings/org.eclipse.jdt.core.prefs deleted file mode 100644 index b2ef4d6e..00000000 --- a/DeFi-Data-Engine/Testing Environment/.settings/org.eclipse.jdt.core.prefs +++ /dev/null @@ -1,16 +0,0 @@ -eclipse.preferences.version=1 -org.eclipse.jdt.core.compiler.codegen.inlineJsrBytecode=enabled -org.eclipse.jdt.core.compiler.codegen.targetPlatform=17 -org.eclipse.jdt.core.compiler.codegen.unusedLocal=preserve -org.eclipse.jdt.core.compiler.compliance=17 -org.eclipse.jdt.core.compiler.debug.lineNumber=generate -org.eclipse.jdt.core.compiler.debug.localVariable=generate -org.eclipse.jdt.core.compiler.debug.sourceFile=generate -org.eclipse.jdt.core.compiler.problem.assertIdentifier=error -org.eclipse.jdt.core.compiler.problem.enablePreviewFeatures=disabled -org.eclipse.jdt.core.compiler.problem.enumIdentifier=error -org.eclipse.jdt.core.compiler.problem.forbiddenReference=warning -org.eclipse.jdt.core.compiler.problem.reportPreviewFeatures=warning -org.eclipse.jdt.core.compiler.processAnnotations=disabled -org.eclipse.jdt.core.compiler.release=enabled -org.eclipse.jdt.core.compiler.source=17 diff --git a/DeFi-Data-Engine/Testing Environment/.settings/org.eclipse.m2e.core.prefs b/DeFi-Data-Engine/Testing Environment/.settings/org.eclipse.m2e.core.prefs deleted file mode 100644 index f897a7f1..00000000 --- a/DeFi-Data-Engine/Testing Environment/.settings/org.eclipse.m2e.core.prefs +++ /dev/null @@ -1,4 +0,0 @@ -activeProfiles= -eclipse.preferences.version=1 -resolveWorkspaceProjects=true -version=1 diff --git a/DeFi-Data-Engine/Testing Environment/Terminal Kafka Startup Commands WSL b/DeFi-Data-Engine/Testing Environment/Terminal Kafka Startup Commands WSL deleted file mode 100644 index fe04bfdb..00000000 --- a/DeFi-Data-Engine/Testing Environment/Terminal Kafka Startup Commands WSL +++ /dev/null @@ -1,10 +0,0 @@ -WSL: -bin/zookeeper-server-start.sh config/zookeeper.properties -bin/kafka-server-start.sh config/server.properties -bin/kafka-topics.sh --create --topic restapi-engine-consumer-reserved --bootstrap-server localhost:9092 -bin/kafka-console-consumer.sh --topic restapi-engine-consumer-reserved --bootstrap-server localhost:9092 - -CMD: (in C:/kafka/) -.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties -.\bin\windows\kafka-server-start.bat .\config\server.properties -.\bin\windows\kafka-console-consumer.bat --topic restapi-reserved --bootstrap-server localhost:9092 \ No newline at end of file diff --git a/DeFi-Data-Engine/Testing Environment/pom.xml b/DeFi-Data-Engine/Testing Environment/pom.xml deleted file mode 100644 index 16770339..00000000 --- a/DeFi-Data-Engine/Testing Environment/pom.xml +++ /dev/null @@ -1,67 +0,0 @@ - - 4.0.0 - TestingEnvironment - TestingEnvironment - 0.0.1-SNAPSHOT - - - org.apache.kafka - kafka-clients - 3.2.1 - - - org.apache.logging.log4j - log4j-api - 2.18.0 - - - org.slf4j - slf4j-simple - 1.7.36 - test - - - com.fasterxml.jackson.core - jackson-databind - 2.12.0 - - - org.scala-lang - scala-library - 2.13.8 - - - javax.jms - javax.jms-api - 2.0.1 - - - org.springframework.kafka - spring-kafka - 2.9.0 - - - org.json - json - 20220320 - - - com.squareup.okhttp3 - okhttp - 4.2.0 - - - - - src - - - maven-compiler-plugin - 3.8.1 - - 17 - - - - - \ No newline at end of file diff --git a/DeFi-Data-Engine/Testing Environment/src/test/connection/socket/LocalTest.java b/DeFi-Data-Engine/Testing Environment/src/test/connection/socket/LocalTest.java deleted file mode 100644 index 4e766a85..00000000 --- a/DeFi-Data-Engine/Testing Environment/src/test/connection/socket/LocalTest.java +++ /dev/null @@ -1,115 +0,0 @@ -package test.connection.socket; - -import java.io.BufferedReader; -import java.io.DataOutputStream; -import java.io.IOException; -import java.io.InputStreamReader; -import java.net.HttpURLConnection; -import java.net.Socket; -import java.net.URL; -import java.net.UnknownHostException; - -import javax.net.SocketFactory; - -import org.json.JSONObject; - -public class LocalTest { - - //private static final String host = "localhost"; - private static final String host = "localhost"; - - public static void main(String[] args) throws UnknownHostException, IOException { - final Socket socket = SocketFactory.getDefault().createSocket(host, 61200); - final BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream())); - final DataOutputStream out = new DataOutputStream(socket.getOutputStream()); - - String destination = readLine(in); - - String init = request(String.format("http://%s:8080/defi/v1/rest/initialize?" - + "source=amber_data&" - + "auth_data=key,UAK7ed69235426c360be22bfc2bde1809b6", - host)); - System.out.println(init); - JSONObject json_init = new JSONObject(init); - String key = json_init.getString("data"); - - out.writeBytes(String.format( - "SRC&&&RQST&&&" - + "destination&&&%s&&&" - + "key&&&%s&&&" - + "start_date&&&2022-08-01&&&" - + "end_date&&&2022-09-01&&&" - + "query&&&blockchain-addresses-dated&&&" - + "request&&&blockchain-addresses-dated\n", - destination, - key)); - - while(true) { - System.out.println(readLine(in)); - } - -// String rqst_protocol_dated = String.format("http://%s:8080/defi/v1/rest/request_dated?" -// + "destination=%s&" -// + "key=%s&" -// + "request=request,aave-protocol-dated&" -// + "query=aave-protocol-dated&" -// + "start_date=%s&" -// + "end_date=%s", -// host, -// destination, -// key, -// "2022-08-01", -// "2022-08-02"); -// -// String rqst_asset_dated = String.format("http://%s:8080/defi/v1/rest/request_dated?" -// + "destination=%s&" -// + "key=%s&" -// + "request=request,aave-protocol-dated&" -// + "query=aave-protocol-dated&" -// + "start_date=%s&" -// + "end_date=%s", -// host, -// destination, -// key, -// "2022-08-01", -// "2022-08-02"); -// -// String rqst = request(rqst_asset_dated); -// System.out.println(rqst); - } - - public static String request(String str) throws IOException { - System.out.println(str); - URL obj = new URL(str); - HttpURLConnection con = (HttpURLConnection) obj.openConnection(); - con.setRequestMethod("GET"); - int responseCode = con.getResponseCode(); - if (responseCode == HttpURLConnection.HTTP_OK) { // success - BufferedReader in = new BufferedReader(new InputStreamReader( - con.getInputStream())); - String inputLine; - StringBuffer response = new StringBuffer(); - - while ((inputLine = in.readLine()) != null) { - response.append(inputLine); - } - in.close(); - - return response.toString(); - } else { - System.err.println(String.format("Request Failure code <%d> url <%s>\nmsg <%s>", responseCode, obj.toString(), con.toString())); - System.exit(1); - } - return ""; - } - - public static final String readLine(BufferedReader in) throws IOException { - StringBuilder out = new StringBuilder(); - char c = 0; - while((c = (char)in.read()) != 10) { - out.append(c); - } - - return out.toString(); - } -} \ No newline at end of file diff --git a/DeFi-Data-Engine/Testing Environment/src/test/connection/socket/ServerTest.java b/DeFi-Data-Engine/Testing Environment/src/test/connection/socket/ServerTest.java deleted file mode 100644 index 5e98e5e7..00000000 --- a/DeFi-Data-Engine/Testing Environment/src/test/connection/socket/ServerTest.java +++ /dev/null @@ -1,73 +0,0 @@ -package test.connection.socket; - -import java.io.BufferedReader; -import java.io.DataInputStream; -import java.io.IOException; -import java.io.InputStreamReader; -import java.net.HttpURLConnection; -import java.net.Socket; -import java.net.URL; -import java.net.UnknownHostException; - -import javax.net.SocketFactory; - -public class ServerTest { - - public static void main(String[] args) throws UnknownHostException, IOException { - final Socket socket = SocketFactory.getDefault().createSocket("defi-de.idea.rpi.edu", 61200); - final DataInputStream in = new DataInputStream(socket.getInputStream()); - - String key = readLine(in); - System.out.println(key); - - Thread thread = new Thread() { - public void run() { - try { - while(true) { - System.out.println(readLine(in)); - } - } catch(Exception e) { - e.printStackTrace(); - System.exit(1); - } - } - }; - thread.start(); - System.out.println("Requesting"); - String sample = request("http://defi-de.idea.rpi.edu:8080/defi/v1/rest/source_exists?source=amber_data"); - System.out.println(sample); - } - - public static String request(String str) throws IOException { - URL obj = new URL(str); - HttpURLConnection con = (HttpURLConnection) obj.openConnection(); - con.setRequestMethod("GET"); - int responseCode = con.getResponseCode(); - if (responseCode == HttpURLConnection.HTTP_OK) { // success - BufferedReader in = new BufferedReader(new InputStreamReader( - con.getInputStream())); - String inputLine; - StringBuffer response = new StringBuffer(); - - while ((inputLine = in.readLine()) != null) { - response.append(inputLine); - } - in.close(); - - return response.toString(); - } else { - System.err.println(String.format("Request Failure code <%d> url <%s>\nmsg <%s>", responseCode, obj.toString(), con.toString())); - System.exit(1); - } - return ""; - } - - public static final String readLine(DataInputStream in) throws IOException { - StringBuilder out = new StringBuilder(); - char c = 0; - while((c = (char)in.read()) != 10) - out.append(c); - - return out.toString(); - } -} \ No newline at end of file diff --git a/DeFi-Data-Engine/Testing Environment/src/test/misc/Testing1.java b/DeFi-Data-Engine/Testing Environment/src/test/misc/Testing1.java deleted file mode 100644 index 2823b092..00000000 --- a/DeFi-Data-Engine/Testing Environment/src/test/misc/Testing1.java +++ /dev/null @@ -1,75 +0,0 @@ -package test.misc; - -import java.io.IOException; - -import org.json.JSONArray; -import org.json.JSONObject; - -import okhttp3.OkHttpClient; -import okhttp3.Request; - -public class Testing1 { - - private static final int request_size = 999; - - public static void main(String args[]) - { - String url = String.format("https://web3api.io/api/v2/addresses?startDate=%s&endDate=%s", - "2022-09-01T01:00:00", - "2022-09-02T01:00:00"); - - Object[] obj = recursiveCall(url, 0); - if(!(boolean)obj[0]) - System.out.println(obj[1]); - System.out.println("Exit"); - System.exit(0); - } - - public static Object[] recursiveCall(String base_url, int page) { - System.out.println(page); - OkHttpClient client = new OkHttpClient(); - - String url = base_url + "&page=" + page; - - Request request = new Request.Builder() - .url(url + "&size=" + request_size) - .get() - .addHeader("x-amberdata-blockchain-id", "ethereum-mainnet") - .addHeader("accept", "application/json") - .addHeader("x-api-key", "UAK7ed69235426c360be22bfc2bde1809b6") - .build(); - - okhttp3.Response response; - try { - response = client.newCall(request).execute(); - JSONObject json = new JSONObject(response.body().string()); - - if(json.toString().equals("") || !json.has("description")) - return new Object[] {false, "JSON Object returned empty or invalid contents."}; - - if(!response.isSuccessful() || json.getInt("status") != 200 - || !json.getString("description").equals("Successful request")) { - System.out.println(json.getString("message")); - return new Object[]{false, json.getString("description")}; - } - - if(!json.has("payload") || !json.getJSONObject("payload").has("records")) - return new Object[] {false, "Malformed Aave packet"}; - - JSONObject payload = json.getJSONObject("payload"); - JSONArray arr = payload.getJSONArray("records"); -// for(int i = 0; i < arr.length(); i++) { -// System.out.println(arr.getJSONObject(i).getJSONObject("hash").getString("address")); -// } - - if(arr.length() >= request_size) { - return recursiveCall(base_url, page + 1); - } else { - return new Object[] {true, ""}; - } - } catch (IOException e) { - e.printStackTrace(); - return new Object[] {false, "Exception."}; - } - } -}