diff options
author | David Robillard <d@drobilla.net> | 2007-10-08 16:36:54 +0000 |
---|---|---|
committer | David Robillard <d@drobilla.net> | 2007-10-08 16:36:54 +0000 |
commit | d9d735f5fcac1d0f9bbb9eaf5896d5b5b2ac74df (patch) | |
tree | 7eab303f1c8cdddeb98b2f87b850b4a55a66fbdc /src/libs/client | |
parent | 763bba9de67fb1bd06658a0bac91440727ee5a51 (diff) | |
download | ingen-d9d735f5fcac1d0f9bbb9eaf5896d5b5b2ac74df.tar.gz ingen-d9d735f5fcac1d0f9bbb9eaf5896d5b5b2ac74df.tar.bz2 ingen-d9d735f5fcac1d0f9bbb9eaf5896d5b5b2ac74df.zip |
Move Serializer from client lib to serialisation lib (engine or client side serialisation, woot).
git-svn-id: http://svn.drobilla.net/lad/ingen@848 a436a847-0d15-0410-975c-d299462d15a1
Diffstat (limited to 'src/libs/client')
-rw-r--r-- | src/libs/client/Makefile.am | 2 | ||||
-rw-r--r-- | src/libs/client/Serializer.cpp | 434 | ||||
-rw-r--r-- | src/libs/client/Serializer.hpp | 96 |
3 files changed, 0 insertions, 532 deletions
diff --git a/src/libs/client/Makefile.am b/src/libs/client/Makefile.am index 9ee32b84..2106c6db 100644 --- a/src/libs/client/Makefile.am +++ b/src/libs/client/Makefile.am @@ -42,8 +42,6 @@ libingen_client_la_SOURCES = \ PortModel.cpp \ PortModel.hpp \ PresetModel.hpp \ - Serializer.cpp \ - Serializer.hpp \ SigClientInterface.hpp \ Store.cpp \ Store.hpp \ diff --git a/src/libs/client/Serializer.cpp b/src/libs/client/Serializer.cpp deleted file mode 100644 index e15ce4dc..00000000 --- a/src/libs/client/Serializer.cpp +++ /dev/null @@ -1,434 +0,0 @@ -/* This file is part of Ingen. - * Copyright (C) 2007 Dave Robillard <http://drobilla.net> - * - * Ingen 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. - * - * Ingen 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 <algorithm> -#include <cassert> -#include <cmath> -#include <cstdlib> // atof -#include <cstring> -#include <fstream> -#include <iostream> -#include <locale.h> -#include <stdexcept> -#include <string> -#include <utility> // pair, make_pair -#include <vector> -#include <raul/Atom.hpp> -#include <raul/AtomRedland.hpp> -#include <raul/Path.hpp> -#include <raul/RDFModel.hpp> -#include <raul/RDFNode.hpp> -#include <raul/RDFWorld.hpp> -#include <raul/TableImpl.hpp> -#include "interface/EngineInterface.hpp" -#include "interface/Plugin.hpp" -#include "interface/Patch.hpp" -#include "interface/Node.hpp" -#include "interface/Port.hpp" -#include "interface/Connection.hpp" -#include "Serializer.hpp" - -using namespace std; -using namespace Raul; -using namespace Raul::RDF; -using namespace Ingen; -using namespace Ingen::Shared; - -namespace Ingen { -namespace Client { - - -Serializer::Serializer(Raul::RDF::World& world) - : _world(world) -{ -} - -void -Serializer::to_file(SharedPtr<GraphObject> object, const string& filename) -{ - _root_object = object; - start_to_filename(filename); - serialize(object); - finish(); -} - - -string -Serializer::to_string(SharedPtr<GraphObject> object) -{ - _root_object = object; - start_to_string(); - serialize(object); - return finish(); -} - - -/** Begin a serialization to a file. - * - * This must be called before any serializing methods. - */ -void -Serializer::start_to_filename(const string& filename) -{ - setlocale(LC_NUMERIC, "C"); - - _base_uri = "file://" + filename; - _model = new RDF::Model(_world); - _mode = TO_FILE; -} - - -/** Begin a serialization to a string. - * - * This must be called before any serializing methods. - * - * The results of the serialization will be returned by the finish() method after - * the desired objects have been serialized. - */ -void -Serializer::start_to_string() -{ - setlocale(LC_NUMERIC, "C"); - - _base_uri = ""; - _model = new RDF::Model(_world); - _mode = TO_STRING; -} - - -/** Finish a serialization. - * - * If this was a serialization to a string, the serialization output - * will be returned, otherwise the empty string is returned. - */ -string -Serializer::finish() -{ - string ret = ""; - - if (_mode == TO_FILE) - _model->serialize_to_file(_base_uri); - else - ret = _model->serialize_to_string(); - - _base_uri = ""; - _node_map.clear(); - - return ret; -} - - -/** Convert a path to an RDF blank node ID for serializing. - */ -RDF::Node -Serializer::path_to_node_id(const Path& path) -{ - assert(_model); - /*string ret = path.substr(1); - - for (size_t i=0; i < ret.length(); ++i) { - if (ret[i] == '/') - ret[i] = '_'; - } - - return RDF::Node(Node::BLANK, ret); - */ - - NodeMap::iterator i = _node_map.find(path); - if (i != _node_map.end()) { - assert(i->second); - assert(i->second.get_node()); - return i->second; - } else { - RDF::Node id = _world.blank_id(); - assert(id); - _node_map[path] = id; - return id; - } -} - - -#if 0 -/** Searches for the filename passed in the path, returning the full - * path of the file, or the empty string if not found. - * - * This function tries to be as friendly a black box as possible - if the path - * passed is an absolute path and the file is found there, it will return - * that path, etc. - * - * additional_path is a list (colon delimeted as usual) of additional - * directories to look in. ie the directory the parent patch resides in would - * be a good idea to pass as additional_path, in the case of a subpatch. - */ -string -Serializer::find_file(const string& filename, const string& additional_path) -{ - string search_path = additional_path + ":" + _patch_search_path; - - // Try to open the raw filename first - std::ifstream is(filename.c_str(), std::ios::in); - if (is.good()) { - is.close(); - return filename; - } - - string directory; - string full_patch_path = ""; - - while (search_path != "") { - directory = search_path.substr(0, search_path.find(':')); - if (search_path.find(':') != string::npos) - search_path = search_path.substr(search_path.find(':')+1); - else - search_path = ""; - - full_patch_path = directory +"/"+ filename; - - std::ifstream is; - is.open(full_patch_path.c_str(), std::ios::in); - - if (is.good()) { - is.close(); - return full_patch_path; - } else { - cerr << "[Serializer] Could not find patch file " << full_patch_path << endl; - } - } - - return ""; -} -#endif - -void -Serializer::serialize(SharedPtr<GraphObject> object) throw (std::logic_error) -{ - if (!_model) - throw std::logic_error("serialize called without serialization in progress"); - - SharedPtr<Shared::Patch> patch = PtrCast<Shared::Patch>(object); - if (patch) { - serialize_patch(patch); - return; - } - - SharedPtr<Shared::Node> node = PtrCast<Shared::Node>(object); - if (node) { - serialize_node(node, path_to_node_id(node->path())); - return; - } - - SharedPtr<Shared::Port> port = PtrCast<Shared::Port>(object); - if (port) { - serialize_port(port.get(), path_to_node_id(port->path())); - return; - } - - cerr << "[Serializer] WARNING: Unsupported object type, " - << object->path() << " not serialized." << endl; -} - - -RDF::Node -Serializer::patch_path_to_rdf_id(const Path& path) -{ - if (path == _root_object->path()) { - return RDF::Node(_model->world(), RDF::Node::RESOURCE, _base_uri); - } else { - assert(path.length() > _root_object->path().length()); - return RDF::Node(_model->world(), RDF::Node::RESOURCE, - _base_uri + string("#") + path.substr(_root_object->path().length())); - } -} - - -void -Serializer::serialize_patch(SharedPtr<Shared::Patch> patch) -{ - assert(_model); - - const RDF::Node patch_id = patch_path_to_rdf_id(patch->path()); - - _model->add_statement( - patch_id, - "rdf:type", - RDF::Node(_model->world(), RDF::Node::RESOURCE, "http://drobilla.net/ns/ingen#Patch")); - - if (patch->path().name().length() > 0) { - _model->add_statement( - patch_id, "ingen:name", - Atom(patch->path().name().c_str())); - } - - _model->add_statement( - patch_id, - "ingen:polyphony", - Atom((int)patch->internal_polyphony())); - - _model->add_statement( - patch_id, - "ingen:enabled", - Atom(patch->enabled())); - - for (GraphObject::MetadataMap::const_iterator m = patch->metadata().begin(); - m != patch->metadata().end(); ++m) { - if (m->first.find(":") != string::npos) { - _model->add_statement( - patch_id, - m->first.c_str(), - m->second); - } - } - - for (GraphObject::const_iterator n = patch->children_begin(); n != patch->children_end(); ++n) { - SharedPtr<Shared::Patch> patch = PtrCast<Shared::Patch>(n->second); - SharedPtr<Shared::Node> node = PtrCast<Shared::Node>(n->second); - if (patch) { - _model->add_statement(patch_id, "ingen:node", patch_path_to_rdf_id(patch->path())); - serialize_patch(patch); - } else if (node) { - const RDF::Node node_id = path_to_node_id(n->second->path()); - _model->add_statement(patch_id, "ingen:node", node_id); - serialize_node(node, node_id); - } - } - - for (uint32_t i=0; i < patch->num_ports(); ++i) { - Port* p = patch->port(i); - const RDF::Node port_id = path_to_node_id(p->path()); - _model->add_statement(patch_id, "ingen:port", port_id); - serialize_port(p, port_id); - } - - for (Shared::Patch::Connections::const_iterator c = patch->connections().begin(); - c != patch->connections().end(); ++c) { - serialize_connection(*c); - } -} - - -void -Serializer::serialize_plugin(SharedPtr<Shared::Plugin> plugin) -{ - assert(_model); - - const RDF::Node plugin_id = RDF::Node(_model->world(), RDF::Node::RESOURCE, plugin->uri()); - - _model->add_statement( - plugin_id, - "rdf:type", - RDF::Node(_model->world(), RDF::Node::RESOURCE, plugin->type_uri())); -} - - -void -Serializer::serialize_node(SharedPtr<Shared::Node> node, const RDF::Node& node_id) -{ - const RDF::Node plugin_id - = RDF::Node(_model->world(), RDF::Node::RESOURCE, node->plugin()->uri()); - - _model->add_statement( - node_id, - "rdf:type", - RDF::Node(_model->world(), RDF::Node::RESOURCE, "ingen:Node")); - - _model->add_statement( - node_id, - "ingen:name", - node->path().name()); - - _model->add_statement( - node_id, - "ingen:plugin", - plugin_id); - - _model->add_statement( - node_id, - "ingen:polyphonic", - node->polyphonic()); - - //serialize_plugin(node->plugin()); - - for (uint32_t i=0; i < node->num_ports(); ++i) { - Port* p = node->port(i); - assert(p); - const RDF::Node port_id = path_to_node_id(p->path()); - serialize_port(p, port_id); - _model->add_statement(node_id, "ingen:port", port_id); - } - - for (GraphObject::MetadataMap::const_iterator m = node->metadata().begin(); - m != node->metadata().end(); ++m) { - if (m->first.find(":") != string::npos) { - _model->add_statement( - node_id, - m->first, - m->second); - } - } -} - -/** Writes a port subject with various information only if there are some - * predicate/object pairs to go with it (eg if the port has metadata, or a value, or..). - * Audio output ports with no metadata will not be written, for example. - */ -void -Serializer::serialize_port(const Port* port, const RDF::Node& port_id) -{ - if (port->is_input()) - _model->add_statement(port_id, "rdf:type", - RDF::Node(_model->world(), RDF::Node::RESOURCE, "ingen:InputPort")); - else - _model->add_statement(port_id, "rdf:type", - RDF::Node(_model->world(), RDF::Node::RESOURCE, "ingen:OutputPort")); - - _model->add_statement(port_id, "ingen:name", Atom(port->path().name().c_str())); - - _model->add_statement(port_id, "rdf:type", - RDF::Node(_model->world(), RDF::Node::RESOURCE, port->type().uri())); - - if (port->type() == DataType::CONTROL && port->is_input()) - _model->add_statement(port_id, "ingen:value", port->value()); - - if (port->metadata().size() > 0) { - for (GraphObject::MetadataMap::const_iterator m = port->metadata().begin(); - m != port->metadata().end(); ++m) { - if (m->first.find(":") != string::npos) { - _model->add_statement( - port_id, - m->first, - m->second); - } - } - } -} - - -void -Serializer::serialize_connection(SharedPtr<Connection> connection) throw (std::logic_error) -{ - if (!_model) - throw std::logic_error("serialize_connection called without serialization in progress"); - - const RDF::Node src_node = path_to_node_id(connection->src_port_path()); - const RDF::Node dst_node = path_to_node_id(connection->dst_port_path()); - - _model->add_statement(dst_node, "ingen:connectedTo", src_node); -} - - -} // namespace Client -} // namespace Ingen diff --git a/src/libs/client/Serializer.hpp b/src/libs/client/Serializer.hpp deleted file mode 100644 index f8b99750..00000000 --- a/src/libs/client/Serializer.hpp +++ /dev/null @@ -1,96 +0,0 @@ -/* This file is part of Ingen. - * Copyright (C) 2007 Dave Robillard <http://drobilla.net> - * - * Ingen 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. - * - * Ingen 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 - */ - -#ifndef SERIALIZER_H -#define SERIALIZER_H - -#include <map> -#include <utility> -#include <string> -#include <stdexcept> -#include <cassert> -#include <raul/SharedPtr.hpp> -#include <raul/Path.hpp> -#include <raul/Atom.hpp> -#include <raul/RDFWorld.hpp> -#include <raul/RDFModel.hpp> - -using namespace Raul; -using namespace Ingen::Shared; - -namespace Ingen { - -namespace Shared { - class Plugin; - class GraphObject; - class Patch; - class Node; - class Port; - class Connection; -} - -namespace Client { - - -/** Serializes Ingen objects (patches, nodes, etc) to RDF. - * - * \ingroup IngenClient - */ -class Serializer -{ -public: - Serializer(Raul::RDF::World& world); - - void to_file(SharedPtr<GraphObject> object, const string& filename); - string to_string(SharedPtr<GraphObject> object); - - void start_to_string(); - void serialize(SharedPtr<GraphObject> object) throw (std::logic_error); - void serialize_connection(SharedPtr<Shared::Connection> c) throw (std::logic_error); - string finish(); - -private: - enum Mode { TO_FILE, TO_STRING }; - - void start_to_filename(const string& filename); - - void setup_prefixes(); - - void serialize_plugin(SharedPtr<Shared::Plugin> p); - - void serialize_patch(SharedPtr<Shared::Patch> p); - void serialize_node(SharedPtr<Shared::Node> n, const Raul::RDF::Node& id); - void serialize_port(const Shared::Port* p, const Raul::RDF::Node& id); - - Raul::RDF::Node path_to_node_id(const Path& path); - Raul::RDF::Node patch_path_to_rdf_id(const Path& path); - - typedef std::map<Raul::Path, Raul::RDF::Node> NodeMap; - - SharedPtr<GraphObject> _root_object; - Mode _mode; - NodeMap _node_map; - string _base_uri; - Raul::RDF::World& _world; - Raul::RDF::Model* _model; -}; - - -} // namespace Client -} // namespace Ingen - -#endif // SERIALIZER_H |