-
Notifications
You must be signed in to change notification settings - Fork 27
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #39 from ava-labs/dev
v0.12.0
- Loading branch information
Showing
49 changed files
with
2,544 additions
and
1,397 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -111,5 +111,5 @@ public/ | |
| # End of https://www.gitignore.io/api/node.idea/* | ||
|
|
||
| .markdownlint.json | ||
|
|
||
| TODO.md | ||
|
|
||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,17 @@ | ||
| import { ChainIdType } from '@/types'; | ||
| import { cChain, pChain, xChain } from '@/Network/network'; | ||
|
|
||
| /** | ||
| * Given a chain alias, returns the chain id. | ||
| * @param alias `X`, `P` or `C` | ||
| */ | ||
| export function chainIdFromAlias(alias: ChainIdType) { | ||
| if (alias === 'X') { | ||
| return xChain.getBlockchainID(); | ||
| } else if (alias === 'P') { | ||
| return pChain.getBlockchainID(); | ||
| } else if (alias === 'C') { | ||
| return cChain.getBlockchainID(); | ||
| } | ||
| throw new Error('Unknown chain alias.'); | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,3 @@ | ||
| export * from './aliasFromNetworkID'; | ||
| export * from './idFromAlias'; | ||
| export * from './rpcFromConfig'; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,148 @@ | ||
| import { BN } from 'avalanche'; | ||
| import { ChainIdType } from '@/types'; | ||
| import { | ||
| UniversalTx, | ||
| UniversalTxActionExport, | ||
| UniversalTxActionImport, | ||
| UniversalTxExport, | ||
| UniversalTxImport, | ||
| } from './types'; | ||
|
|
||
| export abstract class UniversalNodeAbstract { | ||
| parents: UniversalNodeAbstract[]; | ||
| child: UniversalNodeAbstract | null; // can only have 1 child | ||
| balance: BN; | ||
| chain: ChainIdType; | ||
| feeExport: BN; | ||
| feeImport: BN; | ||
|
|
||
| protected constructor(balance: BN, chain: ChainIdType, feeExport: BN, feeImport: BN) { | ||
| this.parents = []; | ||
| this.child = null; | ||
| this.balance = balance; | ||
| this.chain = chain; | ||
| this.feeExport = feeExport; | ||
| this.feeImport = feeImport; | ||
| } | ||
|
|
||
| // Sum of the node's balance + all balance of parents minus the transfer fees | ||
| reduceTotalBalanceFromParents(): BN { | ||
| // If there are no balance return balance of self | ||
| if (this.parents.length === 0) { | ||
| return this.balance; | ||
| } | ||
|
|
||
| let parentBals = this.parents.map((node) => { | ||
| // Subtract transfer fees from parent balance | ||
| // import + export | ||
| let parentBalance = node.reduceTotalBalanceFromParents(); | ||
| parentBalance = parentBalance.sub(this.feeImport).sub(node.feeExport); | ||
| let zero = new BN(0); | ||
| return BN.max(parentBalance, zero); | ||
| }); | ||
|
|
||
| let tot = parentBals.reduce((prev, current) => { | ||
| return prev.add(current); | ||
| }, new BN(0)); | ||
|
|
||
| return tot.add(this.balance); | ||
| } | ||
|
|
||
| /** | ||
| * Returns the export action type from this node to its child | ||
| * @param to | ||
| */ | ||
| abstract getExportMethod(to: ChainIdType): UniversalTxActionExport; | ||
|
|
||
| /** | ||
| * Returns the import action type from this node to its child | ||
| * @param from Which chain are we importing from | ||
| */ | ||
| abstract getImportMethod(from: ChainIdType): UniversalTxActionImport; | ||
|
|
||
| buildExportTx(destChain: ChainIdType, amount: BN): UniversalTxExport { | ||
| return { | ||
| action: this.getExportMethod(destChain), | ||
| amount: amount, | ||
| fee: this.feeExport, | ||
| }; | ||
| } | ||
|
|
||
| buildImportTx(sourceChain: ChainIdType): UniversalTxImport { | ||
| return { | ||
| action: this.getImportMethod(sourceChain), | ||
| fee: this.feeImport, | ||
| }; | ||
| } | ||
|
|
||
| /*** | ||
| * Assumes there is enough balance on node tree | ||
| * Returns empty array even if transaction not possible! | ||
| * What steps to take to have the target balance on this node. | ||
| * @param target Amount of nAVAX needed on this node. | ||
| */ | ||
| getStepsForTargetBalance(target: BN): UniversalTx[] { | ||
| // If the node has enough balance no transaction needed | ||
| // If target is negative or zero no transaction needed | ||
| if (this.balance.gte(target) || target.lte(new BN(0))) { | ||
| return []; | ||
| } | ||
|
|
||
| // If not enough balance and no parents | ||
| // return all the balance | ||
| if (this.balance.lt(target) && this.parents.length === 0) { | ||
| return []; | ||
| } | ||
|
|
||
| // If not enough balance on this node, try to collect it from parents | ||
| // Amount needed to collect from parents | ||
| let remaining = target.sub(this.balance); | ||
|
|
||
| let transactions = []; | ||
| for (let i = 0; i < this.parents.length; i++) { | ||
| let p = this.parents[i]; | ||
|
|
||
| if (remaining.lte(new BN(0))) break; | ||
|
|
||
| // Parent's balance | ||
| let pBal = p.reduceTotalBalanceFromParents(); | ||
| const exportFee = p.feeExport; | ||
| const importFee = this.feeImport; | ||
| const feeImportExport = exportFee.add(importFee); | ||
| // Maximum balance we can import from parent | ||
| let pBalMax = pBal.sub(feeImportExport); | ||
| // The parent needs to have this balance to satisfy the needed amount | ||
|
|
||
| // Try to export the remaining amount, if the parent balance is lower than that export the maximum amount | ||
| // Import amount is the usable amount imported | ||
| const importAmt = BN.min(pBalMax, remaining); // The amount that will cross to the target chain | ||
| // Exported amount should include the import fees | ||
| const exportAmt = importAmt.add(importFee); | ||
|
|
||
| if (exportAmt.lte(new BN(0))) continue; | ||
|
|
||
| let pTx = p.buildExportTx(this.chain, exportAmt); | ||
| let importTx = this.buildImportTx(p.chain); | ||
|
|
||
| transactions.push(pTx); | ||
| transactions.push(importTx); | ||
|
|
||
| remaining = remaining.sub(importAmt); | ||
| } | ||
|
|
||
| // If we still have remaining balance, we can not complete this transfer | ||
| if (remaining.gt(new BN(0))) { | ||
| throw new Error('Insufficient AVAX balances.'); | ||
| } | ||
|
|
||
| return transactions; | ||
| } | ||
|
|
||
| addParent(node: UniversalNodeAbstract) { | ||
| this.parents.push(node); | ||
| } | ||
|
|
||
| setChild(node: UniversalNodeAbstract) { | ||
| this.child = node; | ||
| } | ||
| } |
Oops, something went wrong.