WIP: Add model

1 files changed, 106 insertions, 0 deletions

diff --git a/src/inserter.c b/src/inserter.c
new file mode 100644
index 00000000..393e2c20
--- /dev/null
+++ b/src/inserter.c
@@ -0,0 +1,106 @@
+/*
+  Copyright 2011-2018 David Robillard <http://drobilla.net>
+
+  Permission to use, copy, modify, and/or distribute this software for any
+  purpose with or without fee is hereby granted, provided that the above
+  copyright notice and this permission notice appear in all copies.
+
+  THIS SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
+  WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
+  MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
+  ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
+  WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
+  ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
+  OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
+*/
+
+#include "inserter.h"
+
+#include "model.h"
+#include "statement.h"
+#include "world.h"
+
+#include <stdlib.h>
+
+static SerdStatus
+serd_inserter_on_base(SerdInserter* inserter, const SerdNode* uri)
+{
+	return serd_env_set_base_uri(inserter->env, uri);
+}
+
+static SerdStatus
+serd_inserter_on_prefix(SerdInserter*   inserter,
+                        const SerdNode* name,
+                        const SerdNode* uri)
+{
+	return serd_env_set_prefix(inserter->env, name, uri);
+}
+
+static const SerdNode*
+manage_or_intern(SerdNodes* nodes, SerdNode* manage, const SerdNode* intern)
+{
+	return manage ? serd_nodes_manage(nodes, manage)
+	              : serd_nodes_intern(nodes, intern);
+}
+
+static SerdStatus
+serd_inserter_on_statement(SerdInserter*            inserter,
+                           const SerdStatementFlags flags,
+                           const SerdStatement*     statement)
+{
+	const SerdNode* const subject   = serd_statement_get_subject(statement);
+	const SerdNode* const predicate = serd_statement_get_predicate(statement);
+	const SerdNode* const object    = serd_statement_get_object(statement);
+	const SerdNode* const graph     = serd_statement_get_graph(statement);
+
+	// Attempt to expand all nodes to eliminate CURIEs
+	SerdNode* const s = serd_env_expand(inserter->env, subject);
+	SerdNode* const p = serd_env_expand(inserter->env, predicate);
+	SerdNode* const o = serd_env_expand(inserter->env, object);
+	SerdNode* const g = serd_env_expand(inserter->env, graph);
+
+	SerdNodes* const nodes       = inserter->model->world->nodes;
+	const SerdNode*  model_graph = manage_or_intern(nodes, g, graph);
+	if (!model_graph) {
+		model_graph = serd_nodes_intern(nodes, inserter->default_graph);
+	}
+
+	const SerdStatus st =
+		serd_model_add_internal(inserter->model,
+		                        statement->cursor,
+		                        manage_or_intern(nodes, s, subject),
+		                        manage_or_intern(nodes, p, predicate),
+		                        manage_or_intern(nodes, o, object),
+		                        model_graph);
+
+	return st > SERD_FAILURE ? st : SERD_SUCCESS;
+}
+
+SerdInserter*
+serd_inserter_new(SerdModel* model, SerdEnv* env, const SerdNode* default_graph)
+{
+	SerdInserter* inserter    = (SerdInserter*)calloc(1, sizeof(SerdInserter));
+	inserter->model           = model;
+	inserter->env             = env;
+	inserter->default_graph   = serd_node_copy(default_graph);
+	inserter->iface.handle    = inserter;
+	inserter->iface.base      = (SerdBaseSink)serd_inserter_on_base;
+	inserter->iface.prefix    = (SerdPrefixSink)serd_inserter_on_prefix;
+	inserter->iface.statement = (SerdStatementSink)serd_inserter_on_statement;
+	return inserter;
+}
+
+void
+serd_inserter_free(SerdInserter* inserter)
+{
+	if (inserter) {
+		serd_node_free(inserter->default_graph);
+		free(inserter);
+	}
+}
+
+const SerdSink*
+serd_inserter_get_sink(SerdInserter* inserter)
+{
+	return &inserter->iface;
+}