LBRYCommunity/lbry-sdk
1
0
Fork 1
Code Issues Pull requests Packages Projects Releases 282 Wiki Activity

update name

Browse source
This commit is contained in:
Jack 2016-07-01 03:16:08 -04:00
parent b80fe24179
commit 1cedd8ee5b
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
lbrynet/core/LBRYcrdWallet.py
View file

@ -410,8 +410,8 @@ class LBRYWallet(object):
def update_name(self, name, value, amount): def update_name(self, name, value, amount):
d = self._get_value_for_name(name) d = self._get_value_for_name(name)
d.addCallback(lambda r: (self._update_name(json.loads(r)['txid'], json.dumps(value), amount), json.loads(r)['txid'])) d.addCallback(lambda r: (self._update_name(r['txid'], json.dumps(value), amount), r['txid']))
d.addCallback(lambda new_txid, old_txid: self._update_name_metadata(name, value['sources']['lbry_sd_hash'], old_txid, new_txid)) d.addCallback(lambda (new_txid, old_txid): self._update_name_metadata(name, value['sources']['lbry_sd_hash'], old_txid, new_txid))
return d return d
def get_name_and_validity_for_sd_hash(self, sd_hash): def get_name_and_validity_for_sd_hash(self, sd_hash):
@ -529,7 +529,7 @@ class LBRYWallet(object):
return d return d
def _update_name_metadata(self, name, sd_hash, old_txid, new_txid): def _update_name_metadata(self, name, sd_hash, old_txid, new_txid):
d = self.db.runQuery("delete from name_metadata where txid=? and sd_hash=?", (old_txid, sd_hash)) d = self.db.runQuery("delete * from name_metadata where txid=? and sd_hash=?", (old_txid, sd_hash))
d.addCallback(lambda _: self.db.runQuery("insert into name_metadata values (?, ?, ?)", (name, new_txid, sd_hash))) d.addCallback(lambda _: self.db.runQuery("insert into name_metadata values (?, ?, ?)", (name, new_txid, sd_hash)))
d.addCallback(lambda _: new_txid) d.addCallback(lambda _: new_txid)
return d return d
@ -864,7 +864,7 @@ class LBRYcrdWallet(LBRYWallet):
def _update_name_rpc(self, txid, value, amount): def _update_name_rpc(self, txid, value, amount):
rpc_conn = self._get_rpc_conn() rpc_conn = self._get_rpc_conn()
return rpc_conn.updatename(txid, value, amount) return rpc_conn.updateclaim(txid, value, amount)
@_catch_connection_error @_catch_connection_error
def _send_name_claim_rpc(self, name, value, amount): def _send_name_claim_rpc(self, name, value, amount):