libskyfall 0.1.0

Quantum-Safe P2P Communication System
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

#![allow(missing_docs)]

use libskyfall_macros::{handler, route};

use crate::{handlers::Request, Channel};

pub struct Echo;

#[handler(id = "core.echo", libskyfall = "crate", about = "Simple testing protocol")]
impl Echo {
    #[route(path = "/echo", channel = channel, request = request)]
    pub async fn echo(&self, request: Request, channel: Channel) -> anyhow::Result<()> {
        println!("Got echo request from {:?}", request.peer);
        loop {
            match channel.recv().await {
                Ok(data) => println!("RECV: {}", String::from_utf8(data).unwrap()),
                Err(e) => eprintln!("RECVERR: {e:?}")
            }
        }
    }
}