Spaces:
Sleeping
Sleeping
File size: 1,620 Bytes
a8d6602 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 |
const moment = require("moment-timezone")
let cluster = require('cluster')
let path = require('path')
let fs = require('fs')
const {
createServer
} = require("http");
const {
Server
} = require("socket.io");
const Readline = require('readline')
const yargs = require('yargs/yargs')
const rl = Readline.createInterface(process.stdin, process.stdout)
var isRunning = false
function start(file) {
if (isRunning) return
isRunning = true
let args = [path.join(__dirname, file), ...process.argv.slice(2)]
cluster.setupMaster({
exec: path.join(__dirname, file),
args: args.slice(1),
})
let p = cluster.fork()
p.on('message', data => {
console.log('[RECEIVED]', data)
switch (data) {
case 'reset':
p.process.kill()
isRunning = false
start.apply(this, arguments)
break
case 'null':
p.process.kill()
isRunning = false
start.apply(this, arguments)
break
}
})
p.on('exit', (_, code) => {
if (code == null) process.exit()
isRunning = false
console.error('Exited with code:', code)
if (code === 0) return
fs.watchFile(args[0], () => {
fs.unwatchFile(args[0])
start(file)
})
})
let opts = new Object(yargs(process.argv.slice(2)).exitProcess(false).parse())
if (!opts['test'])
if (!rl.listenerCount()) rl.on('line', line => {
p.emit('message', line.trim())
})
}
start('main.js') |