database

func (*CuratingACL) BlockIP ¶

func (c *CuratingACL) BlockIP(ip string, duration time.Duration, reason string) error

BlockIP blocks an IP for a specified duration

func (*CuratingACL) CleanupExpiredIPBlocks ¶

func (c *CuratingACL) CleanupExpiredIPBlocks() error

CleanupExpiredIPBlocks removes expired IP blocks

func (*CuratingACL) CleanupOldEventCounts ¶

func (c *CuratingACL) CleanupOldEventCounts(beforeDate string) error

CleanupOldEventCounts removes event counts older than the specified date

func (*CuratingACL) CleanupOldIPEventCounts ¶

func (c *CuratingACL) CleanupOldIPEventCounts(beforeDate string) error

CleanupOldIPEventCounts removes IP event counts older than the specified date

func (*CuratingACL) DeleteEventsForPubkey ¶

func (c *CuratingACL) DeleteEventsForPubkey(pubkeyHex string) (int, error)

DeleteEventsForPubkey deletes all events for a given pubkey Returns the number of events deleted

func (*CuratingACL) GetConfig ¶

func (c *CuratingACL) GetConfig() (CuratingConfig, error)

GetConfig returns the curating configuration

func (*CuratingACL) GetEventCount ¶

func (c *CuratingACL) GetEventCount(pubkey, date string) (int, error)

GetEventCount returns the event count for a pubkey on a specific date

func (*CuratingACL) GetEventsForPubkey ¶

func (c *CuratingACL) GetEventsForPubkey(pubkeyHex string, limit, offset int) ([]EventSummary, int, error)

GetEventsForPubkey fetches events for a pubkey, returning simplified event data limit specifies max events to return, offset is for pagination

func (*CuratingACL) GetIPEventCount ¶

func (c *CuratingACL) GetIPEventCount(ip, date string) (int, error)

GetIPEventCount returns the total event count for an IP on a specific date

func (*CuratingACL) GetIPOffense ¶

func (c *CuratingACL) GetIPOffense(ip string) (*IPOffense, error)

GetIPOffense returns the offense record for an IP

func (*CuratingACL) IncrementEventCount ¶

func (c *CuratingACL) IncrementEventCount(pubkey, date string) (int, error)

IncrementEventCount increments and returns the new event count for a pubkey

func (*CuratingACL) IncrementIPEventCount ¶

func (c *CuratingACL) IncrementIPEventCount(ip, date string) (int, error)

IncrementIPEventCount increments and returns the new event count for an IP

func (*CuratingACL) IsConfigured ¶

func (c *CuratingACL) IsConfigured() (bool, error)

IsConfigured returns true if a configuration event has been set

func (*CuratingACL) IsEventSpam ¶

func (c *CuratingACL) IsEventSpam(eventID string) (bool, error)

IsEventSpam checks if an event is marked as spam

func (*CuratingACL) IsIPBlocked ¶

func (c *CuratingACL) IsIPBlocked(ip string) (bool, time.Time, error)

IsIPBlocked checks if an IP is blocked and returns expiration time

func (*CuratingACL) IsKindAllowed ¶

func (c *CuratingACL) IsKindAllowed(kind int, config *CuratingConfig) bool

IsKindAllowed checks if an event kind is allowed based on config

func (*CuratingACL) IsPubkeyBlacklisted ¶

func (c *CuratingACL) IsPubkeyBlacklisted(pubkey string) (bool, error)

IsPubkeyBlacklisted checks if a pubkey is blacklisted

func (*CuratingACL) IsPubkeyTrusted ¶

func (c *CuratingACL) IsPubkeyTrusted(pubkey string) (bool, error)

IsPubkeyTrusted checks if a pubkey is trusted

func (*CuratingACL) ListBlacklistedPubkeys ¶

func (c *CuratingACL) ListBlacklistedPubkeys() ([]BlacklistedPubkey, error)

ListBlacklistedPubkeys returns all blacklisted pubkeys

func (*CuratingACL) ListBlockedIPs ¶

func (c *CuratingACL) ListBlockedIPs() ([]CuratingBlockedIP, error)

ListBlockedIPs returns all blocked IPs (including expired ones)

func (*CuratingACL) ListSpamEvents ¶

func (c *CuratingACL) ListSpamEvents() ([]SpamEvent, error)

ListSpamEvents returns all spam events

func (*CuratingACL) ListTrustedPubkeys ¶

func (c *CuratingACL) ListTrustedPubkeys() ([]TrustedPubkey, error)

ListTrustedPubkeys returns all trusted pubkeys

func (*CuratingACL) ListUnclassifiedUsers ¶

func (c *CuratingACL) ListUnclassifiedUsers(limit int) ([]UnclassifiedUser, error)

ListUnclassifiedUsers returns users who are neither trusted nor blacklisted sorted by event count descending

func (*CuratingACL) MarkEventAsSpam ¶

func (c *CuratingACL) MarkEventAsSpam(eventID, pubkey, reason string) error

MarkEventAsSpam marks an event as spam

func (*CuratingACL) RecordIPOffense ¶

func (c *CuratingACL) RecordIPOffense(ip, pubkey string) (int, error)

RecordIPOffense records a rate limit violation from an IP for a pubkey Returns the new offense count

func (*CuratingACL) RemoveBlacklistedPubkey ¶

func (c *CuratingACL) RemoveBlacklistedPubkey(pubkey string) error

RemoveBlacklistedPubkey removes a blacklisted pubkey from the database

func (*CuratingACL) RemoveTrustedPubkey ¶

func (c *CuratingACL) RemoveTrustedPubkey(pubkey string) error

RemoveTrustedPubkey removes a trusted pubkey from the database

func (*CuratingACL) SaveBlacklistedPubkey ¶

func (c *CuratingACL) SaveBlacklistedPubkey(pubkey string, reason string) error

SaveBlacklistedPubkey saves a blacklisted pubkey to the database

func (*CuratingACL) SaveConfig ¶

func (c *CuratingACL) SaveConfig(config CuratingConfig) error

SaveConfig saves the curating configuration

func (*CuratingACL) SaveTrustedPubkey ¶

func (c *CuratingACL) SaveTrustedPubkey(pubkey string, note string) error

SaveTrustedPubkey saves a trusted pubkey to the database

func (*CuratingACL) ScanAllPubkeys ¶

func (c *CuratingACL) ScanAllPubkeys() (*ScanResult, error)

ScanAllPubkeys scans the database to find all unique pubkeys and count their events. This populates the event count data needed for the unclassified users list. It uses the SerialPubkey index to find all pubkeys, then counts events for each.

func (*CuratingACL) UnblockIP ¶

func (c *CuratingACL) UnblockIP(ip string) error

UnblockIP removes an IP from the blocked list

func (*CuratingACL) UnmarkEventAsSpam ¶

func (c *CuratingACL) UnmarkEventAsSpam(eventID string) error

UnmarkEventAsSpam removes the spam flag from an event

func (*D) AcquireQuerySlot ¶

func (d *D) AcquireQuerySlot(ctx context.Context) bool

AcquireQuerySlot acquires a slot from the query semaphore to limit concurrent queries. This blocks until a slot is available or the context is cancelled. Returns true if slot was acquired, false if context cancelled.

func (*D) AddInboundRefsToResult ¶

func (d *D) AddInboundRefsToResult(result *GraphResult, depth int, kinds []uint16) error

AddInboundRefsToResult collects inbound references (events that reference discovered items) for events at a specific depth in the result.

For example, if you have a follows graph result and want to find all kind-7 reactions to posts by users at depth 1, this collects those reactions and adds them to result.InboundRefs.

Parameters: - result: The graph result to augment with ref data - depth: The depth at which to collect refs (0 = all depths) - kinds: Event kinds to collect (e.g., [7] for reactions, [6] for reposts)

func (*D) AddNIP43Member ¶

func (d *D) AddNIP43Member(pubkey []byte, inviteCode string) error

AddNIP43Member adds a member to the NIP-43 membership list

func (*D) AddOutboundRefsToResult ¶

func (d *D) AddOutboundRefsToResult(result *GraphResult, depth int, kinds []uint16) error

AddOutboundRefsToResult collects outbound references (events referenced by discovered items).

For example, find all events that posts by users at depth 1 reference (quoted posts, replied-to posts).

func (*D) ArchiveRevokedKey ¶

func (d *D) ArchiveRevokedKey(peer *WireGuardPeer) error

ArchiveRevokedKey stores a revoked keypair for audit purposes.

func (*D) BackfillETagGraph ¶

func (d *D) BackfillETagGraph()

BackfillETagGraph populates e-tag graph indexes (eeg/gee) for all existing events. This enables graph traversal queries for thread/reply discovery.

The migration: 1. Iterates all events in compact storage (cmp prefix) 2. Extracts e-tags from each event 3. For e-tags referencing events we have, creates bidirectional edges:

• eeg|source|target|kind|direction(out) - forward edge
• gee|target|kind|direction(in)|source - reverse edge

This is idempotent: running multiple times won't create duplicate edges (BadgerDB overwrites existing keys).

func (*D) BackfillMissingSerialEventIdMappings ¶

func (d *D) BackfillMissingSerialEventIdMappings()

BackfillMissingSerialEventIdMappings finds legacy events that were incorrectly skipped during the v6 compact format migration and creates their SerialEventId mappings. This fixes events whose ID happens to start with byte 0x01, which was mistakenly interpreted as CompactFormatVersion during the original migration.

The v6 migration had this check:

if len(eventData) > 0 && eventData[0] == CompactFormatVersion { continue }

This caused legacy events with IDs starting with 0x01 to be skipped, leaving them without sei mappings and causing "Key not found" errors when fetching.

