Add SerdSinkInterface and hide implementations

5 files changed, 80 insertions, 93 deletions

diff --git a/src/n3.c b/src/n3.c
index 7b91f62d..a0d2ef5e 100644
--- a/src/n3.c
+++ b/src/n3.c
@@ -953,8 +953,8 @@ read_anon(SerdReader* reader, ReadContext ctx, bool subject, Ref* dest)
 			return r_err(reader, SERD_ERR_BAD_SYNTAX, "`.' inside blank\n");
 		}
 		read_ws_star(reader);
-		if (reader->end_sink) {
-			reader->end_sink(reader->handle, deref(reader, *dest));
+		if (reader->sink->end) {
+			reader->sink->end(reader->sink->handle, deref(reader, *dest));
 		}
 		*ctx.flags = old_flags;
 	}
@@ -1248,8 +1248,8 @@ read_base(SerdReader* reader, bool sparql, bool token)
 	Ref uri;
 	read_ws_star(reader);
 	TRY_RET(uri = read_IRIREF(reader));
-	if (reader->base_sink) {
-		reader->base_sink(reader->handle, deref(reader, uri));
+	if (reader->sink->base) {
+		reader->sink->base(reader->sink->handle, deref(reader, uri));
 	}
 	pop_node(reader, uri);
 
@@ -1288,10 +1288,10 @@ read_prefixID(SerdReader* reader, bool sparql, bool token)
 		return false;
 	}
 
