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

delete lbry file with an abandoned claim

Browse source
This commit is contained in:
Jack 2016-09-14 22:27:57 -04:00
parent 6ea1f6f78c
commit 2b1af8eea2
1 changed files with 9 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
lbrynet/lbryfilemanager/LBRYFileDownloader.py
View file

@ -10,6 +10,9 @@ from lbrynet.lbryfilemanager.LBRYFileStatusReport import LBRYFileStatusReport
from lbrynet.interfaces import IStreamDownloaderFactory from lbrynet.interfaces import IStreamDownloaderFactory
from lbrynet.lbryfile.StreamDescriptor import save_sd_info from lbrynet.lbryfile.StreamDescriptor import save_sd_info
from twisted.internet import defer from twisted.internet import defer
import logging
log = logging.getLogger(__name__)
class ManagedLBRYFileDownloader(LBRYFileSaver): class ManagedLBRYFileDownloader(LBRYFileSaver):
@ -48,11 +51,16 @@ class ManagedLBRYFileDownloader(LBRYFileSaver):
self.claim_id = claim_id self.claim_id = claim_id
return defer.succeed(None) return defer.succeed(None)
def _notify_bad_claim(name, txid):
log.error("Error loading name claim for lbry file: lbry://%s, tx %s does not contain a valid claim", name, txid)
log.warning("lbry file for lbry://%s, tx %s has no claim, deleting it", name, txid)
return self.lbry_file_manager.delete_lbry_file(self)
def _save_claim(name, txid): def _save_claim(name, txid):
self.uri = name self.uri = name
self.txid = txid self.txid = txid
d = self.wallet.get_claimid(name, txid) d = self.wallet.get_claimid(name, txid)
d.addCallback(_save_claim_id) d.addCallbacks(_save_claim_id, lambda err: _notify_bad_claim(name, txid))
return d return d
d.addCallback(_save_sd_hash) d.addCallback(_save_sd_hash)