Cleaned up loading code.

Preliminary action loading code (queried from RDF but not actually created yet).
Fixed URI/filename handling so command line 'machina' accepts either.


git-svn-id: http://svn.drobilla.net/lad/machina@367 a436a847-0d15-0410-975c-d299462d15a1

5 files changed, 92 insertions, 113 deletions

diff --git a/src/engine/Engine.cpp b/src/engine/Engine.cpp
index 5991276..fede33f 100644
--- a/src/engine/Engine.cpp
+++ b/src/engine/Engine.cpp
@@ -30,10 +30,11 @@ namespace Machina {
 SharedPtr<Machine>
 Engine::load_machine(const Glib::ustring& uri)
 {
-	Loader l; // FIXME: namespaces?
-	SharedPtr<Machine> m = l.load(uri);
-	m->activate();
-	_driver->set_machine(m);
+	SharedPtr<Machine> m = Loader().load(uri);
+	if (m) {
+		m->activate();
+		_driver->set_machine(m);
+	}
 	return m;
 }
 
diff --git a/src/engine/JackDriver.cpp b/src/engine/JackDriver.cpp
index ee5a0d6..4f08543 100644
--- a/src/engine/JackDriver.cpp
+++ b/src/engine/JackDriver.cpp
@@ -26,7 +26,8 @@ namespace Machina {
 
 
 JackDriver::JackDriver(SharedPtr<Machine> machine)
-	: _machine_changed(0)
+	: Driver(machine)
+	, _machine_changed(0)
 	, _machine(machine)
 	, _input_port(NULL)
 	, _output_port(NULL)
diff --git a/src/engine/Loader.cpp b/src/engine/Loader.cpp
index edc4ac4..5c5ccdb 100644
--- a/src/engine/Loader.cpp
+++ b/src/engine/Loader.cpp
@@ -44,9 +44,9 @@ Loader::Loader(SharedPtr<Namespaces>  namespaces)
 }
 
 
-/** Load (create) all objects from an RDF into the engine.
+/** Load (create) all objects from RDF into the engine.
  *
- * @param uri URI of machine (e.g. resolvable URI to an RDF document).
+ * @param uri URI of machine (resolvable URI to an RDF document).
  * @return Loaded Machine.
  */
 SharedPtr<Machine>
@@ -57,135 +57,114 @@ Loader::load(const Glib::ustring& uri)
 
 	rasqal_init();
 
-	raptor_uri* base_uri = raptor_new_uri((const unsigned char*)"file:.");
-
-	raptor_uri* document_raptor_uri = raptor_new_uri_relative_to_base(
-			base_uri, (const unsigned char*)uri.c_str());
-
-	//raptor_uri* document_raptor_uri = raptor_new_uri_for_retrieval(rel_uri);
-	//raptor_free_uri(rel_uri);
-
-	if (!document_raptor_uri)
-		return machine; // NULL
-
-	machine = SharedPtr<Machine>(new Machine());
-
-	//Glib::ustring document_uri = (const char*)document_uri_str;
-	const Glib::ustring& document_uri = uri;
+	Glib::ustring document_uri = uri;
+
+	// If "URI" doesn't contain a colon, try to resolve as a filename
+	if (uri.find(":") == Glib::ustring::npos) {
+		raptor_uri* base_uri = raptor_new_uri((const unsigned char*)"file:.");
+		raptor_uri* document_raptor_uri = raptor_new_uri_relative_to_base(
+				base_uri, (const unsigned char*)uri.c_str());
+		if (document_raptor_uri) {
+			document_uri = (char*)raptor_uri_as_string(document_raptor_uri);
+			raptor_free_uri(document_raptor_uri);
+			raptor_free_uri(base_uri);
+		} else {
+			raptor_free_uri(base_uri);
+			return machine; // NULL
+		}
+	}
 
-	//string machine_uri = "<> ";
-	//string machine_uri = string("<") + document_uri + "> ";
-	string machine_uri = "?foo ";
+	const Glib::ustring machine_uri = "<>";
 
 	cout << "[Loader] Loading " << machine_uri << " from " << document_uri << endl;
 
+	machine = SharedPtr<Machine>(new Machine());
+	
 	typedef std::map<string, SharedPtr<Node> > Created;
 	Created created;
 
 
 	/* Get initial nodes */
-	
+
 	Raul::RDFQuery query = Raul::RDFQuery(*_namespaces, Glib::ustring(
-		"SELECT DISTINCT ?initialNode ?duration FROM <")
-		+ document_uri + "> WHERE {\n" +
-		machine_uri + " :initialNode ?initialNode .\n"
-		"?initialNode   :duration    ?duration .\n"
-		"}\n");
+			"SELECT DISTINCT ?initialNode ?duration FROM <")
+			+ document_uri + "> WHERE {\n" +
+			machine_uri + " :initialNode ?initialNode .\n"
+			"?initialNode   :duration    ?duration .\n"
+			"}\n");
 
 	RDFQuery::Results results = query.run(document_uri);
 
 	for (RDFQuery::Results::iterator i = results.begin(); i != results.end(); ++i) {
-		const Glib::ustring& node_uri  = (*i)["initialNode"];
-		const Glib::ustring& duration  = (*i)["duration"];
-		
-		raptor_uri* node_raptor_uri
-			= raptor_new_uri((const unsigned char*)node_uri.c_str());
-
-		char* node_name = (char*)
-			raptor_uri_to_relative_uri_string(document_raptor_uri, node_raptor_uri);
-
-		cout << "Initial: " << node_name << " - " << duration << endl;
-
-		cerr << "FIXME: load\n";
-/*
-		SharedPtr<Node> node = SharedPtr<Node>(_node_factory->create_node(
-			node_name,
-			strtol(midi_note.c_str(), NULL, 10),
-			strtol(duration.c_str(), NULL, 10)));
-
-		node->set_initial(true);	
-		//machine->add_node(string(node_name).substr(1), node); // (chop leading "#")
-		machine->add_node(node);
-	
-		created.insert(std::make_pair(node_uri.collate_key(), node));
-		*/
- 
+		const Glib::ustring& node_id  = (*i)["initialNode"];
+		const Glib::ustring& duration = (*i)["duration"];
+
+		cout << "Initial: " << node_id << " - " << duration << endl;
+
 		SharedPtr<Node> node(new Node(strtod(duration.c_str(), NULL), true));
 		machine->add_node(node);
-		created.insert(std::make_pair(node_uri.collate_key(), node));
-
-		raptor_free_uri(node_raptor_uri);
-		free(node_name);
+		created.insert(std::make_pair(node_id.collate_key(), node));
 	}
