🥩🖱️ ↝ Expeditions, stations and docking locations are all now being synced

Author: Gizmotronn

backend/cmd/simple-sync-docking_locations.go

@@ -2,15 +2,16 @@ package main
 
 import (
 	"log"
-	"os"
 
 	"github.com/signal-k/notifs/internal/sync"
 )
 
 func main() {
-	if err := sync.SyncMostRecentDockingLocation(); err != nil {
-		log.Printf("❌ Docking location sync failed: %v", err)
-		os.Exit(1)
+	log.Println("🛰️ Fetching docking locations...")
+
+	if err := sync.SyncDockingLocations(); err != nil {
+		log.Fatalf("Sync failed: %v", err)
 	}
-	log.Println("✅ Docking location sync completed successfully.")
+
+	log.Println("✅ Docking location sync completed.")
 }

backend/cmd/sync-docking_locations/main.go

@@ -0,0 +1,14 @@
+package main
+
+import (
+	"log"
+
+	"github.com/signal-k/notifs/internal/sync"
+)
+
+func main() {
+	log.Println("🧭 Fetching space expeditions...")
+	if err := sync.SyncExpeditions(); err != nil {
+log.Fatalf("Sync failed: failed to parse expedition JSON: %v", err)
+	}
+}

backend/cmd/sync-expeditions/main.go

@@ -0,0 +1,17 @@
+package main
+
+import (
+	"log"
+
+	"github.com/signal-k/notifs/internal/sync"
+)
+
+func main() {
+	log.Println("🛰️ Fetching space stations...")
+
+	if err := sync.SyncStations(); err != nil {
+		log.Fatalf("Sync failed: %v", err)
+	}
+
+	log.Println("✅ Sync completed successfully.")
+}

backend/cmd/sync-stations/main.go

@@ -5,51 +5,39 @@ import (
 	"encoding/json"
 	"fmt"
 	"io"
+	"log"
 	"net/http"
+	"net/url"
 	"time"
 )
 
-type SpaceDevsDockingLocationResponse struct {
-	Results []SpaceDevsDockingLocation `json:"results"`
-}
-
 type SpaceDevsDockingLocation struct {
 	ID           int    `json:"id"`
 	Name         string `json:"name"`
 	Spacestation struct {
 		ID    int    `json:"id"`
-		URL   string `json:"url"`
 		Name  string `json:"name"`
+		URL   string `json:"url"`
 		Image struct {
-			ID           int    `json:"id"`
-			Name         string `json:"name"`
-			ImageURL     string `json:"image_url"`
-			ThumbnailURL string `json:"thumbnail_url"`
-			Credit       string `json:"credit"`
-			License      struct {
-				ID       int    `json:"id"`
-				Name     string `json:"name"`
-				Priority int    `json:"priority"`
-				Link     string `json:"link"`
+			ImageURL string `json:"image_url"`
+			Credit   string `json:"credit"`
+			License  struct {
+				Name string `json:"name"`
+				Link string `json:"link"`
 			} `json:"license"`
-			SingleUse bool `json:"single_use"`
 		} `json:"image"`
 	} `json:"spacestation"`
-	Spacecraft *struct {
-		Name string `json:"name"`
-	} `json:"spacecraft"`
-	Payload *struct {
-		Name string `json:"name"`
-	} `json:"payload"`
 }
 
-// SyncMostRecentDockingLocation fetches and stores the most recent docking location
-func SyncMostRecentDockingLocation() error {
-	fmt.Println("🛰️ Fetching most recent docking location...")
+type SpaceDevsDockingLocationResponse struct {
+	Results []SpaceDevsDockingLocation `json:"results"`
+}
 
-	resp, err := http.Get("https://ll.thespacedevs.com/2.3.0/config/docking_locations/?limit=1&ordering=-id&format=json")
+func SyncDockingLocations() error {
+	apiURL := "https://ll.thespacedevs.com/2.3.0/config/docking_locations/?limit=30&format=json"
+	resp, err := http.Get(apiURL)
 	if err != nil {
-		return fmt.Errorf("failed to fetch docking location: %w", err)
+		return fmt.Errorf("failed to fetch docking locations: %w", err)
 	}
 	defer resp.Body.Close()
 
@@ -60,104 +48,95 @@ func SyncMostRecentDockingLocation() error {
 
 	var data SpaceDevsDockingLocationResponse
 	if err := json.Unmarshal(body, &data); err != nil {
-		return fmt.Errorf("failed to parse docking location response: %w", err)
-	}
-	if len(data.Results) == 0 {
-		return fmt.Errorf("no docking location results found")
+		return fmt.Errorf("failed to parse JSON: %w", err)
 	}
 
-	docking := data.Results[0]
-	if err := createDockingLocationInPocketbase(docking); err != nil {
-		return fmt.Errorf("failed to insert docking location: %w", err)
-	}
+	log.Printf("✅ Fetched %d docking locations\n", len(data.Results))
 
-	fmt.Println("✅ Most Recent Docking Location:")
-	fmt.Printf("- Name: %s\n", docking.Name)
-	fmt.Printf("- Station: %s\n", docking.Spacestation.Name)
-	fmt.Printf("  • Image: %s\n", docking.Spacestation.Image.ImageURL)
-	fmt.Printf("  • Credit: %s\n", docking.Spacestation.Image.Credit)
-	fmt.Printf("  • License: %s (%s)\n", docking.Spacestation.Image.License.Name, docking.Spacestation.Image.License.Link)
-	if docking.Spacecraft != nil {
-		fmt.Printf("- Spacecraft: %s\n", docking.Spacecraft.Name)
-	} else {
-		fmt.Println("- Spacecraft: None")
-	}
-	if docking.Payload != nil {
-		fmt.Printf("- Payload: %s\n", docking.Payload.Name)
-	} else {
-		fmt.Println("- Payload: None")
+	for _, loc := range data.Results {
+		if err := insertDockingLocation(loc); err != nil {
+			log.Printf("❌ Failed to insert docking location %s: %v", loc.Name, err)
+		} else {
+			log.Printf("✅ Inserted: %s (Station: %s)", loc.Name, loc.Spacestation.Name)
+		}
 	}
 
 	return nil
 }
 
-func createDockingLocationInPocketbase(d SpaceDevsDockingLocation) error {
-	// Replace with your actual Pocketbase station record mapping logic
-	stationPbID, err := findStationPocketbaseID(d.Spacestation.ID)
+func insertDockingLocation(loc SpaceDevsDockingLocation) error {
+	// Find the corresponding station in Pocketbase by name
+	stationID, err := findStationIDByName(loc.Spacestation.Name)
 	if err != nil {
-		return fmt.Errorf("could not resolve station: %w", err)
+		return fmt.Errorf("station lookup failed: %w", err)
 	}
 
-	payload := map[string]interface{}{
-		"api_id":               d.ID,
-		"name":                 d.Name,
-		"station":              stationPbID,
-		"spacecraft_name":      derefString(d.Spacecraft),
-		"payload_name":         derefString(d.Payload),
-		"station_image_url":    d.Spacestation.Image.ImageURL,
-		"station_image_credit": d.Spacestation.Image.Credit,
-		"station_license_name": d.Spacestation.Image.License.Name,
-		"station_license_url":  d.Spacestation.Image.License.Link,
-		"api_url":              fmt.Sprintf("https://ll.thespacedevs.com/2.3.0/config/docking_locations/%d/", d.ID),
+	pbURL := "http://127.0.0.1:8080/api/collections/docking_locations/records"
+	payload := map[string]any{
+		"api_id":       loc.ID,
+		"name":         loc.Name,
+		"station":      stationID,
+		"station_url":  loc.Spacestation.URL,
+		"image_url":    loc.Spacestation.Image.ImageURL,
+		"image_credit": loc.Spacestation.Image.Credit,
+		"license_name": loc.Spacestation.Image.License.Name,
+		"license_url":  loc.Spacestation.Image.License.Link,
 	}
 
 	jsonData, err := json.Marshal(payload)
 	if err != nil {
-		return err
+		return fmt.Errorf("marshal payload: %w", err)
 	}
 
-	req, err := http.NewRequest("POST", "http://127.0.0.1:8080/api/collections/docking_locations/records", bytes.NewBuffer(jsonData))
+	req, err := http.NewRequest("POST", pbURL, bytes.NewBuffer(jsonData))
 	if err != nil {
-		return err
+		return fmt.Errorf("create request: %w", err)
 	}
 	req.Header.Set("Content-Type", "application/json")
 
 	client := &http.Client{Timeout: 10 * time.Second}
 	res, err := client.Do(req)
 	if err != nil {
-		return err
+		return fmt.Errorf("POST to Pocketbase: %w", err)
 	}
 	defer res.Body.Close()
 
 	if res.StatusCode >= 400 {
 		body, _ := io.ReadAll(res.Body)
-		return fmt.Errorf("HTTP %d: %s", res.StatusCode, body)
+		return fmt.Errorf("Pocketbase error %d: %s", res.StatusCode, body)
 	}
 
 	return nil
 }
 
-// Helper to safely dereference name field from *structs
-func derefString(ptr interface{}) string {
-	switch v := ptr.(type) {
-	case *struct{ Name string }:
-		if v != nil {
-			return v.Name
-		}
-	case nil:
-		return ""
+func findStationIDByName(stationName string) (string, error) {
+	query := url.QueryEscape(fmt.Sprintf("name='%s'", stationName))
+	apiURL := fmt.Sprintf("http://127.0.0.1:8080/api/collections/stations/records?filter=%s", query)
+
+	res, err := http.Get(apiURL)
+	if err != nil {
+		return "", fmt.Errorf("station lookup HTTP error: %w", err)
 	}
-	return ""
-}
+	defer res.Body.Close()
 
-// Replace with real lookup (from Pocketbase stations by api_id)
-func findStationPocketbaseID(spaceDevsStationID int) (string, error) {
-	// TEMPORARY placeholder — replace with Pocketbase fetch (GET /collections/stations)
-	// that maps api_id -> Pocketbase ID
-	switch spaceDevsStationID {
-	case 4:
-		return "RECORD_ID_FOR_ISS", nil
-	default:
-		return "", fmt.Errorf("no known mapping for station ID %d", spaceDevsStationID)
+	if res.StatusCode != 200 {
+		body, _ := io.ReadAll(res.Body)
+		return "", fmt.Errorf("station lookup failed: HTTP %d: %s", res.StatusCode, body)
 	}
+
+	var response struct {
+		Items []struct {
+			ID string `json:"id"`
+		} `json:"items"`
+	}
+
+	if err := json.NewDecoder(res.Body).Decode(&response); err != nil {
+		return "", fmt.Errorf("decode station lookup: %w", err)
+	}
+
+	if len(response.Items) == 0 {
+		return "", fmt.Errorf("station not found for name: %s", stationName)
+	}
+
+	return response.Items[0].ID, nil
 }