feat(toolkit): implement timeout parameter

Author: guidiaz

toolkit/src/cli/arguments.rs

@@ -29,6 +29,11 @@ pub(crate) struct TryDataRequest {
         help = "Whether to return the full execution trace, including partial results after each operator."
     )]
     pub full_trace: Option<bool>,
+    #[structopt(
+        long, 
+        help = "Maximum amount of seconds to wait for a data source to respond."
+    )]
+    pub timeout: Option<u64>,
 }
 
 /// Easy derivation of `DecodeDataRequest` from `TryDataRequest`

toolkit/src/cli/data_requests.rs

@@ -1,6 +1,6 @@
 //! Implementations of CLI methods related to Witnet data requests.
 
-use std::{fs::File, io::Read, path::Path};
+use std::{fs::File, io::Read, path::Path, time::Duration};
 
 use regex::Regex;
 
@@ -43,9 +43,13 @@ pub(crate) fn try_from_args(
     args: arguments::TryDataRequest,
 ) -> Result<RADRequestExecutionReport, Error> {
     let full_trace = args.full_trace.unwrap_or(true);
+    let timeout: Option<Duration> = if let Some(timeout) = args.timeout {
+        Some(Duration::from_secs(timeout))
+    } else {
+        None
+    };
     let request = decode_from_args(args.into())?.data_request;
-
-    witnet_toolkit::data_requests::try_data_request(&request, full_trace)
+    witnet_toolkit::data_requests::try_data_request(&request, full_trace, timeout)
 }
 
 /// Extract the Protocol Buffers representation of a data request from a Solidity smart contract

toolkit/src/data_requests.rs

@@ -1,4 +1,6 @@
 //! Functions providing convenient utilities for working with Witnet data requests.
+use std::time::Duration;
+
 use witnet_data_structures::{
     chain::{DataRequestOutput, RADRequest},
     proto::ProtobufConvert,
@@ -46,13 +48,14 @@ pub fn decode_rad_from_pb_bytes(pb_bytes: &[u8]) -> Result<DataRequestOutput, Er
 pub fn try_data_request(
     request: &RADRequest,
     full_trace: bool,
+    timeout: Option<Duration>,
 ) -> Result<RADRequestExecutionReport, Error> {
     let settings = if full_trace {
         RadonScriptExecutionSettings::enable_all()
     } else {
         RadonScriptExecutionSettings::disable_all()
     };
-    let report = witnet_rad::try_data_request(request, settings, None, None, false);
+    let report = witnet_rad::try_data_request(request, settings, None, None, false, timeout);
 
     Ok(report)
 }