A fork of the Cocoon PDS but being made more distributed.
playback a days worth of events when starting up
Signed-off-by: Will <did:plc:dadhhalkfcq3gucaq25hjqon>
willdot.net
(Jun 6, 2026, 9:23 PM +0100)
942de25a
cd251b6b
+8
-4
+5
-3
server/event_emmiter.go
+5
-3
server/event_emmiter.go
···
16
16
17
17
logger := s.logger.With("component", "event-emmiter")
18
18
ident := "self"
19
-
var since *int64
20
-
// TODO: track since
19
+
20
+
day := time.Hour * 24
21
+
22
+
since := time.Now().Add(-day).UnixMilli()
21
23
22
24
evts, evtManCancel, err := s.evtman.Subscribe(ctx, ident, func(evt *events.XRPCStreamEvent) bool {
23
25
return true
24
-
}, since)
26
+
}, &since)
25
27
if err != nil {
26
28
return err
27
29
}
+3
-1
server/persist.go
+3
-1
server/persist.go
···
60
60
rec := &models.EventRecord{}
61
61
if err := p.Db.Order("seq desc").Limit(1).First(rec).Error; err != nil {
62
62
slog.Error("fetching most recent event record", "error", err)
63
-
rec.Seq = time.Now().Unix()
63
+
rec.Seq = time.Now().UnixMilli()
64
64
}
65
65
66
66
// if the error on inserting the event record is a constraint error, it means that
···
139
139
Find(&records).Error; err != nil {
140
140
return fmt.Errorf("failed to query events: %w", err)
141
141
}
142
+
143
+
slog.Info("playback", "len of records", len(records))
142
144
143
145
if len(records) == 0 {
144
146
return nil