IAct

@rotorsoft/act-root

---

@rotorsoft/act-root / act/src / IAct

Interface: IAct<TEvents, TActions, TActor>

Defined in: libs/act/src/types/action.ts:1026

Type Parameters

TEvents

TEvents extends Schemas = Schemas

TActions

TActions extends Schemas = Schemas

TActor

TActor extends Actor = Actor

Methods

do()

do<TKey>(action, target, payload, options?): Promise<Snapshot<any, any>[]>

Defined in: libs/act/src/types/action.ts:1031

Type Parameters

TKey

TKey extends string

Parameters

action

TKey

target

Target<TActor>

payload

Readonly<TActions[TKey]>

options?

DoOptions<TEvents>

Returns

Promise<Snapshot<any, any>[]>

---

forget()

forget(stream): Promise<{ eventCount: number; }>

Defined in: libs/act/src/types/action.ts:1094

Wipe the sensitive-data payload for every event on the stream — the application-level half of the sensitive-data epic (#566). Delegates to the Store's forget_pii(stream), invalidates the cache entry for the stream, then emits the forgotten lifecycle event.

Throws at build time if the configured Store does not implement forget_pii (its adapter declares pii_isolation: false or omits the method) — operators get a clear "your adapter can't comply with GDPR erasure" signal before the production callsite is exercised.

Idempotent: a second call on an already-wiped stream returns eventCount: 0 and does NOT re-emit forgotten.

Parameters

stream

string

Target stream to wipe.

Returns

Promise<{ eventCount: number; }>

Count of events whose PII column was set to NULL.

---

load()

Call Signature

load(state, stream, callback?, asOf?): Promise<Snapshot<any, any>>

Defined in: libs/act/src/types/action.ts:1054

Load a state snapshot for a stream. Two shapes:

Anonymous (bare stream) — load(state, stream, callback?, asOf?). The framework default-denies on every PII gate: sensitive event fields come back as [REDACTED], state fields whose names match sensitive event fields are also [REDACTED]. Use this when the caller has no authorization context (background workers, observability probes, etc.).

Auth-aware (LoadTarget) — load(state, {stream, actor, asOf?}, callback?). Symmetric with IAct.do(state, target, payload). The read runs the state's .discloses(predicate) against the supplied actor; sensitive fields come back as plaintext when the predicate returns true, [REDACTED] otherwise. Forgotten events return [SHREDDED] regardless of actor (data is gone, no auth question).

Parameters

state

string | State<any, any, any, string>

stream

string

callback?

(snapshot) => void

asOf?

AsOf

Returns

Promise<Snapshot<any, any>>

Call Signature

load(state, target, callback?): Promise<Snapshot<any, any>>

Defined in: libs/act/src/types/action.ts:1060

Parameters

state

string | State<any, any, any, string>

target

LoadTarget<TActor>

callback?

(snapshot) => void

Returns

Promise<Snapshot<any, any>>

---

query()

query(query, callback?): Promise<{ count: number; first?: Committed<TEvents, keyof TEvents>; last?: Committed<TEvents, keyof TEvents>; }>

Defined in: libs/act/src/types/action.ts:1066

Parameters

query

Query

callback?

(event) => void

Returns

Promise<{ count: number; first?: Committed<TEvents, keyof TEvents>; last?: Committed<TEvents, keyof TEvents>; }>

---

query_array()

query_array(query): Promise<Committed<TEvents, keyof TEvents>[]>

Defined in: libs/act/src/types/action.ts:1075

Parameters

query

Query

Returns

Promise<Committed<TEvents, keyof TEvents>[]>