this repo has no description
always do seq roll-back, not just for .host.bsky.network
+4
-3
+4
-3
cmd/relayered/relay/slurper.go
+4
-3
cmd/relayered/relay/slurper.go
···
6
6
"fmt"
7
7
"log/slog"
8
8
"math/rand"
9
-
"strings"
10
9
"sync"
11
10
"time"
12
11
···
273
272
protocol = "wss"
274
273
}
275
274
276
-
// Special case `.host.bsky.network` Host to rewind cursor by 200 events to smooth over unclean shutdowns
277
-
if strings.HasSuffix(host.Hostname, ".host.bsky.network") && host.LastSeq > 200 {
275
+
// cursor by 200 events to smooth over unclean shutdowns
276
+
if host.LastSeq > 200 {
278
277
host.LastSeq -= 200
278
+
} else {
279
+
host.LastSeq = 0
279
280
}
280
281
281
282
cursor := host.LastSeq