import { OnModuleDestroy } from "@nestjs/common";
import { ConfigService } from "@nestjs/config";
import { Redis } from "ioredis";
import { BaseConfigInterface } from "../../../config/interfaces";
interface ClientInfo {
    userId: string;
    companyId: string;
    socketId: string;
    connectedAt: Date;
}
export declare class RedisClientStorageService implements OnModuleDestroy {
    private readonly configService;
    private redis;
    private readonly CLIENT_KEY_PREFIX;
    private readonly USER_CLIENTS_KEY_PREFIX;
    private readonly COMPANY_USERS_KEY_PREFIX;
    constructor(configService: ConfigService<BaseConfigInterface>);
    getRedisClient(): Redis;
    isConnected(): boolean;
    /**
     * Acquire a distributed lock using Redis SET NX PX.
     * @param key The lock key
     * @param ttlMs Time-to-live in milliseconds (auto-release)
     * @returns Lock value if acquired, null if already locked
     */
    acquireLock(key: string, ttlMs: number): Promise<string | null>;
    /**
     * Release a distributed lock. Only releases if the lock value matches
     * (prevents releasing another holder's lock). Atomic via Lua.
     * @param key The lock key
     * @param lockValue The value returned by acquireLock
     */
    releaseLock(key: string, lockValue: string): Promise<boolean>;
    addClient(userId: string, companyId: string, socketId: string): Promise<void>;
    removeClient(socketId: string): Promise<void>;
    getClientInfo(socketId: string): Promise<ClientInfo | null>;
    getUserClients(userId: string): Promise<string[]>;
    getCompanyUsers(companyId: string): Promise<string[]>;
    getUserCompany(userId: string): Promise<string | null>;
    getAllConnectedUsers(): Promise<string[]>;
    cleanupExpiredClients(): Promise<void>;
    onModuleDestroy(): Promise<void>;
}
export {};
//# sourceMappingURL=redis.client.storage.service.d.ts.map