graph: handle metadata update error in memory backend

Need to handle such error other update event can be
generated for deleted graph elements.

Author: safchain

graffiti/graph/elasticsearch.go

@@ -43,7 +43,7 @@ const graphElementMapping = `
 				"path_match": "*",
 				"path_unmatch": "*.Extra.*",
 				"match_mapping_type": "string",
-                                "mapping": {
+				"mapping": {
 					"type": "keyword"
 				}
 			}

graffiti/graph/memory.go

@@ -44,6 +44,18 @@ type MemoryBackend struct {
 
 // MetadataUpdated return true
 func (m *MemoryBackend) MetadataUpdated(i interface{}) error {
+	switch i := i.(type) {
+	case *Node:
+		if _, ok := m.nodes[i.ID]; !ok {
+
+			return ErrNodeNotFound
+		}
+	case *Edge:
+		if _, ok := m.edges[i.ID]; !ok {
+			return ErrEdgeNotFound
+		}
+	}
+
 	return nil
 }
 

graffiti/hub/pod_endpoint.go

@@ -76,14 +76,14 @@ func (t *TopologyAgentEndpoint) OnStructMessage(c ws.Speaker, msg *ws.StructMess
 		for _, n := range r.Nodes {
 			if t.Graph.GetNode(n.ID) == nil {
 				if err := t.Graph.NodeAdded(n); err != nil {
-					logging.GetLogger().Error(err)
+					logging.GetLogger().Errorf("%s, %+v", err, n)
 				}
 			}
 		}
 		for _, e := range r.Edges {
 			if t.Graph.GetEdge(e.ID) == nil {
 				if err := t.Graph.EdgeAdded(e); err != nil {
-					logging.GetLogger().Error(err)
+					logging.GetLogger().Errorf("%s, %+v", err, e)
 				}
 			}
 		}
@@ -102,7 +102,7 @@ func (t *TopologyAgentEndpoint) OnStructMessage(c ws.Speaker, msg *ws.StructMess
 	}
 
 	if err != nil {
-		logging.GetLogger().Error(err)
+		logging.GetLogger().Errorf("%s, %+v", err, obj)
 	}
 }