From 4bb2d252a321f9f5730fe9266a50b16a6d2e66be Mon Sep 17 00:00:00 2001
From: Will <did:plc:dadhhalkfcq3gucaq25hjqon>
Date: Thu, 18 Jun 2026 17:32:50 +0000
Subject: [PATCH] fixed cursor on startup

Signed-off-by: Will <did:plc:dadhhalkfcq3gucaq25hjqon>
---
 server/event_emmiter.go | 20 +++++++++++++++++---
 server/persist.go | 3 ++-
 2 file(s) changed, 19 insertion(s)(+), 4 deletion(s)(-)

diff --git a/server/event_emmiter.go b/server/event_emmiter.go
--- a/server/event_emmiter.go
+++ b/server/event_emmiter.go
@@ -3,11 +3,13 @@
 import (
 	"bytes"
 	"context"
+	"log/slog"
 	"net/http"
 	"time"
 
 	"github.com/bluesky-social/indigo/events"
 	"github.com/bluesky-social/indigo/lex/util"
+	"github.com/haileyok/cocoon/models"
 )
 
 func (s *Server) emmitEvents(ctx context.Context) error {
@@ -17,9 +19,15 @@
 	logger := s.logger.With("component", "event-emmiter")
 	ident := "self"
 
-	day := time.Hour * 24
+	// get the most recent event
+	rec := &models.EventRecord{}
+	err := s.db.Raw(ctx, "SELECT * from event_records ORDER BY seq DESC LIMIT 1", nil).Scan(&rec).Error
+	if err != nil {
+		slog.Error("fetching most recent event record", "error", err)
+		rec.Seq = time.Now().UnixMilli()
+	}
 
-	since := time.Now().Add(-day).UnixMilli()
+	since := rec.Seq
 
 	evts, evtManCancel, err := s.evtman.Subscribe(ctx, ident, func(evt *events.XRPCStreamEvent) bool {
 		return true
@@ -72,11 +80,17 @@ return
 			}
 
 			// TODO: use a HTTP client here not the default
-			_, err := http.Post(s.config.SubscribeReposServiceURL, "", buf)
+			resp, err := http.Post(s.config.SubscribeReposServiceURL, "", buf)
 			if err != nil {
 				logger.Error("posting to web server", "error", err)
 				return
 			}
+			if resp.StatusCode == http.StatusAccepted {
+				logger.Info("posted event to subscribe repos")
+				return
+			}
+
+			logger.Error("posting event to subscribe repos", "status", resp.StatusCode)
 		}()
 	}
 
diff --git a/server/persist.go b/server/persist.go
--- a/server/persist.go
+++ b/server/persist.go
@@ -116,6 +116,7 @@ return nil
 	}, retry.RetryIf(retryIfFunc))
 
 	if err != nil {
+		slog.Error(err.Error())
 		return err
 	}
 
@@ -140,7 +141,7 @@ Find(&records).Error; err != nil {
 			return fmt.Errorf("failed to query events: %w", err)
 		}
 
-		slog.Info("playback", "len of records", len(records))
+		slog.Info("playback", "len of records", len(records), "cursor", cursor)
 
 		if len(records) == 0 {
 			return nil

--
tangled.sh