/*
  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 "byte_sink.h"
#include "env.h"
#include "node.h"
#include "serd_internal.h"
#include "sink.h"
#include "stack.h"
#include "string_utils.h"
#include "uri_utils.h"

#include "serd/serd.h"

#include <assert.h>
#include <stdarg.h>
#include <stdbool.h>
#include <stdint.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>

typedef enum {
  FIELD_NONE,
  FIELD_SUBJECT,
  FIELD_PREDICATE,
  FIELD_OBJECT,
  FIELD_GRAPH
} Field;

typedef struct {
  SerdNode* graph;
  SerdNode* subject;
  SerdNode* predicate;
} WriteContext;

static const WriteContext WRITE_CONTEXT_NULL = {NULL, NULL, NULL};

typedef enum {
  SEP_NONE,
  SEP_END_S,       ///< End of a subject ('.')
  SEP_END_P,       ///< End of a predicate (';')
  SEP_END_O,       ///< End of an object (',')
  SEP_S_P,         ///< Between a subject and predicate (whitespace)
  SEP_P_O,         ///< Between a predicate and object (whitespace)
  SEP_ANON_BEGIN,  ///< Start of anonymous node ('[')
  SEP_ANON_END,    ///< End of anonymous node (']')
  SEP_LIST_BEGIN,  ///< Start of list ('(')
  SEP_LIST_SEP,    ///< List separator (whitespace)
  SEP_LIST_END,    ///< End of list (')')
  SEP_GRAPH_BEGIN, ///< Start of graph ('{')
  SEP_GRAPH_END,   ///< End of graph ('}')
  SEP_URI_BEGIN,   ///< URI start quote ('<')
  SEP_URI_END      ///< URI end quote ('>')
} Sep;

typedef struct {
  const char* str;              ///< Sep string
  uint8_t     len;              ///< Length of sep string
  uint8_t     space_before;     ///< Newline before sep
  uint8_t     space_after_node; ///< Newline after sep if after node
  uint8_t     space_after_sep;  ///< Newline after sep if after sep
} SepRule;

static const SepRule rules[] = {{NULL, 0, 0, 0, 0},
                                {" .\n\n", 4, 0, 0, 0},
                                {" ;", 2, 0, 1, 1},
                                {" ,", 2, 0, 1, 0},
                                {NULL, 0, 0, 1, 0},
                                {" ", 1, 0, 0, 0},
                                {"[", 1, 0, 1, 1},
                                {"]", 1, 1, 0, 0},
                                {"(", 1, 0, 0, 0},
                                {NULL, 0, 0, 1, 0},
                                {")", 1, 1, 0, 0},
                                {" {", 2, 0, 1, 1},
                                {" }", 2, 0, 1, 1},
                                {"<", 1, 0, 0, 0},
                                {">", 1, 0, 0, 0},
                                {"\n", 1, 0, 1, 0}};

struct SerdWriterImpl {
  SerdSink        iface;
  SerdSyntax      syntax;
  SerdWriterFlags flags;
  SerdEnv*        env;
  SerdNode*       root_node;
  SerdURIView     root_uri;
  SerdStack       anon_stack;
  SerdByteSink    byte_sink;
  SerdErrorFunc   error_func;
  void*           error_handle;
  WriteContext    context;
  SerdNode*       list_subj;
  unsigned        list_depth;
  unsigned        indent;
  char*           bprefix;
  size_t          bprefix_len;
  Sep             last_sep;
  bool            empty;
};

typedef enum { WRITE_STRING, 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,
           Field              field,
           SerdStatementFlags flags);

static bool
supports_abbrev(const SerdWriter* writer)
{
  return writer->syntax == SERD_TURTLE || writer->syntax == SERD_TRIG;
}

static bool
supports_uriref(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, "", 0, 0, fmt, &args};
  serd_error(writer->error_func, writer->error_handle, &e);
  va_end(args);
}

static inline SERD_PURE_FUNC
WriteContext*
anon_stack_top(SerdWriter* writer)
{
  assert(!serd_stack_is_empty(&writer->anon_stack));
  return (WriteContext*)(writer->anon_stack.buf + writer->anon_stack.size -
                         sizeof(WriteContext));
}

static inline SerdNode*
ctx(SerdWriter* writer, const Field field)
{
  SerdNode* node = NULL;
  if (field == FIELD_SUBJECT) {
    node = writer->context.subject;
  } else if (field == FIELD_PREDICATE) {
    node = writer->context.predicate;
  } else if (field == FIELD_GRAPH) {
    node = writer->context.graph;
  }

  return node && node->type ? node : NULL;
}

static inline size_t
sink(const void* buf, size_t len, SerdWriter* writer)
{
  return serd_byte_sink_write(buf, len, &writer->byte_sink);
}

// Write a single character, as an escape for single byte characters
// (Caller prints any single byte characters that don't need escaping)
static size_t
write_character(SerdWriter* writer, const uint8_t* utf8, size_t* size)
{
  char           escape[11] = {0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0};
  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]);
    return sink(replacement_char, sizeof(replacement_char), writer);
  case 1:
    snprintf(escape, sizeof(escape), "\\u%04X", utf8[0]);
    return sink(escape, 6, writer);
  default:
    break;
  }

  if (!(writer->flags & SERD_WRITE_ASCII)) {
    // Write UTF-8 character directly to UTF-8 output
    return sink(utf8, *size, writer);
  }

  if (c <= 0xFFFF) {
    snprintf(escape, sizeof(escape), "\\u%04X", c);
    return sink(escape, 6, writer);
  }

  snprintf(escape, sizeof(escape), "\\U%08X", c);
  return sink(escape, 10, writer);
}

static inline bool
uri_must_escape(const char c)
{
  switch (c) {
  case ' ':
  case '"':
  case '<':
  case '>':
  case '\\':
  case '^':
  case '`':
  case '{':
  case '|':
  case '}':
    return true;
  default:
    return !in_range(c, 0x20, 0x7E);
  }
}

static size_t
write_uri(SerdWriter* writer, const char* utf8, size_t n_bytes)
{
  size_t len = 0;
  for (size_t i = 0; i < n_bytes;) {
    size_t j = i; // Index of next character that must be escaped
    for (; j < n_bytes; ++j) {
      if (uri_must_escape(utf8[j])) {
        break;
      }
    }

    // Bulk write all characters up to this special one
    len += sink(&utf8[i], j - i, writer);
    if ((i = j) == n_bytes) {
      break; // Reached end
    }

    // Write UTF-8 character
    size_t size = 0;
    len += write_character(writer, (const uint8_t*)utf8 + i, &size);
    i += size;
    if (size == 0) {
      // Corrupt input, scan to start of next character
      for (++i; i < n_bytes && (utf8[i] & 0x80); ++i) {
      }
    }
  }
  return len;
}

static size_t
write_uri_from_node(SerdWriter* writer, const SerdNode* node)
{
  return write_uri(writer, serd_node_string(node), node->n_bytes);
}

static bool
lname_must_escape(const char c)
{
  /* This arbitrary list of characters, most of which have nothing to do with
     Turtle, must be handled as special cases here because the RDF and SPARQL
     WGs are apparently intent on making the once elegant Turtle a baroque
     and inconsistent mess, throwing elegance and extensibility completely
     out the window for no good reason.

     Note '-', '.', and '_' are also in PN_LOCAL_ESC, but are valid unescaped
     in local names, so they are not escaped here. */

  switch (c) {
  case '\'':
  case '!':
  case '#':
  case '$':
  case '%':
  case '&':
  case '(':
  case ')':
  case '*':
  case '+':
  case ',':
  case '/':
  case ';':
  case '=':
  case '?':
  case '@':
  case '~':
    return true;
  default:
    break;
  }
  return false;
}

