migrate.go 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459
  1. package migrate
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "log"
  6. "time"
  7. "golang.org/x/exp/slog"
  8. "github.com/google/uuid"
  9. "github.com/gravitl/netmaker/database"
  10. "github.com/gravitl/netmaker/logger"
  11. "github.com/gravitl/netmaker/logic"
  12. "github.com/gravitl/netmaker/logic/acls"
  13. "github.com/gravitl/netmaker/models"
  14. "github.com/gravitl/netmaker/mq"
  15. "github.com/gravitl/netmaker/servercfg"
  16. )
  17. // Run - runs all migrations
  18. func Run() {
  19. updateEnrollmentKeys()
  20. assignSuperAdmin()
  21. createDefaultTagsAndPolicies()
  22. removeOldUserGrps()
  23. syncUsers()
  24. updateHosts()
  25. updateNodes()
  26. updateAcls()
  27. migrateToGws()
  28. }
  29. func assignSuperAdmin() {
  30. users, err := logic.GetUsers()
  31. if err != nil || len(users) == 0 {
  32. return
  33. }
  34. if ok, _ := logic.HasSuperAdmin(); ok {
  35. return
  36. }
  37. createdSuperAdmin := false
  38. owner := servercfg.GetOwnerEmail()
  39. if owner != "" {
  40. user, err := logic.GetUser(owner)
  41. if err != nil {
  42. log.Fatal("error getting user", "user", owner, "error", err.Error())
  43. }
  44. user.PlatformRoleID = models.SuperAdminRole
  45. err = logic.UpsertUser(*user)
  46. if err != nil {
  47. log.Fatal(
  48. "error updating user to superadmin",
  49. "user",
  50. user.UserName,
  51. "error",
  52. err.Error(),
  53. )
  54. }
  55. return
  56. }
  57. for _, u := range users {
  58. if u.IsAdmin {
  59. user, err := logic.GetUser(u.UserName)
  60. if err != nil {
  61. slog.Error("error getting user", "user", u.UserName, "error", err.Error())
  62. continue
  63. }
  64. user.PlatformRoleID = models.SuperAdminRole
  65. user.IsSuperAdmin = true
  66. err = logic.UpsertUser(*user)
  67. if err != nil {
  68. slog.Error(
  69. "error updating user to superadmin",
  70. "user",
  71. user.UserName,
  72. "error",
  73. err.Error(),
  74. )
  75. continue
  76. } else {
  77. createdSuperAdmin = true
  78. }
  79. break
  80. }
  81. }
  82. if !createdSuperAdmin {
  83. slog.Error("failed to create superadmin!!")
  84. }
  85. }
  86. func updateEnrollmentKeys() {
  87. rows, err := database.FetchRecords(database.ENROLLMENT_KEYS_TABLE_NAME)
  88. if err != nil {
  89. return
  90. }
  91. for _, row := range rows {
  92. var key models.EnrollmentKey
  93. if err = json.Unmarshal([]byte(row), &key); err != nil {
  94. continue
  95. }
  96. if key.Type != models.Undefined {
  97. logger.Log(2, "migration: enrollment key type already set")
  98. continue
  99. } else {
  100. logger.Log(2, "migration: updating enrollment key type")
  101. if key.Unlimited {
  102. key.Type = models.Unlimited
  103. } else if key.UsesRemaining > 0 {
  104. key.Type = models.Uses
  105. } else if !key.Expiration.IsZero() {
  106. key.Type = models.TimeExpiration
  107. }
  108. }
  109. data, err := json.Marshal(key)
  110. if err != nil {
  111. logger.Log(0, "migration: marshalling enrollment key: "+err.Error())
  112. continue
  113. }
  114. if err = database.Insert(key.Value, string(data), database.ENROLLMENT_KEYS_TABLE_NAME); err != nil {
  115. logger.Log(0, "migration: inserting enrollment key: "+err.Error())
  116. continue
  117. }
  118. }
  119. existingKeys, err := logic.GetAllEnrollmentKeys()
  120. if err != nil {
  121. return
  122. }
  123. // check if any tags are duplicate
  124. existingTags := make(map[string]struct{})
  125. for _, existingKey := range existingKeys {
  126. for _, t := range existingKey.Tags {
  127. existingTags[t] = struct{}{}
  128. }
  129. }
  130. networks, _ := logic.GetNetworks()
  131. for _, network := range networks {
  132. if _, ok := existingTags[network.NetID]; ok {
  133. continue
  134. }
  135. _, _ = logic.CreateEnrollmentKey(
  136. 0,
  137. time.Time{},
  138. []string{network.NetID},
  139. []string{network.NetID},
  140. []models.TagID{},
  141. true,
  142. uuid.Nil,
  143. true,
  144. )
  145. }
  146. }
  147. func removeOldUserGrps() {
  148. rows, err := database.FetchRecords(database.USER_GROUPS_TABLE_NAME)
  149. if err != nil {
  150. return
  151. }
  152. for key, row := range rows {
  153. userG := models.UserGroup{}
  154. _ = json.Unmarshal([]byte(row), &userG)
  155. if userG.ID == "" {
  156. database.DeleteRecord(database.USER_GROUPS_TABLE_NAME, key)
  157. }
  158. }
  159. }
  160. func updateHosts() {
  161. rows, err := database.FetchRecords(database.HOSTS_TABLE_NAME)
  162. if err != nil {
  163. logger.Log(0, "failed to fetch database records for hosts")
  164. }
  165. for _, row := range rows {
  166. var host models.Host
  167. if err := json.Unmarshal([]byte(row), &host); err != nil {
  168. logger.Log(0, "failed to unmarshal database row to host", "row", row)
  169. continue
  170. }
  171. if host.PersistentKeepalive == 0 {
  172. host.PersistentKeepalive = models.DefaultPersistentKeepAlive
  173. if err := logic.UpsertHost(&host); err != nil {
  174. logger.Log(0, "failed to upsert host", host.ID.String())
  175. continue
  176. }
  177. }
  178. }
  179. }
  180. func updateNodes() {
  181. nodes, err := logic.GetAllNodes()
  182. if err != nil {
  183. slog.Error("migration failed for nodes", "error", err)
  184. return
  185. }
  186. for _, node := range nodes {
  187. node := node
  188. if node.Tags == nil {
  189. node.Tags = make(map[models.TagID]struct{})
  190. logic.UpsertNode(&node)
  191. }
  192. if node.IsIngressGateway {
  193. tagID := models.TagID(fmt.Sprintf("%s.%s", node.Network,
  194. models.RemoteAccessTagName))
  195. if node.Tags == nil {
  196. node.Tags = make(map[models.TagID]struct{})
  197. }
  198. if _, ok := node.Tags[tagID]; !ok {
  199. node.Tags[tagID] = struct{}{}
  200. logic.UpsertNode(&node)
  201. }
  202. host, err := logic.GetHost(node.HostID.String())
  203. if err == nil {
  204. go logic.DeleteRole(models.GetRAGRoleID(node.Network, host.ID.String()), true)
  205. }
  206. }
  207. if node.IsEgressGateway {
  208. egressRanges, update := removeInterGw(node.EgressGatewayRanges)
  209. if update {
  210. node.EgressGatewayRequest.Ranges = egressRanges
  211. node.EgressGatewayRanges = egressRanges
  212. logic.UpsertNode(&node)
  213. }
  214. }
  215. }
  216. }
  217. func removeInterGw(egressRanges []string) ([]string, bool) {
  218. update := false
  219. for i := len(egressRanges) - 1; i >= 0; i-- {
  220. if egressRanges[i] == "0.0.0.0/0" || egressRanges[i] == "::/0" {
  221. update = true
  222. egressRanges = append(egressRanges[:i], egressRanges[i+1:]...)
  223. }
  224. }
  225. return egressRanges, update
  226. }
  227. func updateAcls() {
  228. // get all networks
  229. networks, err := logic.GetNetworks()
  230. if err != nil && !database.IsEmptyRecord(err) {
  231. slog.Error("acls migration failed. error getting networks", "error", err)
  232. return
  233. }
  234. // get current acls per network
  235. for _, network := range networks {
  236. var networkAcl acls.ACLContainer
  237. networkAcl, err := networkAcl.Get(acls.ContainerID(network.NetID))
  238. if err != nil {
  239. if database.IsEmptyRecord(err) {
  240. continue
  241. }
  242. slog.Error(fmt.Sprintf("error during acls migration. error getting acls for network: %s", network.NetID), "error", err)
  243. continue
  244. }
  245. // convert old acls to new acls with clients
  246. // TODO: optimise O(n^2) operation
  247. clients, err := logic.GetNetworkExtClients(network.NetID)
  248. if err != nil {
  249. slog.Error(fmt.Sprintf("error during acls migration. error getting clients for network: %s", network.NetID), "error", err)
  250. continue
  251. }
  252. clientsIdMap := make(map[string]struct{})
  253. for _, client := range clients {
  254. clientsIdMap[client.ClientID] = struct{}{}
  255. }
  256. nodeIdsMap := make(map[string]struct{})
  257. for nodeId := range networkAcl {
  258. nodeIdsMap[string(nodeId)] = struct{}{}
  259. }
  260. /*
  261. initially, networkACL has only node acls so we add client acls to it
  262. final shape:
  263. {
  264. "node1": {
  265. "node2": 2,
  266. "client1": 2,
  267. "client2": 1,
  268. },
  269. "node2": {
  270. "node1": 2,
  271. "client1": 2,
  272. "client2": 1,
  273. },
  274. "client1": {
  275. "node1": 2,
  276. "node2": 2,
  277. "client2": 1,
  278. },
  279. "client2": {
  280. "node1": 1,
  281. "node2": 1,
  282. "client1": 1,
  283. },
  284. }
  285. */
  286. for _, client := range clients {
  287. networkAcl[acls.AclID(client.ClientID)] = acls.ACL{}
  288. // add client values to node acls and create client acls with node values
  289. for id, nodeAcl := range networkAcl {
  290. // skip if not a node
  291. if _, ok := nodeIdsMap[string(id)]; !ok {
  292. continue
  293. }
  294. if nodeAcl == nil {
  295. slog.Warn("acls migration bad data: nil node acl", "node", id, "network", network.NetID)
  296. continue
  297. }
  298. nodeAcl[acls.AclID(client.ClientID)] = acls.Allowed
  299. networkAcl[acls.AclID(client.ClientID)][id] = acls.Allowed
  300. if client.DeniedACLs == nil {
  301. continue
  302. } else if _, ok := client.DeniedACLs[string(id)]; ok {
  303. nodeAcl[acls.AclID(client.ClientID)] = acls.NotAllowed
  304. networkAcl[acls.AclID(client.ClientID)][id] = acls.NotAllowed
  305. }
  306. }
  307. // add clients to client acls response
  308. for _, c := range clients {
  309. if c.ClientID == client.ClientID {
  310. continue
  311. }
  312. networkAcl[acls.AclID(client.ClientID)][acls.AclID(c.ClientID)] = acls.Allowed
  313. if client.DeniedACLs == nil {
  314. continue
  315. } else if _, ok := client.DeniedACLs[c.ClientID]; ok {
  316. networkAcl[acls.AclID(client.ClientID)][acls.AclID(c.ClientID)] = acls.NotAllowed
  317. }
  318. }
  319. // delete oneself from its own acl
  320. delete(networkAcl[acls.AclID(client.ClientID)], acls.AclID(client.ClientID))
  321. }
  322. // remove non-existent client and node acls
  323. for objId := range networkAcl {
  324. if _, ok := nodeIdsMap[string(objId)]; ok {
  325. continue
  326. }
  327. if _, ok := clientsIdMap[string(objId)]; ok {
  328. continue
  329. }
  330. // remove all occurances of objId from all acls
  331. for objId2 := range networkAcl {
  332. delete(networkAcl[objId2], objId)
  333. }
  334. delete(networkAcl, objId)
  335. }
  336. // save new acls
  337. slog.Debug(fmt.Sprintf("(migration) saving new acls for network: %s", network.NetID), "networkAcl", networkAcl)
  338. if _, err := networkAcl.Save(acls.ContainerID(network.NetID)); err != nil {
  339. slog.Error(fmt.Sprintf("error during acls migration. error saving new acls for network: %s", network.NetID), "error", err)
  340. continue
  341. }
  342. slog.Info(fmt.Sprintf("(migration) successfully saved new acls for network: %s", network.NetID))
  343. }
  344. }
  345. func MigrateEmqx() {
  346. err := mq.SendPullSYN()
  347. if err != nil {
  348. logger.Log(0, "failed to send pull syn to clients", "error", err.Error())
  349. }
  350. time.Sleep(time.Second * 3)
  351. slog.Info("proceeding to kicking out clients from emqx")
  352. err = mq.KickOutClients()
  353. if err != nil {
  354. logger.Log(2, "failed to migrate emqx: ", "kickout-error", err.Error())
  355. }
  356. }
  357. func syncUsers() {
  358. // create default network user roles for existing networks
  359. if servercfg.IsPro {
  360. networks, _ := logic.GetNetworks()
  361. for _, netI := range networks {
  362. logic.CreateDefaultNetworkRolesAndGroups(models.NetworkID(netI.NetID))
  363. }
  364. }
  365. users, err := logic.GetUsersDB()
  366. if err == nil {
  367. for _, user := range users {
  368. user := user
  369. if user.PlatformRoleID == models.AdminRole && !user.IsAdmin {
  370. user.IsAdmin = true
  371. logic.UpsertUser(user)
  372. }
  373. if user.PlatformRoleID == models.SuperAdminRole && !user.IsSuperAdmin {
  374. user.IsSuperAdmin = true
  375. logic.UpsertUser(user)
  376. }
  377. if user.PlatformRoleID.String() != "" {
  378. logic.MigrateUserRoleAndGroups(user)
  379. logic.AddGlobalNetRolesToAdmins(user)
  380. continue
  381. }
  382. user.AuthType = models.BasicAuth
  383. if logic.IsOauthUser(&user) == nil {
  384. user.AuthType = models.OAuth
  385. }
  386. if len(user.NetworkRoles) == 0 {
  387. user.NetworkRoles = make(map[models.NetworkID]map[models.UserRoleID]struct{})
  388. }
  389. if len(user.UserGroups) == 0 {
  390. user.UserGroups = make(map[models.UserGroupID]struct{})
  391. }
  392. if user.IsSuperAdmin {
  393. user.PlatformRoleID = models.SuperAdminRole
  394. } else if user.IsAdmin {
  395. user.PlatformRoleID = models.AdminRole
  396. } else {
  397. user.PlatformRoleID = models.ServiceUser
  398. }
  399. logic.UpsertUser(user)
  400. logic.AddGlobalNetRolesToAdmins(user)
  401. logic.MigrateUserRoleAndGroups(user)
  402. }
  403. }
  404. }
  405. func createDefaultTagsAndPolicies() {
  406. networks, err := logic.GetNetworks()
  407. if err != nil {
  408. return
  409. }
  410. for _, network := range networks {
  411. logic.CreateDefaultTags(models.NetworkID(network.NetID))
  412. logic.CreateDefaultAclNetworkPolicies(models.NetworkID(network.NetID))
  413. }
  414. logic.MigrateAclPolicies()
  415. }
  416. func migrateToGws() {
  417. nodes, err := logic.GetAllNodes()
  418. if err != nil {
  419. return
  420. }
  421. for _, node := range nodes {
  422. if node.IsIngressGateway || node.IsRelay {
  423. node.IsGw = true
  424. node.IsIngressGateway = true
  425. node.IsRelay = true
  426. logic.UpsertNode(&node)
  427. }
  428. }
  429. }