migrate.go 13 KB

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