summaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/syntax.c143
1 files changed, 113 insertions, 30 deletions
diff --git a/src/syntax.c b/src/syntax.c
index 6542071..686893d 100644
--- a/src/syntax.c
+++ b/src/syntax.c
@@ -238,7 +238,7 @@ sord_read_file(SordModel model,
SORD_API
bool
-sord_read_file_handle(SordModel sord,
+sord_read_file_handle(SordModel model,
FILE* fd,
const uint8_t* base_uri_str_in,
const SordNode graph,
@@ -246,6 +246,7 @@ sord_read_file_handle(SordModel sord,
{
size_t base_uri_n_bytes = 0;
uint8_t* base_uri_str = copy_string(base_uri_str_in, &base_uri_n_bytes);
+
SerdURI base_uri;
if (!serd_uri_parse(base_uri_str, &base_uri)) {
fprintf(stderr, "invalid base URI `%s'\n", base_uri_str);
@@ -260,7 +261,7 @@ sord_read_file_handle(SordModel sord,
ReadState state = { NULL, env, graph,
base_uri_node, base_uri,
- sord_get_world(sord), sord };
+ sord_get_world(model), model };
state.reader = serd_reader_new(
SERD_TURTLE, &state,
@@ -280,6 +281,43 @@ sord_read_file_handle(SordModel sord,
SORD_API
bool
+sord_read_string(SordModel model,
+ const uint8_t* str,
+ const uint8_t* base_uri_str_in)
+{
+ size_t base_uri_n_bytes = 0;
+ uint8_t* base_uri_str = copy_string(base_uri_str_in, &base_uri_n_bytes);
+
+ SerdURI base_uri;
+ if (!serd_uri_parse(base_uri_str, &base_uri)) {
+ fprintf(stderr, "invalid base URI `%s'\n", base_uri_str);
+ }
+
+ SerdEnv env = serd_env_new();
+
+ const SerdNode base_uri_node = { SERD_URI,
+ base_uri_n_bytes,
+ base_uri_n_bytes - 1, // FIXME: UTF-8
+ base_uri_str };
+
+ ReadState state = { NULL, env, NULL,
+ base_uri_node, base_uri,
+ sord_get_world(model), model };
+
+ state.reader = serd_reader_new(
+ SERD_TURTLE, &state,
+ event_base, event_prefix, event_statement, NULL);
+
+ const bool success = serd_reader_read_string(state.reader, str);
+
+ serd_reader_free(state.reader);
+ serd_node_free(&state.base_uri_node);
+
+ return success;
+}
+
+SORD_API
+bool
sord_write_file(SordModel model,
SerdEnv env,
const uint8_t* uri,
@@ -309,33 +347,11 @@ file_sink(const void* buf, size_t len, void* stream)
return fwrite(buf, 1, len, file);
}
-SORD_API
-bool
-sord_write_file_handle(SordModel model,
- SerdEnv env,
- FILE* fd,
- const uint8_t* base_uri_str_in,
- const SordNode graph,
- const uint8_t* blank_prefix)
+static void
+sord_write(const SordModel model,
+ const SordNode graph,
+ SerdWriter writer)
{
- size_t base_uri_n_bytes = 0;
- uint8_t* base_uri_str = copy_string(base_uri_str_in, &base_uri_n_bytes);
- SerdURI base_uri;
- if (!serd_uri_parse(base_uri_str, &base_uri)) {
- fprintf(stderr, "invalid base URI `%s'\n", base_uri_str);
- }
-
- SerdWriter writer = serd_writer_new(SERD_TURTLE,
- SERD_STYLE_ABBREVIATED|SERD_STYLE_CURIED,
- env,
- &base_uri,
- file_sink,
- fd);
-
- serd_env_foreach(env,
- (SerdPrefixSink)serd_writer_set_prefix,
- writer);
-
SerdNode s_graph;
sord_node_to_serd_node(graph, &s_graph);
for (SordIter i = sord_begin(model); !sord_iter_end(i); sord_iter_next(i)) {
@@ -366,9 +382,76 @@ sord_write_file_handle(SordModel model,
&subject, &predicate, &object,
&datatype, &language);
}
+}
- serd_writer_free(writer);
- free(base_uri_str);
+static SerdWriter
+make_writer(SerdEnv env,
+ const uint8_t* base_uri_str_in,
+ SerdSink sink,
+ void* stream)
+{
+ size_t base_uri_n_bytes = 0;
+ uint8_t* base_uri_str = copy_string(base_uri_str_in, &base_uri_n_bytes);
+ SerdURI base_uri;
+ if (!serd_uri_parse(base_uri_str, &base_uri)) {
+ fprintf(stderr, "invalid base URI `%s'\n", base_uri_str);
+ }
+
+ SerdWriter writer = serd_writer_new(SERD_TURTLE,
+ SERD_STYLE_ABBREVIATED|SERD_STYLE_CURIED,
+ env,
+ &base_uri,
+ sink,
+ stream);
+
+ serd_env_foreach(env,
+ (SerdPrefixSink)serd_writer_set_prefix,
+ writer);
+
+ return writer;
+}
+
+SORD_API
+bool
+sord_write_file_handle(SordModel model,
+ SerdEnv env,
+ FILE* fd,
+ const uint8_t* base_uri_str_in,
+ const SordNode graph,
+ const uint8_t* blank_prefix)
+{
+ SerdWriter writer = make_writer(env, base_uri_str_in, file_sink, fd);
+ sord_write(model, graph, writer);
+ serd_writer_free(writer);
return true;
}
+
+struct SerdBuffer {
+ uint8_t* buf;
+ size_t len;
+};
+
+static size_t
+string_sink(const void* buf, size_t len, void* stream)
+{
+ struct SerdBuffer* out = (struct SerdBuffer*)stream;
+ out->buf = realloc(out->buf, out->len + len);
+ memcpy(out->buf + out->len, buf, len);
+ out->len += len;
+ return len;
+}
+
+SORD_API
+uint8_t*
+sord_write_string(SordModel model,
+ SerdEnv env,
+ const uint8_t* base_uri)
+{
+ struct SerdBuffer buf = { NULL, 0 };
+ SerdWriter writer = make_writer(env, base_uri, string_sink, &buf);
+ sord_write(model, NULL, writer);
+ serd_writer_free(writer);
+ string_sink("", 1, &buf);
+ return buf.buf;
+}