import { ConvosBaseCommand } from "../../baseCommand.js";
export default class ProcessJoinRequests extends ConvosBaseCommand {
    /** Timestamp (ns) of the last DM message we processed — used for onRestart catchup. */
    private lastDmTimestampNs;
    private isCatchingUp;
    private isCatchupPending;
    /** IDs of DM messages we've already fully processed — prevents the batch
     *  pass and the live stream from double-firing for the same invite. */
    private processedMessageIds;
    private static readonly MAX_PROCESSED_IDS;
    /** Returns true the first time we see `id`; false on duplicate. */
    private markProcessed;
    static description: string;
    static examples: {
        command: string;
        description: string;
    }[];
    static flags: {
        watch: import("@oclif/core/interfaces").BooleanFlag<boolean>;
        conversation: import("@oclif/core/interfaces").OptionFlag<string | undefined, import("@oclif/core/interfaces").CustomOptions>;
        "log-level": import("@oclif/core/interfaces").OptionFlag<"off" | "error" | "warn" | "info" | "debug" | "trace" | undefined, import("@oclif/core/interfaces").CustomOptions>;
        "structured-logging": import("@oclif/core/interfaces").BooleanFlag<boolean>;
        "app-version": import("@oclif/core/interfaces").OptionFlag<string | undefined, import("@oclif/core/interfaces").CustomOptions>;
        home: import("@oclif/core/interfaces").OptionFlag<string | undefined, import("@oclif/core/interfaces").CustomOptions>;
        "env-file": import("@oclif/core/interfaces").OptionFlag<string | undefined, import("@oclif/core/interfaces").CustomOptions>;
        env: import("@oclif/core/interfaces").OptionFlag<"local" | "dev" | "production" | undefined, import("@oclif/core/interfaces").CustomOptions>;
        "gateway-host": import("@oclif/core/interfaces").OptionFlag<string | undefined, import("@oclif/core/interfaces").CustomOptions>;
        json: import("@oclif/core/interfaces").BooleanFlag<boolean>;
        fields: import("@oclif/core/interfaces").OptionFlag<string | undefined, import("@oclif/core/interfaces").CustomOptions>;
        verbose: import("@oclif/core/interfaces").BooleanFlag<boolean>;
    };
    private processMessage;
    /**
     * Schedule a DM catchup after a stream restart. Coalesces concurrent restarts:
     * a call during an in-flight catchup sets a pending flag so one more pass runs
     * after the current one completes.
     */
    private scheduleCatchup;
    private catchUp;
    run(): Promise<void>;
}