mirror of
https://github.com/LBRYFoundation/lbry-sdk.git
synced 2025-08-23 17:27:25 +00:00
don't make new lbry file if publish is given a full metadata dict, remove update_claim()
This commit is contained in:
parent
cb985b5a03
commit
66ae865de0
1 changed files with 23 additions and 36 deletions
|
@ -1996,21 +1996,29 @@ class LBRYDaemon(jsonrpc.JSONRPC):
|
||||||
Claim txid
|
Claim txid
|
||||||
"""
|
"""
|
||||||
|
|
||||||
name = p['name']
|
|
||||||
try:
|
|
||||||
verify_name_characters(name)
|
|
||||||
except:
|
|
||||||
log.error("Bad name")
|
|
||||||
return defer.fail(InvalidNameError("Bad name"))
|
|
||||||
bid = p['bid']
|
|
||||||
file_path = p['file_path']
|
|
||||||
metadata = p['metadata']
|
|
||||||
|
|
||||||
def _set_address(address, currency):
|
def _set_address(address, currency):
|
||||||
log.info("Generated new address for key fee: " + str(address))
|
log.info("Generated new address for key fee: " + str(address))
|
||||||
metadata['fee'][currency]['address'] = address
|
metadata['fee'][currency]['address'] = address
|
||||||
return defer.succeed(None)
|
return defer.succeed(None)
|
||||||
|
|
||||||
|
name = p['name']
|
||||||
|
|
||||||
|
try:
|
||||||
|
verify_name_characters(name)
|
||||||
|
except AssertionError:
|
||||||
|
log.error("Bad name")
|
||||||
|
return defer.fail(InvalidNameError("Bad name"))
|
||||||
|
|
||||||
|
bid = p['bid']
|
||||||
|
|
||||||
|
try:
|
||||||
|
metadata = Metadata(p['metadata'])
|
||||||
|
make_lbry_file = False
|
||||||
|
except AssertionError:
|
||||||
|
make_lbry_file = True
|
||||||
|
metadata = p['metadata']
|
||||||
|
file_path = p['file_path']
|
||||||
|
|
||||||
if not self.pending_claim_checker.running:
|
if not self.pending_claim_checker.running:
|
||||||
self.pending_claim_checker.start(30)
|
self.pending_claim_checker.start(30)
|
||||||
|
|
||||||
|
@ -2024,9 +2032,11 @@ class LBRYDaemon(jsonrpc.JSONRPC):
|
||||||
if 'address' not in metadata['fee'][c]:
|
if 'address' not in metadata['fee'][c]:
|
||||||
d.addCallback(lambda _: self.session.wallet.get_new_address())
|
d.addCallback(lambda _: self.session.wallet.get_new_address())
|
||||||
d.addCallback(lambda addr: _set_address(addr, c))
|
d.addCallback(lambda addr: _set_address(addr, c))
|
||||||
|
if make_lbry_file:
|
||||||
pub = Publisher(self.session, self.lbry_file_manager, self.session.wallet)
|
pub = Publisher(self.session, self.lbry_file_manager, self.session.wallet)
|
||||||
d.addCallback(lambda _: pub.start(name, file_path, bid, metadata))
|
d.addCallback(lambda _: pub.start(name, file_path, bid, metadata))
|
||||||
|
else:
|
||||||
|
d.addErrback(lambda _: self.session.wallet.claim_name(name, bid, metadata))
|
||||||
d.addCallback(lambda txid: self._add_to_pending_claims(name, txid))
|
d.addCallback(lambda txid: self._add_to_pending_claims(name, txid))
|
||||||
d.addCallback(lambda r: self._render_response(r, OK_CODE))
|
d.addCallback(lambda r: self._render_response(r, OK_CODE))
|
||||||
d.addErrback(lambda err: self._render_response(err.getTraceback(), BAD_REQUEST))
|
d.addErrback(lambda err: self._render_response(err.getTraceback(), BAD_REQUEST))
|
||||||
|
@ -2423,29 +2433,6 @@ class LBRYDaemon(jsonrpc.JSONRPC):
|
||||||
d.addCallback(lambda r: self._render_response(r, OK_CODE))
|
d.addCallback(lambda r: self._render_response(r, OK_CODE))
|
||||||
return d
|
return d
|
||||||
|
|
||||||
def jsonrpc_update_claim(self, p):
|
|
||||||
def _x(r):
|
|
||||||
log.info(str(r))
|
|
||||||
return r
|
|
||||||
|
|
||||||
def _get_metadata_and_txid(old_claim_info):
|
|
||||||
txid = old_claim_info['txid']
|
|
||||||
r = old_claim_info['value'] if isinstance(old_claim_info['value'], dict) else {}
|
|
||||||
for k in metadata:
|
|
||||||
r[k] = metadata[k]
|
|
||||||
return txid, json.dumps(Metadata(r))
|
|
||||||
|
|
||||||
metadata = p['metadata']
|
|
||||||
bid = p['bid']
|
|
||||||
name = p['name']
|
|
||||||
|
|
||||||
d = self.session.wallet.get_claim_info(name, force_good_metadata=False)
|
|
||||||
d.addCallback(_get_metadata_and_txid)
|
|
||||||
d.addCallback(lambda (txid, s): self.session.wallet.update_name(name, txid, s, bid))
|
|
||||||
d.addCallback(_x)
|
|
||||||
d.addCallback(lambda r: self._render_response(r, OK_CODE))
|
|
||||||
return d
|
|
||||||
|
|
||||||
|
|
||||||
def get_lbrynet_version_from_github():
|
def get_lbrynet_version_from_github():
|
||||||
"""Return the latest released version from github."""
|
"""Return the latest released version from github."""
|
||||||
|
|
Loading…
Add table
Reference in a new issue