Add files via upload

Options.java

@@ -0,0 +1,11 @@
+package net.kloudspace.defichain.jellyfish;
+
+import com.google.gson.Gson;
+
+public class Options {
+
+	public String getAsParameter() {
+		return new Gson().toJson(this);
+	}
+
+}

OptionsArray.java

@@ -0,0 +1,16 @@
+package net.kloudspace.defichain.jellyfish;
+
+public class OptionsArray extends Options {
+
+	Options[] array;
+
+	public void setArray(Options[] options) {this.array = options;}
+
+	@Override
+	public String getAsParameter() {
+		return super.getAsParameter();
+	}
+
+
+
+}

RpcClient.java

@@ -0,0 +1,185 @@
+package net.kloudspace.defichain.jellyfish;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.io.OutputStream;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.nio.charset.StandardCharsets;
+import java.util.Base64;
+
+import org.bitcoinj.core.Base58;
+
+import com.google.gson.JsonObject;
+import com.google.gson.JsonParser;
+
+import net.kloudspace.defichain.jellyfish.apicore.ApiClient;
+import net.kloudspace.defichain.jellyfish.apicore.IRpcRequest;
+import net.kloudspace.defichain.jellyfish.apicore.RpcError;
+import net.kloudspace.defichain.jellyfish.apicore.RpcResponse;
+import net.kloudspace.defichain.jellyfish.apicore.categories.account.AccountController;
+import net.kloudspace.defichain.jellyfish.apicore.categories.blockchain.Blockchain;
+import net.kloudspace.defichain.jellyfish.apicore.categories.governance.GovernanceController;
+import net.kloudspace.defichain.jellyfish.apicore.categories.icxorderbook.ICXOrderBook;
+import net.kloudspace.defichain.jellyfish.apicore.categories.loan.LoanController;
+import net.kloudspace.defichain.jellyfish.apicore.categories.masternode.MasternodeController;
+import net.kloudspace.defichain.jellyfish.apicore.categories.mining.MiningController;
+import net.kloudspace.defichain.jellyfish.apicore.categories.net.NetworkController;
+import net.kloudspace.defichain.jellyfish.apicore.categories.oracle.OracleController;
+import net.kloudspace.defichain.jellyfish.apicore.categories.poolpair.PoolPairController;
+import net.kloudspace.defichain.jellyfish.apicore.categories.rawtx.RawTxController;
+import net.kloudspace.defichain.jellyfish.apicore.categories.server.Server;
+import net.kloudspace.defichain.jellyfish.apicore.categories.token.TokenController;
+import net.kloudspace.defichain.jellyfish.apicore.categories.wallet.WalletController;
+import net.kloudspace.defichain.jellyfish.model.ScriptPubKey;
+
+public class RpcClient extends ApiClient {
+
+	private final String daemonUrl;
+	private final String rpcUsername;
+	private final String rpcPassword;
+	private final Number rpcRequestTimeout;
+
+	public static final String DUMMY_ADDRESS = "dZpek97RbpjTrNNEianYfgkws6xdahpnu9";
+
+	private final AccountController accountController = new AccountController(this);
+	private final Blockchain blockchainController = new Blockchain(this);
+	private final LoanController loanController = new LoanController(this);
+	private final MiningController miningController = new MiningController(this);
+	private final PoolPairController poolpairController = new PoolPairController(this);
+	private final TokenController tokenController = new TokenController(this);
+	private final NetworkController networkController = new NetworkController(this);
+	private final Server serverController = new Server(this);
+	private final GovernanceController governanceController = new GovernanceController(this);
+	private final ICXOrderBook ixcorderbookController = new ICXOrderBook(this);
+	private final MasternodeController masternodeController = new MasternodeController(this);
+	private final OracleController oracleController = new OracleController(this);
+	private final RawTxController rawtx = new RawTxController(this);
+//	private final SPVController spv;
+	private final WalletController wallet = new WalletController(this);
+	public static boolean isLoading = true;
+
+	public RpcClient(String url, String username, String password, Number timeout) {
+		this.daemonUrl = url;
+		this.rpcUsername = username;
+		this.rpcPassword = password;
+		this.rpcRequestTimeout = timeout;
+		System.out.println("Client Constructed");
+
+	}
+
+
+
+	public AccountController getAccountController() {
+		return this.accountController;
+	}
+
+	public Blockchain getBlockchain() {
+		return this.blockchainController;
+	}
+	/**
+	 * Not yet implemented in RPC
+	 * 
+	 * @return The GovernanceApi Controller
+	 */
+	public GovernanceController getGovernanceController() {
+		return this.governanceController;
+	}
+	/**
+	 * Not yet implemented in RPC
+	 * 
+	 * @return The GovernanceApi Controller
+	 */
+	public ICXOrderBook getICXOrderBook() {
+		return this.ixcorderbookController;
+	}
+
+	public LoanController getLoanController() {
+		return this.loanController;
+	}
+
+	public MasternodeController getMasternodeController() {
+		return this.masternodeController;
+	}
+
+	public MiningController getMiningController() {
+		return this.miningController;
+	}
+
+	public NetworkController getNetworkController() {
+		return this.networkController;
+	}
+
+	public OracleController getOracleController() {
+		return this.oracleController;
+	}
+
+	public PoolPairController getPoolController() {
+		return this.poolpairController;
+	}
+
+	public Server getServer() {
+		return this.serverController;
+	}
+
+	public TokenController getTokenController() {
+		return this.tokenController;
+	}
+
+	public WalletController getWalletController() {
+		return this.wallet;
+	}
+
+	public RpcResponse<?> call(final IRpcRequest<?> irr) throws IOException, ApiError {
+		URL url = new URL(daemonUrl);
+
+		HttpURLConnection http = (HttpURLConnection) url.openConnection();
+		http.setRequestMethod("POST");
+		http.setDoOutput(true);
+		http.setRequestProperty("Authorization", "Basic " + encodeAuthToBase64());
+		http.setRequestProperty("Content-Type", "application/json");
+		http.setConnectTimeout((int) rpcRequestTimeout);
+		System.out.println(irr.getParameters().toString());
+		String data = "{\n  \"jsonrpc\":1.0,\n  \"id\":1,\n  \"method\":\"" + irr.getName() + "\",\n  \"params\":"
+				+ irr.getParameters() + "\n}";// TODO:
+		// implement
+		// params
+		System.out.println(data);
+		byte[] out = data.getBytes(StandardCharsets.UTF_8);
+
+		OutputStream stream = http.getOutputStream();
+		stream.write(out);
+
+		System.out.println(http.getResponseCode() + " " + http.getResponseMessage() + " : " + irr.getName());
+		if (http.getResponseCode() != 200)
+			return new RpcResponse<>(new RpcError(http.getResponseCode(), http.getResponseMessage()), -1);
+
+		InputStream is = http.getInputStream();
+		JsonObject obj = JsonParser.parseReader(new InputStreamReader(is)).getAsJsonObject();
+
+		System.out.println(obj.toString());
+
+		is.close();
+		http.disconnect();
+
+		try {
+			return irr.parse(obj);
+		} catch (ApiError e) {
+			return new RpcResponse<>(obj, -2, new RpcError(-2, ""));
+		}
+
+	}
+
+	public String encodeAuthToBase64() {
+		return Base64.getEncoder().encodeToString((rpcUsername + ":" + rpcPassword).getBytes());
+	}
+
+	@SuppressWarnings("serial")
+	public static class ApiError extends Exception {
+
+		public ApiError(String message) {
+			super(message);
+		}
+	}
+}