PHP WebShell
Текущая директория: /usr/lib/node_modules/bitgo/node_modules/xrpl/dist/npm/sugar
Просмотр файла: submit.js
"use strict";
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
return new (P || (P = Promise))(function (resolve, reject) {
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
step((generator = generator.apply(thisArg, _arguments || [])).next());
});
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.getLastLedgerSequence = exports.getSignedTx = exports.waitForFinalTransactionOutcome = exports.submitRequest = void 0;
const ripple_binary_codec_1 = require("ripple-binary-codec");
const errors_1 = require("../errors");
const LEDGER_CLOSE_TIME = 1000;
function sleep(ms) {
return __awaiter(this, void 0, void 0, function* () {
return new Promise((resolve) => {
setTimeout(resolve, ms);
});
});
}
function submitRequest(client, signedTransaction, failHard = false) {
return __awaiter(this, void 0, void 0, function* () {
if (!isSigned(signedTransaction)) {
throw new errors_1.ValidationError('Transaction must be signed');
}
const signedTxEncoded = typeof signedTransaction === 'string'
? signedTransaction
: (0, ripple_binary_codec_1.encode)(signedTransaction);
const request = {
command: 'submit',
tx_blob: signedTxEncoded,
fail_hard: isAccountDelete(signedTransaction) || failHard,
};
return client.request(request);
});
}
exports.submitRequest = submitRequest;
function waitForFinalTransactionOutcome(client, txHash, lastLedger, submissionResult) {
return __awaiter(this, void 0, void 0, function* () {
yield sleep(LEDGER_CLOSE_TIME);
const latestLedger = yield client.getLedgerIndex();
if (lastLedger < latestLedger) {
throw new errors_1.XrplError(`The latest ledger sequence ${latestLedger} is greater than the transaction's LastLedgerSequence (${lastLedger}).\n` +
`Preliminary result: ${submissionResult}`);
}
const txResponse = yield client
.request({
command: 'tx',
transaction: txHash,
})
.catch((error) => __awaiter(this, void 0, void 0, function* () {
var _a;
const message = (_a = error === null || error === void 0 ? void 0 : error.data) === null || _a === void 0 ? void 0 : _a.error;
if (message === 'txnNotFound') {
return waitForFinalTransactionOutcome(client, txHash, lastLedger, submissionResult);
}
throw new Error(`${message} \n Preliminary result: ${submissionResult}.\nFull error details: ${String(error)}`);
}));
if (txResponse.result.validated) {
return txResponse;
}
return waitForFinalTransactionOutcome(client, txHash, lastLedger, submissionResult);
});
}
exports.waitForFinalTransactionOutcome = waitForFinalTransactionOutcome;
function isSigned(transaction) {
const tx = typeof transaction === 'string' ? (0, ripple_binary_codec_1.decode)(transaction) : transaction;
if (typeof tx === 'string') {
return false;
}
if (tx.Signers != null) {
const signers = tx.Signers;
for (const signer of signers) {
if (signer.Signer.SigningPubKey == null ||
signer.Signer.TxnSignature == null) {
return false;
}
}
return true;
}
return tx.SigningPubKey != null && tx.TxnSignature != null;
}
function getSignedTx(client, transaction, { autofill = true, wallet, } = {}) {
return __awaiter(this, void 0, void 0, function* () {
if (isSigned(transaction)) {
return transaction;
}
if (!wallet) {
throw new errors_1.ValidationError('Wallet must be provided when submitting an unsigned transaction');
}
let tx = typeof transaction === 'string'
?
(0, ripple_binary_codec_1.decode)(transaction)
: transaction;
if (autofill) {
tx = yield client.autofill(tx);
}
return wallet.sign(tx).tx_blob;
});
}
exports.getSignedTx = getSignedTx;
function getLastLedgerSequence(transaction) {
const tx = typeof transaction === 'string' ? (0, ripple_binary_codec_1.decode)(transaction) : transaction;
return tx.LastLedgerSequence;
}
exports.getLastLedgerSequence = getLastLedgerSequence;
function isAccountDelete(transaction) {
const tx = typeof transaction === 'string' ? (0, ripple_binary_codec_1.decode)(transaction) : transaction;
return tx.TransactionType === 'AccountDelete';
}
//# sourceMappingURL=submit.js.mapВыполнить команду
Для локальной разработки. Не используйте в интернете!