errors.ts

import { RedisCommandRawReply } from './commands';

export class AbortError extends Error {
    constructor() {
        super('The command was aborted');
    }
}

export class WatchError extends Error {
    constructor() {
        super('One (or more) of the watched keys has been changed');
    }
}

export class ConnectionTimeoutError extends Error {
    constructor() {
        super('Connection timeout');
    }
}

export class ClientClosedError extends Error {
    constructor() {
        super('The client is closed');
    }
}

export class ClientOfflineError extends Error {
    constructor() {
        super('The client is offline');
    }
}

export class DisconnectsClientError extends Error {
    constructor() {
        super('Disconnects client');
    }
}

export class SocketClosedUnexpectedlyError extends Error {
    constructor() {
        super('Socket closed unexpectedly');
    }
}

export class RootNodesUnavailableError extends Error {
    constructor() {
        super('All the root nodes are unavailable');
    }
}

export class ReconnectStrategyError extends Error {
    originalError: Error;
    socketError: unknown;

    constructor(originalError: Error, socketError: unknown) {
        super(originalError.message);
        this.originalError = originalError;
        this.socketError = socketError;
    }
}

export class ErrorReply extends Error {
    constructor(message: string) {
        super(message);
        this.stack = undefined;
    }
}

export class MultiErrorReply extends ErrorReply {
    replies;
    errorIndexes;

    constructor(replies: Array<RedisCommandRawReply | ErrorReply>, errorIndexes: Array<number>) {
        super(`${errorIndexes.length} commands failed, see .replies and .errorIndexes for more information`);
        this.replies = replies;
        this.errorIndexes = errorIndexes;
    }

    *errors() {
        for (const index of this.errorIndexes) {
            yield this.replies[index];
        }
    }
}