const statement = require("./statement.js"); const event = require("./event.js"); const fs = require("fs"); const FileHandler = require("./fileHandler.js"); class Queue { constructor(name, location, config) { if (typeof name != "string") throw new Error(`Expected string, got ${typeof name} for name`); if (typeof location != "string") throw new Error(`Expected string, got ${typeof location} for location`); this.name = name; this.timestamp = new Date(); this.location = location; this.filename = this.location + "/" + this.timestamp.toISOString().replace(/\:/g, "-").replace(/\./g, "-") + ".log"; this.queue = []; this.compact = false; this.fileStarted = false; if (config) { if (config.compact) { if (typeof config.compact != "boolean") throw new Error(`Expected boolean, got ${typeof config.compact} for config.compact`); this.compact = config.compact; } } let configFile = this.location + "/metadata.json"; FileHandler.AppendFile(this.filename, ""); // touch the file FileHandler.AppendFile(configFile, ""); let configContent = fs.readFileSync(configFile).toString(); let queueConfig = []; if (configContent != "") queueConfig = JSON.parse(configContent); queueConfig.push( { "time": this.timestamp, "log": this.filename } ); fs.writeFileSync(configFile, JSON.stringify(queueConfig)); return this; } push() { if (arguments.length >= 3) this.queue.push(new statement(arguments[0], arguments[1], arguments[2])); else if (arguments.length > 0) { if (arguments[0] instanceof event) this.queue.push(arguments[0].statements); // object is an Event else if (arguments[0] instanceof statement) this.queue.push(arguments[0]); // object is a Statement else throw new TypeError("Expected an Event or Statement"); } else throw new Error("Expected at least one argument"); return this; } write() { let recursiveCompactFunction; if (this.compact) { recursiveCompactFunction = function(object) { if (Array.isArray(object)) { for (let i = 0; i < object.length; i++) { object[i] = recursiveCompactFunction(object[i]); } return object; } else { let fixed = {}; fixed.tt = object.timestamp; fixed.v = object.verbosity; fixed.t = object.tag; fixed.m = object.message; return fixed; } } } if (arguments.length > 0) { let toWrite; if (arguments.length >= 3) toWrite = new statement(arguments[0], arguments[1], arguments[2]); else { if (arguments[0] instanceof event) toWrite = arguments[0].statements; // object is an Event else if (arguments[0] instanceof statement) toWrite = arguments[0]; // object is a Statement else throw new TypeError("Expected an Event or Statement"); } if (this.compact) { toWrite = recursiveCompactFunction(toWrite); } let appendString = ""; if (this.fileStarted) appendString += "\n"; appendString += JSON.stringify(toWrite); if (!this.fileStarted) this.fileStarted = true; FileHandler.AppendFile(this.filename, appendString); } else { let queueLength = this.queue.length; if (queueLength > 0) { let appendString = ""; let queue = this; let toWrite = this.queue; if (this.compact) { toWrite = recursiveCompactFunction(toWrite); } toWrite.forEach(function (item) { if (queue.fileStarted) appendString += "\n"; appendString += JSON.stringify(item); if (!queue.fileStarted) queue.fileStarted = true; }); this.queue = this.queue.slice(queueLength); FileHandler.AppendFile(this.filename, appendString); } } return this; } } module.exports = Queue;