bmos_client 1.0.1

bmOS_client is an executable in charge of receiving and parsing JSON input from stdin and sending intents with enough confidence (>0.6) to the address and port provided (to bmOS_server). This is part of the software required to run a custom BMO-Boy.
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

use std::io::{self, BufRead};

use std::env; // args
use std::io::prelude::*;
use std::net::TcpStream;

fn main() -> std::io::Result<()> {
    let args: Vec<String> = env::args().collect();

    if args.len() != 3 {
        println!("Incorrect arguments.\nUsage: ./client server_ip server_port\nExample: ./client 192.168.1.15 2300");
        std::process::exit(-1);
    }

    let dest_ip = &args[1];
    let dest_port = &args[2];

    let mut stream = TcpStream::connect(format!("{}:{}",dest_ip, dest_port))?;

    println!("Client started and connected successfuly. Press Ctrl-C to stop reading."); 

    let stdin = io::stdin();

    for line in stdin.lock().lines() {
        let (name, conf) = bmos_client::parse_intent(line.unwrap().as_bytes()); // Pass the line as an &[u8]
        println!("Recognized: {},{}", name, conf);
        
        let mut name_to_send = name.to_owned();
        name_to_send.push('\n'); // Token to signal the end of the intent to be sent

        if conf > 0.60 { // Only send it if the confidence is high
            stream.write(name_to_send.as_bytes())?;
            println!("Confidence is high enough, sent");
            stream.flush().unwrap(); // Wait until all the bytes are written to the connection, as TcpStream is buffered
        } 
    }

    Ok(())
}