database

Jan 22, 2026

Changes in this version

+ func RegisterGRPCFactory(...) — darwin/amd64, linux/amd64, windows/amd64

+ type BlobDescriptor struct

+ NIP94 [][]string

+ SHA256 string

+ Size int64

+ Type string

+ URL string

+ Uploaded int64

+ type BlobMetadata struct

+ Extension string

+ MimeType string

+ Pubkey []byte

+ Size int64

+ Uploaded int64

type D — darwin/amd64, linux/amd64, windows/amd64

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

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

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

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

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

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

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

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

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

type Database

+ DeleteBlob func(sha256Hash []byte, pubkey []byte) error

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

+ GetBlobMetadata func(sha256Hash []byte) (*BlobMetadata, error)

+ GetTotalBlobStorageUsed func(pubkey []byte) (totalMB int64, err error)

+ HasBlob func(sha256Hash []byte) (exists bool, err error)

+ ListAllBlobUserStats func() ([]*UserBlobStats, error)

+ ListBlobs func(pubkey []byte, since, until int64) ([]*BlobDescriptor, error)

+ SaveBlob func(sha256Hash []byte, data []byte, pubkey []byte, mimeType string, ...) error

+ SaveBlobReport func(sha256Hash []byte, reportData []byte) error

type DatabaseConfig — darwin/amd64, linux/amd64, windows/amd64

+ GRPCConnectTimeout time.Duration

+ GRPCServerAddress string

+ type UserBlobStats struct

+ BlobCount int64

+ PubkeyHex string

+ TotalSizeBytes int64

Jan 21, 2026

Changes in this version

+ const DefaultMaxConcurrentQueries — darwin/amd64, linux/amd64, windows/amd64

type D — darwin/amd64, linux/amd64, windows/amd64

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

+ func (d *D) ReleaseQuerySlot()

Jan 14, 2026

Changes in this version

type CuratingACL — darwin/amd64, linux/amd64, windows/amd64

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

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

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

+ type EventSummary struct — darwin/amd64, linux/amd64, windows/amd64

+ Content string

+ CreatedAt int64

+ ID string

+ Kind int

+ type ScanResult struct — darwin/amd64, linux/amd64, windows/amd64

+ Skipped int

+ TotalEvents int

+ TotalPubkeys int

Jan 9, 2026

Changes in this version

+ const MaxContentLength — darwin/amd64, linux/amd64, windows/amd64

+ const MaxTagElementLength — darwin/amd64, linux/amd64, windows/amd64

+ const MaxTagElements — darwin/amd64, linux/amd64, windows/amd64

+ const MaxTagsPerEvent — darwin/amd64, linux/amd64, windows/amd64

+ var ErrContentTooLarge = errors.New("corrupt data: content too large") — darwin/amd64, linux/amd64, windows/amd64

+ var ErrTagElementTooLong = errors.New("corrupt data: tag element too long") — darwin/amd64, linux/amd64, windows/amd64

+ var ErrTooManyTagElems = errors.New("corrupt data: too many tag elements") — darwin/amd64, linux/amd64, windows/amd64

+ var ErrTooManyTags = errors.New("corrupt data: too many tags") — darwin/amd64, linux/amd64, windows/amd64

+ var ErrUnknownTagElemType = errors.New("corrupt data: unknown tag element type") — darwin/amd64, linux/amd64, windows/amd64

Jan 7, 2026

Changes in this version

type D — darwin/amd64, linux/amd64, windows/amd64

+ func (d *D) CreateNRCConnection(label string, useCashu bool) (*NRCConnection, error)

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

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

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

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

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

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

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

+ type NRCConnection struct — darwin/amd64, linux/amd64, windows/amd64

+ CreatedAt int64

+ ID string

+ Label string

+ LastUsed int64

+ Secret []byte

+ UseCashu bool

Jan 6, 2026

Changes in this version

+ func RegisterBboltFactory(...) — darwin/amd64, linux/amd64, windows/amd64

