From f69753f6a0cf5af4a0274199d87abd5331824c1b Mon Sep 17 00:00:00 2001 From: Jack Date: Mon, 8 Aug 2016 01:42:37 -0400 Subject: [PATCH] add get_claims_for_name --- lbrynet/core/LBRYWallet.py | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/lbrynet/core/LBRYWallet.py b/lbrynet/core/LBRYWallet.py index 415f7378a..5c989d896 100644 --- a/lbrynet/core/LBRYWallet.py +++ b/lbrynet/core/LBRYWallet.py @@ -408,6 +408,8 @@ class LBRYWallet(object): d.addErrback(lambda _: False) if is_mine: d.addCallback(lambda claim: _filter_my_claims(claim) if claim is not False else False) + def get_claims_for_name(self, name): + d = self._get_claims_for_name(name) return d def update_metadata(self, new_metadata, old_metadata): @@ -639,6 +641,9 @@ class LBRYWallet(object): def get_name_claims(self): return defer.fail(NotImplementedError()) + def _get_claims_for_name(self, name): + return defer.fail(NotImplementedError()) + def _check_first_run(self): return defer.fail(NotImplementedError()) @@ -792,6 +797,9 @@ class LBRYcrdWallet(LBRYWallet): def _update_name(self, name, txid, value, amount): return threads.deferToThread(self._update_name_rpc, txid, value, amount) + def _get_claims_for_name(self, name): + return threads.deferToThread(self._get_claims_for_name_rpc, name) + def get_claims_from_tx(self, txid): return threads.deferToThread(self._get_claims_from_tx_rpc, txid) @@ -926,6 +934,11 @@ class LBRYcrdWallet(LBRYWallet): rpc_conn = self._get_rpc_conn() return rpc_conn.getclaimsfortx(txid) + @_catch_connection_error + def _get_claims_for_name_rpc(self, name): + rpc_conn = self._get_rpc_conn() + return rpc_conn.getclaimsforname(name) + @_catch_connection_error def _get_nametrie_rpc(self): rpc_conn = self._get_rpc_conn() @@ -1181,6 +1194,11 @@ class LBRYumWallet(LBRYWallet): d.addCallback(self._broadcast_transaction) return d + def _get_claims_for_name(self, name): + cmd = known_commands['getclaimsforname'] + func = getattr(self.cmd_runner, cmd.name) + return threads.deferToThread(func, name) + def _send_claim_update(self, txid, amount, name, claim_id, val): def send_claim(address): cmd = known_commands['updateclaim']