diff --git a/lbrynet/daemon/Publisher.py b/lbrynet/daemon/Publisher.py index 01ed7a065..f4e6e5501 100644 --- a/lbrynet/daemon/Publisher.py +++ b/lbrynet/daemon/Publisher.py @@ -34,10 +34,9 @@ class Publisher(object): with file_utils.get_read_handle(file_path) as read_handle: stream_hash = yield create_lbry_file(self.session, self.lbry_file_manager, file_name, read_handle) - prm = self.session.payment_rate_manager sd_hash = yield publish_sd_blob(self.lbry_file_manager.stream_info_manager, self.session.blob_manager, stream_hash) - self.lbry_file = yield self.lbry_file_manager.add_lbry_file(stream_hash, prm) + self.lbry_file = yield self.lbry_file_manager.add_lbry_file(stream_hash) if 'source' not in claim_dict['stream']: claim_dict['stream']['source'] = {} claim_dict['stream']['source']['source'] = sd_hash diff --git a/lbrynet/file_manager/EncryptedFileManager.py b/lbrynet/file_manager/EncryptedFileManager.py index fd96aa8f0..517e33f12 100644 --- a/lbrynet/file_manager/EncryptedFileManager.py +++ b/lbrynet/file_manager/EncryptedFileManager.py @@ -183,8 +183,10 @@ class EncryptedFileManager(object): yield self._stop_lbry_file(lbry_file) @defer.inlineCallbacks - def add_lbry_file(self, stream_hash, payment_rate_manager, blob_data_rate=None, + def add_lbry_file(self, stream_hash, payment_rate_manager=None, blob_data_rate=None, download_directory=None, file_name=None): + if not payment_rate_manager: + payment_rate_manager = self.sesion.payment_rate_manager rowid = yield self._save_lbry_file(stream_hash, blob_data_rate) lbry_file = yield self.start_lbry_file(rowid, stream_hash, payment_rate_manager, blob_data_rate, download_directory,