verdnatura/mylogger
verdnatura
/
mylogger
0
0
Fork 0
Code Issues Pull Requests 3 Packages Projects Releases Wiki Activity

fix: Unhandled connection in closed state
gitea/mylogger/pipeline/head This commit looks good Details

This commit is contained in:
Guillermo Bonet 2024-08-28 10:56:16 +02:00
parent 4e709c2091
commit 5857c2294e
2 changed files with 14 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
mylogger.js
View File

@ -57,12 +57,9 @@ module.exports = class MyLogger {
async init() { async init() {
const {conf} = this; const {conf} = this;
this.debug('MyLogger', 'Initializing.'); this.debug('MyLogger', 'Initializing.');
this.onErrorListener = err => this.onError(err);
// DB connection // DB connection
const db = this.db = await mysql.createConnection(conf.dstDb); const db = this.db = await mysql.createConnection(conf.dstDb);
db.on('error', this.onErrorListener);
await this.modelLoader.loadSchema(); await this.modelLoader.loadSchema();
await this.showDb.loadSchema(); await this.showDb.loadSchema();
@ -134,8 +131,6 @@ module.exports = class MyLogger {
if (!this.running) return; if (!this.running) return;
this.running = false; this.running = false;
this.debug('MyLogger', 'Ending.'); this.debug('MyLogger', 'Ending.');
this.db.off('error', this.onErrorListener);
clearInterval(this.flushInterval); clearInterval(this.flushInterval);
clearInterval(this.pingInterval); clearInterval(this.pingInterval);
@ -206,7 +201,6 @@ module.exports = class MyLogger {
zongji.once('error', onError); zongji.once('error', onError);
zongji.start(zongjiOpts); zongji.start(zongjiOpts);
}); });
zongji.on('error', this.onErrorListener);
this.zongji = zongji; this.zongji = zongji;
this.debug('Zongji', 'Started.'); this.debug('Zongji', 'Started.');
} }
@ -220,7 +214,6 @@ module.exports = class MyLogger {
this.zongji = null; this.zongji = null;
zongji.off('binlog', this.onBinlogListener); zongji.off('binlog', this.onBinlogListener);
zongji.off('error', this.onErrorListener);
// FIXME: Cannot call Zongji.stop(), it doesn't wait to end connection // FIXME: Cannot call Zongji.stop(), it doesn't wait to end connection
zongji.connection.destroy(() => { zongji.connection.destroy(() => {
@ -250,7 +243,7 @@ module.exports = class MyLogger {
} }
} }
async onError(err) { async handleError(err) {
if (!this.isOk) return; if (!this.isOk) return;
this.isOk = false; this.isOk = false;
console.log(`Error: ${err.code}: ${err.message}`); console.log(`Error: ${err.code}: ${err.message}`);
@ -259,19 +252,19 @@ module.exports = class MyLogger {
await this.end(true); await this.end(true);
} catch(e) {} } catch(e) {}
switch (err.code) { // FIXME: Error of mysql2/promise
case 'PROTOCOL_CONNECTION_LOST': if (err.message === `Can't add new command when connection is in closed state`)
case 'ECONNRESET':
console.log('Trying to restart process.');
await this.tryRestart(); await this.tryRestart();
break; else
default: switch (err.code) {
process.exit(); case 'PROTOCOL_CONNECTION_LOST':
} case 'ECONNRESET':
} console.log('Trying to restart process.');
await this.tryRestart();
handleError(err) { break;
console.error(err); default:
process.exit();
}
} }
async onBinlog(evt) { async onBinlog(evt) {

2
package.json
View File

@ -1,6 +1,6 @@
{ {
"name": "mylogger", "name": "mylogger",
"version": "1.1.4", "version": "1.1.5",
"author": "Verdnatura Levante SL", "author": "Verdnatura Levante SL",
"description": "MySQL and MariaDB logger using binary log", "description": "MySQL and MariaDB logger using binary log",
"license": "GPL-3.0", "license": "GPL-3.0",