5 files changed, 37 insertions, 33 deletions

diff --git a/src/reader.c b/src/reader.c
index 1c4c5104..a9db44f9 100644
--- a/src/reader.c
+++ b/src/reader.c
@@ -35,7 +35,7 @@ r_err(SerdReader* reader, SerdStatus st, const char* fmt, ...)
 	va_start(args, fmt);
 	const Cursor* const cur = &reader->source.cur;
 	const SerdError e = { st, cur->filename, cur->line, cur->col, fmt, &args };
-	serd_error(reader->world, &e);
+	serd_world_error(reader->world, &e);
 	va_end(args);
 	return 0;
 }
diff --git a/src/serd_internal.h b/src/serd_internal.h
index 172343b8..601af56c 100644
--- a/src/serd_internal.h
+++ b/src/serd_internal.h
@@ -69,15 +69,4 @@ serd_bufalloc(size_t size)
 #endif
 }
 
-static inline void
-serd_error(const SerdWorld* world, const SerdError* e)
-{
-	if (world->error_sink) {
-		world->error_sink(world->error_handle, e);
-	} else {
-		fprintf(stderr, "error: %s:%u:%u: ", e->filename, e->line, e->col);
-		vfprintf(stderr, e->fmt, *e->args);
-	}
-}
-
 #endif  // SERD_INTERNAL_H
diff --git a/src/world.c b/src/world.c
index 07439137..0210760d 100644
--- a/src/world.c
+++ b/src/world.c
@@ -16,8 +16,33 @@
 
 #include "serd_internal.h"
 
+#include <stdarg.h>
+
 #include "world.h"
 
+SerdStatus
+serd_world_error(const SerdWorld* world, const SerdError* e)
+{
+	if (world->error_sink) {
+		world->error_sink(world->error_handle, e);
+	} else {
+		fprintf(stderr, "error: %s:%u:%u: ", e->filename, e->line, e->col);
+		vfprintf(stderr, e->fmt, *e->args);
+	}
+	return e->status;
+}
+
+SerdStatus
+serd_world_errorf(const SerdWorld* world, SerdStatus st, const char* fmt, ...)
+{
+	va_list args;
+	va_start(args, fmt);
+	const SerdError e = { st, NULL, 0, 0, fmt, &args };
+	serd_world_error(world, &e);
+	va_end(args);
+	return st;
+}
+
 SerdWorld*
 serd_world_new(void)
 {
diff --git a/src/world.h b/src/world.h
index 88241b0e..7e451b0e 100644
--- a/src/world.h
+++ b/src/world.h
@@ -24,4 +24,9 @@ struct SerdWorldImpl {
 	void*         error_handle;
 };
 
+SerdStatus serd_world_error(const SerdWorld* world, const SerdError* e);
+
+SerdStatus
+serd_world_errorf(const SerdWorld* world, SerdStatus st, const char* fmt, ...);
+
 #endif  // SERD_WORLD_H
diff --git a/src/writer.c b/src/writer.c
index 04ced4f5..ed8ab0c3 100644
--- a/src/writer.c
+++ b/src/writer.c
@@ -133,22 +133,6 @@ supports_abbrev(const SerdWriter* writer)
 	return writer->syntax == SERD_TURTLE || writer->syntax == SERD_TRIG;
 }
 
-static void
-w_err(SerdWriter* writer, SerdStatus st, const char* fmt, ...)
-{
-	/* TODO: This results in errors with no file information, which is not
-	   helpful when re-serializing a file (particularly for "undefined
-	   namespace prefix" errors.  The statement sink API needs to be changed to
-	   add a Cursor parameter so the source can notify the writer of the
-	   statement origin for better error reporting. */
-
-	va_list args;
-	va_start(args, fmt);
-	const SerdError e = { st, NULL, 0, 0, fmt, &args };
-	serd_error(writer->world, &e);
-	va_end(args);
-}
-
 static inline WriteContext*
 anon_stack_top(SerdWriter* writer)
 {
@@ -191,7 +175,8 @@ write_character(SerdWriter* writer, const uint8_t* utf8, size_t* size)
 	const uint32_t c          = parse_utf8_char(utf8, size);
 	switch (*size) {
 	case 0:
-		w_err(writer, SERD_ERR_BAD_ARG, "invalid UTF-8: %X\n", utf8[0]);
+		serd_world_errorf(
+			writer->world, SERD_ERR_BAD_ARG, "invalid UTF-8: %X\n", utf8[0]);
 		return sink(replacement_char, sizeof(replacement_char), writer);
 	case 1:
 		snprintf(escape, sizeof(escape), "\\u%04X", utf8[0]);
@@ -580,7 +565,8 @@ write_curie(SerdWriter* const        writer,
 	case SERD_NTRIPLES:
 	case SERD_NQUADS:
 		if ((st = serd_env_expand(writer->env, node, &prefix, &suffix))) {
-			w_err(writer, st, "undefined namespace prefix `%s'\n", node_str);
+			serd_world_errorf(writer->world, st,
+			                  "undefined namespace prefix `%s'\n", node_str);
 			return false;
 		}
 		write_sep(writer, SEP_URI_BEGIN);
@@ -841,9 +827,8 @@ serd_writer_end_anon(SerdWriter*     writer,
 		return SERD_SUCCESS;
 	}
 	if (serd_stack_is_empty(&writer->anon_stack) || writer->indent == 0) {
-		w_err(writer, SERD_ERR_UNKNOWN,
-		      "unexpected end of anonymous node\n");
-		return SERD_ERR_UNKNOWN;
+		return serd_world_errorf(writer->world, SERD_ERR_UNKNOWN,
+		                         "unexpected end of anonymous node\n");
 	}
 	--writer->indent;
 	write_sep(writer, SEP_ANON_END);