static size_t
write_lname(SerdWriter* writer, const char* utf8, size_t n_bytes)
{
  size_t len = 0;
  for (size_t i = 0; i < n_bytes; ++i) {
    size_t j = i; // Index of next character that must be escaped
    for (; j < n_bytes; ++j) {
      if (lname_must_escape(utf8[j])) {
        break;
      }
    }

    // Bulk write all characters up to this special one
    len += sink(&utf8[i], j - i, writer);
    if ((i = j) == n_bytes) {
      break; // Reached end
    }

    // Write escape
    len += sink("\\", 1, writer);
    len += sink(&utf8[i], 1, writer);
  }

  return len;
}

static size_t
write_text(SerdWriter* writer,
           TextContext ctx,
           const char* utf8,
           size_t      n_bytes)
{
  size_t len                  = 0;
  size_t n_consecutive_quotes = 0;
  for (size_t i = 0; i < n_bytes;) {
    if (utf8[i] != '"') {
      n_consecutive_quotes = 0;
    }

    // Fast bulk write for long strings of printable ASCII
    size_t j = i;
    for (; j < n_bytes; ++j) {
      if (utf8[j] == '\\' || utf8[j] == '"' ||
          (!in_range(utf8[j], 0x20, 0x7E))) {
        break;
      }
    }

    len += sink(&utf8[i], j - i, writer);
    if ((i = j) == n_bytes) {
      break; // Reached end
    }

    const char in = utf8[i++];
    if (ctx == WRITE_LONG_STRING) {
      n_consecutive_quotes = (in == '\"') ? (n_consecutive_quotes + 1) : 0;

      switch (in) {
      case '\\':
        len += sink("\\\\", 2, writer);
        continue;
      case '\b':
        len += sink("\\b", 2, writer);
        continue;
      case '\n':
      case '\r':
      case '\t':
      case '\f':
        len += sink(&in, 1, writer); // Write character as-is
        continue;
      case '\"':
        if (n_consecutive_quotes >= 3 || i == n_bytes) {
          // Two quotes in a row, or quote at string end, escape
          len += sink("\\\"", 2, writer);
        } else {
          len += sink(&in, 1, writer);
        }
        continue;
      default:
        break;
      }
    } else if (ctx == WRITE_STRING) {
      switch (in) {
      case '\\':
        len += sink("\\\\", 2, writer);
        continue;
      case '\n':
        len += sink("\\n", 2, writer);
        continue;
      case '\r':
        len += sink("\\r", 2, writer);
        continue;
      case '\t':
        len += sink("\\t", 2, writer);
        continue;
      case '"':
        len += sink("\\\"", 2, writer);
        continue;
      default:
        break;
      }
      if (writer->syntax == SERD_TURTLE) {
        switch (in) {
        case '\b':
          len += sink("\\b", 2, writer);
          continue;
        case '\f':
          len += sink("\\f", 2, writer);
          continue;
        default:
          break;
        }
      }
    }

    // Write UTF-8 character
    size_t size = 0;
    len += write_character(writer, (const uint8_t*)utf8 + i - 1, &size);

    if (size == 0) {
      // Corrupt input, scan to start of next character
      for (; i < n_bytes && (utf8[i] & 0x80); ++i) {
      }
    } else {
      i += size - 1;
    }
  }
  return len;
}

