tek/jack/src/jack_port.rs

use crate::*;

pub struct JackPort<T: PortSpec> {
    pub port:    Port<T>,
    pub connect: Vec<PortConnect>
}

impl<T: PortSpec> JackPort<T> {
    //pub fn new (jack: &impl RegisterPort
}

#[derive(Clone, PartialEq)]
pub enum PortConnect {
    Exact(Arc<str>),
    Wildcard(Arc<str>),
    RegExp(Arc<str>),
}

/// This is a utility trait for things that may register or connect [Port]s.
/// It contains shorthand methods to this purpose. It's implemented for
/// `Arc<RwLock<JackConnection>>` for terse port registration in the
/// `init` callback of [JackClient::activate_with].
pub trait RegisterPort {
    fn midi_in   (&self, name: impl AsRef<str>, connect: &[impl AsRef<str>]) -> Usually<Port<MidiIn>>;
    fn midi_out  (&self, name: impl AsRef<str>, connect: &[impl AsRef<str>]) -> Usually<Port<MidiOut>>;
    fn audio_in  (&self, name: impl AsRef<str>, connect: &[impl AsRef<str>]) -> Usually<Port<AudioIn>>;
    fn audio_out (&self, name: impl AsRef<str>, connect: &[impl AsRef<str>]) -> Usually<Port<AudioOut>>;
}

impl RegisterPort for Arc<RwLock<JackConnection>> {
    fn midi_in (&self, name: impl AsRef<str>, connect: &[impl AsRef<str>]) -> Usually<Port<MidiIn>> {
        let jack = self.read().unwrap();
        let input = jack.client().register_port(name.as_ref(), MidiIn::default())?;
        for port in connect.iter() {
            let port = port.as_ref();
            if let Some(output) = jack.port_by_name(port).as_ref() {
                jack.client().connect_ports(output, &input)?;
            } else {
                panic!("Missing MIDI output: {port}. Use jack_lsp to list all port names.");
            }
        }
        Ok(input)
    }
    fn midi_out (&self, name: impl AsRef<str>, connect: &[impl AsRef<str>]) -> Usually<Port<MidiOut>> {
        let jack = self.read().unwrap();
        let output = jack.client().register_port(name.as_ref(), MidiOut::default())?;
        for port in connect.iter() {
            let port = port.as_ref();
            if let Some(input) = jack.port_by_name(port).as_ref() {
                jack.client().connect_ports(&output, input)?;
            } else {
                panic!("Missing MIDI input: {port}. Use jack_lsp to list all port names.");
            }
        }
        Ok(output)
    }
    fn audio_in (&self, name: impl AsRef<str>, connect: &[impl AsRef<str>]) -> Usually<Port<AudioIn>> {
        let jack = self.read().unwrap();
        let input = jack.client().register_port(name.as_ref(), AudioIn::default())?;
        for port in connect.iter() {
            let port = port.as_ref();
            if let Some(output) = jack.port_by_name(port).as_ref() {
                jack.client().connect_ports(output, &input)?;
            } else {
                panic!("Missing MIDI output: {port}. Use jack_lsp to list all port names.");
            }
        }
        Ok(input)
    }
    fn audio_out (&self, name: impl AsRef<str>, connect: &[impl AsRef<str>]) -> Usually<Port<AudioOut>> {
        let jack = self.read().unwrap();
        let output = jack.client().register_port(name.as_ref(), AudioOut::default())?;
        for port in connect.iter() {
            let port = port.as_ref();
            if let Some(input) = jack.port_by_name(port).as_ref() {
                jack.client().connect_ports(&output, input)?;
            } else {
                panic!("Missing MIDI input: {port}. Use jack_lsp to list all port names.");
            }
        }
        Ok(output)
    }
}

///// Collection of JACK ports as [AudioIn]/[AudioOut]/[MidiIn]/[MidiOut].
//#[derive(Default, Debug)]
//pub struct JackPorts {
    //pub audio_ins: BTreeMap<String, Port<AudioIn>>,
    //pub midi_ins: BTreeMap<String, Port<MidiIn>>,
    //pub audio_outs: BTreeMap<String, Port<AudioOut>>,
    //pub midi_outs: BTreeMap<String, Port<MidiOut>>,
