view.py 25 KB

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