Class SqlDurableInbox<T>

The sealer keeps credentials in pending deliveries encrypted at rest.

Type Parameters

T

Implements

IDurableInbox<T>

Index

Constructors

Methods

accept pending acknowledge

Constructors

constructor

new SqlDurableInbox<T>(db, prefix, box): SqlDurableInbox<T>
Type Parameters
- T
Parameters
- db: InboxDb
  The database holding the table durableInboxDdl makes.
- prefix: string
  The prefix the table was made under.
- box: {
  seal(value): string;
  open(value): string;
  }
  Seals each payload before it is stored and opens it on read (a SecretBox, for one).
  - seal:function
    - seal(value): string
    - Parameters
      value: string
      Returns string
      Defined in src/io/channels/meetings/DurableInbox.ts:64
  - open:function
    - open(value): string
    - Parameters
      value: string
      Returns string
      Defined in src/io/channels/meetings/DurableInbox.ts:64
Returns SqlDurableInbox<T>
- Defined in src/io/channels/meetings/DurableInbox.ts:63

Methods

accept

accept(entry): Promise<boolean>
Stores a new entry; false, and nothing changes, when an entry with its id was accepted before (acknowledged or not).
Parameters
- entry: InboxEntry<T>
Returns Promise<boolean>
Implementation of IDurableInbox.accept
- Defined in src/io/channels/meetings/DurableInbox.ts:67

pending

pending(): Promise<InboxEntry<T>[]>
The entries accepted and not yet acknowledged, oldest first.

Returns Promise<InboxEntry<T>[]>
Implementation of IDurableInbox.pending
- Defined in src/io/channels/meetings/DurableInbox.ts:73

acknowledge

acknowledge(id): Promise<void>
Drops the entry's payload once the receiver has acted on it; its id stays, so a replay is still refused.
Parameters
- id: string
Returns Promise<void>
Implementation of IDurableInbox.acknowledge
- Defined in src/io/channels/meetings/DurableInbox.ts:78