peers.go 16 KB

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