-
Notifications
You must be signed in to change notification settings - Fork 3
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
5 changed files
with
298 additions
and
11 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
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,176 @@ | ||
| import type { CaipNetwork, CaipNetworkId } from '@reown/appkit' | ||
| import { bitcoinTestnet } from '@reown/appkit/networks' | ||
| import type { BitcoinConnector } from '@reown/appkit-adapter-bitcoin' | ||
| import { Psbt, networks as bitcoinNetworks, address as bitcoinAddress, payments as bitcoinPayments, type Network, initEccLib } from 'bitcoinjs-lib'; | ||
| import * as bitcoinPSBTUtils from 'bitcoinjs-lib/src/psbt/psbtutils' | ||
| import ecc from '@bitcoinerlab/secp256k1' | ||
|
|
||
| initEccLib(ecc); | ||
|
|
||
| export type CreateSignPSBTParams = { | ||
| senderAddress: string | ||
| recipientAddress: string | ||
| network: CaipNetwork | ||
| amount: number | ||
| utxos: UTXO[] | ||
| feeRate: number | ||
| memo?: string | ||
| } | ||
|
|
||
| export type UTXO = { | ||
| txid: string | ||
| vout: number | ||
| value: number | ||
| status: { | ||
| confirmed: boolean | ||
| block_height: number | ||
| block_hash: string | ||
| block_time: number | ||
| } | ||
| } | ||
| export const calculateChange = (utxos: UTXO[], amount: number, feeRate: number): number => { | ||
| const inputSum = utxos.reduce((sum, utxo) => sum + utxo.value, 0) | ||
| /** | ||
| * 10 bytes: This is an estimated fixed overhead for the transaction. | ||
| * 148 bytes: This is the average size of each input (UTXO). | ||
| * 34 bytes: This is the size of each output. | ||
| * The multiplication by 2 indicates that there are usually two outputs in a typical transaction (one for the recipient and one for change) | ||
| */ | ||
| const estimatedSize = 10 + 148 * utxos.length + 34 * 2 | ||
| const fee = estimatedSize * feeRate | ||
| const change = inputSum - amount - fee | ||
|
|
||
| return change | ||
| } | ||
|
|
||
| export const getBitcoinNetwork = (networkId: CaipNetworkId): Network => { | ||
| return isTestnet(networkId) ? bitcoinNetworks.testnet : bitcoinNetworks.bitcoin | ||
| } | ||
|
|
||
| export const isTestnet = (networkId: CaipNetworkId): boolean => { | ||
| return networkId === bitcoinTestnet.caipNetworkId | ||
| } | ||
|
|
||
| export const getFeeRate = async () => { | ||
| const defaultFeeRate = 2 | ||
| try { | ||
| const response = await fetch('https://mempool.space/api/v1/fees/recommended') | ||
| if (response.ok) { | ||
| const data = await response.json() | ||
|
|
||
| if (data?.fastestFee) { | ||
| return parseInt(data.fastestFee, 10) | ||
| } | ||
| } | ||
| } catch (e) { | ||
| // eslint-disable-next-line no-console | ||
| console.error('Error fetching fee rate', e) | ||
| } | ||
|
|
||
| return defaultFeeRate | ||
| } | ||
|
|
||
| // | ||
| // Get the utxos ... List of unspent transactions that the sender has | ||
| // | ||
| export const getUTXOs = async (address: string, isTestnet: boolean = false): Promise<UTXO[]> => { | ||
| const response = await fetch( | ||
| `https://mempool.space${isTestnet ? '/testnet' : ''}/api/address/${address}/utxo` | ||
| ) | ||
| return await response.json(); | ||
| } | ||
|
|
||
| // | ||
| // Get the payment by address ... The type of address that the sender has | ||
| // | ||
| export const getPaymentByAddress = ( | ||
| address: string, | ||
| network: bitcoinNetworks.Network | ||
| ): bitcoinPayments.Payment => { | ||
| const output = bitcoinAddress.toOutputScript(address, network) | ||
|
|
||
| if (bitcoinPSBTUtils.isP2MS(output)) { | ||
| return bitcoinPayments.p2ms({ output, network }) | ||
| } else if (bitcoinPSBTUtils.isP2PK(output)) { | ||
| return bitcoinPayments.p2pk({ output, network }) | ||
| } else if (bitcoinPSBTUtils.isP2PKH(output)) { | ||
| return bitcoinPayments.p2pkh({ output, network }) | ||
| } else if (bitcoinPSBTUtils.isP2WPKH(output)) { | ||
| return bitcoinPayments.p2wpkh({ output, network }) | ||
| } else if (bitcoinPSBTUtils.isP2WSHScript(output)) { | ||
| return bitcoinPayments.p2wsh({ output, network }) | ||
| } else if (bitcoinPSBTUtils.isP2SHScript(output)) { | ||
| return bitcoinPayments.p2sh({ output, network }) | ||
| } else if (bitcoinPSBTUtils.isP2TR(output)) { | ||
| return bitcoinPayments.p2tr({ output, network }) | ||
| } | ||
|
|
||
| throw new Error('Unsupported payment type') | ||
| } | ||
| // | ||
| // Create a psbt ... The PSBT that will be signed by the sender in the wallet | ||
| // | ||
| export const createPSBT = async (caipNetwork: CaipNetwork, amount: number, address: string, recipientAddress: string): Promise<BitcoinConnector.SignPSBTParams> => { | ||
| // get the bitcoin network from our caipNetwork | ||
| const network = getBitcoinNetwork(caipNetwork.caipNetworkId) | ||
| // get the payment by address ... this is the type of address that the sender has | ||
| const payment = getPaymentByAddress(address, network) | ||
| // get the utxos ... this is the list of unspent transactions that the sender has | ||
| const utxos = await getUTXOs(address, isTestnet(caipNetwork.caipNetworkId)) | ||
| // get the fee rate ... this is the fee per byte | ||
| const feeRate = await getFeeRate() | ||
| // calculate the change ... this is the amount of satoshis that will be sent back to the sender | ||
| const change = calculateChange(utxos, amount, feeRate) | ||
| // the memo is the message that will be embedded in the transaction | ||
| const memo = "Hello Reown AppKit!"; | ||
|
|
||
| const psbt = new Psbt({network: network}); | ||
|
|
||
| // check if the payment output is valid | ||
| if (!payment.output) throw new Error('Invalid payment output'); | ||
| // check if the change is greater than 0 ... this means the sender has enough funds | ||
| //if (change < 0) throw new Error('Insufficient funds'); | ||
|
|
||
| if (change > 0) { | ||
| psbt.addOutput({ | ||
| address: address, | ||
| value: change //BigInt(change) | ||
| }) | ||
| } | ||
|
|
||
| // add the inputs to the psbt | ||
| for (const utxo of utxos) { | ||
| psbt.addInput({ | ||
| hash: utxo.txid, | ||
| index: utxo.vout, | ||
| witnessUtxo: { | ||
| script: payment.output, | ||
| value: utxo.value | ||
| } | ||
| }) | ||
| } | ||
|
|
||
| // add the output to the psbt ... this is the recipient address and the amount of satoshis that will be sent to the recipient | ||
| psbt.addOutput({ | ||
| address: recipientAddress, | ||
| value: amount | ||
| }) | ||
|
|
||
| if (memo) { | ||
| const data = Buffer.from(memo, 'utf8') | ||
| const embed = bitcoinPayments.embed({ data: [data] }) | ||
|
|
||
| if (!embed.output) throw new Error('Invalid embed output'); | ||
|
|
||
| psbt.addOutput({ | ||
| script: embed.output, | ||
| value: 0 | ||
| }) | ||
| } | ||
|
|
||
| return { | ||
| psbt: psbt.toBase64(), | ||
| signInputs: [], | ||
| broadcast: false | ||
| } | ||
| } |