Add SerdSink interface and hide implementations

1 files changed, 112 insertions, 0 deletions

diff --git a/src/sink.c b/src/sink.c
new file mode 100644
index 00000000..959a92b3
--- /dev/null
+++ b/src/sink.c
@@ -0,0 +1,112 @@
+/*
+  Copyright 2011-2020 David Robillard <d@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 "sink.h"
+
+#include "serd/serd.h"
+
+#include <assert.h>
+#include <stdlib.h>
+
+SerdSink*
+serd_sink_new(void* handle, SerdFreeFunc free_handle)
+{
+  SerdSink* sink = (SerdSink*)calloc(1, sizeof(SerdSink));
+
+  sink->handle      = handle;
+  sink->free_handle = free_handle;
+
+  return sink;
+}
+
+void
+serd_sink_free(SerdSink* sink)
+{
+  if (sink) {
+    if (sink->free_handle) {
+      sink->free_handle(sink->handle);
+    }
+
+    free(sink);
+  }
+}
+
+SerdStatus
+serd_sink_set_base_func(SerdSink* sink, SerdBaseFunc base_func)
+{
+  sink->base = base_func;
+  return SERD_SUCCESS;
+}
+
+SerdStatus
+serd_sink_set_prefix_func(SerdSink* sink, SerdPrefixFunc prefix_func)
+{
+  sink->prefix = prefix_func;
+  return SERD_SUCCESS;
+}
+
+SerdStatus
+serd_sink_set_statement_func(SerdSink* sink, SerdStatementFunc statement_func)
+{
+  sink->statement = statement_func;
+  return SERD_SUCCESS;
+}
+
+SerdStatus
+serd_sink_set_end_func(SerdSink* sink, SerdEndFunc end_func)
+{
+  sink->end = end_func;
+  return SERD_SUCCESS;
+}
+
+SerdStatus
+serd_sink_write_base(const SerdSink* sink, const SerdNode* uri)
+{
+  return sink->base ? sink->base(sink->handle, uri) : SERD_SUCCESS;
+}
+
+SerdStatus
+serd_sink_write_prefix(const SerdSink* sink,
+                       const SerdNode* name,
+                       const SerdNode* uri)
+{
+  return sink->prefix ? sink->prefix(sink->handle, name, uri) : SERD_SUCCESS;
+}
+
+SerdStatus
+serd_sink_write(const SerdSink*          sink,
+                const SerdStatementFlags flags,
+                const SerdNode*          subject,
+                const SerdNode*          predicate,
+                const SerdNode*          object,
+                const SerdNode*          graph)
+{
+  assert(sink);
+  assert(subject);
+  assert(predicate);
+  assert(object);
+
+  return sink->statement
+           ? sink->statement(
+               sink->handle, flags, graph, subject, predicate, object)
+           : SERD_SUCCESS;
+}
+
+SerdStatus
+serd_sink_write_end(const SerdSink* sink, const SerdNode* node)
+{
+  return sink->end ? sink->end(sink->handle, node) : SERD_SUCCESS;
+}