fix telemetryPoints for FE

Author: OJPARKINSON

docker-compose.dev.yml

@@ -48,7 +48,7 @@ services:
       JAVA_OPTS: "-Xmx2g -Xms1g -XX:+UseG1GC -XX:MaxGCPauseMillis=200 -XX:G1ReservePercent=20"
       QDB_SHARED_WORKER_COUNT: "5"
       QDB_HTTP_ENABLED: "true"
-      QDB_PG_ENABLED: "false"
+      QDB_PG_ENABLED: "true"
       QDB_LINE_TCP_ENABLED: "true"
       QDB_METRICS_ENABLED: "true"
       QDB_CAIRO_WAL_ENABLED_DEFAULT: "true"

docker-compose.yml

@@ -65,7 +65,7 @@ services:
       JAVA_OPTS: "-Xmx2g -Xms1g -XX:+UseG1GC -XX:MaxGCPauseMillis=200 -XX:G1ReservePercent=20"
       QDB_SHARED_WORKER_COUNT: "2"
       QDB_HTTP_ENABLED: "true"
-      QDB_PG_ENABLED: "false"
+      QDB_PG_ENABLED: "true"
       QDB_METRICS_ENABLED: "true"
       QDB_LINE_TCP_ENABLED: "true"
       QDB_CAIRO_WAL_ENABLED_DEFAULT: "true"

telemetryService/golang/cmd/telemetry-service/main.go