type DatabaseConfig — darwin/amd64, linux/amd64, windows/amd64

+ BboltBatchMaxBytes int64

+ BboltBatchMaxEvents int

+ BboltBloomSizeMB int

+ BboltFlushTimeout time.Duration

+ BboltMmapSize int

+ BboltNoSync bool

Jan 5, 2026

Changes in this version

+ type BlacklistedPubkey struct — darwin/amd64, linux/amd64, windows/amd64

+ Added time.Time

+ Pubkey string

+ Reason string

+ type CuratingACL struct — darwin/amd64, linux/amd64, windows/amd64

+ func NewCuratingACL(db *D) *CuratingACL

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

+ func (c *CuratingACL) CleanupExpiredIPBlocks() error

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type CuratingBlockedIP struct — darwin/amd64, linux/amd64, windows/amd64

+ Added time.Time

+ ExpiresAt time.Time

+ IP string

+ Reason string

+ type CuratingConfig struct — darwin/amd64, linux/amd64, windows/amd64

+ AllowedKinds []int

+ AllowedRanges []string

+ ConfigEventID string

+ ConfigPubkey string

+ ConfiguredAt int64

+ DailyLimit int

+ FirstBanHours int

+ IPDailyLimit int

+ KindCategories []string

+ SecondBanHours int

type D — darwin/amd64, linux/amd64, windows/amd64

+ func (d *D) BackfillETagGraph()

type GraphAdapter — darwin/amd64, linux/amd64, windows/amd64

+ func (a *GraphAdapter) CollectInboundRefs(result graph.GraphResultI, depth int, kinds []uint16) error

+ func (a *GraphAdapter) CollectOutboundRefs(result graph.GraphResultI, depth int, kinds []uint16) error

type GraphResult — darwin/amd64, linux/amd64, windows/amd64

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

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

+ type IPEventCount struct — darwin/amd64, linux/amd64, windows/amd64

+ Count int

+ Date string

+ IP string

+ LastEvent time.Time

+ type IPOffense struct — darwin/amd64, linux/amd64, windows/amd64

+ IP string

+ LastOffense time.Time

+ OffenseCount int

+ PubkeysHit []string

+ type PubkeyEventCount struct — darwin/amd64, linux/amd64, windows/amd64

+ Count int

+ Date string

+ LastEvent time.Time

+ Pubkey string

+ type SpamEvent struct — darwin/amd64, linux/amd64, windows/amd64

+ Added time.Time

+ EventID string

+ Pubkey string

+ Reason string

+ type TrustedPubkey struct — darwin/amd64, linux/amd64, windows/amd64

+ Added time.Time

+ Note string

+ Pubkey string

+ type UnclassifiedUser struct — darwin/amd64, linux/amd64, windows/amd64

+ EventCount int

+ LastEvent time.Time

+ Pubkey string

Jan 3, 2026

Changes in this version

type D — darwin/amd64, linux/amd64, windows/amd64

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

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

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

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

type Database

+ GetEventAccessInfo func(serial uint64) (lastAccess int64, accessCount uint32, err error)

+ GetLeastAccessedEvents func(limit int, minAgeSec int64) (serials []uint64, err error)

+ RecordEventAccess func(serial uint64, connectionID string) error

Dec 29, 2025

Changes in this version

type DatabaseConfig

+ Neo4jFetchSize int

+ Neo4jMaxConnPoolSize int

+ Neo4jMaxTxRetrySeconds int

+ Neo4jQueryResultLimit int

Dec 27, 2025

Changes in this version

type D — darwin/amd64, linux/amd64, windows/amd64

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type WireGuardAccessLog struct — darwin/amd64, linux/amd64, windows/amd64

+ NostrPubkey []byte

+ RemoteAddr string

+ Sequence uint32

+ Timestamp int64

+ WGPublicKey []byte

+ type WireGuardPeer struct — darwin/amd64, linux/amd64, windows/amd64

