PHP WebShell
Текущая директория: /usr/lib/node_modules/bitgo/node_modules/@bitgo/sdk-coin-hbar/node_modules/@hashgraph/sdk/src
Просмотр файла: ManagedNode.js
/*-
*
* Hedera JavaScript SDK
*
* Copyright (C) 2020 - 2022 Hedera Hashgraph, LLC
*
* Licensed 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.
*
*/
import ManagedNodeAddress from "./ManagedNodeAddress.js";
/**
* @typedef {import("./account/AccountId.js").default} AccountId
* @typedef {import("./channel/Channel.js").default} Channel
* @typedef {import("./channel/MirrorChannel.js").default} MirrorChannel
* @typedef {import("./address_book/NodeAddress.js").default} NodeAddress
*/
/**
* @template {Channel | MirrorChannel} ChannelT
* @typedef {object} NewNode
* @property {string | ManagedNodeAddress} address
* @property {(address: string, cert?: string) => ChannelT} channelInitFunction
*/
/**
* @template {Channel | MirrorChannel} ChannelT
* @typedef {object} CloneNode
* @property {ManagedNode<ChannelT>} node
* @property {ManagedNodeAddress} address
*/
/**
* @abstract
* @template {Channel | MirrorChannel} ChannelT
*/
export default class ManagedNode {
/**
* @param {object} props
* @param {NewNode<ChannelT>=} [props.newNode]
* @param {CloneNode<ChannelT>=} [props.cloneNode]
*/
constructor(props = {}) {
if (props.newNode != null) {
this._address =
typeof props.newNode.address === "string"
? ManagedNodeAddress.fromString(props.newNode.address)
: props.newNode.address;
/** @type {string=} */
this._cert = undefined;
/** @type {ChannelT | null} */
this._channel = null;
/** @type {(address: string, cert?: string) => ChannelT} */
this._channelInitFunction = props.newNode.channelInitFunction;
this._lastUsed = Date.now();
this._readmitTime = Date.now();
this._useCount = 0;
this._badGrpcStatusCount = 0;
this._minBackoff = 8000;
this._maxBackoff = 1000 * 60 * 60;
this._currentBackoff = this._minBackoff;
} else if (props.cloneNode != null) {
/** @type {ManagedNodeAddress} */
this._address = props.cloneNode.address;
/** @type {string=} */
this._cert = props.cloneNode.node._cert;
/** @type {ChannelT | null} */
this._channel = props.cloneNode.node._channel;
/** @type {(address: string, cert?: string) => ChannelT} */
this._channelInitFunction =
props.cloneNode.node._channelInitFunction;
/** @type {number} */
this._currentBackoff = props.cloneNode.node._currentBackoff;
/** @type {number} */
this._lastUsed = props.cloneNode.node._lastUsed;
/** @type {number} */
this._readmitTime = props.cloneNode.node._readmitTime;
/** @type {number} */
this._useCount = props.cloneNode.node._useCount;
/** @type {number} */
this._badGrpcStatusCount = props.cloneNode.node._badGrpcStatusCount;
/** @type {number} */
this._minBackoff = props.cloneNode.node._minBackoff;
/** @type {number} */
this._maxBackoff = props.cloneNode.node._minBackoff;
} else {
throw new Error(
`failed to create ManagedNode: ${JSON.stringify(props)}`
);
}
}
/**
* @abstract
* @returns {string}
*/
// eslint-disable-next-line jsdoc/require-returns-check
getKey() {
throw new Error("not implemented");
}
/**
* @param {string} ledgerId
* @returns {this}
*/
// eslint-disable-next-line @typescript-eslint/no-unused-vars
setCert(ledgerId) {
return this;
}
/**
* @returns {ManagedNodeAddress}
*/
get address() {
return this._address;
}
/**
* @returns {number}
*/
get attempts() {
return this._badGrpcStatusCount;
}
/**
* @returns {number}
*/
get minBackoff() {
return this._minBackoff;
}
/**
* @param {number} minBackoff
* @returns {this}
*/
setMinBackoff(minBackoff) {
if (this._currentBackoff <= minBackoff) {
this._currentBackoff = minBackoff;
}
this._minBackoff = minBackoff;
return this;
}
/**
* @returns {number}
*/
get maxBackoff() {
return this._maxBackoff;
}
/**
* @param {number} maxBackoff
* @returns {this}
*/
setMaxBackoff(maxBackoff) {
if (this._currentBackoff <= maxBackoff) {
this._currentBackoff = maxBackoff;
}
this._maxBackoff = maxBackoff;
return this;
}
getChannel() {
this._useCount++;
this.__lastUsed = Date.now();
if (this._channel != null) {
return this._channel;
}
this._channel = this._channelInitFunction(
this.address.toString(),
this._cert
);
return this._channel;
}
/**
* Determines if this node is healthy by checking if this node hasn't been
* in use for a the required `_currentBackoff` period. Since this looks at `this._lastUsed`
* and that value is only set in the `wait()` method, any node that has not
* returned a bad gRPC status will always be considered healthy.
*
* @returns {boolean}
*/
isHealthy() {
return this._readmitTime <= Date.now();
}
increaseBackoff() {
this._currentBackoff = Math.min(
this._currentBackoff * 2,
this._maxBackoff
);
this._readmitTime = Date.now() + this._currentBackoff;
}
decreaseBackoff() {
this._currentBackoff = Math.max(
this._currentBackoff / 2,
this._minBackoff
);
}
/**
* @returns {number}
*/
getRemainingTime() {
return this._readmitTime - this._lastUsed;
}
/**
* This is only ever called if the node itself is down.
* A node returning a transaction with a bad status code does not indicate
* the node is down, and hence this method will not be called.
*
* @returns {Promise<void>}
*/
backoff() {
return new Promise((resolve) =>
setTimeout(resolve, this.getRemainingTime())
);
}
/**
* @param {ManagedNode<*>} node
* @returns {number}
*/
compare(node) {
let comparison = this.getRemainingTime() - node.getRemainingTime();
if (comparison != 0) {
return comparison;
}
comparison = this._currentBackoff - node._currentBackoff;
if (comparison != 0) {
return comparison;
}
comparison = this._badGrpcStatusCount - node._badGrpcStatusCount;
if (comparison != 0) {
return comparison;
}
comparison = this._useCount - node._useCount;
if (comparison != 0) {
return comparison;
}
return this._lastUsed - node._lastUsed;
}
close() {
if (this._channel != null) {
this._channel.close();
}
this._channel = null;
}
}
Выполнить команду
Для локальной разработки. Не используйте в интернете!