import { MongoDBConfig } from '../../../../../typings/config';
import { AccessKey, ARN, ChannelDeliveryPolicy, DeliveryPolicy, EventItem, MessageAttributes, MessageStructure, SubscriptionAttributes, SupportedProtocol, TopicAttributes, TopicTag } from '../../../../client';
import { Publish } from '../../model/publish';
import { Queue } from '../../model/queue';
import { Subscription } from '../../model/subscription';
import { SubscriptionVerificationToken } from '../../model/subscription-verification-token';
import { Topic } from '../../model/topic';
import { User } from '../../model/user';
import { StorageAdapter } from '../storage-adapter';
declare class MongoDBAdapter implements StorageAdapter {
    private static readonly QUEUE_TABLE_PREFIX;
    private static readonly Table;
    private readonly connection;
    private static dbToSystemItem;
    private static getTableName;
    getDBTableName(tableName: string): string;
    constructor(config: MongoDBConfig);
    addEventItem(queue: Queue, eventItem: EventItem): Promise<EventItem>;
    findEventsToProcess(time: Date, limit: number): Promise<Array<EventItem>>;
    getQueues(queueARNPrefix: string): Promise<Array<Queue>>;
    updateEvent(id: string, data: Record<string, unknown>, increment?: Record<string, number>): Promise<any>;
    findById(id: string): Promise<EventItem>;
    findByIdForQueue(queue: Queue, id: string): Promise<EventItem>;
    findByDeduplicationIdForQueue(queue: Queue, id: string): Promise<EventItem>;
    createQueue(user: User, queueName: string, region: string, attributes: Record<string, string>, tags: Record<string, string>): Promise<Queue>;
    getQueue(queueArn: ARN): Promise<Queue>;
    deleteQueue(queue: Queue): Promise<void>;
    confirmSubscription(subscription_: Subscription): Promise<Subscription>;
    createPublish(topicArn: ARN, targetArn: ARN, Message: string, PhoneNumber: string, Subject: string, messageAttributes: MessageAttributes, messageStructure: string, MessageStructureFinal: MessageStructure, status: string): Promise<Publish>;
    createSubscription(user: User, topic: Topic, protocol: SupportedProtocol, endPoint: string, Attributes: SubscriptionAttributes, deliveryPolicy: ChannelDeliveryPolicy, confirmed: boolean): Promise<Subscription>;
    createSubscriptionVerificationToken(subscription: Subscription, token: string): Promise<SubscriptionVerificationToken>;
    findSubscriptionVerificationTokenByToken(token: string): Promise<SubscriptionVerificationToken>;
    createTopic(name: string, displayName: string, region: string, deliveryPolicy: DeliveryPolicy, user: User, attributes: TopicAttributes, tags: TopicTag): Promise<Topic>;
    deleteTopic(topic: Topic): Promise<void>;
    findPublishes(query: {
        [p: string]: unknown;
    }, skip?: number, limit?: number): Promise<Array<Publish>>;
    findSubscriptions(where: {
        [p: string]: unknown;
    }, skip?: number, limit?: number): Promise<Array<Subscription>>;
    findTopicARN(arn: ARN): Promise<Topic>;
    findTopics(where: {
        [p: string]: unknown;
    }, skip?: number, limit?: number): Promise<Array<Topic>>;
    markPublished(publish_: Publish): Promise<void>;
    removeSubscriptions(subscriptions: Array<Subscription>): Promise<void>;
    totalSubscriptions(where: {
        [p: string]: unknown;
    }): Promise<number>;
    totalTopics(where: {
        [p: string]: unknown;
    }): Promise<number>;
    updateTopicAttributes(topic: Topic): Promise<void>;
    findAccessKeys(where: {
        [p: string]: unknown;
    }, skip?: number, limit?: number): Promise<Array<AccessKey>>;
    findUsers(where: {
        [p: string]: unknown;
    }, skip?: number, limit?: number): Promise<Array<User>>;
    accessKey(accessKey: string, secretKey: string, userId: string): Promise<AccessKey>;
    createUser(organizationId: string): Promise<User>;
    updateAccessKey(accessKey: AccessKey): Promise<AccessKey>;
}
export { MongoDBAdapter };