summaryrefslogtreecommitdiff
path: root/golang/pkg/api/systems.go
diff options
context:
space:
mode:
authorJulien Dessaux2025-02-17 00:40:43 +0100
committerJulien Dessaux2025-02-17 00:40:43 +0100
commitbd2fb50c819c2b180758308ef3751e7ea73e6ab7 (patch)
tree19632f7098691a1147357039a5efedf7c40a8d53 /golang/pkg/api/systems.go
parent[golang] handle paginated requests (diff)
downloadspacetraders-bd2fb50c819c2b180758308ef3751e7ea73e6ab7.tar.gz
spacetraders-bd2fb50c819c2b180758308ef3751e7ea73e6ab7.tar.bz2
spacetraders-bd2fb50c819c2b180758308ef3751e7ea73e6ab7.zip
[golang] implement shipyards visits
Diffstat (limited to 'golang/pkg/api/systems.go')
-rw-r--r--golang/pkg/api/systems.go26
1 files changed, 22 insertions, 4 deletions
diff --git a/golang/pkg/api/systems.go b/golang/pkg/api/systems.go
index 3d3a373..05e43e3 100644
--- a/golang/pkg/api/systems.go
+++ b/golang/pkg/api/systems.go
@@ -25,9 +25,10 @@ func (c *Client) GetSystem(symbol string, db *database.DB) (*model.System, error
}
func (c *Client) ListWaypointsInSystem(system *model.System, db *database.DB) ([]model.Waypoint, error) {
- // TODO database caching
- // TODO pagination
- // TODO check updated
+ if waypoints, err := db.LoadWaypointsInSystem(system); err == nil && waypoints != nil {
+ // TODO check last updated time
+ return waypoints, nil
+ }
uriRef := url.URL{Path: path.Join("systems", system.Symbol, "waypoints")}
var waypoints []model.Waypoint
if err := c.Send("GET", &uriRef, nil, &waypoints); err != nil {
@@ -41,9 +42,26 @@ func (c *Client) ListWaypointsInSystem(system *model.System, db *database.DB) ([
return waypoints, nil
}
+func (c *Client) GetShipyard(waypoint *model.Waypoint, db *database.DB) (*model.Shipyard, error) {
+ if shipyard, err := db.LoadShipyard(waypoint.Symbol); err == nil && shipyard != nil &&
+ (shipyard.Ships != nil) { // TODO || !IsThereAShipAtWaypoint(waypoint)) {
+ // TODO check last updated time
+ return shipyard, nil
+ }
+ uriRef := url.URL{Path: path.Join("systems", waypoint.SystemSymbol, "waypoints", waypoint.Symbol, "shipyard")}
+ var shipyard model.Shipyard
+ if err := c.Send("GET", &uriRef, nil, &shipyard); err != nil {
+ return nil, fmt.Errorf("failed to get shipyard at %s: %w", waypoint.Symbol, err)
+ }
+ if err := db.SaveShipyard(&shipyard); err != nil {
+ return nil, fmt.Errorf("failed to get shipyard at %s: %w", waypoint.Symbol, err)
+ }
+ return &shipyard, nil
+}
+
func (c *Client) GetWaypoint(symbol string, db *database.DB) (*model.Waypoint, error) {
- // TODO check updated
if waypoint, err := db.LoadWaypoint(symbol); err == nil && waypoint != nil {
+ // TODO check last updated time
return waypoint, nil
}
systemSymbol := WaypointSymbolToSystemSymbol(symbol)