Function SyncUsers

api/users.go:47–92

(c *gin.Context)

}

func SyncUsers(c *gin.Context) {
	client := http.Client{}
	req, err := http.NewRequest("GET", fmt.Sprintf("%s/sync_users", config.IamURL), nil)
	if err != nil {
		panic(err)
	}
	req.Header.Add("App-ID", config.AppID)
	req.Header.Add("Api-Key", config.AppKey)
	resp, err := client.Do(req)
	if err != nil {
		panic(err)
	}
	buf, err := ioutil.ReadAll(resp.Body)
	if err != nil {
		panic(err)
	}
	s := struct {
		Code    int    `json:"code"`
		Message []User `json:"message"`
	}{}
	if err := json.Unmarshal(buf, &s); err != nil {
		c.AbortWithError(http.StatusInternalServerError, err)
		return
	}
	_, users := mydb.getAllUsers(false, "", "", 0, 0)
	userMap := map[string]struct{}{}
	for _, user := range s.Message {
		userMap[user.Username] = struct{}{}
		if user.Username == "" {
			continue
		}
		user.Type = IAMUser
		user, _ := mydb.createUser(&user)
		log.Println("create user:", user)
	}
	for _, user := range users {
		if _, ok := userMap[user.Username]; ok {
			continue
		}
		if user.Type == IAMUser {
			mydb.deleteUser(user.ID)
			log.Printf("delete iam user %v", user)
		}
	}
	c.JSON(http.StatusOK, gin.H{"users": s})
}

func listAllUsers(c *gin.Context) {
	response := gin.H{"code": http.StatusOK}