ethrpc: client expects ws:// and wss:// for streaming urls

0xsequence · Mar 18, 2024 · a65c80f · a65c80f
1 parent a06badc
commit a65c80f
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/ethrpc/option.go b/ethrpc/option.go
@@ -2,6 +2,7 @@ package ethrpc
 
 import (
 	"net/http"
+	"strings"
 
 	"github.com/goware/breaker"
 	"github.com/goware/logger"
@@ -15,7 +16,10 @@ type httpClient interface {
 
 func WithStreaming(nodeWebsocketURL string) Option {
 	return func(p *Provider) {
-		p.nodeWSURL = nodeWebsocketURL
+		nodeWSURL := nodeWebsocketURL
+		nodeWSURL = strings.Replace(nodeWSURL, "http://", "ws://", 1)
+		nodeWSURL = strings.Replace(nodeWSURL, "https://", "wss://", 1)
+		p.nodeWSURL = nodeWSURL
 	}
 }