Class EventStore

An extended EventSet that handles replaceable events, delets, and models

Implements

IEventStore

Constructors

constructor

new EventStore(): EventStore
Returns EventStore
- Defined in packages/core/src/event-store/event-store.ts:68

Properties

`Optional` `Experimental`addressableLoader

addressableLoader?: (
pointer: AddressPointer,
) => Observable<Event> | Promise<undefined | Event>

A method that will be called when an addressable event isn't found in the store

database

database: EventSet

`Protected`deletedCoords

deletedCoords: Map<string, number> = ...

`Protected`deletedIds

deletedIds: Set<string> = ...

`Optional` `Experimental`eventLoader

eventLoader?: (
pointer: EventPointer,
) => Observable<Event> | Promise<undefined | Event>

A method that will be called when an event isn't found in the store

`Protected`expirations

expirations: Map<string, number> = ...

`Protected`expirationTimeout

expirationTimeout: null | number = null

insert$

insert$: Observable<Event>

A stream of new events added to the store

keepExpired

keepExpired: boolean = false

Enable this to keep expired events

keepOldVersions

keepOldVersions: boolean = false

Enable this to keep old versions of replaceable events

modelKeepWarm

modelKeepWarm: number = 60_000

How long a model should be kept "warm" while nothing is subscribed to it

`Protected`models

models: Map<ModelConstructor<any, any[]>, Map<string, Observable<any>>> = ...

A directory of all active models

`Protected`nextExpirationCheck

nextExpirationCheck: null | number = null

remove$

remove$: Observable<Event>

A stream of events that have been removed

`Optional` `Experimental`replaceableLoader

replaceableLoader?: (
pointer: AddressPointerWithoutD,
) => Observable<Event> | Promise<undefined | Event>

A method that will be called when a replaceable event isn't found in the store

update$

update$: Observable<Event>

A stream of events that have been updated

`Optional`verifyEvent

verifyEvent?: (event: Event) => boolean

A method used to verify new events before added them

Type declaration

- (event: Event): boolean
- Parameters
  - event: Event
  Returns boolean
  true if the event is valid, false if it should be ignored

Methods

add

add(event: Event, fromRelay?: string): null | Event
Adds an event to the store and update subscriptions
Parameters
- event: Event
- OptionalfromRelay: string
Returns null | Event
The existing event or the event that was added, if it was ignored returns null
Implementation of IEventStore.add
- Defined in packages/core/src/event-store/event-store.ts:197

`Protected`addExpiration

addExpiration(event: Event): void
Adds an event to the expiration map
Parameters
- event: Event
Returns void
- Defined in packages/core/src/event-store/event-store.ts:114

addressable

addressable(pointer: AddressPointer): Observable<undefined | Event>
Subscribe to an addressable event by pointer
Parameters
- pointer: AddressPointer
Returns Observable<undefined | Event>
Implementation of IEventStore.addressable
- Defined in packages/core/src/event-store/event-store.ts:437

blossomServers

blossomServers(user: string | ProfilePointer): Observable<URL[]>
Subscribe to a users blossom servers
Parameters
- user: string | ProfilePointer
Returns Observable<URL[]>
Implementation of IEventStore.blossomServers
- Defined in packages/core/src/event-store/event-store.ts:470

`Protected`checkDeleted

checkDeleted(event: string | Event): boolean
Parameters
- event: string | Event
Returns boolean
- Defined in packages/core/src/event-store/event-store.ts:96

claim

claim(event: Event, claim: any): void
Sets the claim on the event and touches it
Parameters
- event: Event
- claim: any
Returns void
Implementation of IEventStore.claim
- Defined in packages/core/src/event-store/event-store.ts:311

clearClaim

clearClaim(event: Event): void
Removes all claims on an event
Parameters
- event: Event
Returns void
Implementation of IEventStore.clearClaim
- Defined in packages/core/src/event-store/event-store.ts:323