+ CreatedAt int64

+ NostrPubkey []byte

+ Sequence uint32

+ WGPrivateKey []byte

+ WGPublicKey []byte

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

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

+ type WireGuardRevokedKey struct — darwin/amd64, linux/amd64, windows/amd64

+ AccessCount int

+ CreatedAt int64

+ LastAccessAt int64

+ NostrPubkey []byte

+ RevokedAt int64

+ Sequence uint32

+ WGPublicKey []byte

Dec 25, 2025

Changes in this version

+ type LRUCache struct — darwin/amd64, linux/amd64, windows/amd64

+ func NewLRUCache[K comparable, V any](maxSize int) *LRUCache[K, V]

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

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

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

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

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

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

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

Dec 22, 2025

Changes in this version

type D — darwin/amd64, linux/amd64, windows/amd64

+ func (d *D) RebuildWordIndexesWithNormalization()

Dec 14, 2025

Changes in this version

+ const WriteOpType — darwin/amd64, linux/amd64, windows/amd64

type D — darwin/amd64, linux/amd64, windows/amd64

+ func (d *D) SetRateLimiter(limiter RateLimiterInterface)

+ type RateLimiterInterface interface — darwin/amd64, linux/amd64, windows/amd64

+ IsEnabled func() bool

+ Wait func(ctx context.Context, opType int) time.Duration

Dec 5, 2025

Changes in this version

type DatabaseConfig — darwin/amd64, linux/amd64, windows/amd64

+ QueryCacheDisabled bool

Dec 4, 2025

Changes in this version

+ var ErrEventNotFound = errors.New("event not found in database") — darwin/amd64, linux/amd64, windows/amd64

+ var ErrPubkeyNotFound = errors.New("pubkey not found in database") — darwin/amd64, linux/amd64, windows/amd64

type D — darwin/amd64, linux/amd64, windows/amd64

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type GraphAdapter struct — darwin/amd64, linux/amd64, windows/amd64

+ func NewGraphAdapter(db *D) *GraphAdapter

+ func (a *GraphAdapter) FindMentions(pubkey []byte, kinds []uint16) (graph.GraphResultI, error)

+ func (a *GraphAdapter) TraverseFollowers(seedPubkey []byte, maxDepth int) (graph.GraphResultI, error)

+ func (a *GraphAdapter) TraverseFollows(seedPubkey []byte, maxDepth int) (graph.GraphResultI, error)

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

+ type GraphResult struct — darwin/amd64, linux/amd64, windows/amd64

+ EventsByDepth map[int][]string

+ FirstSeenEvent map[string]int

+ FirstSeenPubkey map[string]int

+ InboundRefs map[uint16]map[string][]string

+ OutboundRefs map[uint16]map[string][]string

+ PubkeysByDepth map[int][]string

+ TotalEvents int

+ TotalPubkeys int

+ func NewGraphResult() *GraphResult

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (r *GraphResult) GetTotalEvents() int

+ func (r *GraphResult) GetTotalPubkeys() int

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

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

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

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

+ type RefAggregation struct — darwin/amd64, linux/amd64, windows/amd64

+ RefCount int

+ RefEventIDs []string

+ RefKind uint16

+ TargetAuthor string

+ TargetDepth int

+ TargetEventID string

Dec 3, 2025

Changes in this version

+ const CompactFormatVersion — darwin/amd64, linux/amd64, windows/amd64

+ const TagElementEventIdFull — darwin/amd64, linux/amd64, windows/amd64

+ const TagElementEventSerial — darwin/amd64, linux/amd64, windows/amd64

+ const TagElementPubkeySerial — darwin/amd64, linux/amd64, windows/amd64

+ const TagElementRaw — darwin/amd64, linux/amd64, windows/amd64

+ func GetCumulativeCompactSavings() int64 — darwin/amd64, linux/amd64, windows/amd64