func (*D) BackfillPubkeyPubkeyGraph ¶

func (d *D) BackfillPubkeyPubkeyGraph()

BackfillPubkeyPubkeyGraph populates pubkey-to-pubkey (noun-noun) graph indexes (ppg/gpp) for all existing events that contain p-tags. This materializes direct pubkey→pubkey edges, collapsing the two-hop pubkey→event→pubkey traversal into a single-hop lookup.

For each event with p-tags, creates bidirectional edges:

• ppg|author_serial|target_serial|kind|direction(out)|event_serial - forward edge
• gpp|target_serial|kind|direction(in)|author_serial|event_serial - reverse edge

This is idempotent: running multiple times won't create duplicate edges.

func (*D) CacheEvents ¶

func (d *D) CacheEvents(f *filter.F, events event.S)

CacheEvents stores events for a filter (without subscription ID)

func (*D) CacheMarshaledJSON ¶

func (d *D) CacheMarshaledJSON(f *filter.F, marshaledJSON [][]byte)

CacheMarshaledJSON stores marshaled JSON event envelopes for a filter

func (*D) CheckForDeleted ¶

func (d *D) CheckForDeleted(ev *event.E, admins [][]byte) (err error)

CheckForDeleted checks if the event is deleted, and returns an error with prefix "blocked:" if it is. This function also allows designating admin pubkeys that also may delete the event, normally only the author is allowed to delete an event.

func (*D) ClaimAlias ¶

func (d *D) ClaimAlias(alias, pubkeyHex string) error

ClaimAlias atomically claims an alias for a pubkey.

func (*D) CleanupEphemeralEvents ¶

func (d *D) CleanupEphemeralEvents()

func (*D) CleanupKind3WithoutPTags ¶

func (d *D) CleanupKind3WithoutPTags(ctx context.Context) error

CleanupKind3WithoutPTags scans for kind 3 follow list events that have no p tags and deletes them. This cleanup is needed because the directory spider may have saved malformed events that lost their tags during serialization.

func (*D) CleanupLegacyEventStorage ¶

func (d *D) CleanupLegacyEventStorage()

CleanupLegacyEventStorage removes legacy evt and sev storage entries after compact format migration. This reclaims disk space by removing the old storage format entries once all events have been successfully migrated to cmp format.

The cleanup: 1. Iterates through all cmp entries (compact format) 2. For each serial found in cmp, deletes corresponding evt and sev entries 3. Reports total bytes reclaimed

func (*D) Close ¶

func (d *D) Close() (err error)

Close releases resources and closes the database.

func (*D) CollectRefsForPubkeys ¶

func (d *D) CollectRefsForPubkeys(
	pubkeySerials []*types.Uint40,
	refKinds []uint16,
	eventKinds []uint16,
) (*GraphResult, error)

CollectRefsForPubkeys collects inbound references to events by specific pubkeys. This is useful for "find all reactions to posts by these users" queries.

Parameters: - pubkeySerials: The pubkeys whose events should be checked for refs - refKinds: Event kinds to collect (e.g., [7] for reactions) - eventKinds: Event kinds to check for refs (e.g., [1] for notes)

func (*D) CompactStorageStats ¶

func (d *D) CompactStorageStats() (stats CompactStorageStats, err error)

CompactStorageStats calculates storage statistics for compact event storage. This scans the database to provide accurate metrics on space savings.

func (*D) ConvertSmallEventsToInline ¶

func (d *D) ConvertSmallEventsToInline()

ConvertSmallEventsToInline migrates small events (<=384 bytes) to inline storage. This is a Reiser4-inspired optimization that stores small event data in the key itself, avoiding a second database lookup and improving query performance. Also handles replaceable and addressable events with specialized storage.

func (*D) ConvertToCompactEventFormat ¶

func (d *D) ConvertToCompactEventFormat()

ConvertToCompactEventFormat migrates all existing events to the new compact format. This format uses 5-byte serial references instead of 32-byte IDs/pubkeys, dramatically reducing storage requirements (up to 80% savings on ID/pubkey data).

The migration: 1. Reads each event from legacy storage (evt/sev prefixes) 2. Creates SerialEventId mapping (sei prefix) for event ID lookup 3. Re-encodes the event in compact format 4. Stores in cmp prefix 5. Optionally removes legacy storage after successful migration

func (*D) CountEvents ¶

func (d *D) CountEvents(c context.Context, f *filter.F) (
	count int, approx bool, err error,
)

CountEvents mirrors the initial selection logic of QueryEvents but stops once we have identified candidate event serials (id/pk/ts). It returns the count of those serials. The `approx` flag is always false as requested.

func (*D) CreateNRCConnection ¶

func (d *D) CreateNRCConnection(label string, createdBy []byte) (*NRCConnection, error)

CreateNRCConnection generates a new NRC connection with a random secret. createdBy is the pubkey of the admin creating this connection (can be nil for system-created).

func (*D) DeleteAccessRecord ¶

func (d *D) DeleteAccessRecord(serial uint64) error

DeleteAccessRecord removes the access tracking record for an event. This should be called when an event is deleted.

func (*D) DeleteBlob ¶

func (d *D) DeleteBlob(sha256Hash []byte, pubkey []byte) (err error)

DeleteBlob deletes a blob and its metadata

func (*D) DeleteEvent ¶

func (d *D) DeleteEvent(c context.Context, eid []byte) (err error)

DeleteEvent removes an event from the database identified by `eid`. If noTombstone is false or not provided, a tombstone is created for the event.

func (*D) DeleteEventBySerial ¶

func (d *D) DeleteEventBySerial(
	c context.Context, ser *types.Uint40, ev *event.E,
) (err error)

func (*D) DeleteExpired ¶

func (d *D) DeleteExpired()

func (*D) DeleteInviteCode ¶

func (d *D) DeleteInviteCode(code string) error

DeleteInviteCode removes an invite code (after use)

func (*D) DeleteMarker ¶

func (d *D) DeleteMarker(key string) (err error)

DeleteMarker removes a marker from the database

func (*D) DeleteNRCConnection ¶

func (d *D) DeleteNRCConnection(id string) error

DeleteNRCConnection removes an NRC connection from the database.

func (*D) DeletePaidSubscription ¶

func (d *D) DeletePaidSubscription(pubkeyHex string) error

DeletePaidSubscription removes a paid subscription.

func (*D) DeleteWireGuardPeer ¶

func (d *D) DeleteWireGuardPeer(nostrPubkey []byte) error

DeleteWireGuardPeer removes a WireGuard peer from the database. Note: The sequence number is not recycled to prevent subnet reuse.

func (*D) EventIDHexToSerial ¶

func (d *D) EventIDHexToSerial(eventIDHex string) (*types.Uint40, error)

EventIDHexToSerial converts an event ID hex string to its serial, if it exists. Returns an error if the event is not in the database.

func (*D) EventIdsBySerial ¶

func (d *D) EventIdsBySerial(start uint64, count int) (
	evs []uint64, err error,
)

func (*D) Export ¶

func (d *D) Export(c context.Context, w io.Writer, pubkeys ...[]byte)

Export the complete database of stored events to an io.Writer in line structured minified JSON. Supports both legacy and compact event formats.

func (*D) ExtendBlossomSubscription ¶

func (d *D) ExtendBlossomSubscription(
	pubkey []byte, level string, storageMB int64, days int,
) error

ExtendBlossomSubscription extends or creates a blossom subscription with service level

func (*D) ExtendSubscription ¶

func (d *D) ExtendSubscription(pubkey []byte, days int) error

func (*D) FetchEventBySerial ¶

func (d *D) FetchEventBySerial(ser *types.Uint40) (ev *event.E, err error)

FetchEventBySerial fetches a single event by its serial. This function tries multiple storage formats in order: 1. cmp (compact format with serial references) - newest, most space-efficient 2. sev (small event inline) - legacy Reiser4 optimization 3. evt (traditional separate storage) - legacy fallback

func (*D) FetchEventsBySerials ¶

func (d *D) FetchEventsBySerials(serials []*types.Uint40) (events map[uint64]*event.E, err error)

FetchEventsBySerials fetches multiple events by their serials in a single database transaction. Returns a map of serial uint64 value to event, only including successfully fetched events.

This function tries multiple storage formats in order: 1. cmp (compact format with serial references) - newest, most space-efficient 2. sev (small event inline) - legacy Reiser4 optimization 3. evt (traditional separate storage) - legacy fallback

func (*D) FindEventByAuthorAndKind ¶

func (d *D) FindEventByAuthorAndKind(authorSerial *types.Uint40, kind uint16) (*types.Uint40, error)

FindEventByAuthorAndKind finds the most recent event of a specific kind by an author. This is used to find kind-3 contact lists for follow graph traversal. Returns nil, nil if no matching event is found.

func (*D) FindMentions ¶

func (d *D) FindMentions(pubkey []byte, kinds []uint16) (*GraphResult, error)

FindMentions finds events that mention a pubkey via p-tags. This returns events grouped by depth, where depth represents how the events relate: - Depth 1: Events that directly mention the seed pubkey - Depth 2+: Not typically used for mentions (reserved for future expansion)

The kinds parameter filters which event kinds to include (e.g., [1] for notes only, [1,7] for notes and reactions, etc.)

func (*D) FindMentionsByPubkeys ¶

func (d *D) FindMentionsByPubkeys(pubkeySerials []*types.Uint40, kinds []uint16) (*GraphResult, error)

FindMentionsByPubkeys returns events that mention any of the given pubkeys. Useful for finding mentions across a set of followed accounts.

func (*D) FindMentionsFromHex ¶

