/* This file is part of Om. Copyright (C) 2006 Dave Robillard. * * Om 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. * * Om is distributed in the hope that it will be useful, but WITHOUT ANY * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS * FOR A PARTICULAR PURPOSE. See the GNU General Public License for details. * * You should have received a copy of the GNU General Public License along * with this program; if not, write to the Free Software Foundation, Inc., * 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA */ #include "OSCEngineInterface.h" #include "interface/ClientKey.h" namespace LibOmClient { /** Note the sending port is implicitly set by liblo, lo_send by default sends * from the most recently created server, so create the OSC listener before * this to have it all happen on the same port. Yeah, this is a big magic :/ */ OSCEngineInterface::OSCEngineInterface(const string& engine_url) : _engine_url(engine_url) , _engine_addr(lo_address_new_from_url(engine_url.c_str())) , _id(0) { } OSCEngineInterface::~OSCEngineInterface() { lo_address_free(_engine_addr); } /* *** EngineInterface implementation below here *** */ /** Register with the engine via OSC. * * Note that this does not actually use 'key', since the engine creates * it's own key for OSC clients (namely the incoming URL), for NAT * traversal. It is a parameter to remain compatible with EngineInterface. */ void OSCEngineInterface::register_client(ClientKey key, CountedPtr client) { // FIXME: use parameters.. er, somehow. assert(_engine_addr); lo_send(_engine_addr, "/om/engine/register_client", "i", next_id()); } void OSCEngineInterface::unregister_client(ClientKey key) { assert(_engine_addr); lo_send(_engine_addr, "/om/engine/unregister_client", "i", next_id()); } // Engine commands void OSCEngineInterface::load_plugins() { assert(_engine_addr); lo_send(_engine_addr, "/om/engine/load_plugins", "i", next_id()); } void OSCEngineInterface::activate() { assert(_engine_addr); lo_send(_engine_addr, "/om/engine/activate", "i", next_id()); } void OSCEngineInterface::deactivate() { assert(_engine_addr); lo_send(_engine_addr, "/om/engine/deactivate", "i", next_id()); } void OSCEngineInterface::quit() { assert(_engine_addr); lo_send(_engine_addr, "/om/engine/quit", "i", next_id()); } // Object commands void OSCEngineInterface::create_patch(const string& path, uint32_t poly) { assert(_engine_addr); lo_send(_engine_addr, "/om/synth/create_patch", "isi", next_id(), path.c_str(), poly); } void OSCEngineInterface::create_port(const string& path, const string& data_type, bool direction) { assert(_engine_addr); lo_send(_engine_addr, "/om/synth/create_port", "issi", next_id(), path.c_str(), data_type.c_str(), (direction ? 1 : 0)); } void OSCEngineInterface::create_node(const string& path, const string& plugin_type, const string& plugin_uri, bool polyphonic) { assert(_engine_addr); lo_send(_engine_addr, "/om/synth/create_node", "isssi", next_id(), path.c_str(), plugin_type.c_str(), plugin_uri.c_str(), (polyphonic ? 1 : 0)); } void OSCEngineInterface::rename(const string& old_path, const string& new_name) { assert(_engine_addr); lo_send(_engine_addr, "/om/synth/rename", "iss", next_id(), old_path.c_str(), new_name.c_str()); } void OSCEngineInterface::destroy(const string& path) { assert(_engine_addr); lo_send(_engine_addr, "/om/synth/destroy", "is", next_id(), path.c_str()); } void OSCEngineInterface::clear_patch(const string& patch_path) { assert(_engine_addr); lo_send(_engine_addr, "/om/synth/clear_patch", "is", next_id(), patch_path.c_str()); } void OSCEngineInterface::enable_patch(const string& patch_path) { assert(_engine_addr); lo_send(_engine_addr, "/om/synth/enable_patch", "is", next_id(), patch_path.c_str()); } void OSCEngineInterface::disable_patch(const string& patch_path) { assert(_engine_addr); lo_send(_engine_addr, "/om/synth/disable_patch", "is", next_id(), patch_path.c_str()); } void OSCEngineInterface::connect(const string& src_port_path, const string& dst_port_path) { assert(_engine_addr); lo_send(_engine_addr, "/om/synth/connect", "iss", next_id(), src_port_path.c_str(), dst_port_path.c_str()); } void OSCEngineInterface::disconnect(const string& src_port_path, const string& dst_port_path) { assert(_engine_addr); lo_send(_engine_addr, "/om/synth/disconnect", "iss", next_id(), src_port_path.c_str(), dst_port_path.c_str()); } void OSCEngineInterface::disconnect_all(const string& node_path) { assert(_engine_addr); lo_send(_engine_addr, "/om/synth/disconnect_all", "is", next_id(), node_path.c_str()); } void OSCEngineInterface::set_port_value(const string& port_path, float val) { assert(_engine_addr); lo_send(_engine_addr, "/om/synth/set_port_value", "isf", next_id(), port_path.c_str(), val); } void OSCEngineInterface::set_port_value(const string& port_path, uint32_t voice, float val) { assert(_engine_addr); lo_send(_engine_addr, "/om/synth/set_port_value", "isif", next_id(), port_path.c_str(), voice, val); } void OSCEngineInterface::set_port_value_queued(const string& port_path, float val) { assert(_engine_addr); lo_send(_engine_addr, "/om/synth/set_port_value_queued", "isf", next_id(), port_path.c_str(), val); } void OSCEngineInterface::set_program(const string& node_path, uint32_t bank, uint32_t program) { assert(_engine_addr); lo_send(_engine_addr, (string("/dssi") + node_path + "/program").c_str(), "ii", bank, program); } void OSCEngineInterface::midi_learn(const string& node_path) { assert(_engine_addr); lo_send(_engine_addr, "/om/synth/midi_learn", "is", next_id(), node_path.c_str()); } void OSCEngineInterface::set_metadata(const string& obj_path, const string& predicate, const string& value) { assert(_engine_addr); lo_send(_engine_addr, "/om/metadata/set", "isss", next_id(), obj_path.c_str(), predicate.c_str(), value.c_str()); } // Requests // void OSCEngineInterface::ping() { assert(_engine_addr); lo_send(_engine_addr, "/om/ping", "i", next_id()); } void OSCEngineInterface::request_port_value(const string& port_path) { assert(_engine_addr); lo_send(_engine_addr, "/om/request/port_value", "is", next_id(), port_path.c_str()); } void OSCEngineInterface::request_plugins() { assert(_engine_addr); lo_send(_engine_addr, "/om/request/plugins", "i", next_id()); } void OSCEngineInterface::request_all_objects() { assert(_engine_addr); lo_send(_engine_addr, "/om/request/all_objects", "i", next_id()); } } // namespace LibOmClient