feat(platform): paginate vehicle coverage

vehicle-data-platform/apps/api/internal/platform/mysql_queries.go

@@ -7,8 +7,10 @@ import (
 )
 
 type SQLQuery struct {
-	Text string
-	Args []any
+	Text      string
+	Args      []any
+	CountText string
+	CountArgs []any
 }
 
 func buildVehicleListSQL(query url.Values) SQLQuery {
@@ -73,11 +75,17 @@ func buildVehicleCoverageSQL(query url.Values) SQLQuery {
 	case "unbound":
 		having = append(having, "MAX(CASE WHEN b.vin IS NOT NULL AND b.vin <> '' THEN 1 ELSE 0 END) = 0")
 	}
+	countArgs := append([]any(nil), args...)
 	args = append(args, limit, offset)
 	havingSQL := ""
 	if len(having) > 0 {
 		havingSQL = ` HAVING ` + strings.Join(having, " AND ") + ` `
 	}
+	groupSQL := `FROM vehicle_realtime_snapshot s ` +
+		`LEFT JOIN vehicle_identity_binding b ON b.vin = s.vin ` +
+		`WHERE ` + strings.Join(where, " AND ") + ` ` +
+		`GROUP BY s.vin, b.plate, b.phone, b.oem, b.vin ` +
+		havingSQL
 	return SQLQuery{
 		Text: `SELECT s.vin, ` +
 			`COALESCE(NULLIF(MAX(NULLIF(s.plate, '')), ''), b.plate, '') AS plate, ` +
@@ -88,13 +96,11 @@ func buildVehicleCoverageSQL(query url.Values) SQLQuery {
 			`CASE WHEN COUNT(DISTINCT CASE WHEN s.updated_at >= DATE_SUB(NOW(), INTERVAL 1 MINUTE) THEN s.protocol END) > 0 THEN 1 ELSE 0 END AS online, ` +
 			`COALESCE(DATE_FORMAT(MAX(s.updated_at), '%Y-%m-%d %H:%i:%s'), '') AS last_seen, ` +
 			`CASE WHEN b.vin IS NOT NULL AND b.vin <> '' THEN 'bound' ELSE 'unbound' END AS binding_status ` +
-			`FROM vehicle_realtime_snapshot s ` +
-			`LEFT JOIN vehicle_identity_binding b ON b.vin = s.vin ` +
-			`WHERE ` + strings.Join(where, " AND ") + ` ` +
-			`GROUP BY s.vin, b.plate, b.phone, b.oem, b.vin ` +
-			havingSQL +
-			`ORDER BY MAX(s.updated_at) DESC LIMIT ? OFFSET ?`,
-		Args: args,
+			groupSQL +
+			`ORDER BY MAX(s.updated_at) DESC, s.vin ASC LIMIT ? OFFSET ?`,
+		Args:      args,
+		CountText: `SELECT COUNT(*) FROM (SELECT s.vin ` + groupSQL + `) vehicle_coverage_count`,
+		CountArgs: countArgs,
 	}
 }