import type { Kysely } from 'kysely';
import * as z from 'zod';
import type { Api } from '../api';
import type { SqliteDatabase } from '../types';
declare const InputMessage: z.ZodObject<{
    topic: z.ZodLiteral<undefined>;
    payload: z.ZodObject<{
        type: z.ZodLiteral<import("../input-message").MessageType>;
        txLog: z.ZodObject<{
            rootUnitId: z.ZodString;
            changes: z.ZodArray<z.ZodObject<{
                prevOwner: z.ZodNullable<z.ZodString>;
                owner: z.ZodString;
                volume: z.ZodNumber;
                unitId: z.ZodString;
            }, z.core.$strip>>;
        }, z.core.$strip>;
    }, z.core.$loose>;
}, z.core.$strip>;
declare const Config: z.ZodObject<{
    sqliteConfig: z.ZodString;
}, z.core.$strip>;
/**
 * Filters out unit ids that are already processed, and forwards processing.
 * It may happen that `changes` in TxLog is filtered to zero entries.
 */
export declare const ProcessedFilterSqlite: (api: Api) => {
    new (config: z.infer<typeof Config>): {
        database: Promise<Kysely<SqliteDatabase>>;
        onInput(message: z.infer<typeof InputMessage>): Promise<void>;
        api: Api;
        nodeConfig: unknown;
        messageZod: z.ZodObject<{
            topic: z.ZodLiteral<undefined>;
            payload: z.ZodObject<{
                type: z.ZodLiteral<import("../input-message").MessageType>;
                txLog: z.ZodObject<{
                    rootUnitId: z.ZodString;
                    changes: z.ZodArray<z.ZodObject<{
                        prevOwner: z.ZodNullable<z.ZodString>;
                        owner: z.ZodString;
                        volume: z.ZodNumber;
                        unitId: z.ZodString;
                    }, z.core.$strip>>;
                }, z.core.$strip>;
            }, z.core.$loose>;
        }, 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;
        onDestroy?(): void | Promise<void>;
        handleMaybePromise<T>(maybePromiseCb: () => (T | Promise<T>), done: (err?: Error) => void): void;
    };
};
export {};