PHP WebShell
Текущая директория: /opt/BitGoJS/node_modules/@hashgraph/sdk/lib/client
Просмотр файла: Client.cjs
"use strict";
Object.defineProperty(exports, "__esModule", {
value: true
});
exports.default = void 0;
var _AccountId = _interopRequireDefault(require("../account/AccountId.cjs"));
var _AccountBalanceQuery = _interopRequireDefault(require("../account/AccountBalanceQuery.cjs"));
var _Hbar = _interopRequireDefault(require("../Hbar.cjs"));
var _Network = _interopRequireDefault(require("./Network.cjs"));
var _MirrorNetwork = _interopRequireDefault(require("./MirrorNetwork.cjs"));
var _PublicKey = _interopRequireDefault(require("../PublicKey.cjs"));
var _PrivateKey = _interopRequireDefault(require("../PrivateKey.cjs"));
var _LedgerId = _interopRequireDefault(require("../LedgerId.cjs"));
var _FileId = _interopRequireDefault(require("../file/FileId.cjs"));
var _Cache = _interopRequireDefault(require("../Cache.cjs"));
var _Logger = _interopRequireDefault(require("../logger/Logger.cjs"));
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
/*-
*
* 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.
*
*/
// eslint-disable-line
/**
* @typedef {import("../channel/Channel.js").default} Channel
* @typedef {import("../channel/MirrorChannel.js").default} MirrorChannel
* @typedef {import("../address_book/NodeAddressBook.js").default} NodeAddressBook
*/
/**
* @typedef {object} Operator
* @property {string | PrivateKey} privateKey
* @property {string | AccountId} accountId
*/
/**
* @typedef {object} ClientOperator
* @property {PublicKey} publicKey
* @property {AccountId} accountId
* @property {(message: Uint8Array) => Promise<Uint8Array>} transactionSigner
*/
/**
* @typedef {object} ClientConfiguration
* @property {{[key: string]: (string | AccountId)} | string} network
* @property {string[] | string} [mirrorNetwork]
* @property {Operator} [operator]
* @property {boolean} [scheduleNetworkUpdate]
*/
/**
* @typedef {"mainnet" | "testnet" | "previewnet"} NetworkName
*/
/**
* @abstract
* @template {Channel} ChannelT
* @template {MirrorChannel} MirrorChannelT
*/
class Client {
/**
* @protected
* @hideconstructor
* @param {ClientConfiguration} [props]
*/
constructor(props) {
/**
* List of mirror network URLs.
*
* @internal
* @type {MirrorNetwork}
*/
this._mirrorNetwork = new _MirrorNetwork.default(this._createMirrorNetworkChannel());
/**
* Map of node account ID (as a string)
* to the node URL.
*
* @internal
* @type {Network}
*/
this._network = new _Network.default(this._createNetworkChannel());
/**
* @internal
* @type {?ClientOperator}
*/
this._operator = null;
/**
* @private
* @type {?Hbar}
*/
this._defaultMaxTransactionFee = null;
/**
* @private
* @type {Hbar}
*/
this._maxQueryPayment = new _Hbar.default(1);
if (props != null) {
if (props.operator != null) {
this.setOperator(props.operator.accountId, props.operator.privateKey);
}
}
/** @type {number | null} */
this._maxAttempts = null;
/** @private */
this._signOnDemand = false;
/** @private */
this._autoValidateChecksums = false;
/** @private */
this._minBackoff = 250;
/** @private */
this._maxBackoff = 8000;
/** @private */
this._defaultRegenerateTransactionId = true;
/** @private */
this._requestTimeout = null;
/** @private */
this._networkUpdatePeriod = 24 * 60 * 60 * 1000;
/** @private */
this._isShutdown = false;
if (props != null && props.scheduleNetworkUpdate !== false) {
this._initialNetworkUpdate();
this._scheduleNetworkUpdate();
}
/** @internal */
/** @type {NodeJS.Timeout} */
this._timer;
/**
* Logger
*
* @external
* @type {Logger | null}
*/
this._logger = null;
}
/**
* @deprecated
* @param {NetworkName} networkName
* @returns {this}
*/
setNetworkName(networkName) {
// uses custom NetworkName type
// remove if phasing out set|get NetworkName
console.warn("Deprecated: Use `setLedgerId` instead");
return this.setLedgerId(networkName);
}
/**
* @deprecated
* @returns {string | null}
*/
get networkName() {
console.warn("Deprecated: Use `ledgerId` instead");
return this.ledgerId != null ? this.ledgerId.toString() : null;
}
/**
* @param {string|LedgerId} ledgerId
* @returns {this}
*/
setLedgerId(ledgerId) {
this._network.setLedgerId(typeof ledgerId === "string" ? _LedgerId.default.fromString(ledgerId) : ledgerId);
return this;
}
/**
* @returns {LedgerId | null}
*/
get ledgerId() {
return this._network._ledgerId != null ? this._network.ledgerId : null;
}
/**
* @param {{[key: string]: (string | AccountId)} | string} network
* @returns {void}
*/
// eslint-disable-next-line @typescript-eslint/no-unused-vars
setNetwork(network) {
// TODO: This logic _can_ be de-duplicated and likely should
throw new Error("not implemented");
}
/**
* @param {NodeAddressBook} addressBook
* @returns {this}
*/
setNetworkFromAddressBook(addressBook) {
this._network.setNetworkFromAddressBook(addressBook);
return this;
}
/**
* @returns {{[key: string]: (string | AccountId)}}
*/
get network() {
return this._network.network;
}
/**
* @param {string[] | string} mirrorNetwork
* @returns {void}
*/
// eslint-disable-next-line @typescript-eslint/no-unused-vars
setMirrorNetwork(mirrorNetwork) {
throw new Error("not implemented");
}
/**
* @returns {string[]}
*/
get mirrorNetwork() {
return this._mirrorNetwork.network;
}
/**
* @returns {boolean}
*/
get signOnDemand() {
return this._signOnDemand;
}
/**
* @param {boolean} signOnDemand
*/
setSignOnDemand(signOnDemand) {
this._signOnDemand = signOnDemand;
}
/**
* @returns {boolean}
*/
isTransportSecurity() {
return this._network.isTransportSecurity();
}
/**
* @param {boolean} transportSecurity
* @returns {this}
*/
setTransportSecurity(transportSecurity) {
this._network.setTransportSecurity(transportSecurity);
return this;
}
/**
* Set the account that will, by default, pay for transactions and queries built with this client.
*
* @param {AccountId | string} accountId
* @param {PrivateKey | string} privateKey
* @returns {this}
*/
setOperator(accountId, privateKey) {
const key = typeof privateKey === "string" ? _PrivateKey.default.fromString(privateKey) : privateKey;
return this.setOperatorWith(accountId, key.publicKey, message => Promise.resolve(key.sign(message)));
}
/**
* Sets the account that will, by default, pay for transactions and queries built with
* this client.
*
* @param {AccountId | string} accountId
* @param {PublicKey | string} publicKey
* @param {(message: Uint8Array) => Promise<Uint8Array>} transactionSigner
* @returns {this}
*/
setOperatorWith(accountId, publicKey, transactionSigner) {
const accountId_ = accountId instanceof _AccountId.default ? accountId : _AccountId.default.fromString(accountId);
if (this._network._ledgerId != null) {
accountId_.validateChecksum(this);
}
this._operator = {
transactionSigner,
accountId: accountId_,
publicKey: publicKey instanceof _PublicKey.default ? publicKey : _PublicKey.default.fromString(publicKey)
};
return this;
}
/**
* @param {boolean} value
* @returns {this}
*/
setAutoValidateChecksums(value) {
this._autoValidateChecksums = value;
return this;
}
/**
* @returns {boolean}
*/
isAutoValidateChecksumsEnabled() {
return this._autoValidateChecksums;
}
/**
* @returns {?AccountId}
*/
get operatorAccountId() {
return this._operator != null ? this._operator.accountId : null;
}
/**
* @returns {?PublicKey}
*/
get operatorPublicKey() {
return this._operator != null ? this._operator.publicKey : null;
}
/**
* @deprecated - Use `defaultMaxTransactionFee` instead
* @returns {?Hbar}
*/
get maxTransactionFee() {
return this._defaultMaxTransactionFee;
}
/**
* @deprecated - Use `setDefaultMaxTransactionFee()` instead
* Set the maximum fee to be paid for transactions
* executed by this client.
* @param {Hbar} maxTransactionFee
* @returns {this}
*/
setMaxTransactionFee(maxTransactionFee) {
this._defaultMaxTransactionFee = maxTransactionFee;
return this;
}
/**
* @returns {?Hbar}
*/
get defaultMaxTransactionFee() {
return this._defaultMaxTransactionFee;
}
/**
* Set the defaultimum fee to be paid for transactions
* executed by this client.
*
* @param {Hbar} defaultMaxTransactionFee
* @returns {this}
*/
setDefaultMaxTransactionFee(defaultMaxTransactionFee) {
this._defaultMaxTransactionFee = defaultMaxTransactionFee;
return this;
}
/**
* @returns {boolean}
*/
get defaultRegenerateTransactionId() {
return this._defaultRegenerateTransactionId;
}
/**
* Set if a new transaction ID should be generated when a `TRANSACTION_EXPIRED` status
* is returned.
*
* @param {boolean} defaultRegenerateTransactionId
* @returns {this}
*/
setDefaultRegenerateTransactionId(defaultRegenerateTransactionId) {
this._defaultRegenerateTransactionId = defaultRegenerateTransactionId;
return this;
}
/**
* @returns {Hbar}
*/
get maxQueryPayment() {
return this._maxQueryPayment;
}
/**
* Set the maximum payment allowable for queries.
*
* @param {Hbar} maxQueryPayment
* @returns {Client<ChannelT, MirrorChannelT>}
*/
setMaxQueryPayment(maxQueryPayment) {
this._maxQueryPayment = maxQueryPayment;
return this;
}
/**
* @returns {number}
*/
get maxAttempts() {
return this._maxAttempts != null ? this._maxAttempts : 10;
}
/**
* @param {number} maxAttempts
* @returns {this}
*/
setMaxAttempts(maxAttempts) {
this._maxAttempts = maxAttempts;
return this;
}
/**
* @returns {number}
*/
get maxNodeAttempts() {
return this._network.maxNodeAttempts;
}
/**
* @param {number} maxNodeAttempts
* @returns {this}
*/
setMaxNodeAttempts(maxNodeAttempts) {
this._network.setMaxNodeAttempts(maxNodeAttempts);
return this;
}
/**
* @returns {number}
*/
get nodeWaitTime() {
return this._network.minBackoff;
}
/**
* @param {number} nodeWaitTime
* @returns {this}
*/
setNodeWaitTime(nodeWaitTime) {
this._network.setMinBackoff(nodeWaitTime);
return this;
}
/**
* @returns {number}
*/
get maxNodesPerTransaction() {
return this._network.maxNodesPerTransaction;
}
/**
* @param {number} maxNodesPerTransaction
* @returns {this}
*/
setMaxNodesPerTransaction(maxNodesPerTransaction) {
this._network.setMaxNodesPerTransaction(maxNodesPerTransaction);
return this;
}
/**
* @param {?number} minBackoff
* @returns {this}
*/
setMinBackoff(minBackoff) {
if (minBackoff == null) {
throw new Error("minBackoff cannot be null.");
}
if (minBackoff > this._maxBackoff) {
throw new Error("minBackoff cannot be larger than maxBackoff.");
}
this._minBackoff = minBackoff;
return this;
}
/**
* @returns {number}
*/
get minBackoff() {
return this._minBackoff;
}
/**
* @param {?number} maxBackoff
* @returns {this}
*/
setMaxBackoff(maxBackoff) {
if (maxBackoff == null) {
throw new Error("maxBackoff cannot be null.");
} else if (maxBackoff < this._minBackoff) {
throw new Error("maxBackoff cannot be smaller than minBackoff.");
}
this._maxBackoff = maxBackoff;
return this;
}
/**
* @returns {number}
*/
get maxBackoff() {
return this._maxBackoff;
}
/**
* @param {number} nodeMinBackoff
* @returns {this}
*/
setNodeMinBackoff(nodeMinBackoff) {
this._network.setMinBackoff(nodeMinBackoff);
return this;
}
/**
* @returns {number}
*/
get nodeMinBackoff() {
return this._network.minBackoff;
}
/**
* @param {number} nodeMaxBackoff
* @returns {this}
*/
setNodeMaxBackoff(nodeMaxBackoff) {
this._network.setMaxBackoff(nodeMaxBackoff);
return this;
}
/**
* @returns {number}
*/
get nodeMaxBackoff() {
return this._network.maxBackoff;
}
/**
* @param {number} nodeMinReadmitPeriod
* @returns {this}
*/
setNodeMinReadmitPeriod(nodeMinReadmitPeriod) {
this._network.setNodeMinReadmitPeriod(nodeMinReadmitPeriod);
return this;
}
/**
* @returns {number}
*/
get nodeMinReadmitPeriod() {
return this._network.nodeMinReadmitPeriod;
}
/**
* @param {number} nodeMaxReadmitPeriod
* @returns {this}
*/
setNodeMaxReadmitPeriod(nodeMaxReadmitPeriod) {
this._network.setNodeMaxReadmitPeriod(nodeMaxReadmitPeriod);
return this;
}
/**
* @returns {number}
*/
get nodeMaxReadmitPeriod() {
return this._network.nodeMaxReadmitPeriod;
}
/**
* @param {number} requestTimeout - Number of milliseconds
* @returns {this}
*/
setRequestTimeout(requestTimeout) {
this._requestTimeout = requestTimeout;
return this;
}
/**
* @returns {?number}
*/
get requestTimeout() {
return this._requestTimeout;
}
/**
* @returns {number}
*/
get networkUpdatePeriod() {
return this._networkUpdatePeriod;
}
/**
* @param {number} networkUpdatePeriod
* @returns {this}
*/
setNetworkUpdatePeriod(networkUpdatePeriod) {
clearTimeout(this._timer);
this._networkUpdatePeriod = networkUpdatePeriod;
this._scheduleNetworkUpdate();
return this;
}
/**
* Set logger
*
* @param {Logger} logger
* @returns {this}
*/
setLogger(logger) {
this._logger = logger;
return this;
}
/**
* Get logger if set
*
* @returns {?Logger}
*/
get logger() {
return this._logger;
}
/**
* @param {AccountId | string} accountId
*/
async ping(accountId) {
await new _AccountBalanceQuery.default({
accountId
}).setNodeAccountIds([accountId instanceof _AccountId.default ? accountId : _AccountId.default.fromString(accountId)]).execute(this);
}
async pingAll() {
for (const nodeAccountId of Object.values(this._network.network)) {
await this.ping(nodeAccountId);
}
}
/**
* @returns {void}
*/
close() {
this._network.close();
this._mirrorNetwork.close();
this._isShutdown = true;
clearTimeout(this._timer);
}
/**
* @abstract
* @returns {(address: string) => ChannelT}
*/
_createNetworkChannel() {
throw new Error("not implemented");
}
/**
* @abstract
* @returns {(address: string) => MirrorChannelT}
*/
_createMirrorNetworkChannel() {
throw new Error("not implemented");
}
/**
* @private
*/
_scheduleNetworkUpdate() {
// This is the automatic network update promise that _eventually_ completes
// eslint-disable-next-line @typescript-eslint/no-floating-promises,@typescript-eslint/no-misused-promises
this._timer = setTimeout(async () => {
try {
const addressBook = await _Cache.default.addressBookQueryConstructor().setFileId(_FileId.default.ADDRESS_BOOK).execute(this);
this.setNetworkFromAddressBook(addressBook);
if (!this._isShutdown) {
// Recall this method to continuously update the network
// every `networkUpdatePeriod` amount of itme
this._scheduleNetworkUpdate();
}
} catch (error) {
if (this._logger) {
this._logger.trace(`failed to update client address book: ${
/** @type {Error} */error.toString()}`);
}
}
}, this._networkUpdatePeriod);
}
/**
* @private
*/
_initialNetworkUpdate() {
// This is the automatic network update promise that _eventually_ completes
// eslint-disable-next-line @typescript-eslint/no-floating-promises,@typescript-eslint/no-misused-promises
setTimeout(async () => {
try {
const addressBook = await _Cache.default.addressBookQueryConstructor().setFileId(_FileId.default.ADDRESS_BOOK).execute(this);
this.setNetworkFromAddressBook(addressBook);
} catch (error) {
if (this._logger) {
this._logger.trace(`failed to update client address book: ${
/** @type {Error} */error.toString()}`);
}
}
}, 1000);
}
/**
* @returns {boolean}
*/
get isClientShutDown() {
return this._isShutdown;
}
}
exports.default = Client;Выполнить команду
Для локальной разработки. Не используйте в интернете!