import * as amqplib from "amqp-connection-manager";
import { Readable } from "stream";
import { BSBEvents, BSBEventsConstructor, BSBPluginConfig, DTrace } from "@bettercorp/service-base";
import { z } from "zod";
export declare const secSchema: z.ZodDefault<z.ZodObject<{
    platformKey: z.ZodDefault<z.ZodNullable<z.ZodString>>;
    fatalOnDisconnect: z.ZodDefault<z.ZodBoolean>;
    prefetch: z.ZodDefault<z.ZodNumber>;
    endpoints: z.ZodDefault<z.ZodArray<z.ZodString, "many">>;
    credentials: z.ZodDefault<z.ZodObject<{
        username: z.ZodDefault<z.ZodString>;
        password: z.ZodDefault<z.ZodString>;
    }, "strip", z.ZodTypeAny, {
        username: string;
        password: string;
    }, {
        username?: string | undefined;
        password?: string | undefined;
    }>>;
    uniqueId: z.ZodDefault<z.ZodNullable<z.ZodString>>;
}, "strip", z.ZodTypeAny, {
    platformKey: string | null;
    fatalOnDisconnect: boolean;
    prefetch: number;
    endpoints: string[];
    credentials: {
        username: string;
        password: string;
    };
    uniqueId: string | null;
}, {
    platformKey?: string | null | undefined;
    fatalOnDisconnect?: boolean | undefined;
    prefetch?: number | undefined;
    endpoints?: string[] | undefined;
    credentials?: {
        username?: string | undefined;
        password?: string | undefined;
    } | undefined;
    uniqueId?: string | null | undefined;
}>>;
export declare class Config extends BSBPluginConfig<typeof secSchema> {
    validationSchema: z.ZodDefault<z.ZodObject<{
        platformKey: z.ZodDefault<z.ZodNullable<z.ZodString>>;
        fatalOnDisconnect: z.ZodDefault<z.ZodBoolean>;
        prefetch: z.ZodDefault<z.ZodNumber>;
        endpoints: z.ZodDefault<z.ZodArray<z.ZodString, "many">>;
        credentials: z.ZodDefault<z.ZodObject<{
            username: z.ZodDefault<z.ZodString>;
            password: z.ZodDefault<z.ZodString>;
        }, "strip", z.ZodTypeAny, {
            username: string;
            password: string;
        }, {
            username?: string | undefined;
            password?: string | undefined;
        }>>;
        uniqueId: z.ZodDefault<z.ZodNullable<z.ZodString>>;
    }, "strip", z.ZodTypeAny, {
        platformKey: string | null;
        fatalOnDisconnect: boolean;
        prefetch: number;
        endpoints: string[];
        credentials: {
            username: string;
            password: string;
        };
        uniqueId: string | null;
    }, {
        platformKey?: string | null | undefined;
        fatalOnDisconnect?: boolean | undefined;
        prefetch?: number | undefined;
        endpoints?: string[] | undefined;
        credentials?: {
            username?: string | undefined;
            password?: string | undefined;
        } | undefined;
        uniqueId?: string | null | undefined;
    }>>;
    migrate(toVersion: string, fromVersion: string | null, fromConfig: any | null): any;
}
export declare class Plugin extends BSBEvents<Config> {
    publishConnection: amqplib.AmqpConnectionManager;
    receiveConnection: amqplib.AmqpConnectionManager;
    myId: string;
    private ear;
    private broadcast;
    private emit;
    private eas;
    constructor(config: BSBEventsConstructor);
    getPlatformName(name: string): string;
    init(trace: DTrace): Promise<void>;
    private _connectToAMQP;
    dispose(): void;
    onBroadcast(trace: DTrace, pluginName: string, event: string, listener: {
        (trace: DTrace, args: any[]): Promise<void>;
    }): Promise<void>;
    emitBroadcast(trace: DTrace, pluginName: string, event: string, args: any[]): Promise<void>;
    onEvent(trace: DTrace, pluginName: string, event: string, listener: {
        (trace: DTrace, args: any[]): Promise<void>;
    }): Promise<void>;
    emitEvent(trace: DTrace, pluginName: string, event: string, args: any[]): Promise<void>;
    onReturnableEvent(trace: DTrace, pluginName: string, event: string, listener: {
        (trace: DTrace, args: any[]): Promise<any>;
    }): Promise<void>;
    emitEventAndReturn(trace: DTrace, pluginName: string, event: string, timeoutSeconds: number, args: any[]): Promise<any>;
    receiveStream(trace: DTrace, event: string, listener: (trace: DTrace, error: Error | null, stream: Readable) => Promise<void>, timeoutSeconds?: number | undefined): Promise<string>;
    sendStream(trace: DTrace, event: string, streamId: string, stream: Readable): Promise<void>;
}