static size_t
uri_sink(const void* buf, size_t size, size_t nmemb, void* stream)
{
  (void)size;
  assert(size == 1);
  return write_uri((SerdWriter*)stream, (const char*)buf, nmemb);
}

static void
write_newline(SerdWriter* writer)
{
  sink("\n", 1, writer);
  for (unsigned i = 0; i < writer->indent; ++i) {
    sink("\t", 1, writer);
  }
}

static bool
write_sep(SerdWriter* writer, const Sep sep)
{
  const SepRule* rule = &rules[sep];
  if (rule->space_before) {
    write_newline(writer);
  }

  if (rule->str) {
    sink(rule->str, rule->len, writer);
  }

  if ((writer->last_sep && rule->space_after_sep) ||
      (!writer->last_sep && rule->space_after_node)) {
    write_newline(writer);
  } else if (writer->last_sep && rule->space_after_node) {
    sink(" ", 1, writer);
  }

  writer->last_sep = sep;
  return true;
}

static SerdStatus
reset_context(SerdWriter* writer, bool graph)
{
  if (graph && writer->context.graph) {
    memset(writer->context.graph, 0, sizeof(SerdNode));
  }
  if (writer->context.subject) {
    memset(writer->context.subject, 0, sizeof(SerdNode));
  }
  if (writer->context.predicate) {
    memset(writer->context.predicate, 0, sizeof(SerdNode));
  }
  writer->empty = false;
  return SERD_SUCCESS;
}

static SerdStatus
free_context(SerdWriter* writer)
{
  serd_node_free(writer->context.graph);
  serd_node_free(writer->context.subject);
  serd_node_free(writer->context.predicate);
  return SERD_SUCCESS;
}

