device 0.0.4

A generative engine
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

use super::*;

pub(crate) struct Hub {
  #[allow(unused)]
  connections: Vec<midir::MidiInputConnection<()>>,
  messages: Arc<Mutex<Vec<Message>>>,
}

impl Hub {
  pub(crate) fn drain(&self) -> Vec<Message> {
    self.messages.lock().unwrap().drain(..).collect()
  }

  pub(crate) fn new() -> Result<Self> {
    let messages = Arc::new(Mutex::new(Vec::new()));

    let mut connections = Vec::new();

    let input = midir::MidiInput::new("MIDI Input").context(error::MidiInputInit)?;
    for port in input.ports() {
      let name = input.port_name(&port).context(error::MidiPortInfo)?;
      let messages = messages.clone();
      connections.push(
        midir::MidiInput::new(&format!("MIDI Port Input: {name}"))
          .context(error::MidiInputInit)?
          .connect(
            &port,
            &name,
            move |_timestamp, event, ()| match Message::parse(event) {
              Ok(message) => messages.lock().unwrap().push(message),
              Err(err) => log::warn!("MIDI event parse error: {err}"),
            },
            (),
          )
          .context(error::MidiInputPortConnect)?,
      );
    }

    Ok(Self {
      connections,
      messages,
    })
  }
}