Networking, initial attempt

Cargo.toml

@@ -1,23 +1,31 @@
 [package]
 name = "casper-node"
 version = "0.1.0"
-authors = ["Marc Brinkmann <marc@casperlabs.io>",
-           "Fraser Hutchison <fraser@casperlabs.io>"]
+authors = ["Marc Brinkmann <marc@casperlabs.io>", "Fraser Hutchison <fraser@casperlabs.io>"]
 edition = "2018"
-description = "The CasperLabs blockchain node server"
+description = "The CasperLabs blockchain node"
 publish = false  # Prevent accidental `cargo publish` for now.
 license-file = "LICENSE"
 
 [dependencies]
 anyhow = "1.0.28"
-async-trait = "0.1.31"
+displaydoc = "0.1.6"
 either = "1.5.3"
 enum-iterator = "0.6.0"
 futures = "0.3.5"
+hex_fmt = "0.3.0"
+maplit = "1.0.2"
+openssl = "0.10.29"
+rmp-serde = "0.14.3"
 serde = { version = "1.0.110", features = ["derive"] }
+serde-big-array = "0.3.0"
 smallvec = "1.4.0"
 structopt = "0.3.14"
-tokio = { version = "0.2.20", features = ["macros", "rt-threaded", "sync"] }
+thiserror = "1.0.18"
+tokio = { version = "0.2.20", features = ["macros", "rt-threaded", "sync", "tcp"] }
+tokio-openssl = "0.4.0"
+tokio-serde = { version = "0.6.1", features = ["messagepack"] }
+tokio-util = { version = "0.3.1", features = ["codec"] }
 toml = "0.5.6"
 tracing = "0.1.14"
 tracing-subscriber = "0.2.5"

README.md

@@ -1,25 +1,21 @@
-# CasperLabs node
+# casper-node
 
-The is the core application for the CasperLabs blockchain.
-
-## Building
-
-To compile this application, simply run `cargo build` on a recent stable Rust (`>= 1.43.1`) version.
+This is the core application for the CasperLabs blockchain.
 
 ## Running a validator node
 
-Launching a validator node with the default configuration is done by simply launching the application:
+To run a validator node with the default configuration:
 
 ```
-casper-node validator
+cargo run --release -- validator
 ```
 
 It is very likely that the configuration requires editing though, so typically one will want to generate a configuration file first, edit it and then launch:
 
 ```
-casper-node generate-config > mynode.toml
+cargo run --release -- generate-config > mynode.toml
 # ... edit mynode.toml
-casper-node validator -c mynode.toml
+cargo run --release -- validator --config=mynode.toml
 ```
 
 ## Development
@@ -30,4 +26,4 @@ A good starting point is to build the documentation and read it in your browser:
 cargo doc --no-deps --open
 ```
 
-When generating a configuration file, it is usually helpful to set the log-level to `DEBUG` during development.
+When generating a configuration file, it is usually helpful to set the log-level to `DEBUG` during development.

src/cli.rs

@@ -1,49 +1,87 @@
 //! Command-line option parsing.
 //!
-//! Most configuration is done through the configuration, which is the only required command-line
-//! argument. However some configuration values can be overwritten for convenience's sake.
-use std::{io, io::Write, path};
+//! Most configuration is done via config files (see [`config`](../config/index.html) for details).
+
+use std::{io, io::Write, path::PathBuf};
+
+use anyhow::bail;
 use structopt::StructOpt;
+use tracing::Level;
 
-use crate::{config, reactor};
+use crate::{
+    config,
+    reactor::{self, validator::Reactor},
+    tls,
+};
 
 // Note: The docstring on `Cli` is the help shown when calling the binary with `--help`.
 #[derive(Debug, StructOpt)]
 /// CasperLabs blockchain node.
 pub enum Cli {
+    /// Generate a self-signed node certificate.
+    GenerateCert {
+        /// Output path base of the certificate. The certificate will be stored as
+        /// `output.crt.pem`, while the key will be stored as `output.key.pem`.
+        output: PathBuf,
+    },
     /// Generate a configuration file from defaults and dump it to stdout.
     GenerateConfig {},
+
     /// Run the validator node.
     ///
     /// Loads the configuration values from the given configuration file or uses defaults if not
     /// given, then launches the reactor.
     Validator {
         #[structopt(short, long, env)]
         /// Path to configuration file.
-        config: Option<path::PathBuf>,
+        config: Option<PathBuf>,
+
+        /// Override log-level, forcing debug output.
+        #[structopt(short, long)]
+        debug: bool,
     },
 }
 
 impl Cli {
-    /// Execute selected CLI command.
+    /// Executes selected CLI command.
     pub async fn run(self) -> anyhow::Result<()> {
         match self {
+            Cli::GenerateCert { output } => {
+                if output.file_name().is_none() {
+                    bail!("not a valid output path");
+                }
+
+                let mut cert_path = output.clone();
+                cert_path.set_extension("crt.pem");
+
+                let mut key_path = output;
+                key_path.set_extension("key.pem");
+
+                let (cert, key) = tls::generate_node_cert()?;
+
+                tls::save_cert(&cert, cert_path)?;
+                tls::save_private_key(&key, key_path)?;
+
+                Ok(())
+            }
             Cli::GenerateConfig {} => {
                 let cfg_str = config::to_string(&Default::default())?;
                 io::stdout().write_all(cfg_str.as_bytes())?;
 
                 Ok(())
             }
-            Cli::Validator { config } => {
+            Cli::Validator { config, debug } => {
                 // We load the specified config, if any, otherwise use defaults.
-                let cfg = config
+                let mut cfg = config
                     .map(config::load_from_file)
                     .transpose()?
                     .unwrap_or_default();
-
+                if debug {
+                    cfg.log.level = Level::DEBUG;
+                }
                 cfg.log.setup_logging()?;
 
-                reactor::launch::<reactor::validator::Reactor>(cfg).await
+                reactor::launch::<Reactor>(cfg).await
             }
         }
     }

src/components.rs

@@ -0,0 +1,5 @@
+//! Components
+//!
+//! Docs to be written, sorry.
+
+pub mod small_network;