Fix Idle Stream Issue (#952)

livepeer · Nov 7, 2023 · 871a83c · 871a83c
1 parent 39daca5
commit 871a83c
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 2 deletions.
diff --git a/go.mod b/go.mod
@@ -17,7 +17,7 @@ require (
 	github.com/hashicorp/serf v0.10.1
 	github.com/julienschmidt/httprouter v1.3.0
 	github.com/lib/pq v1.10.9
-	github.com/livepeer/go-api-client v0.4.10
+	github.com/livepeer/go-api-client v0.4.12
 	github.com/livepeer/go-tools v0.3.3
 	github.com/livepeer/joy4 v0.1.1
 	github.com/livepeer/livepeer-data v0.7.4

diff --git a/go.sum b/go.sum
@@ -417,6 +417,10 @@ github.com/libp2p/go-netroute v0.2.0 h1:0FpsbsvuSnAhXFnCY0VLFbJOzaK0VnP0r1QT/o4n
 github.com/libp2p/go-openssl v0.1.0 h1:LBkKEcUv6vtZIQLVTegAil8jbNpJErQ9AnT+bWV+Ooo=
 github.com/livepeer/go-api-client v0.4.10 h1:WMWJ2guElf000TBcqQpbrC2zGGRlVlin/7w6lMvSGkY=
 github.com/livepeer/go-api-client v0.4.10/go.mod h1:Jdb+RI7JyzEZOHd1GUuKofwFDKMO/btTa80SdpUpYQw=
+github.com/livepeer/go-api-client v0.4.12-0.20231106122927-b996b8714ada h1:TN0jwa8hA/xBseYHj1nyRM/ZOm4ajdYc1xkbPOZwyAc=
+github.com/livepeer/go-api-client v0.4.12-0.20231106122927-b996b8714ada/go.mod h1:Jdb+RI7JyzEZOHd1GUuKofwFDKMO/btTa80SdpUpYQw=
+github.com/livepeer/go-api-client v0.4.12 h1:wxGBJKgvJ9vWuuwjI2RVGWUeKbBcJv8ihNQtwjdH4t4=
+github.com/livepeer/go-api-client v0.4.12/go.mod h1:Jdb+RI7JyzEZOHd1GUuKofwFDKMO/btTa80SdpUpYQw=
 github.com/livepeer/go-tools v0.3.3 h1:Je2P+ovDIIlFWtlns5v+MmHtdIytsAJS6+XyeZ8sFJI=
 github.com/livepeer/go-tools v0.3.3/go.mod h1:qs31y68b3PQPmSr8nR8l5WQiIWI623z6pqOccqebjos=
 github.com/livepeer/joy4 v0.1.1 h1:Tz7gVcmvpG/nfUKHU+XJn6Qke/k32mTWMiH9qB0bhnM=

diff --git a/mapic/stats_collector.go b/mapic/stats_collector.go
@@ -87,7 +87,7 @@ func (c *metricsCollector) collectMetrics(ctx context.Context, mistState clients
 				return
 			}
 
-			if _, err := c.lapi.SetActive(info.stream.ID, true, info.startedAt); err != nil {
+			if err := c.lapi.Heartbeat(info.stream.ID); err != nil {
 				glog.Errorf("Error updating stream last seen. err=%q streamId=%q", err, info.stream.ID)
 				return
 			}
-Original file line number
+Diff line change
@@ Expand Up @@
     				return
     			}
-    			if _, err := c.lapi.SetActive(info.stream.ID, true, info.startedAt); err != nil {
+    			if err := c.lapi.Heartbeat(info.stream.ID); err != nil {
     				glog.Errorf("Error updating stream last seen. err=%q streamId=%q", err, info.stream.ID)
     				return
     			}
@@ Expand Down @@