import { type AnyObject, type SyncBatchParams } from "prostgles-types";
import type { PRGLIOSocket } from "../../DboBuilder/DboBuilder";
import type { TableHandler } from "../../DboBuilder/TableHandler/TableHandler";
import type { PubSubManager, SyncParams } from "../PubSubManager";
import type { ClientSyncInfo, ServerSyncInfo, SyncBatchInfo } from "./syncData";
import type { EventTypes } from "../../Logging";
type Args = {
    socket: PRGLIOSocket;
    tableHandler: TableHandler;
    sync: SyncParams;
    pubSubManager: PubSubManager;
    logSyncData: (state: Extract<EventTypes.Sync, {
        command: "syncData";
    }>["state"]) => void;
};
export declare const getSyncUtilFunctions: ({ socket, tableHandler, sync, pubSubManager, logSyncData, }: Args) => {
    rowsIdsMatch: (a?: AnyObject, b?: AnyObject) => boolean | undefined;
    rowsFullyMatch: (a?: AnyObject, b?: AnyObject) => boolean | undefined;
    getServerRowInfo: (args?: SyncBatchParams) => Promise<ServerSyncInfo>;
    getClientRowInfo: (args?: SyncBatchInfo) => Promise<Partial<{
        c_fr: AnyObject;
        c_lr: AnyObject;
        c_count: number | string;
    }>>;
    getClientData: (from_synced: number | undefined, offset?: number) => Promise<AnyObject[]>;
    getServerData: (from_synced: number | undefined, offset?: number) => Promise<AnyObject[]>;
    deleteData: (deleted: AnyObject[]) => Promise<void>;
    upsertData: (data: AnyObject[], source: "WAL" | "client") => Promise<{
        inserted: number;
        updated: number;
        total: number;
    }>;
    pushData: (request: {
        state: "syncing-data";
        data: AnyObject[];
    } | {
        state: "synced";
    }) => Promise<{
        pushed: number;
    }>;
    getLastSynced: (clientSyncInfo?: ClientSyncInfo) => Promise<number | null>;
    updateSyncLR: (data: AnyObject[]) => void;
    syncBatch: (from_synced: SyncBatchInfo["from_synced"]) => Promise<boolean>;
};
export {};
//# sourceMappingURL=getSyncUtilFunctions.d.ts.map