${initials}
`
-}
-
-export function fileIsSubType(file, type) {
- const fileType = file?.type?.split('/')?.[1]
-
- if (!fileType) {
- return false
- }
-
- return fileType === type
-}
-
-// fileInTypes({type:'application/json'}, ['image/png'])
-export function fileInMIMETypes(file, types = []) {
- const fileType = file?.type
-
- if (!fileType) {
- return false
- }
-
- return types.includes(fileType)
-}
-
-export function fileTypeInTypes(file, types = []) {
- const fileType = file?.type?.split('/')?.[0]
-
- if (!fileType) {
- return false
- }
-
- return types.includes(fileType)
-}
-
-export function fileTypeInSubtype(file, subtypes = []) {
- const fileSubType = file?.type?.split('/')?.[1]
-
- if (!fileSubType) {
- return false
- }
-
- return subtypes.includes(fileSubType)
-}
-
-export function readFile(file, options) {
- let opts = {
- expectedFileType: 'json',
- denyFileTypes: ['audio','video','image','font','model'],
- denyFileSubTypes: ['msword','xml'],
- callback: () => {},
- errorCallback: () => {},
- ...options,
- }
- let reader = new FileReader();
- let result
-
- reader.addEventListener('load', () => {
- if (
- fileTypeInTypes(
- file,
- opts.denyFileTypes,
- ) || fileTypeInSubtype(
- file,
- opts.denyFileSubTypes,
- )
- ) {
- return opts.errorCallback?.({
- err: `Wrong file type: ${file.type}. Expected: ${opts.expectedFileType}.`,
- file,
- })
- }
-
- try {
- // @ts-ignore
- result = JSON.parse(reader?.result || '{}');
-
- // console.log('parse loaded json', result);
-
- opts.callback?.(result, file)
-
- // state[key] = result
- } catch(err) {
- opts.errorCallback?.({
- err,
- file,
- })
-
- throw new Error(`failed to parse JSON data from ${file.name}`)
- }
- });
-
- reader.readAsText(file);
-}
-
-export async function getRandomWords(len = 32) {
- return await DashPhrase.generate(len)
-}
-
-export async function verifyPhrase(phrase) {
- return await DashPhrase.verify(phrase).catch(_ => false)
-}
-
-export function isUniqueAlias(aliases, preferredAlias) {
- return !aliases[preferredAlias]
-}
-
-export async function getUniqueAlias(aliases, preferredAlias) {
- let uniqueAlias = preferredAlias
- let notUnique = !isUniqueAlias(aliases, uniqueAlias)
-
- if (notUnique) {
- let aliasArr = uniqueAlias.split('_')
- let randomWords = (await getRandomWords()).split(' ')
-
- if (aliasArr.length > 1) {
- let lastWord = aliasArr.pop()
- let index = DashPhrase.base2048.indexOf(lastWord);
-
- if (index < 0) {
- aliasArr.push(lastWord)
- } else {
- aliasArr.push(randomWords[0])
- }
- } else {
- aliasArr.push(randomWords[0])
- }
-
- uniqueAlias = aliasArr.join('_')
-
- return await getUniqueAlias(aliases, uniqueAlias)
- }
-
- return uniqueAlias
-}
-
-export function getPartialHDPath(wallet) {
- return [
- wallet.accountIndex,
- wallet.usageIndex,
- wallet.addressIndex,
- ].join('/')
-}
-
-export function getAddressIndexFromUsage(wallet, account, usageIdx) {
- let usageIndex = usageIdx ?? wallet?.usageIndex ?? 0
- let addressIndex = account.usage?.[usageIndex] ?? account.addressIndex ?? 0
- let usage = account.usage ?? [
- account.addressIndex ?? 0,
- 0
- ]
-
- // console.log(
- // 'getAddressIndexFromUsage',
- // usageIndex,
- // addressIndex,
- // account,
- // usage,
- // )
-
- return {
- ...account,
- usage,
- usageIndex,
- addressIndex,
- }
-}
diff --git a/src/helpers/wallet.js b/src/helpers/wallet.js
deleted file mode 100644
index 78de19f..0000000
--- a/src/helpers/wallet.js
+++ /dev/null
@@ -1,2032 +0,0 @@
-import {
- DashWallet,
- DashTx,
- DashHd,
- DashSight,
- DashSocket,
- Cryptic,
-} from '../imports.js'
-import {
- DatabaseSetup,
-} from './db.js'
-import {
- deriveWalletData,
- getAddressIndexFromUsage,
- loadStoreObject,
-} from './utils.js'
-import {
- STOREAGE_SALT, OIDC_CLAIMS,
- KS_CIPHER, KS_PRF, USAGE,
-} from './constants.js'
-import {
- walletFunds,
-} from '../state/index.js'
-
-// @ts-ignore
-import blake from 'blakejs'
-// @ts-ignore
-import { keccak_256 } from '@noble/hashes/sha3'
-
-// @ts-ignore
-export const dashsight = DashSight.create({
- baseUrl: 'https://insight.dash.org',
- // baseUrl: 'https://dashsight.dashincubator.dev',
-});
-
-let defaultSocketEvents = {
- onClose: async (e) => console.log('onClose', e),
- onError: async (e) => console.log('onError', e),
- onMessage: async (e, data) => console.log('onMessage', e, data),
-}
-
-// Cryptic.setConfig({
-// // cipherAlgorithm: 'AES-GCM',
-// // cipherLength: 256,
-// // hashingAlgorithm: 'SHA-256',
-// // derivationAlgorithm: 'PBKDF2',
-// iterations: 1000,
-// })
-
-export async function initDashSocket(
- events = {}
-) {
- // @ts-ignore
- let dashsocket = DashSocket.create({
- dashsocketBaseUrl: 'https://insight.dash.org/socket.io',
- cookieStore: null,
- debug: true,
- ...defaultSocketEvents,
- ...events,
- })
-
- await dashsocket.init()
- .catch((e) => console.log('dashsocket catch err', e));
-
- // setTimeout(() => {
- // dashsocket.close()
- // }, 15*60*1000);
-
- return dashsocket
-}
-
-export const store = await DatabaseSetup()
-
-export async function getStoredItems(targStore) {
- let result = {}
- let storeLen = await targStore.length()
-
- return await targStore.iterate((
- value, key, iterationNumber
- ) => {
- result[key] = value
-
- if (iterationNumber === storeLen) {
- return result
- }
- })
-}
-
-export async function getFilteredStoreLength(targStore, query = {}) {
- let resLength = 0
- let storeLen = await targStore.length()
- let qs = Object.entries(query)
-
- // console.log('getFilteredStoreLength qs', {
- // storeName: targStore?._config?.storeName,
- // storeLen,
- // qs,
- // })
-
- if (storeLen === 0) {
- return 0
- }
-
- return await targStore.iterate((
- value, key, iterationNumber
- ) => {
- let res = true
-
- // console.log('getFilteredStoreLength qs before each', key, res)
-
- qs.forEach(([k,v]) => {
- // console.log('getFilteredStoreLength qs each', k, v, value[k])
- if (k === 'key' && key !== v || value[k] !== v) {
- res = undefined
- }
- })
-
- // console.log('getFilteredStoreLength qs after each', key, res)
-
- if (res) {
- resLength += 1
- }
-
- if (iterationNumber === storeLen) {
- return resLength
- }
- })
-}
-
-export async function findInStore(targStore, query = {}) {
- let result = {}
- let storeLen = await targStore.length()
- let qs = Object.entries(query)
- // console.log('findInStore qs', qs)
-
- return await targStore.iterate((
- value, key, iterationNumber
- ) => {
- let res = value
-
- // console.log('findInStore qs before each', key, res)
-
- qs.forEach(([k,v]) => {
- // console.log('findInStore qs each', k, v, value[k])
- if (k === 'key' && key !== v || value[k] !== v) {
- res = undefined
- }
- })
-
- // console.log('findInStore qs after each', key, res)
-
- if (res) {
- result[key] = res
- }
-
- if (iterationNumber === storeLen) {
- return result
- }
- })
-}
-
-export async function findOneInStore(targStore, query = {}) {
- let storeLen = await targStore.length()
- let qs = Object.entries(query)
-
- return await targStore.iterate((
- value, key, iterationNumber
- ) => {
- let res = value
-
- qs.forEach(([k,v]) => {
- if (k === 'key' && key !== v || value[k] !== v) {
- res = undefined
- }
- })
-
- if (res) {
- return res
- }
-
- if (iterationNumber === storeLen) {
- return undefined
- }
- })
-}
-
-export async function getUnusedChangeAddress(account) {
- let filterQuery = {
- xkeyId: account.xkeyId,
- usageIndex: DashHd.CHANGE,
- }
-
- let foundAddrs = await findInStore(store.addresses, filterQuery)
-
- for (let [fkey,fval] of Object.entries(foundAddrs)) {
- if (!fval.insight?.balance) {
- return fkey
- }
- }
-
- // return foundAddr.address
- return null
-}
-
-export async function loadWalletsForAlias($alias) {
- $alias.$wallets = {}
-
- if ($alias?.wallets) {
- for (let w of $alias.wallets) {
- let wallet = await store.wallets.getItem(w)
- $alias.$wallets[w] = wallet
- }
- }
-
- return $alias
-}
-
-export async function initWalletsInfo(
- info = {},
-) {
- let wallets = await getStoredItems(store.wallets)
-
- info = {
- ...OIDC_CLAIMS,
- ...info,
- }
-
- let alias = info.preferred_username
-
- wallets = Object.values(wallets || {})
- wallets = wallets
- .filter(w => w.alias === alias)
- .map(w => w.id)
-
- return {
- alias,
- wallets,
- info,
- }
-}
-
-export async function decryptWallet(
- decryptPass,
- decryptIV,
- decryptSalt,
- ciphertext,
-) {
- const cryptic = Cryptic.create(
- decryptPass,
- decryptSalt,
- // Cryptic.bufferToHex(
- // Cryptic.stringToBuffer(decryptSalt)
- // )
- )
-
- return await cryptic.decrypt(ciphertext, decryptIV);
-}
-
-export function blake256(data) {
- if ('string' === typeof data) {
- data = Cryptic.hexToBuffer(data)
- }
- const context = blake.blake2bInit(32, null);
- blake.blake2bUpdate(context, data);
- return Cryptic.toHex(blake.blake2bFinal(context));
-}
-
-export function getKeystoreData(keystore) {
- const {
- ciphertext,
- cipher,
- mac,
- } = keystore.crypto
- const [
- cipherAlgorithm,
- cipherLength,
- ] = KS_CIPHER[cipher]
-
- const derivationAlgorithm = keystore.crypto.kdf.toUpperCase()
- const hashingAlgorithm = KS_PRF[keystore.crypto.kdfparams.prf]
- const derivedKeyLength = keystore?.crypto?.kdfparams?.dklen
- const iterations = keystore.crypto.kdfparams.c
- const iv = keystore.crypto.cipherparams.iv
- const ivBuffer = Cryptic.hexToBuffer(iv)
- const salt = keystore.crypto.kdfparams.salt
- const saltBuffer = Cryptic.hexToBuffer(salt)
-
- const keyLength = derivedKeyLength / 2
- const numBits = (keyLength + iv.length) * 8
-
- return {
- cipher,
- cipherAlgorithm,
- cipherLength,
- ciphertext,
- mac,
- derivationAlgorithm,
- hashingAlgorithm,
- derivedKeyLength,
- iterations,
- iv,
- ivBuffer,
- salt,
- saltBuffer,
- keyLength,
- numBits,
- }
-}
-
-export async function setupCryptic(
- encryptionPassword,
- keystore,
-) {
- const ks = getKeystoreData(keystore)
- const {
- cipherLength, cipherAlgorithm,
- derivationAlgorithm, hashingAlgorithm, iv,
- iterations, salt,
- } = ks
-
- Cryptic.setConfig({
- cipherAlgorithm,
- cipherLength,
- hashingAlgorithm,
- derivationAlgorithm,
- iterations,
- })
-
- const cryptic = Cryptic.create(
- encryptionPassword,
- salt,
- );
-
- return {
- Cryptic,
- cryptic,
- ks,
- }
-}
-
-export async function encryptData(
- encryptionPassword,
- keystore,
- data,
-) {
- const { cryptic, ks } = await setupCryptic(
- encryptionPassword,
- keystore,
- )
-
- return await cryptic.encrypt(data, ks.iv);
-}
-
-export async function decryptData(
- encryptionPassword,
- keystore,
- data,
-) {
- const { cryptic, ks } = await setupCryptic(
- encryptionPassword,
- keystore,
- )
-
- return await cryptic.decrypt(data, ks.iv)
-}
-
-export function storedData(
- encryptionPassword,
- keystore,
-) {
- const SD = {}
-
- SD.decryptData = async function(data) {
- if (data && 'string' === typeof data && data.length > 0) {
- data = JSON.parse(await decryptData(
- encryptionPassword,
- keystore,
- data
- ))
- }
-
- return data
- }
-
- SD.decryptItem = async function(targetStore, item,) {
- let data = await targetStore.getItem(
- item,
- )
-
- data = await SD.decryptData(data)
-
- return data
- }
-
- /**
- *
- * @param {*} targetStore
- * @param {*} item
- * @param {*} data
- * @param {*} extend
- * @returns {Promise<[String,Object]>}
- */
- SD.encryptData = async function(
- targetStore, item, data = {}, extend = true
- ) {
- let encryptedData = ''
- let storedData = {}
- let jsonData = {}
- if (extend) {
- // storedData = await targetStore.getItem(
- // item,
- // )
- storedData = await SD.decryptItem(
- targetStore,
- item
- )
- }
-
- if (data) {
- jsonData = {
- ...storedData,
- ...data,
- }
- encryptedData = await encryptData(
- encryptionPassword,
- keystore,
- JSON.stringify(jsonData)
- )
- }
-
- return [
- encryptedData,
- jsonData,
- ]
- }
-
- SD.encryptItem = async function(
- targetStore, item, data = {}, extend = true
- ) {
- let encryptedData = ''
- let encryptedResult = ''
- let result = {}
-
- if (data || extend) {
- let d = await SD.encryptData(targetStore, item, data, extend)
- encryptedResult = d[0]
- result = d[1]
- encryptedData = await targetStore.setItem(
- item,
- encryptedResult
- )
- }
-
- return result || data || encryptedData
- // return encryptedData
- }
-
- return SD
-}
-
-export async function decryptKeystore(
- encryptionPassword,
- keystore,
-) {
- const { Cryptic, cryptic, ks } = await setupCryptic(
- encryptionPassword,
- keystore,
- )
-
- const derivedBytes = await cryptic.deriveBits(ks.numBits, ks.salt)
-
- const bMAC = blake256([
- ...new Uint8Array(derivedBytes.slice(16, 32)),
- ...Cryptic.toBytes(ks.ciphertext),
- ])
- const kMAC = Cryptic.toHex(keccak_256(new Uint8Array([
- ...new Uint8Array(derivedBytes.slice(16, 32)),
- ...Cryptic.toBytes(ks.ciphertext),
- ])));
-
- if (ks.mac && ![bMAC, kMAC].includes(ks.mac)) {
- throw new Error('Invalid password')
- }
-
- return await cryptic.decrypt(ks.ciphertext, ks.iv)
-}
-
-export function genKeystore(
- // aes-256-gcm
- cipher = 'aes-128-ctr',
- salt = Cryptic.randomBytes(32),
- iv = Cryptic.randomBytes(16),
- iterations = 262144,
- id = crypto.randomUUID(),
-) {
- return {
- crypto: {
- cipher,
- ciphertext: '',
- cipherparams: {
- iv: Cryptic.bufferToHex(iv),
- },
- kdf: "pbkdf2",
- kdfparams: {
- c: iterations,
- dklen: 32,
- prf: "hmac-sha256",
- salt: Cryptic.bufferToHex(salt),
- },
- mac: '',
- },
- id,
- meta: 'dash-incubator-keystore',
- version: 3,
- }
-}
-
-export async function encryptKeystore(
- encryptionPassword,
- recoveryPhrase,
-) {
- let keystore = genKeystore()
- const { Cryptic, cryptic, ks } = await setupCryptic(
- encryptionPassword,
- keystore,
- )
-
- const derivedBytes = await cryptic.deriveBits(ks.numBits, ks.salt)
- const encryptedPhrase = await cryptic.encrypt(recoveryPhrase, ks.iv);
-
- keystore.crypto.ciphertext = encryptedPhrase
-
- const bMAC = blake256([
- ...new Uint8Array(derivedBytes.slice(16, 32)),
- ...Cryptic.toBytes(keystore.crypto.ciphertext),
- ])
- const kMAC = Cryptic.toHex(keccak_256(new Uint8Array([
- ...new Uint8Array(derivedBytes.slice(16, 32)),
- ...Cryptic.toBytes(keystore.crypto.ciphertext),
- ])));
-
- keystore.crypto.mac = bMAC
-
- // console.log(
- // 'encrypted keystore',
- // ks,
- // {
- // encryptedPhrase,
- // // keyMaterial,
- // // derivedKey,
- // // derivedBytes,
- // },
- // {
- // bMAC,
- // kMAC,
- // },
- // )
-
- return keystore
-}
-
-export async function generateAddressIterator(
- xkey,
- xkeyId,
- addressIndex,
-) {
- let key = await xkey.deriveAddress(addressIndex);
- let address = await DashHd.toAddr(key.publicKey);
-
- return {
- address,
- addressIndex,
- usageIndex: xkey.index,
- xkeyId,
- }
-}
-
-export async function generateAndStoreAddressIterator(
- xkey,
- xkeyId,
- walletId,
- accountIndex,
- addressIndex,
- usageIndex = DashHd.RECEIVE,
-) {
- let { address } = await generateAddressIterator(
- xkey,
- xkeyId,
- addressIndex,
- )
-
- // console.log(
- // 'generateAddressIterator',
- // {xkey, xkeyId, key, address, accountIndex, addressIndex},
- // )
-
- store.addresses.getItem(address)
- .then(a => {
- let $addr = a || {}
- // console.log(
- // 'generateAddressIterator store.addresses.getItem',
- // {address, $addr},
- // )
-
- store.addresses.setItem(
- address,
- {
- ...$addr,
- updatedAt: Date.now(),
- walletId,
- xkeyId,
- accountIndex,
- addressIndex,
- usageIndex,
- },
- )
- })
-
- return {
- address,
- addressIndex,
- accountIndex,
- usageIndex: xkey.index,
- xkeyId,
- }
-}
-
-export async function batchXkeyAddressGenerate(
- wallet,
- addressIndex = 0,
- batchSize = 20,
-) {
- let batchLimit = addressIndex + batchSize
- let addresses = []
-
- for (let addrIdx = addressIndex; addrIdx < batchLimit; addrIdx++) {
- addresses.push(
- await generateAddressIterator(
- wallet.xkey,
- wallet.xkeyId,
- addrIdx,
- )
- )
- }
-
- return {
- addresses,
- finalAddressIndex: batchLimit,
- }
-}
-
-export async function batchAddressGenerate(
- wallet,
- accountIndex = 0,
- addressIndex = 0,
- usageIndex = DashHd.RECEIVE,
- batchSize = 20,
-) {
- // let hdpath = `m/44'/5'/${accountIndex}'/${usageIndex}/${addressIndex}`,
- let batchLimit = addressIndex + batchSize
- let addresses = []
-
- let account = await wallet.derivedWallet.deriveAccount(accountIndex);
- let xkey = await account.deriveXKey(usageIndex);
- let xkeyId = await DashHd.toId(xkey);
-
- if (usageIndex !== DashHd.RECEIVE) {
- let xkeyReceive = await account.deriveXKey(DashHd.RECEIVE);
- xkeyId = await DashHd.toId(xkeyReceive);
- }
-
- for (let addrIdx = addressIndex; addrIdx < batchLimit; addrIdx++) {
- addresses.push(
- await generateAndStoreAddressIterator(
- xkey,
- xkeyId,
- wallet.id,
- accountIndex,
- addrIdx,
- usageIndex,
- )
- )
- }
-
- return {
- addresses,
- finalAddressIndex: batchLimit,
- }
-}
-
-export async function batchAddressUsageGenerate(
- wallet,
- accountIndex = 0,
- addressIndex = 0,
- batchSize = 20,
-) {
- // let hdpath = `m/44'/5'/${accountIndex}'/${usageIndex}/${addressIndex}`,
- let batchLimit = addressIndex + batchSize
- let addresses = []
-
- let account = await wallet.derivedWallet.deriveAccount(accountIndex);
- let xkeyReceive = await account.deriveXKey(DashHd.RECEIVE);
- let xkeyChange = await account.deriveXKey(DashHd.CHANGE);
- let xkeyId = await DashHd.toId(xkeyReceive);
-
- console.log(
- 'batchAddressUsageGenerate',
- {batchLimit, account, xkeyReceive, xkeyChange},
- )
-
- for (let addrIdx = addressIndex; addrIdx < batchLimit; addrIdx++) {
- addresses.push(
- await generateAndStoreAddressIterator(
- xkeyReceive,
- xkeyId,
- wallet.id,
- accountIndex,
- addrIdx,
- DashHd.RECEIVE,
- )
- )
- addresses.push(
- await generateAndStoreAddressIterator(
- xkeyChange,
- xkeyId,
- wallet.id,
- accountIndex,
- addrIdx,
- DashHd.CHANGE,
- )
- )
- }
-
- return {
- addresses,
- finalAddressIndex: batchLimit,
- }
-}
-
-export async function initWallet(
- encryptionPassword,
- wallet,
- keystore,
- accountIndex = 0,
- addressIndex = 0,
- infoOverride = {},
-) {
- let {
- alias,
- wallets,
- info,
- } = await initWalletsInfo(infoOverride)
-
- let { id, recoveryPhrase } = wallet
-
- // console.log(
- // 'initWallet wallets',
- // wallets,
- // info,
- // )
-
- if (!wallets.includes(id)) {
- wallets.push(id)
- }
-
- let addrs = await batchAddressUsageGenerate(
- wallet,
- accountIndex,
- addressIndex,
- )
-
- console.log('init wallet batchAddressUsageGenerate', addrs)
-
- for (let a of addrs.addresses) {
- store.addresses.setItem(
- a.address,
- {
- updatedAt: Date.now(),
- walletId: wallet.id,
- accountIndex: a.accountIndex,
- addressIndex: a.addressIndex,
- usageIndex: a.usageIndex,
- xkeyId: a.xkeyId,
- }
- )
- }
-
- let storeWallet = await store.wallets.setItem(
- `${id}`,
- {
- id,
- updatedAt: Date.now(),
- accountIndex,
- addressIndex: addrs?.finalAddressIndex || addressIndex,
- keystore: keystore || await encryptKeystore(
- encryptionPassword,
- recoveryPhrase
- ),
- }
- )
-
- let storedAlias = await store.aliases.setItem(
- `${alias}`,
- await encryptData(
- encryptionPassword,
- storeWallet.keystore,
- JSON.stringify({
- wallets,
- info,
- })
- )
- )
-
- // console.log(
- // 'initWallet stored values',
- // storeWallet,
- // storedAlias,
- // )
-
- let contacts = '{}'
-
- return {
- wallets,
- contacts,
- }
-}
-
-// export async function checkWalletFunds(addr, wallet = {}) {
-// const HOUR = 1000 * 60 * 60;
-
-// let {
-// address,
-// accountIndex,
-// addressIndex,
-// usageIndex,
-// } = addr
-// let updatedAt = Date.now()
-// let $addr = await store.addresses.getItem(address) || {}
-
-// $addr = {
-// walletId: wallet.id,
-// accountIndex,
-// addressIndex,
-// usageIndex,
-// ...$addr,
-// }
-// // console.log('checkWalletFunds $addr', $addr)
-// let walletFunds = $addr?.insight
-
-// if (
-// !walletFunds?.updatedAt ||
-// updatedAt - walletFunds?.updatedAt > HOUR
-// ) {
-// // console.info('check insight api for addr', addr)
-
-// let insightRes = await dashsight.getInstantBalance(address)
-
-// if (insightRes) {
-// let { addrStr, ...res } = insightRes
-// walletFunds = res
-
-// $addr.insight = {
-// ...walletFunds,
-// updatedAt,
-// }
-
-// store.addresses.setItem(
-// address,
-// $addr,
-// )
-// }
-// }
-
-// // console.info('check addr funds', addr, walletFunds)
-
-// return $addr
-// }
-
-export async function updateAddrFunds(
- wallet, insightRes,
-) {
- let updatedAt = Date.now()
- let { addrStr, ...res } = insightRes
- let $addr = await store.addresses.getItem(addrStr) || {}
- let {
- walletId,
- xkeyId,
- } = $addr
-
- // console.log(
- // 'checkWalletFunds $addr',
- // $addr,
- // walletId,
- // wallet?.id,
- // walletId === wallet?.id
- // )
-
- if (walletId && walletId === wallet?.id) {
- let storedWallet = await store.wallets.getItem(walletId) || {}
- let storedAccount = await store.accounts.getItem(xkeyId) || {}
-
- $addr.insight = {
- ...res,
- updatedAt,
- }
-
- store.addresses.setItem(
- addrStr,
- $addr,
- )
-
- if (storedAccount.usage[$addr.usageIndex] < $addr.addressIndex) {
- storedAccount.usage[$addr.usageIndex] = $addr.addressIndex
- store.accounts.setItem(
- xkeyId,
- storedAccount
- )
- }
- if (storedWallet.accountIndex < $addr.accountIndex) {
- store.wallets.setItem(
- walletId,
- {
- ...storedWallet,
- accountIndex: $addr.accountIndex,
- }
- )
- let storeAcctLen = (await store.accounts.length())-1
-
- console.log('updateAddrFunds', {
- acctIdx: $addr.accountIndex,
- storeAcctLen,
- sameOrBigger: $addr.accountIndex >= storeAcctLen,
- })
-
- if ($addr.accountIndex >= storeAcctLen) {
- batchGenAccts(wallet.recoveryPhrase, $addr.accountIndex)
- .then(() => {
- // updateAllFunds(wallet)
- batchGenAcctsAddrs(wallet)
- .then(accts => {
- console.log('batchGenAcctsAddrs', { accts })
-
- updateAllFunds(wallet)
- .then(funds => {
- console.log('updateAllFunds then funds', funds)
- })
- .catch(err => console.error('catch updateAllFunds', err, wallet))
- })
- })
- }
- }
-
- return res
- }
-
- return { balance: 0 }
-}
-
-export async function updateAllFunds(wallet) {
- let funds = 0
- let addrKeys = await store.addresses.keys()
-
- if (addrKeys.length === 0) {
- walletFunds.balance = funds
- return funds
- }
-
- console.log(
- 'updateAllFunds getInstantBalances for',
- {addrKeys},
- addrKeys.length,
- )
-
- let balances = await dashsight.getInstantBalances(addrKeys)
- // let txs = await dashsight.getAllTxs(
- // addrKeys
- // )
-
- // console.log('getAllTxs', txs)
-
- if (balances.length >= 0) {
- walletFunds.balance = funds
- }
-
- // add insight balances to address
- for (const insightRes of balances) {
- let { addrStr } = insightRes
- let addrIdx = addrKeys.indexOf(addrStr)
- if (addrIdx > -1) {
- addrKeys.splice(addrIdx, 1)
- }
- funds += (await updateAddrFunds(wallet, insightRes))?.balance || 0
- walletFunds.balance = funds
- }
-
- // remove insight balances from address
- for (const addr of addrKeys) {
- let { insight, ...$addr } = await store.addresses.getItem(addr) || {}
-
- // walletFunds.balance = funds - (_insight?.balance || 0)
-
- store.addresses.setItem(
- addr,
- $addr,
- )
- }
-
- console.log('updateAllFunds funds', {balances, funds})
-
- return funds
-}
-
-export async function getTotalFunds(wallet) {
- let funds = 0
- let result = {}
- let addrsLen = await store.addresses.length()
-
- return await store.addresses.iterate((
- value, key, iterationNumber
- ) => {
- if (value?.walletId === wallet?.id) {
- result[key] = value
- funds += value?.insight?.balance || 0
- }
-
- if (iterationNumber === addrsLen) {
- return funds
- }
- })
-}
-
-export async function getAddrsWithFunds(wallet) {
- let result = {}
- let addrsLen = await store.addresses.length()
-
- return await store.addresses.iterate((
- value, key, iterationNumber
- ) => {
- if (
- value?.walletId === wallet?.id &&
- value?.insight?.balance > 0
- ) {
- result[key] = {
- ...value,
- address: key,
- }
- }
-
- if (iterationNumber === addrsLen) {
- return result
- }
- })
-}
-
-export async function batchGenAccts(
- phrase,
- accountIndex = 0,
- batchSize = 5,
-) {
- let $accts = await getStoredItems(store.accounts)
- // let $acctsArr = Object.values($accts)
- let accts = {}
- let batch = batchSize + accountIndex
-
- console.log(
- 'BATCH GENERATED ACCOUNTS START',
- {
- $accts,
- // $acctsArr,
- accountIndex,
- batch,
- }
- )
-
- for (let i = accountIndex; i < batch; i++) {
- let acctWallet = await deriveWalletData(
- phrase,
- i,
- )
-
- if (!$accts[acctWallet.xkeyId]) {
- let newAccount = await store.accounts.setItem(
- acctWallet.xkeyId,
- {
- createdAt: (new Date()).toISOString(),
- updatedAt: (new Date()).toISOString(),
- accountIndex: i,
- usage: [0,0],
- walletId: acctWallet.id,
- xkeyId: acctWallet.xkeyId,
- addressKeyId: acctWallet.addressKeyId,
- address: acctWallet.address,
- }
- )
-
- accts[`acct__${i}`] = [ acctWallet, newAccount ]
- }
-
- // accts[`acct__${i}`] = batchGenAcctAddrs(
- // acctWallet,
- // newAccount,
- // )
- }
-
- // let allBatches = Promise.allSettled(Object.values(accts))
-
- return accts
-}
-
-export async function batchGenAcctAddrs(
- wallet,
- account,
- usageIndex = -1,
- batchSize = 20,
-) {
- // console.log('batchGenAcctAddrs account', account, usageIndex)
-
- let filterQuery = {
- accountIndex: account.accountIndex,
- }
-
- if (usageIndex >= 0) {
- filterQuery.usageIndex = usageIndex
- }
-
- let acctAddrsLen = await getFilteredStoreLength(
- store.addresses,
- filterQuery,
- )
-
- // console.log('getFilteredStoreLength res', acctAddrsLen)
-
- let addrUsageIdx = account.usage?.[usageIndex] || 0
- let addrIdx = addrUsageIdx
- let batSize = batchSize
-
- if (acctAddrsLen === 0) {
- addrIdx = 0
- batSize = addrUsageIdx + batchSize
- }
-
- if (acctAddrsLen <= addrUsageIdx + (batchSize / 2)) {
- if (usageIndex >= 0) {
- return await batchAddressGenerate(
- wallet,
- account.accountIndex,
- account.usage[usageIndex],
- usageIndex,
- batSize,
- )
- } else {
- return await batchAddressUsageGenerate(
- wallet,
- account.accountIndex,
- addrIdx,
- batSize,
- )
- }
- }
-
- return null
-}
-
-export async function batchGenAcctsAddrs(
- wallet,
- usageIndex = -1,
- batchSize = 20,
-) {
- let $accts = await getStoredItems(store.accounts)
- let $acctsArr = Object.values($accts)
- let accts = {}
-
- if ($acctsArr.length > 0) {
- for (let $a of $acctsArr) {
- accts[`bat__${$a.accountIndex}`] = await batchGenAcctAddrs(
- wallet,
- $a,
- usageIndex,
- batchSize,
- )
- }
-
- // console.warn(
- // 'BATCH GENERATED ACCOUNTS',
- // accts,
- // )
- }
-
- return accts
-}
-
-export async function getAccountWallet(wallet, phrase) {
- let acctFromStore = await store.accounts.getItem(
- wallet.xkeyId,
- ) || {}
- let acctFromStoreWallet = getAddressIndexFromUsage(
- wallet,
- acctFromStore,
- )
-
- if (acctFromStoreWallet?.addressIndex > 0) {
- return {
- wallet: await deriveWalletData(
- phrase,
- acctFromStoreWallet.accountIndex,
- acctFromStoreWallet.addressIndex,
- acctFromStoreWallet?.usageIndex ?? USAGE.RECEIVE,
- ),
- account: acctFromStore,
- }
- }
-
- return {
- wallet,
- account: acctFromStore,
- }
-}
-
-export async function forceInsightUpdateForAddress(addr) {
- let currentAddr = await store.addresses.getItem(
- addr
- )
- await store.addresses.setItem(
- addr,
- {
- ...currentAddr,
- insight: {
- ...currentAddr.insight,
- updatedAt: 0
- }
- }
- )
-}
-
-export function sortAddrs(a, b) {
- // Ascending Lexicographical on TxId (prev-hash) in-memory (not wire) byte order
- if (a.accountIndex > b.accountIndex) {
- return 1;
- }
- if (a.accountIndex < b.accountIndex) {
- return -1;
- }
- // addressIndex
- // Ascending Vout (Numerical)
- let indexDiff = a.addressIndex - b.addressIndex;
- return indexDiff;
-}
-
-export function getBalance(utxos) {
- return utxos.reduce(function (total, utxo) {
- return total + utxo.satoshis;
- }, 0);
-}
-
-export function selectOptimalUtxos(utxos, output) {
- let balance = getBalance(utxos);
- let fees = DashTx.appraise({
- //@ts-ignore
- inputs: [{}],
- //@ts-ignore
- outputs: [{}],
- });
-
- let fullSats = output + fees.min;
-
- if (balance < fullSats) {
- return [];
- }
-
- // from largest to smallest
- utxos.sort(function (a, b) {
- return b.satoshis - a.satoshis;
- });
-
- // /** @type ArrayComing soon
-Earn interest with
-
- 
- + to signup & fund your CrowdNode account. + `, + footer: state => html` + + `, + }) + + state.status = DIALOG_STATUS.SUCCESS + + cbConfAct = await appDialogs.confirmAction.render(state) + + console.log('CN Card Funding Callback', cnCard) + + cnCard.api.value = { + acceptedToS: true, + balance: 1.234, + earned: 0.987, + } + + cnCard.render({ + cfg, + el: integrationsSection, + position: 'beforeend' + }) + + console.log( + `confirm action SUCCESS`, + {state, fde, cnFunding}, + ) + + return { state, fde } + }, + }) + + console.log('CN Card confAct Submit Event', cnCard) + console.log('confAct', confAct, appDialogs.confirmAction) + + confAct?.elements?.form?.classList.add?.('min-h-auto') + + appDialogs.confirmAction.showModal() + } + + console.log( + `Crowdnode Card submit TX`, + fde.intent, + {event, fde}, + ) + + if (fde.intent === 'deposit') { + appDialogs.sendOrReceive?.elements?.form?.classList.add?.('min-h-auto') + await appDialogs.sendOrReceive.render({ + name: 'Deposit to CrowdNode', + cashSend: () => html``, + hideAddressee: true, + action: fde.intent, + wallet, + account: appState.account, + userInfo, + contacts: appState.contacts, + to: '@crowdnode', + }) + appDialogs.sendOrReceive.showModal() + } + if (fde.intent === 'withdraw') { + crowdnodeTransactionRig.markup.fields = html` +
Coming soon
+ //Earn interest with
+ //WE RETAIN NO BACKUPS OF YOUR WALLET DATA.
`, - callback: () => { + callback: async () => { localStorage.clear() sessionStorage.clear() // @ts-ignore diff --git a/src/rigs/add-contact.js b/src/rigs/add-contact.js index e583b1f..80907fb 100644 --- a/src/rigs/add-contact.js +++ b/src/rigs/add-contact.js @@ -1,26 +1,29 @@ -import { lit as html } from '../helpers/lit.js' -import { qrSvg } from '../helpers/qr.js' import { - deriveWalletData, + OIDC_CLAIMS, + ALIAS_REGEX, +} from '../utils/constants.js' + +import { + lit as html, formDataEntries, setClipboard, openBlobSVG, - // sortContactsByAlias, - // sortContactsByName, + debounce, +} from '../utils/generic.js' + +import { + getStoreData, +} from '../utils/db.js' + +import { qrSvg } from '../utils/qr.js' + +import { + deriveWalletData, parseAddressField, generateContactPairingURI, - getStoreData, - debounce, - // nobounce, - // getRandomWords, getUniqueAlias, isUniqueAlias, -} from '../helpers/utils.js' - -import { - OIDC_CLAIMS, - ALIAS_REGEX, -} from '../helpers/constants.js' +} from '../utils/dash/local.js' export let addContactRig = (async function (globals) { 'use strict'; diff --git a/src/rigs/confirm-action.js b/src/rigs/confirm-action.js index 1e43ca1..8722e7b 100644 --- a/src/rigs/confirm-action.js +++ b/src/rigs/confirm-action.js @@ -1,7 +1,11 @@ -import { lit as html } from '../helpers/lit.js' import { + DIALOG_STATUS, +} from '../utils/constants.js' + +import { + lit as html, formDataEntries, -} from '../helpers/utils.js' +} from '../utils/generic.js' export let confirmActionRig = (async function (globals) { 'use strict'; @@ -26,6 +30,7 @@ export let confirmActionRig = (async function (globals) { actionType: 'warn', actionClasses: { info: 'bg-info dark bg-info-hover', + infoo: 'outline brd-info info dark light-hover bg-info-hover', warn: 'outline brd-warn warn dark-hover bg-warn-hover', dang: 'outline brd-dang dang light-hover bg-dang-hover', }, @@ -79,16 +84,7 @@ export let confirmActionRig = (async function (globals) { `, alert: state => html``, - // alert: state => html` - //
+
+
+
+
+ `,
+ addressee: state => {
+ if (state.hideAddressee) {
+ return html`
+
+ `
+ }
+
+ return html`
+
+
+
+ ${state.qrScanBtn(state)}
+
+ `
+ },
content: state => html`
${state.header(state)}