Function GetUsersInfo

bluesky/blueskyapi.go:502–569

(pds string, token string, items []string, ignoreCache bool)

}

func GetUsersInfo(pds string, token string, items []string, ignoreCache bool) ([]*bridge.TwitterUser, error) {
	var results []*bridge.TwitterUser
	var missing []string

	if !ignoreCache {
		for _, screen_name := range items {
			if user, found := userCache.Get(screen_name); found {
				results = append(results, &user)
			} else {
				missing = append(missing, screen_name)
			}
		}

		if len(missing) == 0 {
			return results, nil
		}
	} else {
		missing = items
	}

	// Parallel fetching for chunks of up to 25 at a time
	var wg sync.WaitGroup
	var mu sync.Mutex
	for i := 0; i < len(missing); i += 25 {
		end := i + 25
		if end > len(missing) {
			end = len(missing)
		}
		chunk := missing[i:end]

		wg.Add(1)
		go func(c []string) {
			defer wg.Done()

			url := pds + "/xrpc/app.bsky.actor.getProfiles" + "?actors=" + strings.Join(c, "&actors=")
			resp, err := SendRequest(&token, http.MethodGet, url, nil)
			if err != nil {
				fmt.Println(err)
				return
			}
			defer resp.Body.Close()
			if resp.StatusCode != http.StatusOK {
				bodyBytes, _ := io.ReadAll(resp.Body)
				fmt.Println("Response Status:", resp.StatusCode)
				fmt.Println("Response Body:", string(bodyBytes))
				return
			}

			var authors struct {
				Profiles []User `json:"profiles"`
			}
			if err := json.NewDecoder(resp.Body).Decode(&authors); err != nil {
				return
			}

			mu.Lock()
			for _, author := range authors.Profiles {
				userObj := AuthorTTB(author)