spacing after comma fix, use Exception init in InvalidStreamInfoError
This commit is contained in:
parent
39b47bc569
commit
7dd5e7ceeb
3 changed files with 5 additions and 6 deletions
|
@ -54,12 +54,11 @@ class InvalidStreamDescriptorError(Exception):
|
||||||
|
|
||||||
class InvalidStreamInfoError(Exception):
|
class InvalidStreamInfoError(Exception):
|
||||||
def __init__(self, name, stream_info):
|
def __init__(self, name, stream_info):
|
||||||
|
msg = '{} has claim with invalid stream info: {}'.format(name, stream_info)
|
||||||
|
Exception.__init__(self, msg)
|
||||||
self.name = name
|
self.name = name
|
||||||
self.stream_info = stream_info
|
self.stream_info = stream_info
|
||||||
|
|
||||||
def __str__(self):
|
|
||||||
return '{} has claim with invalid stream info: {}'.format(self.name,self.stream_info)
|
|
||||||
|
|
||||||
|
|
||||||
class MisbehavingPeerError(Exception):
|
class MisbehavingPeerError(Exception):
|
||||||
pass
|
pass
|
||||||
|
|
|
@ -344,7 +344,7 @@ class Wallet(object):
|
||||||
|
|
||||||
try:
|
try:
|
||||||
metadata = Metadata(json.loads(result['value']))
|
metadata = Metadata(json.loads(result['value']))
|
||||||
except (TypeError,ValueError,ValidationError):
|
except (TypeError, ValueError, ValidationError):
|
||||||
return Failure(InvalidStreamInfoError(name,result['value']))
|
return Failure(InvalidStreamInfoError(name,result['value']))
|
||||||
|
|
||||||
txid = result['txid']
|
txid = result['txid']
|
||||||
|
@ -427,7 +427,7 @@ class Wallet(object):
|
||||||
meta_ver = metadata.version
|
meta_ver = metadata.version
|
||||||
sd_hash = metadata['sources']['lbry_sd_hash']
|
sd_hash = metadata['sources']['lbry_sd_hash']
|
||||||
d = self._save_name_metadata(name, txid, sd_hash)
|
d = self._save_name_metadata(name, txid, sd_hash)
|
||||||
except (TypeError,ValueError,ValidationError):
|
except (TypeError, ValueError, ValidationError):
|
||||||
metadata = claim['value']
|
metadata = claim['value']
|
||||||
meta_ver = "Non-compliant"
|
meta_ver = "Non-compliant"
|
||||||
d = defer.succeed(None)
|
d = defer.succeed(None)
|
||||||
|
|
|
@ -900,7 +900,7 @@ class AddStreamFromLBRYcrdName(AddStreamFromHash):
|
||||||
def _resolve_name(self, name):
|
def _resolve_name(self, name):
|
||||||
def get_name_from_info(stream_info):
|
def get_name_from_info(stream_info):
|
||||||
if 'stream_hash' not in stream_info:
|
if 'stream_hash' not in stream_info:
|
||||||
raise InvalidStreamInfoError(name,stream_info)
|
raise InvalidStreamInfoError(name, stream_info)
|
||||||
self.resolved_name = stream_info.get('name', None)
|
self.resolved_name = stream_info.get('name', None)
|
||||||
self.description = stream_info.get('description', None)
|
self.description = stream_info.get('description', None)
|
||||||
try:
|
try:
|
||||||
|
|
Loading…
Reference in a new issue