some fixes regarding iracing provider transforms and working the auto detection

telemetry/commonTransforms.go

@@ -7,40 +7,35 @@ func EmptyTransform(v any, out *TelemetryField) {
 	out.Raw = uint64('-')
 }
 
-func UInt8Transform(v any, out *TelemetryField) {
+func UInt8Transform(v int, out *TelemetryField) {
 	out.Type = DataTypeUINT8
 
-	if v == nil {
-		out.Raw = 0
-		return
-	}
-
-	out.Raw = uint64(v.(int))
-}
-
-func FloatToStringTransform(v float32, out *TelemetryField) {
-	out.Type = DataTypeSTRING
-	out.Str = strconv.FormatFloat(float64(v), 'f', 1, 32)
-}
-
-func FloatToStringTransformDEPRECATE(v any, out *TelemetryField) {
-	out.Type = DataTypeSTRING
-
-	if v == nil {
-		out.Str = "inv"
-		return
-	}
-
-	out.Str = strconv.FormatFloat(float64(v.(float32)), 'f', 1, 32)
-}
-
-func FloatToUInt8TransformDEPRECATE(v any, out *TelemetryField) {
-	out.Type = DataTypeUINT8
-
-	if v == nil {
+	if v < 0 {
 		out.Raw = uint64(0)
 		return
 	}
 
-	out.Raw = uint64(v.(float32))
+	out.Raw = uint64(v)
+}
+
+func FloatToStringTransform(v float32, out *TelemetryField) {
+	out.Type = DataTypeSTRING
+
+	if v < 0.0 {
+		out.Str = "inv"
+		return
+	}
+
+	out.Str = strconv.FormatFloat(float64(v), 'f', 1, 32)
+}
+
+func FloatToUInt8Transform(v float32, out *TelemetryField) {
+	out.Type = DataTypeUINT8
+
+	if v < 0.0 {
+		out.Raw = uint64(0)
+		return
+	}
+
+	out.Raw = uint64(v)
 }

telemetry/data.go

@@ -30,11 +30,8 @@ type VirtualField interface {
 // BoundField is the data structure we use to bind the telemetry provider's data
 // to our internal telemetry fields
 type BoundField struct {
-	Key       string // NOTE: to be deprecated
-	ID        FieldID
-	Fetch     func() any                 // NOTE: to be deprecated
-	Transform func(any, *TelemetryField) // NOTE: to be deprecated
-	Update    func(out *TelemetryField)
+	ID     FieldID
+	Update func(out *TelemetryField)
 }
 
 var bufferPool = sync.Pool{
@@ -105,7 +102,8 @@ func (tf *TelemetryField) Pack(dest []byte) []byte {
 		case DataTypeINT32, DataTypeUINT32:
 			dest = append(dest, uint8(tf.Raw), uint8(tf.Raw>>8), uint8(tf.Raw>>16), uint8(tf.Raw>>24))
 		case DataTypeINT64, DataTypeUINT64:
-			dest = append(dest, uint8(tf.Raw), uint8(tf.Raw>>8), uint8(tf.Raw>>16),
+			dest = append(
+				dest, uint8(tf.Raw), uint8(tf.Raw>>8), uint8(tf.Raw>>16),
 				uint8(tf.Raw>>24), uint8(tf.Raw>>32), uint8(tf.Raw>>40), uint8(tf.Raw>>48),
 				uint8(tf.Raw>>56),
 			)

telemetry/provider.go

@@ -5,4 +5,5 @@ type TelemetryProvider interface {
 	StopStream()
 	Stream() (<-chan TelemetryData, error)
 	Subscribe(map[int16]FieldID)
+	Stalled() bool // Return true if no fresh data is coming
 }