file-obj-queue

Queue javascript objects dynamically then process the queue according to the appender. All appenders are handled synchronously.

Included tag appenders:

• files - See if inputed files exists.

• all - process all added objects.

• top_one - process only the object in the 0(zero) position of the process array.

• bottom_one - process only the object in the last position of the process array.

• func_all - process custom function names in created objects. Custom processing names can be used in any appender, this is just one example.

• status - queue and process all objects by status.

• name - queue and process all objects by name.

• version - queue and process all objects by version.

• json_all - process a class object per json input array variables.

• json_top_one - process a class object per the first json input array variable.

• json_bottom_one - process a class object per the last json input array variable.

• json_func_all - process custom function names in created objects. Custom processing names can be used in any json appender, this is just one example.

• json_status - queue and process all objects by status.

• json_name - queue and process all objects by name.

• json_version - queue and process all objects by version.

Mocha Test

npm test

General Setup Test

npm run test_files
npm run test_all
npm run test_top_one
npm run test_bottom_one
npm run test_func_all
npm run test_status_matching
npm run test_status_non_matching
npm run test_name_matching
npm run test_name_non_matching
npm run test_version_matching
npm run test_version_non_matching
npm run test_json_all
npm run test_json_top_one
npm run test_json_bottom_one
npm run test_json_func_all
npm run test_json_status_matching
npm run test_json_status_non_matching
npm run test_json_version_matching
npm run test_json_version_non_matching
npm run test_json_name_matching
npm run test_json_name_non_matching

Usage

var queue = require("queueobj");

var tst1 = class test1 {
  constructor(props) {
    let t = this, fname = "test_all.test1.constructor"
    t.log = props.log
    t.id = props.id
  }

  process(callback) {
    let t = this, fname = "test_all.test1.process"
    t.log({ msg: `This object (${fname}) is id (${t.id}). Do stuff here`.bgBrightGreen, type: "info" })
    callback({ success: { msg: `processing all test1` } })
  }
}

var tst2 = class test2 {
  constructor(props) {
    let t = this, fname = "test_all.test2.constructor"
    t.log = props.log
    t.id = props.id
  }

  process(callback) {
    let t = this, fname = "test_all.test2.process"
    t.log({ msg: `This object (${fname}) is id (${t.id}). Do stuff here`.bgBrightGreen, type: "info" })
    setTimeout(() => {
      callback({ success: { msg: `processing all test2` } })
    }, 4000)
  }
}

var tst3 = class test3 {
  constructor(props) {
    let t = this, fname = "test_all.test3.constructor"
    t.log = props.log
    t.id = props.id
  }

  process(callback) {
    let t = this, fname = "test_all.test3.process"
    t.log({ msg: `This object (${fname}) is id (${t.id}). Do stuff here`.bgBrightGreen, type: "info" })
    // callback({success: { msg: `processing all test3` }})
    callback({ error: { msg: `there is some problem thrown here on test3` } })
  }
}

var tst4 = class test4 {
  constructor(props) {
    let t = this, fname = "test_all.test4.constructor"
    t.log = props.log
    t.id = props.id

  }

  process(callback) {
    let t = this, fname = "test_all.test4.process"
    t.log({ msg: `This object (${fname}) is id (${t.id}). Do stuff here`.bgBrightGreen, type: "info" })
    callback({ success: { msg: `processing all test4` } })
  }
}

var qObj = new queue()

qObj.init().process({
  appender: "all",
  exclude_logMsg: ["debug"],   /* example ["debug", "info"] */
  process_objects: [tst1, tst2, tst3, tst4]
}).then((success) => {
  qObj.logMsg({ msg: `test success: {msg: "all objects processed with no errors"}`.success.italic.bold, type: "success" })
}, (error) => {
  if (typeof error == "string") {
    qObj.logMsg({ msg: `error: ${error}`.error.italic.bold, type: "error" })
  } else {
    let add_s = (error.error_count > 1) ? 's' : ''
    qObj.logMsg({ msg: `${error.error_count} error${add_s} detected`.error.italic.bold, type: "error" })
  }
})