snakepipe 2.2.1

A snake game based on stdin/stdout following unix philosophy
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

use futures_util::StreamExt;
use reqwest::get;
use reqwest_eventsource::{Event, EventSource};
use serde_json;

use crate::input::{Game, InitOptions};

async fn fetch_init_options(address: &String) -> Result<InitOptions, Box<dyn std::error::Error>> {
    let response = get(format!("{}/init-options", address)).await?;
    let init_options = response.json::<InitOptions>().await?;
    return Ok(init_options);
}

pub async fn bootstrap(address: String) {
    let mut events = EventSource::get(format!("{}/events", address));
    let mut current_init_options: Option<InitOptions> = None;
    while let Some(event) = events.next().await {
        match event {
            // what if the sse re-opens with different init_options ? we can't support for the moment - message parsers should ignore the header line
            Ok(Event::Open) => {
                if let Ok(init_options) = fetch_init_options(&address).await {
                    println!("{}", serde_json::to_string(&init_options).unwrap());
                    current_init_options = Some(init_options);
                }
            }
            Ok(Event::Message(message)) => {
                if current_init_options.is_some() {
                    if let Ok(game_state) = serde_json::from_str::<Game>(&message.data) {
                        println!("{}", serde_json::to_string(&game_state).unwrap());
                    }
                }
            }
            Err(_) => {
                // for the moment, keep the console clean
                // eprintln!(
                //     "Cannot connect to {}. Please check the server is up. Retrying ...",
                //     address
                // )
            }
        }
    }
}