Method GetUsers

pkg/github/org/org.go:192–249

GetUsers returns the users for a given org. Upon first call, it lazily updates the Organization with the user information

(ctx context.Context)

// GetUsers returns the users for a given org. Upon first call,
// it lazily updates the Organization with the user information
func (org *Organization) GetUsers(ctx context.Context) (
	map[types.UserLogin]types.User, error) {

	if len(org.Users) > 0 {
		return org.Users, nil
	}

	log.Logger.Debugf("Fetching users for %s", *org.info.Login)
	opt := &github.ListMembersOptions{
		ListOptions: github.ListOptions{PerPage: org.paginationSize},
	}
	users, err := utils.GetPaginatedResult(
		ctx,
		org.backoff,
		&opt.ListOptions,
		func(opts *github.ListOptions) ([]*github.User, *github.Response, error) {
			return org.client.Organizations.ListMembers(
				ctx,
				*org.info.Login,
				opt,
			)
		},
		func(ghUsers []*github.User) []types.User {
			var users []types.User
			for _, m := range ghUsers {
				existingUser, ok := org.Users[*m.Login]
				if ok {
					users = append(users, existingUser)
					continue
				}

				// XXX information from listing collborators is incomplete
				// we need to explicitly fetch user info
				u, _, err := org.client.Users.Get(ctx, *m.Login)
				if err != nil {
					log.Logger.Error(err)
					continue
				}
				user := types.User{}
				// FIXME use reflection
				userJson, _ := json.Marshal(u)
				_ = json.Unmarshal(userJson, &user)
				users = append(users, user)
			}
			return users
		},
	)
	if err != nil {
		log.Logger.Error(err)
	}

	members := make(map[types.UserLogin]types.User, len(users))
	for _, u := range users {
		members[types.UserLogin(*u.Login)] = u
	}
	org.Users = members
	return members, nil
}