diff options
Diffstat (limited to 'backend/fetchers/app.bsky.go')
| -rw-r--r-- | backend/fetchers/app.bsky.go | 22 |
1 files changed, 19 insertions, 3 deletions
diff --git a/backend/fetchers/app.bsky.go b/backend/fetchers/app.bsky.go index 7c42f44..b6bb939 100644 --- a/backend/fetchers/app.bsky.go +++ b/backend/fetchers/app.bsky.go @@ -3,6 +3,7 @@ package fetchers import ( "encoding/json" "fmt" + "llostre/backend/auth" "llostre/backend/notes" "net/http" ) @@ -11,10 +12,25 @@ type ListRecordsResponse struct { Records []notes.AppBskyFeedPostRecord `json:"records"` } -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) +func FetchAppBskyFeedPosts(did, pdsURL, accessToken string, keypair *auth.DPoPKeyPair) ([]notes.AppBskyFeedPostNote, error) { + url := fmt.Sprintf("%s/xrpc/com.atproto.repo.listRecords?repo=%s&collection=app.bsky.feed.post", pdsURL, did) - resp, err := http.Get(url) + fmt.Printf("Generating DPoP proof for: %s\n", url) + dpopProof, err := keypair.GenerateDPoPProof("GET", url, "") + if err != nil { + fmt.Printf("DPoP generation failed: %v\n", err) + return nil, err + } + + fmt.Printf("Making request to PDS\n") + req, err := http.NewRequest("GET", url, nil) + if err != nil { + return nil, err + } + req.Header.Set("Authorization", "Bearer "+accessToken) + req.Header.Set("DPoP", dpopProof) + + resp, err := http.DefaultClient.Do(req) if err != nil { return nil, err } |