import type { Kysely } from 'kysely';
import { z } from 'zod';
import type { Api } from '../api';
import type { SqliteDatabase } from '../types';
declare const Config: z.ZodObject<{
    sqliteConfig: z.ZodOptional<z.ZodString>;
    appId: z.ZodOptional<z.ZodString>;
}, z.core.$strip>;
/**
 * Self-acking HTTP source API, using configured SQLite config node or trying to find it in all nodes
 */
export declare const SourceHttpApi: (api: Api) => {
    new (config: any): {
        database: Promise<Kysely<SqliteDatabase>>;
        parsedConfig: z.infer<typeof Config>;
        buildGetMessageUrl(): Promise<URL>;
        getLastAckedMessageId(): Promise<string | null>;
        ackMessage(messageId: string): Promise<void>;
        isDestroying: boolean;
        nextMessageWaitTime: number;
        pendingProcessing: {
            messageId: string;
            resolve: VoidFunction;
            reject: (err: Error) => void;
        } | null;
        config: Promise<z.core.output<z.ZodObject<{
            namespace: z.ZodString;
            host: z.ZodString;
            workerId: z.ZodString;
        }, z.core.$strip>>>;
        getMessageLoop(): Promise<void>;
        setStatus(status: "waiting" | "pending" | "error"): void;
        onInput(message: z.core.output<z.ZodUnion<readonly [z.ZodObject<{
            topic: z.ZodLiteral<"finished-processing">;
            payload: z.ZodObject<{
                httpApiMessageId: z.ZodString;
            }, z.core.$strip>;
        }, z.core.$strip>, z.ZodObject<{
            topic: z.ZodLiteral<"force-reset">;
        }, z.core.$strip>]>>): void;
        getMessage(): Promise<unknown | null>;
        onDestroy(): void;
        api: Api;
        nodeConfig: unknown;
        messageZod: z.ZodUnion<readonly [z.ZodObject<{
            topic: z.ZodLiteral<"finished-processing">;
            payload: z.ZodObject<{
                httpApiMessageId: z.ZodString;
            }, z.core.$strip>;
        }, z.core.$strip>, z.ZodObject<{
            topic: z.ZodLiteral<"force-reset">;
        }, z.core.$strip>]>;
        getBaseUrls(): Promise<z.core.output<typeof import("../node").BaseUrlsConfig>>;
        getNodeEnvConfig(): import("../node").NodeEnvConfig;
        sendBuilder(inputMessage: import("../types").NodeMessage<any>): import("../node").SendBuilder;
        handleMaybePromise<T>(maybePromiseCb: () => (T | Promise<T>), done: (err?: Error) => void): void;
    };
};
export {};