static bool
is_inline_start(const SerdWriter* writer, Field field, SerdStatementFlags flags)
{
  return (supports_abbrev(writer) &&
          ((field == FIELD_SUBJECT && (flags & SERD_ANON_S_BEGIN)) ||
           (field == FIELD_OBJECT && (flags & SERD_ANON_O_BEGIN))));
}

static bool
write_literal(SerdWriter*        writer,
              const SerdNode*    node,
              SerdStatementFlags flags)
{
  const SerdNode* datatype = serd_node_datatype(node);
  const SerdNode* lang     = serd_node_language(node);
  const char*     node_str = serd_node_string(node);
  const char*     type_uri = datatype ? serd_node_string(datatype) : NULL;
  if (supports_abbrev(writer) && type_uri) {
    if (!strncmp(type_uri, NS_XSD, sizeof(NS_XSD) - 1) &&
        (!strcmp(type_uri + sizeof(NS_XSD) - 1, "boolean") ||
         !strcmp(type_uri + sizeof(NS_XSD) - 1, "integer"))) {
      sink(node_str, node->n_bytes, writer);
      return true;
    }

    if (!strncmp(type_uri, NS_XSD, sizeof(NS_XSD) - 1) &&
        !strcmp(type_uri + sizeof(NS_XSD) - 1, "decimal") &&
        strchr(node_str, '.') && node_str[node->n_bytes - 1] != '.') {
      /* xsd:decimal literals without trailing digits, e.g. "5.", can
         not be written bare in Turtle.  We could add a 0 which is
         prettier, but changes the text and breaks round tripping.
      */
      sink(node_str, node->n_bytes, writer);
      return true;
    }
  }

  if (supports_abbrev(writer) &&
      (node->flags & (SERD_HAS_NEWLINE | SERD_HAS_QUOTE))) {
    sink("\"\"\"", 3, writer);
    write_text(writer, WRITE_LONG_STRING, node_str, node->n_bytes);
    sink("\"\"\"", 3, writer);
  } else {
    sink("\"", 1, writer);
    write_text(writer, WRITE_STRING, node_str, node->n_bytes);
    sink("\"", 1, writer);
  }
  if (lang && serd_node_string(lang)) {
    sink("@", 1, writer);
    sink(serd_node_string(lang), lang->n_bytes, writer);
  } else if (type_uri) {
    sink("^^", 2, writer);
    return write_node(writer, datatype, FIELD_NONE, flags);
  }
  return true;
}

// Return true iff `buf` is a valid prefixed name suffix
static inline bool
is_name(const char* buf, const size_t len)
{
  // TODO: This is more strict than it should be
  for (size_t i = 0; i < len; ++i) {
    if (!(is_alpha(buf[i]) || is_digit(buf[i]))) {
      return false;
    }
  }

  return true;
}

static bool
write_uri_node(SerdWriter* const        writer,
               const SerdNode*          node,
               const Field              field,
               const SerdStatementFlags flags)
{
  const SerdNode* prefix = NULL;
  SerdStringView  suffix = {NULL, 0};

  if (is_inline_start(writer, field, flags)) {
    ++writer->indent;
    write_sep(writer, SEP_ANON_BEGIN);
    sink("== ", 3, writer);
  }

  const char* node_str   = serd_node_string(node);
  const bool  has_scheme = serd_uri_string_has_scheme(node_str);
  if (supports_abbrev(writer)) {
    if (field == FIELD_PREDICATE && !strcmp(node_str, NS_RDF "type")) {
      return sink("a", 1, writer) == 1;
    }

    if (!strcmp(node_str, NS_RDF "nil")) {
      return sink("()", 2, writer) == 2;
    }

    if (has_scheme && (writer->flags & SERD_WRITE_CURIED) &&
        serd_env_qualify(writer->env, node, &prefix, &suffix) &&
        is_name(suffix.buf, suffix.len)) {
      write_uri_from_node(writer, prefix);
      sink(":", 1, writer);
      write_uri(writer, suffix.buf, suffix.len);
      return true;
    }
  }

  if (!has_scheme && !supports_uriref(writer) &&
      !serd_env_base_uri(writer->env)) {
    w_err(writer,
          SERD_ERR_BAD_ARG,
          "syntax does not support URI reference <%s>\n",
          node_str);
    return false;
  }

  write_sep(writer, SEP_URI_BEGIN);
  if ((writer->flags & SERD_WRITE_RESOLVED) && serd_env_base_uri(writer->env)) {
    const SerdURIView  base_uri = serd_env_base_uri_view(writer->env);
    SerdURIView        uri      = serd_parse_uri(node_str);
    SerdURIView        abs_uri  = serd_resolve_uri(uri, base_uri);
    bool               rooted   = uri_is_under(&base_uri, &writer->root_uri);
    const SerdURIView* root     = rooted ? &writer->root_uri : &base_uri;

    if (writer->syntax == SERD_NTRIPLES || writer->syntax == SERD_NQUADS ||
        !uri_is_under(&abs_uri, root) || !uri_is_related(&abs_uri, &base_uri)) {
      serd_write_uri(abs_uri, uri_sink, writer);
    } else {
      serd_write_uri(serd_relative_uri(uri, base_uri), uri_sink, writer);
    }
  } else {
    write_uri_from_node(writer, node);
  }
  write_sep(writer, SEP_URI_END);

  if (is_inline_start(writer, field, flags)) {
    sink(" ;", 2, writer);
    write_newline(writer);
  }

  return true;
}

