node

const { rejects } = require('assert');
const fs = require('fs');
const { resolve } = require('path');
const readline = require('readline');
const common = require('../common/common');

exports.jobMain = async function () {
console.log("jobMain start");
/*
var streem = fs.createReadStream('./joblist.txt', 'utf-8');
var rl = readline.createInterface({ input: streem });
for await(const line of rl) {
await common.sleep(500);
console.log('const_' + line);
};
*/

/**
var index = 1;
rl.on('line', (data) => {
console.log('on_' + data);
common.sleep(1000, index);
++index;
});
*/

const jobFile = await readFiles();

for (var line of jobFile) {
//console.log("key=" + line['key']);
console.log(line);
console.log(line['key']);
//JSON.parse(line);
//console.log("key=" + line['key']);
}

console.log("jobMain end");
}

async function readFiles() {
var streem = fs.createReadStream('./joblist.txt', 'utf-8');
var rl = readline.createInterface({ input: streem });

return new Promise((resolve, rejects) => {
const lineList = [];
try {
rl.on('line', (line) => {

console.log(line);
// 末尾のカンマがあったら削除
line = line.replace(/,\s*$/, "");
console.log(line);

lineList.push(JSON.parse(line));
}).on('close', () => {
console.log('close()');
resolve(lineList);
})
} catch (err) {
rejects(err);
}
});
}