view native/vampyhost.cpp @ 139:aa96f69e2f14

Add support for process timestamp method to low-level api

/* -*- c-basic-offset: 4 indent-tabs-mode: nil -*-  vi:set ts=8 sts=4 sw=4: */

/*
    VampyHost

    Use Vamp audio analysis plugins in Python

    Gyorgy Fazekas and Chris Cannam
    Centre for Digital Music, Queen Mary, University of London
    Copyright 2008-2015 Queen Mary, University of London
  
    Permission is hereby granted, free of charge, to any person
    obtaining a copy of this software and associated documentation
    files (the "Software"), to deal in the Software without
    restriction, including without limitation the rights to use, copy,
    modify, merge, publish, distribute, sublicense, and/or sell copies
    of the Software, and to permit persons to whom the Software is
    furnished to do so, subject to the following conditions:

    The above copyright notice and this permission notice shall be
    included in all copies or substantial portions of the Software.

    THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
    EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
    MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
    NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS BE LIABLE FOR
    ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF
    CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
    WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

    Except as contained in this notice, the names of the Centre for
    Digital Music; Queen Mary, University of London; and the authors
    shall not be used in advertising or otherwise to promote the sale,
    use or other dealings in this Software without prior written
    authorization.
*/

// include for python extension module: must be first
#include <Python.h>

// define a unique API pointer 
#define PY_ARRAY_UNIQUE_SYMBOL VAMPYHOST_ARRAY_API
#define NPY_NO_DEPRECATED_API NPY_1_7_API_VERSION
#include "numpy/arrayobject.h"

#include "PyRealTime.h"
#include "PyPluginObject.h"

#include "vamp-hostsdk/PluginHostAdapter.h"
#include "vamp-hostsdk/PluginChannelAdapter.h"
#include "vamp-hostsdk/PluginInputDomainAdapter.h"
#include "vamp-hostsdk/PluginLoader.h"

#include "VectorConversion.h"
#include "StringConversion.h"
#include "PyRealTime.h"

#include <iostream>
#include <string>

#include <cmath>

#if (VAMP_SDK_MAJOR_VERSION != 2 || VAMP_SDK_MINOR_VERSION < 6)
#error "Vamp plugin SDK v2, version 2.6 or newer required"
#endif

using namespace std;
using namespace Vamp;
using namespace Vamp::HostExt;

static PyObject *
list_plugins(PyObject *self, PyObject *)
{
    PluginLoader *loader = PluginLoader::getInstance();
    vector<PluginLoader::PluginKey> plugins = loader->listPlugins();
    VectorConversion conv;
    return conv.PyValue_From_StringVector(plugins);
}

static PyObject *
get_plugin_path(PyObject *self, PyObject *)
{
    vector<string> path = PluginHostAdapter::getPluginPath();
    VectorConversion conv;
    return conv.PyValue_From_StringVector(path);
}

static string toPluginKey(PyObject *pyPluginKey)
{
    // convert to stl string
    string pluginKey(StringConversion().py2string(pyPluginKey));

    // check pluginKey validity
    string::size_type ki = pluginKey.find(':');
    if (ki == string::npos) {
        PyErr_SetString(PyExc_TypeError,
                        "Plugin key must be of the form library:identifier");
        return "";
    }

    return pluginKey;
}

static PyObject *
get_library_for(PyObject *self, PyObject *args)
{
    PyObject *pyPluginKey;

    if (!PyArg_ParseTuple(args,
#if (PY_MAJOR_VERSION >= 3)
                          "U",
#else
                          "S",
#endif
                          &pyPluginKey)) {
        PyErr_SetString(PyExc_TypeError,
                        "get_library_for() takes plugin key (string) argument");
        return 0; }

    string pluginKey = toPluginKey(pyPluginKey);
    if (pluginKey == "") return 0;
    
    PluginLoader *loader = PluginLoader::getInstance();
    string path = loader->getLibraryPathForPlugin(pluginKey);
    PyObject *pyPath = StringConversion().string2py(path.c_str());
    return pyPath;
}

static PyObject *
get_category_of(PyObject *self, PyObject *args)
{
    PyObject *pyPluginKey;

    if (!PyArg_ParseTuple(args,
#if (PY_MAJOR_VERSION >= 3)
                          "U",
#else
                          "S",
#endif
                          &pyPluginKey)) {
        PyErr_SetString(PyExc_TypeError,
                        "get_category_of() takes plugin key (string) argument");
        return 0; }

    string pluginKey = toPluginKey(pyPluginKey);
    if (pluginKey == "") return 0;

    PluginLoader *loader = PluginLoader::getInstance();
    PluginLoader::PluginCategoryHierarchy
        category = loader->getPluginCategory(pluginKey);

    VectorConversion conv;
    return conv.PyValue_From_StringVector(category);
}

