File Manager

Current Path: Root / node_modules/ bfj/ src

Parent Directory

Name	Size	Last Modified
[F]datastream.js Edit	394 bytes	2022-10-08 17:28:24
[F]error.js Edit	479 bytes	2022-10-08 17:28:24
[F]eventify.js Edit	7.00 KB	2022-10-08 17:28:24
[F]events.js Edit	457 bytes	2022-10-08 17:28:25
[F]index.js Edit	346 bytes	2022-10-08 17:28:25
[F]jsonstream.js Edit	394 bytes	2022-10-08 17:28:25
[F]match.js Edit	5.44 KB	2022-10-08 17:28:25
[F]memory.js Edit	856 bytes	2022-10-08 17:28:26
[F]parse.js Edit	3.81 KB	2022-10-08 17:28:26
[F]promise.js Edit	88 bytes	2022-10-08 17:28:26
[F]read.js Edit	779 bytes	2022-10-08 17:28:26
[F]stream.js Edit	504 bytes	2022-10-08 17:28:26
[F]streamify.js Edit	5.91 KB	2022-10-08 17:28:26
[F]stringify.js Edit	1.74 KB	2022-10-08 17:28:26
[F]unpipe.js Edit	1.17 KB	2022-10-08 17:28:26
[F]walk.js Edit	14.15 KB	2022-10-08 17:28:26
[F]write.js Edit	1.65 KB	2022-10-08 17:28:27

Editing: parse.js

'use strict'

const check = require('check-types')
const events = require('./events')
const promise = require('./promise')
const walk = require('./walk')

module.exports = parse

const NDJSON_STATE = new Map()

/**
 * Public function `parse`.
 *
 * Returns a promise and asynchronously parses a stream of JSON data. If
 * there are no errors, the promise is resolved with the parsed data. If
 * errors occur, the promise is rejected with the first error.
 *
 * @param stream:     Readable instance representing the incoming JSON.
 *
 * @option reviver:   Transformation function, invoked depth-first.
 *
 * @option yieldRate: The number of data items to process per timeslice,
 *                    default is 16384.
 *
 * @option Promise:   The promise constructor to use, defaults to bluebird.
 *
 * @option ndjson:    Set this to true to parse newline-delimited JSON. In
 *                    this case, each call will be resolved with one value
 *                    from the stream. To parse the entire stream, calls
 *                    should be made sequentially one-at-a-time until the
 *                    returned promise resolves to `undefined`.
 **/
function parse (stream, options = {}) {
  const Promise = promise(options)

try {
    check.assert.maybe.function(options.reviver, 'Invalid reviver option')
  } catch (err) {
    return Promise.reject(err)
  }

const errors = []
  const scopes = []
  const reviver = options.reviver
  const shouldHandleNdjson = !! options.ndjson

let emitter, resolve, reject, scopeKey
  if (shouldHandleNdjson && NDJSON_STATE.has(stream)) {
    const state = NDJSON_STATE.get(stream)
    NDJSON_STATE.delete(stream)
    emitter = state.emitter
    setImmediate(state.resume)
  } else {
    emitter = walk(stream, options)
  }

emitter.on(events.array, array)
  emitter.on(events.object, object)
  emitter.on(events.property, property)
  emitter.on(events.string, value)
  emitter.on(events.number, value)
  emitter.on(events.literal, value)
  emitter.on(events.endArray, endScope)
  emitter.on(events.endObject, endScope)
  emitter.on(events.end, end)
  emitter.on(events.error, error)
  emitter.on(events.dataError, error)

if (shouldHandleNdjson) {
    emitter.on(events.endLine, endLine)
  }

return new Promise((res, rej) => {
    resolve = res
    reject = rej
  })

function array () {
    if (errors.length > 0) {
      return
    }

beginScope([])
  }

function beginScope (parsed) {
    if (errors.length > 0) {
      return
    }

if (scopes.length > 0) {
      value(parsed)
    }

scopes.push(parsed)
  }

function value (v) {
    if (errors.length > 0) {
      return
    }

if (scopes.length === 0) {
      return scopes.push(v)
    }

const scope = scopes[scopes.length - 1]

if (scopeKey) {
      scope[scopeKey] = v
      scopeKey = null
    } else {
      scope.push(v)
    }
  }

function object () {
    if (errors.length > 0) {
      return
    }

beginScope({})
  }

function property (name) {
    if (errors.length > 0) {
      return
    }

scopeKey = name
  }

function endScope () {
    if (errors.length > 0) {
      return
    }

if (scopes.length > 1) {
      scopes.pop()
    }
  }

function end () {
    if (shouldHandleNdjson) {
      const resume = emitter.pause()
      emitter.removeAllListeners()
      NDJSON_STATE.set(stream, { emitter, resume })
    }

if (errors.length > 0) {
      return reject(errors[0])
    }

if (reviver) {
      scopes[0] = transform(scopes[0], '')
    }

resolve(scopes[0])
  }

function transform (obj, key) {
    if (obj && typeof obj === 'object') {
      Object.entries(obj).forEach(([ k, v ]) => {
        obj[k] = transform(v, k)
      })
    }

return reviver(key, obj)
  }

function error (e) {
    errors.push(e)
  }

function endLine () {
    if (scopes.length > 0) {
      end()
    }
  }
}

Cancel

File Explorer

Navigation

File Manager

Editing: parse.js

File Explorer

Navigation

File Manager

Editing: parse.js

Confirm Deletion

Rename Item

Change Permissions (Chmod)