added slingshot fetching + refactored fetching in general

1 files changed, 9 insertions, 6 deletions

diff --git a/backend/main.go b/backend/main.go
index f6851da..3c10887 100644
--- a/backend/main.go
+++ b/backend/main.go
@@ -16,12 +16,13 @@ import (
 )
 
 var (
-	logger		  *slog.Logger
+	logger        *slog.Logger
 	backendURL    string
 	frontendURL   string
+	slingshotURL  string
 	sessionsMutex sync.RWMutex
 	sessions      = make(map[string]*auth.OAuthState)
-	notesCache 	  *fetchers.Cache
+	cache         *fetchers.Cache
 )
 
 func init() {
@@ -53,7 +54,9 @@ func init() {
 		Level: logLevel,
 	}))
 
-	notesCache = fetchers.NewCache()
+	slingshotURL = os.Getenv("SLINGSHOT_URL")
+
+	cache = fetchers.NewCache()
 }
 
 func loginHandler(w http.ResponseWriter, r *http.Request) {
@@ -166,7 +169,7 @@ func callbackHandler(w http.ResponseWriter, r *http.Request) {
 		oauthState.PDS,
 		code,
 		oauthState.CodeVerifier,
-		backendURL + "/callback",
+		backendURL+"/callback",
 		oauthState.KeyPair,
 	)
 	if err != nil {
@@ -277,7 +280,7 @@ func postsHandler(w http.ResponseWriter, r *http.Request) {
 	sessionsMutex.RUnlock()
 
 	if needsRefresh {
-		newTokens, err := auth.RefreshAccessToken(pds, refreshToken, backendURL + "/callback", keypair)
+		newTokens, err := auth.RefreshAccessToken(pds, refreshToken, backendURL+"/callback", keypair)
 		if err != nil {
 			sessionsMutex.Lock()
 			delete(sessions, cookie.Value)
@@ -294,7 +297,7 @@ func postsHandler(w http.ResponseWriter, r *http.Request) {
 	}
 
 	// Fetch app.bsky.feed.post records
-	posts, err := fetchers.FetchAppBskyFeedPosts(logger, session.DID, session.PDS, session.AccessToken, session.KeyPair, notesCache)
+	posts, err := fetchers.FetchAppBskyFeedPosts(logger, session.DID, session.PDS, slingshotURL, cache)
 	if err != nil {
 		logger.Error("fetching app.bsky.feed.posts failed", "error", err)
 		http.Error(w, err.Error(), http.StatusInternalServerError)