1 files changed, 73 insertions, 0 deletions
diff --git a/pkg/navitia_api_client/departures.go b/pkg/navitia_api_client/departures.go
new file mode 100644
index 0000000..7738940
--- /dev/null
+++ b/pkg/navitia_api_client/departures.go
@@ -0,0 +1,73 @@
+package navitia_api_client
+
+import (
+	"encoding/json"
+	"fmt"
+	"net/http"
+	"time"
+)
+
+type DeparturesResponse struct {
+	Disruptions []interface{} `json:"disruptions"`
+	Notes       []interface{} `json:"notes"`
+	Departures  []struct {
+		DisplayInformations struct {
+			Direction      string        `json:"direction"`
+			Code           string        `json:"code"`
+			Network        string        `json:"network"`
+			Links          []interface{} `json:"links"`
+			Color          string        `json:"color"`
+			Name           string        `json:"name"`
+			PhysicalMode   string        `json:"physical_mode"`
+			Headsign       string        `json:"headsign"`
+			Label          string        `json:"label"`
+			Equipments     []interface{} `json:"equipments"`
+			TextColor      string        `json:"text_color"`
+			TripShortName  string        `json:"trip_short_name"`
+			CommercialMode string        `json:"commercial_mode"`
+			Description    string        `json:"description"`
+		} `json:"display_informations"`
+		StopDateTime struct {
+			Links                  []interface{} `json:"links"`
+			ArrivalDateTime        string        `json:"arrival_date_time"`
+			AdditionalInformations []interface{} `json:"additional_informations"`
+			DepartureDateTime      string        `json:"departure_date_time"`
+			BaseArrivalDateTime    string        `json:"base_arrival_date_time"`
+			BaseDepartureDateTime  string        `json:"base_departure_date_time"`
+			DataFreshness          string        `json:"data_freshness"`
+		} `json:"stop_date_time"`
+	} `json:"departures"`
+	Context struct {
+		Timezone        string `json:"timezone"`
+		CurrentDatetime string `json:"current_datetime"`
+	} `json:"context"`
+}
+
+func (c *Client) GetDepartures() (departures *DeparturesResponse, err error) {
+	request := fmt.Sprintf("%s/coverage/sncf/stop_areas/stop_area:SNCF:87723502/departures", c.baseURL)
+	start := time.Now()
+	c.mutex.Lock()
+	defer c.mutex.Unlock()
+	if cachedResult, ok := c.cache[request]; ok {
+		if start.Sub(cachedResult.ts) < 60*1000*1000*1000 {
+			return cachedResult.result.(*DeparturesResponse), nil
+		}
+	}
+	req, err := http.NewRequest("GET", request, nil)
+	if err != nil {
+		return nil, err
+	}
+	resp, err := c.httpClient.Do(req)
+	if err != nil {
+		return nil, err
+	}
+	defer resp.Body.Close()
+	if err = json.NewDecoder(resp.Body).Decode(&departures); err != nil {
+		return nil, err
+	}
+	c.cache[request] = cachedResult{
+		ts:     start,
+		result: departures,
+	}
+	return
+}