From d14166efacf5f36d8436c2c5369c313d3d369078 Mon Sep 17 00:00:00 2001
From: Peter Kieltyka <peter.kieltyka@gmail.com>
Date: Fri, 29 Mar 2024 20:25:38 -0400
Subject: [PATCH] upgrade goware/channel dep which adds Label option

---
 ethmonitor/ethmonitor.go      | 8 +++++++-
 ethmonitor/ethmonitor_test.go | 6 +++---
 go.mod                        | 2 +-
 go.sum                        | 4 ++--
 4 files changed, 13 insertions(+), 7 deletions(-)

diff --git a/ethmonitor/ethmonitor.go b/ethmonitor/ethmonitor.go
index 49ec00df..c3f78867 100644
--- a/ethmonitor/ethmonitor.go
+++ b/ethmonitor/ethmonitor.go
@@ -863,14 +863,20 @@ func (m *Monitor) broadcast(events Blocks) {
 	}
 }
 
-func (m *Monitor) Subscribe() Subscription {
+func (m *Monitor) Subscribe(optLabel ...string) Subscription {
 	m.mu.Lock()
 	defer m.mu.Unlock()
 
+	var label string
+	if len(optLabel) > 0 {
+		label = optLabel[0]
+	}
+
 	subscriber := &subscriber{
 		ch: channel.NewUnboundedChan[Blocks](10, 5000, channel.Options{
 			Logger:  m.log,
 			Alerter: m.alert,
+			Label:   label,
 		}),
 		done: make(chan struct{}),
 	}
diff --git a/ethmonitor/ethmonitor_test.go b/ethmonitor/ethmonitor_test.go
index 550f9e21..3d6f8529 100644
--- a/ethmonitor/ethmonitor_test.go
+++ b/ethmonitor/ethmonitor_test.go
@@ -59,13 +59,13 @@ func TestMonitorBasic(t *testing.T) {
 	}(t)
 	defer monitor.Stop()
 
-	sub := monitor.Subscribe()
+	sub := monitor.Subscribe("TestMonitorBasic")
 	defer sub.Unsubscribe()
 
 	subs := []ethmonitor.Subscription{}
 	go func() {
 		for i := 0; i < 10; i++ {
-			s := monitor.Subscribe()
+			s := monitor.Subscribe(fmt.Sprintf("TestMonitorBasic/sub/%d", i))
 			subs = append(subs, s)
 		}
 
@@ -231,7 +231,7 @@ func TestMonitorWithReorgme(t *testing.T) {
 	}(t)
 	defer monitor.Stop()
 
-	sub := monitor.Subscribe()
+	sub := monitor.Subscribe("TestMonitorWithReorgme")
 	defer sub.Unsubscribe()
 
 	events := make([]*ethmonitor.Block, 0)
diff --git a/go.mod b/go.mod
index 303f9a3c..c8ed2de8 100644
--- a/go.mod
+++ b/go.mod
@@ -19,7 +19,7 @@ require (
 	github.com/goware/breaker v0.1.2
 	github.com/goware/cachestore v0.8.0
 	github.com/goware/calc v0.2.0
-	github.com/goware/channel v0.4.0
+	github.com/goware/channel v0.4.1
 	github.com/goware/logger v0.3.0
 	github.com/goware/pp v0.0.3
 	github.com/goware/superr v0.0.2
diff --git a/go.sum b/go.sum
index f322bbc4..eacf7dd2 100644
--- a/go.sum
+++ b/go.sum
@@ -75,8 +75,8 @@ github.com/goware/cachestore v0.8.0 h1:NWW9nh7eXgDQfaxdhWOdopKRDc6bWH8qm5kv2w6LS
 github.com/goware/cachestore v0.8.0/go.mod h1:ikiO2RmxIt4cVqEBII6yR+V4Z7pH+y8bMQHpd1MvG1Y=
 github.com/goware/calc v0.2.0 h1:3B9qjXYpE0kgS4LhyklbM6X/0cOvZLdUZG7sdAuVCb4=
 github.com/goware/calc v0.2.0/go.mod h1:BSQUbfS6ICW9RvSV9SikDY+t6/HQKI+CUxIpjE3VD28=
-github.com/goware/channel v0.4.0 h1:MfJPLJKhZi2D+seuM2MTKQxOzzjP/zIE7yAn8y47UbA=
-github.com/goware/channel v0.4.0/go.mod h1:m3JBDrah57BipyVWu8R1eBanf1YacnZRluIVSv0jF/U=
+github.com/goware/channel v0.4.1 h1:N6AqSuB6ZMOrfezhpQJ2xo5Y6jlJES+m+P+JyyX9XIo=
+github.com/goware/channel v0.4.1/go.mod h1:m3JBDrah57BipyVWu8R1eBanf1YacnZRluIVSv0jF/U=
 github.com/goware/logger v0.3.0 h1:pdgnsqj2rSDXtfdu+UuAFuBuOapxeDYNETY39227LMM=
 github.com/goware/logger v0.3.0/go.mod h1:IC34c5H56R1I4/R/d51aQhzHsjSJqkQyIHyuJxOiu0w=
 github.com/goware/pp v0.0.3 h1:2Yv0IFGOpVjCDayPYzrqskCe9qmGoKBIyu6Uy//LVUU=