From a65c80fc96cf8af8728e180aa5490f9a20666b91 Mon Sep 17 00:00:00 2001
From: Peter Kieltyka <peter.kieltyka@gmail.com>
Date: Mon, 18 Mar 2024 12:44:33 -0400
Subject: [PATCH] ethrpc: client expects ws:// and wss:// for streaming urls

---
 ethrpc/option.go | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/ethrpc/option.go b/ethrpc/option.go
index cac0546..844be12 100644
--- 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
 	}
 }