func (d *D) FindMentionsFromHex(pubkeyHex string, kinds []uint16) (*GraphResult, error)

FindMentionsFromHex is a convenience wrapper that accepts hex-encoded pubkey.

func (*D) GetAccessLogs ¶

func (d *D) GetAccessLogs(nostrPubkey []byte) (logs []*WireGuardAccessLog, err error)

GetAccessLogs returns access logs for a user.

func (*D) GetAliasByPubkey ¶

func (d *D) GetAliasByPubkey(pubkeyHex string) (string, error)

GetAliasByPubkey returns the alias for a pubkey, or "" if none.

func (*D) GetAliasesByPubkey ¶

func (d *D) GetAliasesByPubkey(pubkeyHex string) ([]string, error)

GetAliasesByPubkey returns all aliases for a pubkey.

func (*D) GetAllAccessLogs ¶

func (d *D) GetAllAccessLogs() (logs []*WireGuardAccessLog, err error)

GetAllAccessLogs returns all access logs (admin view).

func (*D) GetAllNIP43Members ¶

func (d *D) GetAllNIP43Members() ([][]byte, error)

GetAllNIP43Members returns all NIP-43 members

func (*D) GetAllNRCConnections ¶

func (d *D) GetAllNRCConnections() (conns []*NRCConnection, err error)

GetAllNRCConnections returns all NRC connections.

func (*D) GetAllRevokedKeys ¶

func (d *D) GetAllRevokedKeys() (keys []*WireGuardRevokedKey, err error)

GetAllRevokedKeys returns all revoked keys across all users (admin view).

func (*D) GetAllWireGuardPeers ¶

func (d *D) GetAllWireGuardPeers() (peers []*WireGuardPeer, err error)

GetAllWireGuardPeers returns all WireGuard peers.

func (*D) GetBlob ¶

func (d *D) GetBlob(sha256Hash []byte) (data []byte, metadata *BlobMetadata, err error)

GetBlob retrieves blob data by SHA256 hash

func (*D) GetBlobMetadata ¶

func (d *D) GetBlobMetadata(sha256Hash []byte) (metadata *BlobMetadata, err error)

GetBlobMetadata retrieves only metadata for a blob

func (*D) GetBlossomStorageQuota ¶

func (d *D) GetBlossomStorageQuota(pubkey []byte) (quotaMB int64, err error)

GetBlossomStorageQuota returns the current blossom storage quota in MB for a pubkey

func (*D) GetCachedEvents ¶

func (d *D) GetCachedEvents(f *filter.F) (event.S, bool)

GetCachedEvents retrieves cached events for a filter (without subscription ID) Returns nil, false if not found

func (*D) GetCachedJSON ¶

func (d *D) GetCachedJSON(f *filter.F) ([][]byte, bool)

GetCachedJSON retrieves cached marshaled JSON for a filter Returns nil, false if not found

func (*D) GetETagsFromEventSerial ¶

func (d *D) GetETagsFromEventSerial(eventSerial *types.Uint40) ([]*types.Uint40, error)

GetETagsFromEventSerial extracts e-tag event serials from an event by its serial. This is a pure index-based operation - no event decoding required. It scans the eeg (event-event-graph) index for outbound e-tag edges.

func (*D) GetEventAccessInfo ¶

func (d *D) GetEventAccessInfo(serial uint64) (lastAccess int64, accessCount uint32, err error)

GetEventAccessInfo returns access information for an event. Returns (0, 0, nil) if the event has never been accessed.

func (*D) GetEventAuthorSerial ¶

func (d *D) GetEventAuthorSerial(eventSerial *types.Uint40) (*types.Uint40, error)

GetEventAuthorSerial finds the author pubkey serial for an event. Uses the epg (event-pubkey-graph) index with author direction.

func (*D) GetEventIDFromSerial ¶

func (d *D) GetEventIDFromSerial(serial *types.Uint40) (string, error)

GetEventIDFromSerial converts an event serial to its hex ID string.

func (*D) GetEventIdBySerial ¶

func (d *D) GetEventIdBySerial(ser *types.Uint40) (eventId []byte, err error)

GetEventIdBySerial looks up an event ID by its serial number. Uses the SerialEventId index (sei prefix).

func (*D) GetEventsByAuthor ¶

func (d *D) GetEventsByAuthor(authorSerial *types.Uint40, kinds []uint16) ([]*types.Uint40, error)

GetEventsByAuthor finds all events authored by a pubkey. Uses the peg (pubkey-event-graph) index with direction filter for author edges. Optionally filters by event kinds.

func (*D) GetEventsReferencingPubkey ¶

func (d *D) GetEventsReferencingPubkey(pubkeySerial *types.Uint40, kinds []uint16) ([]*types.Uint40, error)

GetEventsReferencingPubkey finds all events that reference a pubkey via p-tags. Uses the peg (pubkey-event-graph) index with direction filter for inbound p-tags. Optionally filters by event kinds.

func (*D) GetFollowersByKindViaGPP ¶

func (d *D) GetFollowersByKindViaGPP(targetSerial *types.Uint40, kind uint16) ([]*types.Uint40, error)

GetFollowersByKindViaGPP returns pubkey serials that reference the target pubkey via the gpp reverse index, filtered to a specific event kind. This enables efficient lookup of e.g. kind-10000 muters or kind-1984 reporters without scanning unrelated relationship types.

Key format: gpp(3)|target(5)|kind(2)|direction(1)|source(5)|event(5) = 21 bytes Prefix used: gpp(3)|target(5)|kind(2) = 10 bytes

func (*D) GetFollowersOfPubkeySerial ¶

func (d *D) GetFollowersOfPubkeySerial(targetSerial *types.Uint40) ([]*types.Uint40, error)

GetFollowersOfPubkeySerial returns the pubkey serials of users who follow a given pubkey. This finds all kind-3 events that have a p-tag referencing the target pubkey.

func (*D) GetFollowersViaGPP ¶

func (d *D) GetFollowersViaGPP(targetSerial *types.Uint40) ([]*types.Uint40, error)

GetFollowersViaGPP returns pubkey serials that reference the target pubkey via the gpp (graph-pubkey-pubkey) reverse index. This is a single prefix scan that replaces the three-hop GetFollowersOfPubkeySerial (find referencing events → get authors → dedup).

Key format: gpp(3)|target(5)|kind(2)|direction(1)|source(5)|event(5) = 21 bytes For kind-3 followers, we can optionally narrow with kind filter.

func (*D) GetFollowsByKindViaPPG ¶

func (d *D) GetFollowsByKindViaPPG(sourceSerial *types.Uint40, kind uint16) ([]*types.Uint40, error)

GetFollowsByKindViaPPG returns pubkey serials that the source pubkey references via the ppg index, filtered to a specific event kind. This restricts the outbound scan to e.g. kind-3 follows only, excluding kind-10000 mutes or kind-1984 reports.

Key format: ppg(3)|source(5)|target(5)|kind(2)|direction(1)|event(5) = 21 bytes Scan prefix: ppg(3)|source(5) = 8 bytes; kind is checked at bytes 13..15 in-loop.

func (*D) GetFollowsFromPubkeySerial ¶

func (d *D) GetFollowsFromPubkeySerial(pubkeySerial *types.Uint40) ([]*types.Uint40, error)

GetFollowsFromPubkeySerial returns the pubkey serials that a user follows. This extracts p-tags from the user's kind-3 contact list event. Returns an empty slice if no kind-3 event is found.

func (*D) GetFollowsViaPPG ¶

func (d *D) GetFollowsViaPPG(sourceSerial *types.Uint40) ([]*types.Uint40, error)

GetFollowsViaPPG returns pubkey serials that the source pubkey references via the ppg (pubkey-pubkey-graph) materialized index. This is a single prefix scan that replaces the two-hop GetFollowsFromPubkeySerial (find kind-3 → extract p-tags).

Key format: ppg(3)|source(5)|target(5)|kind(2)|direction(1)|event(5) = 21 bytes We scan prefix ppg|source and extract target serials at offset 8..13.

func (*D) GetFullIdPubkeyBySerial ¶

func (d *D) GetFullIdPubkeyBySerial(ser *types.Uint40) (
	fidpk *store.IdPkTs, err error,
)

func (*D) GetFullIdPubkeyBySerials ¶

func (d *D) GetFullIdPubkeyBySerials(sers []*types.Uint40) (
	fidpks []*store.IdPkTs, err error,
)

GetFullIdPubkeyBySerials seeks directly to each serial's prefix in the FullIdPubkey index. The input sers slice is expected to be sorted in ascending order, allowing efficient forward-only iteration via a single Badger iterator.

func (*D) GetLeastAccessedEvents ¶

func (d *D) GetLeastAccessedEvents(limit int, minAgeSec int64) (serials []uint64, err error)

GetLeastAccessedEvents returns event serials sorted by coldness. Events with older last access times and lower access counts are returned first. limit: maximum number of events to return minAgeSec: minimum age in seconds since last access (events accessed more recently are excluded)

func (*D) GetMarker ¶

func (d *D) GetMarker(key string) (value []byte, err error)

GetMarker retrieves an arbitrary marker from the database

func (*D) GetNIP43Membership ¶

func (d *D) GetNIP43Membership(pubkey []byte) (*NIP43Membership, error)

GetNIP43Membership retrieves membership details for a pubkey

func (*D) GetNRCAuthorizedSecrets ¶

func (d *D) GetNRCAuthorizedSecrets() (map[string]string, error)

GetNRCAuthorizedSecrets returns a map of derived pubkeys to labels for all connections. This is used by the NRC bridge to authorize incoming connections.

func (*D) GetNRCConnection ¶

