Thornode -> ThornodeQuote
This commit is contained in:
parent
048e2e7505
commit
00781a3554
4 changed files with 12 additions and 12 deletions
|
|
@ -145,9 +145,9 @@ class THORChainRemoteRPCClient(RemoteRPCClient):
|
|||
from_asset = get_swap_asset(self.cfg, send_asset, direction='send')
|
||||
to_asset = get_swap_asset(self.cfg, recv_asset, direction='recv')
|
||||
send_amt = init_swap_proto(self.cfg, from_asset).coin_amt(str(amt))
|
||||
return self.get_quote(from_asset, to_asset, send_amt)
|
||||
return self.do_quote(from_asset, to_asset, send_amt)
|
||||
|
||||
def get_quote(self, from_asset, to_asset, amt, *, amt_is_atomic=False):
|
||||
def do_quote(self, from_asset, to_asset, amt, *, amt_is_atomic=False):
|
||||
from ....swap.util import get_swap_proto_mod
|
||||
swap_cfg = get_swap_proto_mod(self.swap_proto).SwapCfg(self.cfg)
|
||||
qs = make_query_string({
|
||||
|
|
|
|||
|
|
@ -21,9 +21,9 @@ class ExpInt4(ExpInt):
|
|||
def __new__(cls, spec):
|
||||
return ExpInt.__new__(cls, spec, prec=exp_prec)
|
||||
|
||||
def rpc_client(tx, amt):
|
||||
from .thornode import Thornode
|
||||
return Thornode(tx, amt)
|
||||
def quote_client(tx, amt):
|
||||
from .quote import ThornodeQuote
|
||||
return ThornodeQuote(tx, amt)
|
||||
|
||||
from .cfg import THORChainSwapCfg as SwapCfg
|
||||
|
||||
|
|
|
|||
|
|
@ -7,7 +7,7 @@
|
|||
# https://gitlab.com/mmgen/mmgen-wallet
|
||||
|
||||
"""
|
||||
swap.proto.thorchain.thornode: THORChain swap protocol network query ops
|
||||
swap.proto.thorchain.quote: THORChain swap protocol remote quote class
|
||||
"""
|
||||
|
||||
import time
|
||||
|
|
@ -23,7 +23,7 @@ gas_unit_data = {
|
|||
'gwei': _gd('G', 'Gwei'),
|
||||
}
|
||||
|
||||
class Thornode:
|
||||
class ThornodeQuote:
|
||||
|
||||
def __init__(self, tx, amt):
|
||||
self.tx = tx
|
||||
|
|
@ -36,10 +36,10 @@ class Thornode:
|
|||
and self.tx.send_asset.chain != 'THOR'): # token swap
|
||||
from ....swap.util import get_swap_asset
|
||||
rune_asset = get_swap_asset(self.tx.cfg, 'RUNE')
|
||||
in_data = self.rpc.get_quote(self.tx.send_asset, rune_asset, self.in_amt)
|
||||
in_data = self.rpc.do_quote(self.tx.send_asset, rune_asset, self.in_amt)
|
||||
if self.tx.proto.network != 'regtest':
|
||||
time.sleep(1.1) # ninerealms max request rate 1/sec
|
||||
out_data = self.rpc.get_quote(
|
||||
out_data = self.rpc.do_quote(
|
||||
rune_asset,
|
||||
self.tx.recv_asset,
|
||||
in_data['expected_amount_out'],
|
||||
|
|
@ -49,7 +49,7 @@ class Thornode:
|
|||
'fees': out_data['fees'],
|
||||
'expiry': min(in_data['expiry'], out_data['expiry'])}
|
||||
else:
|
||||
self.data = self.rpc.get_quote(self.tx.send_asset, self.tx.recv_asset, self.in_amt)
|
||||
self.data = self.rpc.do_quote(self.tx.send_asset, self.tx.recv_asset, self.in_amt)
|
||||
|
||||
async def format_quote(self, *, deduct_est_fee=False, skip_est_fee=False):
|
||||
from ....util import make_timestr, ymsg
|
||||
|
|
@ -130,7 +130,7 @@ class NewSwap(New):
|
|||
if not args.send_amt:
|
||||
die(1, 'With --quote, you must supply a send amount')
|
||||
await self.display_quote(
|
||||
self.swap_proto_mod.rpc_client(self, args.send_amt),
|
||||
self.swap_proto_mod.quote_client(self, args.send_amt),
|
||||
skip_est_fee = True)
|
||||
sys.exit(0)
|
||||
|
||||
|
|
@ -204,7 +204,7 @@ class NewSwap(New):
|
|||
|
||||
async def update_vault_output(self, amt, *, deduct_est_fee=False):
|
||||
from ..term import get_char
|
||||
qd = self.swap_proto_mod.rpc_client(self, amt)
|
||||
qd = self.swap_proto_mod.quote_client(self, amt)
|
||||
while True:
|
||||
await self.display_quote(qd, deduct_est_fee=deduct_est_fee)
|
||||
ch = get_char('Press ‘r’ to refresh quote, any other key to continue: ')
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue