laantungir/nak
1
0
Fork 0
mirror of https://github.com/fiatjaf/nak.git synced 2025-12-09 00:58:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

nak/b and nak/s user-agents.

Browse Source
This commit is contained in:
fiatjaf
2024-09-26 22:17:31 -03:00
parent d7c0ff2bb7
commit 2988c71ccb
4 changed files with 13 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
paginate.go
View File

@@ -12,8 +12,8 @@ import (
func paginateWithParams(
interval time.Duration,
globalLimit uint64,
) func(ctx context.Context, urls []string, filters nostr.Filters) chan nostr.RelayEvent {
return func(ctx context.Context, urls []string, filters nostr.Filters) chan nostr.RelayEvent {
) func(ctx context.Context, urls []string, filters nostr.Filters, opts ...nostr.SubscriptionOption) chan nostr.RelayEvent {
return func(ctx context.Context, urls []string, filters nostr.Filters, opts ...nostr.SubscriptionOption) chan nostr.RelayEvent {
// filters will always be just one
filter := filters[0]
@@ -42,7 +42,7 @@ func paginateWithParams(
time.Sleep(interval)
keepGoing := false
for evt := range sys.Pool.SubManyEose(ctx, urls, nostr.Filters{filter}) {
for evt := range sys.Pool.SubManyEose(ctx, urls, nostr.Filters{filter}, opts...) {
if slices.Contains(repeatedCache, evt.ID) {
continue
}