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