Add check for 'connection reset by peer' (#51)

vulpemventures · Feb 17, 2023 · 19e7b4b · 19e7b4b
1 parent f7a2bed
commit 19e7b4b
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/internal/infrastructure/blockchain-scanner/electrum/tcp_client.go b/internal/infrastructure/blockchain-scanner/electrum/tcp_client.go
@@ -10,6 +10,7 @@ import (
 	"net"
 	"sync"
 	"sync/atomic"
+	"syscall"
 	"time"
 
 	"github.com/btcsuite/btcd/chaincfg/chainhash"
@@ -78,7 +79,8 @@ func (c *tcpClient) listen() {
 		var resp response
 		bytes, err := conn.ReadBytes(delim)
 		if err != nil {
-			if errors.Is(err, net.ErrClosed) || errors.Is(err, io.EOF) {
+			if errors.Is(err, net.ErrClosed) || errors.Is(err, io.EOF) ||
+				errors.Is(err, syscall.ECONNRESET) {
 				c.log("connection with server dropped, attempting to reconnect...")
 				c.reconnect()
 				return