index.js

/**
* The main module
* @module H5Recorder
*/

const { exec } = require('child_process');
const express = require('express');
const http = require('http')
const path = require('path');
const fs = require('fs');
const Ajv = require('ajv');
const schema = require('./schema.json')
const {
		Recorder,
 		OverlayHandler,
  	MergeHandler,
		AMergeHandler,
	 	LocalPageServer } = require('./Handlers')
const {
	isServerNeeded,
	getAdjustedModelURL } = LocalPageServer

var app = express();



let data = []
let ajv = new Ajv()
let jsonSchemaValidator = ajv.compile(schema)
let port = process.env ? (process.env.PORT||0) : 0;
// If port is omitted or is 0, the operating system will assign an arbitrary unused port, which can be retrieved by using server.address().port after the 'listening' event has been emitted.
// see https://nodejs.org/api/net.html#net_server_listen_port_host_backlog_callback

// https://github.com/wekan/wekan/wiki/REST-API-Swimlanes

/**
 * Executes the process: data ->(Recorder-> OverlayHandler-> MergeHandler-> MergeHandler)-> callback
 * @param {Object} data - data
 * @param {boolean} runInCmd - runInCmd
 * @param {boolean} callback - callback
 // * @exports process -
 */
function process(data, runInCmd, callback) {
	let outputs = []
	let toClean = {}

	function errorCallback(err) {
		Object.keys(toClean).forEach(fs.unlinkSync)
		console.log(err)
		callback(err)
	}

	Recorder(data, runInCmd).then((screenRecords) => {
		// console.log('recorder/screenRecords', screenRecords)
		OverlayHandler(data, screenRecords).then((overlayOutputs) => {
			console.log('OverlayHandler Outputs:', overlayOutputs)

			screenRecords.forEach((v) => { toClean[v] = true;})

			AMergeHandler(data, overlayOutputs).then((aMergeOutputs) => {
				console.log('AMergeHandler Outputs:', aMergeOutputs)

				overlayOutputs.forEach((v) => { toClean[v] = true;})


				MergeHandler(aMergeOutputs).then((overlayMergeOutput) => {
					console.log('MergeHandler Outputs:', overlayMergeOutput)

					if (aMergeOutputs && aMergeOutputs.length > 0) {
						aMergeOutputs.forEach((v) => { toClean[v] = true;})
					}
					Object.keys(toClean).forEach(fs.unlinkSync)

					console.log('final output', overlayMergeOutput)
					callback(null, overlayMergeOutput)

				}, (err)=> {
					fs.unlinkSync(overlayMergeOutput)
					errorCallback(err)
				})
			}, errorCallback)
		}, errorCallback)
	}, errorCallback)
}

/**
 * Loop over data entries, starts local server if needed then trigger the process function
 * @param {Object} data - data
 * @param {boolean} runInCmd - runInCmd
 * @param {boolean} callback - callback
 // * @exports process -
 */
function main(data, runInCmd = false, callback) {

			var valid = jsonSchemaValidator(data);
			if (!valid) {
				jsonSchemaValidator.errors.push(data)
				return callback(jsonSchemaValidator.errors, null)
			}

			if (isServerNeeded) {
				// http://expressjs.com/en/4x/api.html#app.listen
				let server = http.createServer(app)
				server.listen(port, () => {
					let serverPort = server.address().port
					data = getAdjustedModelURL(data, app, serverPort)
					// server.close()
					console.log('LocalPageServer: ', server.address().port) //process.argv[2]
					process(data, runInCmd, (err, result) => {
						server.close();
						callback(err, result);
					});
				})
			} else {
				process(data, runInCmd, callback);
			}

}

module.exports = function (infile, runInCmd = false, cb) {
  if (cb) return main(infile, runInCmd, cb)

  return new Promise(function (resolve, reject) {
    main(infile, runInCmd, function (err, data) {
      if (err) return reject(err)
      resolve(data)
    })
  })
}