Function GetPosts

bluesky/blueskyapi.go:913–961

https://docs.bsky.app/docs/api/app-bsky-feed-get-posts

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

// https://docs.bsky.app/docs/api/app-bsky-feed-get-posts
func GetPosts(pds string, token string, items []string) ([]*Post, error) {
	var results []*Post

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

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

			url := pds + "/xrpc/app.bsky.feed.getPosts" + "?uris=" + strings.Join(c, "&uris=")
			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 posts struct {
				Posts []Post `json:"posts"`
			}
			if err := json.NewDecoder(resp.Body).Decode(&posts); err != nil {
				return
			}

			mu.Lock()
			for _, post := range posts.Posts {
				results = append(results, &post)
			}
			mu.Unlock()
		}(chunk)
	}

	wg.Wait()
	return results, nil
}

// https://docs.bsky.app/docs/api/app-bsky-graph-get-followers
func GetFollowers(pds string, token string, context string, actor string) (*FollowersTimeline, error) {