func (d *D) GetNRCConnection(id string) (conn *NRCConnection, err error)

GetNRCConnection retrieves an NRC connection by ID.

func (*D) GetNRCConnectionByDerivedPubkey ¶

func (d *D) GetNRCConnectionByDerivedPubkey(derivedPubkey []byte) (*NRCConnection, error)

GetNRCConnectionByDerivedPubkey retrieves an NRC connection by its derived pubkey.

func (*D) GetNRCConnectionURI ¶

func (d *D) GetNRCConnectionURI(conn *NRCConnection, relayPubkey []byte, rendezvousURL string) (string, error)

GetNRCConnectionURI generates the full connection URI for a connection. relayPubkey is the relay's public key (32 bytes). rendezvousURL is the public relay URL.

func (*D) GetNextWGSequence ¶

func (d *D) GetNextWGSequence() (seq uint64, err error)

GetNextWGSequence retrieves and increments the sequence counter using Badger's Sequence.

func (*D) GetOrCreatePubkeySerial ¶

func (d *D) GetOrCreatePubkeySerial(pubkey []byte) (ser *types.Uint40, err error)

GetOrCreatePubkeySerial returns the serial for a pubkey, creating one if it doesn't exist. The pubkey parameter should be 32 bytes (schnorr public key). This function is thread-safe and uses transactions to ensure atomicity.

func (*D) GetOrCreateRelayIdentitySecret ¶

func (d *D) GetOrCreateRelayIdentitySecret() (skb []byte, err error)

GetOrCreateRelayIdentitySecret retrieves the existing relay identity secret key or creates and stores a new one if none exists.

func (*D) GetOrCreateSubnetPool ¶

func (d *D) GetOrCreateSubnetPool(baseNetwork string) (*wireguard.SubnetPool, error)

GetOrCreateSubnetPool creates or restores a subnet pool from the database.

func (*D) GetOrCreateWireGuardPeer ¶

func (d *D) GetOrCreateWireGuardPeer(nostrPubkey []byte, pool *wireguard.SubnetPool) (peer *WireGuardPeer, err error)

GetOrCreateWireGuardPeer retrieves or creates a WireGuard peer. The pool is used for subnet derivation from the sequence number.

func (*D) GetOrCreateWireGuardServerKey ¶

func (d *D) GetOrCreateWireGuardServerKey() (key []byte, err error)

GetOrCreateWireGuardServerKey retrieves or creates the WireGuard server key.

func (*D) GetPTagsFromEventSerial ¶

func (d *D) GetPTagsFromEventSerial(eventSerial *types.Uint40) ([]*types.Uint40, error)

GetPTagsFromEventSerial extracts p-tag pubkey serials from an event by its serial. This is a pure index-based operation - no event decoding required. It scans the epg (event-pubkey-graph) index for p-tag edges.

func (*D) GetPaidSubscription ¶

func (d *D) GetPaidSubscription(pubkeyHex string) (*PaidSubscription, error)

GetPaidSubscription returns the paid subscription for a pubkey.

func (*D) GetPaymentHistory ¶

func (d *D) GetPaymentHistory(pubkey []byte) ([]Payment, error)

func (*D) GetPubkeyByAlias ¶

func (d *D) GetPubkeyByAlias(alias string) (string, error)

GetPubkeyByAlias returns the pubkey for an alias, or "" if not found.

func (*D) GetPubkeyBySerial ¶

func (d *D) GetPubkeyBySerial(ser *types.Uint40) (pubkey []byte, err error)

GetPubkeyBySerial returns the full 32-byte pubkey for a given serial.

func (*D) GetPubkeyHexFromSerial ¶

func (d *D) GetPubkeyHexFromSerial(serial *types.Uint40) (string, error)

GetPubkeyHexFromSerial converts a pubkey serial to its hex string representation.

func (*D) GetPubkeySerial ¶

func (d *D) GetPubkeySerial(pubkey []byte) (ser *types.Uint40, err error)

GetPubkeySerial returns the serial for a pubkey if it exists. Returns an error if the pubkey doesn't have a serial yet.

func (*D) GetReferencingEvents ¶

func (d *D) GetReferencingEvents(targetSerial *types.Uint40, kinds []uint16) ([]*types.Uint40, error)

GetReferencingEvents finds all events that reference a target event via e-tags. Optionally filters by event kinds. Uses the gee (reverse e-tag graph) index.

func (*D) GetRelayIdentitySecret ¶

func (d *D) GetRelayIdentitySecret() (skb []byte, err error)

GetRelayIdentitySecret returns the relay identity secret key bytes if present. If the key is not found, returns (nil, badger.ErrKeyNotFound).

func (*D) GetRevokedKeys ¶

func (d *D) GetRevokedKeys(nostrPubkey []byte) (keys []*WireGuardRevokedKey, err error)

GetRevokedKeys returns all revoked keys for a user.

func (*D) GetSerialById ¶

func (d *D) GetSerialById(id []byte) (ser *types.Uint40, err error)

func (*D) GetSerialsByIds ¶

func (d *D) GetSerialsByIds(ids *tag.T) (
	serials map[string]*types.Uint40, err error,
)

GetSerialsByIds takes a tag.T containing multiple IDs and returns a map of IDs to their corresponding serial numbers. It directly queries the IdPrefix index for matching IDs, which is more efficient than using GetIndexesFromFilter.

func (*D) GetSerialsByIdsWithFilter ¶

func (d *D) GetSerialsByIdsWithFilter(
	ids *tag.T, fn func(ev *event.E, ser *types.Uint40) bool,
) (serials map[string]*types.Uint40, err error)

GetSerialsByIdsWithFilter takes a tag.T containing multiple IDs and returns a map of IDs to their corresponding serial numbers, applying a filter function to each event. The function directly creates ID index prefixes for efficient querying.

func (*D) GetSerialsByRange ¶

func (d *D) GetSerialsByRange(idx Range) (
	sers types.Uint40s, err error,
)

func (*D) GetSerialsFromFilter ¶

func (d *D) GetSerialsFromFilter(f *filter.F) (
	sers types.Uint40s, err error,
)

func (*D) GetSubnetSeed ¶

func (d *D) GetSubnetSeed() (seed []byte, err error)

GetSubnetSeed retrieves the subnet pool seed.

func (*D) GetSubscription ¶

func (d *D) GetSubscription(pubkey []byte) (*Subscription, error)

func (*D) GetThreadParents ¶

func (d *D) GetThreadParents(eventID []byte) (*GraphResult, error)

GetThreadParents finds events that a given event references (its parents/quotes).

func (*D) GetThreadReplies ¶

func (d *D) GetThreadReplies(eventID []byte, kinds []uint16) (*GraphResult, error)

GetThreadReplies finds all direct replies to an event. This is a convenience method that returns events at depth 1 with inbound direction.

func (*D) GetThumbnail ¶

func (d *D) GetThumbnail(key string) (data []byte, err error)

GetThumbnail retrieves a cached thumbnail by key

func (*D) GetTotalBlobStorageUsed ¶

func (d *D) GetTotalBlobStorageUsed(pubkey []byte) (totalMB int64, err error)

GetTotalBlobStorageUsed calculates total storage used by a pubkey in MB

func (*D) GetWireGuardPeer ¶

func (d *D) GetWireGuardPeer(nostrPubkey []byte) (peer *WireGuardPeer, err error)

GetWireGuardPeer retrieves a WireGuard peer by Nostr pubkey.

func (*D) GetWireGuardServerKey ¶

func (d *D) GetWireGuardServerKey() (key []byte, err error)

GetWireGuardServerKey retrieves the WireGuard server private key.

func (*D) HasBlob ¶

func (d *D) HasBlob(sha256Hash []byte) (exists bool, err error)

HasBlob checks if a blob exists

func (*D) HasMarker ¶

func (d *D) HasMarker(key string) (exists bool)

HasMarker checks if a marker exists in the database

func (*D) HealthCheck ¶

func (d *D) HealthCheck(progress io.Writer) (report *HealthReport, err error)

HealthCheck performs a comprehensive health check of the database. It scans all index prefixes and verifies referential integrity.

func (*D) Import ¶

func (d *D) Import(rr io.Reader)

Import a collection of events in line structured minified JSON format (JSONL). This runs synchronously to ensure the reader remains valid during processing. The actual event processing happens after buffering to a temp file, so the caller can close the reader after Import returns.

func (*D) ImportEventsFromReader ¶

func (d *D) ImportEventsFromReader(ctx context.Context, rr io.Reader) error

ImportEventsFromReader imports events from an io.Reader containing JSONL data

func (*D) ImportEventsFromStrings ¶

func (d *D) ImportEventsFromStrings(ctx context.Context, eventJSONs []string, policyManager interface {
	CheckPolicy(action string, ev *event.E, pubkey []byte, remote string) (bool, error)
}) error

ImportEventsFromStrings imports events from a slice of JSON strings with policy filtering

func (*D) IncrementRevokedKeyAccess ¶

func (d *D) IncrementRevokedKeyAccess(nostrPubkey, wgPubkey []byte) error

IncrementRevokedKeyAccess updates the access count for a revoked key.

func (*D) Init ¶

func (d *D) Init(path string) (err error)

Init initializes the database with the given path.

func (*D) InvalidateQueryCache ¶

func (d *D) InvalidateQueryCache()

InvalidateQueryCache clears all entries from the query cache

func (*D) IsAliasTaken ¶

func (d *D) IsAliasTaken(alias string) (bool, error)

IsAliasTaken returns true if the alias is claimed by any pubkey.

func (*D) IsFirstTimeUser ¶

