From 6c3d50a6f48dd048efea863fb7aebb29c994eb5f Mon Sep 17 00:00:00 2001
From: rachel-rose <ihateface@autistici.org>
Date: Tue, 18 May 2021 09:05:55 +0200
Subject: [PATCH] removed redundant python script and moved option code to a
 module

---
 src/rpc/__init__.py   |  2 -
 src/rpc/jsonclient.py | 53 --------------------------
 src/rpc/options.rs    | 89 +++++++++++++++++++++++++++++++++++++++++++
 3 files changed, 89 insertions(+), 55 deletions(-)
 delete mode 100644 src/rpc/__init__.py
 delete mode 100644 src/rpc/jsonclient.py
 create mode 100644 src/rpc/options.rs

diff --git a/src/rpc/__init__.py b/src/rpc/__init__.py
deleted file mode 100644
index 2fbf57db8..000000000
--- a/src/rpc/__init__.py
+++ /dev/null
@@ -1,2 +0,0 @@
-from rpc import jsonclient
-from .jsonclient import RpcClient
diff --git a/src/rpc/jsonclient.py b/src/rpc/jsonclient.py
deleted file mode 100644
index cb1775181..000000000
--- a/src/rpc/jsonclient.py
+++ /dev/null
@@ -1,53 +0,0 @@
-import requests
-
-# TODO: generate random ID (4 byte unsigned int) (rand range 0 - max size uint32)
-# TODO: make functions async
-# TODO: parse json replies into something more legible
-
-class RpcClient:
-    def __init__(self):
-        self.url = "http://localhost:8000/"
-        self.payload = {
-            "method": [],
-            "params": [],
-            "jsonrpc": [],
-            "id": [],
-        }
-
-    def key_gen(self, payload):
-        payload['method'] = "key_gen"
-        payload['jsonrpc'] = "2.0"
-        payload['id'] = "0"
-        key = self.__request(payload)
-        print(key)
-
-    def get_info(self, payload):
-        payload['method'] = "get_info"
-        payload['jsonrpc'] = "2.0"
-        payload['id'] = "0"
-        info = self.__request(payload)
-        print(info)
-
-    def stop(self, payload):
-        payload['method'] = "stop"
-        payload['jsonrpc'] = "2.0"
-        payload['id'] = "0"
-        stop = self.__request(payload)
-        print(stop)
-
-    def say_hello(self, payload):
-        payload['method'] = "say_hello"
-        payload['jsonrpc'] = "2.0"
-        payload['id'] = "0"
-        hello = self.__request(payload)
-        print(hello)
-
-    def __request(self, payload):
-        response = requests.post(self.url, json=payload).json()
-        print(response)
-        assert response["jsonrpc"]
-
-    
-if __name__ == "__main__":
-    client = RpcClient()
-
diff --git a/src/rpc/options.rs b/src/rpc/options.rs
new file mode 100644
index 000000000..76f7ce466
--- /dev/null
+++ b/src/rpc/options.rs
@@ -0,0 +1,89 @@
+#[macro_use]
+use std::net::SocketAddr;
+use crate::{net, Error, Result};
+use async_executor::Executor;
+use async_native_tls::TlsAcceptor;
+use async_std::sync::Mutex;
+use easy_parallel::Parallel;
+use http_types::{Request, Response, StatusCode};
+use log::*;
+use smol::Async;
+use std::net::TcpListener;
+use std::sync::Arc;
+
+pub struct ProgramOptions {
+    pub network_settings: net::Settings,
+    pub log_path: Box<std::path::PathBuf>,
+    pub rpc_port: u16,
+}
+
+impl ProgramOptions {
+    pub fn load() -> Result<ProgramOptions> {
+        let app = clap_app!(dfi =>
+            (version: "0.1.0")
+            (author: "Amir Taaki <amir@dyne.org>")
+            (about: "Dark node")
+            (@arg ACCEPT: -a --accept +takes_value "Accept add//ress")
+            (@arg SEED_NODES: -s --seeds ... "Seed nodes")
+            (@arg CONNECTS: -c --connect ... "Manual connections")
+            (@arg CONNECT_SLOTS: --slots +takes_value "Connection slots")
+            (@arg LOG_PATH: --log +takes_value "Logfile path")
+            (@arg RPC_PORT: -r --rpc +takes_value "RPC port")
+        )
+        .get_matches();
+
+        let accept_addr = if let Some(accept_addr) = app.value_of("ACCEPT") {
+            Some(accept_addr.parse()?)
+        } else {
+            None
+        };
+
+        let mut seed_addrs: Vec<SocketAddr> = vec![];
+        if let Some(seeds) = app.values_of("SEED_NODES") {
+            for seed in seeds {
+                seed_addrs.push(seed.parse()?);
+            }
+        }
+
+        let mut manual_connects: Vec<SocketAddr> = vec![];
+        if let Some(connections) = app.values_of("CONNECTS") {
+            for connect in connections {
+                manual_connects.push(connect.parse()?);
+            }
+        }
+
+        let connection_slots = if let Some(connection_slots) = app.value_of("CONNECT_SLOTS") {
+            connection_slots.parse()?
+        } else {
+            0
+        };
+
+        let log_path = Box::new(
+            if let Some(log_path) = app.value_of("LOG_PATH") {
+                std::path::Path::new(log_path)
+            } else {
+                std::path::Path::new("/tmp/darkfid.log")
+            }
+            .to_path_buf(),
+        );
+
+        let rpc_port = if let Some(rpc_port) = app.value_of("RPC_PORT") {
+            rpc_port.parse()?
+        } else {
+            8000
+        };
+
+        Ok(ProgramOptions {
+            network_settings: net::Settings {
+                inbound: accept_addr,
+                outbound_connections: connection_slots,
+                external_addr: accept_addr,
+                peers: manual_connects,
+                seeds: seed_addrs,
+                ..Default::default()
+            },
+            log_path,
+            rpc_port,
+        })
+    }
+}