Browse Source

send host update on delete

Abhishek Kondur 2 years ago
parent
commit
2e9e2fdf0a
1 changed files with 6 additions and 1 deletions
  1. 6 1
      controllers/hosts.go

+ 6 - 1
controllers/hosts.go

@@ -152,7 +152,12 @@ func deleteHost(w http.ResponseWriter, r *http.Request) {
 		logic.ReturnErrorResponse(w, r, logic.FormatError(err, "internal"))
 		logic.ReturnErrorResponse(w, r, logic.FormatError(err, "internal"))
 		return
 		return
 	}
 	}
-	// TODO: publish host update with delete action using MQ
+	if err = mq.HostUpdate(&models.HostUpdate{
+		Action: models.DeleteHost,
+		Host:   *currHost,
+	}); err != nil {
+		logger.Log(0, r.Header.Get("user"), "failed to send delete host update: ", currHost.ID.String(), err.Error())
+	}
 
 
 	if err = mq.DeleteMqClient(currHost.ID.String()); err != nil {
 	if err = mq.DeleteMqClient(currHost.ID.String()); err != nil {
 		logger.Log(0, "error removing DynSec credentials for host:", currHost.Name, err.Error())
 		logger.Log(0, "error removing DynSec credentials for host:", currHost.Name, err.Error())