oscanity 1.0.0

Lightweight command-line tools for sending and receiving OSC messages
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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63

extern crate rosc;

use clap::Args;
use log::*;
use rosc::OscPacket;
use std::net::UdpSocket;

#[derive(Args, Default)]
pub struct ReceiveOptions {
    #[arg(long = "host", default_value_t = String::from("0.0.0.0"))]
    pub host: String,

    #[arg(long = "port", default_value_t = 12345)]
    pub port: usize,
}

pub fn receive_osc(options: &ReceiveOptions) {
    // let args: Vec<String> = env::args().collect();
    // let usage = format!("Usage: {} RECEIVE_IP:RECEIVE_PORT", &args[0]);
    // if args.len() < 2 {
    //     println!("{}", &usage);
    //     panic!()
    // }
    // let receive_address = get_addr_from_arg(&args[1]);
    let receive_url = format!("{}:{}", options.host, options.port);
    info!("Will listen at {}", &receive_url);

    let socket = UdpSocket::bind(&receive_url).expect("Error binding udp socket");
    // println!("Listening to {}", receive_address);
    //

    let mut receive_buffer = [0u8; rosc::decoder::MTU];

    loop {
        match socket.recv_from(&mut receive_buffer) {
            Ok((size, addr)) => {
                debug!("Received packet (length {}) from: {}", size, addr);
                let packet =
                    rosc::decoder::decode(&receive_buffer[..size]).expect("Error decoding packet");
                handle_packet(packet);
            }
            Err(e) => {
                error!("Error receiving from socket: {}", e);
                break;
            }
        }
    }
}

fn handle_packet(packet: OscPacket) {
    match packet {
        OscPacket::Message(msg) => {
            let arg_list = match msg.args {
                Some(args) => format!("{:?}", args),
                None => String::from("zero"),
            };
            println!("RCV OSC {} :: {}", msg.addr, arg_list);
        }
        OscPacket::Bundle(bundle) => {
            println!("OSC Bundle: {:?}", bundle);
        }
    }
}