func (d *D) IsFirstTimeUser(pubkey []byte) (bool, error)

IsFirstTimeUser checks if a user is logging in for the first time and marks them as seen

func (*D) IsNIP43Member ¶

func (d *D) IsNIP43Member(pubkey []byte) (isMember bool, err error)

IsNIP43Member checks if a pubkey is a NIP-43 member

func (*D) IsSubscriptionActive ¶

func (d *D) IsSubscriptionActive(pubkey []byte) (bool, error)

func (*D) ListAllBlobUserStats ¶

func (d *D) ListAllBlobUserStats() (stats []*UserBlobStats, err error)

ListAllBlobUserStats returns storage statistics for all users who have uploaded blobs

func (*D) ListAllBlobs ¶

func (d *D) ListAllBlobs() (descriptors []*BlobDescriptor, err error)

ListAllBlobs returns all blob descriptors in the database

func (*D) ListBlobs ¶

func (d *D) ListBlobs(
	pubkey []byte, since, until int64,
) (descriptors []*BlobDescriptor, err error)

ListBlobs lists all blobs for a given pubkey

func (*D) ListPaidSubscriptions ¶

func (d *D) ListPaidSubscriptions() ([]*PaidSubscription, error)

ListPaidSubscriptions returns all paid subscriptions.

func (*D) LogCompactSavings ¶

func (d *D) LogCompactSavings()

LogCompactSavings logs the storage savings achieved by compact format. Call this periodically or after significant operations.

func (*D) LogObsoleteAccess ¶

func (d *D) LogObsoleteAccess(nostrPubkey, wgPubkey []byte, sequence uint32, remoteAddr string) error

LogObsoleteAccess records an access attempt to an obsolete WireGuard address.

func (*D) Path ¶

func (d *D) Path() string

Path returns the path where the database files are stored.

func (*D) ProcessDelete ¶

func (d *D) ProcessDelete(ev *event.E, admins [][]byte) (err error)

func (*D) PubkeyHexToSerial ¶

func (d *D) PubkeyHexToSerial(pubkeyHex string) (*types.Uint40, error)

PubkeyHexToSerial converts a pubkey hex string to its serial, if it exists. Returns an error if the pubkey is not in the database.

func (*D) PublishNIP43MembershipEvent ¶

func (d *D) PublishNIP43MembershipEvent(kind int, pubkey []byte) error

PublishNIP43MembershipEvent publishes membership change events

func (*D) QueryAllVersions ¶

func (d *D) QueryAllVersions(c context.Context, f *filter.F) (
	evs event.S, err error,
)

QueryAllVersions queries events and returns all versions of replaceable events

func (*D) QueryCacheStats ¶

func (d *D) QueryCacheStats() querycache.CacheStats

QueryCacheStats returns statistics about the query cache

func (*D) QueryDeleteEventsByTargetId ¶

func (d *D) QueryDeleteEventsByTargetId(c context.Context, targetEventId []byte) (
	evs event.S, err error,
)

QueryDeleteEventsByTargetId queries for delete events that target a specific event ID

func (*D) QueryEvents ¶

func (d *D) QueryEvents(c context.Context, f *filter.F) (
	evs event.S, err error,
)

func (*D) QueryEventsWithOptions ¶

func (d *D) QueryEventsWithOptions(c context.Context, f *filter.F, includeDeleteEvents bool, showAllVersions bool) (
	evs event.S, err error,
)

func (*D) QueryForAddressableEvent ¶

func (d *D) QueryForAddressableEvent(f *filter.F) (serial *types.Uint40, err error)

QueryForAddressableEvent performs a direct O(1) lookup for a NIP-33 parameterized replaceable event using the AddressableEvent index. Returns the serial if found, nil if not found, or an error.

func (*D) QueryForIds ¶

func (d *D) QueryForIds(c context.Context, f *filter.F) (
	idPkTs []*store.IdPkTs, err error,
)

QueryForIds retrieves a list of IdPkTs based on the provided filter. It supports filtering by ranges and tags but disallows filtering by Ids. Results are sorted by timestamp in reverse chronological order by default. When a search query is present, results are ranked by a 50/50 blend of match count (how many distinct search terms matched) and recency. Returns an error if the filter contains Ids or if any operation fails.

func (*D) QueryForSerials ¶

func (d *D) QueryForSerials(c context.Context, f *filter.F) (
	sers types.Uint40s, err error,
)

QueryForSerials takes a filter and returns the serials of events that match, sorted in reverse chronological order.

func (*D) QueryPTagGraph ¶

func (d *D) QueryPTagGraph(f *filter.F) (sers types.Uint40s, err error)

QueryPTagGraph uses the pubkey graph index for efficient p-tag queries.

This query path is optimized for filters like:

{"#p": ["<pubkey>"], "kinds": [1, 6, 7]}

Performance benefits: - 41% smaller index keys (16 bytes vs 27 bytes) - No hash collisions (exact serial match) - Kind-indexed in key structure - Direction-aware filtering

func (*D) Ready ¶

func (d *D) Ready() <-chan struct{}

Ready returns a channel that closes when the database is ready to serve requests. This allows callers to wait for database warmup to complete.

func (*D) RebuildWordIndexesWithNormalization ¶

func (d *D) RebuildWordIndexesWithNormalization()

RebuildWordIndexesWithNormalization rebuilds all word indexes with unicode normalization applied. This migration: 1. Deletes all existing word indexes (wrd prefix) 2. Re-tokenizes all events with normalizeRune() applied 3. Creates new consolidated indexes where decorative unicode maps to ASCII

After this migration, "ᴅᴇᴀᴛʜ" (small caps) and "𝔇𝔢𝔞𝔱𝔥" (fraktur) will index the same as "death", eliminating duplicate entries and enabling proper search.

func (*D) ReconcileBlobMetadata ¶

func (d *D) ReconcileBlobMetadata() (reconciled int, err error)

ReconcileBlobMetadata scans the blossom directory for blob files that don't have corresponding metadata in the database and creates entries for them. This is useful for recovering from situations where blob files exist but their metadata was lost or never created.

func (*D) RecordEventAccess ¶

func (d *D) RecordEventAccess(serial uint64, connectionID string) error

RecordEventAccess updates access tracking for an event. This increments the access count and updates the last access time. The connectionID is currently not used for deduplication in the database layer, but is passed for potential future use. Deduplication is handled in the higher-level AccessTracker which maintains an in-memory cache.

func (*D) RecordPayment ¶

func (d *D) RecordPayment(
	pubkey []byte, amount int64, invoice, preimage string,
) error

func (*D) ReencodeEventsWithOptimizedTags ¶

func (d *D) ReencodeEventsWithOptimizedTags()

ReencodeEventsWithOptimizedTags re-encodes all events to use the new binary tag format that stores e/p tag values as 33-byte binary (32-byte hash + null) instead of 64-byte hex strings. This reduces memory usage by ~48% for these tags.

func (*D) RegenerateWireGuardPeer ¶

func (d *D) RegenerateWireGuardPeer(nostrPubkey []byte, pool *wireguard.SubnetPool) (peer *WireGuardPeer, err error)

RegenerateWireGuardPeer generates a new keypair for an existing peer. The sequence number (and thus subnet) is preserved. The old keypair is archived for audit purposes.

func (*D) ReleaseQuerySlot ¶

func (d *D) ReleaseQuerySlot()

ReleaseQuerySlot releases a previously acquired query slot.

func (*D) RemoveNIP43Member ¶

func (d *D) RemoveNIP43Member(pubkey []byte) error

RemoveNIP43Member removes a member from the NIP-43 membership list

func (*D) Repair ¶

func (d *D) Repair(ctx context.Context, opts *RepairOptions) (report *RepairReport, err error)

Repair performs database repair operations based on the provided options. It fixes integrity issues found by HealthCheck.

func (*D) RunMigrations ¶

func (d *D) RunMigrations()

func (*D) SaveBlob ¶

func (d *D) SaveBlob(
	sha256Hash []byte, data []byte, pubkey []byte, mimeType string, extension string,
) (err error)

SaveBlob stores a blob with its metadata

func (*D) SaveBlobMetadata ¶

func (d *D) SaveBlobMetadata(
	sha256Hash []byte, size int64, pubkey []byte, mimeType string, extension string,
) (err error)

SaveBlobMetadata stores only the metadata and index for a blob whose file already exists on disk. This is used by the streaming upload path where the file is written during hashing and then renamed into place before this call.

func (*D) SaveBlobReport ¶

func (d *D) SaveBlobReport(sha256Hash []byte, reportData []byte) (err error)

SaveBlobReport stores a report for a blob (BUD-09)

func (*D) SaveEvent ¶

func (d *D) SaveEvent(c context.Context, ev *event.E) (
	replaced bool, err error,
)

SaveEvent saves an event to the database, generating all the necessary indexes.

func (*D) SaveNRCConnection ¶

func (d *D) SaveNRCConnection(conn *NRCConnection) error

SaveNRCConnection stores an NRC connection in the database.

func (*D) SavePaidSubscription ¶

func (d *D) SavePaidSubscription(sub *PaidSubscription) error

SavePaidSubscription saves or updates a paid subscription. Delegates to the PaidACL storage layer.

func (*D) SaveThumbnail ¶

func (d *D) SaveThumbnail(key string, data []byte) error

SaveThumbnail caches a thumbnail with the given key

func (*D) SerialCacheStats ¶

func (d *D) SerialCacheStats() SerialCacheStats

SerialCacheStats returns statistics about the serial cache.

func (*D) SetLogLevel ¶

func (d *D) SetLogLevel(level string)

func (*D) SetMarker ¶

func (d *D) SetMarker(key string, value []byte) (err error)