comments

comments(event: Event): Observable<Event[]>
Subscribe to a event's comments
Parameters
- event: Event
Returns Observable<Event[]>
- Defined in packages/core/src/event-store/event-store.ts:486

contacts

contacts(user: string | ProfilePointer): Observable<ProfilePointer[]>
Subscribe to a users contacts
Parameters
- user: string | ProfilePointer
Returns Observable<ProfilePointer[]>
Implementation of IEventStore.contacts
- Defined in packages/core/src/event-store/event-store.ts:452

event

event(pointer: string | EventPointer): Observable<undefined | Event>
Creates a EventModel
Parameters
- pointer: string | EventPointer
Returns Observable<undefined | Event>
Implementation of IEventStore.event
- Defined in packages/core/src/event-store/event-store.ts:411

events

events(ids: string[]): Observable<Record<string, undefined | Event>>
Parameters
- ids: string[]
Returns Observable<Record<string, undefined | Event>>
Deprecated
use multiple EventModel instead
Implementation of IEventStore.events
- Defined in packages/core/src/event-store/event-store.ts:491

filters

filters(filters: Filter | Filter[], onlyNew?: boolean): Observable<Event>
Creates an observable that streams all events that match the filter
Parameters
- filters: Filter | Filter[]
- OptionalonlyNew: boolean = false
  Only subscribe to new events
Returns Observable<Event>
Implementation of IEventStore.filters
- Defined in packages/core/src/event-store/event-store.ts:377

getByFilters

getByFilters(filters: Filter | Filter[]): Set<Event>
Get all events matching a filter
Parameters
- filters: Filter | Filter[]
Returns Set<Event>
Implementation of IEventStore.getByFilters
- Defined in packages/core/src/event-store/event-store.ts:301

getEvent

getEvent(id: string): undefined | Event
Get an event by id from the store
Parameters
- id: string
Returns undefined | Event
Implementation of IEventStore.getEvent
- Defined in packages/core/src/event-store/event-store.ts:281

getReplaceable

getReplaceable(
    kind: number,
    pubkey: string,
    identifier?: string,
): undefined | Event
Gets the latest version of a replaceable event
Parameters
- kind: number
- pubkey: string
- Optionalidentifier: string
Returns undefined | Event
Implementation of IEventStore.getReplaceable
- Defined in packages/core/src/event-store/event-store.ts:291

getReplaceableHistory

getReplaceableHistory(
    kind: number,
    pubkey: string,
    identifier?: string,
): undefined | Event[]
Returns all versions of a replaceable event
Parameters
- kind: number
- pubkey: string
- Optionalidentifier: string
Returns undefined | Event[]
Implementation of IEventStore.getReplaceableHistory
- Defined in packages/core/src/event-store/event-store.ts:296

getTimeline

getTimeline(filters: Filter | Filter[]): Event[]
Returns a timeline of events that match filters
Parameters
- filters: Filter | Filter[]
Returns Event[]
Implementation of IEventStore.getTimeline
- Defined in packages/core/src/event-store/event-store.ts:306

`Protected`handleDeleteEvent

handleDeleteEvent(deleteEvent: Event): void
Parameters
- deleteEvent: Event
Returns void
- Defined in packages/core/src/event-store/event-store.ts:155

`Protected`handleExpiringEvent

handleExpiringEvent(event: Event): void
Parameters
- event: Event
Returns void
- Defined in packages/core/src/event-store/event-store.ts:121

hasEvent

hasEvent(id: string): boolean
Check if the store has an event by id
Parameters
- id: string
Returns boolean
Implementation of IEventStore.hasEvent
- Defined in packages/core/src/event-store/event-store.ts:276

hasReplaceable

hasReplaceable(kind: number, pubkey: string, d?: string): boolean
Check if the store has a replaceable event
Parameters
- kind: number
- pubkey: string
- Optionald: string
Returns boolean
Implementation of IEventStore.hasReplaceable
- Defined in packages/core/src/event-store/event-store.ts:286

