feat: Iridium pass predictor + queue proxy (Priorities 3d + 4)

Priority 3d — queue proxy:
- 4 new proxy handlers in communication.go: GetMeshsatIridiumQueue,
  PostMeshsatIridiumQueue, PostMeshsatIridiumQueueCancel, PostMeshsatIridiumQueuePriority
- Routes: /communication/meshsat/iridium/queue and sub-paths

Priority 4 — server-side pass predictor:
- Schema migration v26: iridium_locations table (with Leiden + Thessaloniki seeds)
  and iridium_tle_cache table
- tle_manager.go: daily Celestrak TLE fetch, SGP4 pass computation via
  github.com/akhenakh/sgp4, location CRUD, cache info
- 5 new handlers: GetIridiumPasses, PostIridiumPassesRefresh,
  GetIridiumLocations, PostIridiumLocation, DeleteIridiumLocation
- Routes: /communication/iridium/passes, /communication/iridium/passes/refresh,
  /communication/iridium/locations (CRUD)
- main.go: wire TLEManager + SetTLEManager on CommunicationHandler

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: papadopouloskyriakos

cmd/cubeos-api/main.go

@@ -589,6 +589,13 @@ func main() {
 	defer signalRecorder.Stop()
 	log.Info().Msg("Iridium signal recorder started")
 
+	// Start Iridium TLE manager (daily Celestrak fetch + SGP4 pass prediction)
+	tleManager := managers.NewTLEManager(db.DB)
+	tleManager.Start(engineCtx)
+	defer tleManager.Stop()
+	communicationHandler.SetTLEManager(tleManager)
+	log.Info().Msg("Iridium TLE manager started")
+
 	// Create WebSocket manager and handlers
 	wsManager := handlers.NewWSManager(systemMgr, networkMgr, monitoringMgr, docker)
 	wsHandlers := handlers.NewWSHandlers(wsManager)

go.mod

@@ -22,6 +22,7 @@ require (
 require (
 	github.com/KyleBanks/depth v1.2.1 // indirect
 	github.com/Microsoft/go-winio v0.6.2 // indirect
+	github.com/akhenakh/sgp4 v0.0.0-20250910232432-ca28846088fc // indirect
 	github.com/containerd/log v0.1.0 // indirect
 	github.com/distribution/reference v0.6.0 // indirect
 	github.com/docker/go-connections v0.5.0 // indirect

go.sum

@@ -6,6 +6,8 @@ github.com/KyleBanks/depth v1.2.1 h1:5h8fQADFrWtarTdtDudMmGsC7GPbOAu6RVB3ffsVFHc
 github.com/KyleBanks/depth v1.2.1/go.mod h1:jzSb9d0L43HxTQfT+oSA1EEp2q+ne2uh6XgeJcm8brE=
 github.com/Microsoft/go-winio v0.6.2 h1:F2VQgta7ecxGYO8k3ZZz3RS8fVIXVxONVUPlNERoyfY=
 github.com/Microsoft/go-winio v0.6.2/go.mod h1:yd8OoFMLzJbo9gZq8j5qaps8bJ9aShtEA8Ipt1oGCvU=
+github.com/akhenakh/sgp4 v0.0.0-20250910232432-ca28846088fc h1:MuvZBPt391TvmQGeyKbaFM8y13OqW+Lp1bGhx/izMbg=
+github.com/akhenakh/sgp4 v0.0.0-20250910232432-ca28846088fc/go.mod h1:JfAepWD223Cel6uRpzYdip/xijWZ2FT457YFLWy8Md4=
 github.com/cenkalti/backoff/v4 v4.2.1 h1:y4OZtCnogmCPw98Zjyt5a6+QwPLGkiQsYW5oUqylYbM=
 github.com/cenkalti/backoff/v4 v4.2.1/go.mod h1:Y3VNntkOUPxTVeUxJ/G5vcM//AlwfmyYozVcomhLiZE=
 github.com/containerd/log v0.1.0 h1:TCJt7ioM2cr/tfR8GPbGf9/VRAX8D2B4PjzCpfX540I=

internal/database/migrations.go

@@ -1015,6 +1015,44 @@ var migrations = []Migration{
 			return nil
 		},
 	},
+	{
+		Version:     26,
+		Description: "Add Iridium pass predictor tables: locations and TLE cache",
+		Up: func(db *sql.DB) error {
+			stmts := []string{
+				// iridium_locations: ground stations for pass prediction
+				`CREATE TABLE IF NOT EXISTS iridium_locations (
+					id         INTEGER PRIMARY KEY AUTOINCREMENT,
+					name       TEXT NOT NULL,
+					lat        REAL NOT NULL,
+					lon        REAL NOT NULL,
+					alt_m      REAL NOT NULL DEFAULT 0,
+					builtin    INTEGER NOT NULL DEFAULT 0,
+					created_at INTEGER NOT NULL DEFAULT (CAST(strftime('%s','now') AS INTEGER))
+				)`,
+				// Seed built-in locations
+				`INSERT OR IGNORE INTO iridium_locations (name, lat, lon, alt_m, builtin) VALUES ('Leiden', 52.160, 4.497, 0, 1)`,
+				`INSERT OR IGNORE INTO iridium_locations (name, lat, lon, alt_m, builtin) VALUES ('Thessaloniki', 40.629, 22.947, 0, 1)`,
+
+				// iridium_tle_cache: cached TLE data fetched from Celestrak
+				`CREATE TABLE IF NOT EXISTS iridium_tle_cache (
+					id             INTEGER PRIMARY KEY AUTOINCREMENT,
+					satellite_name TEXT NOT NULL,
+					line1          TEXT NOT NULL,
+					line2          TEXT NOT NULL,
+					fetched_at     INTEGER NOT NULL  -- Unix epoch seconds
+				)`,
+				`CREATE INDEX IF NOT EXISTS idx_tle_cache_name ON iridium_tle_cache(satellite_name)`,
+			}
+			for _, stmt := range stmts {
+				if _, err := db.Exec(stmt); err != nil {
+					return fmt.Errorf("migration 26 failed: %w\nStatement: %s", err, stmt)
+				}
+			}
+			log.Info().Msg("Migration 26: Created iridium_locations and iridium_tle_cache tables")
+			return nil
+		},
+	},
 }
 
 // isDuplicateColumnError checks if an error is a "duplicate column" error