+ func MarshalCompactEvent(ev *event.E, resolver SerialResolver) (data []byte, err error) — darwin/amd64, linux/amd64, windows/amd64

+ func ResetCompactSavingsCounter() — darwin/amd64, linux/amd64, windows/amd64

+ func TrackCompactSaving(legacySize, compactSize int) — darwin/amd64, linux/amd64, windows/amd64

+ func UnmarshalCompactEvent(data []byte, eventId []byte, resolver SerialResolver) (ev *event.E, err error) — darwin/amd64, linux/amd64, windows/amd64

+ type CompactStorageStats struct — darwin/amd64, linux/amd64, windows/amd64

+ AverageCompact float64

+ AverageLegacy float64

+ BytesSaved int64

+ CompactBytes int64

+ CompactEvents int64

+ LegacyBytes int64

+ LegacyEvents int64

+ PercentSaved float64

+ SerialEventIdBytes int64

+ SerialEventIdEntries int64

+ TotalEvents int64

type D — darwin/amd64, linux/amd64, windows/amd64

+ func (d *D) CleanupLegacyEventStorage()

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

+ func (d *D) ConvertToCompactEventFormat()

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

+ func (d *D) LogCompactSavings()

+ func (d *D) SerialCacheStats() SerialCacheStats

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

type DatabaseConfig — darwin/amd64, linux/amd64, windows/amd64

+ SerialCacheEventIds int

+ SerialCachePubkeys int

+ ZSTDLevel int

+ type DatabaseSerialResolver struct — darwin/amd64, linux/amd64, windows/amd64

+ func NewDatabaseSerialResolver(db *D, cache *SerialCache) *DatabaseSerialResolver

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

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

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

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

+ type SerialCache struct — darwin/amd64, linux/amd64, windows/amd64

+ func NewSerialCache(maxPubkeys, maxEventIds int) *SerialCache

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

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

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

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

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

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

+ func (c *SerialCache) Stats() SerialCacheStats

+ type SerialCacheStats struct — darwin/amd64, linux/amd64, windows/amd64

+ EventIdMemoryBytes int

+ EventIdsCached int

+ EventIdsMaxSize int

+ PubkeyMemoryBytes int

+ PubkeysCached int

+ PubkeysMaxSize int

+ TotalMemoryBytes int

+ type SerialResolver interface — darwin/amd64, linux/amd64, windows/amd64

+ GetEventIdBySerial func(serial uint64) (eventId []byte, err error)

+ GetEventSerialById func(eventId []byte) (serial uint64, found bool, err error)

+ GetOrCreatePubkeySerial func(pubkey []byte) (serial uint64, err error)

+ GetPubkeyBySerial func(serial uint64) (pubkey []byte, err error)

Dec 3, 2025

Changes in this version

+ func RegisterWasmDBFactory(...)

Dec 2, 2025

Changes in this version

type D

+ func NewWithConfig(ctx context.Context, cancel context.CancelFunc, cfg *DatabaseConfig) (d *D, err error)

type Database

+ func NewDatabaseWithConfig(ctx context.Context, cancel context.CancelFunc, dbType string, ...) (Database, error)

+ type DatabaseConfig struct

+ BlockCacheMB int

+ DataDir string

+ DgraphURL string

+ IndexCacheMB int

+ InlineEventThreshold int

+ LogLevel string

+ Neo4jPassword string

+ Neo4jURI string

+ Neo4jUser string

+ QueryCacheMaxAge time.Duration

+ QueryCacheSizeMB int

Nov 27, 2025

Changes in this version

type D

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

Nov 26, 2025

Changes in this version

+ const BinaryEncodedLen

+ const HashLen

+ const HexEncodedLen

+ func BinaryToHex(binVal []byte) []byte

+ func HexToBinary(hexVal []byte) []byte

+ func IsBinaryEncoded(val []byte) bool

+ func IsBinaryOptimizedTag(key byte) bool

