Interface: MakaioBusContext

Makaio Framework / bus-core / MakaioBusContext

Interface: MakaioBusContext

Defined in: ../../../packages/bus-core/src/types/bus.ts:42

Internal bus context containing handler registries and shared state.

Enables creation of isolated bus instances (e.g., for testing) by providing separate handler maps per instance.

Handler arrays are sorted by priority (highest first), with registration order preserved for handlers with equal priority.

Properties

anyHandlers

anyHandlers: Set<AnyHandler>

Defined in: ../../../packages/bus-core/src/types/bus.ts:46

eventHandlers

eventHandlers: Map<string, HandlerEntry<EventHandler<unknown>>[]>

Defined in: ../../../packages/bus-core/src/types/bus.ts:43

interceptorHandlers

interceptorHandlers: Map<string, InterceptorEntry<InterceptorHandler<unknown>>[]>

Defined in: ../../../packages/bus-core/src/types/bus.ts:45

namespaceRegistry

namespaceRegistry: object

Defined in: ../../../packages/bus-core/src/types/bus.ts:48

__resetNamespaces

__resetNamespaces: (() => void) | undefined

Internal

Reset all registered namespaces (for testing only).

extendSubjectSchema()

extendSubjectSchema(fullSubjectKey, additionalFields): void

Additively extend a registered subject’s schema with new fields.

For request subjects, extends the request and/or response ZodObject via .extend(). For event subjects, extends the event ZodObject directly. Successive calls accumulate fields; if a later extension redefines an existing key, the later definition wins (Zod .extend() semantics).

Parameters

fullSubjectKey

string

Fully-qualified key (e.g., “session.list”)

additionalFields

Readonly<{[k: string]: $ZodType<unknown, unknown, $ZodTypeInternals<unknown, unknown>>; }> | { request?: Readonly<{[k: string]: $ZodType<unknown, unknown, $ZodTypeInternals<unknown, unknown>>; }>; response?: Readonly<{[k: string]: $ZodType<unknown, unknown, $ZodTypeInternals<unknown, unknown>>; }>; }

For request subjects: { request?, response? } each a record of Zod field definitions. For event subjects: a flat record of Zod field definitions.

Returns

void

Throws

Error if the subject is not registered or the existing schema is not a ZodObject

getSchema()

getSchema(subject): BaseSubjectSchema | undefined

Get the schema for a registered subject. Returns the unwrapped schema (LocalSubjectSchema and ChannelSubjectSchema wrappers are removed during registration).

Parameters

subject

string | SubjectDefinition

Subject identifier (e.g., “adapter.getCapabilities”)

Returns

BaseSubjectSchema | undefined

Schema if found, undefined otherwise

isLocalSubject()

isLocalSubject(subject): boolean

Check if a subject was registered as a local-only subject.

Local subjects must never be routed over transports. The __local flag is stripped by unwrapSchema, so locality is tracked in a separate set populated at registration time.

Parameters

subject

string

Full subject identifier (e.g., “widget.register”)

Returns

boolean

True if the subject was wrapped with localSubject()

isRequestSubject()

isRequestSubject(subject): boolean

Check if a subject is registered as a request subject.

Parameters

subject

string

Subject identifier

Returns

boolean

True if subject exists and is a request schema

listRegisteredSubjects()

listRegisteredSubjects(): RegisteredSubjectSchema[]

List all registered subjects with their runtime schema metadata.

Returns

RegisteredSubjectSchema[]

Registered subjects sorted by fully-qualified subject key

registerNamespace()

registerNamespace<Domain, Schemas>(domain, schemas, options?): BusNamespace<Domain, SubjectRecordFromSchemaRecord<Schemas>, { [KeyType in PropertyKey]: AllPropertiesOfUnion<FilterablePayload<SubjectRecordFromSchemaRecord<Schemas>[keyof Schemas & string]>>[KeyType] }, Schemas>

The FilterPayload type parameter is computed eagerly from the schemas, enabling type-safe filtering via withFilter().

Type Parameters

Domain

Domain extends string

Schemas

Schemas extends Record<string, SubjectSchema>

Parameters

domain

Domain

Domain string

schemas

Schemas

SubjectNamespace object

options?

NamespaceRegistrationOptions

Registration options (e.g., skipBusValidation)

Returns

BusNamespace<Domain, SubjectRecordFromSchemaRecord<Schemas>, { [KeyType in PropertyKey]: AllPropertiesOfUnion<FilterablePayload<SubjectRecordFromSchemaRecord<Schemas>[keyof Schemas & string]>>[KeyType] }, Schemas>

The registered namespace with pre-computed FilterPayload type

shouldSkipValidation()

shouldSkipValidation(subject): boolean

Check if validation should be skipped for a subject.

Returns true if the subject belongs to a namespace registered with skipBusValidation: true.

Parameters

subject

string

Full subject identifier (e.g., “adapter:github-copilot.sdk.event”)

Returns

boolean

True if validation should be skipped

remoteEventHandlers

remoteEventHandlers: Map<string, Set<string>>

Defined in: ../../../packages/bus-core/src/types/bus.ts:60

Set of transport names that have subscribed to each subject with event-only handlers (i.e. subscribe messages whose priority array was empty).

Tracked separately from remoteRequestHandlers because event-only subscriptions produce no priority entries yet must still influence advertised-state decisions: if a remote has event-only handlers for a subject, peers should still receive a subscribe (with an empty priority array) rather than an unsubscribe.