From f63c29df622dd4f4fde6de3906ec53765117fb79 Mon Sep 17 00:00:00 2001 From: David Robillard Date: Tue, 12 Dec 2006 23:30:38 +0000 Subject: Loading subpatches (ie not just into root). Initial patch metadata. Subpatch browsing (via double clicking modules). git-svn-id: http://svn.drobilla.net/lad/ingen@218 a436a847-0d15-0410-975c-d299462d15a1 --- src/libs/client/Loader.cpp | 124 ++++++++++++++++++++++++++++++------------- src/libs/client/Loader.h | 7 ++- src/libs/client/RDFQuery.cpp | 12 ++++- src/libs/client/RDFQuery.h | 2 +- 4 files changed, 104 insertions(+), 41 deletions(-) (limited to 'src/libs/client') diff --git a/src/libs/client/Loader.cpp b/src/libs/client/Loader.cpp index e1590540..68b04b58 100644 --- a/src/libs/client/Loader.cpp +++ b/src/libs/client/Loader.cpp @@ -15,6 +15,7 @@ */ #include +#include #include "Loader.h" #include "RDFQuery.h" #include "ModelEngineInterface.h" @@ -42,36 +43,85 @@ Loader::Loader(SharedPtr engine, SharedPtr nam * @param parent Path of parent under which to load objects. * @return whether or not load was successful. */ -void +bool Loader::load(const Glib::ustring& filename, - const Path& parent) + const Path& parent, + Glib::ustring patch_uri, + MetadataMap data) { + // FIXME: this whole thing is a mess + std::map created; + // FIXME: kluge + unsigned char* document_uri_str = raptor_uri_filename_to_uri_string(filename.c_str()); + Glib::ustring document_uri = (const char*)document_uri_str; + //Glib::ustring document_uri = "file:///home/dave/code/codesonnet/ingen/src/progs/ingenuity/test2.ingen.ttl"; + + if (patch_uri == "") + patch_uri = "<>"; + + cerr << "[Loader] Loading " << patch_uri << " from " << document_uri + << " under " << parent << endl; + + /* Get polyphony (mandatory) */ + + // FIXME: polyphony datatype + RDFQuery query(Glib::ustring( + "SELECT DISTINCT ?poly \nFROM <") + document_uri + ">\nWHERE {\n\t" + + patch_uri + " ingen:polyphony ?poly .\n" + "}"); + + RDFQuery::Results results = query.run(document_uri); + + if (results.size() == 0) { + cerr << "[Loader] ERROR: No polyphony found!" << endl; + return false; + } + + size_t patch_poly = atoi(((*results.begin())["poly"]).c_str()); + + + /* Get name (if available) */ + + query = RDFQuery(Glib::ustring( + "SELECT DISTINCT ?name \nFROM <") + document_uri + ">\nWHERE {\n\t" + + patch_uri + " ingen:name ?name .\n" + "}"); + + results = query.run(document_uri); + + string patch_name = string(filename.substr(filename.find_last_of("/")+1)); + Path patch_path = parent.base() + string(filename.substr(filename.find_last_of("/")+1)); + + if (results.size() > 0) + patch_path = parent.base() + string((*results.begin())["name"]); + + cerr << "************ PATCH: " << patch_path << ", poly = " << patch_poly << endl; + + _engine->create_patch(patch_path, patch_poly); + /* Load nodes */ - RDFQuery query(Glib::ustring( - "SELECT DISTINCT ?patch ?name ?plugin ?floatkey ?floatval FROM <") + filename + "> WHERE {\n" - "?patch ingen:node ?node .\n" - "?node ingen:name ?name ;\n" - " ingen:plugin ?plugin ;\n" + query = RDFQuery(Glib::ustring( + "SELECT DISTINCT ?name ?plugin ?floatkey ?floatval FROM <") + document_uri + "> WHERE {\n" + + patch_uri + " ingen:node ?node .\n" + "?node ingen:name ?name ;\n" + " ingen:plugin ?plugin .\n" "OPTIONAL { ?node ?floatkey ?floatval . \n" " FILTER ( datatype(?floatval) = xsd:decimal ) }\n" "}"); - RDFQuery::Results nodes = query.run(filename); + results = query.run(document_uri); - for (RDFQuery::Results::iterator i = nodes.begin(); i != nodes.end(); ++i) { + for (RDFQuery::Results::iterator i = results.begin(); i != results.end(); ++i) { - const Glib::ustring& patch = (*i)["patch"]; const Glib::ustring& name = (*i)["name"]; const Glib::ustring& plugin = (*i)["plugin"]; - cerr << "LOADING NODE IN PATCH : " << patch << endl; - if (created.find(name) == created.end()) { - _engine->create_node(parent.base() + name, plugin, false); + _engine->create_node(patch_path.base() + name, plugin, false); created[name] = true; } @@ -80,28 +130,28 @@ Loader::load(const Glib::ustring& filename, if (floatkey != "" && floatval != "") { const float val = atof(floatval.c_str()); - _engine->set_metadata(parent.base() + name, floatkey, Atom(val)); + _engine->set_metadata(patch_path.base() + name, floatkey, Atom(val)); } } created.clear(); - /* Load patch ports */ + /* Load this patch's ports */ query = RDFQuery(Glib::ustring( - "SELECT DISTINCT ?port ?type ?name ?datatype ?floatkey ?floatval FROM <") + filename + "> WHERE {\n" - "?patch ingen:port ?port .\n" - "?port a ?type ;\n" - " ingen:name ?name ;\n" - " ingen:dataType ?datatype .\n" + "SELECT DISTINCT ?port ?type ?name ?datatype ?floatkey ?floatval FROM <") + document_uri + "> WHERE {\n" + + patch_uri + " ingen:port ?port .\n" + "?port a ?type ;\n" + " ingen:name ?name ;\n" + " ingen:dataType ?datatype .\n" "OPTIONAL { ?port ?floatkey ?floatval . \n" " FILTER ( datatype(?floatval) = xsd:decimal ) }\n" "}"); - RDFQuery::Results ports = query.run(filename); + results = query.run(document_uri); - for (RDFQuery::Results::iterator i = ports.begin(); i != ports.end(); ++i) { + for (RDFQuery::Results::iterator i = results.begin(); i != results.end(); ++i) { const Glib::ustring& name = (*i)["name"]; const Glib::ustring& type = _namespaces->qualify((*i)["type"]); const Glib::ustring& datatype = (*i)["datatype"]; @@ -109,7 +159,7 @@ Loader::load(const Glib::ustring& filename, if (created.find(name) == created.end()) { //cerr << "TYPE: " << type << endl; bool is_output = (type == "ingen:OutputPort"); // FIXME: check validity - _engine->create_port(parent.base() + name, datatype, is_output); + _engine->create_port(patch_path.base() + name, datatype, is_output); created[name] = true; } @@ -118,14 +168,15 @@ Loader::load(const Glib::ustring& filename, if (floatkey != "" && floatval != "") { const float val = atof(floatval.c_str()); - _engine->set_metadata(parent.base() + name, floatkey, Atom(val)); + _engine->set_metadata(patch_path.base() + name, floatkey, Atom(val)); } } /* Load connections */ + // FIXME: path? query = RDFQuery(Glib::ustring( - "SELECT DISTINCT ?srcnode ?src ?dstnode ?dst FROM <") + filename + "> WHERE {\n" + "SELECT DISTINCT ?srcnode ?src ?dstnode ?dst FROM <") + document_uri + "> WHERE {\n" + "?srcnoderef ingen:port ?srcref .\n" "?dstnoderef ingen:port ?dstref .\n" "?dstref ingen:connectedTo ?srcref .\n" @@ -135,28 +186,29 @@ Loader::load(const Glib::ustring& filename, "OPTIONAL { ?dstnoderef ingen:name ?dstnode }\n" "}\n"); - cerr << "*************\n" << query.string() << "*****************\n"; - - RDFQuery::Results connections = query.run(filename); + results = query.run(document_uri); - for (RDFQuery::Results::iterator i = connections.begin(); i != connections.end(); ++i) { - // FIXME: kludge - Path src_node = string("/"); + for (RDFQuery::Results::iterator i = results.begin(); i != results.end(); ++i) { + Path src_node = patch_path; if ((*i).find("srcnode") != (*i).end()) - src_node += string((*i)["srcnode"]); + src_node = patch_path.base() + string((*i)["srcnode"]); Path src_port = src_node.base() + string((*i)["src"]); - Path dst_node = string("/"); + Path dst_node = patch_path; if ((*i).find("dstnode") != (*i).end()) - dst_node += string((*i)["dstnode"]); + dst_node = patch_path.base() + string((*i)["dstnode"]); Path dst_port = dst_node.base() + string((*i)["dst"]); - cerr << "CONNECTION: " << src_port << " -> " << dst_port << endl; + //cerr << "CONNECTION: " << src_port << " -> " << dst_port << endl; _engine->connect(src_port, dst_port); } + + // Set passed metadata last to override any loaded values + for (MetadataMap::const_iterator i = data.begin(); i != data.end(); ++i) + _engine->set_metadata(patch_path, i->first, i->second); - + return true; } diff --git a/src/libs/client/Loader.h b/src/libs/client/Loader.h index 3176c2f6..86317c1f 100644 --- a/src/libs/client/Loader.h +++ b/src/libs/client/Loader.h @@ -21,6 +21,7 @@ #include "raul/SharedPtr.h" #include "raul/Path.h" #include "Namespaces.h" +#include "ObjectModel.h" namespace Ingen { namespace Client { @@ -34,8 +35,10 @@ class Loader { public: Loader(SharedPtr engine, SharedPtr = SharedPtr()); - void load(const Glib::ustring& filename, - const Path& parent); + bool load(const Glib::ustring& filename, + const Path& parent, + Glib::ustring patch_uri = "", + MetadataMap initial_data = MetadataMap()); private: //string _patch_search_path; diff --git a/src/libs/client/RDFQuery.cpp b/src/libs/client/RDFQuery.cpp index 3993de20..196868b8 100644 --- a/src/libs/client/RDFQuery.cpp +++ b/src/libs/client/RDFQuery.cpp @@ -27,7 +27,7 @@ namespace Client { RDFQuery::Results -RDFQuery::run(const Glib::ustring filename) const +RDFQuery::run(const Glib::ustring base_uri_str) const { Results result; @@ -35,7 +35,11 @@ RDFQuery::run(const Glib::ustring filename) const rasqal_query *rq = rasqal_new_query("sparql", NULL); - rasqal_query_prepare(rq, (unsigned char*)_query.c_str(), NULL); + raptor_uri* base_uri = NULL; + if (base_uri_str != "") + base_uri = raptor_new_uri((const unsigned char*)base_uri_str.c_str()); + rasqal_query_prepare(rq, (unsigned char*)_query.c_str(), base_uri); + rasqal_query_results* results = rasqal_query_execute(rq); assert(results); @@ -62,6 +66,10 @@ RDFQuery::run(const Glib::ustring filename) const rasqal_free_query_results(results); rasqal_free_query(rq); + + if (base_uri) + raptor_free_uri(base_uri); + rasqal_finish(); return result; diff --git a/src/libs/client/RDFQuery.h b/src/libs/client/RDFQuery.h index 990d9e4f..065664e9 100644 --- a/src/libs/client/RDFQuery.h +++ b/src/libs/client/RDFQuery.h @@ -45,7 +45,7 @@ public: _query = _prefix_header + query; } - Results run(const Glib::ustring filename) const; + Results run(const Glib::ustring base_uri) const; Glib::ustring string() const { return _query; }; -- cgit v1.2.1