isClaimed

isClaimed(event: Event): boolean
Checks if an event is claimed by anything
Parameters
- event: Event
Returns boolean
Implementation of IEventStore.isClaimed
- Defined in packages/core/src/event-store/event-store.ts:315

mailboxes

mailboxes(
user: string | ProfilePointer,
): Observable<undefined | { inboxes: string[]; outboxes: string[] }>
Subscribe to a users NIP-65 mailboxes
Parameters
- user: string | ProfilePointer
Returns Observable<undefined | { inboxes: string[]; outboxes: string[] }>
Implementation of IEventStore.mailboxes
- Defined in packages/core/src/event-store/event-store.ts:464

model

model<T extends unknown, Args extends any[]>(
constructor: ModelConstructor<T, Args>,
...args: Args,
): Observable<T>
Get or create a model on the event store
Type Parameters
- T extends unknown
- Args extends any[]
Parameters
- constructor: ModelConstructor<T, Args>
- ...args: Args
Returns Observable<T>
Implementation of IEventStore.model
- Defined in packages/core/src/event-store/event-store.ts:334

mutes

mutes(user: string | ProfilePointer): Observable<undefined | Mutes>
Subscribe to a users mutes
Parameters
- user: string | ProfilePointer
Returns Observable<undefined | Mutes>
Implementation of IEventStore.mutes
- Defined in packages/core/src/event-store/event-store.ts:458

profile

profile(user: string | ProfilePointer): Observable<undefined | ProfileContent>
Subscribe to a users profile
Parameters
- user: string | ProfilePointer
Returns Observable<undefined | ProfileContent>
Implementation of IEventStore.profile
- Defined in packages/core/src/event-store/event-store.ts:447

prune

prune(max?: number): number
Removes any event that is not being used by a subscription
Parameters
- Optionalmax: number
Returns number
- Defined in packages/core/src/event-store/event-store.ts:271

`Protected`pruneExpired

pruneExpired(): void
Remove expired events from the store

Returns void
- Defined in packages/core/src/event-store/event-store.ts:139

reactions

reactions(event: Event): Observable<Event[]>
Subscribe to an event's reactions
Parameters
- event: Event
Returns Observable<Event[]>
Implementation of IEventStore.reactions
- Defined in packages/core/src/event-store/event-store.ts:476

remove

remove(event: string | Event): boolean
Removes an event from the database and updates subscriptions
Parameters
- event: string | Event
Returns boolean
Implementation of IEventStore.remove
- Defined in packages/core/src/event-store/event-store.ts:261

removeClaim

removeClaim(event: Event, claim: any): void
Removes a claim from an event
Parameters
- event: Event
- claim: any
Returns void
Implementation of IEventStore.removeClaim
- Defined in packages/core/src/event-store/event-store.ts:319

removed

removed(id: string): Observable<never>
Returns an observable that completes when an event is removed
Parameters
- id: string
Returns Observable<never>
Implementation of IEventStore.removed
- Defined in packages/core/src/event-store/event-store.ts:389

replaceable

replaceable(
pointer: AddressPointer | AddressPointerWithoutD,
): Observable<undefined | Event>
Creates a ReplaceableModel
Parameters
- pointer: AddressPointer | AddressPointerWithoutD
Returns Observable<undefined | Event>
Implementation of IEventStore.replaceable
- Defined in packages/core/src/event-store/event-store.ts:418
replaceable(
    kind: number,
    pubkey: string,
    identifier?: string,
): Observable<undefined | Event>
Creates a ReplaceableModel
Parameters
- kind: number
- pubkey: string
- Optionalidentifier: string
Returns Observable<undefined | Event>
Implementation of IEventStore.replaceable
- Defined in packages/core/src/event-store/event-store.ts:419

