Differential D11673 Diff 34157 web/cashtab/src/hooks/useWallet.js

Changeset View

Standalone View

web/cashtab/src/hooks/useWallet.js

Show All 27 Lines	import {
xecReceivedNotificationWebsocket,		xecReceivedNotificationWebsocket,
eTokenReceivedNotification,		eTokenReceivedNotification,
} from 'components/Common/Notifications';		} from 'components/Common/Notifications';
import { ChronikClient } from 'chronik-client';		import { ChronikClient } from 'chronik-client';
// For XEC, eCash chain:		// For XEC, eCash chain:
const chronik = new ChronikClient(currency.chronikUrl);		const chronik = new ChronikClient(currency.chronikUrl);

const useWallet = () => {		const useWallet = () => {
const [walletRefreshInterval] = useState(currency.walletRefreshInterval);		const [walletRefreshInterval, setWalletRefreshInterval] = useState(
		currency.walletRefreshInterval,
		);
const [wallet, setWallet] = useState(false);		const [wallet, setWallet] = useState(false);
const [chronikWebsocket, setChronikWebsocket] = useState(null);		const [chronikWebsocket, setChronikWebsocket] = useState(null);
const [contactList, setContactList] = useState(false);		const [contactList, setContactList] = useState(false);
const [cashtabSettings, setCashtabSettings] = useState(false);		const [cashtabSettings, setCashtabSettings] = useState(false);
const [fiatPrice, setFiatPrice] = useState(null);		const [fiatPrice, setFiatPrice] = useState(null);
const [apiError, setApiError] = useState(false);		const [apiError, setApiError] = useState(false);
const [checkFiatInterval, setCheckFiatInterval] = useState(null);		const [checkFiatInterval, setCheckFiatInterval] = useState(null);
const [hasUpdated, setHasUpdated] = useState(false);		const [hasUpdated, setHasUpdated] = useState(false);
▲ Show 20 Lines • Show All 159 Lines • ▼ Show 20 Lines	const haveUtxosChanged = (wallet, utxos, previousUtxos) => {
}		}
}		}

// Compare utxo sets		// Compare utxo sets
return !isEqual(utxos, utxosToCompare);		return !isEqual(utxos, utxosToCompare);
};		};

