mirror of
https://github.com/darkrenaissance/darkfi.git
synced 2026-04-28 03:00:18 -04:00
bin: upgrade send_request rpc function across bins
This commit is contained in:
@@ -36,7 +36,7 @@ impl Client {
|
||||
|
||||
async fn request(&self, r: jsonrpc::JsonRequest) -> Result<Value> {
|
||||
let reply: JsonResult =
|
||||
match jsonrpc::send_request(&Url::parse(&self.url)?, json!(r), None).await {
|
||||
match jsonrpc::send_request(&Url::parse(&self.url)?, json!(r)).await {
|
||||
Ok(v) => v,
|
||||
Err(e) => return Err(e),
|
||||
};
|
||||
|
||||
@@ -45,7 +45,7 @@ impl DnetView {
|
||||
}
|
||||
|
||||
async fn request(&self, r: jsonrpc::JsonRequest) -> Result<Value> {
|
||||
let reply: JsonResult = match jsonrpc::send_request(&self.url, json!(r), None).await {
|
||||
let reply: JsonResult = match jsonrpc::send_request(&self.url, json!(r)).await {
|
||||
Ok(v) => v,
|
||||
Err(e) => return Err(e),
|
||||
};
|
||||
|
||||
@@ -103,7 +103,7 @@ impl Drk {
|
||||
let ep =
|
||||
if endpoint.is_some() { endpoint.unwrap().clone() } else { self.rpc_endpoint.clone() };
|
||||
|
||||
let reply = match jsonrpc::send_request(&ep, json!(r), None).await {
|
||||
let reply = match jsonrpc::send_request(&ep, json!(r)).await {
|
||||
Ok(v) => v,
|
||||
Err(e) => return Err(e),
|
||||
};
|
||||
|
||||
@@ -134,7 +134,7 @@ async fn realmain(settings: Args, executor: Arc<Executor<'_>>) -> Result<()> {
|
||||
let datastore_path = expand_path(&settings.datastore)?;
|
||||
let net_settings = settings.net;
|
||||
let datastore_raft = datastore_path.join("ircd.db");
|
||||
let mut raft = Raft::<Privmsg>::new(net_settings.inbound, datastore_raft)?;
|
||||
let mut raft = Raft::<Privmsg>::new(net_settings.inbound.clone(), datastore_raft)?;
|
||||
let raft_sender = raft.get_broadcast();
|
||||
let raft_receiver = raft.get_commits();
|
||||
|
||||
|
||||
@@ -8,7 +8,7 @@ use darkfi::{
|
||||
};
|
||||
|
||||
pub async fn request(r: jsonrpc::JsonRequest, url: String) -> Result<Value> {
|
||||
let reply: JsonResult = match jsonrpc::send_request(&Url::parse(&url)?, json!(r), None).await {
|
||||
let reply: JsonResult = match jsonrpc::send_request(&Url::parse(&url)?, json!(r)).await {
|
||||
Ok(v) => v,
|
||||
Err(e) => return Err(e),
|
||||
};
|
||||
|
||||
Reference in New Issue
Block a user