-
Notifications
You must be signed in to change notification settings - Fork 28
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Marina Web Provider: Broadcast transaction (#346)
* add marina.broadcastTransaction * lock selected inputs * lint * select Utxos from all accounts * slice hash to prevent mutation * get addresses from all accounts * prettier * code refactor, dry code * remove redux selectors from utils/utxos.ts * prettier
- Loading branch information
Showing
4 changed files
with
199 additions
and
47 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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,22 +1,142 @@ | ||
| import { UnblindedOutput, unblindOutput } from 'ldk'; | ||
| import { Transaction } from 'liquidjs-lib'; | ||
| import { | ||
| AddressInterface, | ||
| getNetwork, | ||
| IdentityInterface, | ||
| NetworkString, | ||
| UnblindedOutput, | ||
| unblindOutput, | ||
| } from 'ldk'; | ||
| import { address, networks, Transaction } from 'liquidjs-lib'; | ||
| import { RawHex } from 'marina-provider'; | ||
| import { Account } from '../../domain/account'; | ||
| import { UnconfirmedOutput } from '../../domain/unconfirmed'; | ||
|
|
||
| export const toStringOutpoint = (outpoint: { txid: string; vout: number }) => { | ||
| export const toStringOutpoint = (outpoint: { txid: string; vout: number }): string => { | ||
| return `${outpoint.txid}:${outpoint.vout}`; | ||
| }; | ||
|
|
||
| // for each unconfirmed output get unblindData and return utxo | ||
| export const makeUnconfirmedUtxos = async ( | ||
| txHex: string, | ||
| unconfirmedOutputs: UnconfirmedOutput[] | ||
| changeUtxos: UnconfirmedOutput[] | ||
| ): Promise<UnblindedOutput[]> => { | ||
| const unconfirmedUtxos: UnblindedOutput[] = []; | ||
| const transaction = Transaction.fromHex(txHex); | ||
| for (const { txid, vout, blindPrivKey } of unconfirmedOutputs) { | ||
| for (const { txid, vout, blindPrivKey } of changeUtxos) { | ||
| const prevout = transaction.outs[vout]; | ||
| const utxo = await unblindOutput({ txid, vout, prevout }, blindPrivKey); | ||
| unconfirmedUtxos.push(utxo); | ||
| } | ||
| return unconfirmedUtxos; | ||
| }; | ||
|
|
||
| export interface UtxosFromTx { | ||
| selectedUtxos: UnblindedOutput[]; | ||
| changeUtxos: UnconfirmedOutput[]; | ||
| } | ||
|
|
||
| // given a signed tx hex, get selected utxos and change utxos | ||
| export const getUtxosFromTx = async ( | ||
| accounts: Account[], | ||
| coins: UnblindedOutput[], | ||
| network: NetworkString, | ||
| signedTxHex: RawHex | ||
| ): Promise<UtxosFromTx> => { | ||
| const tx = Transaction.fromHex(signedTxHex); | ||
| const txid = tx.getId(); | ||
|
|
||
| // get selected utxos used in this transaction: | ||
| // - get all coins from marina | ||
| // - iterate over all transaction inputs and check if is a coin of ours | ||
|
|
||
| // array to store all utxos selected in this transaction | ||
| const selectedUtxos: UnblindedOutput[] = []; | ||
|
|
||
| // find all inputs that are a coin of ours | ||
| tx.ins.forEach((_in) => { | ||
| const { hash, index } = _in; // txid and vout | ||
| const txid = hash.slice().reverse().toString('hex'); | ||
| for (const coin of coins) { | ||
| if (coin.txid === txid && coin.vout === index) { | ||
| selectedUtxos.push(coin); | ||
| break; | ||
| } | ||
| } | ||
| }); | ||
|
|
||
| // get credit change utxos: | ||
| // - get all addresses used by marina | ||
| // - iterate over all transaction outputs and check if belongs to marina | ||
|
|
||
| // array to store all utxos to be found | ||
| const changeUtxos: UnconfirmedOutput[] = []; | ||
|
|
||
| // get all marina addresses (from all accounts) | ||
| let allAddresses: AddressInterface[] = []; | ||
| for (const account of accounts) { | ||
| const identity = await account.getWatchIdentity(network); | ||
| allAddresses = [...allAddresses, ...(await identity.getAddresses())]; | ||
| } | ||
|
|
||
| // iterate over transaction outputs | ||
| tx.outs.forEach((out, vout) => { | ||
| try { | ||
| // get address from output script | ||
| const addressFromOutputScript = address.fromOutputScript( | ||
| Buffer.from(out.script), | ||
| networks[network] | ||
| ); | ||
| // iterate over marina addresses | ||
| for (const addr of allAddresses) { | ||
| // get unconfidential address for addr | ||
| const unconfidentialAddress = address.fromConfidential( | ||
| addr.confidentialAddress | ||
| ).unconfidentialAddress; | ||
| // compare with address from output script | ||
| if ( | ||
| addressFromOutputScript === unconfidentialAddress || | ||
| addressFromOutputScript === addr.confidentialAddress | ||
| ) { | ||
| changeUtxos.push({ | ||
| txid, | ||
| vout, | ||
| blindPrivKey: addr.blindingPrivateKey, | ||
| }); | ||
| break; | ||
| } | ||
| } | ||
| } catch (_) { | ||
| // probably this output doesn't belong to us | ||
| } | ||
| }); | ||
|
|
||
| return { | ||
| selectedUtxos, | ||
| changeUtxos, | ||
| }; | ||
| }; | ||
|
|
||
| export const getUtxosFromChangeAddresses = async ( | ||
| changeAddresses: string[], | ||
| identities: IdentityInterface[], | ||
| network: NetworkString, | ||
| tx: RawHex | ||
| ): Promise<UnconfirmedOutput[]> => { | ||
| const changeUtxos: UnconfirmedOutput[] = []; | ||
| if (changeAddresses && identities[0]) { | ||
| const transaction = Transaction.fromHex(tx); | ||
| const txid = transaction.getId(); | ||
| for (const addr of changeAddresses) { | ||
| const changeOutputScript = address.toOutputScript(addr, getNetwork(network)); | ||
| const vout = transaction.outs.findIndex( | ||
| (o: any) => o.script.toString() === changeOutputScript.toString() | ||
| ); | ||
| if (vout !== -1 && transaction?.outs[vout]?.script) { | ||
| const script = transaction.outs[vout].script.toString('hex'); | ||
| const blindPrivKey = await identities[0].getBlindingPrivateKey(script); | ||
| changeUtxos.push({ txid, vout, blindPrivKey }); | ||
| } | ||
| } | ||
| } | ||
| return changeUtxos; | ||
| }; |
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