Class AsyncEventStore

An async wrapper around an async event database that handles replaceable events, deletes, and models

Hierarchy

(Anonymous class)<typeof __class, IEventStore | IAsyncEventStore, this> & (Anonymous class)<
this,
>
- AsyncEventStore

Implements

IAsyncEventStore

Indexable

[key: string]: any

Constructors

constructor

new AsyncEventStore(database: IAsyncEventDatabase): AsyncEventStore
Parameters
- database: IAsyncEventDatabase
Returns AsyncEventStore
Overrides EventStoreModelMixin(class {}).constructor
- Defined in packages/core/src/event-store/async-event-store.ts:62

Properties

`Optional`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: IAsyncEventDatabase

`Protected`deletedCoords

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

`Protected`deletedIds

deletedIds: Set<string> = ...

`Optional`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$: Subject<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

`Optional`memory

memory?: EventMemory

Optional memory database for ensuring single event instances

modelKeepWarm

modelKeepWarm: number = 60_000

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

models

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

A directory of all active models

`Protected`nextExpirationCheck

nextExpirationCheck: null | number = null

remove$

remove$: Subject<Event> = ...

A stream of events that have been removed

`Optional`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$: Subject<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): Promise<null | Event>
Adds an event to the store and update subscriptions
Parameters
- event: Event
- OptionalfromRelay: string
Returns Promise<null | Event>
The existing event or the event that was added, if it was ignored returns null
Implementation of IAsyncEventStore.add
- Defined in packages/core/src/event-store/async-event-store.ts:192

