|
@@ -21,11 +21,11 @@ import (
|
|
func Run() {
|
|
func Run() {
|
|
updateEnrollmentKeys()
|
|
updateEnrollmentKeys()
|
|
assignSuperAdmin()
|
|
assignSuperAdmin()
|
|
|
|
+ removeOldUserGrps()
|
|
syncUsers()
|
|
syncUsers()
|
|
updateHosts()
|
|
updateHosts()
|
|
updateNodes()
|
|
updateNodes()
|
|
updateAcls()
|
|
updateAcls()
|
|
-
|
|
|
|
}
|
|
}
|
|
|
|
|
|
func assignSuperAdmin() {
|
|
func assignSuperAdmin() {
|
|
@@ -124,6 +124,24 @@ func updateEnrollmentKeys() {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+func removeOldUserGrps() {
|
|
|
|
+ rows, err := database.FetchRecords(database.USER_GROUPS_TABLE_NAME)
|
|
|
|
+ if err != nil {
|
|
|
|
+ return
|
|
|
|
+ }
|
|
|
|
+ for key, row := range rows {
|
|
|
|
+ userG := models.UserGroup{}
|
|
|
|
+ err = json.Unmarshal([]byte(row), &userG)
|
|
|
|
+ if err == nil {
|
|
|
|
+ if userG.ID == "" {
|
|
|
|
+ database.DeleteRecord(database.USER_GROUPS_TABLE_NAME, key)
|
|
|
|
+ }
|
|
|
|
+ } else {
|
|
|
|
+ database.DeleteRecord(database.USER_GROUPS_TABLE_NAME, key)
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+}
|
|
|
|
+
|
|
func updateHosts() {
|
|
func updateHosts() {
|
|
rows, err := database.FetchRecords(database.HOSTS_TABLE_NAME)
|
|
rows, err := database.FetchRecords(database.HOSTS_TABLE_NAME)
|
|
if err != nil {
|
|
if err != nil {
|