static bool
write_curie(SerdWriter* const        writer,
            const SerdNode*          node,
            const Field              field,
            const SerdStatementFlags flags)
{
  const char* node_str = serd_node_string(node);

  SerdStringView prefix = {NULL, 0};
  SerdStringView suffix = {NULL, 0};
  SerdStatus     st     = SERD_SUCCESS;
  switch (writer->syntax) {
  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);
      return false;
    }
    write_sep(writer, SEP_URI_BEGIN);
    write_uri(writer, prefix.buf, prefix.len);
    write_uri(writer, suffix.buf, suffix.len);
    write_sep(writer, SEP_URI_END);
    break;
  case SERD_TURTLE:
  case SERD_TRIG:
    if (is_inline_start(writer, field, flags)) {
      ++writer->indent;
      write_sep(writer, SEP_ANON_BEGIN);
      sink("== ", 3, writer);
    }
    write_lname(writer, node_str, node->n_bytes);
    if (is_inline_start(writer, field, flags)) {
      sink(" ;", 2, writer);
      write_newline(writer);
    }
  }
  return true;
}

static bool
write_blank(SerdWriter* const        writer,
            const SerdNode*          node,
            const Field              field,
            const SerdStatementFlags flags)
{
  const char* node_str = serd_node_string(node);
  if (supports_abbrev(writer)) {
    if (is_inline_start(writer, field, flags)) {
      ++writer->indent;
      return write_sep(writer, SEP_ANON_BEGIN);
    }

    if (field == FIELD_SUBJECT && (flags & SERD_LIST_S_BEGIN)) {
      assert(writer->list_depth == 0);
      serd_node_set(&writer->list_subj, node);
      ++writer->list_depth;
      ++writer->indent;
      return write_sep(writer, SEP_LIST_BEGIN);
    }

    if (field == FIELD_OBJECT && (flags & SERD_LIST_O_BEGIN)) {
      ++writer->indent;
      ++writer->list_depth;
      return write_sep(writer, SEP_LIST_BEGIN);
    }

    if ((field == FIELD_SUBJECT && (flags & SERD_EMPTY_S)) ||
        (field == FIELD_OBJECT && (flags & SERD_EMPTY_O))) {
      return sink("[]", 2, writer) == 2;
    }
  }

  sink("_:", 2, writer);
  if (writer->bprefix &&
      !strncmp(node_str, writer->bprefix, writer->bprefix_len)) {
    sink(node_str + writer->bprefix_len,
         node->n_bytes - writer->bprefix_len,
         writer);
  } else {
    sink(node_str, node->n_bytes, writer);
  }

  return true;
}

static bool
write_node(SerdWriter*        writer,
           const SerdNode*    node,
           Field              field,
           SerdStatementFlags flags)
{
  bool ret = false;
  switch (node->type) {
  case SERD_LITERAL:
    ret = write_literal(writer, node, flags);
    break;
  case SERD_URI:
    ret = write_uri_node(writer, node, field, flags);
    break;
  case SERD_CURIE:
    ret = write_curie(writer, node, field, flags);
    break;
  case SERD_BLANK:
    ret = write_blank(writer, node, field, flags);
    break;
  }
  writer->last_sep = SEP_NONE;
  return ret;
}