`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/async-event-store.ts:108

addressable

addressable(pointer: AddressPointer): Observable<undefined | Event>
Subscribe to an addressable event by pointer
Parameters
- pointer: AddressPointer
Returns Observable<undefined | Event>
Implementation of IAsyncEventStore.addressable
Inherited from EventStoreModelMixin(class {}).addressable
- Defined in packages/core/src/event-store/model-mixin.ts:133

blossomServers

blossomServers(user: string | ProfilePointer): Observable<URL[]>
Subscribe to a users blossom servers
Parameters
- user: string | ProfilePointer
Returns Observable<URL[]>
Implementation of IAsyncEventStore.blossomServers
Inherited from EventStoreModelMixin(class {}).blossomServers
- Defined in packages/core/src/event-store/model-mixin.ts:162

`Protected`checkDeleted

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

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 IAsyncEventStore.claim
- Defined in packages/core/src/event-store/async-event-store.ts:355

clearClaim

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

comments

comments(event: Event): Observable<Event[]>
Subscribe to a event's comments
Parameters
- event: Event
Returns Observable<Event[]>
Implementation of IAsyncEventStore.comments
Inherited from EventStoreModelMixin(class {}).comments
- Defined in packages/core/src/event-store/model-mixin.ts:175

contacts

contacts(user: string | ProfilePointer): Observable<ProfilePointer[]>
Subscribe to a users contacts
Parameters
- user: string | ProfilePointer
Returns Observable<ProfilePointer[]>
Implementation of IAsyncEventStore.contacts
Inherited from EventStoreModelMixin(class {}).contacts
- Defined in packages/core/src/event-store/model-mixin.ts:147

event

event(pointer: string | EventPointer): Observable<undefined | Event>
Creates a EventModel
Parameters
- pointer: string | EventPointer
Returns Observable<undefined | Event>
Implementation of IAsyncEventStore.event
Inherited from EventStoreModelMixin(class {}).event
- Defined in packages/core/src/event-store/model-mixin.ts:108

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 IAsyncEventStore.events
Inherited from EventStoreModelMixin(class {}).events
- Defined in packages/core/src/event-store/model-mixin.ts:180

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 IAsyncEventStore.filters
Inherited from EventStoreModelMixin(class {}).filters
- Defined in packages/core/src/event-store/model-mixin.ts:82

getByFilters

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

getEvent

getEvent(id: string): Promise<undefined | Event>
Get an event by id from the store
Parameters
- id: string
Returns Promise<undefined | Event>
Implementation of IAsyncEventStore.getEvent
- Defined in packages/core/src/event-store/async-event-store.ts:302

getReplaceable

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

getReplaceableHistory

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

getTimeline

getTimeline(filters: Filter | Filter[]): Promise<Event[]>
Returns a timeline of events that match filters
Parameters
- filters: Filter | Filter[]
Returns Promise<Event[]>
Implementation of IAsyncEventStore.getTimeline
- Defined in packages/core/src/event-store/async-event-store.ts:344

`Protected`handleDeleteEvent

handleDeleteEvent(deleteEvent: Event): Promise<void>
Parameters
- deleteEvent: Event
Returns Promise<void>
- Defined in packages/core/src/event-store/async-event-store.ts:149

`Protected`handleExpiringEvent

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

hasEvent

hasEvent(id: string): Promise<boolean>
Check if the store has an event by id
Parameters
- id: string
Returns Promise<boolean>
Implementation of IAsyncEventStore.hasEvent
- Defined in packages/core/src/event-store/async-event-store.ts:296

hasReplaceable

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

isClaimed

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

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 IAsyncEventStore.mailboxes
Inherited from EventStoreModelMixin(class {}).mailboxes
- Defined in packages/core/src/event-store/model-mixin.ts:157

model

model<T extends unknown, Args extends any[]>(
constructor: ModelConstructor<T, Args, IEventStore | IAsyncEventStore>,
...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, IEventStore | IAsyncEventStore>
- ...args: Args
Returns Observable<T>
Implementation of IAsyncEventStore.model
Inherited from EventStoreModelMixin(class {}).model
- Defined in packages/core/src/event-store/model-mixin.ts:39

mutes

mutes(user: string | ProfilePointer): Observable<undefined | Mutes>
Subscribe to a users mutes
Parameters
- user: string | ProfilePointer
Returns Observable<undefined | Mutes>
Implementation of IAsyncEventStore.mutes
Inherited from EventStoreModelMixin(class {}).mutes
- Defined in packages/core/src/event-store/model-mixin.ts:152

profile

profile(user: string | ProfilePointer): Observable<undefined | ProfileContent>
Subscribe to a users profile
Parameters
- user: string | ProfilePointer
Returns Observable<undefined | ProfileContent>
Implementation of IAsyncEventStore.profile
Inherited from EventStoreModelMixin(class {}).profile
- Defined in packages/core/src/event-store/model-mixin.ts:143

prune

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

`Protected`pruneExpired

pruneExpired(): Promise<void>
Remove expired events from the store

Returns Promise<void>
- Defined in packages/core/src/event-store/async-event-store.ts:133

reactions

reactions(event: Event): Observable<Event[]>
Subscribe to an event's reactions
Parameters
- event: Event
Returns Observable<Event[]>
Implementation of IAsyncEventStore.reactions
Inherited from EventStoreModelMixin(class {}).reactions
- Defined in packages/core/src/event-store/model-mixin.ts:167

remove

remove(event: string | Event): Promise<boolean>
Removes an event from the store and updates subscriptions
Parameters
- event: string | Event
Returns Promise<boolean>
Implementation of IAsyncEventStore.remove
- Defined in packages/core/src/event-store/async-event-store.ts:266

removeClaim

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

removed

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

replaceable

replaceable(
pointer: AddressPointer | AddressPointerWithoutD,
): Observable<undefined | Event>
Creates a ReplaceableModel
Parameters
- pointer: AddressPointer | AddressPointerWithoutD
Returns Observable<undefined | Event>
Implementation of IAsyncEventStore.replaceable
Inherited from EventStoreModelMixin(class {}).replaceable
- Defined in packages/core/src/event-store/model-mixin.ts:114
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 IAsyncEventStore.replaceable
Inherited from EventStoreModelMixin(class {}).replaceable
- Defined in packages/core/src/event-store/model-mixin.ts:115

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 IAsyncEventStore.replaceableSet
Inherited from EventStoreModelMixin(class {}).replaceableSet
- Defined in packages/core/src/event-store/model-mixin.ts:184

thread

thread(root: string | EventPointer | AddressPointer): Observable<Thread>
Subscribe to a thread
Parameters
- root: string | EventPointer | AddressPointer
Returns Observable<Thread>
Implementation of IAsyncEventStore.thread
Inherited from EventStoreModelMixin(class {}).thread
- Defined in packages/core/src/event-store/model-mixin.ts:171

timeline

timeline(
filters: Filter | Filter[],
includeOldVersion?: boolean,
): Observable<Event[]>
Creates a TimelineModel
Parameters
- filters: Filter | Filter[]
- includeOldVersion: boolean = false
Returns Observable<Event[]>
Implementation of IAsyncEventStore.timeline
Inherited from EventStoreModelMixin(class {}).timeline
- Defined in packages/core/src/event-store/model-mixin.ts:138

touch

touch(event: Event): undefined | void
Passthrough method for the database.touch
Parameters
- event: Event
Returns undefined | void
Implementation of IAsyncEventStore.touch
- Defined in packages/core/src/event-store/async-event-store.ts:351

unclaimed

unclaimed(): Generator<Event>
Pass through method for the database.unclaimed

Returns Generator<Event>
Implementation of IAsyncEventStore.unclaimed
- Defined in packages/core/src/event-store/async-event-store.ts:371

update

update(event: Event): Promise<void>
Add an event to the store and notifies all subscribes it has updated
Parameters
- event: Event
Returns Promise<void>
Implementation of IAsyncEventStore.update
- Defined in packages/core/src/event-store/async-event-store.ts:284

updated

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

`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/async-event-store.ts:177

Class AsyncEventStore

Hierarchy

Implements

Indexable

Index

Constructors

Properties

Methods

Constructors

constructor

Parameters

Returns AsyncEventStore

Properties

OptionaladdressableLoader

database

ProtecteddeletedCoords

ProtecteddeletedIds

OptionaleventLoader

Protectedexpirations

ProtectedexpirationTimeout

insert$

keepExpired

keepOldVersions

Optionalmemory

modelKeepWarm

models

ProtectednextExpirationCheck

remove$

OptionalreplaceableLoader

update$

OptionalverifyEvent

Type Declaration

Parameters

Returns boolean

Methods

add

Parameters

Returns Promise<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 Promise<Event[]>

getEvent

Parameters

Returns Promise<undefined | Event>

getReplaceable

Parameters

`Optional`addressableLoader

`Protected`deletedCoords

`Protected`deletedIds

`Optional`eventLoader

`Protected`expirations

`Protected`expirationTimeout

`Optional`memory

`Protected`nextExpirationCheck

`Optional`replaceableLoader

`Optional`verifyEvent

`Protected`addExpiration

`Protected`checkDeleted

`Protected`handleDeleteEvent

`Protected`handleExpiringEvent

`Protected`pruneExpired