added some logging and caching

1 files changed, 6 insertions, 1 deletions

diff --git a/backend/main.go b/backend/main.go
index d5fbb91..f6851da 100644
--- a/backend/main.go
+++ b/backend/main.go
@@ -21,6 +21,7 @@ var (
 	frontendURL   string
 	sessionsMutex sync.RWMutex
 	sessions      = make(map[string]*auth.OAuthState)
+	notesCache 	  *fetchers.Cache
 )
 
 func init() {
@@ -51,6 +52,8 @@ func init() {
 	logger = slog.New(slog.NewTextHandler(os.Stdout, &slog.HandlerOptions{
 		Level: logLevel,
 	}))
+
+	notesCache = fetchers.NewCache()
 }
 
 func loginHandler(w http.ResponseWriter, r *http.Request) {
@@ -266,6 +269,7 @@ func postsHandler(w http.ResponseWriter, r *http.Request) {
 		logger.Debug("session public key", "key", session.KeyPair.PublicKey)
 	}
 
+	// Check for access token refresh
 	needsRefresh := time.Now().After(session.ExpiresAt)
 	pds := session.PDS
 	refreshToken := session.RefreshToken
@@ -289,7 +293,8 @@ func postsHandler(w http.ResponseWriter, r *http.Request) {
 		sessionsMutex.Unlock()
 	}
 
-	posts, err := fetchers.FetchAppBskyFeedPosts(session.DID, session.PDS, session.AccessToken, session.KeyPair)
+	// Fetch app.bsky.feed.post records
+	posts, err := fetchers.FetchAppBskyFeedPosts(logger, session.DID, session.PDS, session.AccessToken, session.KeyPair, notesCache)
 	if err != nil {
 		logger.Error("fetching app.bsky.feed.posts failed", "error", err)
 		http.Error(w, err.Error(), http.StatusInternalServerError)