Skip to content

Commit 05e1921

Browse files
committed
feat: add logs on recent data when error occur (#1)
1 parent 190502c commit 05e1921

File tree

2 files changed

+20
-2
lines changed

2 files changed

+20
-2
lines changed

index.js

Lines changed: 19 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,15 +11,33 @@ var DB = process.env.DB || path.join(__dirname, 'db')
1111

1212
var db = DB_CLOSED ? {} : level(DB)
1313

14+
var EXTENDED_LOGS = ['arborist', 'blackbird', 'strategis'].some(p => (process.env.HOSTNAME || '').includes(p) || (process.env.DB_NAME || '').includes(p))
15+
1416
var server = net.createServer(function (sock) {
17+
var dataBuffer = []
18+
var mldbServer = multileveldown.server(db)
19+
20+
sock.on('data', function (data) {
21+
if (EXTENDED_LOGS) dataBuffer.push({ data: data.toString(), ts: new Date().toISOString() })
22+
if (dataBuffer.length > 200) dataBuffer.shift()
23+
})
24+
25+
mldbServer.on('error', function (err) {
26+
if (EXTENDED_LOGS) console.log({ dataBuffer, mldbError: err })
27+
sock.destroy()
28+
if (err) return console.error(err)
29+
process.exit(1)
30+
})
31+
1532
sock.on('error', function (err) {
33+
if (EXTENDED_LOGS) console.log({ dataBuffer, socketError: err })
1634
sock.destroy()
1735
if (err) return console.error(err)
1836
process.exit(1)
1937
})
2038

2139
if (!DB_CLOSED) {
22-
sock.pipe(multileveldown.server(db)).pipe(sock)
40+
sock.pipe(mldbServer).pipe(sock)
2341
}
2442
})
2543

package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "multilevel-db",
3-
"version": "2.2.0",
3+
"version": "2.2.1",
44
"main": "index.js",
55
"scripts": {
66
"start": "node index.js",

0 commit comments

Comments
 (0)