import { z } from 'zod/v4-mini';
import { Readable } from 'node:stream';
import { mongodb } from '@unchainedshop/mongodb';
import * as AssortmentHandlers from './handlers/assortment/index.ts';
import * as FilterHandlers from './handlers/filter/index.ts';
import * as ProductHandlers from './handlers/product/index.ts';
import type { Modules } from '../modules.ts';
import type { Services } from '../services/index.ts';
export interface BulkImportOperationResult {
    entity: string;
    operation: string;
    success: boolean;
}
export type BulkImportOperation<T> = {
    payloadSchema?: z.ZodMiniObject;
} & ((payload: any, options: {
    bulk: (collection: string) => typeof mongodb.BulkOperationBase;
    createShouldUpsertIfIDExists?: boolean;
    updateShouldUpsertIfIDNotExists?: boolean;
    skipCacheInvalidation?: boolean;
}, unchainedAPI: T) => Promise<BulkImportOperationResult>);
export type BulkImportHandler<T> = Record<string, BulkImportOperation<T>>;
export declare const getOperation: (entity: string, operation: string) => BulkImportOperation<any>;
export default function createBulkImporterFactory(db: any, bulkImporterOptions: any): {
    createBulkImporter: (options: any) => {
        validate: (event: any) => Promise<void>;
        prepare: (event: any, unchainedAPI: {
            modules: Modules;
            services: Services;
        }) => Promise<void>;
        execute: () => Promise<({
            processedOperations: {};
            processedBulkOperations: PromiseSettledResult<any>[];
        } | {
            preparationIssues: {
                operation: string;
                entity: string;
                payloadId: string;
                errorCode: string;
                errorMessage: string;
            }[];
        })[] | ({
            processedOperations: {};
            processedBulkOperations: PromiseSettledResult<any>[];
        } | null)[]>;
        invalidateCaches: (unchainedAPI: {
            modules: Modules;
            services: Services;
        }) => Promise<void>;
    };
    validateEventStream: (readStream: Readable) => Promise<void>;
    pipeEventStream: (readStream: Readable, bulkImporter: ReturnType<(options: any) => {
        validate: (event: any) => Promise<void>;
        prepare: (event: any, unchainedAPI: {
            modules: Modules;
            services: Services;
        }) => Promise<void>;
        execute: () => Promise<({
            processedOperations: {};
            processedBulkOperations: PromiseSettledResult<any>[];
        } | {
            preparationIssues: {
                operation: string;
                entity: string;
                payloadId: string;
                errorCode: string;
                errorMessage: string;
            }[];
        })[] | ({
            processedOperations: {};
            processedBulkOperations: PromiseSettledResult<any>[];
        } | null)[]>;
        invalidateCaches: (unchainedAPI: {
            modules: Modules;
            services: Services;
        }) => Promise<void>;
    }>, unchainedAPI: {
        modules: Modules;
        services: Services;
    }) => Promise<void>;
};
export type BulkImporter = ReturnType<typeof createBulkImporterFactory>;
export { AssortmentHandlers, ProductHandlers, FilterHandlers };