From a28f99633090ee6634ac23626f8b51cd79cd2cb8 Mon Sep 17 00:00:00 2001
From: Eduardo Silva <eduardosilva@disroot.org>
Date: Tue, 23 Jun 2026 10:23:14 +0100
Subject: [PATCH] start and stop behaviour

---
 providers/beamng/beamng.go            |  1 -
 providers/iracing/iracing.go          |  4 ++++
 telemetry/provider.go                 |  1 +
 tui/internal/controllers/streaming.go | 20 +++++++++++++-------
 tui/internal/services/telemetry.go    | 10 ++++++++--
 5 files changed, 26 insertions(+), 10 deletions(-)

diff --git a/providers/beamng/beamng.go b/providers/beamng/beamng.go
index 372b1f7..a950618 100644
--- a/providers/beamng/beamng.go
+++ b/providers/beamng/beamng.go
@@ -6,7 +6,6 @@ import (
 	bngsdk "github.com/ESilva15/gobngsdk"
 )
 
-// This will implement the GameSink interface from the main package
 type BeamNG struct {
 	SDK *bngsdk.BNGSDK
 }
diff --git a/providers/iracing/iracing.go b/providers/iracing/iracing.go
index fb3fcae..2752ac5 100644
--- a/providers/iracing/iracing.go
+++ b/providers/iracing/iracing.go
@@ -160,6 +160,10 @@ func (i *IRacing) Stream() (<-chan telem.TelemetryData, error) {
 	return i.streamCh, nil
 }
 
+func (i *IRacing) StopStream() {
+	i.streamCancel()
+}
+
 func (i *IRacing) Subscribe(requestFields map[int16]telem.FieldID) {
 	i.logger.Debug(fmt.Sprintf("Len Req: %d\n", len(requestFields)))
 
diff --git a/telemetry/provider.go b/telemetry/provider.go
index 785b2f6..2aea6be 100644
--- a/telemetry/provider.go
+++ b/telemetry/provider.go
@@ -2,6 +2,7 @@
 package telemetry
 
 type TelemetryProvider interface {
+	StopStream()
 	Stream() (<-chan TelemetryData, error)
 	Subscribe(map[int16]FieldID)
 }
diff --git a/tui/internal/controllers/streaming.go b/tui/internal/controllers/streaming.go
index 7a7ab31..dc98f96 100644
--- a/tui/internal/controllers/streaming.go
+++ b/tui/internal/controllers/streaming.go
@@ -21,8 +21,10 @@ type StreamingCtrl struct {
 	Internal   chan string
 	Run        bool
 	OnExit     func()
-	isRunning  bool
 	TelemServ  *services.TelemetryService
+
+	// Stream State
+	isRunning bool
 }
 
 func NewStreamingCtrl(
@@ -62,11 +64,8 @@ func (sc *StreamingCtrl) registerHooks() {
 
 		switch ev.Rune() {
 		case 's':
-			// Start
-			sc.Start()
-		case 'p':
-			// Pause
-			// sc.Stop()
+			// Start - stop
+			sc.StartStop()
 		case 'u':
 			// Update
 			// NOTE: run the same routine for the form Update button here
@@ -85,8 +84,15 @@ func (sc *StreamingCtrl) registerHooks() {
 	}
 }
 
-func (sc *StreamingCtrl) Start() {
+func (sc *StreamingCtrl) StartStop() {
+	if sc.isRunning {
+		sc.TelemServ.StopStream()
+		sc.isRunning = false
+		return
+	}
+
 	stream := sc.TelemServ.StartStream()
+	sc.isRunning = true
 
 	var isDrawing atomic.Bool
 
diff --git a/tui/internal/services/telemetry.go b/tui/internal/services/telemetry.go
index 4118e5e..8695c15 100644
--- a/tui/internal/services/telemetry.go
+++ b/tui/internal/services/telemetry.go
@@ -1,9 +1,10 @@
 package services
 
 import (
-	providerir "esdi/providers/iracing"
 	"log/slog"
 
+	providerir "esdi/providers/iracing"
+
 	telemetry "esdi/telemetry"
 )
 
@@ -48,8 +49,13 @@ func (t *TelemetryService) SetProvider(provider string) *TelemetryService {
 func (t *TelemetryService) StartStream() <-chan telemetry.TelemetryData {
 	stream, _ := t.ActiveProvider.Stream()
 
-	// Somewhere around here we have to tell the device service to also send data
+	// NOTE: we don't want to just send data to the cdashdisplay. We want to support
+	// multiple devices at the same time
 	t.cdash.StreamData(stream)
 
 	return stream
 }
+
+func (t *TelemetryService) StopStream() {
+	t.ActiveProvider.StopStream()
+}