static PyObject *
get_outputs_of(PyObject *self, PyObject *args)
{
    PyObject *pyPluginKey;

    if (!PyArg_ParseTuple(args,
#if (PY_MAJOR_VERSION >= 3)
                          "U",
#else
                          "S",
#endif
                          &pyPluginKey)) {
        PyErr_SetString(PyExc_TypeError,
                        "get_outputs_of() takes plugin key (string) argument");
        return 0; }

    Plugin::OutputList outputs;

    string pluginKey = toPluginKey(pyPluginKey);
    if (pluginKey == "") return 0;

    PluginLoader *loader = PluginLoader::getInstance();

    Plugin *plugin = loader->loadPlugin(pluginKey, 48000, 0);
    if (!plugin) {
        string pyerr("Failed to load plugin: "); pyerr += pluginKey;
        PyErr_SetString(PyExc_TypeError, pyerr.c_str());
        return 0;
    }

    outputs = plugin->getOutputDescriptors();

    PyObject *pyList = PyList_New(outputs.size());

    for (size_t i = 0; i < outputs.size(); ++i) {
        PyObject *pyOutputId =
            StringConversion().string2py(outputs[i].identifier.c_str());
        PyList_SET_ITEM(pyList, i, pyOutputId);
    }

    return pyList;
}

static PyObject *
load_plugin(PyObject *self, PyObject *args)
{
    PyObject *pyPluginKey;
    float inputSampleRate;
    ssize_t adapterFlags;

    if (!PyArg_ParseTuple(args,
#if (PY_MAJOR_VERSION >= 3)
                          "Ufn",
#else
                          "Sfn",
#endif
                          &pyPluginKey,
                          &inputSampleRate,
                          &adapterFlags)) {
        PyErr_SetString(PyExc_TypeError,
                        "load_plugin() takes plugin key (string), sample rate (float), and adapter flags (int) arguments");
        return 0; }

    string pluginKey = toPluginKey(pyPluginKey);
    if (pluginKey == "") return 0;

    PluginLoader *loader = PluginLoader::getInstance();

    Plugin *plugin = loader->loadPlugin(pluginKey,
                                        inputSampleRate,
                                        adapterFlags);
    if (!plugin) {
        string pyerr("Failed to load plugin: "); pyerr += pluginKey;
        PyErr_SetString(PyExc_TypeError,pyerr.c_str());
        return 0;
    }

    return PyPluginObject_From_Plugin(plugin);
}

static PyObject *
frame_to_realtime(PyObject *self, PyObject *args)
{
    ssize_t frame;
    float rate;

    if (!PyArg_ParseTuple(args, "nf",
                          &frame,
                          &rate)) {
        PyErr_SetString(PyExc_TypeError,
                        "frame_to_realtime() takes frame (int) and sample rate (float) arguments");
        return 0; }

    RealTime rt = RealTime::frame2RealTime(frame, rate);
    return PyRealTime_FromRealTime(rt);
}
    
// module methods table
static PyMethodDef vampyhost_methods[] = {
    
    {"list_plugins", list_plugins, METH_NOARGS,
     "list_plugins() -> Return a list of the plugin keys of all installed Vamp plugins." },

    {"get_plugin_path", get_plugin_path, METH_NOARGS,
     "get_plugin_path() -> Return a list of directories which will be searched for Vamp plugins. This may be changed by setting the VAMP_PATH environment variable."},

    {"get_category_of", get_category_of, METH_VARARGS,
     "get_category_of(plugin_key) -> Return the category of a Vamp plugin given its key, if known. The category is expressed as a list of nested types from least to most specific."},

    {"get_library_for", get_library_for, METH_VARARGS,
     "get_library_for(plugin_key) -> Return the file path of the Vamp plugin library in which the given plugin key is found, or an empty string if the plugin is not installed."},

    {"get_outputs_of", get_outputs_of, METH_VARARGS,
     "get_outputs_of(plugin_key) -> Return a list of the output identifiers of the plugin with the given key, if installed."},

    {"load_plugin", load_plugin, METH_VARARGS,
     "load_plugin(plugin_key, sample_rate, adapter_flags) -> Load the plugin that has the given key, if installed, and return the plugin object. The adapter_flags may be ADAPT_NONE, any additive combination of ADAPT_INPUT_DOMAIN, ADAPT_CHANNEL_COUNT, ADAPT_BUFFER_SIZE, or one of the special flags ADAPT_ALL_SAFE or ADAPT_ALL. If in doubt, pass ADAPT_ALL_SAFE. See the Vamp SDK documentation for the PluginLoader class for more details."},

    {"frame_to_realtime", frame_to_realtime, METH_VARARGS,
     "frame_to_realtime() -> Convert sample frame number and sample rate to a RealTime object." },

    {0, 0}              /* sentinel */
};