@@ -21,7 +21,7 @@ func main() {
 
 	cfg := config.NewConfig()
 
-	schema := questdb.NewRepository(cfg.QuestDbHost, cfg.QuestDBPort)
+	schema := questdb.NewSchema(cfg.QuestDbHost, cfg.QuestDBPort)
 	if err := schema.CreateTableHTTP(); err != nil {
 		log.Printf("Failed to create table: %v", err)
 		log.Println("Exiting due to database initialization failure")
@@ -38,7 +38,7 @@ func main() {
 	}
 	log.Println("Sender pool created successfully")
 
-	pgxPool, err := pgxpool.New(context.Background(), fmt.Sprintf("postgres://%s:%d/questdb?sslmode=disable", cfg.QuestDbHost,
+	pgxPool, err := pgxpool.New(context.Background(), fmt.Sprintf("postgres://admin:quest@%s:%d/questdb?sslmode=disable", cfg.QuestDbHost,
 		8812))
 	if err != nil {
 		log.Fatalf("pgx pool: %v", err)

telemetryService/golang/internal/adapter/questdb/reader.go

@@ -3,47 +3,65 @@ package questdb
 import (
 	"context"
 	"fmt"
+	"strconv"
+	"time"
 
+	"github.com/jackc/pgx/v5/pgtype"
 	"github.com/ojparkinson/telemetryService/internal/db/generated"
 	"github.com/ojparkinson/telemetryService/internal/domain"
 )
 
 func (r *Repository) ListSessions(ctx context.Context) ([]domain.Session, error) {
 	rows, err := r.queries.ListSessions(ctx)
 	if err != nil {
-		return nil, fmt.Errorf("list sessions: %W", err)
+		return nil, fmt.Errorf("list sessions: %w", err)
 	}
 
 	sessions := make([]domain.Session, len(rows))
 	for i, row := range rows {
+		var maxLapID string
+		if v, ok := row.MaxLapID.(string); ok {
+			maxLapID = v
+		} else if v, ok := row.MaxLapID.(pgtype.Text); ok {
+			maxLapID = v.String
+		}
+
+		var lastUpdated time.Time
+		if v, ok := row.LastUpdated.(time.Time); ok {
+			lastUpdated = v
+		} else if v, ok := row.LastUpdated.(pgtype.Timestamp); ok && v.Valid {
+			lastUpdated = v.Time
+		}
+
 		sessions[i] = domain.Session{
-			SessionID:   row.SessionID,
-			TrackName:   row.TrackName,
-			SessionName: row.SessionName,
-			MaxLapID:    row.MaxLapID,
-			LastUpdated: row.LastUpdated,
+			SessionID:   row.SessionID.String,
+			TrackName:   row.TrackName.String,
+			SessionName: row.SessionName.String,
+			MaxLapID:    maxLapID,
+			LastUpdated: lastUpdated,
 		}
 	}
 	return sessions, nil
 }
 
 func (r *Repository) ListLaps(ctx context.Context, sessionsID string) ([]domain.Lap, error) {
-	rows, err := r.queries.ListLaps(ctx, sessionsID)
+	rows, err := r.queries.ListLaps(ctx, pgtype.Text{String: sessionsID, Valid: true})
 	if err != nil {
 		return nil, fmt.Errorf("list laps: %w", err)
 	}
 
 	laps := make([]domain.Lap, len(rows))
 	for i, row := range rows {
-		laps[i] = domain.Lap{LapID: row.LapID}
+		lapID, _ := strconv.Atoi(row.String)
+		laps[i] = domain.Lap{LapID: lapID}
 	}
 	return laps, nil
 }
 
 func (r *Repository) GetLapTelemetry(ctx context.Context, sessionID, lapID string) ([]domain.TelemetryPoint, error) {
 	rows, err := r.queries.GetLapTelemetry(ctx, generated.GetLapTelemetryParams{
-		SessionID: sessionID,
-		LapID:     lapID,
+		SessionID: pgtype.Text{String: sessionID, Valid: true},
+		LapID:     pgtype.Text{String: lapID, Valid: true},
 	})
 	if err != nil {
 		return nil, fmt.Errorf("get lap telemetry: %w", err)
@@ -58,11 +76,31 @@ func (r *Repository) GetLapTelemetry(ctx context.Context, sessionID, lapID strin
 
 func telemetryPointFromRow(row generated.Telemetrytick) domain.TelemetryPoint {
 	return domain.TelemetryPoint{
-		Speed:    row.Speed,
-		Throttle: row.Throttle,
-		Brake:    row.Brake,
-		RPM:      row.Rpm,
-		Gear:     row.Gear,
-		// ... all fields, but now it's typed — no getString/getFloat64 helpers
+		Speed:              row.Speed.Float64,
+		Throttle:           row.Throttle.Float64,
+		Brake:              row.Brake.Float64,
+		RPM:                row.Rpm.Float64,
+		Gear:               uint32(row.Gear.Int32),
+		LapDistPct:         row.LapDistPct.Float64,
+		SteeringWheelAngle: row.SteeringWheelAngle.Float64,
+		Lat:                row.Lat.Float64,
+		Lon:                row.Lon.Float64,
+		Alt:                row.Alt.Float64,
+		VelocityX:          row.VelocityX.Float64,
+		VelocityY:          row.VelocityY.Float64,
+		VelocityZ:          row.VelocityZ.Float64,
+		LatAccel:           row.LatAccel.Float64,
+		LongAccel:          row.LongAccel.Float64,
+		VertAccel:          row.VertAccel.Float64,
+		Pitch:              row.Pitch.Float64,
+		Roll:               row.Roll.Float64,
+		Yaw:                row.Yaw.Float64,
+		YawNorth:           row.YawNorth.Float64,
+		FuelLevel:          row.FuelLevel.Float64,
+		LapCurrentLapTime:  row.LapCurrentLapTime.Float64,
+		PlayerCarPosition:  uint32(row.PlayerCarPosition.Int32),
+		TrackName:          row.TrackName.String,
+		SessionNum:         row.SessionNum.String,
+		SessionTime:        row.SessionTime.Float64,
 	}
 }

telemetryService/golang/internal/adapter/questdb/schema.go

@@ -9,7 +9,11 @@ import (
 
 type Schema struct {
 	host string
-	port string
+	port int
+}
+
+func NewSchema(host string, port int) *Schema {
+	return &Schema{host: host, port: port}
 }
 
 func (s *Schema) CreateTableHTTP() error {

telemetryService/golang/internal/api/handlers.go

@@ -43,7 +43,13 @@ func (s *Server) handleGetLaps(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 
-	respondJSON(w, 200, rows)
+	lapIDs := make([]int, len(rows))
+
+	for i, row := range rows {
+		lapIDs[i] = row.LapID
+	}
+
+	respondJSON(w, 200, lapIDs)
 
 }
 

telemetryService/golang/internal/db/db.go

@@ -1,6 +1 @@
 package db
-
-
-type database struct {
-	conn sql.
-}

telemetryService/golang/internal/db/generated/laps.sql.go

@@ -1,3 +1,3 @@
 -- name: ListLaps :many
 SELECT DISTINCT lap_id FROM TelemetryTicks
-WHERE session_id = @session_id ORDER BY lap_id ASC;
+WHERE session_id = $1 ORDER BY CAST(lap_id as int) ASC;

telemetryService/golang/internal/db/queries/laps.sql

@@ -13,5 +13,5 @@ type SessionRepository interface {
 }
 
 type TelemetryWriter interface {
-	WriteBatch(ctx context.Context, records []*messaging.Telemetry)
+	WriteBatch(ctx context.Context, records []*messaging.Telemetry) error
 }