Chris@498
|
1 /* -*- c-basic-offset: 4 indent-tabs-mode: nil -*- vi:set ts=8 sts=4 sw=4: */
|
Chris@498
|
2
|
Chris@498
|
3 /*
|
Chris@498
|
4 Sonic Annotator
|
Chris@498
|
5 A utility for batch feature extraction from audio files.
|
Chris@498
|
6 Mark Levy, Chris Sutton and Chris Cannam, Queen Mary, University of London.
|
Chris@498
|
7 Copyright 2007-2008 QMUL.
|
Chris@498
|
8
|
Chris@498
|
9 This program is free software; you can redistribute it and/or
|
Chris@498
|
10 modify it under the terms of the GNU General Public License as
|
Chris@498
|
11 published by the Free Software Foundation; either version 2 of the
|
Chris@498
|
12 License, or (at your option) any later version. See the file
|
Chris@498
|
13 COPYING included with this distribution for more information.
|
Chris@498
|
14 */
|
Chris@498
|
15
|
Chris@498
|
16 #include <fstream>
|
Chris@498
|
17
|
Chris@498
|
18 #include "vamp-hostsdk/PluginHostAdapter.h"
|
Chris@498
|
19 #include "vamp-hostsdk/PluginLoader.h"
|
Chris@498
|
20
|
Chris@599
|
21 #include "base/Exceptions.h"
|
Chris@599
|
22
|
Chris@498
|
23 #include "RDFFeatureWriter.h"
|
Chris@498
|
24 #include "RDFTransformFactory.h"
|
Chris@597
|
25 #include "PluginRDFIndexer.h"
|
Chris@498
|
26
|
Chris@498
|
27 #include <QTextStream>
|
Chris@498
|
28 #include <QUrl>
|
Chris@508
|
29 #include <QFileInfo>
|
Chris@498
|
30 #include <QRegExp>
|
Chris@498
|
31
|
Chris@498
|
32 using namespace std;
|
Chris@498
|
33 using Vamp::Plugin;
|
Chris@498
|
34 using Vamp::PluginBase;
|
Chris@498
|
35
|
Chris@498
|
36 RDFFeatureWriter::RDFFeatureWriter() :
|
Chris@498
|
37 FileFeatureWriter(SupportOneFilePerTrackTransform |
|
Chris@498
|
38 SupportOneFilePerTrack |
|
Chris@498
|
39 SupportOneFileTotal,
|
Chris@498
|
40 "n3"),
|
Chris@498
|
41 m_plain(false),
|
Chris@597
|
42 m_network(false),
|
Chris@597
|
43 m_networkRetrieved(false),
|
Chris@498
|
44 m_count(0)
|
Chris@498
|
45 {
|
Chris@498
|
46 }
|
Chris@498
|
47
|
Chris@498
|
48 RDFFeatureWriter::~RDFFeatureWriter()
|
Chris@498
|
49 {
|
Chris@498
|
50 }
|
Chris@498
|
51
|
Chris@498
|
52 RDFFeatureWriter::ParameterList
|
Chris@498
|
53 RDFFeatureWriter::getSupportedParameters() const
|
Chris@498
|
54 {
|
Chris@498
|
55 ParameterList pl = FileFeatureWriter::getSupportedParameters();
|
Chris@498
|
56 Parameter p;
|
Chris@498
|
57
|
Chris@498
|
58 p.name = "plain";
|
Chris@498
|
59 p.description = "Use \"plain\" RDF even if transform metadata is available.";
|
Chris@498
|
60 p.hasArg = false;
|
Chris@498
|
61 pl.push_back(p);
|
Chris@498
|
62
|
Chris@586
|
63 p.name = "audiofile-uri";
|
Chris@586
|
64 p.description = "Link the output RDF to the given audio file URI instead of its actual location.";
|
Chris@498
|
65 p.hasArg = true;
|
Chris@498
|
66 pl.push_back(p);
|
Chris@594
|
67
|
Chris@594
|
68 p.name = "track-uri";
|
Chris@594
|
69 p.description = "Link the output RDF to the given track URI.";
|
Chris@594
|
70 p.hasArg = true;
|
Chris@594
|
71 pl.push_back(p);
|
Chris@594
|
72
|
Chris@594
|
73 p.name = "maker-uri";
|
Chris@594
|
74 p.description = "Link the track in the output RDF to the given foaf:maker URI.";
|
Chris@594
|
75 p.hasArg = true;
|
Chris@594
|
76 pl.push_back(p);
|
Chris@597
|
77
|
mathieu@714
|
78 //mathieub: remove this functionality for the library edition
|
mathieu@714
|
79 //p.name = "network";
|
mathieu@714
|
80 //p.description = "Attempt to retrieve RDF descriptions of plugins from network, if not available locally";
|
mathieu@714
|
81 //p.hasArg = false;
|
mathieu@714
|
82 //pl.push_back(p);
|
Chris@498
|
83
|
Chris@498
|
84 return pl;
|
Chris@498
|
85 }
|
Chris@498
|
86
|
Chris@498
|
87 void
|
Chris@498
|
88 RDFFeatureWriter::setParameters(map<string, string> ¶ms)
|
Chris@498
|
89 {
|
Chris@498
|
90 FileFeatureWriter::setParameters(params);
|
Chris@498
|
91
|
Chris@498
|
92 for (map<string, string>::iterator i = params.begin();
|
Chris@498
|
93 i != params.end(); ++i) {
|
Chris@498
|
94 if (i->first == "plain") {
|
Chris@498
|
95 m_plain = true;
|
Chris@498
|
96 }
|
Chris@586
|
97 if (i->first == "audiofile-uri") {
|
Chris@594
|
98 m_userAudioFileUri = i->second.c_str();
|
Chris@594
|
99 }
|
Chris@594
|
100 if (i->first == "track-uri") {
|
Chris@594
|
101 m_userTrackUri = i->second.c_str();
|
Chris@594
|
102 }
|
Chris@594
|
103 if (i->first == "maker-uri") {
|
Chris@594
|
104 m_userMakerUri = i->second.c_str();
|
Chris@498
|
105 }
|
mathieu@714
|
106 //mathieub: remove this functionality for the library edition
|
mathieu@714
|
107 //if (i->first == "network") {
|
mathieu@714
|
108 // m_network = true;
|
mathieu@714
|
109 //}
|
Chris@498
|
110 }
|
Chris@498
|
111 }
|
Chris@498
|
112
|
Chris@504
|
113 void
|
Chris@504
|
114 RDFFeatureWriter::setTrackMetadata(QString trackId,
|
Chris@504
|
115 TrackMetadata metadata)
|
Chris@504
|
116 {
|
Chris@686
|
117 // cerr << "setTrackMetadata: title = " << metadata.title << ", maker = " << metadata.maker << endl;
|
Chris@504
|
118 m_metadata[trackId] = metadata;
|
Chris@504
|
119 }
|
Chris@504
|
120
|
Chris@504
|
121 void
|
Chris@510
|
122 RDFFeatureWriter::setFixedEventTypeURI(QString uri)
|
Chris@510
|
123 {
|
Chris@510
|
124 m_fixedEventTypeURI = uri;
|
Chris@510
|
125 }
|
Chris@510
|
126
|
Chris@510
|
127 void
|
Chris@504
|
128 RDFFeatureWriter::write(QString trackId,
|
Chris@504
|
129 const Transform &transform,
|
Chris@504
|
130 const Plugin::OutputDescriptor& output,
|
Chris@504
|
131 const Plugin::FeatureList& features,
|
Chris@504
|
132 std::string summaryType)
|
Chris@498
|
133 {
|
Chris@498
|
134 QString pluginId = transform.getPluginIdentifier();
|
Chris@498
|
135
|
Chris@498
|
136 if (m_rdfDescriptions.find(pluginId) == m_rdfDescriptions.end()) {
|
Chris@498
|
137
|
Chris@597
|
138 if (m_network && !m_networkRetrieved) {
|
Chris@597
|
139 PluginRDFIndexer::getInstance()->indexConfiguredURLs();
|
Chris@597
|
140 m_networkRetrieved = true;
|
Chris@597
|
141 }
|
Chris@597
|
142
|
Chris@498
|
143 m_rdfDescriptions[pluginId] = PluginRDFDescription(pluginId);
|
Chris@498
|
144
|
Chris@498
|
145 if (m_rdfDescriptions[pluginId].haveDescription()) {
|
Chris@690
|
146 SVDEBUG << "NOTE: Have RDF description for plugin ID \""
|
Chris@686
|
147 << pluginId << "\"" << endl;
|
Chris@498
|
148 } else {
|
Chris@690
|
149 SVDEBUG << "NOTE: No RDF description for plugin ID \""
|
Chris@686
|
150 << pluginId << "\"" << endl;
|
Chris@597
|
151 if (!m_network) {
|
Chris@597
|
152 cerr << " Consider using the --rdf-network option to retrieve plugin descriptions" << endl;
|
Chris@597
|
153 cerr << " from the network where possible." << endl;
|
Chris@597
|
154 }
|
Chris@498
|
155 }
|
Chris@498
|
156 }
|
Chris@498
|
157
|
Chris@498
|
158 // Need to select appropriate output file for our track/transform
|
Chris@498
|
159 // combination
|
Chris@498
|
160
|
Chris@498
|
161 QTextStream *stream = getOutputStream(trackId, transform.getIdentifier());
|
Chris@512
|
162 if (!stream) {
|
Chris@605
|
163 throw FailedToOpenOutputStream(trackId, transform.getIdentifier());
|
Chris@512
|
164 }
|
Chris@498
|
165
|
Chris@498
|
166 if (m_startedStreamTransforms.find(stream) ==
|
Chris@498
|
167 m_startedStreamTransforms.end()) {
|
Chris@594
|
168 // cerr << "This stream is new, writing prefixes" << endl;
|
Chris@498
|
169 writePrefixes(stream);
|
Chris@498
|
170 if (m_singleFileName == "" && !m_stdout) {
|
Chris@498
|
171 writeSignalDescription(stream, trackId);
|
Chris@498
|
172 }
|
Chris@498
|
173 }
|
Chris@498
|
174
|
Chris@498
|
175 if (m_startedStreamTransforms[stream].find(transform) ==
|
Chris@498
|
176 m_startedStreamTransforms[stream].end()) {
|
Chris@498
|
177 m_startedStreamTransforms[stream].insert(transform);
|
Chris@498
|
178 writeLocalFeatureTypes
|
Chris@498
|
179 (stream, transform, output, m_rdfDescriptions[pluginId]);
|
Chris@498
|
180 }
|
Chris@498
|
181
|
Chris@498
|
182 if (m_singleFileName != "" || m_stdout) {
|
Chris@498
|
183 if (m_startedTrackIds.find(trackId) == m_startedTrackIds.end()) {
|
Chris@498
|
184 writeSignalDescription(stream, trackId);
|
Chris@498
|
185 m_startedTrackIds.insert(trackId);
|
Chris@498
|
186 }
|
Chris@498
|
187 }
|
Chris@498
|
188
|
Chris@498
|
189 QString timelineURI = m_trackTimelineURIs[trackId];
|
Chris@498
|
190
|
Chris@498
|
191 if (timelineURI == "") {
|
Chris@498
|
192 cerr << "RDFFeatureWriter: INTERNAL ERROR: writing features without having established a timeline URI!" << endl;
|
Chris@498
|
193 exit(1);
|
Chris@498
|
194 }
|
Chris@498
|
195
|
Chris@498
|
196 if (summaryType != "") {
|
Chris@498
|
197
|
Chris@498
|
198 writeSparseRDF(stream, transform, output, features,
|
Chris@498
|
199 m_rdfDescriptions[pluginId], timelineURI);
|
Chris@498
|
200
|
Chris@498
|
201 } else if (m_rdfDescriptions[pluginId].haveDescription() &&
|
Chris@498
|
202 m_rdfDescriptions[pluginId].getOutputDisposition
|
Chris@498
|
203 (output.identifier.c_str()) ==
|
Chris@498
|
204 PluginRDFDescription::OutputDense) {
|
Chris@498
|
205
|
Chris@498
|
206 QString signalURI = m_trackSignalURIs[trackId];
|
Chris@498
|
207
|
Chris@498
|
208 if (signalURI == "") {
|
Chris@498
|
209 cerr << "RDFFeatureWriter: INTERNAL ERROR: writing dense features without having established a signal URI!" << endl;
|
Chris@498
|
210 exit(1);
|
Chris@498
|
211 }
|
Chris@498
|
212
|
Chris@498
|
213 writeDenseRDF(stream, transform, output, features,
|
Chris@498
|
214 m_rdfDescriptions[pluginId], signalURI, timelineURI);
|
Chris@498
|
215
|
Chris@507
|
216 } else if (!m_plain &&
|
Chris@507
|
217 m_rdfDescriptions[pluginId].haveDescription() &&
|
Chris@507
|
218 m_rdfDescriptions[pluginId].getOutputDisposition
|
Chris@507
|
219 (output.identifier.c_str()) ==
|
Chris@507
|
220 PluginRDFDescription::OutputTrackLevel &&
|
Chris@507
|
221 m_rdfDescriptions[pluginId].getOutputFeatureAttributeURI
|
Chris@507
|
222 (output.identifier.c_str()) != "") {
|
Chris@507
|
223
|
Chris@507
|
224 QString signalURI = m_trackSignalURIs[trackId];
|
Chris@507
|
225
|
Chris@507
|
226 if (signalURI == "") {
|
Chris@507
|
227 cerr << "RDFFeatureWriter: INTERNAL ERROR: writing track-level features without having established a signal URI!" << endl;
|
Chris@507
|
228 exit(1);
|
Chris@507
|
229 }
|
Chris@507
|
230
|
Chris@507
|
231 writeTrackLevelRDF(stream, transform, output, features,
|
Chris@507
|
232 m_rdfDescriptions[pluginId], signalURI);
|
Chris@507
|
233
|
Chris@498
|
234 } else {
|
Chris@498
|
235
|
Chris@498
|
236 writeSparseRDF(stream, transform, output, features,
|
Chris@498
|
237 m_rdfDescriptions[pluginId], timelineURI);
|
Chris@498
|
238 }
|
Chris@498
|
239 }
|
Chris@498
|
240
|
Chris@498
|
241 void
|
Chris@498
|
242 RDFFeatureWriter::writePrefixes(QTextStream *sptr)
|
Chris@498
|
243 {
|
Chris@498
|
244 QTextStream &stream = *sptr;
|
Chris@498
|
245
|
Chris@498
|
246 stream << "@prefix dc: <http://purl.org/dc/elements/1.1/> .\n"
|
Chris@498
|
247 << "@prefix mo: <http://purl.org/ontology/mo/> .\n"
|
Chris@498
|
248 << "@prefix af: <http://purl.org/ontology/af/> .\n"
|
Chris@504
|
249 << "@prefix foaf: <http://xmlns.com/foaf/0.1/> . \n"
|
Chris@498
|
250 << "@prefix event: <http://purl.org/NET/c4dm/event.owl#> .\n"
|
Chris@498
|
251 << "@prefix rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#> .\n"
|
Chris@498
|
252 << "@prefix rdfs: <http://www.w3.org/2000/01/rdf-schema#> .\n"
|
Chris@498
|
253 << "@prefix xsd: <http://www.w3.org/2001/XMLSchema#> .\n"
|
Chris@498
|
254 << "@prefix tl: <http://purl.org/NET/c4dm/timeline.owl#> .\n"
|
Chris@498
|
255 << "@prefix vamp: <http://purl.org/ontology/vamp/> .\n"
|
Chris@498
|
256 << "@prefix : <#> .\n\n";
|
Chris@498
|
257 }
|
Chris@498
|
258
|
Chris@498
|
259 void
|
Chris@590
|
260 RDFFeatureWriter::reviewFileForAppending(QString filename)
|
Chris@590
|
261 {
|
Chris@590
|
262 // Appending to an RDF file is tricky, because we need to ensure
|
Chris@590
|
263 // that our URIs differ from any already in the file. This is a
|
Chris@590
|
264 // dirty grubby low-rent way of doing that. This function is
|
Chris@590
|
265 // called by FileFeatureWriter::getOutputFile when in append mode.
|
Chris@590
|
266
|
Chris@686
|
267 // std::cerr << "reviewFileForAppending(" << filename << ")" << std::endl;
|
Chris@590
|
268
|
Chris@590
|
269 QFile file(filename);
|
Chris@590
|
270
|
Chris@590
|
271 // just return, don't report failure -- function that called us will do that
|
Chris@590
|
272 if (!file.open(QIODevice::ReadOnly)) return;
|
Chris@590
|
273
|
Chris@590
|
274 QTextStream in(&file);
|
Chris@590
|
275
|
Chris@590
|
276 QRegExp localObjectUriWithDigits(":[^ ]+_([0-9]+) a ");
|
Chris@590
|
277
|
Chris@590
|
278 while (!in.atEnd()) {
|
Chris@590
|
279 QString line = in.readLine();
|
Chris@590
|
280 if (line.length() > 120) { // probably data
|
Chris@590
|
281 continue;
|
Chris@590
|
282 }
|
Chris@590
|
283 if (localObjectUriWithDigits.indexIn(line) > -1) {
|
Chris@590
|
284 QString numeric = localObjectUriWithDigits.cap(1);
|
Chris@590
|
285 int number = numeric.toInt();
|
Chris@590
|
286 if (number >= m_count) m_count = number + 1;
|
Chris@590
|
287 }
|
Chris@590
|
288 }
|
Chris@590
|
289
|
Chris@590
|
290 file.close();
|
Chris@590
|
291 }
|
Chris@590
|
292
|
Chris@590
|
293 void
|
Chris@498
|
294 RDFFeatureWriter::writeSignalDescription(QTextStream *sptr,
|
Chris@498
|
295 QString trackId)
|
Chris@498
|
296 {
|
Chris@690
|
297 // SVDEBUG << "RDFFeatureWriter::writeSignalDescription" << endl;
|
Chris@530
|
298
|
Chris@498
|
299 QTextStream &stream = *sptr;
|
Chris@498
|
300
|
Chris@498
|
301 /*
|
Chris@498
|
302 * Describe signal we're analysing (AudioFile, Signal, TimeLine, etc.)
|
Chris@498
|
303 */
|
Chris@498
|
304
|
Christophe@615
|
305 QUrl url(trackId, QUrl::StrictMode);
|
Chris@498
|
306 QString scheme = url.scheme().toLower();
|
Chris@498
|
307 bool local = (scheme == "" || scheme == "file" || scheme.length() == 1);
|
Chris@498
|
308
|
Chris@498
|
309 if (local) {
|
Chris@498
|
310 if (scheme == "") {
|
Chris@498
|
311 url.setScheme("file");
|
Chris@508
|
312 url.setPath(QFileInfo(url.path()).absoluteFilePath());
|
Chris@498
|
313 } else if (scheme.length() == 1) { // DOS drive letter!
|
Chris@498
|
314 url.setScheme("file");
|
Chris@498
|
315 url.setPath(scheme + ":" + url.path());
|
Chris@498
|
316 }
|
Chris@498
|
317 }
|
Chris@498
|
318
|
Chris@590
|
319 // Note reviewFileForAppending above (when opening in append mode)
|
Chris@498
|
320
|
Chris@602
|
321 unsigned long signalCount = m_count++;
|
Chris@498
|
322
|
Chris@498
|
323 if (m_trackSignalURIs.find(trackId) == m_trackSignalURIs.end()) {
|
Chris@498
|
324 m_trackSignalURIs[trackId] = QString(":signal_%1").arg(signalCount);
|
Chris@498
|
325 }
|
Chris@498
|
326 QString signalURI = m_trackSignalURIs[trackId];
|
Chris@498
|
327
|
Chris@585
|
328 if (m_trackTrackURIs.find(trackId) == m_trackTrackURIs.end()) {
|
Chris@585
|
329 m_trackTrackURIs[trackId] = QString(":track_%1").arg(signalCount);
|
Chris@585
|
330 }
|
Chris@585
|
331 QString trackURI = m_trackTrackURIs[trackId];
|
Chris@594
|
332
|
Chris@594
|
333 bool userSpecifiedTrack = false;
|
Chris@594
|
334 if (m_userTrackUri != "") {
|
Chris@594
|
335 trackURI = "<" + m_userTrackUri + ">";
|
Chris@594
|
336 m_trackTrackURIs[trackId] = trackURI;
|
Chris@594
|
337 userSpecifiedTrack = true;
|
Chris@594
|
338 }
|
Chris@585
|
339
|
Chris@498
|
340 if (m_trackTimelineURIs.find(trackId) == m_trackTimelineURIs.end()) {
|
Chris@498
|
341 m_trackTimelineURIs[trackId] = QString(":signal_timeline_%1").arg(signalCount);
|
Chris@498
|
342 }
|
Chris@498
|
343 QString timelineURI = m_trackTimelineURIs[trackId];
|
Chris@498
|
344
|
Chris@586
|
345 QString afURI = url.toEncoded().data();
|
Chris@594
|
346 if (m_userAudioFileUri != "") afURI = m_userAudioFileUri;
|
Chris@586
|
347
|
Chris@594
|
348 bool wantTrack = (userSpecifiedTrack ||
|
Chris@594
|
349 (m_userMakerUri != "") ||
|
Chris@594
|
350 (m_metadata.find(trackId) != m_metadata.end()));
|
Chris@594
|
351
|
Chris@594
|
352 // cerr << "wantTrack = " << wantTrack << " (userSpecifiedTrack = "
|
Chris@686
|
353 // << userSpecifiedTrack << ", m_userMakerUri = " << m_userMakerUri << ", have metadata = " << (m_metadata.find(trackId) != m_metadata.end()) << ")" << endl;
|
Chris@594
|
354
|
Chris@594
|
355 if (wantTrack) {
|
Chris@594
|
356 // We only write a Track at all if we have some title/artist
|
Chris@594
|
357 // metadata to put in it, or if the user has requested a
|
Chris@594
|
358 // specific track URI. Otherwise we can't be sure that what
|
Chris@594
|
359 // we have is a Track, in the publication sense -- it may just
|
Chris@594
|
360 // be a fragment, a test file, whatever. Since we'd have no
|
Chris@594
|
361 // metadata to associate with our Track, the only effect of
|
Chris@594
|
362 // including a Track would be to assert that this was one,
|
Chris@594
|
363 // which is the one thing we wouldn't know...
|
Chris@594
|
364 TrackMetadata tm;
|
Chris@594
|
365 if (m_metadata.find(trackId) != m_metadata.end()) {
|
Chris@594
|
366 tm = m_metadata[trackId];
|
Chris@585
|
367 }
|
Chris@594
|
368 stream << trackURI << " a mo:Track ";
|
Chris@594
|
369 if (tm.title != "") {
|
Chris@594
|
370 stream << ";\n dc:title \"\"\"" << tm.title << "\"\"\" ";
|
Chris@594
|
371 }
|
Chris@594
|
372 if (m_userMakerUri != "") {
|
Chris@594
|
373 stream << ";\n foaf:maker <" << m_userMakerUri << "> ";
|
Chris@594
|
374 } else if (tm.maker != "") {
|
Chris@594
|
375 stream << ";\n foaf:maker [ a mo:MusicArtist; foaf:name \"\"\"" << tm.maker << "\"\"\" ] ";
|
Chris@594
|
376 }
|
Chris@594
|
377 if (afURI != "") {
|
Chris@594
|
378 stream << ";\n mo:available_as <" << afURI << "> ";
|
Chris@594
|
379 }
|
Chris@594
|
380 stream << ".\n\n";
|
Chris@585
|
381 }
|
Chris@585
|
382
|
Chris@594
|
383 if (afURI != "") {
|
Chris@586
|
384 stream << "<" << afURI << "> a mo:AudioFile ;\n";
|
Chris@585
|
385 stream << " mo:encodes " << signalURI << ".\n\n";
|
Chris@500
|
386 }
|
Chris@500
|
387
|
Chris@500
|
388 stream << signalURI << " a mo:Signal ;\n";
|
Chris@500
|
389
|
Chris@500
|
390 stream << " mo:time [\n"
|
Chris@498
|
391 << " a tl:Interval ;\n"
|
Chris@498
|
392 << " tl:onTimeLine "
|
Chris@498
|
393 << timelineURI << "\n ] .\n\n";
|
Chris@585
|
394
|
Chris@585
|
395 stream << timelineURI << " a tl:Timeline .\n";
|
Chris@498
|
396 }
|
Chris@498
|
397
|
Chris@498
|
398 void
|
Chris@498
|
399 RDFFeatureWriter::writeLocalFeatureTypes(QTextStream *sptr,
|
Chris@498
|
400 const Transform &transform,
|
Chris@498
|
401 const Plugin::OutputDescriptor &od,
|
Chris@498
|
402 PluginRDFDescription &desc)
|
Chris@498
|
403 {
|
Chris@498
|
404 QString outputId = od.identifier.c_str();
|
Chris@498
|
405 QTextStream &stream = *sptr;
|
Chris@498
|
406
|
Chris@507
|
407 // There is no "needFeatureType" for track-level outputs, because
|
Chris@507
|
408 // we can't meaningfully write a feature at all if we don't know
|
Chris@507
|
409 // what property to use for it. If the output is track level but
|
Chris@507
|
410 // there is no feature type given, we have to revert to events.
|
Chris@507
|
411
|
Chris@498
|
412 bool needEventType = false;
|
Chris@498
|
413 bool needSignalType = false;
|
Chris@498
|
414
|
Chris@498
|
415 //!!! bin names, extents and so on can be written out using e.g. vamp:bin_names ( "a" "b" "c" )
|
Chris@498
|
416
|
Chris@498
|
417 if (desc.getOutputDisposition(outputId) ==
|
Chris@498
|
418 PluginRDFDescription::OutputDense) {
|
Chris@498
|
419
|
Chris@498
|
420 // no feature events, so may need signal type but won't need
|
Chris@498
|
421 // event type
|
Chris@498
|
422
|
Chris@498
|
423 if (m_plain) {
|
Chris@498
|
424
|
Chris@498
|
425 needSignalType = true;
|
Chris@498
|
426
|
Chris@498
|
427 } else if (desc.getOutputSignalTypeURI(outputId) == "") {
|
Chris@498
|
428
|
Chris@498
|
429 needSignalType = true;
|
Chris@498
|
430 }
|
Chris@498
|
431
|
Chris@507
|
432 } else if (desc.getOutputDisposition(outputId) ==
|
Chris@507
|
433 PluginRDFDescription::OutputTrackLevel) {
|
Chris@507
|
434
|
Chris@507
|
435 // see note above -- need to generate an event type if no
|
Chris@507
|
436 // feature type given, or if in plain mode
|
Chris@507
|
437
|
Chris@507
|
438 if (m_plain) {
|
Chris@507
|
439
|
Chris@507
|
440 needEventType = true;
|
Chris@507
|
441
|
Chris@507
|
442 } else if (desc.getOutputFeatureAttributeURI(outputId) == "") {
|
Chris@507
|
443
|
Chris@507
|
444 if (desc.getOutputEventTypeURI(outputId) == "") {
|
Chris@507
|
445
|
Chris@507
|
446 needEventType = true;
|
Chris@507
|
447 }
|
Chris@507
|
448 }
|
Chris@507
|
449
|
Chris@498
|
450 } else {
|
Chris@498
|
451
|
Chris@498
|
452 // may need event type but won't need signal type
|
Chris@498
|
453
|
Chris@498
|
454 if (m_plain) {
|
Chris@498
|
455
|
Chris@498
|
456 needEventType = true;
|
Chris@498
|
457
|
Chris@498
|
458 } else if (desc.getOutputEventTypeURI(outputId) == "") {
|
Chris@498
|
459
|
Chris@498
|
460 needEventType = true;
|
Chris@498
|
461 }
|
Chris@498
|
462 }
|
Chris@498
|
463
|
Chris@498
|
464 QString transformUri;
|
Chris@498
|
465 if (m_transformURIs.find(transform) != m_transformURIs.end()) {
|
Chris@498
|
466 transformUri = m_transformURIs[transform];
|
Chris@498
|
467 } else {
|
Chris@498
|
468 transformUri = QString(":transform_%1_%2").arg(m_count++).arg(outputId);
|
Chris@498
|
469 m_transformURIs[transform] = transformUri;
|
Chris@498
|
470 }
|
Chris@498
|
471
|
Chris@500
|
472 if (transform.getIdentifier() != "") {
|
Chris@508
|
473 stream << endl
|
Chris@508
|
474 << RDFTransformFactory::writeTransformToRDF(transform, transformUri)
|
Chris@500
|
475 << endl;
|
Chris@500
|
476 }
|
Chris@498
|
477
|
Chris@510
|
478 if (needEventType && m_fixedEventTypeURI == "") {
|
Chris@498
|
479
|
Chris@498
|
480 QString uri;
|
Chris@498
|
481 if (m_syntheticEventTypeURIs.find(transform) !=
|
Chris@498
|
482 m_syntheticEventTypeURIs.end()) {
|
Chris@498
|
483 uri = m_syntheticEventTypeURIs[transform];
|
Chris@498
|
484 } else {
|
Chris@498
|
485 uri = QString(":event_type_%1").arg(m_count++);
|
Chris@498
|
486 m_syntheticEventTypeURIs[transform] = uri;
|
Chris@498
|
487 }
|
Chris@498
|
488
|
Chris@498
|
489 stream << uri
|
Chris@498
|
490 << " rdfs:subClassOf event:Event ;" << endl
|
Chris@498
|
491 << " dc:title \"" << od.name.c_str() << "\" ;" << endl
|
Chris@498
|
492 << " dc:format \"" << od.unit.c_str() << "\" ;" << endl
|
Chris@498
|
493 << " dc:description \"" << od.description.c_str() << "\" ."
|
Chris@498
|
494 << endl << endl;
|
Chris@498
|
495 }
|
Chris@498
|
496
|
Chris@498
|
497 if (needSignalType) {
|
Chris@498
|
498
|
Chris@498
|
499 QString uri;
|
Chris@498
|
500 if (m_syntheticSignalTypeURIs.find(transform) !=
|
Chris@498
|
501 m_syntheticSignalTypeURIs.end()) {
|
Chris@498
|
502 uri = m_syntheticSignalTypeURIs[transform];
|
Chris@498
|
503 } else {
|
Chris@498
|
504 uri = QString(":signal_type_%1").arg(m_count++);
|
Chris@498
|
505 m_syntheticSignalTypeURIs[transform] = uri;
|
Chris@498
|
506 }
|
Chris@498
|
507
|
Chris@498
|
508 stream << uri
|
Chris@498
|
509 << " rdfs:subClassOf af:Signal ;" << endl
|
Chris@498
|
510 << " dc:title \"" << od.name.c_str() << "\" ;" << endl
|
Chris@498
|
511 << " dc:format \"" << od.unit.c_str() << "\" ;" << endl
|
Chris@498
|
512 << " dc:description \"" << od.description.c_str() << "\" ."
|
Chris@498
|
513 << endl << endl;
|
Chris@498
|
514 }
|
Chris@498
|
515 }
|
Chris@498
|
516
|
Chris@498
|
517 void
|
Chris@498
|
518 RDFFeatureWriter::writeSparseRDF(QTextStream *sptr,
|
Chris@498
|
519 const Transform &transform,
|
Chris@498
|
520 const Plugin::OutputDescriptor& od,
|
Chris@498
|
521 const Plugin::FeatureList& featureList,
|
Chris@498
|
522 PluginRDFDescription &desc,
|
Chris@498
|
523 QString timelineURI)
|
Chris@498
|
524 {
|
Chris@690
|
525 // SVDEBUG << "RDFFeatureWriter::writeSparseRDF: have " << featureList.size() << " features" << endl;
|
Chris@512
|
526
|
Chris@498
|
527 if (featureList.empty()) return;
|
Chris@498
|
528 QTextStream &stream = *sptr;
|
Chris@498
|
529
|
Chris@498
|
530 bool plain = (m_plain || !desc.haveDescription());
|
Chris@498
|
531
|
Chris@498
|
532 QString outputId = od.identifier.c_str();
|
Chris@498
|
533
|
Chris@498
|
534 // iterate through FeatureLists
|
Chris@498
|
535
|
Chris@498
|
536 for (int i = 0; i < featureList.size(); ++i) {
|
Chris@498
|
537
|
Chris@498
|
538 const Plugin::Feature &feature = featureList[i];
|
Chris@602
|
539 unsigned long featureNumber = m_count++;
|
Chris@498
|
540
|
Chris@498
|
541 stream << ":event_" << featureNumber << " a ";
|
Chris@498
|
542
|
Chris@510
|
543 if (m_fixedEventTypeURI != "") {
|
Chris@510
|
544 stream << m_fixedEventTypeURI << " ;\n";
|
Chris@510
|
545 } else {
|
Chris@510
|
546 QString eventTypeURI = desc.getOutputEventTypeURI(outputId);
|
Chris@510
|
547 if (plain || eventTypeURI == "") {
|
Chris@510
|
548 if (m_syntheticEventTypeURIs.find(transform) !=
|
Chris@510
|
549 m_syntheticEventTypeURIs.end()) {
|
Chris@510
|
550 stream << m_syntheticEventTypeURIs[transform] << " ;\n";
|
Chris@510
|
551 } else {
|
Chris@510
|
552 stream << ":event_type_" << outputId << " ;\n";
|
Chris@510
|
553 }
|
Chris@498
|
554 } else {
|
Chris@510
|
555 stream << "<" << eventTypeURI << "> ;\n";
|
Chris@498
|
556 }
|
Chris@498
|
557 }
|
Chris@498
|
558
|
Chris@498
|
559 QString timestamp = feature.timestamp.toString().c_str();
|
Chris@498
|
560 timestamp.replace(QRegExp("^ +"), "");
|
Chris@498
|
561
|
Chris@498
|
562 if (feature.hasDuration && feature.duration > Vamp::RealTime::zeroTime) {
|
Chris@498
|
563
|
Chris@498
|
564 QString duration = feature.duration.toString().c_str();
|
Chris@498
|
565 duration.replace(QRegExp("^ +"), "");
|
Chris@498
|
566
|
Chris@498
|
567 stream << " event:time [ \n"
|
Chris@498
|
568 << " a tl:Interval ;\n"
|
Chris@498
|
569 << " tl:onTimeLine " << timelineURI << " ;\n"
|
Chris@498
|
570 << " tl:beginsAt \"PT" << timestamp
|
Chris@498
|
571 << "S\"^^xsd:duration ;\n"
|
Chris@498
|
572 << " tl:duration \"PT" << duration
|
Chris@498
|
573 << "S\"^^xsd:duration ;\n"
|
Chris@498
|
574 << " ] ";
|
Chris@498
|
575
|
Chris@498
|
576 } else {
|
Chris@498
|
577
|
Chris@498
|
578 stream << " event:time [ \n"
|
Chris@498
|
579 << " a tl:Instant ;\n" //location of the event in time
|
Chris@498
|
580 << " tl:onTimeLine " << timelineURI << " ;\n"
|
Chris@498
|
581 << " tl:at \"PT" << timestamp
|
Chris@498
|
582 << "S\"^^xsd:duration ;\n ] ";
|
Chris@498
|
583 }
|
Chris@498
|
584
|
Chris@500
|
585 if (transform.getIdentifier() != "") {
|
Chris@500
|
586 stream << ";\n";
|
Chris@500
|
587 stream << " vamp:computed_by " << m_transformURIs[transform] << " ";
|
Chris@500
|
588 }
|
Chris@498
|
589
|
Chris@498
|
590 if (feature.label.length() > 0) {
|
Chris@498
|
591 stream << ";\n";
|
Chris@510
|
592 stream << " rdfs:label \"\"\"" << feature.label.c_str() << "\"\"\" ";
|
Chris@498
|
593 }
|
Chris@498
|
594
|
Chris@498
|
595 if (!feature.values.empty()) {
|
Chris@498
|
596 stream << ";\n";
|
Chris@498
|
597 //!!! named bins?
|
Chris@498
|
598 stream << " af:feature \"" << feature.values[0];
|
Chris@498
|
599 for (int j = 1; j < feature.values.size(); ++j) {
|
Chris@498
|
600 stream << " " << feature.values[j];
|
Chris@498
|
601 }
|
Chris@498
|
602 stream << "\" ";
|
Chris@498
|
603 }
|
Chris@498
|
604
|
Chris@498
|
605 stream << ".\n";
|
Chris@498
|
606 }
|
Chris@498
|
607 }
|
Chris@498
|
608
|
Chris@498
|
609 void
|
Chris@507
|
610 RDFFeatureWriter::writeTrackLevelRDF(QTextStream *sptr,
|
Chris@507
|
611 const Transform &transform,
|
Chris@507
|
612 const Plugin::OutputDescriptor& od,
|
Chris@507
|
613 const Plugin::FeatureList& featureList,
|
Chris@507
|
614 PluginRDFDescription &desc,
|
Chris@507
|
615 QString signalURI)
|
Chris@507
|
616 {
|
Chris@507
|
617 if (featureList.empty()) return;
|
Chris@507
|
618 QTextStream &stream = *sptr;
|
Chris@507
|
619
|
Chris@507
|
620 bool plain = (m_plain || !desc.haveDescription());
|
Chris@507
|
621
|
Chris@507
|
622 QString outputId = od.identifier.c_str();
|
Chris@507
|
623 QString featureUri = desc.getOutputFeatureAttributeURI(outputId);
|
Chris@507
|
624
|
Chris@507
|
625 if (featureUri == "") {
|
Chris@690
|
626 SVDEBUG << "RDFFeatureWriter::writeTrackLevelRDF: ERROR: No feature URI available -- this function should not have been called!" << endl;
|
Chris@507
|
627 return;
|
Chris@507
|
628 }
|
Chris@507
|
629
|
Chris@507
|
630 for (int i = 0; i < featureList.size(); ++i) {
|
Chris@507
|
631
|
Chris@507
|
632 const Plugin::Feature &feature = featureList[i];
|
Chris@507
|
633
|
Chris@507
|
634 if (feature.values.empty()) {
|
Chris@507
|
635
|
Chris@507
|
636 if (feature.label == "") continue;
|
Chris@507
|
637
|
Chris@508
|
638 stream << signalURI << " " << featureUri << " \"\"\""
|
Chris@508
|
639 << feature.label.c_str() << "\"\"\" .\n";
|
Chris@507
|
640
|
Chris@507
|
641 } else {
|
Chris@507
|
642
|
Chris@507
|
643 stream << signalURI << " " << featureUri << " \""
|
Chris@507
|
644 << feature.values[0] << "\"^^xsd:float .\n";
|
Chris@507
|
645 }
|
Chris@507
|
646 }
|
Chris@507
|
647 }
|
Chris@507
|
648
|
Chris@507
|
649 void
|
Chris@498
|
650 RDFFeatureWriter::writeDenseRDF(QTextStream *sptr,
|
Chris@498
|
651 const Transform &transform,
|
Chris@498
|
652 const Plugin::OutputDescriptor& od,
|
Chris@498
|
653 const Plugin::FeatureList& featureList,
|
Chris@498
|
654 PluginRDFDescription &desc,
|
Chris@498
|
655 QString signalURI,
|
Chris@498
|
656 QString timelineURI)
|
Chris@498
|
657 {
|
Chris@498
|
658 if (featureList.empty()) return;
|
Chris@498
|
659
|
Chris@498
|
660 StringTransformPair sp(signalURI, transform);
|
Chris@498
|
661
|
Chris@498
|
662 if (m_openDenseFeatures.find(sp) == m_openDenseFeatures.end()) {
|
Chris@498
|
663
|
Chris@498
|
664 StreamBuffer b(sptr, "");
|
Chris@498
|
665 m_openDenseFeatures[sp] = b;
|
Chris@498
|
666
|
Chris@498
|
667 QString &str(m_openDenseFeatures[sp].second);
|
Chris@498
|
668 QTextStream stream(&str);
|
Chris@498
|
669
|
Chris@498
|
670 bool plain = (m_plain || !desc.haveDescription());
|
Chris@498
|
671 QString outputId = od.identifier.c_str();
|
Chris@498
|
672
|
Chris@602
|
673 unsigned long featureNumber = m_count++;
|
Chris@498
|
674
|
Chris@498
|
675 // need to write out feature timeline map -- for this we need
|
Chris@498
|
676 // the sample rate, window length and hop size from the
|
Chris@498
|
677 // transform
|
Chris@498
|
678
|
Chris@498
|
679 stream << "\n:feature_timeline_" << featureNumber << " a tl:DiscreteTimeLine .\n\n";
|
Chris@498
|
680
|
Chris@498
|
681 size_t stepSize = transform.getStepSize();
|
Chris@498
|
682 if (stepSize == 0) {
|
Chris@498
|
683 cerr << "RDFFeatureWriter: INTERNAL ERROR: writing dense features without having set the step size properly!" << endl;
|
Chris@498
|
684 return;
|
Chris@498
|
685 }
|
Chris@498
|
686
|
Chris@498
|
687 size_t blockSize = transform.getBlockSize();
|
Chris@498
|
688 if (blockSize == 0) {
|
Chris@498
|
689 cerr << "RDFFeatureWriter: INTERNAL ERROR: writing dense features without having set the block size properly!" << endl;
|
Chris@498
|
690 return;
|
Chris@498
|
691 }
|
Chris@498
|
692
|
Chris@498
|
693 float sampleRate = transform.getSampleRate();
|
Chris@498
|
694 if (sampleRate == 0.f) {
|
Chris@498
|
695 cerr << "RDFFeatureWriter: INTERNAL ERROR: writing dense features without having set the sample rate properly!" << endl;
|
Chris@498
|
696 return;
|
Chris@498
|
697 }
|
Chris@498
|
698
|
Chris@498
|
699 stream << ":feature_timeline_map_" << featureNumber
|
Chris@498
|
700 << " a tl:UniformSamplingWindowingMap ;\n"
|
Chris@498
|
701 << " tl:rangeTimeLine :feature_timeline_" << featureNumber << " ;\n"
|
Chris@498
|
702 << " tl:domainTimeLine " << timelineURI << " ;\n"
|
Chris@498
|
703 << " tl:sampleRate \"" << int(sampleRate) << "\"^^xsd:int ;\n"
|
Chris@498
|
704 << " tl:windowLength \"" << blockSize << "\"^^xsd:int ;\n"
|
Chris@498
|
705 << " tl:hopSize \"" << stepSize << "\"^^xsd:int .\n\n";
|
Chris@498
|
706
|
Chris@498
|
707 stream << signalURI << " af:signal_feature :feature_"
|
Chris@498
|
708 << featureNumber << " ." << endl << endl;
|
Chris@498
|
709
|
Chris@498
|
710 stream << ":feature_" << featureNumber << " a ";
|
Chris@498
|
711
|
Chris@498
|
712 QString signalTypeURI = desc.getOutputSignalTypeURI(outputId);
|
Chris@498
|
713 if (plain || signalTypeURI == "") {
|
Chris@498
|
714 if (m_syntheticSignalTypeURIs.find(transform) !=
|
Chris@498
|
715 m_syntheticSignalTypeURIs.end()) {
|
Chris@498
|
716 stream << m_syntheticSignalTypeURIs[transform] << " ;\n";
|
Chris@498
|
717 } else {
|
Chris@498
|
718 stream << ":signal_type_" << outputId << " ;\n";
|
Chris@498
|
719 }
|
Chris@498
|
720 } else {
|
Chris@587
|
721 stream << "<" << signalTypeURI << "> ;\n";
|
Chris@498
|
722 }
|
Chris@498
|
723
|
Chris@498
|
724 stream << " mo:time ["
|
Chris@498
|
725 << "\n a tl:Interval ;"
|
Chris@498
|
726 << "\n tl:onTimeLine :feature_timeline_" << featureNumber << " ;";
|
Chris@498
|
727
|
Chris@498
|
728 RealTime startrt = transform.getStartTime();
|
Chris@498
|
729 RealTime durationrt = transform.getDuration();
|
Chris@498
|
730
|
Chris@498
|
731 int start = RealTime::realTime2Frame(startrt, sampleRate) / stepSize;
|
Chris@498
|
732 int duration = RealTime::realTime2Frame(durationrt, sampleRate) / stepSize;
|
Chris@498
|
733
|
Chris@498
|
734 if (start != 0) {
|
Chris@498
|
735 stream << "\n tl:start \"" << start << "\"^^xsd:int ;";
|
Chris@498
|
736 }
|
Chris@498
|
737 if (duration != 0) {
|
Chris@498
|
738 stream << "\n tl:duration \"" << duration << "\"^^xsd:int ;";
|
Chris@498
|
739 }
|
Chris@498
|
740
|
Chris@498
|
741 stream << "\n ] ;\n";
|
Chris@498
|
742
|
Chris@584
|
743 if (transform.getIdentifier() != "") {
|
Chris@584
|
744 stream << " vamp:computed_by " << m_transformURIs[transform] << " ;\n";
|
Chris@584
|
745 }
|
Chris@584
|
746
|
Chris@498
|
747 if (od.hasFixedBinCount) {
|
Chris@498
|
748 // We only know the height, so write the width as zero
|
Chris@498
|
749 stream << " af:dimensions \"" << od.binCount << " 0\" ;\n";
|
Chris@498
|
750 }
|
Chris@498
|
751
|
Chris@498
|
752 stream << " af:value \"";
|
Chris@498
|
753 }
|
Chris@498
|
754
|
Chris@498
|
755 QString &str = m_openDenseFeatures[sp].second;
|
Chris@498
|
756 QTextStream stream(&str);
|
Chris@498
|
757
|
Chris@498
|
758 for (int i = 0; i < featureList.size(); ++i) {
|
Chris@498
|
759
|
Chris@498
|
760 const Plugin::Feature &feature = featureList[i];
|
Chris@498
|
761
|
Chris@498
|
762 for (int j = 0; j < feature.values.size(); ++j) {
|
Chris@498
|
763 stream << feature.values[j] << " ";
|
Chris@498
|
764 }
|
Chris@498
|
765 }
|
Chris@498
|
766 }
|
Chris@498
|
767
|
Chris@498
|
768 void RDFFeatureWriter::finish()
|
Chris@498
|
769 {
|
Chris@690
|
770 // SVDEBUG << "RDFFeatureWriter::finish()" << endl;
|
Chris@498
|
771
|
Chris@498
|
772 // close any open dense feature literals
|
Chris@498
|
773
|
Chris@498
|
774 for (map<StringTransformPair, StreamBuffer>::iterator i =
|
Chris@498
|
775 m_openDenseFeatures.begin();
|
Chris@498
|
776 i != m_openDenseFeatures.end(); ++i) {
|
Chris@690
|
777 // SVDEBUG << "closing a stream" << endl;
|
Chris@498
|
778 StreamBuffer &b = i->second;
|
Chris@498
|
779 *(b.first) << b.second << "\" ." << endl;
|
Chris@498
|
780 }
|
Chris@498
|
781
|
Chris@498
|
782 m_openDenseFeatures.clear();
|
Chris@530
|
783 m_startedStreamTransforms.clear();
|
Chris@530
|
784
|
Chris@530
|
785 FileFeatureWriter::finish();
|
Chris@498
|
786 }
|
Chris@498
|
787
|
Chris@498
|
788
|