aboutsummaryrefslogtreecommitdiff
path: root/backend/main.go
diff options
context:
space:
mode:
Diffstat (limited to 'backend/main.go')
-rw-r--r--backend/main.go15
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)