static inline bool
is_resource(const SerdNode* node)
{
  return node && node->type > SERD_LITERAL;
}

static void
write_pred(SerdWriter* writer, SerdStatementFlags flags, const SerdNode* pred)
{
  write_node(writer, pred, FIELD_PREDICATE, flags);
  write_sep(writer, SEP_P_O);
  serd_node_set(&writer->context.predicate, pred);
}

static bool
write_list_obj(SerdWriter*        writer,
               SerdStatementFlags flags,
               const SerdNode*    predicate,
               const SerdNode*    object)
{
  if (!strcmp(serd_node_string(object), NS_RDF "nil")) {
    --writer->indent;
    write_sep(writer, SEP_LIST_END);
    return true;
  }

  if (!strcmp(serd_node_string(predicate), NS_RDF "first")) {
    write_sep(writer, SEP_LIST_SEP);
    write_node(writer, object, FIELD_OBJECT, flags);
  }

  return false;
}

static SerdStatus
serd_writer_write_statement(SerdWriter*        writer,
                            SerdStatementFlags flags,
                            const SerdNode*    graph,
                            const SerdNode*    subject,
                            const SerdNode*    predicate,
                            const SerdNode*    object)
{
  if (!is_resource(subject) || !is_resource(predicate) || !object) {
    return SERD_ERR_BAD_ARG;
  }

#define TRY(write_result)      \
  do {                         \
    if (!(write_result)) {     \
      return SERD_ERR_UNKNOWN; \
    }                          \
  } while (0)

  if (writer->syntax == SERD_NTRIPLES || writer->syntax == SERD_NQUADS) {
    TRY(write_node(writer, subject, FIELD_SUBJECT, flags));
    sink(" ", 1, writer);
    TRY(write_node(writer, predicate, FIELD_PREDICATE, flags));
    sink(" ", 1, writer);
    TRY(write_node(writer, object, FIELD_OBJECT, flags));
    if (writer->syntax == SERD_NQUADS && graph) {
      sink(" ", 1, writer);
      TRY(write_node(writer, graph, FIELD_GRAPH, flags));
    }
    sink(" .\n", 3, writer);
    return SERD_SUCCESS;
  }

  if ((graph && !serd_node_equals(graph, writer->context.graph)) ||
      (!graph && ctx(writer, FIELD_GRAPH))) {
    writer->indent = 0;
    if (ctx(writer, FIELD_SUBJECT)) {
      write_sep(writer, SEP_END_S);
    }
    if (ctx(writer, FIELD_GRAPH)) {
      write_sep(writer, SEP_GRAPH_END);
    }

    reset_context(writer, true);
    if (graph) {
      TRY(write_node(writer, graph, FIELD_GRAPH, flags));
      ++writer->indent;
      write_sep(writer, SEP_GRAPH_BEGIN);
      serd_node_set(&writer->context.graph, graph);
    }
  }

  if ((flags & SERD_LIST_CONT)) {
    if (write_list_obj(writer, flags, predicate, object)) {
      // Reached end of list
      if (--writer->list_depth == 0 && writer->list_subj) {
        reset_context(writer, false);
        serd_node_free(writer->context.subject);
        writer->context.subject = writer->list_subj;
        writer->list_subj       = NULL;
      }
      return SERD_SUCCESS;
    }
  } else if (serd_node_equals(subject, writer->context.subject)) {
    if (serd_node_equals(predicate, writer->context.predicate)) {
      // Abbreviate S P
      if (!(flags & SERD_ANON_O_BEGIN)) {
        ++writer->indent;
      }
      write_sep(writer, SEP_END_O);
      write_node(writer, object, FIELD_OBJECT, flags);
      if (!(flags & SERD_ANON_O_BEGIN)) {
        --writer->indent;
      }
    } else {
      // Abbreviate S
      Sep sep = ctx(writer, FIELD_PREDICATE) ? SEP_END_P : SEP_S_P;
      write_sep(writer, sep);
      write_pred(writer, flags, predicate);
      write_node(writer, object, FIELD_OBJECT, flags);
    }
  } else {
    // No abbreviation
    if (ctx(writer, FIELD_SUBJECT)) {
      assert(writer->indent > 0);
      --writer->indent;
      if (serd_stack_is_empty(&writer->anon_stack)) {
        write_sep(writer, SEP_END_S);
      }
    } else if (!writer->empty) {
      write_sep(writer, SEP_S_P);
    }

    if (!(flags & SERD_ANON_CONT)) {
      write_node(writer, subject, FIELD_SUBJECT, flags);
      ++writer->indent;
      write_sep(writer, SEP_S_P);
    } else {
      ++writer->indent;
    }

    reset_context(writer, false);
    serd_node_set(&writer->context.subject, subject);

    if (!(flags & SERD_LIST_S_BEGIN)) {
      write_pred(writer, flags, predicate);
    }

    write_node(writer, object, FIELD_OBJECT, flags);
  }

  if (flags & (SERD_ANON_S_BEGIN | SERD_ANON_O_BEGIN)) {
    WriteContext* ctx =
      (WriteContext*)serd_stack_push(&writer->anon_stack, sizeof(WriteContext));
    *ctx                     = writer->context;
    WriteContext new_context = {
      serd_node_copy(graph), serd_node_copy(subject), NULL};
    if ((flags & SERD_ANON_S_BEGIN)) {
      new_context.predicate = serd_node_copy(predicate);
    }
    writer->context = new_context;
  } else {
    serd_node_set(&writer->context.graph, graph);
    serd_node_set(&writer->context.subject, subject);
    serd_node_set(&writer->context.predicate, predicate);
  }

  return SERD_SUCCESS;
}

