nodejs-client/src/errors.js

/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */

"use strict";

const util = require('util');
const ErrorType = require('./dsn/dsn_types').error_type;

//Base Error
function PException(msg) {
    this.message = msg || 'Error';
}

util.inherits(PException, Error);

//IOException
function IOException(msg) {
    IOException.super_.call(this, msg, this.constructor);
    this.name = 'IOException';
}

util.inherits(IOException, PException);

//InvalidParamException
function InvalidParamException(msg) {
    InvalidParamException.super_.call(this, msg, this.constructor);
    this.name = 'InvalidParamException';
}

util.inherits(InvalidParamException, PException);

//RPCException
function RPCException(err_type, msg) {
    RPCException.super_.call(this, msg, this.constructor);
    this.name = 'RPCException';
    this.err_type = err_type;
    this.err_code = ErrorType[this.err_type];
}

util.inherits(RPCException, IOException);

//MetaException
function MetaException(err_type, msg) {
    MetaException.super_.call(this, msg, this.constructor);
    this.name = 'MetaException';
    this.err_type = err_type;
    this.err_code = ErrorType[this.err_type];
}

util.inherits(MetaException, IOException);

let RocksDBErrorCode = {
    'kOk': 0,
    'kNotFound': 1,
    'kCorruption': 2,
    'kNotSupported': 3,
    'kInvalidArgument': 4,
    'kIOError': 5,
    'kMergeInProgress': 6,
    'kIncomplete': 7,
    'kShutdownInProgress': 8,
    'kTimedOut': 9,
    'kAborted': 10,
    'kBusy': 11,
    'kExpired': 12,
    'kTryAgain': 13,
    'kNoNeedOperate': 101,
};

//RocksDBException
function RocksDBException(err_code, msg) {
    let key, value;
    for (key in RocksDBErrorCode) {
        if (RocksDBErrorCode[key] === err_code) {
            value = key;
            break;
        }
    }
    msg = msg + ', RocksDB error ' + value;
    RocksDBException.super_.call(this, msg, this.constructor);
    this.name = 'RocksDBException';
    this.err_code = err_code;
}

util.inherits(RocksDBException, IOException);

//ConnectionClosedException
function ConnectionClosedException(msg) {
    ConnectionClosedException.super_.call(this, msg, this.constructor);
    this.name = 'ConnectionClosedException';
}

util.inherits(ConnectionClosedException, IOException);

//ThriftException
function ThriftException(msg) {
    ThriftException.super_.call(this, msg, this.constructor);
    this.name = 'ThriftException';
}

util.inherits(ThriftException, IOException);

module.exports = {
    PException: PException,
    IOException: IOException,
    InvalidParamException: InvalidParamException,
    RPCException: RPCException,
    MetaException: MetaException,
    RocksDBException: RocksDBException,
    ConnectionClosedException: ConnectionClosedException,
};