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

[esplora] print log when retrying unix socket - don't fallback to tcp socket on ETIMEDOUT

Browse Source
This commit is contained in:
nymkappa 2023-04-05 17:00:41 +09:00
parent 66109afb0d
commit db27e5a92c
No known key found for this signature in database
GPG Key ID: E155910B16E8BD04
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
backend/src/api/bitcoin/esplora-api.ts
View File

@ -29,9 +29,10 @@ class ElectrsApi implements AbstractBitcoinApi {
fallbackToTcpSocket() { fallbackToTcpSocket() {
if (!this.unixSocketRetryTimeout) { if (!this.unixSocketRetryTimeout) {
logger.err(`Unable to connect to esplora unix socket. Falling back to tcp socket. Retrying unix socket in ${config.ESPLORA.RETRY_UNIX_SOCKET_AFTER} seconds`); logger.err(`Unable to connect to esplora unix socket. Falling back to tcp socket. Retrying unix socket in ${config.ESPLORA.RETRY_UNIX_SOCKET_AFTER / 1000} seconds`);
// Retry the unix socket after a few seconds // Retry the unix socket after a few seconds
this.unixSocketRetryTimeout = setTimeout(() => { this.unixSocketRetryTimeout = setTimeout(() => {
logger.info(`Retrying to use unix socket for esplora now (applied for the next query)`);
this.activeAxiosConfig = this.axiosConfigWithUnixSocket; this.activeAxiosConfig = this.axiosConfigWithUnixSocket;
}, config.ESPLORA.RETRY_UNIX_SOCKET_AFTER); }, config.ESPLORA.RETRY_UNIX_SOCKET_AFTER);
} }
@ -44,7 +45,7 @@ class ElectrsApi implements AbstractBitcoinApi {
return axiosConnection.get<T>(url, { ...this.activeAxiosConfig, responseType: responseType }) return axiosConnection.get<T>(url, { ...this.activeAxiosConfig, responseType: responseType })
.then((response) => response.data) .then((response) => response.data)
.catch((e) => { .catch((e) => {
if (e?.code === 'ECONNREFUSED' || e?.code === 'ETIMEDOUT') { if (e?.code === 'ECONNREFUSED') {
this.fallbackToTcpSocket(); this.fallbackToTcpSocket();
// Retry immediately // Retry immediately
return axiosConnection.get<T>(url, this.activeAxiosConfig) return axiosConnection.get<T>(url, this.activeAxiosConfig)