static SerdStatus
serd_writer_end_anon(SerdWriter* writer, const SerdNode* node)
{
  if (writer->syntax == SERD_NTRIPLES || writer->syntax == SERD_NQUADS) {
    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;
  }
  --writer->indent;
  write_sep(writer, SEP_ANON_END);
  free_context(writer);
  writer->context = *anon_stack_top(writer);
  serd_stack_pop(&writer->anon_stack, sizeof(WriteContext));
  const bool is_subject = serd_node_equals(node, writer->context.subject);
  if (is_subject) {
    serd_node_set(&writer->context.subject, node);
    memset(writer->context.predicate, 0, sizeof(SerdNode));
  }
  return SERD_SUCCESS;
}

SerdStatus
serd_writer_finish(SerdWriter* writer)
{
  if (ctx(writer, FIELD_SUBJECT)) {
    write_sep(writer, SEP_END_S);
  }
  if (ctx(writer, FIELD_GRAPH)) {
    write_sep(writer, SEP_GRAPH_END);
  }
  serd_byte_sink_flush(&writer->byte_sink);
  free_context(writer);
  writer->indent  = 0;
  writer->context = WRITE_CONTEXT_NULL;
  return SERD_SUCCESS;
}

SerdWriter*
serd_writer_new(SerdSyntax      syntax,
                SerdWriterFlags flags,
                SerdEnv*        env,
                SerdWriteFunc   ssink,
                void*           stream)
{
  const WriteContext context = WRITE_CONTEXT_NULL;
  SerdWriter*        writer  = (SerdWriter*)calloc(1, sizeof(SerdWriter));

  writer->syntax     = syntax;
  writer->flags      = flags;
  writer->env        = env;
  writer->root_node  = NULL;
  writer->root_uri   = SERD_URI_NULL;
  writer->anon_stack = serd_stack_new(4 * sizeof(WriteContext));
  writer->context    = context;
  writer->list_subj  = NULL;
  writer->empty      = true;
  writer->byte_sink  = serd_byte_sink_new(
    ssink, stream, (flags & SERD_WRITE_BULK) ? SERD_PAGE_SIZE : 1);

  writer->iface.handle    = writer;
  writer->iface.base      = (SerdBaseFunc)serd_writer_set_base_uri;
  writer->iface.prefix    = (SerdPrefixFunc)serd_writer_set_prefix;
  writer->iface.statement = (SerdStatementFunc)serd_writer_write_statement;
  writer->iface.end       = (SerdEndFunc)serd_writer_end_anon;

  return writer;
}