replaceableSet

replaceableSet(
pointers: { identifier?: string; kind: number; pubkey: string }[],
): Observable<Record<string, undefined | Event>>
Parameters
- pointers: { identifier?: string; kind: number; pubkey: string }[]
Returns Observable<Record<string, undefined | Event>>
Deprecated
use multiple ReplaceableModel instead
Implementation of IEventStore.replaceableSet
- Defined in packages/core/src/event-store/event-store.ts:496

thread

thread(root: string | EventPointer | AddressPointer): Observable<Thread>
Subscribe to a thread
Parameters
- root: string | EventPointer | AddressPointer
Returns Observable<Thread>
Implementation of IEventStore.thread
- Defined in packages/core/src/event-store/event-store.ts:481

timeline

timeline(
filters: Filter | Filter[],
includeOldVersion?: boolean,
): Observable<Event[]>
Creates a TimelineModel
Parameters
- filters: Filter | Filter[]
- includeOldVersion: boolean = false
Returns Observable<Event[]>
Implementation of IEventStore.timeline
- Defined in packages/core/src/event-store/event-store.ts:442

update

update(event: Event): boolean
Add an event to the store and notifies all subscribes it has updated
Parameters
- event: Event
Returns boolean
Implementation of IEventStore.update
- Defined in packages/core/src/event-store/event-store.ts:266

updated

updated(event: string | Event): Observable<Event>
Creates an observable that emits when event is updated
Parameters
- event: string | Event
Returns Observable<Event>
Implementation of IEventStore.updated
- Defined in packages/core/src/event-store/event-store.ts:404

`Static`mergeDuplicateEvent

mergeDuplicateEvent(source: Event, dest: Event): void
Copies important metadata from and identical event to another
Parameters
- source: Event
- dest: Event
Returns void
- Defined in packages/core/src/event-store/event-store.ts:182

Class EventStore

Implements

Index

Constructors

Properties

Methods

Constructors

constructor

Returns EventStore

Properties

Optional ExperimentaladdressableLoader

database

ProtecteddeletedCoords

ProtecteddeletedIds

Optional ExperimentaleventLoader

Protectedexpirations

ProtectedexpirationTimeout

insert$

keepExpired

keepOldVersions

modelKeepWarm

Protectedmodels

ProtectednextExpirationCheck

remove$

Optional ExperimentalreplaceableLoader

update$

OptionalverifyEvent

Type declaration

Parameters

Returns boolean

Methods

add

Parameters

Returns null | Event

ProtectedaddExpiration

Parameters

Returns void

addressable

Parameters

Returns Observable<undefined | Event>

blossomServers

Parameters

Returns Observable<URL[]>

ProtectedcheckDeleted

Parameters

Returns boolean

claim

Parameters

Returns void

clearClaim

Parameters

Returns void

comments

Parameters

Returns Observable<Event[]>

contacts

Parameters

Returns Observable<ProfilePointer[]>

event

Parameters

Returns Observable<undefined | Event>

events

Parameters

Returns Observable<Record<string, undefined | Event>>

Deprecated

filters

Parameters

Returns Observable<Event>

getByFilters

Parameters

Returns Set<Event>

getEvent

Parameters

Returns undefined | Event

getReplaceable

Parameters

Returns undefined | Event

getReplaceableHistory

Parameters

Returns undefined | Event[]

`Optional` `Experimental`addressableLoader

`Protected`deletedCoords

`Protected`deletedIds

`Optional` `Experimental`eventLoader

`Protected`expirations

`Protected`expirationTimeout

`Protected`models

`Protected`nextExpirationCheck

`Optional` `Experimental`replaceableLoader

`Optional`verifyEvent

`Protected`addExpiration

`Protected`checkDeleted

`Protected`handleDeleteEvent

`Protected`handleExpiringEvent

`Protected`pruneExpired

`Static`mergeDuplicateEvent