Implemented OAuth login

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
 	}