git.iko.soy/bridge
on fc0bf50 help sign in
bridge/src/lib/reticket.js
218 lines 5.6 kB history raw
1import Tx from 'ethereumjs-tx';
2import * as azimuth from 'azimuth-js';
3import * as tank from './tank';
5import { hexify } from './txn';
6import {
7 deriveNetworkSeedFromUrbitWallet,
8 deriveNetworkKeys,
9 CRYPTO_SUITE_VERSION,
10} from './keys';
11import { addHexPrefix } from './wallet';
12import { sendAndAwaitAll } from './txn';
13import { getSuggestedGasPrice } from './useSuggestedGasPrice';
14import { GAS_LIMITS } from './constants';
15import { toWei } from 'web3-utils';
17// the initial network key revision is always 1
18const INITIAL_NETWORK_KEY_REVISION = 1;
20export const TRANSACTION_PROGRESS = {
21 GENERATING: 0.01,
22 SIGNING: 0.15,
23 FUNDING: 0.3,
24 TRANSFERRING: 0.55,
25 CLEANING: 0.95,
26 DONE: 1.0,
27};
29export async function reticketPointBetweenWallets({
30 fromWallet,
31 toWallet,
32 point,
33 web3,
34 contracts,
35 networkType,
36 onUpdate,
37 transferEth = false,
38 nextRevision = INITIAL_NETWORK_KEY_REVISION,
39}) {
40 const askForFunding = (address, minBalance, balance) =>
41 onUpdate({
42 type: 'askFunding',
43 value: { address, minBalance, balance },
44 });
46 const gotFunding = () => onUpdate({ type: 'gotFunding' });
47 const progress = state => onUpdate({ type: 'progress', state });
49 //
50 // generate transactions
51 //
53 progress(TRANSACTION_PROGRESS.GENERATING);
55 // transfer to invite wallet, so it can configure
56 //NOTE doing this in the invite wallet instead of the final wallet makes
57 // failure cases "solvable" by just telling the user to fully retry.
58 // in other words, the invite flow is effectively idempotent.
60 //TODO no harm done if we already owned it, but should still get a bool arg
61 // for skipping this, if it isn't too big a burden for callers
62 const transferTmpTx = azimuth.ecliptic.transferPoint(
63 contracts,
64 point,
65 fromWallet.address,
66 false
67 );
68 transferTmpTx.gas = GAS_LIMITS.TRANSFER;
70 // configure networking public keys
71 const seed = await deriveNetworkSeedFromUrbitWallet(toWallet, nextRevision);
73 const networkSeed = seed.matchWith({
74 Nothing: () => {
75 throw new Error('network seed not derived');
76 },
77 Just: p => p.value,
78 });
80 const networkKeys = deriveNetworkKeys(networkSeed);
82 const keysTx = azimuth.ecliptic.configureKeys(
83 contracts,
84 point,
85 addHexPrefix(networkKeys.crypt.public),
86 addHexPrefix(networkKeys.auth.public),
87 CRYPTO_SUITE_VERSION,
88 /* discontinuous */ false
89 );
90 keysTx.gas = GAS_LIMITS.CONFIGURE_KEYS;
92 // configure management proxy
94 const managementTx = azimuth.ecliptic.setManagementProxy(
95 contracts,
96 point,
97 toWallet.management.keys.address
98 );
99 managementTx.gas = GAS_LIMITS.SET_PROXY;
101 // set spawn & voting proxies situationally
103 let txs = [transferTmpTx, keysTx, managementTx];
104 if (
105 azimuth.azimuth.getPointSize(point) !== azimuth.azimuth.PointSize.Planet
106 ) {
107 const spawnTx = azimuth.ecliptic.setSpawnProxy(
108 contracts,
109 point,
110 toWallet.spawn.keys.address
111 );
112 spawnTx.gas = GAS_LIMITS.SET_PROXY;
113 txs.push(spawnTx);
115 if (
116 azimuth.azimuth.getPointSize(point) === azimuth.azimuth.PointSize.Galaxy
117 ) {
118 const votingTx = azimuth.ecliptic.setVotingProxy(
119 contracts,
120 point,
121 toWallet.voting.keys.address
122 );
123 votingTx.gas = GAS_LIMITS.SET_PROXY;
124 txs.push(votingTx);
125 }
126 }
128 // transfer configured point to user's new wallet
130 const transferFinalTx = azimuth.ecliptic.transferPoint(
131 contracts,
132 point,
133 toWallet.ownership.keys.address,
134 false
135 );
136 transferFinalTx.gas = GAS_LIMITS.TRANSFER;
137 txs.push(transferFinalTx);
139 //
140 // finalizing & signing transactions
141 //
143 progress(TRANSACTION_PROGRESS.SIGNING);
145 const suggestedGasPrice = await getSuggestedGasPrice(networkType);
146 const gasPrice = parseInt(toWei(suggestedGasPrice.toFixed(), 'gwei'), 10);
147 let totalCost = 0;
148 let inviteNonce = await web3.eth.getTransactionCount(fromWallet.address);
149 txs = txs.map(tx => {
150 tx.from = fromWallet.address;
151 tx.nonce = inviteNonce++;
152 tx.gasPrice = gasPrice;
153 totalCost = totalCost + tx.gasPrice * tx.gas;
154 return tx;
155 });
157 let txPairs = txs.map(tx => {
158 let stx = new Tx(tx);
159 stx.sign(Buffer.from(fromWallet.privateKey, 'hex'));
160 return {
161 raw: hexify(stx.serialize()),
162 signed: stx,
163 };
164 });
166 //
167 // ensuring funding for transactions
168 //
170 progress(TRANSACTION_PROGRESS.FUNDING);
172 const usedTank = await tank.ensureFundsFor(
173 web3,
174 point,
175 fromWallet.address,
176 totalCost,
177 txPairs.map(p => p.raw),
178 askForFunding,
179 gotFunding
180 );
182 //
183 // sending and awaiting transactions
184 //
186 progress(TRANSACTION_PROGRESS.TRANSFERRING);
188 await sendAndAwaitAll(web3, txPairs.map(p => p.signed), usedTank);
190 //
191 // move leftover eth
192 //
194 progress(TRANSACTION_PROGRESS.CLEANING);
196 // if non-trivial eth left in invite wallet, transfer to new ownership
197 let balance = await web3.eth.getBalance(fromWallet.address);
198 const gasLimit = GAS_LIMITS.SEND_ETH;
199 const sendEthCost = gasPrice * gasLimit;
200 if (transferEth && balance > sendEthCost) {
201 const value = balance - sendEthCost;
202 const tx = {
203 to: toWallet.ownership.keys.address,
204 value: value,
205 gasPrice: gasPrice,
206 gas: gasLimit,
207 nonce: inviteNonce++,
208 };
209 let stx = new Tx(tx);
210 stx.sign(fromWallet.privateKey);
211 const rawTx = hexify(stx.serialize());
212 web3.eth.sendSignedTransaction(rawTx).catch(err => {
213 console.log('error sending value tx, who cares', err);
214 });
215 }
217 progress(TRANSACTION_PROGRESS.DONE);