+ func IsValidHexValue(b []byte) bool

+ func NormalizeFilter(f *filter.F) *filter.F

+ func NormalizeFilterTag(t *tag.T) *tag.T

+ func NormalizeFilterTags(tags *tag.S) *tag.S

+ func NormalizeTagToHex(val []byte) []byte

+ func NormalizeTagValue(key byte, val []byte) []byte

+ func NormalizeTagValueForHash(key byte, valueBytes []byte) []byte

+ func TagValuesMatch(key byte, eventVal, filterVal []byte) bool

+ func TagValuesMatchUsingTagMethods(eventTag *tag.T, filterVal []byte) bool

Nov 25, 2025

Changes in this version

type D

+ func (d *D) ReencodeEventsWithOptimizedTags()

Nov 20, 2025

Changes in this version

+ func CanUsePTagGraph(f *filter.F) bool

type D

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

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

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

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

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

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

type Database

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

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

Nov 18, 2025

Changes in this version

+ func RegisterNeo4jFactory(...)

Nov 16, 2025

Changes in this version

+ func RegisterDgraphFactory(...)

type D

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

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

+ func (d *D) InvalidateQueryCache()

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

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

+ type Database interface

+ AddNIP43Member func(pubkey []byte, inviteCode string) error

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

+ CheckForDeleted func(ev *event.E, admins [][]byte) error

+ Close func() error

+ CountEvents func(c context.Context, f *filter.F) (count int, approximate bool, err error)

+ DeleteEvent func(c context.Context, eid []byte) error

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

+ DeleteExpired func()

+ DeleteInviteCode func(code string) error

+ DeleteMarker func(key string) error

+ EventIdsBySerial func(start uint64, count int) (evs []uint64, err error)

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

+ ExtendBlossomSubscription func(pubkey []byte, tier string, storageMB int64, daysExtended int) error

+ ExtendSubscription func(pubkey []byte, days int) error

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

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

+ GetAllNIP43Members func() ([][]byte, error)

+ GetBlossomStorageQuota func(pubkey []byte) (quotaMB int64, err error)

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

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

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

+ GetMarker func(key string) (value []byte, err error)

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

+ GetOrCreateRelayIdentitySecret func() (skb []byte, err error)

+ GetPaymentHistory func(pubkey []byte) ([]Payment, error)

+ GetRelayIdentitySecret func() (skb []byte, err error)

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

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

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

+ GetSerialsByRange func(idx Range) (serials types.Uint40s, err error)

+ GetSerialsFromFilter func(f *filter.F) (serials types.Uint40s, err error)

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

+ HasMarker func(key string) bool

+ Import func(rr io.Reader)

+ ImportEventsFromReader func(ctx context.Context, rr io.Reader) error

+ ImportEventsFromStrings func(ctx context.Context, eventJSONs []string, policyManager interface{ ... }) error

+ Init func(path string) error

+ InvalidateQueryCache func()

+ IsFirstTimeUser func(pubkey []byte) (bool, error)

+ IsNIP43Member func(pubkey []byte) (isMember bool, err error)

+ IsSubscriptionActive func(pubkey []byte) (bool, error)

+ Path func() string

+ ProcessDelete func(ev *event.E, admins [][]byte) error

+ PublishNIP43MembershipEvent func(kind int, pubkey []byte) error

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

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

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

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

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

+ QueryForSerials func(c context.Context, f *filter.F) (serials types.Uint40s, err error)

+ Ready func() <-chan struct{}

+ RecordPayment func(pubkey []byte, amount int64, invoice, preimage string) error

+ RemoveNIP43Member func(pubkey []byte) error

+ RunMigrations func()

+ SaveEvent func(c context.Context, ev *event.E) (exists bool, err error)

+ SetLogLevel func(level string)

+ SetMarker func(key string, value []byte) error

+ SetRelayIdentitySecret func(skb []byte) error

+ StoreInviteCode func(code string, expiresAt time.Time) error

