apivolve_generator_api 0.1.1

Api for creating generators for Apivolve, an API evolution tool that helps keep your APIs backwards compatible yet clean.
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
41
42
43

use ::std::net::TcpListener;
use ::std::thread;

use ::log::debug;
use ::log::error;

use crate::gen1::ErrMsg;

#[allow(unused)] //TODO @mark:
fn accept_single_connection() -> Result<(), ErrMsg> {
    let address = "127.0.0.1:47400";
    let listener = TcpListener::bind(address).map_err(|err| {
        format!(
            "failed to listen for tcp connection on {}, err {}",
            address, err
        )
    })?;
    // let mut worker;
    if let Some(connection) = listener.incoming().next() {
        match connection {
            Ok(_connection) => {}
            Err(err) => panic!(
                "failed to accept the first connection on {}, err {}",
                address, err
            ),
        }
    }
    thread::spawn(|| reject_extra_connections(listener));
    // for connection in listener.incoming() {
    //     let stream = connection.map_err(|err| format!("failed to accept the first connection on {}, err {}", address, err))?;
    //     worker = thread::spawn(move || stream);
    // }
    // worker.join().expect("generator thread failed to join");
    Ok(())
}

#[allow(unused)] //TODO @mark:
fn reject_extra_connections(listener: TcpListener) {
    for extra_connection in listener.incoming() {
        debug!("unexpected connection: {:?}", extra_connection);
        error!("received more than one connection! this should not happen, it will be ignored");
    }
}