|
|
@@ -166,73 +166,6 @@ func ServerStartNotify() error {
|
|
|
return nil
|
|
|
}
|
|
|
|
|
|
-// PublishDNSUpdatev1 - published dns updates to all nodes passed
|
|
|
-func PublishDNSUpdatev1(network string, dns models.DNSUpdate, nodes []models.Node) error {
|
|
|
- for _, node := range nodes {
|
|
|
- host, err := logic.GetHost(node.HostID.String())
|
|
|
- if err != nil {
|
|
|
- logger.Log(0, "error retrieving host for dns update", node.HostID.String(), err.Error())
|
|
|
- continue
|
|
|
- }
|
|
|
- data, err := json.Marshal(dns)
|
|
|
- if err != nil {
|
|
|
- logger.Log(0, "failed to encode dns data for node", node.ID.String(), err.Error())
|
|
|
- }
|
|
|
- if err := publish(host, "dns/update/"+host.ID.String()+"/"+servercfg.GetServer(), data); err != nil {
|
|
|
- logger.Log(0, "error publishing dns update to host", host.ID.String(), err.Error())
|
|
|
- continue
|
|
|
- }
|
|
|
- logger.Log(3, "published dns update to host", host.ID.String())
|
|
|
- }
|
|
|
- return nil
|
|
|
-}
|
|
|
-
|
|
|
-// PublishDNSUpdate publishes a dns update to all nodes on a network
|
|
|
-func PublishDNSUpdate(network string, dns models.DNSUpdate) error {
|
|
|
- nodes, err := logic.GetNetworkNodes(network)
|
|
|
- if err != nil {
|
|
|
- return err
|
|
|
- }
|
|
|
- for _, node := range nodes {
|
|
|
- host, err := logic.GetHost(node.HostID.String())
|
|
|
- if err != nil {
|
|
|
- logger.Log(0, "error retrieving host for dns update", node.HostID.String(), err.Error())
|
|
|
- continue
|
|
|
- }
|
|
|
- data, err := json.Marshal(dns)
|
|
|
- if err != nil {
|
|
|
- logger.Log(0, "failed to encode dns data for node", node.ID.String(), err.Error())
|
|
|
- }
|
|
|
- if err := publish(host, "dns/update/"+host.ID.String()+"/"+servercfg.GetServer(), data); err != nil {
|
|
|
- logger.Log(0, "error publishing dns update to host", host.ID.String(), err.Error())
|
|
|
- continue
|
|
|
- }
|
|
|
- logger.Log(3, "published dns update to host", host.ID.String())
|
|
|
- }
|
|
|
- return nil
|
|
|
-}
|
|
|
-
|
|
|
-// PublishAllDNS publishes an array of dns updates (ip / host.network) for each peer to a node joining a network
|
|
|
-func PublishAllDNS(newnode *models.Node) error {
|
|
|
- alldns := []models.DNSUpdate{}
|
|
|
- newnodeHost, err := logic.GetHost(newnode.HostID.String())
|
|
|
- if err != nil {
|
|
|
- return fmt.Errorf("error retrieving host for dns update %w", err)
|
|
|
- }
|
|
|
- alldns = append(alldns, getNodeDNS(newnode.Network)...)
|
|
|
- alldns = append(alldns, getExtClientDNS(newnode.Network)...)
|
|
|
- alldns = append(alldns, getCustomDNS(newnode.Network)...)
|
|
|
- data, err := json.Marshal(alldns)
|
|
|
- if err != nil {
|
|
|
- return fmt.Errorf("error encoding dns data %w", err)
|
|
|
- }
|
|
|
- if err := publish(newnodeHost, "dns/all/"+newnodeHost.ID.String()+"/"+servercfg.GetServer(), data); err != nil {
|
|
|
- return fmt.Errorf("error publishing full dns update to %s, %w", newnodeHost.ID.String(), err)
|
|
|
- }
|
|
|
- logger.Log(3, "published full dns update to %s", newnodeHost.ID.String())
|
|
|
- return nil
|
|
|
-}
|
|
|
-
|
|
|
// PublishMqUpdatesForDeletedNode - published all the required updates for deleted node
|
|
|
func PublishMqUpdatesForDeletedNode(node models.Node, sendNodeUpdate bool, gwClients []models.ExtClient) {
|
|
|
// notify of peer change
|
|
|
@@ -246,162 +179,10 @@ func PublishMqUpdatesForDeletedNode(node models.Node, sendNodeUpdate bool, gwCli
|
|
|
if err := PublishDeletedNodePeerUpdate(&node); err != nil {
|
|
|
logger.Log(1, "error publishing peer update ", err.Error())
|
|
|
}
|
|
|
- host, err := logic.GetHost(node.HostID.String())
|
|
|
- if err != nil {
|
|
|
- logger.Log(1, "failed to retrieve host for node", node.ID.String(), err.Error())
|
|
|
+ if servercfg.IsDNSMode() {
|
|
|
+ logic.SetDNS()
|
|
|
}
|
|
|
- if err := PublishDNSDelete(&node, host); err != nil {
|
|
|
- logger.Log(1, "error publishing dns update", err.Error())
|
|
|
- }
|
|
|
- if err := PublishDeleteAllExtclientsDNS(node.Network, gwClients); err != nil {
|
|
|
- logger.Log(1, "error publishing ext dns update", err.Error())
|
|
|
- }
|
|
|
-
|
|
|
-}
|
|
|
|
|
|
-// PublishDNSDelete publish a dns update deleting a node to all hosts on a network
|
|
|
-func PublishDNSDelete(node *models.Node, host *models.Host) error {
|
|
|
- dns := models.DNSUpdate{
|
|
|
- Action: models.DNSDeleteByIP,
|
|
|
- Name: host.Name + "." + node.Network,
|
|
|
- }
|
|
|
- if node.Address.IP != nil {
|
|
|
- dns.Address = node.Address.IP.String()
|
|
|
- if err := PublishDNSUpdate(node.Network, dns); err != nil {
|
|
|
- return fmt.Errorf("dns update node deletion %w", err)
|
|
|
- }
|
|
|
- }
|
|
|
- if node.Address6.IP != nil {
|
|
|
- dns.Address = node.Address6.IP.String()
|
|
|
- if err := PublishDNSUpdate(node.Network, dns); err != nil {
|
|
|
- return fmt.Errorf("dns update node deletion %w", err)
|
|
|
- }
|
|
|
- }
|
|
|
- return nil
|
|
|
-}
|
|
|
-
|
|
|
-// PublishReplaceDNS publish a dns update to replace a dns entry on all hosts in network
|
|
|
-func PublishReplaceDNS(oldNode, newNode *models.Node, host *models.Host) error {
|
|
|
- dns := models.DNSUpdate{
|
|
|
- Action: models.DNSReplaceIP,
|
|
|
- Name: host.Name + "." + oldNode.Network,
|
|
|
- }
|
|
|
- if !oldNode.Address.IP.Equal(newNode.Address.IP) {
|
|
|
- dns.Address = oldNode.Address.IP.String()
|
|
|
- dns.NewAddress = newNode.Address.IP.String()
|
|
|
- if err := PublishDNSUpdate(oldNode.Network, dns); err != nil {
|
|
|
- return err
|
|
|
- }
|
|
|
- }
|
|
|
- if !oldNode.Address6.IP.Equal(newNode.Address6.IP) {
|
|
|
- dns.Address = oldNode.Address6.IP.String()
|
|
|
- dns.NewAddress = newNode.Address6.IP.String()
|
|
|
- if err := PublishDNSUpdate(oldNode.Network, dns); err != nil {
|
|
|
- return err
|
|
|
- }
|
|
|
- }
|
|
|
- return nil
|
|
|
-}
|
|
|
-
|
|
|
-// PublishExtClientDNS publish dns update for new extclient
|
|
|
-func PublishExtClientDNS(client *models.ExtClient) error {
|
|
|
- errMsgs := models.DNSError{}
|
|
|
- dns := models.DNSUpdate{
|
|
|
- Action: models.DNSInsert,
|
|
|
- Name: client.ClientID + "." + client.Network,
|
|
|
- Address: client.Address,
|
|
|
- }
|
|
|
- if client.Address != "" {
|
|
|
- dns.Address = client.Address
|
|
|
- if err := PublishDNSUpdate(client.Network, dns); err != nil {
|
|
|
- errMsgs.ErrorStrings = append(errMsgs.ErrorStrings, err.Error())
|
|
|
- }
|
|
|
-
|
|
|
- }
|
|
|
- if client.Address6 != "" {
|
|
|
- dns.Address = client.Address6
|
|
|
- if err := PublishDNSUpdate(client.Network, dns); err != nil {
|
|
|
- errMsgs.ErrorStrings = append(errMsgs.ErrorStrings, err.Error())
|
|
|
- }
|
|
|
- }
|
|
|
- if len(errMsgs.ErrorStrings) > 0 {
|
|
|
- return errMsgs
|
|
|
- }
|
|
|
- return nil
|
|
|
-}
|
|
|
-
|
|
|
-// PublishExtClientDNSUpdate update for extclient name change
|
|
|
-func PublishExtClientDNSUpdate(old, new models.ExtClient, network string) error {
|
|
|
- dns := models.DNSUpdate{
|
|
|
- Action: models.DNSReplaceName,
|
|
|
- Name: old.ClientID + "." + network,
|
|
|
- NewName: new.ClientID + "." + network,
|
|
|
- }
|
|
|
- if err := PublishDNSUpdate(network, dns); err != nil {
|
|
|
- return err
|
|
|
- }
|
|
|
- return nil
|
|
|
-}
|
|
|
-
|
|
|
-// PublishDeleteAllExtclientsDNS - publish to delete all passed ext clients dns entries
|
|
|
-func PublishDeleteAllExtclientsDNS(network string, clients []models.ExtClient) error {
|
|
|
- nodes, err := logic.GetNetworkNodes(network)
|
|
|
- if err != nil {
|
|
|
- return err
|
|
|
- }
|
|
|
- for _, client := range clients {
|
|
|
- dns := models.DNSUpdate{
|
|
|
- Action: models.DNSDeleteByName,
|
|
|
- Name: client.ClientID + "." + client.Network,
|
|
|
- }
|
|
|
- go PublishDNSUpdatev1(client.Network, dns, nodes)
|
|
|
- }
|
|
|
- return nil
|
|
|
-}
|
|
|
-
|
|
|
-// PublishDeleteExtClientDNS publish dns update to delete extclient entry
|
|
|
-func PublishDeleteExtClientDNS(client *models.ExtClient) error {
|
|
|
- dns := models.DNSUpdate{
|
|
|
- Action: models.DNSDeleteByName,
|
|
|
- Name: client.ClientID + "." + client.Network,
|
|
|
- }
|
|
|
- if err := PublishDNSUpdate(client.Network, dns); err != nil {
|
|
|
- return err
|
|
|
- }
|
|
|
- return nil
|
|
|
-}
|
|
|
-
|
|
|
-// PublishCustomDNS publish dns update for new custom dns entry
|
|
|
-func PublishCustomDNS(entry *models.DNSEntry) error {
|
|
|
- dns := models.DNSUpdate{
|
|
|
- Action: models.DNSInsert,
|
|
|
- Name: entry.Name,
|
|
|
- //entry.Address6 is never used
|
|
|
- Address: entry.Address,
|
|
|
- }
|
|
|
- if err := PublishDNSUpdate(entry.Network, dns); err != nil {
|
|
|
- return err
|
|
|
- }
|
|
|
- return nil
|
|
|
-}
|
|
|
-
|
|
|
-// PublishHostDNSUpdate publishes dns update on host name change
|
|
|
-func PublishHostDNSUpdate(old, new *models.Host, networks []string) error {
|
|
|
- errMsgs := models.DNSError{}
|
|
|
- for _, network := range networks {
|
|
|
- dns := models.DNSUpdate{
|
|
|
- Action: models.DNSReplaceName,
|
|
|
- Name: old.Name + "." + network,
|
|
|
- NewName: new.Name + "." + network,
|
|
|
- }
|
|
|
- if err := PublishDNSUpdate(network, dns); err != nil {
|
|
|
- errMsgs.ErrorStrings = append(errMsgs.ErrorStrings, err.Error())
|
|
|
- }
|
|
|
- }
|
|
|
- if len(errMsgs.ErrorStrings) > 0 {
|
|
|
- return errMsgs
|
|
|
- }
|
|
|
- return nil
|
|
|
}
|
|
|
|
|
|
func PushMetricsToExporter(metrics models.Metrics) error {
|
|
|
@@ -422,71 +203,6 @@ func PushMetricsToExporter(metrics models.Metrics) error {
|
|
|
return nil
|
|
|
}
|
|
|
|
|
|
-func getNodeDNS(network string) []models.DNSUpdate {
|
|
|
- alldns := []models.DNSUpdate{}
|
|
|
- dns := models.DNSUpdate{}
|
|
|
- nodes, err := logic.GetNetworkNodes(network)
|
|
|
- if err != nil {
|
|
|
- logger.Log(0, "error retreiving network nodes for network", network, err.Error())
|
|
|
- }
|
|
|
- for _, node := range nodes {
|
|
|
- host, err := logic.GetHost(node.HostID.String())
|
|
|
- if err != nil {
|
|
|
- logger.Log(0, "error retrieving host for dns update", node.HostID.String(), err.Error())
|
|
|
- continue
|
|
|
- }
|
|
|
- dns.Action = models.DNSInsert
|
|
|
- dns.Name = host.Name + "." + node.Network
|
|
|
- if node.Address.IP != nil {
|
|
|
- dns.Address = node.Address.IP.String()
|
|
|
- alldns = append(alldns, dns)
|
|
|
- }
|
|
|
- if node.Address6.IP != nil {
|
|
|
- dns.Address = node.Address6.IP.String()
|
|
|
- alldns = append(alldns, dns)
|
|
|
- }
|
|
|
- }
|
|
|
- return alldns
|
|
|
-}
|
|
|
-
|
|
|
-func getExtClientDNS(network string) []models.DNSUpdate {
|
|
|
- alldns := []models.DNSUpdate{}
|
|
|
- dns := models.DNSUpdate{}
|
|
|
- clients, err := logic.GetNetworkExtClients(network)
|
|
|
- if err != nil {
|
|
|
- logger.Log(0, "error retrieving extclients", err.Error())
|
|
|
- }
|
|
|
- for _, client := range clients {
|
|
|
- dns.Action = models.DNSInsert
|
|
|
- dns.Name = client.ClientID + "." + client.Network
|
|
|
- if client.Address != "" {
|
|
|
- dns.Address = client.Address
|
|
|
- alldns = append(alldns, dns)
|
|
|
- }
|
|
|
- if client.Address6 != "" {
|
|
|
- dns.Address = client.Address
|
|
|
- alldns = append(alldns, dns)
|
|
|
- }
|
|
|
- }
|
|
|
- return alldns
|
|
|
-}
|
|
|
-
|
|
|
-func getCustomDNS(network string) []models.DNSUpdate {
|
|
|
- alldns := []models.DNSUpdate{}
|
|
|
- dns := models.DNSUpdate{}
|
|
|
- customdns, err := logic.GetCustomDNS(network)
|
|
|
- if err != nil {
|
|
|
- logger.Log(0, "error retrieving custom dns entries", err.Error())
|
|
|
- }
|
|
|
- for _, custom := range customdns {
|
|
|
- dns.Action = models.DNSInsert
|
|
|
- dns.Address = custom.Address
|
|
|
- dns.Name = custom.Name + "." + custom.Network
|
|
|
- alldns = append(alldns, dns)
|
|
|
- }
|
|
|
- return alldns
|
|
|
-}
|
|
|
-
|
|
|
// sendPeers - retrieve networks, send peer ports to all peers
|
|
|
func sendPeers() {
|
|
|
|
abhishek9686