view.py 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843
  1. #!/usr/bin/env python3
  2. #
  3. # MMGen Wallet, a terminal-based cryptocurrency wallet
  4. # Copyright (C)2013-2025 The MMGen Project <mmgen@tuta.io>
  5. #
  6. # This program is free software: you can redistribute it and/or modify
  7. # it under the terms of the GNU General Public License as published by
  8. # the Free Software Foundation, either version 3 of the License, or
  9. # (at your option) any later version.
  10. #
  11. # This program is distributed in the hope that it will be useful,
  12. # but WITHOUT ANY WARRANTY; without even the implied warranty of
  13. # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  14. # GNU General Public License for more details.
  15. #
  16. # You should have received a copy of the GNU General Public License
  17. # along with this program. If not, see <http://www.gnu.org/licenses/>.
  18. """
  19. tw.view: base class for tracking wallet view classes
  20. """
  21. import sys, time, asyncio
  22. from collections import namedtuple
  23. from ..cfg import gv
  24. from ..objmethods import MMGenObject
  25. from ..obj import get_obj, MMGenIdx, MMGenList
  26. from ..color import nocolor, yellow, green, red, blue
  27. from ..util import msg, msg_r, fmt, die, capfirst, make_timestr
  28. from ..rpc import rpc_init
  29. from ..base_obj import AsyncInit
  30. # these are replaced by fake versions in overlay:
  31. CUR_HOME = '\033[H'
  32. CUR_UP = lambda n: f'\033[{n}A'
  33. CUR_DOWN = lambda n: f'\033[{n}B'
  34. ERASE_ALL = '\033[0J'
  35. # decorator for action.run():
  36. def enable_echo(orig_func):
  37. async def f(self, parent, action_method):
  38. if parent.scroll:
  39. parent.term.set('echo')
  40. ret = await orig_func(self, parent, action_method)
  41. if parent.scroll:
  42. parent.term.set('noecho')
  43. return ret
  44. return f
  45. # base class for TwUnspentOutputs, TwAddresses, TwTxHistory:
  46. class TwView(MMGenObject, metaclass=AsyncInit):
  47. class display_type:
  48. class squeezed:
  49. detail = False
  50. fmt_method = 'gen_squeezed_display'
  51. line_fmt_method = 'squeezed_format_line'
  52. subhdr_fmt_method = 'gen_subheader'
  53. colhdr_fmt_method = 'squeezed_col_hdr'
  54. need_column_widths = True
  55. item_separator = '\n'
  56. print_header = '[screen print truncated to width {}]\n'
  57. class detail:
  58. detail = True
  59. fmt_method = 'gen_detail_display'
  60. line_fmt_method = 'detail_format_line'
  61. subhdr_fmt_method = 'gen_subheader'
  62. colhdr_fmt_method = 'detail_col_hdr' # set to None to disable
  63. need_column_widths = True
  64. item_separator = '\n'
  65. print_header = ''
  66. class line_processing:
  67. class print:
  68. @staticmethod
  69. def do(method, data, cw, fs, color, fmt_method):
  70. return [l.rstrip() for l in method(data, cw, fs, color, fmt_method)]
  71. has_wallet = True
  72. has_amt2 = False
  73. dates_set = False
  74. reverse = False
  75. group = False
  76. use_cached = False
  77. txid_w = 64
  78. sort_key = 'age'
  79. display_hdr = ()
  80. display_body = ()
  81. prompt_fs_repl = {}
  82. nodata_msg = '[no data for requested parameters]'
  83. cols = 0
  84. term_height = 0
  85. term_width = 0
  86. scrollable_height = 0
  87. min_scrollable_height = 5
  88. addr_view_pref = 0
  89. pos = 0
  90. filters = ()
  91. fp = namedtuple('fs_params', ['fs_key', 'hdr_fs_repl', 'fs_repl', 'hdr_fs', 'fs'])
  92. fs_params = {
  93. 'num': fp('n', True, True, ' {n:>%s}', ' {n:>%s}'),
  94. 'txid': fp('t', True, False, ' {t:%s}', ' {t}'),
  95. 'vout': fp('v', True, False, '{v:%s}', '{v}'),
  96. 'used': fp('u', True, False, ' {u:%s}', ' {u}'),
  97. 'addr': fp('a', True, False, ' {a:%s}', ' {a}'),
  98. 'mmid': fp('m', True, False, ' {m:%s}', ' {m}'),
  99. 'comment': fp('c', True, False, ' {c:%s}', ' {c}'),
  100. 'amt': fp('A', True, False, ' {A:%s}', ' {A}'),
  101. 'amt2': fp('B', True, False, ' {B:%s}', ' {B}'),
  102. 'date': fp('d', True, True, ' {d:%s}', ' {d:<%s}'),
  103. 'date_time': fp('D', True, True, ' {D:%s}', ' {D:%s}'),
  104. 'block': fp('b', True, True, ' {b:%s}', ' {b:<%s}'),
  105. 'inputs': fp('i', True, False, ' {i:%s}', ' {i}'),
  106. 'outputs': fp('o', True, False, ' {o:%s}', ' {o}'),
  107. }
  108. age_fmts = ('confs', 'block', 'days', 'date', 'date_time')
  109. age_fmts_date_dependent = ('days', 'date', 'date_time')
  110. _age_fmt = 'confs'
  111. bch_addr_fmts = ('cashaddr', 'legacy')
  112. age_col_params = {
  113. 'confs': (7, 'Confs'),
  114. 'block': (8, 'Block'),
  115. 'days': (6, 'Age(d)'),
  116. 'date': (8, 'Date'),
  117. 'date_time': (16, 'Date/Time'),
  118. }
  119. date_formatter = {
  120. 'days': lambda rpc, secs: (rpc.cur_date - secs) // 86400 if secs else 0,
  121. 'date': (
  122. lambda rpc, secs: '{}-{:02}-{:02}'.format(*time.gmtime(secs)[:3])[2:]
  123. if secs else '- '),
  124. 'date_time': (
  125. lambda rpc, secs: '{}-{:02}-{:02} {:02}:{:02}'.format(*time.gmtime(secs)[:5])
  126. if secs else '- '),
  127. }
  128. twidth_diemsg = """
  129. --columns or MMGEN_COLUMNS value ({}) is too small to display the {}
  130. Minimum value for this configuration: {}
  131. """
  132. twidth_errmsg = """
  133. Screen is too narrow to display the {} with current configuration
  134. Please resize your screen to at least {} characters and hit any key:
  135. """
  136. theight_errmsg = """
  137. Terminal window is too small to display the {} with current configuration
  138. Please resize it to at least {} lines and hit any key:
  139. """
  140. squeezed_format_line = None
  141. detail_format_line = None
  142. scroll_keys = {
  143. 'vi': {
  144. 'k': 'm_cursor_up',
  145. 'j': 'm_cursor_down',
  146. 'b': 'm_pg_up',
  147. 'f': 'm_pg_down',
  148. 'g': 'm_top',
  149. 'G': 'm_bot',
  150. },
  151. 'linux': {
  152. '\x1b[A': 'm_cursor_up',
  153. '\x1b[B': 'm_cursor_down',
  154. '\x1b[5~': 'm_pg_up',
  155. '\x1b[6~': 'm_pg_down',
  156. '\x1b[7~': 'm_top',
  157. '\x1b[8~': 'm_bot',
  158. },
  159. 'win32': {
  160. '\xe0H': 'm_cursor_up',
  161. '\xe0P': 'm_cursor_down',
  162. '\xe0I': 'm_pg_up',
  163. '\xe0Q': 'm_pg_down',
  164. '\xe0G': 'm_top',
  165. '\xe0O': 'm_bot',
  166. }
  167. }
  168. scroll_keys['darwin'] = scroll_keys['linux']
  169. extra_key_mappings = {}
  170. def __new__(cls, cfg, proto, *args, **kwargs):
  171. return MMGenObject.__new__(proto.base_proto_subclass(cls, cls.mod_subpath))
  172. async def __init__(self, cfg, proto):
  173. self.cfg = cfg
  174. self.proto = proto
  175. self.rpc = await rpc_init(cfg, proto)
  176. if self.has_wallet:
  177. from .ctl import TwCtl
  178. self.twctl = await TwCtl(cfg, proto, mode='w')
  179. self.amt_keys = {'amt':'iwidth', 'amt2':'iwidth2'} if self.has_amt2 else {'amt':'iwidth'}
  180. if repl := self.prompt_fs_repl.get(self.proto.coin):
  181. self.prompt_fs_in[repl[0]] = repl[1]
  182. self.prompt_fs = '\n'.join(self.prompt_fs_in)
  183. self.key_mappings.update(self.extra_key_mappings)
  184. if self.proto.coin == 'BCH':
  185. self.key_mappings.update({'h': 'd_addr_view_pref'})
  186. self.addr_view_pref = 1 if not self.cfg.cashaddr else not self.proto.cashaddr
  187. @property
  188. def age_w(self):
  189. return self.age_col_params[self.age_fmt][0]
  190. @property
  191. def age_hdr(self):
  192. return self.age_col_params[self.age_fmt][1]
  193. @property
  194. def age_fmt(self):
  195. return self._age_fmt
  196. @age_fmt.setter
  197. def age_fmt(self, val):
  198. if val not in self.age_fmts:
  199. die('BadAgeFormat', f'{val!r}: invalid age format (must be one of {self.age_fmts!r})')
  200. self._age_fmt = val
  201. def age_disp(self, o, age_fmt):
  202. if age_fmt == 'confs':
  203. return o.confs or '-'
  204. elif age_fmt == 'block':
  205. return self.rpc.blockcount + 1 - o.confs if o.confs else '-'
  206. else:
  207. return self.date_formatter[age_fmt](self.rpc, o.date)
  208. def get_disp_prec(self, wide):
  209. return self.proto.coin_amt.max_prec
  210. sort_disp = {
  211. 'addr': 'Addr',
  212. 'age': 'Age',
  213. 'amt': 'Amt',
  214. 'txid': 'TxID',
  215. 'twmmid': 'MMGenID',
  216. }
  217. sort_funcs = {
  218. 'addr': lambda i: i.addr,
  219. 'age': lambda i: 0 - i.confs,
  220. 'amt': lambda i: i.amt,
  221. 'txid': lambda i: f'{i.txid} {i.vout:04}',
  222. 'twmmid': lambda i: i.twmmid.sort_key
  223. }
  224. def sort_info(self, *, include_group=True):
  225. ret = ([], ['Reverse'])[self.reverse]
  226. ret.append(self.sort_disp[self.sort_key])
  227. if include_group and self.group and (self.sort_key in ('addr', 'txid', 'twmmid')):
  228. ret.append('Grouped')
  229. return ret
  230. def do_sort(self, key=None, *, reverse=False):
  231. key = key or self.sort_key
  232. if key not in self.sort_funcs:
  233. die(1, f'{key!r}: invalid sort key. Valid options: {" ".join(self.sort_funcs)}')
  234. self.sort_key = key
  235. assert isinstance(reverse, bool)
  236. save = self.data.copy()
  237. self.data.sort(key=self.sort_funcs[key], reverse=reverse or self.reverse)
  238. if self.data != save:
  239. self.pos = 0
  240. async def get_data(self, *, sort_key=None, reverse_sort=False):
  241. rpc_data = await self.get_rpc_data()
  242. if not rpc_data:
  243. die(1, fmt(self.no_rpcdata_errmsg).strip())
  244. lbl_id = ('account', 'label')['label_api' in self.rpc.caps]
  245. res = self.gen_data(rpc_data, lbl_id)
  246. self.data = MMGenList(await res if type(res).__name__ == 'coroutine' else res)
  247. self.disp_data = list(self.filter_data())
  248. if not self.data:
  249. die(1, self.no_data_errmsg)
  250. self.do_sort(key=sort_key, reverse=reverse_sort)
  251. # get_data() is immediately followed by display header, and get_rpc_data() produces output,
  252. # so add NL here (' ' required because CUR_HOME erases preceding blank lines)
  253. msg(' ')
  254. def get_term_dimensions(self, min_cols, *, min_lines=None):
  255. from ..term import get_terminal_size, get_char_raw, _term_dimensions
  256. user_resized = False
  257. while True:
  258. ts = get_terminal_size()
  259. cols = self.cfg.columns or ts.width
  260. lines = ts.height
  261. if cols >= min_cols and (min_lines is None or lines >= min_lines):
  262. if user_resized:
  263. msg_r(CUR_HOME + ERASE_ALL)
  264. return _term_dimensions(cols, ts.height)
  265. if sys.stdout.isatty():
  266. if self.cfg.columns and cols < min_cols:
  267. die(1, '\n'+fmt(self.twidth_diemsg.format(self.cfg.columns, self.desc, min_cols), indent=' '))
  268. else:
  269. m, dim = (self.twidth_errmsg, min_cols) if cols < min_cols else (self.theight_errmsg, min_lines)
  270. get_char_raw(CUR_HOME + ERASE_ALL + fmt(m.format(self.desc, dim), append=''))
  271. user_resized = True
  272. else:
  273. return _term_dimensions(min_cols, ts.height)
  274. def compute_column_widths(self, widths, maxws, minws, maxws_nice, *, wide, interactive):
  275. def do_ret(freews):
  276. widths.update({k:minws[k] + freews.get(k, 0) for k in minws})
  277. widths.update({ikey: widths[key] - self.disp_prec - 1 for key, ikey in self.amt_keys.items()})
  278. return namedtuple('column_widths', widths.keys())(*widths.values())
  279. def do_ret_max():
  280. widths.update({k:max(minws[k], maxws[k]) for k in minws})
  281. widths.update({ikey: widths[key] - self.disp_prec - 1 for key, ikey in self.amt_keys.items()})
  282. return namedtuple('column_widths', widths.keys())(*widths.values())
  283. def get_freews(cols, varws, varw, minw):
  284. freew = cols - minw
  285. if freew and varw:
  286. x = freew / varw
  287. freews = {k:int(varws[k] * x) for k in varws}
  288. remainder = freew - sum(freews.values())
  289. for k in varws:
  290. if not remainder:
  291. break
  292. if freews[k] < varws[k]:
  293. freews[k] += 1
  294. remainder -= 1
  295. return freews
  296. else:
  297. return {k:0 for k in varws}
  298. varws = {k:maxws[k] - minws[k] for k in maxws if maxws[k] > minws[k]}
  299. minw = sum(widths.values()) + sum(minws.values())
  300. varw = sum(varws.values())
  301. self.min_term_width = 40 if wide else max(self.prompt_width, minw) if interactive else minw
  302. td = self.get_term_dimensions(self.min_term_width)
  303. self.term_height = td.height
  304. self.term_width = td.width
  305. self.cols = min(self.term_width, minw + varw)
  306. if wide or self.cols == minw + varw:
  307. return do_ret_max()
  308. if maxws_nice:
  309. # compute high-priority widths:
  310. varws_hp = {k: maxws_nice[k] - minws[k] if k in maxws_nice else varws[k] for k in varws}
  311. varw_hp = sum(varws_hp.values())
  312. widths_hp = get_freews(
  313. min(self.term_width, minw + varw_hp),
  314. varws_hp,
  315. varw_hp,
  316. minw)
  317. # compute low-priority (nice) widths:
  318. varws_lp = {k: varws[k] - varws_hp[k] for k in maxws_nice if k in varws}
  319. widths_lp = get_freews(
  320. self.cols,
  321. varws_lp,
  322. sum(varws_lp.values()),
  323. minw + sum(widths_hp.values()))
  324. # sum the two for each field:
  325. return do_ret({k:widths_hp[k] + widths_lp.get(k, 0) for k in varws})
  326. else:
  327. return do_ret(get_freews(self.cols, varws, varw, minw))
  328. def gen_subheader(self, cw, color):
  329. return ()
  330. def gen_footer(self, color):
  331. if hasattr(self, 'total'):
  332. yield 'TOTAL: {} {}'.format(self.total.hl(color=color), self.proto.dcoin)
  333. def set_amt_widths(self, data):
  334. # width of amts column: min(7, width of integer part) + len('.') + width of fractional part
  335. self.amt_widths = {
  336. k:min(7, max(len(str(getattr(d, k).to_integral_value())) for d in data)) + 1 + self.disp_prec
  337. for k in self.amt_keys}
  338. async def format(
  339. self,
  340. display_type,
  341. *,
  342. color = True,
  343. interactive = False,
  344. line_processing = None,
  345. scroll = False):
  346. def make_display():
  347. def gen_hdr(spc):
  348. Blue, Green = (blue, green) if color else (nocolor, nocolor)
  349. Yes, No, All = (green('yes'), red('no'), yellow('all')) if color else ('yes', 'no', 'all')
  350. sort_info = ' '.join(self.sort_info())
  351. def fmt_filter(k):
  352. return '{}:{}'.format(k, {0:No, 1:Yes, 2:All}[getattr(self, k)])
  353. yield '{} (sort order: {}){}'.format(
  354. self.hdr_lbl.upper(),
  355. Blue(sort_info),
  356. spc * (self.cols - len(f'{self.hdr_lbl} (sort order: {sort_info})')))
  357. if self.filters:
  358. yield 'Filters: {}{}'.format(
  359. ' '.join(map(fmt_filter, self.filters)),
  360. spc * len(self.filters))
  361. yield 'Network: {}'.format(Green(
  362. self.proto.coin + ' ' + self.proto.chain_name.upper()))
  363. yield 'Block {} [{}]'.format(
  364. self.rpc.blockcount.hl(color=color),
  365. make_timestr(self.rpc.cur_date))
  366. if hasattr(self, 'total'):
  367. yield 'Total {}: {}'.format(self.proto.dcoin, self.total.hl(color=color))
  368. yield from getattr(self, dt.subhdr_fmt_method)(cw, color)
  369. yield spc * self.term_width
  370. if data and dt.colhdr_fmt_method:
  371. col_hdr = getattr(self, dt.colhdr_fmt_method)(cw, hdr_fs, color)
  372. yield col_hdr.rstrip() if line_processing == 'print' else col_hdr
  373. def get_body(method):
  374. if line_processing:
  375. return getattr(self.line_processing, line_processing).do(
  376. method, data, cw, fs, color, getattr(self, dt.line_fmt_method))
  377. else:
  378. return method(data, cw, fs, color, getattr(self, dt.line_fmt_method))
  379. if data and dt.need_column_widths:
  380. self.set_amt_widths(data)
  381. cw = self.get_column_widths(data, wide=dt.detail, interactive=interactive)
  382. cwh = cw._asdict()
  383. fp = self.fs_params
  384. rfill = ' ' * (self.term_width - self.cols) if scroll else ''
  385. hdr_fs = ''.join(fp[name].hdr_fs % ((), cwh[name])[fp[name].hdr_fs_repl]
  386. for name in dt.cols if cwh[name]) + rfill
  387. fs = ''.join(fp[name].fs % ((), cwh[name])[fp[name].fs_repl]
  388. for name in dt.cols if cwh[name]) + rfill
  389. else:
  390. cw = hdr_fs = fs = None
  391. return (
  392. tuple(gen_hdr(spc='' if line_processing == 'print' else ' ')),
  393. tuple(
  394. get_body(getattr(self, dt.fmt_method)) if data else
  395. [(nocolor, yellow)[color](self.nodata_msg.ljust(self.term_width))])
  396. )
  397. if not gv.stdout.isatty():
  398. line_processing = 'print'
  399. dt = getattr(self.display_type, display_type)
  400. if self.use_cached:
  401. self.use_cached = False
  402. display_hdr = self.display_hdr
  403. display_body = self.display_body
  404. else:
  405. self.disp_prec = self.get_disp_prec(wide=dt.detail)
  406. if self.has_age and (self.age_fmt in self.age_fmts_date_dependent or dt.detail):
  407. await self.set_dates(self.data)
  408. dsave = self.disp_data
  409. data = self.disp_data = list(self.filter_data()) # method could be a generator
  410. if data != dsave:
  411. self.pos = 0
  412. display_hdr, display_body = make_display()
  413. if scroll:
  414. fixed_height = len(display_hdr) + self.prompt_height + 1
  415. if self.term_height - fixed_height < self.min_scrollable_height:
  416. td = self.get_term_dimensions(
  417. self.min_term_width,
  418. min_lines = self.min_scrollable_height + fixed_height)
  419. self.term_height = td.height
  420. self.term_width = td.width
  421. display_hdr, display_body = make_display()
  422. self.scrollable_height = self.term_height - fixed_height
  423. self.max_pos = max(0, len(display_body) - self.scrollable_height)
  424. self.pos = min(self.pos, self.max_pos)
  425. if not dt.detail:
  426. self.display_hdr = display_hdr
  427. self.display_body = display_body
  428. if scroll:
  429. top = self.pos
  430. bot = self.pos + self.scrollable_height
  431. fill = ('\n' + ''.ljust(self.term_width)) * (self.scrollable_height - len(display_body))
  432. else:
  433. top, bot, fill = (None, None, '')
  434. if interactive:
  435. footer = ''
  436. else:
  437. footer = '\n'.join(self.gen_footer(color))
  438. footer = ('\n\n' + footer if footer else '') + '\n'
  439. return (
  440. '\n'.join(display_hdr) + '\n'
  441. + dt.item_separator.join(display_body[top:bot])
  442. + fill
  443. + footer
  444. )
  445. async def view_filter_and_sort(self):
  446. action_map = {
  447. 'a_': 'action',
  448. 's_': 'sort_action',
  449. 'd_': 'display_action',
  450. 'm_': 'scroll_action',
  451. 'i_': 'item_action',
  452. }
  453. def make_key_mappings(scroll):
  454. if scroll:
  455. for k in self.scroll_keys['vi']:
  456. assert k not in self.key_mappings, f'{k!r} is in key_mappings'
  457. self.key_mappings.update(self.scroll_keys['vi'])
  458. self.key_mappings.update(self.scroll_keys[sys.platform])
  459. return self.key_mappings
  460. scroll = self.scroll = self.cfg.scroll
  461. key_mappings = make_key_mappings(scroll)
  462. action_classes = {k: getattr(self, action_map[v[:2]])() for k, v in key_mappings.items()}
  463. action_methods = {k: getattr(v, key_mappings[k]) for k, v in action_classes.items()}
  464. prompt = self.prompt_fs.strip().format(
  465. s='\nScrolling: k=up, j=down, b=pgup, f=pgdown, g=top, G=bottom' if scroll else '')
  466. self.prompt_width = max(len(l) for l in prompt.split('\n'))
  467. self.prompt_height = len(prompt.split('\n'))
  468. self.oneshot_msg = ''
  469. prompt += '\b'
  470. clear_screen = '\n\n' if self.cfg.no_blank else CUR_HOME + ('' if scroll else ERASE_ALL)
  471. from ..term import get_term, get_char, get_char_raw
  472. if scroll:
  473. self.term = get_term()
  474. self.term.register_cleanup()
  475. self.term.set('noecho')
  476. get_char = get_char_raw
  477. msg_r(CUR_HOME + ERASE_ALL)
  478. while True:
  479. if self.oneshot_msg and scroll:
  480. msg_r(self.blank_prompt + self.oneshot_msg + ' ') # oneshot_msg must be a one-liner
  481. await asyncio.sleep(2)
  482. msg_r('\r' + ''.ljust(self.term_width))
  483. reply = get_char(
  484. clear_screen
  485. + await self.format('squeezed', interactive=True, scroll=scroll)
  486. + '\n\n'
  487. + (self.oneshot_msg + '\n\n' if self.oneshot_msg and not scroll else '')
  488. + prompt,
  489. immed_chars = key_mappings)
  490. self.oneshot_msg = ''
  491. if reply in key_mappings:
  492. ret = action_classes[reply].run(self, action_methods[reply])
  493. if type(ret).__name__ == 'coroutine':
  494. await ret
  495. elif reply == 'q':
  496. msg('')
  497. if self.scroll:
  498. self.term.set('echo')
  499. return
  500. else:
  501. if not scroll:
  502. msg_r('\ninvalid keypress ')
  503. await asyncio.sleep(0.3)
  504. @property
  505. def blank_prompt(self):
  506. return CUR_HOME + CUR_DOWN(self.term_height - self.prompt_height) + ERASE_ALL
  507. def keypress_confirm(self, *args, **kwargs):
  508. from ..ui import keypress_confirm
  509. if keypress_confirm(self.cfg, *args, no_nl=self.scroll, **kwargs):
  510. return True
  511. else:
  512. if self.scroll:
  513. msg_r('\r'+''.ljust(self.term_width)+'\r'+yellow('Canceling! '))
  514. return False
  515. class action:
  516. @enable_echo
  517. async def run(self, parent, action_method):
  518. return await action_method(parent)
  519. async def a_print_detail(self, parent):
  520. return await self._print(parent, output_type='detail')
  521. async def a_print_squeezed(self, parent):
  522. return await self._print(parent, output_type='squeezed')
  523. async def _print(self, parent, output_type):
  524. if not parent.disp_data:
  525. return None
  526. outfile = '{a}{b}-{c}{d}[{e}].out'.format(
  527. a = parent.dump_fn_pfx,
  528. b = f'-{output_type}' if len(parent.print_output_types) > 1 else '',
  529. c = parent.proto.dcoin,
  530. d = ('' if parent.proto.network == 'mainnet' else '-'+parent.proto.network.upper()),
  531. e = ','.join(parent.sort_info(include_group=False)).replace(' ', ''))
  532. print_hdr = getattr(parent.display_type, output_type).print_header.format(parent.cols)
  533. msg_r(parent.blank_prompt if parent.scroll else '\n')
  534. from ..fileutil import write_data_to_file
  535. from ..exception import UserNonConfirmation
  536. try:
  537. write_data_to_file(
  538. cfg = parent.cfg,
  539. outfile = outfile,
  540. data = print_hdr + await parent.format(
  541. display_type = output_type,
  542. line_processing = 'print',
  543. color = False),
  544. desc = f'{parent.desc} listing')
  545. except UserNonConfirmation:
  546. parent.oneshot_msg = yellow(f'File {outfile!r} not overwritten by user request')
  547. else:
  548. parent.oneshot_msg = green(f'Data written to {outfile!r}')
  549. async def a_view(self, parent):
  550. from ..ui import do_pager
  551. parent.use_cached = True
  552. msg_r(CUR_HOME)
  553. do_pager(await parent.format('squeezed', color=True))
  554. async def a_view_detail(self, parent):
  555. from ..ui import do_pager
  556. msg_r(CUR_HOME)
  557. do_pager(await parent.format('detail', color=True))
  558. class item_action:
  559. @enable_echo
  560. async def run(self, parent, action_method):
  561. if not parent.disp_data:
  562. return
  563. from ..ui import line_input
  564. while True:
  565. msg_r(parent.blank_prompt if parent.scroll else '\n')
  566. ret = line_input(
  567. parent.cfg,
  568. f'Enter {parent.item_desc} number (or ENTER to return to main menu): ')
  569. if ret == '':
  570. if parent.scroll:
  571. msg_r(CUR_UP(1) + '\r' + ''.ljust(parent.term_width))
  572. return
  573. idx = get_obj(MMGenIdx, n=ret, silent=True)
  574. if not idx or idx < 1 or idx > len(parent.disp_data):
  575. msg_r(
  576. 'Choice must be a single number between 1 and {n}{s}'.format(
  577. n = len(parent.disp_data),
  578. s = ' ' if parent.scroll else ''))
  579. if parent.scroll:
  580. await asyncio.sleep(1.5)
  581. msg_r(CUR_UP(1) + '\r' + ERASE_ALL)
  582. else:
  583. # action return values:
  584. # True: action successfully performed
  585. # None: action aborted by user or no action performed
  586. # False: an error occurred
  587. # 'redo': user will be re-prompted for item number
  588. ret = await action_method(parent, idx)
  589. if ret != 'redo':
  590. break
  591. await asyncio.sleep(0.5)
  592. if parent.scroll and ret is False:
  593. # error messages could leave screen in messy state, so do complete redraw:
  594. msg_r(
  595. CUR_HOME + ERASE_ALL +
  596. await parent.format(display_type='squeezed', interactive=True, scroll=True))
  597. async def i_balance_refresh(self, parent, idx):
  598. if not parent.keypress_confirm(
  599. f'Refreshing tracking wallet {parent.item_desc} #{idx}. Is this what you want?'):
  600. return 'redo'
  601. await parent.twctl.get_balance(parent.disp_data[idx-1].addr, force_rpc=True)
  602. await parent.get_data()
  603. parent.oneshot_msg = yellow(f'{parent.proto.dcoin} balance for account #{idx} refreshed')
  604. async def i_addr_delete(self, parent, idx):
  605. if not parent.keypress_confirm(
  606. 'Removing {} {} from tracking wallet. Is this what you want?'.format(
  607. parent.item_desc, red(f'#{idx}'))):
  608. return 'redo'
  609. if await parent.twctl.remove_address(parent.disp_data[idx-1].addr):
  610. await parent.get_data()
  611. parent.oneshot_msg = yellow(f'{capfirst(parent.item_desc)} #{idx} removed')
  612. return True
  613. else:
  614. await asyncio.sleep(3)
  615. parent.oneshot_msg = red('Address could not be removed')
  616. return False
  617. async def i_comment_add(self, parent, idx):
  618. async def do_comment_add(comment):
  619. if await parent.twctl.set_comment(
  620. addrspec = None,
  621. comment = comment,
  622. trusted_pair = (entry.twmmid, entry.addr),
  623. silent = parent.scroll):
  624. entry.comment = comment
  625. edited = cur_comment and comment
  626. parent.oneshot_msg = (green if comment else yellow)('Label {a} {b}{c}'.format(
  627. a = 'for' if edited else 'added to' if comment else 'removed from',
  628. b = desc,
  629. c = ' edited' if edited else ''))
  630. return True
  631. else:
  632. await asyncio.sleep(3)
  633. parent.oneshot_msg = red('Label for {desc} could not be {action}'.format(
  634. desc = desc,
  635. action = 'edited' if cur_comment and comment else 'added' if comment else 'removed'
  636. ))
  637. return False
  638. entry = parent.disp_data[idx-1]
  639. desc = f'{parent.item_desc} #{idx}'
  640. cur_comment = parent.disp_data[idx-1].comment
  641. msg('Current label: {}'.format(cur_comment.hl() if cur_comment else '(none)'))
  642. from ..ui import line_input
  643. res = line_input(
  644. parent.cfg,
  645. 'Enter label text for {} {}: '.format(parent.item_desc, red(f'#{idx}')),
  646. insert_txt = cur_comment)
  647. if res == cur_comment:
  648. parent.oneshot_msg = yellow(f'Label for {desc} unchanged')
  649. return None
  650. elif res == '':
  651. if not parent.keypress_confirm(f'Removing label for {desc}. Is this what you want?'):
  652. return 'redo'
  653. return await do_comment_add(res)
  654. class scroll_action:
  655. def run(self, parent, action_method):
  656. self.use_cached = True
  657. return action_method(parent)
  658. def m_cursor_up(self, parent):
  659. parent.pos -= min(parent.pos - 0, 1)
  660. def m_cursor_down(self, parent):
  661. parent.pos += min(parent.max_pos - parent.pos, 1)
  662. def m_pg_up(self, parent):
  663. parent.pos -= min(parent.scrollable_height, parent.pos - 0)
  664. def m_pg_down(self, parent):
  665. parent.pos += min(parent.scrollable_height, parent.max_pos - parent.pos)
  666. def m_top(self, parent):
  667. parent.pos = 0
  668. def m_bot(self, parent):
  669. parent.pos = parent.max_pos
  670. class sort_action:
  671. def run(self, parent, action_method):
  672. return action_method(parent)
  673. def s_addr(self, parent):
  674. parent.do_sort('addr')
  675. def s_age(self, parent):
  676. parent.do_sort('age')
  677. def s_amt(self, parent):
  678. parent.do_sort('amt')
  679. def s_txid(self, parent):
  680. parent.do_sort('txid')
  681. def s_twmmid(self, parent):
  682. parent.do_sort('twmmid')
  683. def s_reverse(self, parent):
  684. parent.data.reverse()
  685. parent.reverse = not parent.reverse
  686. class display_action:
  687. def run(self, parent, action_method):
  688. return action_method(parent)
  689. def d_days(self, parent):
  690. af = parent.age_fmts
  691. parent.age_fmt = af[(af.index(parent.age_fmt) + 1) % len(af)]
  692. if parent.update_widths_on_age_toggle: # TODO
  693. pass
  694. def d_redraw(self, parent):
  695. msg_r(CUR_HOME + ERASE_ALL)
  696. def d_addr_view_pref(self, parent):
  697. parent.addr_view_pref = (parent.addr_view_pref + 1) % len(parent.bch_addr_fmts)