daemon.py 4.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148
  1. #!/usr/bin/env python3
  2. #
  3. # mmgen = Multi-Mode GENerator, a command-line cryptocurrency wallet
  4. # Copyright (C)2013-2023 The MMGen Project <mmgen@tuta.io>
  5. # Licensed under the GNU General Public License, Version 3:
  6. # https://www.gnu.org/licenses
  7. # Public project repositories:
  8. # https://github.com/mmgen/mmgen
  9. # https://gitlab.com/mmgen/mmgen
  10. """
  11. proto.xmr.daemon: Monero base protocol daemon classes
  12. """
  13. import os
  14. from ...globalvars import g
  15. from ...opts import opt
  16. from ...util import list_gen,die
  17. from ...daemon import CoinDaemon,RPCDaemon,_nw,_dd
  18. class monero_daemon(CoinDaemon):
  19. daemon_data = _dd('Monero', 'N/A', 'N/A')
  20. networks = ('mainnet','testnet')
  21. exec_fn = 'monerod'
  22. testnet_dir = 'stagenet'
  23. new_console_mswin = True
  24. host = 'localhost' # FIXME
  25. rpc_ports = _nw(18081, 38081, None) # testnet is stagenet
  26. cfg_file = 'bitmonero.conf'
  27. datadirs = {
  28. 'linux': [g.home_dir,'.bitmonero'],
  29. 'win': ['/','c','ProgramData','bitmonero']
  30. }
  31. def init_datadir(self):
  32. self.logdir = super().init_datadir()
  33. return os.path.join(
  34. self.logdir,
  35. self.testnet_dir if self.network == 'testnet' else '' )
  36. def get_p2p_port(self):
  37. return self.rpc_port - 1
  38. def init_subclass(self):
  39. from .rpc import MoneroRPCClientRaw
  40. self.rpc = MoneroRPCClientRaw(
  41. host = self.host,
  42. port = self.rpc_port,
  43. user = None,
  44. passwd = None,
  45. test_connection = False,
  46. daemon = self )
  47. self.shared_args = list_gen(
  48. [f'--no-zmq'],
  49. [f'--p2p-bind-port={self.p2p_port}', self.p2p_port],
  50. [f'--rpc-bind-port={self.rpc_port}'],
  51. ['--stagenet', self.network == 'testnet'],
  52. )
  53. self.coind_args = list_gen(
  54. ['--hide-my-port'],
  55. ['--no-igd'],
  56. [f'--data-dir={self.datadir}', self.non_dfl_datadir],
  57. [f'--pidfile={self.pidfile}', self.platform == 'linux'],
  58. ['--detach', not (self.opt.no_daemonize or self.platform=='win')],
  59. ['--offline', not self.opt.online],
  60. )
  61. @property
  62. def stop_cmd(self):
  63. return ['kill','-Wf',self.pid] if self.platform == 'win' else [self.exec_fn] + self.shared_args + ['exit']
  64. class MoneroWalletDaemon(RPCDaemon):
  65. master_daemon = 'monero_daemon'
  66. rpc_type = 'Monero wallet'
  67. exec_fn = 'monero-wallet-rpc'
  68. coin = 'XMR'
  69. new_console_mswin = True
  70. networks = ('mainnet','testnet')
  71. rpc_ports = _nw(13131, 13141, None) # testnet is non-standard
  72. def __init__(
  73. self,
  74. proto,
  75. wallet_dir,
  76. test_suite = False,
  77. host = None,
  78. user = None,
  79. passwd = None,
  80. daemon_addr = None,
  81. proxy = None,
  82. port_shift = None,
  83. datadir = None ):
  84. self.proto = proto
  85. self.test_suite = test_suite
  86. super().__init__()
  87. self.network = proto.network
  88. self.wallet_dir = wallet_dir
  89. self.rpc_port = getattr(self.rpc_ports,self.network) + (11 if test_suite else 0)
  90. if port_shift:
  91. self.rpc_port += port_shift
  92. id_str = f'{self.exec_fn}-{self.bind_port}'
  93. self.datadir = os.path.join((datadir or self.exec_fn),('','test_suite')[test_suite])
  94. self.pidfile = os.path.join(self.datadir,id_str+'.pid')
  95. self.logfile = os.path.join(self.datadir,id_str+'.log')
  96. self.proxy = proxy
  97. self.daemon_addr = daemon_addr
  98. self.daemon_port = None if daemon_addr else CoinDaemon(proto=proto,test_suite=test_suite).rpc_port
  99. self.host = host or opt.wallet_rpc_host or g.monero_wallet_rpc_host
  100. self.user = user or opt.wallet_rpc_user or g.monero_wallet_rpc_user
  101. self.passwd = passwd or opt.wallet_rpc_password or g.monero_wallet_rpc_password
  102. assert self.host
  103. assert self.user
  104. if not self.passwd:
  105. die(1,
  106. 'You must set your Monero wallet RPC password.\n' +
  107. 'This can be done on the command line with the --wallet-rpc-password option\n' +
  108. "(insecure, not recommended), or by setting 'monero_wallet_rpc_password' in\n" +
  109. "the MMGen config file." )
  110. self.daemon_args = list_gen(
  111. ['--untrusted-daemon'],
  112. [f'--rpc-bind-port={self.rpc_port}'],
  113. ['--wallet-dir='+self.wallet_dir],
  114. ['--log-file='+self.logfile],
  115. [f'--rpc-login={self.user}:{self.passwd}'],
  116. [f'--daemon-address={self.daemon_addr}', self.daemon_addr],
  117. [f'--daemon-port={self.daemon_port}', not self.daemon_addr],
  118. [f'--proxy={self.proxy}', self.proxy],
  119. [f'--pidfile={self.pidfile}', self.platform == 'linux'],
  120. ['--detach', not (self.opt.no_daemonize or self.platform=='win')],
  121. ['--stagenet', self.network == 'testnet'],
  122. ['--allow-mismatched-daemon-version', test_suite],
  123. )
  124. from .rpc import MoneroWalletRPCClient
  125. self.rpc = MoneroWalletRPCClient( daemon=self, test_connection=False )