Add basic application framework and example application to show interaction between events an NBI

Depends on:

• !340 (merged)
• !344 (merged)
• !349 (merged)
• !342 (merged)

controller/topology/nodes/nodeStore.go

@@ -41,7 +41,7 @@ func (s *DatabaseNodeStore) Get(query store.Query) (Node, error) {
 	if query.ID.String() != "" {
 		loadedNode, err := s.getByID(query.ID)
 		if err != nil {
-			return loadedNode, errors.ErrCouldNotFind{StoreName: s.storeName}
+			return loadedNode, errors.ErrCouldNotFind{ID: query.ID, Name: query.Name}
 		}
 
 		return loadedNode, nil
@@ -49,13 +49,13 @@ func (s *DatabaseNodeStore) Get(query store.Query) (Node, error) {
 
 	loadedNode, err := s.getByName(query.Name)
 	if err != nil {
-		return loadedNode, errors.ErrCouldNotFind{StoreName: s.storeName}
+		return loadedNode, errors.ErrCouldNotFind{ID: query.ID, Name: query.Name}
 	}
 
 	return loadedNode, nil
 }
 
-func (s *DatabaseNodeStore) getByID(idOfLink uuid.UUID) (Node, error) {
+func (s *DatabaseNodeStore) getByID(idOfNode uuid.UUID) (Node, error) {
 	var loadedNode Node
 
 	client, ctx, cancel := database.GetMongoConnection()
@@ -64,21 +64,21 @@ func (s *DatabaseNodeStore) getByID(idOfLink uuid.UUID) (Node, error) {
 
 	db := client.Database(database.DatabaseName)
 	collection := db.Collection(s.storeName)
-	result := collection.FindOne(ctx, bson.D{primitive.E{Key: "_id", Value: idOfLink.String()}})
+	result := collection.FindOne(ctx, bson.D{primitive.E{Key: "_id", Value: idOfNode.String()}})
 	if result == nil {
-		return loadedNode, errors.ErrCouldNotFind{StoreName: s.storeName}
+		return loadedNode, errors.ErrCouldNotFind{ID: idOfNode}
 	}
 
 	err := result.Decode(&loadedNode)
 	if err != nil {
 		log.Printf("Failed marshalling %v", err)
-		return loadedNode, errors.ErrCouldNotFind{StoreName: s.storeName}
+		return loadedNode, errors.ErrCouldNotFind{ID: idOfNode}
 	}
 
 	return loadedNode, nil
 }
 
-func (s *DatabaseNodeStore) getByName(nameOfDevice string) (Node, error) {
+func (s *DatabaseNodeStore) getByName(nameOfNode string) (Node, error) {
 	var loadedNode Node
 
 	client, ctx, cancel := database.GetMongoConnection()
@@ -87,15 +87,15 @@ func (s *DatabaseNodeStore) getByName(nameOfDevice string) (Node, error) {
 
 	db := client.Database(database.DatabaseName)
 	collection := db.Collection(s.storeName)
-	result := collection.FindOne(ctx, bson.D{primitive.E{Key: "name", Value: nameOfDevice}})
+	result := collection.FindOne(ctx, bson.D{primitive.E{Key: "name", Value: nameOfNode}})
 	if result == nil {
-		return loadedNode, errors.ErrCouldNotFind{StoreName: s.storeName}
+		return loadedNode, errors.ErrCouldNotFind{Name: nameOfNode}
 	}
 
 	err := result.Decode(&loadedNode)
 	if err != nil {
 		log.Printf("Failed marshalling %v", err)
-		return loadedNode, errors.ErrCouldNotFind{StoreName: s.storeName}
+		return loadedNode, errors.ErrCouldNotFind{Name: nameOfNode}
 	}
 
 	return loadedNode, nil