static int
setint(PyObject *d, const char *name, int value)
{
    PyObject *v;
    int err;
#if (PY_MAJOR_VERSION >= 3)
    v = PyLong_FromLong((long)value);
#else
    v = PyInt_FromLong((long)value);
#endif
    err = PyDict_SetItemString(d, name, v);
    Py_XDECREF(v);
    return err;
}

/* Initialization function for the module (*must* be called initxx) */

#if (PY_MAJOR_VERSION >= 3)
static struct PyModuleDef vampyhostdef = {
    PyModuleDef_HEAD_INIT,
    "vampyhost",
    "Load and run Vamp audio analysis plugins.",
    -1,
    vampyhost_methods,
    0, 0, 0, 0
};
#else
PyDoc_STRVAR(module_doc, "Load and run Vamp audio analysis plugins.");
#endif

// module initialization (includes extern C {...} as necessary)
PyMODINIT_FUNC
#if (PY_MAJOR_VERSION >= 3)
PyInit_vampyhost(void)
#else
initvampyhost(void)
#endif
{
    PyObject *m;

#if (PY_MAJOR_VERSION >= 3)
#define GOOD_RETURN m
#define BAD_RETURN 0
#else
#define GOOD_RETURN
#define BAD_RETURN
#endif
    
    if (PyType_Ready(&RealTime_Type) < 0) return BAD_RETURN;
    if (PyType_Ready(&Plugin_Type) < 0) return BAD_RETURN;

#if (PY_MAJOR_VERSION >= 3)
    m = PyModule_Create(&vampyhostdef);
#else
    m = Py_InitModule3("vampyhost", vampyhost_methods, module_doc);
#endif
    
    if (!m) {
        cerr << "ERROR: initvampyhost: Failed to initialise module" << endl;
        return BAD_RETURN;
    }

    import_array();

    PyModule_AddObject(m, "RealTime", (PyObject *)&RealTime_Type);
    PyModule_AddObject(m, "Plugin", (PyObject *)&Plugin_Type);

    // Some enum types
    PyObject *dict = PyModule_GetDict(m);
    if (!dict) {
        cerr << "ERROR: initvampyhost: Failed to obtain module dictionary" << endl;
        return BAD_RETURN;
    }

    if (setint(dict, "ONE_SAMPLE_PER_STEP",
               Plugin::OutputDescriptor::OneSamplePerStep) < 0 ||
        setint(dict, "FIXED_SAMPLE_RATE",
               Plugin::OutputDescriptor::FixedSampleRate) < 0 ||
        setint(dict, "VARIABLE_SAMPLE_RATE",
               Plugin::OutputDescriptor::VariableSampleRate) < 0 ||
        setint(dict, "TIME_DOMAIN",
               Plugin::TimeDomain) < 0 ||
        setint(dict, "FREQUENCY_DOMAIN",
               Plugin::FrequencyDomain) < 0 ||
        setint(dict, "ADAPT_NONE",
               0) < 0 ||
        setint(dict, "ADAPT_INPUT_DOMAIN",
               PluginLoader::ADAPT_INPUT_DOMAIN) < 0 ||
        setint(dict, "ADAPT_CHANNEL_COUNT",
               PluginLoader::ADAPT_CHANNEL_COUNT) < 0 ||
        setint(dict, "ADAPT_BUFFER_SIZE",
               PluginLoader::ADAPT_BUFFER_SIZE) < 0 ||
        setint(dict, "ADAPT_ALL_SAFE",
               PluginLoader::ADAPT_ALL_SAFE) < 0 ||
        setint(dict, "ADAPT_ALL",
               PluginLoader::ADAPT_ALL) < 0 ||
        setint(dict, "SHIFT_TIMESTAMP",
               PluginInputDomainAdapter::ShiftTimestamp) < 0 ||
        setint(dict, "SHIFT_DATA",
               PluginInputDomainAdapter::ShiftData) < 0 ||
        setint(dict, "NO_SHIFT",
               PluginInputDomainAdapter::NoShift) < 0) {
        cerr << "ERROR: initvampyhost: Failed to add enums to module dictionary" << endl;
        return BAD_RETURN;
    }

    return GOOD_RETURN;
}