You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
89 lines
2.4 KiB
TypeScript
89 lines
2.4 KiB
TypeScript
/* eslint-disable import/no-duplicates */
|
|
/* eslint-disable no-constant-condition */
|
|
/* eslint-disable no-await-in-loop */
|
|
/* ..
|
|
.' @`._
|
|
~ ...._.' ,__.-;
|
|
_..- - - /` .-' ~
|
|
: __./' , .'-'- .._
|
|
~ `- -(.-'''- -. \`._ `. ~
|
|
_.- '( .______.'.-' `-.` `.
|
|
: `-..____`-. ;
|
|
`. ```` 稻花香里说丰年， ; ~
|
|
`-.__ 听取人生经验。 __.-'
|
|
````- - -.......- - -''' ~
|
|
~ */
|
|
import './utils';
|
|
|
|
import { getConfig } from './config';
|
|
import * as Session from './hosts/index';
|
|
import log from './log';
|
|
import { Queue, sleep } from './utils';
|
|
|
|
declare global {
|
|
namespace NodeJS {
|
|
interface Global {
|
|
onDestroy: Function[]
|
|
hosts: any
|
|
}
|
|
}
|
|
}
|
|
if (!global.onDestroy) global.onDestroy = [];
|
|
if (!global.hosts) global.hosts = [];
|
|
let exit = false;
|
|
|
|
const terminate = async () => {
|
|
log.info('正在保存数据');
|
|
try {
|
|
await Promise.all(global.onDestroy.map((f: Function) => f()));
|
|
process.exit(1);
|
|
} catch (e) {
|
|
if (exit) process.exit(1);
|
|
log.error(e.stack);
|
|
log.error('发生了错误。');
|
|
log.error('再次按下 Ctrl-C 可强制退出。');
|
|
exit = true;
|
|
}
|
|
};
|
|
process.on('SIGINT', terminate);
|
|
process.on('SIGTERM', terminate);
|
|
process.on('unhandledRejection', (reason, p) => {
|
|
console.log('Unhandled Rejection at: Promise ', p);
|
|
});
|
|
|
|
async function worker(queue: Queue<any>) {
|
|
while ('Orz Soha') {
|
|
const [task] = await queue.get();
|
|
task.handle();
|
|
}
|
|
}
|
|
|
|
async function daemon() {
|
|
const _hosts = getConfig('hosts');
|
|
const delay = getConfig('retry_delay_sec');
|
|
const hosts = {};
|
|
const queue = new Queue<any>();
|
|
for (const i in _hosts) {
|
|
_hosts[i].host = _hosts[i].host || i;
|
|
hosts[i] = new Session[_hosts[i].type || 'vj4'](_hosts[i]);
|
|
await hosts[i].init();
|
|
}
|
|
global.hosts = hosts;
|
|
worker(queue);
|
|
for (const i in hosts) {
|
|
while ('Orz twd2') {
|
|
try {
|
|
await hosts[i].consume(queue);
|
|
break;
|
|
} catch (e) {
|
|
log.error(e, e.stack);
|
|
log.info(`在 ${delay} 秒后重试`);
|
|
await sleep(delay * 1000);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
if (require.main === module) daemon();
|
|
export = daemon;
|