peers.go 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454
  1. package logic
  2. import (
  3. "errors"
  4. "net"
  5. "net/netip"
  6. "github.com/gravitl/netmaker/database"
  7. "github.com/gravitl/netmaker/logger"
  8. "github.com/gravitl/netmaker/logic/acls/nodeacls"
  9. "github.com/gravitl/netmaker/models"
  10. "github.com/gravitl/netmaker/servercfg"
  11. "golang.org/x/exp/slices"
  12. "golang.org/x/exp/slog"
  13. "golang.zx2c4.com/wireguard/wgctrl/wgtypes"
  14. )
  15. var (
  16. // ResetFailOver - function to reset failOvered peers on this node
  17. ResetFailOver = func(failOverNode *models.Node) error {
  18. return nil
  19. }
  20. // ResetFailedOverPeer - removes failed over node from network peers
  21. ResetFailedOverPeer = func(failedOverNode *models.Node) error {
  22. return nil
  23. }
  24. // GetFailOverPeerIps - gets failover peerips
  25. GetFailOverPeerIps = func(peer, node *models.Node) []net.IPNet {
  26. return []net.IPNet{}
  27. }
  28. CreateFailOver = func(node models.Node) error {
  29. return nil
  30. }
  31. )
  32. // GetPeerUpdateForHost - gets the consolidated peer update for the host from all networks
  33. func GetPeerUpdateForHost(network string, host *models.Host, allNodes []models.Node,
  34. deletedNode *models.Node, deletedClients []models.ExtClient) (models.HostPeerUpdate, error) {
  35. if host == nil {
  36. return models.HostPeerUpdate{}, errors.New("host is nil")
  37. }
  38. // track which nodes are deleted
  39. // after peer calculation, if peer not in list, add delete config of peer
  40. hostPeerUpdate := models.HostPeerUpdate{
  41. Host: *host,
  42. Server: servercfg.GetServer(),
  43. ServerVersion: servercfg.GetVersion(),
  44. ServerAddrs: []models.ServerAddr{},
  45. FwUpdate: models.FwUpdate{
  46. EgressInfo: make(map[string]models.EgressInfo),
  47. },
  48. PeerIDs: make(models.PeerMap, 0),
  49. Peers: []wgtypes.PeerConfig{},
  50. NodePeers: []wgtypes.PeerConfig{},
  51. HostNetworkInfo: models.HostInfoMap{},
  52. }
  53. slog.Debug("peer update for host", "hostId", host.ID.String())
  54. peerIndexMap := make(map[string]int)
  55. for _, nodeID := range host.Nodes {
  56. nodeID := nodeID
  57. node, err := GetNodeByID(nodeID)
  58. if err != nil {
  59. continue
  60. }
  61. if !node.Connected || node.PendingDelete || node.Action == models.NODE_DELETE {
  62. continue
  63. }
  64. if host.OS == models.OS_Types.IoT {
  65. hostPeerUpdate.NodeAddrs = append(hostPeerUpdate.NodeAddrs, node.PrimaryAddressIPNet())
  66. if node.IsRelayed {
  67. relayNode, err := GetNodeByID(node.RelayedBy)
  68. if err != nil {
  69. continue
  70. }
  71. relayHost, err := GetHost(relayNode.HostID.String())
  72. if err != nil {
  73. continue
  74. }
  75. relayPeer := wgtypes.PeerConfig{
  76. PublicKey: relayHost.PublicKey,
  77. PersistentKeepaliveInterval: &relayHost.PersistentKeepalive,
  78. ReplaceAllowedIPs: true,
  79. AllowedIPs: GetAllowedIPs(&node, &relayNode, nil),
  80. }
  81. uselocal := false
  82. if host.EndpointIP.String() == relayHost.EndpointIP.String() {
  83. // peer is on same network
  84. // set to localaddress
  85. uselocal = true
  86. if node.LocalAddress.IP == nil {
  87. // use public endpint
  88. uselocal = false
  89. }
  90. if node.LocalAddress.String() == relayNode.LocalAddress.String() {
  91. uselocal = false
  92. }
  93. }
  94. relayPeer.Endpoint = &net.UDPAddr{
  95. IP: relayHost.EndpointIP,
  96. Port: GetPeerListenPort(relayHost),
  97. }
  98. if uselocal {
  99. relayPeer.Endpoint.IP = relayNode.LocalAddress.IP
  100. relayPeer.Endpoint.Port = relayHost.ListenPort
  101. }
  102. hostPeerUpdate.Peers = append(hostPeerUpdate.Peers, relayPeer)
  103. } else if deletedNode != nil && deletedNode.IsRelay {
  104. relayHost, err := GetHost(deletedNode.HostID.String())
  105. if err != nil {
  106. continue
  107. }
  108. relayPeer := wgtypes.PeerConfig{
  109. PublicKey: relayHost.PublicKey,
  110. Remove: true,
  111. }
  112. hostPeerUpdate.Peers = append(hostPeerUpdate.Peers, relayPeer)
  113. }
  114. continue
  115. }
  116. currentPeers := GetNetworkNodesMemory(allNodes, node.Network)
  117. for _, peer := range currentPeers {
  118. peer := peer
  119. if peer.ID.String() == node.ID.String() {
  120. logger.Log(2, "peer update, skipping self")
  121. // skip yourself
  122. continue
  123. }
  124. peerHost, err := GetHost(peer.HostID.String())
  125. if err != nil {
  126. logger.Log(1, "no peer host", peer.HostID.String(), err.Error())
  127. continue
  128. }
  129. peerConfig := wgtypes.PeerConfig{
  130. PublicKey: peerHost.PublicKey,
  131. PersistentKeepaliveInterval: &peerHost.PersistentKeepalive,
  132. ReplaceAllowedIPs: true,
  133. }
  134. if peer.IsEgressGateway {
  135. hostPeerUpdate.EgressRoutes = append(hostPeerUpdate.EgressRoutes, models.EgressNetworkRoutes{
  136. NodeAddr: node.PrimaryAddressIPNet(),
  137. EgressRanges: peer.EgressGatewayRanges,
  138. })
  139. }
  140. if peer.IsIngressGateway {
  141. hostPeerUpdate.EgressRoutes = append(hostPeerUpdate.EgressRoutes, getExtpeersExtraRoutes(peer.Network)...)
  142. }
  143. _, isFailOverPeer := node.FailOverPeers[peer.ID.String()]
  144. if servercfg.IsPro {
  145. if (node.IsRelayed && node.RelayedBy != peer.ID.String()) ||
  146. (peer.IsRelayed && peer.RelayedBy != node.ID.String()) || isFailOverPeer {
  147. // if node is relayed and peer is not the relay, set remove to true
  148. if _, ok := peerIndexMap[peerHost.PublicKey.String()]; ok {
  149. continue
  150. }
  151. peerConfig.Remove = true
  152. hostPeerUpdate.Peers = append(hostPeerUpdate.Peers, peerConfig)
  153. peerIndexMap[peerHost.PublicKey.String()] = len(hostPeerUpdate.Peers) - 1
  154. continue
  155. }
  156. }
  157. uselocal := false
  158. if host.EndpointIP.String() == peerHost.EndpointIP.String() {
  159. // peer is on same network
  160. // set to localaddress
  161. uselocal = true
  162. if node.LocalAddress.IP == nil {
  163. // use public endpint
  164. uselocal = false
  165. }
  166. if node.LocalAddress.String() == peer.LocalAddress.String() {
  167. uselocal = false
  168. }
  169. }
  170. peerConfig.Endpoint = &net.UDPAddr{
  171. IP: peerHost.EndpointIP,
  172. Port: GetPeerListenPort(peerHost),
  173. }
  174. if uselocal {
  175. peerConfig.Endpoint.IP = peer.LocalAddress.IP
  176. peerConfig.Endpoint.Port = peerHost.ListenPort
  177. }
  178. allowedips := GetAllowedIPs(&node, &peer, nil)
  179. if peer.Action != models.NODE_DELETE &&
  180. !peer.PendingDelete &&
  181. peer.Connected &&
  182. nodeacls.AreNodesAllowed(nodeacls.NetworkID(node.Network), nodeacls.NodeID(node.ID.String()), nodeacls.NodeID(peer.ID.String())) &&
  183. (deletedNode == nil || (deletedNode != nil && peer.ID.String() != deletedNode.ID.String())) {
  184. peerConfig.AllowedIPs = allowedips // only append allowed IPs if valid connection
  185. }
  186. var nodePeer wgtypes.PeerConfig
  187. if _, ok := peerIndexMap[peerHost.PublicKey.String()]; !ok {
  188. hostPeerUpdate.Peers = append(hostPeerUpdate.Peers, peerConfig)
  189. peerIndexMap[peerHost.PublicKey.String()] = len(hostPeerUpdate.Peers) - 1
  190. hostPeerUpdate.HostNetworkInfo[peerHost.PublicKey.String()] = models.HostNetworkInfo{
  191. Interfaces: peerHost.Interfaces,
  192. ListenPort: peerHost.ListenPort,
  193. IsStatic: peerHost.IsStatic,
  194. }
  195. nodePeer = peerConfig
  196. } else {
  197. peerAllowedIPs := hostPeerUpdate.Peers[peerIndexMap[peerHost.PublicKey.String()]].AllowedIPs
  198. peerAllowedIPs = append(peerAllowedIPs, peerConfig.AllowedIPs...)
  199. hostPeerUpdate.Peers[peerIndexMap[peerHost.PublicKey.String()]].AllowedIPs = peerAllowedIPs
  200. hostPeerUpdate.Peers[peerIndexMap[peerHost.PublicKey.String()]].Remove = false
  201. hostPeerUpdate.HostNetworkInfo[peerHost.PublicKey.String()] = models.HostNetworkInfo{
  202. Interfaces: peerHost.Interfaces,
  203. ListenPort: peerHost.ListenPort,
  204. IsStatic: peerHost.IsStatic,
  205. }
  206. nodePeer = hostPeerUpdate.Peers[peerIndexMap[peerHost.PublicKey.String()]]
  207. }
  208. if node.Network == network && !peerConfig.Remove && len(peerConfig.AllowedIPs) > 0 { // add to peers map for metrics
  209. hostPeerUpdate.PeerIDs[peerHost.PublicKey.String()] = models.IDandAddr{
  210. ID: peer.ID.String(),
  211. HostID: peerHost.ID.String(),
  212. Address: peer.PrimaryAddress(),
  213. Name: peerHost.Name,
  214. Network: peer.Network,
  215. ListenPort: peerHost.ListenPort,
  216. }
  217. hostPeerUpdate.NodePeers = append(hostPeerUpdate.NodePeers, nodePeer)
  218. }
  219. }
  220. var extPeers []wgtypes.PeerConfig
  221. var extPeerIDAndAddrs []models.IDandAddr
  222. var egressRoutes []models.EgressNetworkRoutes
  223. if node.IsIngressGateway {
  224. extPeers, extPeerIDAndAddrs, egressRoutes, err = getExtPeers(&node, &node)
  225. if err == nil {
  226. hostPeerUpdate.EgressRoutes = append(hostPeerUpdate.EgressRoutes, egressRoutes...)
  227. hostPeerUpdate.Peers = append(hostPeerUpdate.Peers, extPeers...)
  228. for _, extPeerIdAndAddr := range extPeerIDAndAddrs {
  229. extPeerIdAndAddr := extPeerIdAndAddr
  230. if node.Network == network {
  231. hostPeerUpdate.PeerIDs[extPeerIdAndAddr.ID] = extPeerIdAndAddr
  232. hostPeerUpdate.NodePeers = append(hostPeerUpdate.NodePeers, extPeers...)
  233. }
  234. }
  235. } else if !database.IsEmptyRecord(err) {
  236. logger.Log(1, "error retrieving external clients:", err.Error())
  237. }
  238. }
  239. addedInetGwRanges := false
  240. if node.IsEgressGateway && node.EgressGatewayRequest.NatEnabled == "yes" && len(node.EgressGatewayRequest.Ranges) > 0 {
  241. hostPeerUpdate.FwUpdate.IsEgressGw = true
  242. if IsInternetGw(node) {
  243. hostPeerUpdate.FwUpdate.IsEgressGw = true
  244. egressrange := []string{"0.0.0.0/0"}
  245. if node.Address6.IP != nil {
  246. egressrange = append(egressrange, "::/0")
  247. }
  248. node.EgressGatewayRequest.Ranges = append(node.EgressGatewayRequest.Ranges, egressrange...)
  249. addedInetGwRanges = true
  250. }
  251. hostPeerUpdate.FwUpdate.EgressInfo[node.ID.String()] = models.EgressInfo{
  252. EgressID: node.ID.String(),
  253. Network: node.PrimaryNetworkRange(),
  254. EgressGwAddr: net.IPNet{
  255. IP: net.ParseIP(node.PrimaryAddress()),
  256. Mask: getCIDRMaskFromAddr(node.PrimaryAddress()),
  257. },
  258. EgressGWCfg: node.EgressGatewayRequest,
  259. }
  260. }
  261. if IsInternetGw(node) && !addedInetGwRanges {
  262. hostPeerUpdate.FwUpdate.IsEgressGw = true
  263. egressrange := []string{"0.0.0.0/0"}
  264. if node.Address6.IP != nil {
  265. egressrange = append(egressrange, "::/0")
  266. }
  267. hostPeerUpdate.FwUpdate.EgressInfo[node.ID.String()] = models.EgressInfo{
  268. EgressID: node.ID.String(),
  269. Network: node.PrimaryAddressIPNet(),
  270. EgressGwAddr: net.IPNet{
  271. IP: net.ParseIP(node.PrimaryAddress()),
  272. Mask: getCIDRMaskFromAddr(node.PrimaryAddress()),
  273. },
  274. EgressGWCfg: models.EgressGatewayRequest{
  275. NodeID: node.ID.String(),
  276. NetID: node.Network,
  277. NatEnabled: "yes",
  278. Ranges: egressrange,
  279. },
  280. }
  281. }
  282. }
  283. // == post peer calculations ==
  284. // indicate removal if no allowed IPs were calculated
  285. for i := range hostPeerUpdate.Peers {
  286. peer := hostPeerUpdate.Peers[i]
  287. if len(peer.AllowedIPs) == 0 {
  288. peer.Remove = true
  289. }
  290. hostPeerUpdate.Peers[i] = peer
  291. }
  292. if deletedNode != nil && host.OS != models.OS_Types.IoT {
  293. peerHost, err := GetHost(deletedNode.HostID.String())
  294. if err == nil && host.ID != peerHost.ID {
  295. if _, ok := peerIndexMap[peerHost.PublicKey.String()]; !ok {
  296. hostPeerUpdate.Peers = append(hostPeerUpdate.Peers, wgtypes.PeerConfig{
  297. PublicKey: peerHost.PublicKey,
  298. Remove: true,
  299. })
  300. }
  301. }
  302. }
  303. for i := range hostPeerUpdate.NodePeers {
  304. peer := hostPeerUpdate.NodePeers[i]
  305. if len(peer.AllowedIPs) == 0 {
  306. peer.Remove = true
  307. }
  308. hostPeerUpdate.NodePeers[i] = peer
  309. }
  310. if len(deletedClients) > 0 {
  311. for i := range deletedClients {
  312. deletedClient := deletedClients[i]
  313. key, err := wgtypes.ParseKey(deletedClient.PublicKey)
  314. if err == nil {
  315. hostPeerUpdate.Peers = append(hostPeerUpdate.Peers, wgtypes.PeerConfig{
  316. PublicKey: key,
  317. Remove: true,
  318. })
  319. }
  320. }
  321. }
  322. return hostPeerUpdate, nil
  323. }
  324. // GetPeerListenPort - given a host, retrieve it's appropriate listening port
  325. func GetPeerListenPort(host *models.Host) int {
  326. peerPort := host.ListenPort
  327. if host.WgPublicListenPort != 0 {
  328. peerPort = host.WgPublicListenPort
  329. }
  330. return peerPort
  331. }
  332. // GetAllowedIPs - calculates the wireguard allowedip field for a peer of a node based on the peer and node settings
  333. func GetAllowedIPs(node, peer *models.Node, metrics *models.Metrics) []net.IPNet {
  334. var allowedips []net.IPNet
  335. allowedips = getNodeAllowedIPs(peer, node)
  336. // handle ingress gateway peers
  337. if peer.IsIngressGateway {
  338. extPeers, _, _, err := getExtPeers(peer, node)
  339. if err != nil {
  340. logger.Log(2, "could not retrieve ext peers for ", peer.ID.String(), err.Error())
  341. }
  342. for _, extPeer := range extPeers {
  343. allowedips = append(allowedips, extPeer.AllowedIPs...)
  344. }
  345. }
  346. if node.IsRelayed && node.RelayedBy == peer.ID.String() {
  347. allowedips = append(allowedips, GetAllowedIpsForRelayed(node, peer)...)
  348. }
  349. return allowedips
  350. }
  351. func GetEgressIPs(peer *models.Node) []net.IPNet {
  352. peerHost, err := GetHost(peer.HostID.String())
  353. if err != nil {
  354. logger.Log(0, "error retrieving host for peer", peer.ID.String(), err.Error())
  355. }
  356. // check for internet gateway
  357. internetGateway := false
  358. if slices.Contains(peer.EgressGatewayRanges, "0.0.0.0/0") || slices.Contains(peer.EgressGatewayRanges, "::/0") {
  359. internetGateway = true
  360. }
  361. allowedips := []net.IPNet{}
  362. for _, iprange := range peer.EgressGatewayRanges { // go through each cidr for egress gateway
  363. _, ipnet, err := net.ParseCIDR(iprange) // confirming it's valid cidr
  364. if err != nil {
  365. logger.Log(1, "could not parse gateway IP range. Not adding ", iprange)
  366. continue // if can't parse CIDR
  367. }
  368. // getting the public ip of node
  369. if ipnet.Contains(peerHost.EndpointIP) && !internetGateway { // ensuring egress gateway range does not contain endpoint of node
  370. logger.Log(2, "egress IP range of ", iprange, " overlaps with ", peerHost.EndpointIP.String(), ", omitting")
  371. continue // skip adding egress range if overlaps with node's ip
  372. }
  373. // TODO: Could put in a lot of great logic to avoid conflicts / bad routes
  374. if ipnet.Contains(peer.LocalAddress.IP) && !internetGateway { // ensuring egress gateway range does not contain public ip of node
  375. logger.Log(2, "egress IP range of ", iprange, " overlaps with ", peer.LocalAddress.String(), ", omitting")
  376. continue // skip adding egress range if overlaps with node's local ip
  377. }
  378. if err != nil {
  379. logger.Log(1, "error encountered when setting egress range", err.Error())
  380. } else {
  381. allowedips = append(allowedips, *ipnet)
  382. }
  383. }
  384. return allowedips
  385. }
  386. func getNodeAllowedIPs(peer, node *models.Node) []net.IPNet {
  387. var allowedips = []net.IPNet{}
  388. if peer.Address.IP != nil {
  389. allowed := net.IPNet{
  390. IP: peer.Address.IP,
  391. Mask: net.CIDRMask(32, 32),
  392. }
  393. allowedips = append(allowedips, allowed)
  394. }
  395. if peer.Address6.IP != nil {
  396. allowed := net.IPNet{
  397. IP: peer.Address6.IP,
  398. Mask: net.CIDRMask(128, 128),
  399. }
  400. allowedips = append(allowedips, allowed)
  401. }
  402. // handle egress gateway peers
  403. if peer.IsEgressGateway {
  404. // hasGateway = true
  405. egressIPs := GetEgressIPs(peer)
  406. allowedips = append(allowedips, egressIPs...)
  407. }
  408. if peer.IsRelay {
  409. allowedips = append(allowedips, RelayedAllowedIPs(peer, node)...)
  410. }
  411. if peer.IsFailOver {
  412. allowedips = append(allowedips, GetFailOverPeerIps(peer, node)...)
  413. }
  414. return allowedips
  415. }
  416. func getCIDRMaskFromAddr(addr string) net.IPMask {
  417. cidr := net.CIDRMask(32, 32)
  418. ipAddr, err := netip.ParseAddr(addr)
  419. if err != nil {
  420. return cidr
  421. }
  422. if ipAddr.Is6() {
  423. cidr = net.CIDRMask(128, 128)
  424. }
  425. return cidr
  426. }