view framework/OSCScript.h @ 783:4d10365aa6a9

Pull across a fix from the MATCH code

/* -*- 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>

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;
};

#endif