diff options
Diffstat (limited to 'backend/fetchers/app.bsky.go')
| -rw-r--r-- | backend/fetchers/app.bsky.go | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/backend/fetchers/app.bsky.go b/backend/fetchers/app.bsky.go index 2955cde..b787e00 100644 --- a/backend/fetchers/app.bsky.go +++ b/backend/fetchers/app.bsky.go @@ -12,7 +12,7 @@ type ListRecordsResponse struct { Records []notes.AppBskyFeedPostRecord `json:"records"` } -func FetchBlueskyPosts(did string, pdsURL string) ([]notes.AppBskyFeedPostNote, error) { +func FetchAppBskyFeedPosts(did string, pdsURL string) ([]notes.AppBskyFeedPostNote, error) { url := fmt.Sprintf("%s/xrpc/com.atproto.repo.listRecords?repo=%s&collection=app.bsky.feed.post&limit=50", pdsURL, did) resp, err := http.Get(url) @@ -32,9 +32,16 @@ func FetchBlueskyPosts(did string, pdsURL string) ([]notes.AppBskyFeedPostNote, return nil, err } + profile, err := FetchProfile(did, pdsURL) + if err != nil { + fmt.Printf("Profile fetch failed for %s: %v\n", did, err) + } else { + fmt.Printf("Fetched profile: %+v\n", profile) + } + var posts []notes.AppBskyFeedPostNote for _, record := range response.Records { - bp, err := notes.AppBskyFeedPostFromRecord(record) + bp, err := notes.AppBskyFeedPostFromRecord(record, profile) if err != nil { fmt.Printf("skipping malformed record %s: %v\n", record.URI, err) continue |