mirror of
https://github.com/nbd-wtf/go-nostr.git
synced 2025-03-17 21:32:56 +01:00
69 lines
1.4 KiB
Go
69 lines
1.4 KiB
Go
package nostr
|
|
|
|
import (
|
|
"context"
|
|
"math"
|
|
"slices"
|
|
"time"
|
|
)
|
|
|
|
func (pool *SimplePool) PaginatorWithInterval(
|
|
interval time.Duration,
|
|
) func(ctx context.Context, urls []string, filter Filter, opts ...SubscriptionOption) chan RelayEvent {
|
|
return func(ctx context.Context, urls []string, filter Filter, opts ...SubscriptionOption) chan RelayEvent {
|
|
nextUntil := Now()
|
|
if filter.Until != nil {
|
|
nextUntil = *filter.Until
|
|
}
|
|
|
|
globalLimit := uint64(filter.Limit)
|
|
if globalLimit == 0 && !filter.LimitZero {
|
|
globalLimit = math.MaxUint64
|
|
}
|
|
var globalCount uint64 = 0
|
|
globalCh := make(chan RelayEvent)
|
|
|
|
repeatedCache := make([]string, 0, 300)
|
|
nextRepeatedCache := make([]string, 0, 300)
|
|
|
|
go func() {
|
|
defer close(globalCh)
|
|
|
|
for {
|
|
filter.Until = &nextUntil
|
|
time.Sleep(interval)
|
|
|
|
keepGoing := false
|
|
for evt := range pool.SubManyEose(ctx, urls, Filters{filter}, opts...) {
|
|
if slices.Contains(repeatedCache, evt.ID) {
|
|
continue
|
|
}
|
|
|
|
keepGoing = true // if we get one that isn't repeated, then keep trying to get more
|
|
nextRepeatedCache = append(nextRepeatedCache, evt.ID)
|
|
|
|
globalCh <- evt
|
|
|
|
globalCount++
|
|
if globalCount >= globalLimit {
|
|
return
|
|
}
|
|
|
|
if evt.CreatedAt < *filter.Until {
|
|
nextUntil = evt.CreatedAt
|
|
}
|
|
}
|
|
|
|
if !keepGoing {
|
|
return
|
|
}
|
|
|
|
repeatedCache = nextRepeatedCache
|
|
nextRepeatedCache = nextRepeatedCache[:0]
|
|
}
|
|
}()
|
|
|
|
return globalCh
|
|
}
|
|
}
|