machankura/mempool
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[server] disable unix socket listening by default

Browse Source
This commit is contained in:
nymkappa 2024-04-09 15:11:40 +09:00
parent bed00fbd41
commit 7a098952c8
No known key found for this signature in database
GPG Key ID: 92358FC85D9645DE
3 changed files with 19 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
backend/mempool-config.sample.json
View File

@ -35,7 +35,8 @@
"MAX_PUSH_TX_SIZE_WEIGHT": 4000000, "MAX_PUSH_TX_SIZE_WEIGHT": 4000000,
"ALLOW_UNREACHABLE": true, "ALLOW_UNREACHABLE": true,
"PRICE_UPDATES_PER_HOUR": 1, "PRICE_UPDATES_PER_HOUR": 1,
"MAX_TRACKED_ADDRESSES": 100 "MAX_TRACKED_ADDRESSES": 100,
"UNIX_SOCKET_PATH": ""
}, },
"CORE_RPC": { "CORE_RPC": {
"HOST": "127.0.0.1", "HOST": "127.0.0.1",

2
backend/src/config.ts
View File

@ -165,7 +165,7 @@ const defaults: IConfig = {
'NETWORK': 'mainnet', 'NETWORK': 'mainnet',
'BACKEND': 'none', 'BACKEND': 'none',
'HTTP_PORT': 8999, 'HTTP_PORT': 8999,
'UNIX_SOCKET_PATH': '/mempool/socket/mempool-bitcoin-mainnet', 'UNIX_SOCKET_PATH': '',
'SPAWN_CLUSTER_PROCS': 0, 'SPAWN_CLUSTER_PROCS': 0,
'API_URL_PREFIX': '/api/v1/', 'API_URL_PREFIX': '/api/v1/',
'POLL_RATE_MS': 2000, 'POLL_RATE_MS': 2000,

26
backend/src/index.ts
View File

@ -138,9 +138,11 @@ class Server {
} }
this.server = http.createServer(this.app); this.server = http.createServer(this.app);
this.serverUnixSocket = http.createServer(this.app);
this.wss = new WebSocket.Server({ server: this.server }); this.wss = new WebSocket.Server({ server: this.server });
this.wssUnixSocket = new WebSocket.Server({ server: this.serverUnixSocket }); if (config.MEMPOOL.UNIX_SOCKET_PATH) {
this.serverUnixSocket = http.createServer(this.app);
this.wssUnixSocket = new WebSocket.Server({ server: this.serverUnixSocket });
}
this.setUpWebsocketHandling(); this.setUpWebsocketHandling();
@ -197,13 +199,15 @@ class Server {
} }
}); });
this.serverUnixSocket.listen(config.MEMPOOL.UNIX_SOCKET_PATH, () => { if (this.serverUnixSocket) {
if (worker) { this.serverUnixSocket.listen(config.MEMPOOL.UNIX_SOCKET_PATH, () => {
logger.info(`Mempool Server worker #${process.pid} started`); if (worker) {
} else { logger.info(`Mempool Server worker #${process.pid} started`);
logger.notice(`Mempool Server is listening on ${config.MEMPOOL.UNIX_SOCKET_PATH}`); } else {
} logger.notice(`Mempool Server is listening on ${config.MEMPOOL.UNIX_SOCKET_PATH}`);
}); }
});
}
} }
async runMainUpdateLoop(): Promise<void> { async runMainUpdateLoop(): Promise<void> {
@ -357,7 +361,9 @@ class Server {
this.server?.close(); this.server?.close();
this.serverUnixSocket?.close(); this.serverUnixSocket?.close();
this.wss?.close(); this.wss?.close();
this.wssUnixSocket?.close(); if (this.wssUnixSocket) {
this.wssUnixSocket.close();
}
process.exit(code); process.exit(code);
} }