From 8be0409b6adbd8d41212c9c6de4f241c706db038 Mon Sep 17 00:00:00 2001 From: Farukh Khan Date: Fri, 25 Aug 2023 16:53:01 +0800 Subject: [PATCH] NET-555 (#2524) * IoT peer updates remove flag is now only triggering on relay deletion. Not triggering on extclients deletion anymore. * Small typo fix on publish dns update for new extclient function name. --- controllers/ext_client.go | 2 +- mq/publishers.go | 8 +++++--- 2 files changed, 6 insertions(+), 4 deletions(-) diff --git a/controllers/ext_client.go b/controllers/ext_client.go index 35d6358a..1e2f29f2 100644 --- a/controllers/ext_client.go +++ b/controllers/ext_client.go @@ -398,7 +398,7 @@ func createExtClient(w http.ResponseWriter, r *http.Request) { if err := mq.PublishPeerUpdate(); err != nil { logger.Log(1, "error setting ext peers on "+nodeid+": "+err.Error()) } - if err := mq.PublishExtCLientDNS(&extclient); err != nil { + if err := mq.PublishExtClientDNS(&extclient); err != nil { logger.Log(1, "error publishing extclient dns", err.Error()) } }() diff --git a/mq/publishers.go b/mq/publishers.go index ac195aa3..a470b99e 100644 --- a/mq/publishers.go +++ b/mq/publishers.go @@ -79,8 +79,10 @@ func PublishDeletedClientPeerUpdate(delClient *models.ExtClient) error { } for _, host := range hosts { host := host - if err = PublishSingleHostPeerUpdate(&host, nodes, nil, []models.ExtClient{*delClient}); err != nil { - logger.Log(1, "failed to publish peer update to host", host.ID.String(), ": ", err.Error()) + if host.OS != models.OS_Types.IoT { + if err = PublishSingleHostPeerUpdate(&host, nodes, nil, []models.ExtClient{*delClient}); err != nil { + logger.Log(1, "failed to publish peer update to host", host.ID.String(), ": ", err.Error()) + } } } return err @@ -258,7 +260,7 @@ func PublishReplaceDNS(oldNode, newNode *models.Node, host *models.Host) error { } // PublishExtClientDNS publish dns update for new extclient -func PublishExtCLientDNS(client *models.ExtClient) error { +func PublishExtClientDNS(client *models.ExtClient) error { errMsgs := models.DNSError{} dns := models.DNSUpdate{ Action: models.DNSInsert,