aboutsummaryrefslogtreecommitdiffstats
path: root/daemon/src/device_connection.h
blob: 5f2b05194b31ee36172a268258c83a21c1a79cc1 (plain)
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
64
#pragma once

#include "types.h"
#include "submitter.h"
#include "sender.h"

#include <rtmidi/RtMidi.h>

#include <string>
#include <mutex>

namespace midi_router
{

struct Device_Connection : public Sender
{
    Device_Connection(Device_Id const & source_id, std::string const & device_name, Submitter & submitter, RtMidiIn::RtMidiCallback callback):
        source_id(source_id),
        device_name(device_name),
        submitter(submitter) 
    {
        midi_in.setCallback(callback, this);
        midi_in.ignoreTypes(true, false, true);
    }

    Device_Id const & source_id;
    std::string const & device_name;
    Submitter & submitter;
    RtMidiIn midi_in {};
    RtMidiOut midi_out {};
    std::mutex mutex {};

    void
    send(std::vector<std::uint8_t> const & payload) override
    {
        const std::lock_guard<std::mutex> lock(mutex);
        if (midi_out.isPortOpen()) midi_out.sendMessage(&payload);
    }

    std::string
    get_id() const override
    {
        return source_id;
    }

    void
    connect(std::size_t port)
    {
        const std::lock_guard<std::mutex> lock(mutex);
        if (!midi_in.isPortOpen()) midi_in.openPort(port);
        if (!midi_out.isPortOpen()) midi_out.openPort(port);
    }

    void
    disconnect()
    {
        const std::lock_guard<std::mutex> lock(mutex);
        if (midi_in.isPortOpen()) midi_in.closePort();
        if (midi_out.isPortOpen()) midi_out.closePort();
    }
};

} // namespace midi_router