lbry-desktop/ui/redux/selectors/wallet.js
zeppi ee9f63a161 integrate all the things
bugfix

wip

flow

fix

cleaning

clean
2021-10-15 23:49:41 -04:00

274 lines
10 KiB
JavaScript

import { createSelector } from 'reselect';
import * as TRANSACTIONS from 'constants/transaction_types';
import { PAGE_SIZE, LATEST_PAGE_SIZE } from 'constants/transaction_list';
import { selectClaimIdsByUri } from 'redux/selectors/claims';
import parseData from 'util/parse-data';
export const selectState = (state) => state.wallet || {};
export const selectWalletState = selectState;
export const selectWalletIsEncrypted = createSelector(selectState, (state) => state.walletIsEncrypted);
export const selectWalletEncryptPending = createSelector(selectState, (state) => state.walletEncryptPending);
export const selectWalletEncryptSucceeded = createSelector(selectState, (state) => state.walletEncryptSucceded);
export const selectPendingSupportTransactions = createSelector(
selectState,
(state) => state.pendingSupportTransactions
);
export const selectPendingOtherTransactions = createSelector(selectState, (state) => state.pendingTxos);
export const selectAbandonClaimSupportError = createSelector(selectState, (state) => state.abandonClaimSupportError);
export const makeSelectPendingAmountByUri = (uri) =>
createSelector(selectClaimIdsByUri, selectPendingSupportTransactions, (claimIdsByUri, pendingSupports) => {
const uriEntry = Object.entries(claimIdsByUri).find(([u, cid]) => u === uri);
const claimId = uriEntry && uriEntry[1];
const pendingSupport = claimId && pendingSupports[claimId];
return pendingSupport ? pendingSupport.effective : undefined;
});
export const selectWalletEncryptResult = createSelector(selectState, (state) => state.walletEncryptResult);
export const selectWalletDecryptPending = createSelector(selectState, (state) => state.walletDecryptPending);
export const selectWalletDecryptSucceeded = createSelector(selectState, (state) => state.walletDecryptSucceded);
export const selectWalletDecryptResult = createSelector(selectState, (state) => state.walletDecryptResult);
export const selectWalletUnlockPending = createSelector(selectState, (state) => state.walletUnlockPending);
export const selectWalletUnlockSucceeded = createSelector(selectState, (state) => state.walletUnlockSucceded);
export const selectWalletUnlockResult = createSelector(selectState, (state) => state.walletUnlockResult);
export const selectWalletLockPending = createSelector(selectState, (state) => state.walletLockPending);
export const selectWalletLockSucceeded = createSelector(selectState, (state) => state.walletLockSucceded);
export const selectWalletLockResult = createSelector(selectState, (state) => state.walletLockResult);
export const selectBalance = createSelector(selectState, (state) => state.balance);
export const selectTotalBalance = createSelector(selectState, (state) => state.totalBalance);
export const selectReservedBalance = createSelector(selectState, (state) => state.reservedBalance);
export const selectClaimsBalance = createSelector(selectState, (state) => state.claimsBalance);
export const selectSupportsBalance = createSelector(selectState, (state) => state.supportsBalance);
export const selectTipsBalance = createSelector(selectState, (state) => state.tipsBalance);
export const selectTransactionsById = createSelector(selectState, (state) => state.transactions || {});
export const selectSupportsByOutpoint = createSelector(selectState, (state) => state.supports || {});
export const selectTotalSupports = createSelector(selectSupportsByOutpoint, (byOutpoint) => {
let total = parseFloat('0.0');
Object.values(byOutpoint).forEach((support) => {
const { amount } = support;
total = amount ? total + parseFloat(amount) : total;
});
return total;
});
export const selectTransactionItems = createSelector(selectTransactionsById, (byId) => {
const items = [];
Object.keys(byId).forEach((txid) => {
const tx = byId[txid];
// ignore dust/fees
// it is fee only txn if all infos are also empty
if (
Math.abs(tx.value) === Math.abs(tx.fee) &&
tx.claim_info.length === 0 &&
tx.support_info.length === 0 &&
tx.update_info.length === 0 &&
tx.abandon_info.length === 0
) {
return;
}
const append = [];
append.push(
...tx.claim_info.map((item) =>
Object.assign({}, tx, item, {
type: item.claim_name[0] === '@' ? TRANSACTIONS.CHANNEL : TRANSACTIONS.PUBLISH,
})
)
);
append.push(
...tx.support_info.map((item) =>
Object.assign({}, tx, item, {
type: !item.is_tip ? TRANSACTIONS.SUPPORT : TRANSACTIONS.TIP,
})
)
);
append.push(...tx.update_info.map((item) => Object.assign({}, tx, item, { type: TRANSACTIONS.UPDATE })));
append.push(...tx.abandon_info.map((item) => Object.assign({}, tx, item, { type: TRANSACTIONS.ABANDON })));
if (!append.length) {
append.push(
Object.assign({}, tx, {
type: tx.value < 0 ? TRANSACTIONS.SPEND : TRANSACTIONS.RECEIVE,
})
);
}
items.push(
...append.map((item) => {
// value on transaction, amount on outpoint
// amount is always positive, but should match sign of value
const balanceDelta = parseFloat(item.balance_delta);
const value = parseFloat(item.value);
const amount = balanceDelta || value;
const fee = parseFloat(tx.fee);
return {
txid,
timestamp: tx.timestamp,
date: tx.timestamp ? new Date(Number(tx.timestamp) * 1000) : null,
amount,
fee,
claim_id: item.claim_id,
claim_name: item.claim_name,
type: item.type || TRANSACTIONS.SPEND,
nout: item.nout,
confirmations: tx.confirmations,
};
})
);
});
return items.sort((tx1, tx2) => {
if (!tx1.timestamp && !tx2.timestamp) {
return 0;
} else if (!tx1.timestamp && tx2.timestamp) {
return -1;
} else if (tx1.timestamp && !tx2.timestamp) {
return 1;
}
return tx2.timestamp - tx1.timestamp;
});
});
export const selectRecentTransactions = createSelector(selectTransactionItems, (transactions) => {
const threshold = new Date();
threshold.setDate(threshold.getDate() - 7);
return transactions.filter((transaction) => {
if (!transaction.date) {
return true; // pending transaction
}
return transaction.date > threshold;
});
});
export const selectHasTransactions = createSelector(
selectTransactionItems,
(transactions) => transactions && transactions.length > 0
);
export const selectIsFetchingTransactions = createSelector(selectState, (state) => state.fetchingTransactions);
/**
* CSV of 'selectTransactionItems'.
*/
export const selectTransactionsFile = createSelector(selectTransactionItems, (transactions) => {
if (!transactions || transactions.length === 0) {
// No data.
return undefined;
}
const parsed = parseData(transactions, 'csv');
if (!parsed) {
// Invalid data, or failed to parse.
return null;
}
return parsed;
});
export const selectIsSendingSupport = createSelector(selectState, (state) => state.sendingSupport);
export const selectReceiveAddress = createSelector(selectState, (state) => state.receiveAddress);
export const selectGettingNewAddress = createSelector(selectState, (state) => state.gettingNewAddress);
export const selectDraftTransaction = createSelector(selectState, (state) => state.draftTransaction || {});
export const selectDraftTransactionAmount = createSelector(selectDraftTransaction, (draft) => draft.amount);
export const selectDraftTransactionAddress = createSelector(selectDraftTransaction, (draft) => draft.address);
export const selectDraftTransactionError = createSelector(selectDraftTransaction, (draft) => draft.error);
export const selectBlocks = createSelector(selectState, (state) => state.blocks);
export const selectCurrentHeight = createSelector(selectState, (state) => state.latestBlock);
export const selectTransactionListFilter = createSelector(selectState, (state) => state.transactionListFilter || '');
export const selectFilteredTransactions = createSelector(
selectTransactionItems,
selectTransactionListFilter,
(transactions, filter) => {
return transactions.filter((transaction) => {
return filter === TRANSACTIONS.ALL || filter === transaction.type;
});
}
);
export const selectTxoPageParams = createSelector(selectState, (state) => state.txoFetchParams);
export const selectTxoPage = createSelector(selectState, (state) => (state.txoPage && state.txoPage.items) || []);
export const selectTxoPageNumber = createSelector(selectState, (state) => (state.txoPage && state.txoPage.page) || 1);
export const selectTxoItemCount = createSelector(
selectState,
(state) => (state.txoPage && state.txoPage.total_items) || 1
);
export const selectFetchingTxosError = createSelector(selectState, (state) => state.fetchingTxosError);
export const selectIsFetchingTxos = createSelector(selectState, (state) => state.fetchingTxos);
export const makeSelectFilteredTransactionsForPage = (page = 1) =>
createSelector(selectFilteredTransactions, (filteredTransactions) => {
const start = (Number(page) - 1) * Number(PAGE_SIZE);
const end = Number(page) * Number(PAGE_SIZE);
return filteredTransactions && filteredTransactions.length ? filteredTransactions.slice(start, end) : [];
});
export const makeSelectLatestTransactions = createSelector(selectTransactionItems, (transactions) => {
return transactions && transactions.length ? transactions.slice(0, LATEST_PAGE_SIZE) : [];
});
export const selectFilteredTransactionCount = createSelector(
selectFilteredTransactions,
(filteredTransactions) => filteredTransactions.length
);
export const selectIsWalletReconnecting = createSelector(selectState, (state) => state.walletReconnecting);
export const selectIsFetchingUtxoCounts = createSelector(selectState, (state) => state.fetchingUtxoCounts);
export const selectIsConsolidatingUtxos = createSelector(selectState, (state) => state.consolidatingUtxos);
export const selectIsMassClaimingTips = createSelector(selectState, (state) => state.massClaimingTips);
export const selectPendingConsolidateTxid = createSelector(selectState, (state) => state.pendingConsolidateTxid);
export const selectPendingMassClaimTxid = createSelector(selectState, (state) => state.pendingMassClaimTxid);
export const selectUtxoCounts = createSelector(selectState, (state) => state.utxoCounts);