rickub
nandi/gleanpublic⑂ Fork 0
⑂ 7c84f4a
Branches
claude/modal-container-min-76527a main View all branches → View all tags →
Commits
⬇ Clone ▾
git clone https://git.rickub.com/nandi/glean.git
git clone ssh://git@rickub.com/nandi/glean.git

Host key fingerprint (ed25519): SHA256:iycHnxEyq0Q7uyVpB7JlznP0G7JrTPXLYRcAU5CSLhc — verify it before your first connect.

Call immediately runSyncAll in PeriodicSyncUnverified

Julien Robert committed 2026-05-01T22:07:11+02:00 Browse files
7c84f4a parent: ee1eae0
modified internal/server/server.go +2 -0
@@ -400,6 +400,8 @@ func (s *Server) syncUserInBackground(userDID string, client *atproto.Client) {
400400 // appear after Jetstream downtime or rare missed events. This catches up by
401401 // reconciling each user's PDS records against the local index.
402402 func (s *Server) PeriodicSync(ctx context.Context, interval time.Duration) {
403+ s.runSyncAll(ctx)
404+
403405 ticker := time.NewTicker(interval)
404406 defer ticker.Stop()
405407
@@ -400,6 +400,8 @@ func (s *Server) syncUserInBackground(userDID string, client *atproto.Client) {
400 // appear after Jetstream downtime or rare missed events. This catches up by400 // appear after Jetstream downtime or rare missed events. This catches up by
401 // reconciling each user's PDS records against the local index.401 // reconciling each user's PDS records against the local index.
402 func (s *Server) PeriodicSync(ctx context.Context, interval time.Duration) {402 func (s *Server) PeriodicSync(ctx context.Context, interval time.Duration) {
403+ s.runSyncAll(ctx)
404+
403 ticker := time.NewTicker(interval)405 ticker := time.NewTicker(interval)
404 defer ticker.Stop()406 defer ticker.Stop()
405 407