forc 0.3.3

Fuel Orchestrator.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

use fuel_gql_client::client::FuelClient;
use std::process::Stdio;
use tokio::process::{Child, Command};
use tokio::time::{sleep, Duration};

pub async fn start_fuel_core(node_url: &str, client: &FuelClient) -> Result<Child, String> {
    let mut url_parts = node_url.split(':').collect::<Vec<&str>>();
    let port = url_parts.pop().unwrap_or("4000");
    let ip = url_parts.join(":");

    let mut cmd = Command::new("fuel-core");
    cmd.args([format!("--port={}", port), format!("--ip={}", ip)]);
    cmd.stderr(Stdio::piped());

    match cmd.spawn() {
        Ok(child) => {
            if client.health().await.is_ok() {
                return Ok(child);
            }

            for _ in 0..5 {
                sleep(Duration::from_millis(300)).await;
                if client.health().await.is_ok() {
                    return Ok(child);
                }
            }

            Err("Could not start fuel-core".into())
        }
        Err(e) => Err(format!("Failed to spawn: {:?}. Error: {:?}", cmd, e)),
    }
}