Browse Source

add logic to grpc leave handler to publish peer update message

Matthew R Kasun 3 years ago
parent
commit
09b9e658b9
1 changed files with 4 additions and 0 deletions
  1. 4 0
      controllers/node_grpc.go

+ 4 - 0
controllers/node_grpc.go

@@ -153,6 +153,10 @@ func (s *NodeServiceServer) DeleteNode(ctx context.Context, req *nodepb.Object)
 	if err != nil {
 		return nil, err
 	}
+	// notify other nodes on network of deleted peer
+	if err := mq.NewPeer(node); err != nil {
+		logger.Log(0, "failed to inform peers of deleted node "+err.Error())
+	}
 
 	err = runServerPeerUpdate(node.Network, true)
 	if err != nil {