listerner setup + cli + rust workflow

Author: seun-ja

.github/workflows/rust.yml

@@ -0,0 +1,44 @@
+name: Rust
+
+on:
+  push:
+    branches: ["main"]
+  pull_request:
+    branches: ["main"]
+
+env:
+  CARGO_TERM_COLOR: always
+
+jobs:
+  rustfmt:
+    name: Rustfmt
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout repository
+        uses: actions/checkout@v3
+      - name: Check formatting
+        run: cargo fmt --all --check
+  build:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v3
+      - name: Build
+        run: cargo build --verbose
+      - name: Run tests
+        run: cargo test --verbose
+  clippy:
+    name: Clippy
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout repository
+        uses: actions/checkout@v3
+      - name: Run clippy
+        run: cargo clippy --all-targets --all-features -- -D warnings
+  test:
+    name: Test
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout repository
+        uses: actions/checkout@v3
+      - name: Run tests
+        run: cargo test --verbose

README.md

@@ -0,0 +1,7 @@
+# Blockchain Node
+
+# Tasks
+
+- [ ] Consensus Algorithm
+- [ ] Networking
+- [ ] Temp Storage

src/comms/message.rs

@@ -0,0 +1,4 @@
+#[derive(Debug)]
+pub enum Message {
+    RememeberMe,
+}

src/comms/mod.rs

@@ -0,0 +1 @@
+pub mod message;

src/lib.rs

@@ -1,4 +1,5 @@
 pub mod cli;
+pub mod comms;
 
 pub mod tracing {
     use tracing_subscriber::{EnvFilter, layer::SubscriberExt as _};

src/main.rs

@@ -1,4 +1,7 @@
-use std::net::{Ipv4Addr, SocketAddrV4, TcpListener};
+use std::{
+    io::Read,
+    net::{Ipv4Addr, SocketAddrV4, TcpListener},
+};
 
 use clap::Parser as _;
 use peer_node::cli::Args;
@@ -14,10 +17,12 @@ async fn main() -> Result<(), std::io::Error> {
     tracing::info!("Node address: {}", address);
     tracing::info!("A {}", args.role);
 
-    for _incoming_stream in listerner.incoming().flatten() {
-        // incoming_stream
-    }
+    loop {
+        for mut incoming_stream in listerner.incoming().flatten() {
+            let mut msg = [0; 16];
+            let _byte_count = incoming_stream.read(&mut msg)?;
 
-    // loop {}
-    Ok(())
+            tracing::info!("Message received: {:?}", msg);
+        }
+    }
 }