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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
|
#include "connection_manager.h"
#include "sender.h"
#include <iostream>
#include <rtmidi/RtMidi.h>
namespace midi_router
{
struct Device_Connection : public Sender
{
Device_Connection(Device_Id const & source_id, Submitter & submitter):
source_id(source_id),
submitter(submitter)
{}
Device_Id const & source_id;
Submitter & submitter;
RtMidiIn midi_in {};
RtMidiOut midi_out {};
void
send(std::array<std::uint8_t, 3> const & payload) override
{
if (midi_out.isPortOpen())
{
midi_out.sendMessage(payload.data(), 3);
}
}
};
static void
callback(double time_stamp, std::vector<unsigned char> *raw, void *user_data)
{
Device_Connection* device = static_cast<Device_Connection*>(user_data);
if (raw->size() != 3)
{
std::cerr << "Received message with wrong size from " << device->source_id << ", dropping\n";
}
Message message { &device->source_id, {raw->at(0), raw->at(1), raw->at(2)} };
device->submitter.submit(message);
}
Connection_Manager::Connection_Manager(Device_Map const & device_map, Submitter & submitter):
m_device_map(device_map),
m_submitter(submitter),
m_connections{}
{
for (auto const & [name, id] : device_map)
{
m_connections[id] = std::make_unique<Device_Connection>(id, submitter);
auto & connection = m_connections[id];
connection->midi_in.setCallback(&callback, connection.get());
connection->midi_in.ignoreTypes(true, true, true);
if (!open_port(&connection->midi_in, name))
{
std::cerr << "Input port not found for device " << name << "\n";
}
if (!open_port(&connection->midi_out, name))
{
std::cerr << "Output port not found for device " << name << "\n";
}
}
}
Connection_Manager::~Connection_Manager() = default;
Sender &
Connection_Manager::get_sender(Device_Id const & device) const
{
return *m_connections.at(device);
}
bool
Connection_Manager::open_port(RtMidi* const midi, std::string const & name)
{
for (std::size_t i = 0; i < midi->getPortCount(); ++i)
{
if (midi->getPortName(i).contains(name))
{
midi->openPort(i);
return true;
}
}
return false;
}
} // namespace midi_router
|