-	
-	
-	/* Get remaining nodes */
-	
+
+
+	/* Get remaining (non-initial) nodes */
+
 	query = Raul::RDFQuery(*_namespaces, Glib::ustring(
-		"SELECT DISTINCT ?node ?duration FROM <")
-		+ document_uri + "> WHERE {\n" +
-		machine_uri + " :node     ?node .\n"
-		"?node          :duration ?duration .\n"
-		"}\n");
+			"SELECT DISTINCT ?node ?duration FROM <")
+			+ document_uri + "> WHERE {\n" +
+			machine_uri + " :node     ?node .\n"
+			"?node          :duration ?duration .\n"
+			"}\n");
 
 	results = query.run(document_uri);
 
 	for (RDFQuery::Results::iterator i = results.begin(); i != results.end(); ++i) {
-		const Glib::ustring& node_uri  = (*i)["node"];
-		const Glib::ustring& duration  = (*i)["duration"];
-		
-		raptor_uri* node_raptor_uri
-			= raptor_new_uri((const unsigned char*)node_uri.c_str());
-
-		char* node_name = (char*)
-			raptor_uri_to_relative_uri_string(document_raptor_uri, node_raptor_uri);
-
-		cout << "Node: " << node_name << " - " << duration << endl;
-
-		cerr << "FIXME: load (2)\n";
-		/*
-		SharedPtr<Node> node = SharedPtr<Node>(_node_factory->create_node(
-			node_name,
-			strtol(midi_note.c_str(), NULL, 10),
-			strtol(duration.c_str(), NULL, 10)));
-		
-		
-		if (created.find(node_uri) == created.end()) {
-			//cout << "Node: " << node_name << ": " << midi_note << " - " << duration << endl;
-			//machine->add_node(string(node_name).substr(1), node); // (chop leading "#")
-			machine->add_node(node);
-			created.insert(std::make_pair(node_uri.collate_key(), node));
+		const Glib::ustring& node_id  = (*i)["node"];
+		const Glib::ustring& duration = (*i)["duration"];
+
+		cout << "Node: " << node_id << " - " << duration << endl;
+
+		if (created.find(node_id.collate_key()) == created.end()) {
+			SharedPtr<Node> node(new Node(strtod(duration.c_str(), NULL), true));
+			machine->add_node(node); 
+			created.insert(std::make_pair(node_id.collate_key(), node));
+		} else {
+			cout << "Already created, skipping." << endl;
 		}
-		*/
-		SharedPtr<Node> node(new Node(strtod(duration.c_str(), NULL), true));
-		machine->add_node(node); 
-		created.insert(std::make_pair(node_uri.collate_key(), node));
+	}
+
+
+	/* Get actions */
+
+	query = Raul::RDFQuery(*_namespaces, Glib::ustring(
+			"SELECT DISTINCT ?node ?enter_action ?exit_action FROM <")
+			+ document_uri + "> WHERE {\n" +
+			"?node :enterAction ?enter_action ;\n"
+			"      :exitAction  ?exit_action .\n"
+			"}\n");
+
+	results = query.run(document_uri);
+
+	for (RDFQuery::Results::iterator i = results.begin(); i != results.end(); ++i) {
+		const Glib::ustring& node         = (*i)["node"];
+		const Glib::ustring& enter_action = (*i)["enter_action"];
+		const Glib::ustring& exit_action  = (*i)["exit_action"];
+
+		cout << "Node: " << node << ", Action: " << enter_action << " .. " << exit_action <<endl;
 
-		raptor_free_uri(node_raptor_uri);
-		free(node_name);
 	}
 
 
 	/* Get edges */
 
 	query = Raul::RDFQuery(*_namespaces, Glib::ustring(
-		"SELECT DISTINCT ?edge ?src ?dst ?prob FROM <")
-		+ document_uri + "> WHERE {\n" +
-		machine_uri + " :edge ?edge .\n"
-		"?edge :tail        ?src ;\n"
-		"      :head        ?dst ;\n"
-		"      :probability ?prob .\n }");
-	
+			"SELECT DISTINCT ?edge ?src ?dst ?prob FROM <")
+			+ document_uri + "> WHERE {\n" +
+			machine_uri + " :edge ?edge .\n"
+			"?edge :tail        ?src ;\n"
+			"      :head        ?dst ;\n"
+			"      :probability ?prob .\n }");
+
 	results = query.run(document_uri);
 
 	for (RDFQuery::Results::iterator i = results.begin(); i != results.end(); ++i) {
@@ -199,7 +178,7 @@ Loader::load(const Glib::ustring& uri)
 		if (src_i != created.end() && dst_i != created.end()) {
 			const SharedPtr<Node> src = src_i->second;
 			const SharedPtr<Node> dst = dst_i->second;
-		
+
 			SharedPtr<Edge> edge(new Edge(src, dst));
 			edge->set_probability(prob);
 			src->add_outgoing_edge(edge);
@@ -210,12 +189,9 @@ Loader::load(const Glib::ustring& uri)
 		}
 
 	}
-		
-	//free(document_uri_str);
-	raptor_free_uri(document_raptor_uri);
-	raptor_free_uri(base_uri);
 
-	machine->reset();
+	if (machine)
+		machine->reset();
 
 	return machine;
 }
diff --git a/src/engine/Makefile.am b/src/engine/Makefile.am
index eab7970..8d41dd6 100644
--- a/src/engine/Makefile.am
+++ b/src/engine/Makefile.am
@@ -17,5 +17,5 @@ libmachina_la_SOURCES = \
 	LearnRequest.cpp
 	
 if WITH_JACK
-	JackDriver.cpp
+libmachina_la_SOURCES += JackDriver.cpp
 endif
diff --git a/src/engine/machina/JackDriver.hpp b/src/engine/machina/JackDriver.hpp
index 13005c0..e5d0abb 100644
--- a/src/engine/machina/JackDriver.hpp
+++ b/src/engine/machina/JackDriver.hpp
@@ -44,6 +44,7 @@ class JackDriver : public Raul::JackDriver,
                    public boost::enable_shared_from_this<JackDriver> {
 public:
 	JackDriver(SharedPtr<Machine> machine = SharedPtr<Machine>());
+	~JackDriver();
 
 	void attach(const std::string& client_name);
 	void detach();