cap-nodejs

CAP Node.js API


CAP Node.js API / cap-core/src / InMemoryReceivedStorage

Class: InMemoryReceivedStorage

Defined in: cap-core/src/testing/in-memory-received-storage.ts:9

Implements

Constructors

Constructor

new InMemoryReceivedStorage(): InMemoryReceivedStorage

Returns

InMemoryReceivedStorage

Properties

store

readonly store: Map<string, CapReceivedEvent<JsonValue>>

Defined in: cap-core/src/testing/in-memory-received-storage.ts:10

Methods

findReceivedById()

findReceivedById(id): Promise<CapReceivedEvent<JsonValue> | undefined>

Defined in: cap-core/src/testing/in-memory-received-storage.ts:76

Parameters

id

string

Returns

Promise<CapReceivedEvent<JsonValue> | undefined>

Implementation of

ReceivedStoragePort.findReceivedById


getRetryDue()

getRetryDue(limit, now?): Promise<CapReceivedEvent<JsonValue>[]>

Defined in: cap-core/src/testing/in-memory-received-storage.ts:42

Parameters

limit

number

now?

Date = ...

Returns

Promise<CapReceivedEvent<JsonValue>[]>

Implementation of

ReceivedStoragePort.getRetryDue


listReceived()

listReceived(options?): Promise<{ items: CapReceivedEvent<JsonValue>[]; total: number; }>

Defined in: cap-core/src/testing/in-memory-received-storage.ts:83

Parameters

options?
due?

boolean

limit?

number

offset?

number

topic?

string

Returns

Promise<{ items: CapReceivedEvent<JsonValue>[]; total: number; }>

Implementation of

ReceivedStoragePort.listReceived


markProcessed()

markProcessed(id, processedAt?): Promise<void>

Defined in: cap-core/src/testing/in-memory-received-storage.ts:31

Parameters

id

string

processedAt?

Date = ...

Returns

Promise<void>

Implementation of

ReceivedStoragePort.markProcessed


markReceivedFailed()

markReceivedFailed(id, error, options): Promise<void>

Defined in: cap-core/src/testing/in-memory-received-storage.ts:60

Parameters

id

string

error

unknown

options

MarkReceivedFailedOptions

Returns

Promise<void>

Implementation of

ReceivedStoragePort.markReceivedFailed


trySaveReceived()

trySaveReceived<T>(event): Promise<TrySaveReceivedResult<T>>

Defined in: cap-core/src/testing/in-memory-received-storage.ts:13

Type Parameters

T

T extends JsonValue = JsonValue

Parameters

event

CapReceivedEvent<T>

Returns

Promise<TrySaveReceivedResult<T>>

Implementation of

ReceivedStoragePort.trySaveReceived