apt-swarm 0.6.0

🥸 Experimental p2p gossip network for OpenPGP signature transparency 🥸
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
33
34
35
36
37
38
39
40

use crate::db::DatabaseServerClient;
use crate::errors::*;
use crate::p2p::{self, peerdb};
use crate::sync;
use std::convert::Infallible;
use tokio::io::AsyncWriteExt;
use tokio::net::{TcpListener, TcpStream};

pub async fn serve_sync_client(
    db: &mut DatabaseServerClient,
    peerdb: peerdb::Client,
    mut stream: TcpStream,
) -> Result<()> {
    let (rx, mut tx) = stream.split();
    let result =
        sync::sync_yield(db, Some(peerdb), rx, &mut tx, Some(p2p::SYNC_IDLE_TIMEOUT)).await;
    tx.shutdown().await.ok();
    result
}

pub async fn spawn_sync_server(
    db: &DatabaseServerClient,
    peerdb: peerdb::Client,
    listener: TcpListener,
) -> Result<Infallible> {
    loop {
        let (stream, src_addr) = listener.accept().await?;
        debug!("Accepted connection from client: {:?}", src_addr);

        let mut db = db.clone();
        let peerdb = peerdb.clone();
        tokio::spawn(async move {
            if let Err(err) = serve_sync_client(&mut db, peerdb, stream).await {
                error!("Error while serving client: {err:#}");
            } else {
                debug!("Client disconnected: {src_addr:?}");
            }
        });
    }
}