import { createEventBus } from 'eventbus-z';
import type { RuntimeContainer } from '../app/container';
export type RuntimeLogger = {
    info(message: string, meta?: unknown): void;
    error(message: string, meta?: unknown): void;
};
export type RuntimeEventBus = ReturnType<typeof createEventBus>;
export type GlobalEventBus = ReturnType<typeof createEventBus>;
export type TypedRuntimeEventBus<TEvents extends Record<string, any[]>> = {
    $emit<K extends keyof TEvents>(event: K, ...args: TEvents[K]): void;
    $on<K extends keyof TEvents>(event: K, listener: (...args: TEvents[K]) => void): () => void;
    $off?<K extends keyof TEvents>(event: K, listener?: (...args: TEvents[K]) => void): void;
    $once?<K extends keyof TEvents>(event: K, listener: (...args: TEvents[K]) => void): void;
};
export type RuntimeContext = {
    requestId: string;
    signal: AbortSignal;
    container: RuntimeContainer;
    logger: RuntimeLogger;
    events: RuntimeEventBus;
    globalEvents?: GlobalEventBus;
    cache: Map<string, unknown>;
    auth?: {
        userId: string;
    };
    throwIfAborted(): void;
};
export type ActionNext<TResult> = () => Promise<TResult>;
export type Middleware<TInput = unknown, TResult = unknown> = (params: {
    input: TInput;
    context: RuntimeContext;
    next: ActionNext<TResult>;
}) => Promise<TResult>;
export type ActionHandler<TInput, TResult> = (params: {
    input: TInput;
    context: RuntimeContext;
}) => Promise<TResult>;
export type RuntimeAction<TInput, TResult> = {
    name: string;
    middleware?: Middleware<TInput, TResult>[];
    retry?: {
        attempts: number;
    };
    handler: ActionHandler<TInput, TResult>;
};
export type RuntimeSystem = {
    globalEvents: GlobalEventBus;
};