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

rename update_stream and prevent it from using old metadata

Browse source
This commit is contained in:
Kay Kurokawa 2017-03-30 15:12:07 -04:00
parent d3173b157e
commit 23596b434a
2 changed files with 14 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
lbrynet/lbrynet_daemon/Daemon.py
View file

@ -716,9 +716,9 @@ class Daemon(AuthJSONRPCServer):
if bid <= 0.0: if bid <= 0.0:
raise Exception("Invalid bid") raise Exception("Invalid bid")
if not file_path: if not file_path:
claim_out = yield publisher.update_stream(name, bid, metadata) claim_out = yield publisher.publish_stream(name, bid, metadata)
else: else:
claim_out = yield publisher.publish_stream(name, file_path, bid, metadata) claim_out = yield publisher.create_and_publish_stream(name, bid, metadata, file_path)
if conf.settings['reflect_uploads']: if conf.settings['reflect_uploads']:
d = reupload.reflect_stream(publisher.lbry_file) d = reupload.reflect_stream(publisher.lbry_file)
d.addCallbacks(lambda _: log.info("Reflected new publication to lbry://%s", name), d.addCallbacks(lambda _: log.info("Reflected new publication to lbry://%s", name),

13
lbrynet/lbrynet_daemon/Publisher.py
View file

@ -19,8 +19,11 @@ class Publisher(object):
self.wallet = wallet self.wallet = wallet
self.lbry_file = None self.lbry_file = None
"""
Create lbry file and make claim
"""
@defer.inlineCallbacks @defer.inlineCallbacks
def publish_stream(self, name, file_path, bid, metadata): def create_and_publish_stream(self, name, bid, metadata, file_path):
log.info('Starting publish for %s', name) log.info('Starting publish for %s', name)
file_name = os.path.basename(file_path) file_name = os.path.basename(file_path)
with file_utils.get_read_handle(file_path) as read_handle: with file_utils.get_read_handle(file_path) as read_handle:
@ -41,6 +44,14 @@ class Publisher(object):
yield self.lbry_file.save_status() yield self.lbry_file.save_status()
defer.returnValue(claim_out) defer.returnValue(claim_out)
"""
Make a claim without creating a lbry file
"""
@defer.inlineCallbacks
def publish_stream(self, name, bid, metadata):
claim_out = yield self.make_claim(name, bid, metadata)
defer.returnValue(claim_out)
@defer.inlineCallbacks @defer.inlineCallbacks
def update_stream(self, name, bid, metadata): def update_stream(self, name, bid, metadata):
my_claim = yield self.wallet.get_my_claim(name) my_claim = yield self.wallet.get_my_claim(name)