From d4cd24e778a751537c365b41a81755544ecdf2af Mon Sep 17 00:00:00 2001 From: Matthew R Kasun Date: Wed, 8 Feb 2023 11:32:28 -0500 Subject: [PATCH] extclient update --- controllers/ext_client.go | 5 +---- mq/publishers.go | 13 +++++++++++++ 2 files changed, 14 insertions(+), 4 deletions(-) diff --git a/controllers/ext_client.go b/controllers/ext_client.go index 83eb79db..b3c17790 100644 --- a/controllers/ext_client.go +++ b/controllers/ext_client.go @@ -497,10 +497,7 @@ func updateExtClient(w http.ResponseWriter, r *http.Request) { json.NewEncoder(w).Encode(newclient) if changedID { go func() { - if err := mq.PublishDeleteExtClientDNS(&oldExtClient); err != nil { - logger.Log(1, "error pubishing dns update for extcient update", err.Error()) - } - if err := mq.PublishExtCLientDNS(&newExtClient); err != nil { + if err := mq.PublishExtClientDNSUpdate(oldExtClient, newExtClient, networkName); err != nil { logger.Log(1, "error pubishing dns update for extcient update", err.Error()) } }() diff --git a/mq/publishers.go b/mq/publishers.go index 45785ab4..096f3ee0 100644 --- a/mq/publishers.go +++ b/mq/publishers.go @@ -312,6 +312,19 @@ func PublishExtCLientDNS(client *models.ExtClient) error { return nil } +// PublishExtClientUpdate publishes dns update for extclient name change +func PublishExtClientDNSUpdate(old, new models.ExtClient, network string) error { + dns := models.DNSUpdate{ + Action: models.DNSReplaceName, + Name: old.ClientID, + NewName: new.ClientID, + } + if err := PublishDNSUpdate(network, dns); err != nil { + return err + } + return nil +} + // PublishDeleteExtClient publish dns update to delete extclient entry func PublishDeleteExtClientDNS(client *models.ExtClient) error { dns := models.DNSUpdate{