mirror of
https://github.com/Xahau/xahau.js.git
synced 2025-11-08 14:55:49 +00:00
Compare commits
17 Commits
hooks-test
...
@transia/x
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
445d0c6633 | ||
|
|
501d3158a0 | ||
|
|
e27943aa3a | ||
|
|
c7aafb2595 | ||
|
|
036312d361 | ||
|
|
3467680506 | ||
|
|
f209126364 | ||
|
|
33a8b3679a | ||
|
|
572aaa7a40 | ||
|
|
b6c11d1df8 | ||
|
|
526d1e7686 | ||
|
|
3c668f41b8 | ||
|
|
aeb29a20a1 | ||
|
|
8c814482e5 | ||
|
|
5b57ea8b77 | ||
|
|
7663e6049f | ||
|
|
420d6b2c35 |
2
.vscode/settings.json
vendored
2
.vscode/settings.json
vendored
@@ -29,7 +29,7 @@
|
||||
"enable": true
|
||||
},
|
||||
"editor.codeActionsOnSave": {
|
||||
"source.fixAll.eslint": true
|
||||
"source.fixAll.eslint": "explicit"
|
||||
},
|
||||
"files.insertFinalNewline": true,
|
||||
"files.trimFinalNewlines": true,
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "@transia/ripple-binary-codec",
|
||||
"version": "1.4.6-alpha.5",
|
||||
"version": "1.4.6-alpha.8",
|
||||
"description": "XRP Ledger binary codec",
|
||||
"files": [
|
||||
"dist/*",
|
||||
|
||||
@@ -2521,11 +2521,11 @@
|
||||
"temBAD_PATH": -291,
|
||||
"temBAD_PATH_LOOP": -290,
|
||||
"temBAD_REGKEY": -289,
|
||||
"temBAD_SEND_XRP_LIMIT": -288,
|
||||
"temBAD_SEND_XRP_MAX": -287,
|
||||
"temBAD_SEND_XRP_NO_DIRECT": -286,
|
||||
"temBAD_SEND_XRP_PARTIAL": -285,
|
||||
"temBAD_SEND_XRP_PATHS": -284,
|
||||
"temBAD_SEND_NATIVE_LIMIT": -288,
|
||||
"temBAD_SEND_NATIVE_MAX": -287,
|
||||
"temBAD_SEND_NATIVE_NO_DIRECT": -286,
|
||||
"temBAD_SEND_NATIVE_PARTIAL": -285,
|
||||
"temBAD_SEND_NATIVE_PATHS": -284,
|
||||
"temBAD_SEQUENCE": -283,
|
||||
"temBAD_SIGNATURE": -282,
|
||||
"temBAD_SRC_ACCOUNT": -281,
|
||||
@@ -2557,7 +2557,6 @@
|
||||
"temXCHAIN_BRIDGE_BAD_REWARD_AMOUNT": -255,
|
||||
"temXCHAIN_TOO_MANY_ATTESTATIONS": -254,
|
||||
"temHOOK_DATA_TOO_LARGE": -253,
|
||||
"temHOOK_REJECTED": -252,
|
||||
|
||||
"tefFAILURE": -199,
|
||||
"tefALREADY": -198,
|
||||
@@ -2582,6 +2581,7 @@
|
||||
"tefNFTOKEN_IS_NOT_TRANSFERABLE": -179,
|
||||
"tefPAST_IMPORT_SEQ": -178,
|
||||
"tefPAST_IMPORT_VL_SEQ": -177,
|
||||
"tefNONDIR_EMIT": -176,
|
||||
|
||||
"terRETRY": -99,
|
||||
"terFUNDS_SPENT": -98,
|
||||
@@ -2610,7 +2610,7 @@
|
||||
"tecINSUF_RESERVE_LINE": 122,
|
||||
"tecINSUF_RESERVE_OFFER": 123,
|
||||
"tecNO_DST": 124,
|
||||
"tecNO_DST_INSUF_XRP": 125,
|
||||
"tecNO_DST_INSUF_NATIVE": 125,
|
||||
"tecNO_LINE_INSUF_RESERVE": 126,
|
||||
"tecNO_LINE_REDUNDANT": 127,
|
||||
"tecPATH_DRY": 128,
|
||||
@@ -2672,6 +2672,7 @@
|
||||
"tecXCHAIN_PAYMENT_FAILED": 184,
|
||||
"tecXCHAIN_SELF_COMMIT": 185,
|
||||
"tecXCHAIN_BAD_PUBLIC_KEY_ACCOUNT_PAIR": 186,
|
||||
"tecINSUF_RESERVE_SELLER": 187,
|
||||
"tecLAST_POSSIBLE_ENTRY": 255
|
||||
},
|
||||
"TRANSACTION_TYPES": {
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "@transia/xrpl",
|
||||
"version": "2.7.3-alpha.18",
|
||||
"version": "2.7.3-alpha.25",
|
||||
"license": "ISC",
|
||||
"description": "A TypeScript/JavaScript API for interacting with the XRP Ledger in Node.js and the browser",
|
||||
"files": [
|
||||
@@ -23,7 +23,7 @@
|
||||
},
|
||||
"dependencies": {
|
||||
"@transia/ripple-address-codec": "^4.2.8-alpha.0",
|
||||
"@transia/ripple-binary-codec": "^1.4.6-alpha.5",
|
||||
"@transia/ripple-binary-codec": "^1.4.6-alpha.8",
|
||||
"@transia/ripple-keypairs": "^1.1.8-alpha.0",
|
||||
"bignumber.js": "^9.0.0",
|
||||
"bip32": "^2.0.6",
|
||||
|
||||
46
packages/xrpl/src/models/methods/accountNamespace.ts
Normal file
46
packages/xrpl/src/models/methods/accountNamespace.ts
Normal file
@@ -0,0 +1,46 @@
|
||||
import { HookState } from '../ledger'
|
||||
|
||||
import { BaseRequest, BaseResponse } from './baseMethod'
|
||||
|
||||
/**
|
||||
* The `account_namespace` command retrieves the account namespace. All information retrieved is relative to a
|
||||
* particular version of the ledger. Returns an {@link AccountNamespaceResponse}.
|
||||
*
|
||||
* @category Requests
|
||||
*/
|
||||
export interface AccountNamespaceRequest extends BaseRequest {
|
||||
command: 'account_namespace'
|
||||
/** A unique identifier for the account, most commonly the account's address. */
|
||||
account: string
|
||||
/** The hex namespace. */
|
||||
namespace_id?: string
|
||||
}
|
||||
|
||||
/**
|
||||
* Response expected from an {@link AccountNamespaceRequest}.
|
||||
*
|
||||
* @category Responses
|
||||
*/
|
||||
export interface AccountNamespaceResponse extends BaseResponse {
|
||||
result: {
|
||||
/**
|
||||
* The account requested.
|
||||
*/
|
||||
account: string
|
||||
/**
|
||||
* The namespace_id requested.
|
||||
*/
|
||||
namespace_id: string
|
||||
/**
|
||||
* A list of HookStates for the specified account namespace_id.
|
||||
*/
|
||||
namespace_entries: HookState[]
|
||||
/**
|
||||
* The ledger index of the current open ledger, which was used when
|
||||
* retrieving this information.
|
||||
*/
|
||||
ledger_current_index: number
|
||||
/** If true, this data comes from a validated ledger. */
|
||||
validated: boolean
|
||||
}
|
||||
}
|
||||
@@ -8,6 +8,10 @@ import {
|
||||
} from './accountCurrencies'
|
||||
import { AccountInfoRequest, AccountInfoResponse } from './accountInfo'
|
||||
import { AccountLinesRequest, AccountLinesResponse } from './accountLines'
|
||||
import {
|
||||
AccountNamespaceRequest,
|
||||
AccountNamespaceResponse,
|
||||
} from './accountNamespace'
|
||||
import { AccountNFTsRequest, AccountNFTsResponse } from './accountNFTs'
|
||||
import { AccountObjectsRequest, AccountObjectsResponse } from './accountObjects'
|
||||
import {
|
||||
@@ -83,6 +87,7 @@ type Request =
|
||||
| AccountCurrenciesRequest
|
||||
| AccountInfoRequest
|
||||
| AccountLinesRequest
|
||||
| AccountNamespaceRequest
|
||||
| AccountNFTsRequest
|
||||
| AccountObjectsRequest
|
||||
| AccountOffersRequest
|
||||
@@ -133,6 +138,7 @@ type Response =
|
||||
| AccountCurrenciesResponse
|
||||
| AccountInfoResponse
|
||||
| AccountLinesResponse
|
||||
| AccountNamespaceResponse
|
||||
| AccountNFTsResponse
|
||||
| AccountObjectsResponse
|
||||
| AccountOffersResponse
|
||||
|
||||
@@ -56,7 +56,6 @@ export interface ServerInfoResponse extends BaseResponse {
|
||||
amendment_blocked?: boolean
|
||||
/** The version number of the running rippled version. */
|
||||
build_version: string
|
||||
initial_sync_duration_us?: string
|
||||
/**
|
||||
* Information on the most recently closed ledger that has not been
|
||||
* validated by consensus. If the most recently validated ledger is
|
||||
@@ -141,7 +140,6 @@ export interface ServerInfoResponse extends BaseResponse {
|
||||
* The network id of the server.
|
||||
*/
|
||||
network_id?: number
|
||||
node_size?: string
|
||||
/**
|
||||
* Current multiplier to the transaction cost based on
|
||||
* load to this server.
|
||||
|
||||
@@ -23,7 +23,6 @@ export interface ServerStateResponse extends BaseResponse {
|
||||
state: {
|
||||
amendment_blocked?: boolean
|
||||
build_version: string
|
||||
initial_sync_duration_us?: string
|
||||
complete_ledgers: string
|
||||
closed_ledger?: {
|
||||
age: number
|
||||
@@ -52,8 +51,6 @@ export interface ServerStateResponse extends BaseResponse {
|
||||
load_factor_fee_queue?: number
|
||||
load_factor_fee_reference?: number
|
||||
load_factor_server?: number
|
||||
network_id?: number
|
||||
node_size?: string
|
||||
peer_disconnects?: string
|
||||
peer_disconnects_resources?: string
|
||||
peers: number
|
||||
|
||||
@@ -15,7 +15,12 @@ export interface EscrowCancel extends BaseTransaction {
|
||||
* Transaction sequence (or Ticket number) of EscrowCreate transaction that.
|
||||
* created the escrow to cancel.
|
||||
*/
|
||||
OfferSequence: number
|
||||
OfferSequence?: number
|
||||
/**
|
||||
* The ID of the Escrow ledger object to cancel as a 64-character hexadecimal
|
||||
* string.
|
||||
*/
|
||||
EscrowID?: string
|
||||
}
|
||||
|
||||
/**
|
||||
@@ -35,11 +40,17 @@ export function validateEscrowCancel(tx: Record<string, unknown>): void {
|
||||
throw new ValidationError('EscrowCancel: Owner must be a string')
|
||||
}
|
||||
|
||||
if (tx.OfferSequence === undefined) {
|
||||
throw new ValidationError('EscrowCancel: missing OfferSequence')
|
||||
if (tx.OfferSequence === undefined && tx.EscrowID === undefined) {
|
||||
throw new ValidationError(
|
||||
'EscrowCancel: must include OfferSequence or EscrowID',
|
||||
)
|
||||
}
|
||||
|
||||
if (typeof tx.OfferSequence !== 'number') {
|
||||
throw new ValidationError('EscrowCancel: OfferSequence must be a number')
|
||||
if (tx.OfferSequence !== undefined && typeof tx.OfferSequence !== 'number') {
|
||||
throw new ValidationError('EscrowCancel: invalid OfferSequence')
|
||||
}
|
||||
|
||||
if (tx.EscrowID !== undefined && typeof tx.EscrowID !== 'string') {
|
||||
throw new ValidationError('EscrowCancel: invalid EscrowID')
|
||||
}
|
||||
}
|
||||
|
||||
@@ -11,6 +11,16 @@ export interface HookExecution {
|
||||
HookReturnCode: string
|
||||
HookReturnString: string
|
||||
HookStateChangeCount: number
|
||||
Flags: number
|
||||
}
|
||||
}
|
||||
|
||||
export interface HookEmission {
|
||||
HookEmission: {
|
||||
EmittedTxnID: string
|
||||
HookAccount: string
|
||||
HookHash: string
|
||||
EmitNonce: string
|
||||
}
|
||||
}
|
||||
|
||||
@@ -75,6 +85,7 @@ export function isDeletedNode(node: Node): node is DeletedNode {
|
||||
|
||||
export interface TransactionMetadata {
|
||||
HookExecutions?: HookExecution[]
|
||||
HookEmissions?: HookEmission[]
|
||||
AffectedNodes: Node[]
|
||||
DeliveredAmount?: Amount
|
||||
// "unavailable" possible for transactions before 2014-01-20
|
||||
|
||||
@@ -15,7 +15,12 @@ export interface OfferCancel extends BaseTransaction {
|
||||
* created by that transaction. It is not considered an error if the offer.
|
||||
* specified does not exist.
|
||||
*/
|
||||
OfferSequence: number
|
||||
OfferSequence?: number
|
||||
/**
|
||||
* The ID of the Escrow ledger object to cancel as a 64-character hexadecimal
|
||||
* string.
|
||||
*/
|
||||
OfferID?: string
|
||||
}
|
||||
|
||||
/**
|
||||
@@ -27,11 +32,17 @@ export interface OfferCancel extends BaseTransaction {
|
||||
export function validateOfferCancel(tx: Record<string, unknown>): void {
|
||||
validateBaseTransaction(tx)
|
||||
|
||||
if (tx.OfferSequence === undefined) {
|
||||
throw new ValidationError('OfferCancel: missing field OfferSequence')
|
||||
if (tx.OfferSequence === undefined && tx.OfferID === undefined) {
|
||||
throw new ValidationError(
|
||||
'OfferCancel: must include OfferSequence or OfferID',
|
||||
)
|
||||
}
|
||||
|
||||
if (typeof tx.OfferSequence !== 'number') {
|
||||
throw new ValidationError('OfferCancel: OfferSequence must be a number')
|
||||
if (tx.OfferSequence !== undefined && typeof tx.OfferSequence !== 'number') {
|
||||
throw new ValidationError('OfferCancel: invalid OfferSequence')
|
||||
}
|
||||
|
||||
if (tx.OfferID !== undefined && typeof tx.OfferID !== 'string') {
|
||||
throw new ValidationError('OfferCancel: invalid OfferID')
|
||||
}
|
||||
}
|
||||
|
||||
@@ -103,6 +103,11 @@ export interface OfferCreate extends BaseTransaction {
|
||||
Expiration?: number
|
||||
/** An offer to delete first, specified in the same way as OfferCancel. */
|
||||
OfferSequence?: number
|
||||
/**
|
||||
* The ID of the Offer ledger object to cancel as a 64-character hexadecimal
|
||||
* string.
|
||||
*/
|
||||
OfferID?: string
|
||||
/** The amount and type of currency being provided by the offer creator. */
|
||||
TakerGets: Amount
|
||||
/** The amount and type of currency being requested by the offer creator. */
|
||||
@@ -141,4 +146,8 @@ export function validateOfferCreate(tx: Record<string, unknown>): void {
|
||||
if (tx.OfferSequence !== undefined && typeof tx.OfferSequence !== 'number') {
|
||||
throw new ValidationError('OfferCreate: invalid OfferSequence')
|
||||
}
|
||||
|
||||
if (tx.OfferID !== undefined && typeof tx.OfferID !== 'string') {
|
||||
throw new ValidationError('OfferCreate: invalid OfferID')
|
||||
}
|
||||
}
|
||||
|
||||
@@ -2,16 +2,15 @@ import {
|
||||
xAddressToClassicAddress,
|
||||
isValidXAddress,
|
||||
} from '@transia/ripple-address-codec'
|
||||
import BigNumber from 'bignumber.js'
|
||||
import { encode } from '@transia/ripple-binary-codec'
|
||||
|
||||
import type { Client } from '..'
|
||||
import { ValidationError, XrplError } from '../errors'
|
||||
import { AccountInfoRequest, AccountObjectsRequest } from '../models/methods'
|
||||
import { Transaction } from '../models/transactions'
|
||||
import { setTransactionFlagsToNumber } from '../models/utils/flags'
|
||||
import { xrpToDrops } from '../utils'
|
||||
|
||||
import { getFeeXrp } from './getFeeXrp'
|
||||
import { getFeeEstimateXrp } from './getFeeXrp'
|
||||
|
||||
// Expire unconfirmed transactions after 20 ledger versions, approximately 1 minute, by default
|
||||
const LEDGER_OFFSET = 20
|
||||
@@ -50,17 +49,18 @@ async function autofill<T extends Transaction>(
|
||||
if (tx.Sequence == null) {
|
||||
promises.push(setNextValidSequenceNumber(this, tx))
|
||||
}
|
||||
if (tx.Fee == null) {
|
||||
promises.push(calculateFeePerTransactionType(this, tx, signersCount))
|
||||
}
|
||||
if (tx.LastLedgerSequence == null) {
|
||||
promises.push(setLatestValidatedLedgerSequence(this, tx))
|
||||
}
|
||||
if (tx.TransactionType === 'AccountDelete') {
|
||||
promises.push(checkAccountDeleteBlockers(this, tx))
|
||||
}
|
||||
await Promise.all(promises).then(() => tx)
|
||||
|
||||
return Promise.all(promises).then(() => tx)
|
||||
if (tx.Fee == null) {
|
||||
await calculateFeePerTransactionType(this, tx, signersCount)
|
||||
}
|
||||
return tx
|
||||
}
|
||||
|
||||
function setValidAddresses(tx: Transaction): void {
|
||||
@@ -146,64 +146,17 @@ async function setNextValidSequenceNumber(
|
||||
tx.Sequence = data.result.account_data.Sequence
|
||||
}
|
||||
|
||||
async function fetchAccountDeleteFee(client: Client): Promise<BigNumber> {
|
||||
const response = await client.request({ command: 'server_state' })
|
||||
const fee = response.result.state.validated_ledger?.reserve_inc
|
||||
|
||||
if (fee == null) {
|
||||
return Promise.reject(new Error('Could not fetch Owner Reserve.'))
|
||||
}
|
||||
|
||||
return new BigNumber(fee)
|
||||
}
|
||||
|
||||
async function calculateFeePerTransactionType(
|
||||
client: Client,
|
||||
tx: Transaction,
|
||||
signersCount = 0,
|
||||
): Promise<void> {
|
||||
// netFee is usually 0.00001 XRP (10 drops)
|
||||
const netFeeXRP = await getFeeXrp(client)
|
||||
const netFeeDrops = xrpToDrops(netFeeXRP)
|
||||
let baseFee = new BigNumber(netFeeDrops)
|
||||
|
||||
// EscrowFinish Transaction with Fulfillment
|
||||
if (tx.TransactionType === 'EscrowFinish' && tx.Fulfillment != null) {
|
||||
const fulfillmentBytesSize: number = Math.ceil(tx.Fulfillment.length / 2)
|
||||
// 10 drops × (33 + (Fulfillment size in bytes / 16))
|
||||
const product = new BigNumber(
|
||||
// eslint-disable-next-line @typescript-eslint/no-magic-numbers -- expected use of magic numbers
|
||||
scaleValue(netFeeDrops, 33 + fulfillmentBytesSize / 16),
|
||||
)
|
||||
baseFee = product.dp(0, BigNumber.ROUND_CEIL)
|
||||
}
|
||||
|
||||
// AccountDelete Transaction
|
||||
if (tx.TransactionType === 'AccountDelete') {
|
||||
baseFee = await fetchAccountDeleteFee(client)
|
||||
}
|
||||
|
||||
/*
|
||||
* Multi-signed Transaction
|
||||
* 10 drops × (1 + Number of Signatures Provided)
|
||||
*/
|
||||
if (signersCount > 0) {
|
||||
baseFee = BigNumber.sum(baseFee, scaleValue(netFeeDrops, 1 + signersCount))
|
||||
}
|
||||
|
||||
const maxFeeDrops = xrpToDrops(client.maxFeeXRP)
|
||||
const totalFee =
|
||||
tx.TransactionType === 'AccountDelete'
|
||||
? baseFee
|
||||
: BigNumber.min(baseFee, maxFeeDrops)
|
||||
|
||||
// Round up baseFee and return it as a string
|
||||
// eslint-disable-next-line no-param-reassign, @typescript-eslint/no-magic-numbers -- param reassign is safe, base 10 magic num
|
||||
tx.Fee = totalFee.dp(0, BigNumber.ROUND_CEIL).toString(10)
|
||||
}
|
||||
|
||||
function scaleValue(value, multiplier): string {
|
||||
return new BigNumber(value).times(multiplier).toString()
|
||||
const copyTx = { ...tx }
|
||||
copyTx.SigningPubKey = ``
|
||||
copyTx.Fee = `0`
|
||||
const tx_blob = encode(copyTx)
|
||||
// eslint-disable-next-line require-atomic-updates, no-param-reassign -- ignore
|
||||
tx.Fee = await getFeeEstimateXrp(client, tx_blob, signersCount)
|
||||
}
|
||||
|
||||
async function setLatestValidatedLedgerSequence(
|
||||
|
||||
@@ -50,15 +50,20 @@ export async function getFeeXrp(
|
||||
*
|
||||
* @param client - The Client used to connect to the ledger.
|
||||
* @param txBlob - The encoded transaction to estimate the fee for.
|
||||
* @param signersCount - The number of multisigners.
|
||||
* @returns The transaction fee.
|
||||
*/
|
||||
export async function getFeeEstimateXrp(
|
||||
client: Client,
|
||||
txBlob: string,
|
||||
signersCount = 0,
|
||||
): Promise<string> {
|
||||
const response = await client.request({
|
||||
command: 'fee',
|
||||
tx_blob: txBlob,
|
||||
})
|
||||
return response.result.drops.base_fee
|
||||
const openLedgerFee = response.result.drops.open_ledger_fee
|
||||
const baseFee = new BigNumber(response.result.drops.base_fee)
|
||||
const totalFee = BigNumber.sum(openLedgerFee, Number(baseFee) * signersCount)
|
||||
return new BigNumber(totalFee.toFixed(NUM_DECIMAL_PLACES)).toString(BASE_10)
|
||||
}
|
||||
|
||||
@@ -36,7 +36,6 @@ describe('account_info', function () {
|
||||
account_data: {
|
||||
Account: testContext.wallet.classicAddress,
|
||||
Balance: '400000000',
|
||||
AccountIndex: '1',
|
||||
Flags: 0,
|
||||
LedgerEntryType: 'AccountRoot',
|
||||
OwnerCount: 0,
|
||||
@@ -66,14 +65,12 @@ describe('account_info', function () {
|
||||
assert.equal(typeof response.result.account_data.Sequence, 'number')
|
||||
assert.deepEqual(
|
||||
omit(response.result.account_data, [
|
||||
'AccountIndex',
|
||||
'PreviousTxnID',
|
||||
'PreviousTxnLgrSeq',
|
||||
'Sequence',
|
||||
'index',
|
||||
]),
|
||||
omit(expected.result.account_data, [
|
||||
'AccountIndex',
|
||||
'PreviousTxnID',
|
||||
'PreviousTxnLgrSeq',
|
||||
'Sequence',
|
||||
|
||||
@@ -31,13 +31,12 @@ describe('server_info (rippled)', function () {
|
||||
id: 0,
|
||||
result: {
|
||||
info: {
|
||||
build_version: '2023.10.9-release+391',
|
||||
initial_sync_duration_us: '443484',
|
||||
build_version: '1.7.3',
|
||||
complete_ledgers: '2563-2928',
|
||||
hostid: '44578fe64241',
|
||||
io_latency_ms: 1,
|
||||
jq_trans_overflow: '0',
|
||||
last_close: { converge_time_s: 0.001, proposers: 0 },
|
||||
last_close: { converge_time_s: 0.1, proposers: 0 },
|
||||
load: {
|
||||
job_types: [
|
||||
{
|
||||
@@ -54,8 +53,6 @@ describe('server_info (rippled)', function () {
|
||||
threads: 1,
|
||||
},
|
||||
load_factor: 1,
|
||||
network_id: 21337,
|
||||
node_size: 'small',
|
||||
peer_disconnects: '0',
|
||||
peer_disconnects_resources: '0',
|
||||
peers: 0,
|
||||
@@ -132,7 +129,7 @@ describe('server_info (rippled)', function () {
|
||||
)
|
||||
assert.equal(
|
||||
typeof response.result.info.state_accounting[key].transitions,
|
||||
'string',
|
||||
'number',
|
||||
)
|
||||
})
|
||||
|
||||
|
||||
@@ -31,13 +31,12 @@ describe('server_state', function () {
|
||||
id: 0,
|
||||
result: {
|
||||
state: {
|
||||
build_version: '2023.10.9-release+391',
|
||||
initial_sync_duration_us: '443484',
|
||||
build_version: '1.7.3',
|
||||
complete_ledgers: '2563-2932',
|
||||
io_latency_ms: 1,
|
||||
jq_trans_overflow: '0',
|
||||
last_close: {
|
||||
converge_time: 1,
|
||||
converge_time: 100,
|
||||
proposers: 0,
|
||||
},
|
||||
load: {
|
||||
@@ -61,8 +60,6 @@ describe('server_state', function () {
|
||||
load_factor_fee_queue: 256,
|
||||
load_factor_fee_reference: 256,
|
||||
load_factor_server: 256,
|
||||
network_id: 21337,
|
||||
node_size: 'small',
|
||||
peer_disconnects: '0',
|
||||
peer_disconnects_resources: '0',
|
||||
peers: 0,
|
||||
@@ -136,7 +133,7 @@ describe('server_state', function () {
|
||||
)
|
||||
assert.equal(
|
||||
typeof response.result.state.state_accounting[key].transitions,
|
||||
'string',
|
||||
'number',
|
||||
)
|
||||
})
|
||||
|
||||
|
||||
@@ -75,7 +75,7 @@ describe('subscribe', function () {
|
||||
command: 'subscribe',
|
||||
})
|
||||
|
||||
// assert.deepEqual(response.result, {})
|
||||
assert.deepEqual(response.result, {})
|
||||
assert.equal(response.type, 'response')
|
||||
},
|
||||
TIMEOUT,
|
||||
@@ -86,7 +86,7 @@ describe('subscribe', function () {
|
||||
command: 'unsubscribe',
|
||||
})
|
||||
|
||||
// assert.deepEqual(response.result, {})
|
||||
assert.deepEqual(response.result, {})
|
||||
assert.equal(response.type, 'response')
|
||||
})
|
||||
|
||||
|
||||
@@ -52,7 +52,6 @@ describe('tx', function () {
|
||||
Fee: txResponse.result.Fee,
|
||||
Flags: 0,
|
||||
LastLedgerSequence: txResponse.result.LastLedgerSequence,
|
||||
NetworkID: txResponse.result.NetworkID,
|
||||
Sequence: txResponse.result.Sequence,
|
||||
SigningPubKey: testContext.wallet.publicKey,
|
||||
TxnSignature: txResponse.result.TxnSignature,
|
||||
|
||||
@@ -36,7 +36,6 @@ export async function setupClient(
|
||||
client: new Client(server, { timeout: 200000 }),
|
||||
wallet: Wallet.generate(),
|
||||
}
|
||||
context.client.networkID = 21337
|
||||
return connectWithRetry(context.client).then(async () => {
|
||||
await fundAccount(context.client, context.wallet, {
|
||||
count: 20,
|
||||
|
||||
@@ -0,0 +1,68 @@
|
||||
import { Client } from '@transia/xrpl'
|
||||
import { assert } from 'chai'
|
||||
import _ from 'lodash'
|
||||
|
||||
import {
|
||||
convertStringToHex,
|
||||
getNFTokenID,
|
||||
NFTokenMint,
|
||||
TransactionMetadata,
|
||||
} from '../../../src'
|
||||
|
||||
// how long before each test case times out
|
||||
const TIMEOUT = 20000
|
||||
|
||||
describe('NFTokenMint', function () {
|
||||
// TODO: Once we update our integration tests to handle NFTs, replace this client with XrplIntegrationTestContext
|
||||
it(
|
||||
'get NFTokenID',
|
||||
async function () {
|
||||
const client = new Client('wss://s.altnet.rippletest.net:51233/')
|
||||
await client.connect()
|
||||
|
||||
const { wallet, balance: _balance } = await client.fundWallet()
|
||||
|
||||
const tx: NFTokenMint = {
|
||||
TransactionType: 'NFTokenMint',
|
||||
Account: wallet.address,
|
||||
URI: convertStringToHex('https://www.google.com'),
|
||||
NFTokenTaxon: 0,
|
||||
}
|
||||
try {
|
||||
const response = await client.submitAndWait(tx, {
|
||||
wallet,
|
||||
})
|
||||
assert.equal(response.type, 'response')
|
||||
assert.equal(
|
||||
(response.result.meta as TransactionMetadata).TransactionResult,
|
||||
'tesSUCCESS',
|
||||
)
|
||||
|
||||
const accountNFTs = await client.request({
|
||||
command: 'account_nfts',
|
||||
account: wallet.address,
|
||||
})
|
||||
|
||||
const nftokenID =
|
||||
getNFTokenID(response.result.meta as TransactionMetadata) ??
|
||||
'undefined'
|
||||
const accountHasNFT = accountNFTs.result.account_nfts.some(
|
||||
(value) => value.NFTokenID === nftokenID,
|
||||
)
|
||||
|
||||
assert.isTrue(
|
||||
accountHasNFT,
|
||||
`Expected to find an NFT with NFTokenID ${nftokenID} in account ${
|
||||
wallet.address
|
||||
} but did not find it.
|
||||
\n\nHere's what was returned from 'account_nfts' for ${
|
||||
wallet.address
|
||||
}: ${JSON.stringify(accountNFTs)}`,
|
||||
)
|
||||
} finally {
|
||||
await client.disconnect()
|
||||
}
|
||||
},
|
||||
TIMEOUT,
|
||||
)
|
||||
})
|
||||
@@ -214,7 +214,6 @@ export async function verifySubmittedTransaction(
|
||||
assert(data.result)
|
||||
assert.deepEqual(
|
||||
omit(data.result, [
|
||||
'ctid',
|
||||
'date',
|
||||
'hash',
|
||||
'inLedger',
|
||||
|
||||
Reference in New Issue
Block a user