-	if (reader->prefix_sink) {
-		ret = !reader->prefix_sink(reader->handle,
-		                           deref(reader, name),
-		                           deref(reader, uri));
+	if (reader->sink->prefix) {
+		ret = !reader->sink->prefix(reader->sink->handle,
+		                            deref(reader, name),
+		                            deref(reader, uri));
 	}
 	pop_node(reader, uri);
 	pop_node(reader, name);
diff --git a/src/reader.c b/src/reader.c
index c02a2a13..7e05d25c 100644
--- a/src/reader.c
+++ b/src/reader.c
@@ -121,9 +121,9 @@ emit_statement(SerdReader* reader, ReadContext ctx, Ref o, Ref d, Ref l)
 	if (!graph && reader->default_graph) {
 		graph = reader->default_graph;
 	}
-	bool ret = !reader->statement_sink ||
-		!reader->statement_sink(
-			reader->handle, *ctx.flags, graph,
+	bool ret = !reader->sink->statement ||
+		!reader->sink->statement(
+			reader->sink->handle, *ctx.flags, graph,
 			deref(reader, ctx.subject), deref(reader, ctx.predicate),
 			deref(reader, o));
 	*ctx.flags &= SERD_ANON_CONT|SERD_LIST_CONT;  // Preserve only cont flags
@@ -157,26 +157,16 @@ serd_reader_read_document(SerdReader* reader)
 
 SERD_API
 SerdReader*
-serd_reader_new(SerdSyntax        syntax,
-                void*             handle,
-                void              (*free_handle)(void*),
-                SerdBaseSink      base_sink,
-                SerdPrefixSink    prefix_sink,
-                SerdStatementSink statement_sink,
-                SerdEndSink       end_sink)
+serd_reader_new(SerdSyntax               syntax,
+                const SerdSinkInterface* sink)
 {
-	SerdReader*  me  = (SerdReader*)calloc(1, sizeof(SerdReader));
-	me->handle           = handle;
-	me->free_handle      = free_handle;
-	me->base_sink        = base_sink;
-	me->prefix_sink      = prefix_sink;
-	me->statement_sink   = statement_sink;
-	me->end_sink         = end_sink;
-	me->default_graph    = NULL;
-	me->stack            = serd_stack_new(SERD_PAGE_SIZE);
-	me->syntax           = syntax;
-	me->next_id          = 1;
-	me->strict           = true;
+	SerdReader* me = (SerdReader*)calloc(1, sizeof(SerdReader));
+	me->sink          = sink;
+	me->default_graph = NULL;
+	me->stack         = serd_stack_new(SERD_PAGE_SIZE);
+	me->syntax        = syntax;
+	me->next_id       = 1;
+	me->strict        = true;
 
 	me->rdf_first = push_node(me, SERD_URI, NS_RDF "first", 48);
 	me->rdf_rest  = push_node(me, SERD_URI, NS_RDF "rest", 47);
@@ -216,20 +206,10 @@ serd_reader_free(SerdReader* reader)
 #endif
 	free(reader->stack.buf);
 	free(reader->bprefix);
-	if (reader->free_handle) {
-		reader->free_handle(reader->handle);
-	}
 	free(reader);
 }
 
 SERD_API
-void*
-serd_reader_get_handle(const SerdReader* reader)
-{
-	return reader->handle;
-}
-
-SERD_API
 void
 serd_reader_add_blank_prefix(SerdReader* reader,
                              const char* prefix)
diff --git a/src/reader.h b/src/reader.h
index 842ba8b8..ec2532b0 100644
--- a/src/reader.h
+++ b/src/reader.h
@@ -46,31 +46,26 @@ typedef struct {
 } ReadContext;
 
 struct SerdReaderImpl {
-	void*             handle;
-	void              (*free_handle)(void* ptr);
-	SerdBaseSink      base_sink;
-	SerdPrefixSink    prefix_sink;
-	SerdStatementSink statement_sink;
-	SerdEndSink       end_sink;
-	SerdErrorSink     error_sink;
-	void*             error_handle;
-	Ref               rdf_first;
-	Ref               rdf_rest;
-	Ref               rdf_nil;
-	SerdNode*         default_graph;
-	SerdByteSource    source;
-	SerdStack         stack;
-	SerdSyntax        syntax;
-	unsigned          next_id;
-	SerdStatus        status;
-	uint8_t*          buf;
-	char*             bprefix;
-	size_t            bprefix_len;
-	bool              strict;     ///< True iff strict parsing
-	bool              seen_genid;
+	const SerdSinkInterface* sink;
+	SerdErrorSink            error_sink;
+	void*                    error_handle;
+	Ref                      rdf_first;
+	Ref                      rdf_rest;
+	Ref                      rdf_nil;
+	SerdNode*                default_graph;
+	SerdByteSource           source;
+	SerdStack                stack;
+	SerdSyntax               syntax;
+	unsigned                 next_id;
+	SerdStatus               status;
+	uint8_t*                 buf;
+	char*                    bprefix;
+	size_t                   bprefix_len;
+	bool                     strict; ///< True iff strict parsing
+	bool                     seen_genid;
 #ifdef SERD_STACK_CHECK
-	Ref*              allocs;     ///< Stack of push offsets
-	size_t            n_allocs;   ///< Number of stack pushes
+	Ref*                     allocs; ///< Stack of push offsets
+	size_t                   n_allocs; ///< Number of stack pushes
 #endif
 };
 
diff --git a/src/serdi.c b/src/serdi.c
index 134cd369..dc8e3207 100644
--- a/src/serdi.c
+++ b/src/serdi.c
@@ -277,11 +277,7 @@ main(int argc, char** argv)
 		env, &base_uri, serd_file_sink, out_fd);
 
 	SerdReader* reader = serd_reader_new(
-		input_syntax, writer, NULL,
-		(SerdBaseSink)serd_writer_set_base_uri,
-		(SerdPrefixSink)serd_writer_set_prefix,
-		(SerdStatementSink)serd_writer_write_statement,
-		(SerdEndSink)serd_writer_end_anon);
+		input_syntax, serd_writer_get_sink_interface(writer));
 
 	serd_reader_set_strict(reader, !lax);
 	if (quiet) {
diff --git a/src/writer.c b/src/writer.c
index f75c23a0..2671ba7d 100644
--- a/src/writer.c
+++ b/src/writer.c
@@ -89,24 +89,25 @@ static const SepRule rules[] = {
 };
 
 struct SerdWriterImpl {
-	SerdSyntax    syntax;
-	SerdStyle     style;
-	SerdEnv*      env;
-	SerdNode*     root_node;
-	SerdURI       root_uri;
-	SerdURI       base_uri;
-	SerdStack     anon_stack;
-	SerdByteSink  byte_sink;
-	SerdErrorSink error_sink;
-	void*         error_handle;
-	WriteContext  context;
-	SerdNode*     list_subj;
-	unsigned      list_depth;
-	unsigned      indent;
-	uint8_t*      bprefix;
-	size_t        bprefix_len;
-	Sep           last_sep;
-	bool          empty;
+	SerdSinkInterface iface;
+	SerdSyntax        syntax;
+	SerdStyle         style;
+	SerdEnv*          env;
+	SerdNode*         root_node;
+	SerdURI           root_uri;
+	SerdURI           base_uri;
+	SerdStack         anon_stack;
+	SerdByteSink      byte_sink;
+	SerdErrorSink     error_sink;
+	void*             error_handle;
+	WriteContext      context;
+	SerdNode*         list_subj;
+	unsigned          list_depth;
+	unsigned          indent;
+	uint8_t*          bprefix;
+	size_t            bprefix_len;
+	Sep               last_sep;
+	bool              empty;
 };
 
 typedef enum {
@@ -114,6 +115,11 @@ typedef enum {
 	WRITE_LONG_STRING
 } TextContext;
 
+static SerdStatus
+serd_writer_set_prefix(SerdWriter*     writer,
+                       const SerdNode* name,
+                       const SerdNode* uri);
+
 static bool
 write_node(SerdWriter*        writer,
            const SerdNode*    node,
@@ -693,8 +699,7 @@ write_list_obj(SerdWriter*        writer,
 	return false;
 }
 
-SERD_API
-SerdStatus
+static SerdStatus
 serd_writer_write_statement(SerdWriter*        writer,
                             SerdStatementFlags flags,
                             const SerdNode*    graph,
@@ -827,8 +832,7 @@ serd_writer_write_statement(SerdWriter*        writer,
 	return SERD_SUCCESS;
 }
 
-SERD_API
-SerdStatus
+static SerdStatus
 serd_writer_end_anon(SerdWriter*     writer,
                      const SerdNode* node)
 {
@@ -893,6 +897,13 @@ serd_writer_new(SerdSyntax     syntax,
 	writer->empty        = true;
 	writer->byte_sink    = serd_byte_sink_new(
 		ssink, stream, (style & SERD_STYLE_BULK) ? SERD_PAGE_SIZE : 1);
+
+	writer->iface.handle    = writer;
+	writer->iface.base      = (SerdBaseSink)serd_writer_set_base_uri;
+	writer->iface.prefix    = (SerdPrefixSink)serd_writer_set_prefix;
+	writer->iface.statement = (SerdStatementSink)serd_writer_write_statement;
+	writer->iface.end       = (SerdEndSink)serd_writer_end_anon;
+
 	return writer;
 }
 
@@ -921,7 +932,6 @@ serd_writer_chop_blank_prefix(SerdWriter* writer,
 	}
 }
 
-SERD_API
 SerdStatus
 serd_writer_set_base_uri(SerdWriter*     writer,
                          const SerdNode* uri)
@@ -961,7 +971,6 @@ serd_writer_set_root_uri(SerdWriter*     writer,
 	return SERD_SUCCESS;
 }
 
-SERD_API
 SerdStatus
 serd_writer_set_prefix(SerdWriter*     writer,
                        const SerdNode* name,
@@ -998,6 +1007,13 @@ serd_writer_free(SerdWriter* writer)
 }
 
 SERD_API
+const SerdSinkInterface*
+serd_writer_get_sink_interface(SerdWriter* writer)
+{
+	return &writer->iface;
+}
+
+SERD_API
 SerdEnv*
 serd_writer_get_env(SerdWriter* writer)
 {