const update = async ({ wallet }) => {		const update = async ({ wallet }) => {
//console.log(`tick()`);		console.log(`tick()`);
//console.time("update");		//console.time("update");

		// Check if walletRefreshInterval is set to 10, i.e. this was called by websocket tx detection
		// If walletRefreshInterval is 10, set it back to the usual refresh rate
		if (walletRefreshInterval === 10) {
		console.log(`walletRefreshInterval is 10, reset`);
		setWalletRefreshInterval(currency.walletRefreshInterval);
		}
try {		try {
if (!wallet) {		if (!wallet) {
return;		return;
}		}
const cashAddresses = [		const cashAddresses = [
wallet.Path245.cashAddress,		wallet.Path245.cashAddress,
wallet.Path145.cashAddress,		wallet.Path145.cashAddress,
wallet.Path1899.cashAddress,		wallet.Path1899.cashAddress,
Show All 21 Lines	const update = async ({ wallet }) => {
}		}

// Need to call with wallet as a parameter rather than trusting it is in state, otherwise can sometimes get wallet=false from haveUtxosChanged		// Need to call with wallet as a parameter rather than trusting it is in state, otherwise can sometimes get wallet=false from haveUtxosChanged
const utxosHaveChanged = haveUtxosChanged(		const utxosHaveChanged = haveUtxosChanged(
wallet,		wallet,
utxos,		utxos,
previousUtxos,		previousUtxos,
);		);
		console.log(`utxosHaveChanged`, utxosHaveChanged);

// If the utxo set has not changed,		// If the utxo set has not changed,
if (!utxosHaveChanged) {		if (!utxosHaveChanged) {
// remove api error here; otherwise it will remain if recovering from a rate		// remove api error here; otherwise it will remain if recovering from a rate
// limit error with an unchanged utxo set		// limit error with an unchanged utxo set
setApiError(false);		setApiError(false);
// then wallet.state has not changed and does not need to be updated		// then wallet.state has not changed and does not need to be updated
//console.timeEnd("update");		//console.timeEnd("update");
Show All 14 Lines	const update = async ({ wallet }) => {
throw new Error(		throw new Error(
'Wallet does not have required state for incremental approach, hydrating full utxo set',		'Wallet does not have required state for incremental approach, hydrating full utxo set',
);		);
}		}
const utxosAdded = whichUtxosWereAdded(		const utxosAdded = whichUtxosWereAdded(
wallet.state.utxos,		wallet.state.utxos,
utxos,		utxos,
);		);
		console.log(`utxosAdded`, utxosAdded);
const utxosConsumed = whichUtxosWereConsumed(		const utxosConsumed = whichUtxosWereConsumed(
wallet.state.utxos,		wallet.state.utxos,
utxos,		utxos,
);		);

incrementallyAdjustedHydratedUtxoDetails =		incrementallyAdjustedHydratedUtxoDetails =
wallet.state.hydratedUtxoDetails;		wallet.state.hydratedUtxoDetails;

▲ Show 20 Lines • Show All 81 Lines • ▼ Show 20 Lines	const update = async ({ wallet }) => {

newState.utxos = utxos;		newState.utxos = utxos;

newState.hydratedUtxoDetails =		newState.hydratedUtxoDetails =
incrementallyAdjustedHydratedUtxoDetails;		incrementallyAdjustedHydratedUtxoDetails;

// Set wallet with new state field		// Set wallet with new state field
wallet.state = newState;		wallet.state = newState;
		console.log(`newState`, newState);
setWallet(wallet);		setWallet(wallet);

// Write this state to indexedDb using localForage		// Write this state to indexedDb using localForage
writeWalletState(wallet, newState);		writeWalletState(wallet, newState);
// If everything executed correctly, remove apiError		// If everything executed correctly, remove apiError
setApiError(false);		setApiError(false);
} catch (error) {		} catch (error) {
console.log(`Error in update({wallet})`);		console.log(`Error in update({wallet})`);
▲ Show 20 Lines • Show All 549 Lines • ▼ Show 20 Lines	const processChronikWsMsg = async (msg, wallet, fiatPrice) => {
const { type } = msg;		const { type } = msg;
// For now, only act on "first seen" transactions, as the only logic to happen is first seen notifications		// For now, only act on "first seen" transactions, as the only logic to happen is first seen notifications
// Dev note: Other chronik msg types		// Dev note: Other chronik msg types
// "BlockConnected", arrives as new blocks are found		// "BlockConnected", arrives as new blocks are found
// "Confirmed", arrives as subscribed + seen txid is confirmed in a block		// "Confirmed", arrives as subscribed + seen txid is confirmed in a block
if (type !== 'AddedToMempool') {		if (type !== 'AddedToMempool') {
return;		return;
}		}
		// If you see a tx from your subscribed addresses added to the mempool, then the wallet utxo set has changed
		// Update it
		setWalletRefreshInterval(10);

// get txid info		// get txid info
const txid = msg.txid;		const txid = msg.txid;
const txDetails = await chronik.tx(txid);		const txDetails = await chronik.tx(txid);

// parse tx for notification		// parse tx for notification
const hash160Array = getHashArrayFromWallet(wallet);		const hash160Array = getHashArrayFromWallet(wallet);
const parsedChronikTx = parseChronikTx(txDetails, hash160Array);		const parsedChronikTx = parseChronikTx(txDetails, hash160Array);
if (parsedChronikTx.incoming) {		if (parsedChronikTx.incoming) {
▲ Show 20 Lines • Show All 517 Lines • Show Last 20 Lines