void
serd_writer_set_error_sink(SerdWriter*   writer,
                           SerdErrorFunc error_func,
                           void*         error_handle)
{
  writer->error_func   = error_func;
  writer->error_handle = error_handle;
}

void
serd_writer_chop_blank_prefix(SerdWriter* writer, const char* prefix)
{
  free(writer->bprefix);
  writer->bprefix_len = 0;
  writer->bprefix     = NULL;

  const size_t prefix_len = prefix ? strlen(prefix) : 0;
  if (prefix_len) {
    writer->bprefix_len = prefix_len;
    writer->bprefix     = (char*)malloc(writer->bprefix_len + 1);
    memcpy(writer->bprefix, prefix, writer->bprefix_len + 1);
  }
}

SerdStatus
serd_writer_set_base_uri(SerdWriter* writer, const SerdNode* uri)
{
  if (uri->type != SERD_URI) {
    return SERD_ERR_BAD_ARG;
  }

  if (!serd_env_set_base_uri(writer->env, serd_node_string_view(uri))) {
    if (writer->syntax == SERD_TURTLE || writer->syntax == SERD_TRIG) {
      if (ctx(writer, FIELD_GRAPH) || ctx(writer, FIELD_SUBJECT)) {
        sink(" .\n\n", 4, writer);
        reset_context(writer, true);
      }
      sink("@base <", 7, writer);
      sink(serd_node_string(uri), uri->n_bytes, writer);
      sink("> .\n", 4, writer);
    }
    writer->indent = 0;
    return reset_context(writer, true);
  }
  return SERD_ERR_UNKNOWN;
}

SerdStatus
serd_writer_set_root_uri(SerdWriter* writer, const SerdNode* uri)
{
  serd_node_free(writer->root_node);
  if (uri) {
    writer->root_node = serd_node_copy(uri);
    writer->root_uri  = serd_node_uri_view(writer->root_node);
  } else {
    writer->root_node = NULL;
    writer->root_uri  = SERD_URI_NULL;
  }
  return SERD_SUCCESS;
}

SerdStatus
serd_writer_set_prefix(SerdWriter*     writer,
                       const SerdNode* name,
                       const SerdNode* uri)
{
  if (name->type != SERD_LITERAL || uri->type != SERD_URI) {
    return SERD_ERR_BAD_ARG;
  }

  if (!serd_env_set_prefix(
        writer->env, serd_node_string_view(name), serd_node_string_view(uri))) {
    if (writer->syntax == SERD_TURTLE || writer->syntax == SERD_TRIG) {
      if (ctx(writer, FIELD_GRAPH) || ctx(writer, FIELD_SUBJECT)) {
        sink(" .\n\n", 4, writer);
        reset_context(writer, true);
      }
      sink("@prefix ", 8, writer);
      sink(serd_node_string(name), name->n_bytes, writer);
      sink(": <", 3, writer);
      write_uri_from_node(writer, uri);
      sink("> .\n", 4, writer);
    }
    writer->indent = 0;
    return reset_context(writer, true);
  }
  return SERD_ERR_UNKNOWN;
}

void
serd_writer_free(SerdWriter* writer)
{
  if (!writer) {
    return;
  }

  serd_writer_finish(writer);
  serd_stack_free(&writer->anon_stack);
  free(writer->bprefix);
  serd_byte_sink_free(&writer->byte_sink);
  serd_node_free(writer->root_node);
  free(writer);
}

const SerdSink*
serd_writer_sink(SerdWriter* writer)
{
  return &writer->iface;
}

SerdEnv*
serd_writer_env(SerdWriter* writer)
{
  return writer->env;
}

size_t
serd_buffer_sink(const void* buf, size_t size, size_t nmemb, void* stream)
{
  assert(size == 1);
  (void)size;

  SerdBuffer* buffer = (SerdBuffer*)stream;
  buffer->buf        = (char*)realloc(buffer->buf, buffer->len + nmemb);
  memcpy((uint8_t*)buffer->buf + buffer->len, buf, nmemb);
  buffer->len += nmemb;
  return nmemb;
}

char*
serd_buffer_sink_finish(SerdBuffer* stream)
{
  serd_buffer_sink("", 1, 1, stream);
  return (char*)stream->buf;
}