/** * @license * Copyright 2025 Google LLC * SPDX-License-Identifier: Apache-2.0 */ import { EventEmitter } from 'node:events'; /** * Defines the severity level for user-facing feedback. * This maps loosely to UI `MessageType` */ export type FeedbackSeverity = 'info' | 'warning' | 'error'; /** * Payload for the 'user-feedback' event. */ export interface UserFeedbackPayload { /** * The severity level determines how the message is rendered in the UI * (e.g. colored text, specific icon). */ severity: FeedbackSeverity; /** * The main message to display to the user in the chat history or stdout. */ message: string; /** * The original error object, if applicable. * Listeners can use this to extract stack traces for debug logging * or verbose output, while keeping the 'message' field clean for end users. */ error?: unknown; } /** * Payload for the 'fallback-mode-changed' event. */ export interface FallbackModeChangedPayload { /** * Whether fallback mode is now active. */ isInFallbackMode: boolean; } /** * Payload for the 'subscription-blocked' event. */ export interface SubscriptionBlockedPayload { /** * Whether user should be blocked due to exceeding token limit. */ shouldBlock: boolean; /** * Total tokens used by the user. */ totalTokensUsed: number; /** * Whether user is a subscriber. */ isSubscriber: boolean; } export declare enum CoreEvent { UserFeedback = "user-feedback", FallbackModeChanged = "fallback-mode-changed", SubscriptionBlocked = "subscription-blocked" } export declare class CoreEventEmitter extends EventEmitter { private _feedbackBacklog; private static readonly MAX_BACKLOG_SIZE; constructor(); /** * Sends actionable feedback to the user. * Buffers automatically if the UI hasn't subscribed yet. */ emitFeedback(severity: FeedbackSeverity, message: string, error?: unknown): void; /** * Notifies subscribers that fallback mode has changed. * This is synchronous and doesn't use backlog (UI should already be initialized). */ emitFallbackModeChanged(isInFallbackMode: boolean): void; /** * Notifies subscribers that subscription blocking status has changed. */ emitSubscriptionBlocked(shouldBlock: boolean, totalTokensUsed: number, isSubscriber: boolean): void; /** * Flushes buffered messages. Call this immediately after primary UI listener * subscribes. */ drainFeedbackBacklog(): void; on(event: CoreEvent.UserFeedback, listener: (payload: UserFeedbackPayload) => void): this; on(event: CoreEvent.FallbackModeChanged, listener: (payload: FallbackModeChangedPayload) => void): this; on(event: CoreEvent.SubscriptionBlocked, listener: (payload: SubscriptionBlockedPayload) => void): this; off(event: CoreEvent.UserFeedback, listener: (payload: UserFeedbackPayload) => void): this; off(event: CoreEvent.FallbackModeChanged, listener: (payload: FallbackModeChangedPayload) => void): this; off(event: CoreEvent.SubscriptionBlocked, listener: (payload: SubscriptionBlockedPayload) => void): this; emit(event: CoreEvent.UserFeedback, payload: UserFeedbackPayload): boolean; emit(event: CoreEvent.FallbackModeChanged, payload: FallbackModeChangedPayload): boolean; emit(event: CoreEvent.SubscriptionBlocked, payload: SubscriptionBlockedPayload): boolean; } export declare const coreEvents: CoreEventEmitter;