Merge branch 'develop' of ssh://github.com/alice-lg/alice-lg into develop

cmd/alice-lg/main.go

@@ -120,7 +120,7 @@ func main() {
 	log.Println("Using configuration:", cfg.File)
 
 	// Start stores
-	if cfg.Server.EnablePrefixLookup == true {
+	if cfg.Server.EnablePrefixLookup {
 		go neighborsStore.Start()
 		go routesStore.Start()
 	}

pkg/http/api_endpoints_neighbors.go

@@ -30,6 +30,9 @@ func (s *Server) apiNeighborsList(
 	// from the summary.
 	if s.neighborsStore.IsInitialized(rsID) {
 		status, err := s.neighborsStore.GetStatus(rsID)
+		if err != nil {
+			return nil, err
+		}
 		neighbors, err := s.neighborsStore.GetNeighborsAt(ctx, rsID)
 		if err != nil {
 			return nil, err

pkg/sources/birdwatcher/parsers_test.go

@@ -97,7 +97,7 @@ func Test_RoutesParsing(t *testing.T) {
 	config := Config{Timezone: "UTC"} // Or ""
 	bird, _ := parseTestResponse(APIResponseRoutes)
 
-	routes, err := parseRoutes(bird, config)
+	routes, err := parseRoutes(bird, config, true)
 	if err != nil {
 		t.Error(err)
 	}

pkg/store/backends/postgres/package.go

@@ -0,0 +1,6 @@
+// Package postgres is an implementation of a routes and neighbors
+// store using the postgres database.
+//
+// Routes and neighbors are stored as jsonb information
+// with indexes for query performance.
+package postgres

pkg/store/neighbors_store_test.go

@@ -113,6 +113,7 @@ func TestGetNeighbors(t *testing.T) {
 	if err == nil {
 		t.Error("Unknown source should have yielded zero results")
 	}
+  t.Log(neighbors)
 
 }
 

pkg/store/package.go

@@ -0,0 +1,8 @@
+// Package store provides an interface for keeping
+// routes and neighbor information without querying
+// a route server. The refresh happens in a configurable
+// interval.
+//
+// There a currently two implementations: A postgres and
+// and in-memory backend.
+package store

pkg/store/sources_store.go

@@ -318,5 +318,4 @@ func (s *SourcesStore) RefreshError(
 	status.LastRefresh = time.Now().UTC()
 	status.LastRefreshDuration = time.Since(status.lastRefreshStart)
 	status.LastError = sourceErr
-	return
 }