import { ArcSSEClient } from '../../services/providers/ArcSSEClient';
import { Monitor } from '../Monitor';
import { WalletMonitorTask } from './WalletMonitorTask';
/**
 * Monitor task that receives transaction status updates from Arcade via SSE
 * and processes them — including fetching merkle proofs directly from Arcade
 * when transactions are MINED.
 */
export declare class TaskArcadeSSE extends WalletMonitorTask {
    static readonly taskName = "ArcadeSSE";
    sseClient: ArcSSEClient | null;
    private readonly pendingEvents;
    constructor(monitor: Monitor);
    asyncSetup(): Promise<void>;
    private logSetupEvent;
    trigger(_nowMsecsSinceEpoch: number): {
        run: boolean;
    };
    runTask(): Promise<string>;
    fetchNow(): Promise<number>;
    /** Close the live stream and reject any unacknowledged monitor event. */
    close(): void;
    private processStatusEvent;
    private canRecoverTerminalRequest;
    private applyStatusEvent;
    private applyAcceptedStatus;
    private applyMinedStatus;
    private applyDoubleSpendStatus;
    private classifyRejection;
    private applyRejectedStatus;
    private applyTerminalFailure;
    /**
     * Complete a MINED/IMMUTABLE status by using the configured proof providers.
     * Arcade is first when configured, but the shared provider path validates the
     * proof against the wallet chaintracker before a ProvenTx is persisted.
     */
    private fetchProofFromServices;
}
//# sourceMappingURL=TaskArcSSE.d.ts.map