+ Sync func() error

+ ValidateInviteCode func(code string) (valid bool, err error)

+ Wipe func() error

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

+ func NewDatabase(ctx context.Context, cancel context.CancelFunc, dbType string, dataDir string, ...) (Database, error)

Nov 14, 2025

Changes in this version

type D

+ func (d *D) ConvertSmallEventsToInline()

Nov 9, 2025

Changes in this version

type D

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

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

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

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

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

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

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

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

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

+ type NIP43Membership struct

+ AddedAt time.Time

+ InviteCode string

+ Pubkey []byte

Nov 5, 2025

Changes in this version

type D

+ func (d *D) CleanupEphemeralEvents()

Nov 3, 2025

Changes in this version

type D

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

+ func (d *D) ImportEventsFromStrings(ctx context.Context, eventJSONs []string) error

Nov 3, 2025

Changes in this version

type D

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

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

type Subscription

+ BlossomLevel string

+ BlossomStorage int64

Oct 20, 2025

Changes in this version

type D

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

Oct 16, 2025

Changes in this version

+ type AllowedEvent struct

+ Added time.Time

+ ID string

+ Reason string

+ type AllowedKind struct

+ Added time.Time

+ Kind int

+ type AllowedPubkey struct

+ Added time.Time

+ Pubkey string

+ Reason string

+ type BannedEvent struct

+ Added time.Time

+ ID string

+ Reason string

+ type BannedPubkey struct

+ Added time.Time

+ Pubkey string

+ Reason string

+ type BlockedIP struct

+ Added time.Time

+ IP string

+ Reason string

+ type EventNeedingModeration struct

+ Added time.Time

+ ID string

+ Reason string

+ type ManagedACL struct

+ func NewManagedACL(db *D) *ManagedACL

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type ManagedACLConfig struct

+ RelayDescription string

+ RelayIcon string

+ RelayName string

Oct 10, 2025

Changes in this version

type D

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

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

Oct 7, 2025

Changes in this version

+ var ErrMissingDTag = errors.New("event is missing a d tag identifier")

+ var ErrOlderThanExisting = errors.New("older than existing event")

type D

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

Oct 6, 2025

Changes in this version

type D

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

Oct 1, 2025

Changes in this version

+ func TokenHashes(content []byte) [][]byte

type D

+ func (d *D) UpdateWordIndexes()

Sep 23, 2025

Changes in this version

type D

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

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

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

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

Sep 21, 2025

Changes in this version

type D

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

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

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

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

Sep 20, 2025

Changes in this version

type D

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

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

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

Sep 12, 2025

Changes in this version

+ func CheckExpiration(ev *event.E) (expired bool)

+ func CreateIdHashFromData(data []byte) (i *types2.IdHash, err error)

+ func CreatePubHashFromData(data []byte) (p *types2.PubHash, err error)

+ func GetIndexesForEvent(ev *event.E, serial uint64) (idxs [][]byte, err error)

+ func IsHexString(data []byte) (isHex bool)

+ func NewLogger(logLevel int, label string) (l *logger)

+ type D struct

+ Logger *logger

+ func New(ctx context.Context, cancel context.CancelFunc, dataDir, logLevel string) (d *D, err error)

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

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

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

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

+ func (d *D) DeleteExpired()

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (d *D) Path() string

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

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

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

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

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

+ func (d *D) RunMigrations()

+ func (d *D) SaveEvent(c context.Context, ev *event.E) (kc, vc int, err error)

+ func (d *D) SetLogLevel(level string)

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

+ func (d *D) UpdateExpirationTags()

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

+ type Payment struct

+ Amount int64

+ Invoice string

+ Preimage string

+ Timestamp time.Time

+ type Range struct

+ End []byte

+ Start []byte

+ func GetIndexesFromFilter(f *filter.F) (idxs []Range, err error)

+ type Subscription struct

+ PaidUntil time.Time

+ TrialEnd time.Time