Function GetUsersInfoRaw

bluesky/blueskyapi.go:572–621

TODO: Combine this with GetUsersInfo... somehow

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

// TODO: Combine this with GetUsersInfo... somehow
func GetUsersInfoRaw(pds string, token string, items []string, ignoreCache bool) ([]*User, error) {
	var results []*User
	missing := items // hack

	// 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 {
				results = append(results, &author)
			}
			mu.Unlock()
		}(chunk)
	}

	wg.Wait()
	return results, nil
}

// https://docs.bsky.app/docs/api/app-bsky-graph-get-relationships
func GetRelationships(pds string, token string, source string, others []string) (*RelationshipsRes, error) {