SetMarker stores an arbitrary marker in the database

func (*D) SetRateLimiter ¶

func (d *D) SetRateLimiter(limiter RateLimiterInterface)

SetRateLimiter sets the rate limiter for controlling memory during import/export

func (*D) SetRelayIdentitySecret ¶

func (d *D) SetRelayIdentitySecret(skb []byte) (err error)

SetRelayIdentitySecret stores the relay identity secret key bytes (expects 32 bytes).

func (*D) SetSubnetSeed ¶

func (d *D) SetSubnetSeed(seed []byte) error

SetSubnetSeed stores the subnet pool seed.

func (*D) SetWireGuardServerKey ¶

func (d *D) SetWireGuardServerKey(key []byte) error

SetWireGuardServerKey stores the WireGuard server private key.

func (*D) StoreEventIdSerial ¶

func (d *D) StoreEventIdSerial(txn *badger.Txn, serial uint64, eventId []byte) error

StoreEventIdSerial stores the mapping from event serial to full event ID. This is called during event save to enable later reconstruction.

func (*D) StoreInviteCode ¶

func (d *D) StoreInviteCode(code string, expiresAt time.Time) error

StoreInviteCode stores an invite code with expiry

func (*D) Sync ¶

func (d *D) Sync() (err error)

Sync flushes the database buffers to disk.

func (*D) TraverseEventEventFromPubkey ¶

func (d *D) TraverseEventEventFromPubkey(seedPubkey []byte, maxDepth int, direction string) (*GraphResult, error)

TraverseEventEventFromPubkey performs BFS traversal of event↔event edges, seeded from events authored by the given pubkey.

func (*D) TraverseFollowers ¶

func (d *D) TraverseFollowers(seedPubkey []byte, maxDepth int) (*GraphResult, error)

TraverseFollowers performs BFS traversal to find who follows the seed pubkey. This is the reverse of TraverseFollows - it finds users whose kind-3 lists contain the target pubkey(s).

At each depth: - Depth 1: Users who directly follow the seed - Depth 2: Users who follow anyone at depth 1 (followers of followers) - etc.

func (*D) TraverseFollowersFromHex ¶

func (d *D) TraverseFollowersFromHex(seedPubkeyHex string, maxDepth int) (*GraphResult, error)

TraverseFollowersFromHex is a convenience wrapper that accepts hex-encoded pubkey.

func (*D) TraverseFollows ¶

func (d *D) TraverseFollows(seedPubkey []byte, maxDepth int) (*GraphResult, error)

TraverseFollows performs BFS traversal of the follow graph starting from a seed pubkey. Returns pubkeys grouped by first-discovered depth (no duplicates across depths).

The traversal works by: 1. Starting with the seed pubkey at depth 0 (not included in results) 2. For each pubkey at the current depth, find their kind-3 contact list 3. Extract p-tags from the contact list to get follows 4. Add new (unseen) follows to the next depth 5. Continue until maxDepth is reached or no new pubkeys are found

Early termination occurs if two consecutive depths yield no new pubkeys.

func (*D) TraverseFollowsFromHex ¶

func (d *D) TraverseFollowsFromHex(seedPubkeyHex string, maxDepth int) (*GraphResult, error)

TraverseFollowsFromHex is a convenience wrapper that accepts hex-encoded pubkey.

func (*D) TraversePubkeyEvent ¶

func (d *D) TraversePubkeyEvent(seedPubkey []byte, maxDepth int, direction string) (*GraphResult, error)

TraversePubkeyEvent performs BFS traversal of pubkey↔event edges. Direction "out" = events authored by/referencing the seed pubkey (peg index). Direction "in" = events that reference the seed pubkey (epg reverse).

func (*D) TraversePubkeyPubkey ¶

func (d *D) TraversePubkeyPubkey(seedPubkey []byte, maxDepth int, direction string) (*GraphResult, error)

TraversePubkeyPubkey performs BFS traversal of the pubkey↔pubkey graph using the ppg/gpp materialized index. This collapses the two-hop pubkey→event→pubkey traversal into a single prefix scan per frontier node.

Direction selects which index to scan:

• "out": ppg index (who does seed follow/reference?)
• "in": gpp index (who references seed?)
• "both": union of both directions at each depth

func (*D) TraversePubkeyPubkeyBaseline ¶

func (d *D) TraversePubkeyPubkeyBaseline(seedPubkey []byte, maxDepth int, direction string) (*GraphResult, error)

TraversePubkeyPubkeyBaseline performs the same BFS as TraversePubkeyPubkey but uses the old multi-hop approach: find kind-3 event → extract p-tags. This provides the benchmark baseline for comparison against the ppg/gpp index.

func (*D) TraverseThread ¶

func (d *D) TraverseThread(seedEventID []byte, maxDepth int, direction string) (*GraphResult, error)

TraverseThread performs BFS traversal of thread structure via e-tags. Starting from a seed event, it finds all replies/references at each depth.

The traversal works bidirectionally: - Forward: Events that the seed references (parents, quoted posts) - Backward: Events that reference the seed (replies, reactions, reposts)

