Skip to content

Class: MessageHandle

Makaio Framework


Makaio Framework / ai-adapters-core / MessageHandle

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:6

new MessageHandle(messageId, message, deliveryMode, messageHistory?, turnContext?): MessageHandle

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:29

string

NormalizedMessageInput

"replace" | "enqueue" | "immediate"

object[]

Curated message history from sessionContext

Record<string, JsonValue>

Turn-scoped context from PreUserMessage hooks

MessageHandle

protected readonly deferredAcknowledgement: DeferredPromise<boolean>

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:8


protected readonly deferredCompletion: DeferredPromise<MessageResult>

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:7


readonly deliveryMode: "replace" | "enqueue" | "immediate"

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:32


optional mergedFrom?: string[]

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:16

If this is the merge winner, messageIds that were folded in


optional mergedInto?: string

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:14

If this message was merged into another, the winner’s messageId


readonly message: NormalizedMessageInput

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:31


readonly messageId: string

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:30


state: MessageState

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:9


optional supersededBy?: string

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:18

If this message was superseded by replace/immediate, the replacer’s messageId

get adapterSessionId(): string | undefined

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:75

Get adapter session ID synchronously (undefined if not yet set)

string | undefined

The adapter session ID or undefined if not yet set

set adapterSessionId(value): void

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:82

Set adapter session ID (called by connector when processing starts)

string | undefined

void


get isProcessed(): boolean

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:98

boolean


get messageHistory(): object[] | undefined

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:49

Curated message history from sessionContext

object[] | undefined

The message history array or undefined if not set

set messageHistory(value): void

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:54

Set messageHistory (used by merge strategies to propagate history)

object[] | undefined

void


get turnContext(): Record<string, JsonValue> | undefined

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:62

Turn-scoped context from PreUserMessage hooks

Record<string, JsonValue> | undefined

The turn context record or undefined if not set

set turnContext(value): void

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:67

Set turnContext (used by merge strategies to propagate context)

Record<string, JsonValue> | undefined

void

cancel(): Promise<boolean>

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:118

Cancel a pending message

Promise<boolean>

True if cancelled, false if already submitted/completed


getState(): MessageState

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:102

MessageState


markAcknowledged(delivered?): void

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:134

Mark message as acknowledged

boolean = true

Whether message was successfully delivered to provider (e.g. false if immediate message arrived too late)

void


markCompleted(result): void

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:146

Mark message turn as completed

MessageResult

The result message or null if no result available

void


updateState(state): void

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:110

Update message state

MessageState

New message state

void


waitForAcknowledgment(timeoutMs?): Promise<boolean>

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:163

number

Promise<boolean>


waitForAdapterSessionId(): Promise<string>

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:93

Wait for adapter session ID to be set

Promise<string>

Promise resolving to session ID when processing starts


waitForCompletion(timeoutMs?): Promise<MessageResult>

Defined in: ../../../adapters/core/src/message-handle/message-handle.ts:182

number

Promise<MessageResult>