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
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
|
/* -*- c-basic-offset: 4 indent-tabs-mode: nil -*- vi:set ts=8 sts=4 sw=4: */
/*
Sonic Visualiser
An audio file viewer and annotation editor.
Centre for Digital Music, Queen Mary, University of London.
This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License as
published by the Free Software Foundation; either version 2 of the
License, or (at your option) any later version. See the file
COPYING included with this distribution for more information.
*/
#ifndef SV_OSC_SCRIPT_H
#define SV_OSC_SCRIPT_H
#include <QThread>
#include <QFile>
#include <QTextStream>
#include "base/Debug.h"
#include "base/StringBits.h"
#include "data/osc/OSCQueue.h"
#include "data/osc/OSCMessage.h"
#include <stdexcept>
namespace sv {
class OSCScript : public QThread
{
Q_OBJECT
public:
OSCScript(QString filename, OSCQueue *queue) :
m_filename(filename),
m_queue(queue),
m_abandoning(false) {
}
void run() override {
if (!m_queue) {
SVCERR << "OSCScript: No OSC queue available" << endl;
throw std::runtime_error("OSC queue not running");
}
QFile f;
QString reportedFilename;
if (m_filename == "-") {
f.open(stdin, QFile::ReadOnly | QFile::Text);
reportedFilename = "<stdin>";
} else {
f.setFileName(m_filename);
if (!f.open(QFile::ReadOnly | QFile::Text)) {
SVCERR << "OSCScript: Failed to open script file \""
<< m_filename << "\" for reading" << endl;
throw std::runtime_error("OSC script file not found");
}
reportedFilename = m_filename;
}
QTextStream str(&f);
int lineno = 0;
while (!str.atEnd() && !m_abandoning) {
++lineno;
QString line = str.readLine().trimmed();
if (line == QString()) continue;
if (line[0] == '#') {
continue;
} else if (line[0].isDigit()) {
bool ok = false;
float pause = line.toFloat(&ok);
if (ok) {
SVCERR << "OSCScript: "
<< reportedFilename << ":" << lineno
<< ": pausing for " << pause << " sec" << endl;
msleep(unsigned(round(pause * 1000.0f)));
continue;
} else {
SVCERR << "OSCScript: "
<< reportedFilename << ":" << lineno
<< ": warning: failed to parse sleep time, ignoring"
<< endl;
continue;
}
} else if (line[0] == '/' && line.size() > 1) {
QStringList parts = StringBits::splitQuoted(line, ' ');
if (parts.empty()) {
SVCERR << "OSCScript: "
<< reportedFilename << ":" << lineno
<< ": warning: empty command spec, ignoring"
<< endl;
continue;
}
OSCMessage message;
message.setMethod(parts[0].mid(1));
for (int i = 1; i < parts.size(); ++i) {
message.addArg(parts[i]);
}
SVCERR << "OSCScript: " << reportedFilename << ":" << lineno
<< ": posting " << message.toString() << endl;
m_queue->postMessage(message);
} else {
SVCERR << "OSCScript: " << reportedFilename << ":" << lineno
<< ": warning: message expected, ignoring" << endl;
}
}
SVCERR << "OSCScript: " << reportedFilename << ": finished" << endl;
}
void abandon() {
m_abandoning = true;
}
private:
QString m_filename;
OSCQueue *m_queue; // I do not own this
bool m_abandoning;
};
} // end namespace sv
#endif
|
