aljaz/crawler_v2
1
0
Fork 0
mirror of https://github.com/aljazceru/crawler_v2.git synced 2025-12-17 07:24:21 +01:00
Code Issues Packages Projects Releases Wiki Activity

added expiration to "active_pubkeys" HLL

Browse Source
This commit is contained in:
pippellia-btc
2025-09-14 21:32:43 +02:00
parent 0cca8d54cb
commit 4558dd5b3c
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
pkg/pipe/recorder.go
View File

@@ -60,6 +60,8 @@ const (
KeyKind = "kind" KeyKind = "kind"
KeyActivePubkeys = "active_pubkeys" KeyActivePubkeys = "active_pubkeys"
KeyTotalPubkeys = "total_pubkeys" KeyTotalPubkeys = "total_pubkeys"
expiration = 30 * 24 * time.Hour
) )
func stats(day string) string { return KeyStats + separator + day } func stats(day string) string { return KeyStats + separator + day }
@@ -82,6 +84,7 @@ func recordEvent(db redb.RedisDB, event *nostr.Event) error {
pipe := db.Client.TxPipeline() pipe := db.Client.TxPipeline()
pipe.HIncrBy(ctx, stats(today), kind(event.Kind), 1) pipe.HIncrBy(ctx, stats(today), kind(event.Kind), 1)
pipe.PFAdd(ctx, activePubkeys(today), event.PubKey) pipe.PFAdd(ctx, activePubkeys(today), event.PubKey)
pipe.Expire(ctx, activePubkeys(today), 30*expiration)
if _, err := pipe.Exec(ctx); err != nil { if _, err := pipe.Exec(ctx); err != nil {
return fmt.Errorf("failed to record event: pipeline failed: %w", err) return fmt.Errorf("failed to record event: pipeline failed: %w", err)