Parameters: - seedEventID: The event ID to start traversal from - maxDepth: Maximum depth to traverse - direction: "both" (default), "inbound" (replies to seed), "outbound" (seed's references)

func (*D) TraverseThreadFromHex ¶

func (d *D) TraverseThreadFromHex(seedEventIDHex string, maxDepth int, direction string) (*GraphResult, error)

TraverseThreadFromHex is a convenience wrapper that accepts hex-encoded event ID.

func (*D) UpdateExpirationTags ¶

func (d *D) UpdateExpirationTags()

func (*D) UpdateNRCConnectionLastUsed ¶

func (d *D) UpdateNRCConnectionLastUsed(id string) error

UpdateNRCConnectionLastUsed updates the last used timestamp for a connection.

func (*D) UpdateWordIndexes ¶

func (d *D) UpdateWordIndexes()

func (*D) ValidateInviteCode ¶

func (d *D) ValidateInviteCode(code string) (valid bool, err error)

ValidateInviteCode checks if an invite code is valid and not expired

func (*D) Wipe ¶

func (d *D) Wipe() (err error)

func (*D) WouldReplaceEvent ¶

func (d *D) WouldReplaceEvent(ev *event.E) (bool, types.Uint40s, error)

WouldReplaceEvent checks if the provided event would replace existing events based on Nostr's replaceable or parameterized replaceable semantics. It returns true if the candidate is newer-or-equal than existing events. If an existing event is newer, it returns (false, nil, ErrOlderThanExisting). If no conflicts exist, it returns (false, nil, nil).

func (*DatabaseSerialResolver) GetEventIdBySerial ¶

func (r *DatabaseSerialResolver) GetEventIdBySerial(serial uint64) (eventId []byte, err error)

GetEventIdBySerial implements SerialResolver.

func (*DatabaseSerialResolver) GetEventSerialById ¶

func (r *DatabaseSerialResolver) GetEventSerialById(eventId []byte) (serial uint64, found bool, err error)

GetEventSerialById implements SerialResolver.

func (*DatabaseSerialResolver) GetOrCreatePubkeySerial ¶

func (r *DatabaseSerialResolver) GetOrCreatePubkeySerial(pubkey []byte) (serial uint64, err error)

GetOrCreatePubkeySerial implements SerialResolver.

func (*DatabaseSerialResolver) GetPubkeyBySerial ¶

func (r *DatabaseSerialResolver) GetPubkeyBySerial(serial uint64) (pubkey []byte, err error)

GetPubkeyBySerial implements SerialResolver.

func (*GrapeVineStore) DeleteScoreSet ¶

func (g *GrapeVineStore) DeleteScoreSet(observerHex string) error

DeleteScoreSet removes all stored scores for an observer. Uses WriteBatch to avoid exceeding Badger's transaction size limit on large graphs.

func (*GrapeVineStore) GetScore ¶

func (g *GrapeVineStore) GetScore(observerHex, targetHex string) ([]byte, error)

GetScore returns the raw JSON for a single score entry, or nil if not found.

func (*GrapeVineStore) GetScoreSet ¶

func (g *GrapeVineStore) GetScoreSet(observerHex string) ([]byte, error)

GetScoreSet returns the raw JSON for a full score set, or nil if not found.

func (*GrapeVineStore) SaveScoreSet ¶

func (g *GrapeVineStore) SaveScoreSet(observerHex string, setData []byte, entries map[string][]byte) error

SaveScoreSet persists a complete score set for an observer. setData is the JSON-marshaled full score set. entries maps target pubkey hex to JSON-marshaled individual score entries. Uses WriteBatch to avoid exceeding Badger's transaction size limit on large graphs.

func (*GraphAdapter) TraverseEventEvent ¶

func (a *GraphAdapter) TraverseEventEvent(seedEventID []byte, maxDepth int, direction string) (graph.GraphResultI, error)

TraverseEventEvent implements graph.GraphDatabase.

func (*GraphAdapter) TraversePubkeyEvent ¶

func (a *GraphAdapter) TraversePubkeyEvent(seedPubkey []byte, maxDepth int, direction string) (graph.GraphResultI, error)

TraversePubkeyEvent implements graph.GraphDatabase.

func (*GraphAdapter) TraversePubkeyPubkey ¶

func (a *GraphAdapter) TraversePubkeyPubkey(seedPubkey []byte, maxDepth int, direction string) (graph.GraphResultI, error)

TraversePubkeyPubkey implements graph.GraphDatabase. Uses the ppg/gpp materialized index for single-hop prefix scans.

func (*GraphAdapter) TraversePubkeyPubkeyBaseline ¶

func (a *GraphAdapter) TraversePubkeyPubkeyBaseline(seedPubkey []byte, maxDepth int, direction string) (graph.GraphResultI, error)

TraversePubkeyPubkeyBaseline implements graph.GraphDatabase. Uses multi-hop NIP-01 queries (no ppg/gpp index) for benchmark comparison.

func (*GraphResult) AddEventAtDepth ¶

func (r *GraphResult) AddEventAtDepth(eventIDHex string, depth int) bool

AddEventAtDepth adds an event ID to the result at the specified depth if not already seen. Returns true if the event was added (first time seen), false if already exists.

func (*GraphResult) AddInboundRef ¶

func (r *GraphResult) AddInboundRef(kind uint16, targetIDHex string, referencingEventIDHex string)

AddInboundRef records an inbound reference from a referencing event to a target.

func (*GraphResult) AddOutboundRef ¶

func (r *GraphResult) AddOutboundRef(kind uint16, sourceIDHex string, referencedEventIDHex string)

AddOutboundRef records an outbound reference from a source event to a referenced event.

func (*GraphResult) AddPubkeyAtDepth ¶

func (r *GraphResult) AddPubkeyAtDepth(pubkeyHex string, depth int) bool

AddPubkeyAtDepth adds a pubkey to the result at the specified depth if not already seen. Returns true if the pubkey was added (first time seen), false if already exists.

func (*GraphResult) GetAllEvents ¶

func (r *GraphResult) GetAllEvents() []string

GetAllEvents returns all event IDs discovered across all depths.

func (*GraphResult) GetAllPubkeys ¶

func (r *GraphResult) GetAllPubkeys() []string

GetAllPubkeys returns all pubkeys discovered across all depths.

func (*GraphResult) GetDepthsSorted ¶

func (r *GraphResult) GetDepthsSorted() []int

GetDepthsSorted returns all depths that have pubkeys, sorted ascending.

func (*GraphResult) GetEventDepth ¶

func (r *GraphResult) GetEventDepth(eventIDHex string) int

GetEventDepth returns the depth at which an event was first discovered. Returns 0 if the event was not found.

func (*GraphResult) GetEventDepthsSorted ¶

func (r *GraphResult) GetEventDepthsSorted() []int

GetEventDepthsSorted returns all depths that have events, sorted ascending.

func (*GraphResult) GetEventsAtDepth ¶

func (r *GraphResult) GetEventsAtDepth(depth int) []string

GetEventsAtDepth returns events at a specific depth, or empty slice if none.

func (*GraphResult) GetEventsByDepth ¶

func (r *GraphResult) GetEventsByDepth() map[int][]string

GetEventsByDepth returns the EventsByDepth map for external access.

func (*GraphResult) GetInboundRefs ¶

func (r *GraphResult) GetInboundRefs() map[uint16]map[string][]string

GetInboundRefs returns the InboundRefs map for external access.

func (*GraphResult) GetInboundRefsSorted ¶

func (r *GraphResult) GetInboundRefsSorted(kind uint16) []RefAggregation

GetInboundRefsSorted returns inbound refs for a kind, sorted by count descending.

func (*GraphResult) GetOutboundRefs ¶

func (r *GraphResult) GetOutboundRefs() map[uint16]map[string][]string

GetOutboundRefs returns the OutboundRefs map for external access.

func (*GraphResult) GetOutboundRefsSorted ¶

func (r *GraphResult) GetOutboundRefsSorted(kind uint16) []RefAggregation

GetOutboundRefsSorted returns outbound refs for a kind, sorted by count descending.

func (*GraphResult) GetPubkeyDepth ¶

func (r *GraphResult) GetPubkeyDepth(pubkeyHex string) int

GetPubkeyDepth returns the depth at which a pubkey was first discovered. Returns 0 if the pubkey was not found.

func (*GraphResult) GetPubkeysAtDepth ¶

func (r *GraphResult) GetPubkeysAtDepth(depth int) []string

GetPubkeysAtDepth returns pubkeys at a specific depth, or empty slice if none.

func (*GraphResult) GetPubkeysByDepth ¶

func (r *GraphResult) GetPubkeysByDepth() map[int][]string

GetPubkeysByDepth returns the PubkeysByDepth map for external access.

func (*GraphResult) GetTotalEvents ¶

func (r *GraphResult) GetTotalEvents() int

GetTotalEvents returns the total event count for external access.

func (*GraphResult) GetTotalPubkeys ¶

func (r *GraphResult) GetTotalPubkeys() int

GetTotalPubkeys returns the total pubkey count for external access.

func (*GraphResult) HasEvent ¶

func (r *GraphResult) HasEvent(eventIDHex string) bool

HasEvent returns true if the event has been discovered at any depth.

func (*GraphResult) HasPubkey ¶

func (r *GraphResult) HasPubkey(pubkeyHex string) bool

HasPubkey returns true if the pubkey has been discovered at any depth.

func (*GraphResult) ToDepthArrays ¶

func (r *GraphResult) ToDepthArrays() [][]string

ToDepthArrays converts the result to the response format: array of arrays. Index 0 = depth 1 pubkeys, Index 1 = depth 2 pubkeys, etc. Empty arrays are included for depths with no pubkeys to maintain index alignment.

func (*GraphResult) ToEventDepthArrays ¶

func (r *GraphResult) ToEventDepthArrays() [][]string

ToEventDepthArrays converts event results to the response format: array of arrays. Index 0 = depth 1 events, Index 1 = depth 2 events, etc.

func (*HealthReport) String ¶

func (r *HealthReport) String() string

String returns a human-readable health report.

func (*LRUCache[K, V]) Clear ¶

func (c *LRUCache[K, V]) Clear()

Clear removes all entries from the cache.

func (*LRUCache[K, V]) Contains ¶

func (c *LRUCache[K, V]) Contains(key K) bool

Contains returns true if the key exists in the cache without updating LRU order.

func (*LRUCache[K, V]) Delete ¶

func (c *LRUCache[K, V]) Delete(key K)

Delete removes an entry from the cache.

func (*LRUCache[K, V]) Get ¶

func (c *LRUCache[K, V]) Get(key K) (value V, found bool)

Get retrieves a value by key and marks it as recently used.

func (*LRUCache[K, V]) Len ¶

func (c *LRUCache[K, V]) Len() int

Len returns the current number of entries in the cache.

func (*LRUCache[K, V]) MaxSize ¶

func (c *LRUCache[K, V]) MaxSize() int

MaxSize returns the maximum capacity of the cache.

func (*LRUCache[K, V]) Put ¶

func (c *LRUCache[K, V]) Put(key K, value V)

Put adds or updates a value, evicting the LRU entry if at capacity.

func (*LRUCache[K, V]) Shutdown ¶

func (c *LRUCache[K, V]) Shutdown()

Shutdown stops the actor goroutine.

func (*ManagedACL) GetRelayConfig ¶

func (m *ManagedACL) GetRelayConfig() (ManagedACLConfig, error)

GetRelayConfig returns relay configuration

func (*ManagedACL) IsEventAllowed ¶

func (m *ManagedACL) IsEventAllowed(eventID string) (bool, error)

Check if an event is explicitly allowed

func (*ManagedACL) IsEventBanned ¶

func (m *ManagedACL) IsEventBanned(eventID string) (bool, error)

Check if an event is banned

func (*ManagedACL) IsIPBlocked ¶

func (m *ManagedACL) IsIPBlocked(ip string) (bool, error)

Check if an IP is blocked

func (*ManagedACL) IsKindAllowed ¶

func (m *ManagedACL) IsKindAllowed(kind int) (bool, error)

Check if a kind is allowed

func (*ManagedACL) IsPubkeyAllowed ¶

func (m *ManagedACL) IsPubkeyAllowed(pubkey string) (bool, error)

Check if a pubkey is explicitly allowed

func (*ManagedACL) IsPubkeyBanned ¶

func (m *ManagedACL) IsPubkeyBanned(pubkey string) (bool, error)

Check if a pubkey is banned

func (*ManagedACL) ListAllowedEvents ¶

func (m *ManagedACL) ListAllowedEvents() ([]AllowedEvent, error)

ListAllowedEvents returns all allowed events

func (*ManagedACL) ListAllowedKinds ¶

func (m *ManagedACL) ListAllowedKinds() ([]int, error)

ListAllowedKinds returns all allowed kinds

func (*ManagedACL) ListAllowedPubkeys ¶

func (m *ManagedACL) ListAllowedPubkeys() ([]AllowedPubkey, error)

ListAllowedPubkeys returns all allowed pubkeys

func (*ManagedACL) ListBannedEvents ¶

func (m *ManagedACL) ListBannedEvents() ([]BannedEvent, error)

ListBannedEvents returns all banned events

func (*ManagedACL) ListBannedPubkeys ¶

func (m *ManagedACL) ListBannedPubkeys() ([]BannedPubkey, error)

ListBannedPubkeys returns all banned pubkeys

func (*ManagedACL) ListBlockedIPs ¶

func (m *ManagedACL) ListBlockedIPs() ([]BlockedIP, error)

ListBlockedIPs returns all blocked IPs

func (*ManagedACL) ListEventsNeedingModeration ¶

func (m *ManagedACL) ListEventsNeedingModeration() ([]EventNeedingModeration, error)

ListEventsNeedingModeration returns all events needing moderation

func (*ManagedACL) RemoveAllowedEvent ¶

func (m *ManagedACL) RemoveAllowedEvent(eventID string) error

RemoveAllowedEvent removes an allowed event from the database

func (*ManagedACL) RemoveAllowedKind ¶

func (m *ManagedACL) RemoveAllowedKind(kind int) error

RemoveAllowedKind removes an allowed kind from the database

func (*ManagedACL) RemoveAllowedPubkey ¶

func (m *ManagedACL) RemoveAllowedPubkey(pubkey string) error

RemoveAllowedPubkey removes an allowed pubkey from the database

func (*ManagedACL) RemoveBannedEvent ¶

func (m *ManagedACL) RemoveBannedEvent(eventID string) error

RemoveBannedEvent removes a banned event from the database

func (*ManagedACL) RemoveBannedPubkey ¶

func (m *ManagedACL) RemoveBannedPubkey(pubkey string) error

RemoveBannedPubkey removes a banned pubkey from the database

func (*ManagedACL) RemoveBlockedIP ¶

func (m *ManagedACL) RemoveBlockedIP(ip string) error

RemoveBlockedIP removes a blocked IP from the database

func (*ManagedACL) RemoveEventNeedingModeration ¶

func (m *ManagedACL) RemoveEventNeedingModeration(eventID string) error

RemoveEventNeedingModeration removes an event from moderation queue

func (*ManagedACL) SaveAllowedEvent ¶

func (m *ManagedACL) SaveAllowedEvent(eventID string, reason string) error

SaveAllowedEvent saves an allowed event to the database

func (*ManagedACL) SaveAllowedKind ¶

func (m *ManagedACL) SaveAllowedKind(kind int) error

SaveAllowedKind saves an allowed kind to the database

func (*ManagedACL) SaveAllowedPubkey ¶

func (m *ManagedACL) SaveAllowedPubkey(pubkey string, reason string) error

SaveAllowedPubkey saves an allowed pubkey to the database

func (*ManagedACL) SaveBannedEvent ¶

func (m *ManagedACL) SaveBannedEvent(eventID string, reason string) error

SaveBannedEvent saves a banned event to the database

func (*ManagedACL) SaveBannedPubkey ¶

func (m *ManagedACL) SaveBannedPubkey(pubkey string, reason string) error

SaveBannedPubkey saves a banned pubkey to the database

func (*ManagedACL) SaveBlockedIP ¶

func (m *ManagedACL) SaveBlockedIP(ip string, reason string) error

SaveBlockedIP saves a blocked IP to the database

func (*ManagedACL) SaveEventNeedingModeration ¶

func (m *ManagedACL) SaveEventNeedingModeration(eventID string, reason string) error

SaveEventNeedingModeration saves an event that needs moderation

func (*ManagedACL) SaveRelayConfig ¶

func (m *ManagedACL) SaveRelayConfig(config ManagedACLConfig) error

SaveRelayConfig saves relay configuration

func (*NRCAuthorizer) GetNRCClientByPubkey ¶

func (a *NRCAuthorizer) GetNRCClientByPubkey(derivedPubkey []byte) (id string, label string, found bool, err error)

GetNRCClientByPubkey looks up an authorized client by their derived pubkey. Returns the client ID, label, and whether the client was found.

func (*NRCAuthorizer) UpdateNRCClientLastUsed ¶

func (a *NRCAuthorizer) UpdateNRCClientLastUsed(id string) error

UpdateNRCClientLastUsed updates the last used timestamp for tracking.

func (*NRCEventAuthorizer) GetNRCClientByPubkey ¶

func (a *NRCEventAuthorizer) GetNRCClientByPubkey(derivedPubkey []byte) (id string, label string, found bool, err error)

GetNRCClientByPubkey looks up an authorized client by their derived pubkey.

func (*NRCEventAuthorizer) UpdateNRCClientLastUsed ¶

func (a *NRCEventAuthorizer) UpdateNRCClientLastUsed(id string) error

UpdateNRCClientLastUsed updates the last used timestamp for tracking.

func (*NRCEventStore) CreateNRCConnection ¶

func (s *NRCEventStore) CreateNRCConnection(label string, rendezvousURL string, createdBy []byte) (*NRCConnection, error)

CreateNRCConnection generates a new NRC connection with a random secret.

func (*NRCEventStore) DeleteNRCConnection ¶

func (s *NRCEventStore) DeleteNRCConnection(id string) error

DeleteNRCConnection removes an NRC connection by deleting its event.

func (*NRCEventStore) GetAllNRCConnections ¶

func (s *NRCEventStore) GetAllNRCConnections() ([]*NRCConnection, error)

GetAllNRCConnections returns all NRC connections.

func (*NRCEventStore) GetNRCAuthorizedSecrets ¶

func (s *NRCEventStore) GetNRCAuthorizedSecrets() (map[string]string, error)

GetNRCAuthorizedSecrets returns a map of derived pubkeys to labels.

func (*NRCEventStore) GetNRCConnection ¶

func (s *NRCEventStore) GetNRCConnection(id string) (*NRCConnection, error)

GetNRCConnection retrieves an NRC connection by ID.

func (*NRCEventStore) GetNRCConnectionByDerivedPubkey ¶

func (s *NRCEventStore) GetNRCConnectionByDerivedPubkey(derivedPubkey []byte) (*NRCConnection, error)

GetNRCConnectionByDerivedPubkey retrieves an NRC connection by its derived pubkey.

func (*NRCEventStore) GetNRCConnectionURI ¶

func (s *NRCEventStore) GetNRCConnectionURI(conn *NRCConnection, relayPubkey []byte) (string, error)

GetNRCConnectionURI generates the full connection URI for a connection. Uses the rendezvous URL stored in the connection.

func (*NRCEventStore) SaveNRCConnection ¶

func (s *NRCEventStore) SaveNRCConnection(conn *NRCConnection) error

SaveNRCConnection stores an NRC connection as an event.

func (*NRCEventStore) UpdateNRCConnectionLastUsed ¶

func (s *NRCEventStore) UpdateNRCConnectionLastUsed(id string) error

UpdateNRCConnectionLastUsed updates the last used timestamp.

func (*PaidACL) ClaimAlias ¶

func (p *PaidACL) ClaimAlias(alias, pubkeyHex string) error

ClaimAlias atomically claims an alias for a pubkey. Returns an error if the alias is already taken by another pubkey. One pubkey can have multiple aliases — each claim appends to the list.

func (*PaidACL) DeleteSubscription ¶

func (p *PaidACL) DeleteSubscription(pubkeyHex string) error

DeleteSubscription removes a subscription.

func (*PaidACL) GetAliasByPubkey ¶

func (p *PaidACL) GetAliasByPubkey(pubkeyHex string) (string, error)

GetAliasByPubkey returns the first alias for a pubkey, or "" if none.

func (*PaidACL) GetAliasesByPubkey ¶

func (p *PaidACL) GetAliasesByPubkey(pubkeyHex string) ([]string, error)

GetAliasesByPubkey returns all aliases for a pubkey.

func (*PaidACL) GetPubkeyByAlias ¶

func (p *PaidACL) GetPubkeyByAlias(alias string) (string, error)

GetPubkeyByAlias returns the pubkey for an alias, or "" if not found.

func (*PaidACL) GetSubscription ¶

func (p *PaidACL) GetSubscription(pubkeyHex string) (*PaidSubscription, error)

GetSubscription returns the subscription for a pubkey.

func (*PaidACL) IsAliasTaken ¶

func (p *PaidACL) IsAliasTaken(alias string) (bool, error)

IsAliasTaken returns true if the alias is claimed by any pubkey.

func (*PaidACL) ListSubscriptions ¶

func (p *PaidACL) ListSubscriptions() ([]*PaidSubscription, error)

ListSubscriptions returns all subscriptions.

func (*PaidACL) SaveSubscription ¶

func (p *PaidACL) SaveSubscription(sub *PaidSubscription) error

SaveSubscription saves or updates a subscription.

func (*PaidSubscription) IsActive ¶

func (s *PaidSubscription) IsActive() bool

IsActive returns true if the subscription has not expired.

func (*RepairReport) String ¶

func (r *RepairReport) String() string

String returns a human-readable repair report.

func (*SerialCache) CacheEventId ¶

func (c *SerialCache) CacheEventId(serial uint64, eventId []byte)

CacheEventId adds an event ID to the cache in both directions.

func (*SerialCache) CachePubkey ¶

func (c *SerialCache) CachePubkey(serial uint64, pubkey []byte)

CachePubkey adds a pubkey to the cache in both directions.

func (*SerialCache) GetEventIdBySerial ¶

func (c *SerialCache) GetEventIdBySerial(serial uint64) (eventId []byte, found bool)

GetEventIdBySerial returns the event ID for a serial from cache.

func (*SerialCache) GetPubkeyBySerial ¶

func (c *SerialCache) GetPubkeyBySerial(serial uint64) (pubkey []byte, found bool)

GetPubkeyBySerial returns the pubkey for a serial from cache.

func (*SerialCache) GetSerialByEventId ¶

func (c *SerialCache) GetSerialByEventId(eventId []byte) (serial uint64, found bool)

GetSerialByEventId returns the serial for an event ID from cache.

func (*SerialCache) GetSerialByPubkey ¶

func (c *SerialCache) GetSerialByPubkey(pubkey []byte) (serial uint64, found bool)

GetSerialByPubkey returns the serial for a pubkey from cache.

func (*SerialCache) Stats ¶

func (c *SerialCache) Stats() SerialCacheStats

Stats returns statistics about the serial cache.

func (*WireGuardPeer) ClientIP ¶

func (p *WireGuardPeer) ClientIP(pool *wireguard.SubnetPool) string

ClientIP returns the derived client IP for this peer's subnet.

func (*WireGuardPeer) ServerIP ¶

func (p *WireGuardPeer) ServerIP(pool *wireguard.SubnetPool) string

ServerIP returns the derived server IP for this peer's subnet.