node.go 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668
  1. package models
  2. import (
  3. "bytes"
  4. "math/rand"
  5. "net"
  6. "strings"
  7. "sync"
  8. "time"
  9. "github.com/google/uuid"
  10. "golang.zx2c4.com/wireguard/wgctrl/wgtypes"
  11. )
  12. type NodeStatus string
  13. const (
  14. OnlineSt NodeStatus = "online"
  15. OfflineSt NodeStatus = "offline"
  16. WarningSt NodeStatus = "warning"
  17. ErrorSt NodeStatus = "error"
  18. UnKnown NodeStatus = "unknown"
  19. Disconnected NodeStatus = "disconnected"
  20. )
  21. // LastCheckInThreshold - if node's checkin more than this threshold,then node is declared as offline
  22. const LastCheckInThreshold = time.Minute * 10
  23. const (
  24. // NODE_SERVER_NAME - the default server name
  25. NODE_SERVER_NAME = "netmaker"
  26. // MAX_NAME_LENGTH - max name length of node
  27. MAX_NAME_LENGTH = 62
  28. // == ACTIONS == (can only be set by server)
  29. // NODE_DELETE - delete node action
  30. NODE_DELETE = "delete"
  31. // NODE_IS_PENDING - node pending status
  32. NODE_IS_PENDING = "pending"
  33. // NODE_NOOP - node no op action
  34. NODE_NOOP = "noop"
  35. // NODE_FORCE_UPDATE - indicates a node should pull all changes
  36. NODE_FORCE_UPDATE = "force"
  37. // FIREWALL_IPTABLES - indicates that iptables is the firewall in use
  38. FIREWALL_IPTABLES = "iptables"
  39. // FIREWALL_NFTABLES - indicates nftables is in use (Linux only)
  40. FIREWALL_NFTABLES = "nftables"
  41. // FIREWALL_NONE - indicates that no supported firewall in use
  42. FIREWALL_NONE = "none"
  43. )
  44. var seededRand *rand.Rand = rand.New(
  45. rand.NewSource(time.Now().UnixNano()))
  46. // NodeCheckin - struct for node checkins with server
  47. type NodeCheckin struct {
  48. Version string
  49. Connected bool
  50. Ifaces []Iface
  51. }
  52. // Iface struct for local interfaces of a node
  53. type Iface struct {
  54. Name string `json:"name"`
  55. Address net.IPNet `json:"address"`
  56. AddressString string `json:"addressString"`
  57. }
  58. // CommonNode - represents a commonn node data elements shared by netmaker and netclient
  59. type CommonNode struct {
  60. ID uuid.UUID `json:"id" yaml:"id"`
  61. HostID uuid.UUID `json:"hostid" yaml:"hostid"`
  62. Network string `json:"network" yaml:"network"`
  63. NetworkRange net.IPNet `json:"networkrange" yaml:"networkrange" swaggertype:"primitive,integer"`
  64. NetworkRange6 net.IPNet `json:"networkrange6" yaml:"networkrange6" swaggertype:"primitive,number"`
  65. Server string `json:"server" yaml:"server"`
  66. Connected bool `json:"connected" yaml:"connected"`
  67. Address net.IPNet `json:"address" yaml:"address"`
  68. Address6 net.IPNet `json:"address6" yaml:"address6"`
  69. Action string `json:"action" yaml:"action"`
  70. LocalAddress net.IPNet `json:"localaddress" yaml:"localaddress"`
  71. IsEgressGateway bool `json:"isegressgateway" yaml:"isegressgateway"`
  72. EgressGatewayRanges []string `json:"egressgatewayranges" yaml:"egressgatewayranges"`
  73. IsIngressGateway bool `json:"isingressgateway" yaml:"isingressgateway"`
  74. IsRelayed bool `json:"isrelayed" yaml:"isrelayed"`
  75. RelayedBy string `json:"relayedby" yaml:"relayedby"`
  76. IsRelay bool `json:"isrelay" yaml:"isrelay"`
  77. IsGw bool `json:"is_gw" yaml:"is_gw"`
  78. RelayedNodes []string `json:"relaynodes" yaml:"relayedNodes"`
  79. IngressDNS string `json:"ingressdns" yaml:"ingressdns"`
  80. AutoAssignGateway bool `json:"auto_assign_gw"`
  81. }
  82. // Node - a model of a network node
  83. type Node struct {
  84. CommonNode
  85. PendingDelete bool `json:"pendingdelete"`
  86. LastModified time.Time `json:"lastmodified"`
  87. LastCheckIn time.Time `json:"lastcheckin"`
  88. LastPeerUpdate time.Time `json:"lastpeerupdate"`
  89. ExpirationDateTime time.Time `json:"expdatetime"`
  90. EgressGatewayNatEnabled bool `json:"egressgatewaynatenabled"`
  91. EgressGatewayRequest EgressGatewayRequest `json:"egressgatewayrequest"`
  92. IngressGatewayRange string `json:"ingressgatewayrange"`
  93. IngressGatewayRange6 string `json:"ingressgatewayrange6"`
  94. IngressPersistentKeepalive int32 `json:"ingresspersistentkeepalive"`
  95. IngressMTU int32 `json:"ingressmtu"`
  96. Metadata string `json:"metadata"`
  97. // == PRO ==
  98. DefaultACL string `json:"defaultacl,omitempty" validate:"checkyesornoorunset"`
  99. OwnerID string `json:"ownerid,omitempty"`
  100. IsFailOver bool `json:"is_fail_over"`
  101. IsAutoRelay bool `json:"is_auto_relay"`
  102. AutoRelayedPeers map[string]struct{} `json:"auto_relayed_peers"`
  103. AutoRelayedBy uuid.UUID `json:"auto_relayed_by"`
  104. FailOverPeers map[string]struct{} `json:"fail_over_peers"`
  105. FailedOverBy uuid.UUID `json:"failed_over_by"`
  106. IsInternetGateway bool `json:"isinternetgateway"`
  107. InetNodeReq InetNodeReq `json:"inet_node_req"`
  108. InternetGwID string `json:"internetgw_node_id"`
  109. AdditionalRagIps []net.IP `json:"additional_rag_ips" swaggertype:"array,number"`
  110. Tags map[TagID]struct{} `json:"tags"`
  111. IsStatic bool `json:"is_static"`
  112. IsUserNode bool `json:"is_user_node"`
  113. StaticNode ExtClient `json:"static_node"`
  114. Status NodeStatus `json:"node_status"`
  115. Mutex *sync.Mutex `json:"-"`
  116. EgressDetails EgressDetails `json:"-"`
  117. }
  118. type EgressDetails struct {
  119. EgressGatewayNatEnabled bool
  120. EgressGatewayRequest EgressGatewayRequest
  121. IsEgressGateway bool
  122. EgressGatewayRanges []string
  123. // IsInternetGateway bool `json:"isinternetgateway" yaml:"isinternetgateway"`
  124. // InetNodeReq InetNodeReq `json:"inet_node_req" yaml:"inet_node_req"`
  125. // InternetGwID string `json:"internetgw_node_id" yaml:"internetgw_node_id"`
  126. }
  127. // LegacyNode - legacy struct for node model
  128. type LegacyNode struct {
  129. ID string `json:"id,omitempty" bson:"id,omitempty" yaml:"id,omitempty" validate:"required,min=5,id_unique"`
  130. Address string `json:"address" bson:"address" yaml:"address" validate:"omitempty,ipv4"`
  131. Address6 string `json:"address6" bson:"address6" yaml:"address6" validate:"omitempty,ipv6"`
  132. LocalAddress string `json:"localaddress" bson:"localaddress" yaml:"localaddress" validate:"omitempty"`
  133. Interfaces []Iface `json:"interfaces" yaml:"interfaces"`
  134. Name string `json:"name" bson:"name" yaml:"name" validate:"omitempty,max=62,in_charset"`
  135. NetworkSettings Network `json:"networksettings" bson:"networksettings" yaml:"networksettings" validate:"-"`
  136. ListenPort int32 `json:"listenport" bson:"listenport" yaml:"listenport" validate:"omitempty,numeric,min=1024,max=65535"`
  137. LocalListenPort int32 `json:"locallistenport" bson:"locallistenport" yaml:"locallistenport" validate:"numeric,min=0,max=65535"`
  138. PublicKey string `json:"publickey" bson:"publickey" yaml:"publickey" validate:"required,base64"`
  139. Endpoint string `json:"endpoint" bson:"endpoint" yaml:"endpoint" validate:"required,ip"`
  140. AllowedIPs []string `json:"allowedips" bson:"allowedips" yaml:"allowedips"`
  141. PersistentKeepalive int32 `json:"persistentkeepalive" bson:"persistentkeepalive" yaml:"persistentkeepalive" validate:"omitempty,numeric,max=1000"`
  142. IsHub string `json:"ishub" bson:"ishub" yaml:"ishub" validate:"checkyesorno"`
  143. AccessKey string `json:"accesskey" bson:"accesskey" yaml:"accesskey"`
  144. Interface string `json:"interface" bson:"interface" yaml:"interface"`
  145. LastModified int64 `json:"lastmodified" bson:"lastmodified" yaml:"lastmodified" swaggertype:"primitive,integer" format:"int64"`
  146. ExpirationDateTime int64 `json:"expdatetime" bson:"expdatetime" yaml:"expdatetime" swaggertype:"primitive,integer" format:"int64"`
  147. LastPeerUpdate int64 `json:"lastpeerupdate" bson:"lastpeerupdate" yaml:"lastpeerupdate" swaggertype:"primitive,integer" format:"int64"`
  148. LastCheckIn int64 `json:"lastcheckin" bson:"lastcheckin" yaml:"lastcheckin" swaggertype:"primitive,integer" format:"int64"`
  149. MacAddress string `json:"macaddress" bson:"macaddress" yaml:"macaddress"`
  150. Password string `json:"password" bson:"password" yaml:"password" validate:"required,min=6"`
  151. Network string `json:"network" bson:"network" yaml:"network" validate:"network_exists"`
  152. IsRelayed string `json:"isrelayed" bson:"isrelayed" yaml:"isrelayed"`
  153. IsPending string `json:"ispending" bson:"ispending" yaml:"ispending"`
  154. IsRelay string `json:"isrelay" bson:"isrelay" yaml:"isrelay" validate:"checkyesorno"`
  155. IsDocker string `json:"isdocker" bson:"isdocker" yaml:"isdocker" validate:"checkyesorno"`
  156. IsK8S string `json:"isk8s" bson:"isk8s" yaml:"isk8s" validate:"checkyesorno"`
  157. IsEgressGateway string `json:"isegressgateway" bson:"isegressgateway" yaml:"isegressgateway" validate:"checkyesorno"`
  158. IsIngressGateway string `json:"isingressgateway" bson:"isingressgateway" yaml:"isingressgateway" validate:"checkyesorno"`
  159. EgressGatewayRanges []string `json:"egressgatewayranges" bson:"egressgatewayranges" yaml:"egressgatewayranges"`
  160. EgressGatewayNatEnabled string `json:"egressgatewaynatenabled" bson:"egressgatewaynatenabled" yaml:"egressgatewaynatenabled"`
  161. EgressGatewayRequest EgressGatewayRequest `json:"egressgatewayrequest" bson:"egressgatewayrequest" yaml:"egressgatewayrequest"`
  162. RelayAddrs []string `json:"relayaddrs" bson:"relayaddrs" yaml:"relayaddrs"`
  163. FailoverNode string `json:"failovernode" bson:"failovernode" yaml:"failovernode"`
  164. IngressGatewayRange string `json:"ingressgatewayrange" bson:"ingressgatewayrange" yaml:"ingressgatewayrange"`
  165. IngressGatewayRange6 string `json:"ingressgatewayrange6" bson:"ingressgatewayrange6" yaml:"ingressgatewayrange6"`
  166. // IsStatic - refers to if the Endpoint is set manually or dynamically
  167. IsStatic string `json:"isstatic" bson:"isstatic" yaml:"isstatic" validate:"checkyesorno"`
  168. UDPHolePunch string `json:"udpholepunch" bson:"udpholepunch" yaml:"udpholepunch" validate:"checkyesorno"`
  169. DNSOn string `json:"dnson" bson:"dnson" yaml:"dnson" validate:"checkyesorno"`
  170. IsServer string `json:"isserver" bson:"isserver" yaml:"isserver" validate:"checkyesorno"`
  171. Action string `json:"action" bson:"action" yaml:"action"`
  172. IPForwarding string `json:"ipforwarding" bson:"ipforwarding" yaml:"ipforwarding" validate:"checkyesorno"`
  173. OS string `json:"os" bson:"os" yaml:"os"`
  174. MTU int32 `json:"mtu" bson:"mtu" yaml:"mtu"`
  175. Version string `json:"version" bson:"version" yaml:"version"`
  176. Server string `json:"server" bson:"server" yaml:"server"`
  177. TrafficKeys TrafficKeys `json:"traffickeys" bson:"traffickeys" yaml:"traffickeys"`
  178. FirewallInUse string `json:"firewallinuse" bson:"firewallinuse" yaml:"firewallinuse"`
  179. InternetGateway string `json:"internetgateway" bson:"internetgateway" yaml:"internetgateway"`
  180. Connected string `json:"connected" bson:"connected" yaml:"connected" validate:"checkyesorno"`
  181. // == PRO ==
  182. DefaultACL string `json:"defaultacl,omitempty" bson:"defaultacl,omitempty" yaml:"defaultacl,omitempty" validate:"checkyesornoorunset"`
  183. OwnerID string `json:"ownerid,omitempty" bson:"ownerid,omitempty" yaml:"ownerid,omitempty"`
  184. Failover string `json:"failover" bson:"failover" yaml:"failover" validate:"checkyesorno"`
  185. }
  186. // NodesArray - used for node sorting
  187. type NodesArray []Node
  188. // NodesArray.Len - gets length of node array
  189. func (a NodesArray) Len() int { return len(a) }
  190. // NodesArray.Less - gets returns lower rank of two node addressesFill
  191. func (a NodesArray) Less(i, j int) bool {
  192. return isLess(a[i].Address.IP.String(), a[j].Address.IP.String())
  193. }
  194. // NodesArray.Swap - swaps two nodes in array
  195. func (a NodesArray) Swap(i, j int) { a[i], a[j] = a[j], a[i] }
  196. func isLess(ipA string, ipB string) bool {
  197. ipNetA := net.ParseIP(ipA)
  198. ipNetB := net.ParseIP(ipB)
  199. return bytes.Compare(ipNetA, ipNetB) < 0
  200. }
  201. // Node.PrimaryAddress - return ipv4 address if present, else return ipv6
  202. func (node *Node) PrimaryAddressIPNet() net.IPNet {
  203. if node.Address.IP != nil {
  204. return node.Address
  205. }
  206. return node.Address6
  207. }
  208. // Node.PrimaryAddress - return ipv4 address if present, else return ipv6
  209. func (node *Node) PrimaryAddress() string {
  210. if node.Address.IP != nil {
  211. return node.Address.IP.String()
  212. }
  213. return node.Address6.IP.String()
  214. }
  215. func (node *Node) AddressIPNet4() net.IPNet {
  216. return net.IPNet{
  217. IP: node.Address.IP,
  218. Mask: net.CIDRMask(32, 32),
  219. }
  220. }
  221. func (node *Node) AddressIPNet6() net.IPNet {
  222. return net.IPNet{
  223. IP: node.Address6.IP,
  224. Mask: net.CIDRMask(128, 128),
  225. }
  226. }
  227. // ExtClient.PrimaryAddress - returns ipv4 IPNet format
  228. func (extPeer *ExtClient) AddressIPNet4() net.IPNet {
  229. return net.IPNet{
  230. IP: net.ParseIP(extPeer.Address),
  231. Mask: net.CIDRMask(32, 32),
  232. }
  233. }
  234. // ExtClient.AddressIPNet6 - return ipv6 IPNet format
  235. func (extPeer *ExtClient) AddressIPNet6() net.IPNet {
  236. return net.IPNet{
  237. IP: net.ParseIP(extPeer.Address6),
  238. Mask: net.CIDRMask(128, 128),
  239. }
  240. }
  241. // Node.PrimaryNetworkRange - returns node's parent network, returns ipv4 address if present, else return ipv6
  242. func (node *Node) PrimaryNetworkRange() net.IPNet {
  243. if node.NetworkRange.IP != nil {
  244. return node.NetworkRange
  245. }
  246. return node.NetworkRange6
  247. }
  248. // Node.SetDefaultConnected
  249. func (node *Node) SetDefaultConnected() {
  250. node.Connected = true
  251. }
  252. // Node.SetDefaultACL
  253. func (node *LegacyNode) SetDefaultACL() {
  254. if node.DefaultACL == "" {
  255. node.DefaultACL = "yes"
  256. }
  257. }
  258. // Node.SetDefaultMTU - sets default MTU of a node
  259. func (node *LegacyNode) SetDefaultMTU() {
  260. if node.MTU == 0 {
  261. node.MTU = 1280
  262. }
  263. }
  264. // Node.SetDefaultNFTablesPresent - sets default for nftables check
  265. func (node *LegacyNode) SetDefaultNFTablesPresent() {
  266. if node.FirewallInUse == "" {
  267. node.FirewallInUse = FIREWALL_IPTABLES // default to iptables
  268. }
  269. }
  270. // Node.SetDefaultIsRelayed - set default is relayed
  271. func (node *LegacyNode) SetDefaultIsRelayed() {
  272. if node.IsRelayed == "" {
  273. node.IsRelayed = "no"
  274. }
  275. }
  276. // Node.SetDefaultIsRelayed - set default is relayed
  277. func (node *LegacyNode) SetDefaultIsHub() {
  278. if node.IsHub == "" {
  279. node.IsHub = "no"
  280. }
  281. }
  282. // Node.SetDefaultIsRelay - set default isrelay
  283. func (node *LegacyNode) SetDefaultIsRelay() {
  284. if node.IsRelay == "" {
  285. node.IsRelay = "no"
  286. }
  287. }
  288. // Node.SetDefaultIsDocker - set default isdocker
  289. func (node *LegacyNode) SetDefaultIsDocker() {
  290. if node.IsDocker == "" {
  291. node.IsDocker = "no"
  292. }
  293. }
  294. // Node.SetDefaultIsK8S - set default isk8s
  295. func (node *LegacyNode) SetDefaultIsK8S() {
  296. if node.IsK8S == "" {
  297. node.IsK8S = "no"
  298. }
  299. }
  300. // Node.SetDefaultEgressGateway - sets default egress gateway status
  301. func (node *LegacyNode) SetDefaultEgressGateway() {
  302. if node.IsEgressGateway == "" {
  303. node.IsEgressGateway = "no"
  304. }
  305. }
  306. // Node.SetDefaultIngressGateway - sets default ingress gateway status
  307. func (node *LegacyNode) SetDefaultIngressGateway() {
  308. if node.IsIngressGateway == "" {
  309. node.IsIngressGateway = "no"
  310. }
  311. }
  312. // Node.SetDefaultAction - sets default action status
  313. func (node *LegacyNode) SetDefaultAction() {
  314. if node.Action == "" {
  315. node.Action = NODE_NOOP
  316. }
  317. }
  318. // Node.SetRoamingDefault - sets default roaming status
  319. //func (node *Node) SetRoamingDefault() {
  320. // if node.Roaming == "" {
  321. // node.Roaming = "yes"
  322. // }
  323. //}
  324. // Node.SetIPForwardingDefault - set ip forwarding default
  325. func (node *LegacyNode) SetIPForwardingDefault() {
  326. if node.IPForwarding == "" {
  327. node.IPForwarding = "yes"
  328. }
  329. }
  330. // Node.SetDNSOnDefault - sets dns on default
  331. func (node *LegacyNode) SetDNSOnDefault() {
  332. if node.DNSOn == "" {
  333. node.DNSOn = "yes"
  334. }
  335. }
  336. // Node.SetIsServerDefault - sets node isserver default
  337. func (node *LegacyNode) SetIsServerDefault() {
  338. if node.IsServer != "yes" {
  339. node.IsServer = "no"
  340. }
  341. }
  342. // Node.SetIsStaticDefault - set is static default
  343. func (node *LegacyNode) SetIsStaticDefault() {
  344. if node.IsServer == "yes" {
  345. node.IsStatic = "yes"
  346. } else if node.IsStatic != "yes" {
  347. node.IsStatic = "no"
  348. }
  349. }
  350. // Node.SetLastModified - set last modified initial time
  351. func (node *Node) SetLastModified() {
  352. node.LastModified = time.Now().UTC()
  353. }
  354. // Node.SetLastCheckIn - set checkin time of node
  355. func (node *Node) SetLastCheckIn() {
  356. node.LastCheckIn = time.Now().UTC()
  357. }
  358. // Node.SetLastPeerUpdate - sets last peer update time
  359. func (node *Node) SetLastPeerUpdate() {
  360. node.LastPeerUpdate = time.Now().UTC()
  361. }
  362. // Node.SetExpirationDateTime - sets node expiry time
  363. func (node *Node) SetExpirationDateTime() {
  364. if node.ExpirationDateTime.IsZero() {
  365. node.ExpirationDateTime = time.Now().AddDate(100, 1, 0)
  366. }
  367. }
  368. // Node.SetDefaultName - sets a random name to node
  369. func (node *LegacyNode) SetDefaultName() {
  370. if node.Name == "" {
  371. node.Name = GenerateNodeName()
  372. }
  373. }
  374. // Node.SetDefaultFailover - sets default value of failover status to no if not set
  375. func (node *LegacyNode) SetDefaultFailover() {
  376. if node.Failover == "" {
  377. node.Failover = "no"
  378. }
  379. }
  380. // Node.Fill - fills other node data into calling node data if not set on calling node (skips DNSOn)
  381. func (newNode *Node) Fill(
  382. currentNode *Node,
  383. isPro bool,
  384. ) { // TODO add new field for nftables present
  385. newNode.ID = currentNode.ID
  386. newNode.HostID = currentNode.HostID
  387. // Revisit the logic for boolean values
  388. // TODO ---- !!!!!!!!!!!!!!!!!!!!!!!!!!!!
  389. // TODO ---- !!!!!!!!!!!!!!!!!!!!!!!!!!
  390. if newNode.Address.String() == "" {
  391. newNode.Address = currentNode.Address
  392. }
  393. if newNode.Address6.String() == "" {
  394. newNode.Address6 = currentNode.Address6
  395. }
  396. if newNode.LastModified != currentNode.LastModified {
  397. newNode.LastModified = currentNode.LastModified
  398. }
  399. if newNode.ExpirationDateTime.IsZero() {
  400. newNode.ExpirationDateTime = currentNode.ExpirationDateTime
  401. }
  402. if newNode.LastPeerUpdate.IsZero() {
  403. newNode.LastPeerUpdate = currentNode.LastPeerUpdate
  404. }
  405. if newNode.LastCheckIn.IsZero() {
  406. newNode.LastCheckIn = currentNode.LastCheckIn
  407. }
  408. if newNode.Network == "" {
  409. newNode.Network = currentNode.Network
  410. }
  411. if newNode.IsIngressGateway != currentNode.IsIngressGateway {
  412. newNode.IsIngressGateway = currentNode.IsIngressGateway
  413. }
  414. if newNode.IngressGatewayRange == "" {
  415. newNode.IngressGatewayRange = currentNode.IngressGatewayRange
  416. }
  417. if newNode.IngressGatewayRange6 == "" {
  418. newNode.IngressGatewayRange6 = currentNode.IngressGatewayRange6
  419. }
  420. if newNode.Action == "" {
  421. newNode.Action = currentNode.Action
  422. }
  423. if newNode.RelayedNodes == nil {
  424. newNode.RelayedNodes = currentNode.RelayedNodes
  425. }
  426. if newNode.IsRelay != currentNode.IsRelay && isPro {
  427. newNode.IsRelay = currentNode.IsRelay
  428. }
  429. if newNode.IsRelayed == currentNode.IsRelayed && isPro {
  430. newNode.IsRelayed = currentNode.IsRelayed
  431. }
  432. if newNode.Server == "" {
  433. newNode.Server = currentNode.Server
  434. }
  435. if newNode.DefaultACL == "" {
  436. newNode.DefaultACL = currentNode.DefaultACL
  437. }
  438. if newNode.IsFailOver != currentNode.IsFailOver {
  439. newNode.IsFailOver = currentNode.IsFailOver
  440. }
  441. newNode.FailOverPeers = currentNode.FailOverPeers
  442. if newNode.Tags == nil {
  443. if currentNode.Tags == nil {
  444. currentNode.Tags = make(map[TagID]struct{})
  445. }
  446. newNode.Tags = currentNode.Tags
  447. }
  448. }
  449. // StringWithCharset - returns random string inside defined charset
  450. func StringWithCharset(length int, charset string) string {
  451. b := make([]byte, length)
  452. for i := range b {
  453. b[i] = charset[seededRand.Intn(len(charset))]
  454. }
  455. return string(b)
  456. }
  457. // IsIpv4Net - check for valid IPv4 address
  458. // Note: We dont handle IPv6 AT ALL!!!!! This definitely is needed at some point
  459. // But for iteration 1, lets just stick to IPv4. Keep it simple stupid.
  460. func IsIpv4Net(host string) bool {
  461. return net.ParseIP(host) != nil
  462. }
  463. // Node.NameInNodeCharset - returns if name is in charset below or not
  464. func (node *LegacyNode) NameInNodeCharSet() bool {
  465. charset := "abcdefghijklmnopqrstuvwxyz1234567890-"
  466. for _, char := range node.Name {
  467. if !strings.Contains(charset, strings.ToLower(string(char))) {
  468. return false
  469. }
  470. }
  471. return true
  472. }
  473. // == PRO ==
  474. // Node.DoesACLAllow - checks if default ACL on node is "yes"
  475. func (node *Node) DoesACLAllow() bool {
  476. return node.DefaultACL == "yes"
  477. }
  478. // Node.DoesACLDeny - checks if default ACL on node is "no"
  479. func (node *Node) DoesACLDeny() bool {
  480. return node.DefaultACL == "no"
  481. }
  482. func (ln *LegacyNode) ConvertToNewNode() (*Host, *Node) {
  483. var node Node
  484. //host:= logic.GetHost(node.HostID)
  485. var host Host
  486. if host.ID.String() == "" {
  487. host.ID = uuid.New()
  488. host.FirewallInUse = ln.FirewallInUse
  489. host.Version = ln.Version
  490. host.IPForwarding = parseBool(ln.IPForwarding)
  491. host.HostPass = ln.Password
  492. host.Name = ln.Name
  493. host.ListenPort = int(ln.ListenPort)
  494. host.MTU = int(ln.MTU)
  495. host.PublicKey, _ = wgtypes.ParseKey(ln.PublicKey)
  496. host.MacAddress, _ = net.ParseMAC(ln.MacAddress)
  497. host.TrafficKeyPublic = ln.TrafficKeys.Mine
  498. id, _ := uuid.Parse(ln.ID)
  499. host.Nodes = append(host.Nodes, id.String())
  500. host.Interfaces = ln.Interfaces
  501. host.EndpointIP = net.ParseIP(ln.Endpoint)
  502. // host.ProxyEnabled = ln.Proxy // this will always be false..
  503. }
  504. id, _ := uuid.Parse(ln.ID)
  505. node.ID = id
  506. node.Network = ln.Network
  507. if _, cidr, err := net.ParseCIDR(ln.NetworkSettings.AddressRange); err == nil {
  508. node.NetworkRange = *cidr
  509. }
  510. if _, cidr, err := net.ParseCIDR(ln.NetworkSettings.AddressRange6); err == nil {
  511. node.NetworkRange6 = *cidr
  512. }
  513. node.Server = ln.Server
  514. node.Connected = parseBool(ln.Connected)
  515. if ln.Address != "" {
  516. node.Address = net.IPNet{
  517. IP: net.ParseIP(ln.Address),
  518. Mask: net.CIDRMask(32, 32),
  519. }
  520. }
  521. if ln.Address6 != "" {
  522. node.Address = net.IPNet{
  523. IP: net.ParseIP(ln.Address6),
  524. Mask: net.CIDRMask(128, 128),
  525. }
  526. }
  527. node.Action = ln.Action
  528. node.IsIngressGateway = parseBool(ln.IsIngressGateway)
  529. return &host, &node
  530. }
  531. // Node.Legacy converts node to legacy format
  532. func (n *Node) Legacy(h *Host, s *ServerConfig, net *Network) *LegacyNode {
  533. l := LegacyNode{}
  534. l.ID = n.ID.String()
  535. //l.HostID = h.ID.String()
  536. l.Address = n.Address.String()
  537. l.Address6 = n.Address6.String()
  538. l.Interfaces = h.Interfaces
  539. l.Name = h.Name
  540. l.NetworkSettings = *net
  541. l.ListenPort = int32(h.ListenPort)
  542. l.PublicKey = h.PublicKey.String()
  543. l.Endpoint = h.EndpointIP.String()
  544. //l.AllowedIPs =
  545. l.AccessKey = ""
  546. l.Interface = WIREGUARD_INTERFACE
  547. //l.LastModified =
  548. //l.ExpirationDateTime
  549. //l.LastPeerUpdate
  550. //l.LastCheckIn
  551. l.MacAddress = h.MacAddress.String()
  552. l.Password = h.HostPass
  553. l.Network = n.Network
  554. //l.IsRelayed = formatBool(n.Is)
  555. //l.IsRelay = formatBool(n.IsRelay)
  556. //l.IsDocker = formatBool(n.IsDocker)
  557. //l.IsK8S = formatBool(n.IsK8S)
  558. l.IsIngressGateway = formatBool(n.IsIngressGateway)
  559. //l.EgressGatewayRanges = n.EgressGatewayRanges
  560. //l.EgressGatewayNatEnabled = n.EgressGatewayNatEnabled
  561. //l.RelayAddrs = n.RelayAddrs
  562. //l.FailoverNode = n.FailoverNode
  563. //l.IngressGatewayRange = n.IngressGatewayRange
  564. //l.IngressGatewayRange6 = n.IngressGatewayRange6
  565. l.IsStatic = formatBool(h.IsStatic)
  566. l.UDPHolePunch = formatBool(true)
  567. l.Action = n.Action
  568. l.IPForwarding = formatBool(h.IPForwarding)
  569. l.OS = h.OS
  570. l.MTU = int32(h.MTU)
  571. l.Version = h.Version
  572. l.Server = n.Server
  573. l.TrafficKeys.Mine = h.TrafficKeyPublic
  574. l.TrafficKeys.Server = s.TrafficKey
  575. l.FirewallInUse = h.FirewallInUse
  576. l.Connected = formatBool(n.Connected)
  577. //l.PendingDelete = formatBool(n.PendingDelete)
  578. l.DefaultACL = n.DefaultACL
  579. l.OwnerID = n.OwnerID
  580. //l.Failover = n.Failover
  581. return &l
  582. }
  583. // Node.NetworkSettings updates a node with network settings
  584. func (node *Node) NetworkSettings(n Network) {
  585. _, cidr, err := net.ParseCIDR(n.AddressRange)
  586. if err == nil {
  587. node.NetworkRange = *cidr
  588. }
  589. _, cidr, err = net.ParseCIDR(n.AddressRange6)
  590. if err == nil {
  591. node.NetworkRange6 = *cidr
  592. }
  593. }
  594. func parseBool(s string) bool {
  595. b := false
  596. if s == "yes" {
  597. b = true
  598. }
  599. return b
  600. }
  601. func formatBool(b bool) string {
  602. s := "no"
  603. if b {
  604. s = "yes"
  605. }
  606. return s
  607. }