Abstract Class: BaseConnectorTurn<TState>

Makaio Framework

---

Makaio Framework / ai-adapters-core / BaseConnectorTurn

Abstract Class: BaseConnectorTurn<TState>

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:28

Base abstract class for connector turn implementations.

Turns manage the state machine for a single user message:

• State transitions (idle to turn_started to step_started to …)
• Pause/resume mechanics
• Safe boundary detection for immediate messages
• Message handle delegation (acknowledgment, completion)

Each adapter implements its own turn subclass with adapter-specific state handling and SDK integration.

Extended by

• ProceduralConnectorTurn

Type Parameters

TState

TState extends string = string

Turn state enum type (string union)

Constructors

Constructor

new BaseConnectorTurn<TState>(bus, adapterId, adapterName, initialState): BaseConnectorTurn<TState>

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:41

Parameters

bus

ScopedBus<string>

adapterId

string

adapterName

string

initialState

TState

Returns

BaseConnectorTurn<TState>

Properties

activeMessageHandle

abstract protected activeMessageHandle: MessageHandle

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:39

Active message handle for this turn. Subclasses must provide this handle for message lifecycle management.

---

adapterId

protected readonly adapterId: string

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:31

---

adapterName

protected readonly adapterName: string

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:32

---

bus

protected readonly bus: ScopedBus<string>

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:30

---

state

protected state: TState

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:29

---

stateChangedCallback?

protected optional stateChangedCallback?: (oldState, newState) => void | Promise<void>

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:33

Parameters

oldState

TState

newState

TState

Returns

void | Promise<void>

Methods

emitStateChange()

abstract protected emitStateChange(oldState, newState): Promise<void>

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:97

Emit state change event - implemented by subclass with typed subjects.

Parameters

oldState

TState

Previous state

newState

TState

New state

Returns

Promise<void>

---

getMessageHandle()

getMessageHandle(): MessageHandle

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:111

Get the message handle for this turn.

Returns

MessageHandle

The message handle for this turn

---

getState()

getState(): TState

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:103

Get current turn state.

Returns

TState

Current turn state

---

isPaused()

abstract isPaused(): boolean

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:63

Check if turn is currently paused.

Returns

boolean

---

markAcknowledged()

markAcknowledged(): void

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:118

Mark message handle as acknowledged.

Returns

void

---

markCompleted()

markCompleted(result): void

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:126

Mark message handle as completed.

Parameters

result

The completion result with outcome and optional result/error

error?

unknown

outcome

string

result?

unknown

Returns

void

---

onStateChanged()

onStateChanged(cb): void

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:69

Register callback for state changes.

Parameters

cb

(oldState, newState) => void | Promise<void>

Callback to invoke on state transitions

Returns

void

---

pause()

abstract pause(): Promise<PauseResult<TState>>

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:52

Pause the turn at next safe boundary.

Returns

Promise<PauseResult<TState>>

Pause result indicating whether turn already ended

---

resume()

abstract resume(message?): Promise<void>

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:58

Resume the paused turn with optional additional message.

Parameters

message?

unknown

Optional message to inject when resuming

Returns

Promise<void>

---

transitionTo()

protected transitionTo(newState): Promise<void>

Defined in: ../../../adapters/core/src/connector/base-connector-turn.ts:81

Transition to new state and notify listeners. Template method for shared state transition pattern.

NOTE: Subclasses should use their typed namespace subjects for emission. This is a template - concrete implementation in adapter-specific Turn classes.

Parameters

newState

TState

New state to transition to

Returns

Promise<void>