import { S as StorageAdapter, A as AgentConfig, a as AgentData, T as ThreadConfig, b as ThreadData, M as MessageRole, c as MessageAttachment, d as MessageData } from '../index-BajTtLGW.js';

/**
 * Upstash Redis configuration
 */
interface UpstashStorageConfig {
    /**
     * Upstash Redis REST URL
     * @example "https://your-redis.upstash.io"
     */
    url: string;
    /**
     * Upstash Redis REST token
     */
    token: string;
    /**
     * Optional key prefix for multi-tenancy
     * @default "snap-agent"
     */
    prefix?: string;
}
/**
 * Upstash Redis Storage Adapter
 *
 * Edge-compatible persistent storage using Upstash Redis REST API.
 * Works with Cloudflare Workers, Vercel Edge, Deno Deploy, and any WinterCG runtime.
 *
 * @example
 * ```typescript
 * import { UpstashStorage } from '@snap-agent/core/storage';
 *
 * const storage = new UpstashStorage({
 *   url: process.env.UPSTASH_REDIS_REST_URL!,
 *   token: process.env.UPSTASH_REDIS_REST_TOKEN!,
 * });
 *
 * const client = createClient({
 *   storage,
 *   providers: { openai: { apiKey: process.env.OPENAI_API_KEY! } },
 * });
 * ```
 */
declare class UpstashStorage implements StorageAdapter {
    private url;
    private token;
    private prefix;
    constructor(config: UpstashStorageConfig);
    private command;
    private pipeline;
    private key;
    private generateId;
    createAgent(config: AgentConfig): Promise<string>;
    getAgent(agentId: string): Promise<AgentData | null>;
    updateAgent(agentId: string, updates: Partial<AgentConfig>): Promise<void>;
    deleteAgent(agentId: string): Promise<void>;
    listAgents(userId: string, organizationId?: string): Promise<AgentData[]>;
    createThread(config: ThreadConfig): Promise<string>;
    getThread(threadId: string): Promise<ThreadData | null>;
    updateThread(threadId: string, updates: Partial<ThreadConfig>): Promise<void>;
    deleteThread(threadId: string): Promise<void>;
    listThreads(filters: {
        userId?: string;
        agentId?: string;
        organizationId?: string;
    }): Promise<ThreadData[]>;
    addMessage(threadId: string, role: MessageRole, content: string, attachments?: MessageAttachment[], metadata?: Record<string, any>): Promise<string>;
    getMessages(threadId: string, limit?: number): Promise<MessageData[]>;
    getConversationContext(threadId: string, maxMessages?: number): Promise<Array<{
        role: string;
        content: string;
    }>>;
    private parseStoredAgent;
    private parseStoredThread;
    /**
     * Test connection to Upstash Redis
     */
    ping(): Promise<boolean>;
    /**
     * Clear all data with this prefix (use with caution!)
     */
    clear(): Promise<void>;
    /**
     * Get storage statistics
     */
    getStats(): Promise<{
        agents: number;
        threads: number;
    }>;
}

export { UpstashStorage, type UpstashStorageConfig };