blob: e4fb165c5497f234e0ab8b70ea65d94822d48f37 [file] [log] [blame]
/*
* 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 ArgumentChecker = require('./internal/ArgumentChecker');
const Errors = require('./Errors');
/**
* Class representing an item of Ignite enum type.
*
* The item is defined by:
* - type Id (mandatory) - Id of the Ignite enum type.
* - ordinal (optional) - ordinal of the item in the Ignite enum type.
* - name (optional) - name of the item (field name in the Ignite enum type).
* - value (optional) - value of the item.
* Usually, at least one from the optional ordinal, name or value must be specified
* in order to use an instance of this class in Ignite operations.
*
* To distinguish one item from another, the Ignite client analyzes the optional fields in the following order:
* ordinal, name, value.
*/
class EnumItem {
/**
* Public constructor.
*
* @param {number} typeId - Id of the Ignite enum type.
*
* @return {EnumItem} - new EnumItem instance
*
* @throws {IgniteClientError} if error.
*/
constructor(typeId) {
this.setTypeId(typeId);
this._ordinal = null;
this._name = null;
this._value = null;
}
/**
* Returns Id of the Ignite enum type.
*
* @return {number} - Id of the enum type.
*/
getTypeId() {
return this._typeId;
}
/**
* Updates Id of the Ignite enum type.
*
* @param {number} typeId - new Id of the Ignite enum type.
*
* @return {EnumItem} - the same instance of EnumItem
*
* @throws {IgniteClientError} if error.
*/
setTypeId(typeId) {
ArgumentChecker.isInteger(typeId, 'typeId');
this._typeId = typeId;
return this;
}
/**
* Returns ordinal of the item in the Ignite enum type
* or null if ordinal is not set.
*
* @return {number} - ordinal of the item in the Ignite enum type.
*/
getOrdinal() {
return this._ordinal;
}
/**
* Sets or updates ordinal of the item in the Ignite enum type.
*
* @param {number} ordinal - ordinal of the item in the Ignite enum type.
*
* @return {EnumItem} - the same instance of EnumItem
*
* @throws {IgniteClientError} if error.
*/
setOrdinal(ordinal) {
ArgumentChecker.isInteger(ordinal, 'ordinal');
this._ordinal = ordinal;
return this;
}
/**
* Returns name of the item
* or null if name is not set.
*
* @return {string} - name of the item.
*/
getName() {
return this._name;
}
/**
* Sets or updates name of the item.
*
* @param {string} name - name of the item.
*
* @return {EnumItem} - the same instance of EnumItem
*
* @throws {IgniteClientError} if error.
*/
setName(name) {
ArgumentChecker.notEmpty(name, 'name');
this._name = name;
return this;
}
/**
* Returns value of the item
* or null if value is not set.
*
* @return {number} - value of the item.
*/
getValue() {
return this._value;
}
/**
* Sets or updates value of the item.
*
* @param {number} value - value of the item.
*
* @return {EnumItem} - the same instance of EnumItem
*
* @throws {IgniteClientError} if error.
*/
setValue(value) {
ArgumentChecker.isInteger(value, 'value');
this._value = value;
return this;
}
/** Private methods */
/**
* @ignore
*/
async _write(buffer) {
buffer.writeInteger(this._typeId);
if (this._ordinal !== null) {
buffer.writeInteger(this._ordinal);
return;
}
else if (this._name !== null || this._value !== null) {
const type = await this._getType(this._typeId);
if (type._isEnum && type._enumValues) {
for (let i = 0; i < type._enumValues.length; i++) {
if (this._name === type._enumValues[i][0] ||
this._value === type._enumValues[i][1]) {
buffer.writeInteger(i);
return;
}
}
}
}
throw Errors.IgniteClientError.illegalArgumentError(
'Proper ordinal, name or value must be specified for EnumItem');
}
/**
* @ignore
*/
async _read(buffer) {
this._typeId = buffer.readInteger();
this._ordinal = buffer.readInteger();
const type = await this._getType(this._typeId);
if (!type._isEnum || !type._enumValues || type._enumValues.length <= this._ordinal) {
throw new Errors.IgniteClientError('EnumItem can not be deserialized: type mismatch');
}
this._name = type._enumValues[this._ordinal][0];
this._value = type._enumValues[this._ordinal][1];
}
/**
* @ignore
*/
async _getType(typeId) {
const BinaryTypeStorage = require('./internal/BinaryTypeStorage');
return await BinaryTypeStorage.getEntity().getType(typeId);
}
}
module.exports = EnumItem;