//}

///// Collection of JACK ports as [Unowned].
//#[derive(Default, Debug)]
//pub struct UnownedJackPorts {
    //pub audio_ins: BTreeMap<String, Port<Unowned>>,
    //pub midi_ins: BTreeMap<String, Port<Unowned>>,
    //pub audio_outs: BTreeMap<String, Port<Unowned>>,
    //pub midi_outs: BTreeMap<String, Port<Unowned>>,
//}

//impl JackPorts {
    //pub fn clone_unowned(&self) -> UnownedJackPorts {
        //let mut unowned = UnownedJackPorts::default();
        //for (name, port) in self.midi_ins.iter() {
            //unowned.midi_ins.insert(name.clone(), port.clone_unowned());
        //}
        //for (name, port) in self.midi_outs.iter() {
            //unowned.midi_outs.insert(name.clone(), port.clone_unowned());
        //}
        //for (name, port) in self.audio_ins.iter() {
            //unowned.audio_ins.insert(name.clone(), port.clone_unowned());
        //}
        //for (name, port) in self.audio_outs.iter() {
            //unowned
                //.audio_outs
                //.insert(name.clone(), port.clone_unowned());
        //}
        //unowned
    //}
//}

///// Implement the `Ports` trait.
//#[macro_export]
//macro_rules! ports {
    //($T:ty $({ $(audio: {
        //$(ins:  |$ai_arg:ident|$ai_impl:expr,)?
        //$(outs: |$ao_arg:ident|$ao_impl:expr,)?
    //})? $(midi: {
        //$(ins:  |$mi_arg:ident|$mi_impl:expr,)?
        //$(outs: |$mo_arg:ident|$mo_impl:expr,)?
    //})?})?) => {
        //impl Ports for $T {$(
            //$(
                //$(fn audio_ins <'a> (&'a self) -> Usually<Vec<&'a Port<Unowned>>> {
                    //let cb = |$ai_arg:&'a Self|$ai_impl;
                    //cb(self)
                //})?
            //)?
            //$(
                //$(fn audio_outs <'a> (&'a self) -> Usually<Vec<&'a Port<Unowned>>> {
                    //let cb = (|$ao_arg:&'a Self|$ao_impl);
                    //cb(self)
                //})?
            //)?
        //)? $(
            //$(
                //$(fn midi_ins <'a> (&'a self) -> Usually<Vec<&'a Port<Unowned>>> {
                    //let cb = (|$mi_arg:&'a Self|$mi_impl);
                    //cb(self)
                //})?
            //)?
            //$(
                //$(fn midi_outs <'a> (&'a self) -> Usually<Vec<&'a Port<Unowned>>> {
                    //let cb = (|$mo_arg:&'a Self|$mo_impl);
                    //cb(self)
                //})?
            //)?
        //)?}
    //};
//}

/// Trait for things that may expose JACK ports.
pub trait Ports {
    fn audio_ins(&self) -> Usually<Vec<&Port<Unowned>>> {
        Ok(vec![])
    }
    fn audio_outs(&self) -> Usually<Vec<&Port<Unowned>>> {
        Ok(vec![])
    }
    fn midi_ins(&self) -> Usually<Vec<&Port<Unowned>>> {
        Ok(vec![])
    }
    fn midi_outs(&self) -> Usually<Vec<&Port<Unowned>>> {
        Ok(vec![])
    }
}

fn register_ports<T: PortSpec + Copy>(
    client: &Client,
    names: Vec<String>,
    spec: T,
) -> Usually<BTreeMap<String, Port<T>>> {
    names
        .into_iter()
        .try_fold(BTreeMap::new(), |mut ports, name| {
            let port = client.register_port(&name, spec)?;
            ports.insert(name, port);
            Ok(ports)
        })
}

fn query_ports(client: &Client, names: Vec<String>) -> BTreeMap<String, Port<Unowned>> {
    names.into_iter().fold(BTreeMap::new(), |mut ports, name| {
        let port = client.port_by_name(&name).unwrap();
        ports.insert(name, port);
        ports
    })
}