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

exporting ParsePubkeys

Browse Source
This commit is contained in:
pippellia-btc
2025-06-23 18:02:53 +02:00
parent 68362c0a6b
commit a24c739a41
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/pipe/engine.go
View File

@@ -194,7 +194,7 @@ func computeDelta(ctx context.Context, db redb.RedisDB, cache *walks.CachedWalke
return graph.Delta{}, fmt.Errorf("failed to compute delta: %w", err) return graph.Delta{}, fmt.Errorf("failed to compute delta: %w", err)
} }
pubkeys := parsePubkeys(event) pubkeys := ParsePubkeys(event)
onMissing := redb.Ignore onMissing := redb.Ignore
if author.Status == graph.StatusActive { if author.Status == graph.StatusActive {
// active nodes are the only ones that can add new pubkeys to the database // active nodes are the only ones that can add new pubkeys to the database
@@ -239,8 +239,8 @@ const (
maxFollows = 50000 maxFollows = 50000
) )
// parse unique pubkeys (excluding author) from the "p" tags in the event. // Parse unique pubkeys (excluding author) from the "p" tags in the event.
func parsePubkeys(event *nostr.Event) []string { func ParsePubkeys(event *nostr.Event) []string {
pubkeys := make([]string, 0, min(len(event.Tags), maxFollows)) pubkeys := make([]string, 0, min(len(event.Tags), maxFollows))
for _, tag := range event.Tags { for _, tag := range event.Tags {
if len(pubkeys) > maxFollows { if len(pubkeys) > maxFollows {