migrate.go 12 KB

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