meriadec
7 years ago
8 changed files with 8 additions and 206 deletions
@ -1,135 +0,0 @@ |
|||||
// This is a work in progress
|
|
||||
// The goal is to provide a cli which allow interact
|
|
||||
// with device & libcore for faster iterations
|
|
||||
|
|
||||
require('babel-polyfill') |
|
||||
require('babel-register') |
|
||||
|
|
||||
const chalk = require('chalk') |
|
||||
const inquirer = require('inquirer') |
|
||||
const path = require('path') |
|
||||
const TransportNodeHid = require('@ledgerhq/hw-transport-node-hid').default |
|
||||
|
|
||||
const { serializeAccounts, encodeAccount, decodeAccount } = require('../src/reducers/accounts') |
|
||||
const { doSignAndBroadcast } = require('../src/commands/libcoreSignAndBroadcast') |
|
||||
|
|
||||
const coreHelper = require('../src/helpers/libcore') |
|
||||
const withLibcore = require('../src/helpers/withLibcore').default |
|
||||
|
|
||||
if (!process.env.LEDGER_LIVE_SQLITE_PATH) { |
|
||||
throw new Error('you must define process.env.LEDGER_LIVE_SQLITE_PATH first') |
|
||||
} |
|
||||
|
|
||||
const LOCAL_DIRECTORY_PATH = path.resolve(process.env.LEDGER_LIVE_SQLITE_PATH, '../') |
|
||||
|
|
||||
gimmeDeviceAndLibCore(async ({ device, core, njsWalletPool }) => { |
|
||||
const raw = require(path.join(LOCAL_DIRECTORY_PATH, 'accounts.json')) // eslint-disable-line import/no-dynamic-require
|
|
||||
const accounts = serializeAccounts(raw.data) |
|
||||
const accountToUse = await chooseAccount('Which account to use?', accounts) |
|
||||
await actionLoop({ account: accountToUse, accounts, core, njsWalletPool, device }) |
|
||||
process.exit(0) |
|
||||
}) |
|
||||
|
|
||||
async function actionLoop(props) { |
|
||||
try { |
|
||||
const { account, accounts, core, njsWalletPool, device } = props |
|
||||
const actionToDo = await chooseAction(`What do you want to do with [${account.name}] ?`) |
|
||||
if (actionToDo === 'send funds') { |
|
||||
const transport = await TransportNodeHid.open(device.path) |
|
||||
const accountToReceive = await chooseAccount('To which account?', accounts) |
|
||||
const receiveAddress = await getFreshAddress({ |
|
||||
account: accountToReceive, |
|
||||
core, |
|
||||
njsWalletPool, |
|
||||
}) |
|
||||
console.log(`the receive address is ${receiveAddress}`) |
|
||||
const rawAccount = encodeAccount(account) |
|
||||
console.log(`trying to sign and broadcast...`) |
|
||||
const rawOp = await doSignAndBroadcast({ |
|
||||
account: rawAccount, |
|
||||
transaction: { |
|
||||
amount: 4200000, |
|
||||
recipient: receiveAddress, |
|
||||
feePerByte: 16, |
|
||||
isRBF: false, |
|
||||
}, |
|
||||
deviceId: device.path, |
|
||||
core, |
|
||||
transport, |
|
||||
}) |
|
||||
console.log(rawOp) |
|
||||
} else if (actionToDo === 'sync') { |
|
||||
console.log(`\nLaunch sync...\n`) |
|
||||
const rawAccount = encodeAccount(account) |
|
||||
const syncedAccount = await coreHelper.syncAccount({ rawAccount, core, njsWalletPool }) |
|
||||
console.log(`\nEnd sync...\n`) |
|
||||
console.log(`updated account: `, displayAccount(syncedAccount, 'red')) |
|
||||
} else if (actionToDo === 'quit') { |
|
||||
return true |
|
||||
} |
|
||||
} catch (err) { |
|
||||
console.log(`x Something went wrong`) |
|
||||
console.log(err) |
|
||||
process.exit(1) |
|
||||
} |
|
||||
return actionLoop(props) |
|
||||
} |
|
||||
|
|
||||
async function chooseInList(msg, list, formatItem = i => i) { |
|
||||
const choices = list.map(formatItem) |
|
||||
const { choice } = await inquirer.prompt([ |
|
||||
{ |
|
||||
type: 'list', |
|
||||
name: 'choice', |
|
||||
message: msg, |
|
||||
choices, |
|
||||
}, |
|
||||
]) |
|
||||
const index = choices.indexOf(choice) |
|
||||
return list[index] |
|
||||
} |
|
||||
|
|
||||
async function chooseAction(msg) { |
|
||||
return chooseInList(msg, ['sync', 'send funds', 'quit']) |
|
||||
} |
|
||||
|
|
||||
function chooseAccount(msg, accounts) { |
|
||||
return chooseInList(msg, accounts, acc => displayAccount(acc)) |
|
||||
} |
|
||||
|
|
||||
async function gimmeDeviceAndLibCore(cb) { |
|
||||
withLibcore((core, njsWalletPool) => { |
|
||||
TransportNodeHid.listen({ |
|
||||
error: () => {}, |
|
||||
complete: () => {}, |
|
||||
next: async e => { |
|
||||
if (!e.device) { |
|
||||
return |
|
||||
} |
|
||||
if (e.type === 'add') { |
|
||||
const { device } = e |
|
||||
cb({ device, core, njsWalletPool }) |
|
||||
} |
|
||||
}, |
|
||||
}) |
|
||||
}) |
|
||||
} |
|
||||
|
|
||||
function displayAccount(acc, color = null) { |
|
||||
const isRawAccount = typeof acc.lastSyncDate === 'string' |
|
||||
if (isRawAccount) { |
|
||||
acc = decodeAccount(acc) |
|
||||
} |
|
||||
const str = `[${acc.name}] ${acc.isSegwit ? '' : '(legacy) '}${acc.unit.code} ${acc.balance} - ${ |
|
||||
acc.operations.length |
|
||||
} txs` |
|
||||
return color ? chalk[color](str) : str |
|
||||
} |
|
||||
|
|
||||
async function getFreshAddress({ account, core, njsWalletPool }) { |
|
||||
const njsAccount = await coreHelper.getNJSAccount({ account, njsWalletPool }) |
|
||||
const unsub = await core.syncAccount(njsAccount) |
|
||||
unsub() |
|
||||
const rawAddresses = await njsAccount.getFreshPublicAddresses() |
|
||||
return rawAddresses[0] |
|
||||
} |
|
||||
@ -1,63 +0,0 @@ |
|||||
// Utility to human-read the accounts.json file
|
|
||||
// You have to pass it in parameter, because the location
|
|
||||
// differ depending on the OS.
|
|
||||
|
|
||||
const { |
|
||||
formatCurrencyUnit, |
|
||||
getCryptoCurrencyById, |
|
||||
} = require('@ledgerhq/live-common/lib/helpers/currencies') |
|
||||
const chalk = require('chalk') |
|
||||
const padStart = require('lodash/padStart') |
|
||||
const padEnd = require('lodash/padEnd') |
|
||||
|
|
||||
const { argv } = process |
|
||||
|
|
||||
const [, , FILE_PATH] = argv |
|
||||
|
|
||||
if (!FILE_PATH) { |
|
||||
console.log(`You need to specify a file`) |
|
||||
process.exit(1) |
|
||||
} |
|
||||
|
|
||||
const { data: wrappedAccounts } = require(FILE_PATH) // eslint-disable-line
|
|
||||
|
|
||||
const str = wrappedAccounts |
|
||||
.map(({ data: account }) => { |
|
||||
const currency = getCryptoCurrencyById(account.currencyId) |
|
||||
const unit = currency.units[0] |
|
||||
const headline = `${account.isSegwit ? '[SEGWIT]' : '[NOT SEGWIT]'} ${account.name} | ${ |
|
||||
account.id |
|
||||
} | ${account.path} | balance: ${formatCurrencyUnit(unit, account.balance, { |
|
||||
showCode: true, |
|
||||
alwaysShowSign: true, |
|
||||
})}` |
|
||||
return [ |
|
||||
headline, |
|
||||
headline |
|
||||
.split('') |
|
||||
.map(() => '-') |
|
||||
.join(''), |
|
||||
account.operations |
|
||||
.map(op => { |
|
||||
const opType = op.amount < 0 ? 'SEND' : 'RECEIVE' |
|
||||
return [ |
|
||||
padEnd(opType, 8), |
|
||||
op.date.substr(0, 10), |
|
||||
chalk[opType === 'SEND' ? 'red' : 'green']( |
|
||||
padStart( |
|
||||
formatCurrencyUnit(unit, op.amount, { |
|
||||
showCode: true, |
|
||||
alwaysShowSign: true, |
|
||||
}), |
|
||||
15, |
|
||||
), |
|
||||
), |
|
||||
op.hash, |
|
||||
].join(' ') |
|
||||
}) |
|
||||
.join('\n'), |
|
||||
].join('\n') |
|
||||
}) |
|
||||
.join('\n\n') |
|
||||
|
|
||||
console.log(str) |
|
||||
Loading…
Reference in new issue