load and fetch routes dumps

backend/main.go

@@ -32,6 +32,10 @@ func main() {
 
 	log.Println("Using configuration:", AliceConfig.File)
 
+	// Setup local routes store
+	routesStore := NewRoutesStore(AliceConfig)
+	routesStore.Start()
+
 	// Setup request routing
 	router := httprouter.New()
 

backend/routes_store.go

@@ -8,44 +8,86 @@ import (
 	"time"
 )
 
+const (
+	STATE_INIT = iota
+	STATE_READY
+	STATE_UPDATING
+	STATE_ERROR
+)
+
+type StoreStatus struct {
+	LastRefresh time.Time
+	LastError   error
+	State       int
+}
+
 type RoutesStore struct {
 	routesMap map[sources.Source]api.RoutesResponse
-	ttlMap    map[string]time.Time
+	statusMap map[sources.Source]StoreStatus
 }
 
 func NewRoutesStore(config *Config) *RoutesStore {
 
 	// Build mapping based on source instances
 	routesMap := make(map[sources.Source]api.RoutesResponse)
+	statusMap := make(map[sources.Source]StoreStatus)
 	for _, source := range config.Sources {
-		routesMap[source.getInstance()] = api.RoutesResponse{}
+		instance := source.getInstance()
+		routesMap[instance] = api.RoutesResponse{}
+		statusMap[instance] = StoreStatus{
+			State: STATE_INIT,
+		}
 	}
 
 	store := &RoutesStore{
 		routesMap: routesMap,
-		ttlMap:    make(map[string]time.Time),
+		statusMap: statusMap,
 	}
 	return store
 }
 
 func (self *RoutesStore) Start() {
 	log.Println("Starting local routes store")
-}
-
-func (self *RoutesStore) init() {
 
+	// Initial refresh
+	go self.update()
 }
 
 // Update all routes
 func (self *RoutesStore) update() {
 	for source, _ := range self.routesMap {
+		// Get current update state
+		if self.statusMap[source].State == STATE_UPDATING {
+			continue // nothing to do here
+		}
+
+		// Set update state
+		self.statusMap[source] = StoreStatus{
+			State: STATE_UPDATING,
+		}
+
 		routes, err := source.AllRoutes()
 		if err != nil {
+			self.statusMap[source] = StoreStatus{
+				State:       STATE_ERROR,
+				LastError:   err,
+				LastRefresh: time.Now(),
+			}
+
 			log.Println("Error while updating routes cache:", err)
 			continue
 		}
+
+		// Update data
 		self.routesMap[source] = routes
+		// Update state
+		self.statusMap[source] = StoreStatus{
+			LastRefresh: time.Now(),
+			State:       STATE_READY,
+		}
 	}
+
+	log.Println("All caches refreshed")
 }
 
 func (self *RoutesStore) Lookup(prefix string) []api.LookupRoute {