1. module jsonstream
   1. function jsonstream.parse (path, map)
   2. function jsonstream.stringify (op, sep, cl, indent)
   3. function jsonstream.stringifyObject (op, sep, cl, indent)

module jsonstream

function jsonstream.parse (path, map)

• description and source-code

  parse = function (path, map) {
  
    var parser = new Parser()
    var stream = through(function (chunk) {
      if('string' === typeof chunk)
        chunk = new Buffer(chunk)
      parser.write(chunk)
    },
    function (data) {
      if(data)
        stream.write(data)
      stream.queue(null)
    })
  
    if('string' === typeof path)
      path = path.split('.').map(function (e) {
        if (e === '*')
          return true
        else if (e === '') // '..'.split('.') returns an empty string
          return {recurse: true}
        else
          return e
      })
  
  
    var count = 0, _key
    if(!path || !path.length)
      path = null
  
    parser.onValue = function (value) {
      if (!this.root)
        stream.root = value
  
      if(! path) return
  
      var i = 0 // iterates on path
      var j  = 0 // iterates on stack
      while (i < path.length) {
        var key = path[i]
        var c
        j++
  
        if (key && !key.recurse) {
          c = (j === this.stack.length) ? this : this.stack[j]
          if (!c) return
          if (! check(key, c.key)) return
          i++
        } else {
          i++
          var nextKey = path[i]
          if (! nextKey) return
          while (true) {
            c = (j === this.stack.length) ? this : this.stack[j]
            if (!c) return
            if (check(nextKey, c.key)) {
              i++;
              this.stack[j].value = null
              break
            }
            j++
          }
        }
  
      }
      if (j !== this.stack.length) return
  
      count ++
      var actualPath = this.stack.slice(1).map(function(element) { return element.key }).concat([this.key])
      var data = this.value[this.key]
      if(null != data)
        if(null != (data = map ? map(data, actualPath) : data))
          stream.queue(data)
      delete this.value[this.key]
      for(var k in this.stack)
        this.stack[k].value = null
    }
    parser._onToken = parser.onToken;
  
    parser.onToken = function (token, value) {
      parser._onToken(token, value);
      if (this.stack.length === 0) {
        if (stream.root) {
          if(!path)
            stream.queue(stream.root)
          count = 0;
          stream.root = null;
        }
      }
    }
  
    parser.onError = function (err) {
      if(err.message.indexOf("at position") > -1)
        err.message = "Invalid JSON (" + err.message + ")";
      stream.emit('error', err)
    }
  
  
    return stream
  }

• example usage

  ...
    })
  
    return stream
  }
  
  if(!module.parent && process.title !== 'browser') {
    process.stdin
      .pipe(exports.parse(process.argv[2]))
      .pipe(exports.stringify('[', ',\n', ']\n', 2))
      .pipe(process.stdout)
  }
  ...

function jsonstream.stringify (op, sep, cl, indent)

• description and source-code

  stringify = function (op, sep, cl, indent) {
    indent = indent || 0
    if (op === false){
      op = ''
      sep = '\n'
      cl = ''
    } else if (op == null) {
  
      op = '[\n'
      sep = '\n,\n'
      cl = '\n]\n'
  
    }
  
    //else, what ever you like
  
    var stream
      , first = true
      , anyData = false
    stream = through(function (data) {
      anyData = true
      var json = JSON.stringify(data, null, indent)
      if(first) { first = false ; stream.queue(op + json)}
      else stream.queue(sep + json)
    },
    function (data) {
      if(!anyData)
        stream.queue(op)
      stream.queue(cl)
      stream.queue(null)
    })
  
    return stream
  }

• example usage

  ...
  //else, what ever you like
  
  var stream
    , first = true
    , anyData = false
  stream = through(function (data) {
    anyData = true
    var json = JSON.stringify(data, null, indent)
    if(first) { first = false ; stream.queue(op + json)}
    else stream.queue(sep + json)
  },
  function (data) {
    if(!anyData)
      stream.queue(op)
    stream.queue(cl)
  ...

function jsonstream.stringifyObject (op, sep, cl, indent)

• description and source-code

  stringifyObject = function (op, sep, cl, indent) {
    indent = indent || 0
    if (op === false){
      op = ''
      sep = '\n'
      cl = ''
    } else if (op == null) {
  
      op = '{\n'
      sep = '\n,\n'
      cl = '\n}\n'
  
    }
  
    //else, what ever you like
  
    var first = true
      , anyData = false
    stream = through(function (data) {
      anyData = true
      var json = JSON.stringify(data[0]) + ':' + JSON.stringify(data[1], null, indent)
      if(first) { first = false ; this.queue(op + json)}
      else this.queue(sep + json)
    },
    function (data) {
      if(!anyData) this.queue(op)
      this.queue(cl)
  
      this.queue(null)
    })
  
    return stream
  }

• example usage

  ...
  the elements will only be seperated by a newline.
  
  If you only write one item this will be valid JSON.
  
  If you write many items,
  you can use a `RegExp` to split it into valid chunks.
  
  ## JSONStream.stringifyObject(open, sep, close)
  
  Very much like `JSONStream.stringify`,
  but creates a writable stream for objects instead of arrays.
  
  Accordingly, `open='{\n', sep='\n,\n', close='\n}\n'`.
  
  When you `.write()` to the stream you must supply an array with `[ key, data ]`
  ...