summaryrefslogtreecommitdiffstats
path: root/deluge/core/core.py
diff options
context:
space:
mode:
authorCalum Lind <calumlind@gmail.com>2018-06-01 15:35:19 +0100
committerCalum Lind <calumlind@gmail.com>2018-06-01 23:41:17 +0100
commitd642fa398924913c04eea3c2ddb769a4a6857fc3 (patch)
tree420c6e4d20b5550d1fc2ac2586968df4bf407ac6 /deluge/core/core.py
parentbae1647e99e68244607e50633ca67a8c5b16ebfb (diff)
downloaddeluge-d642fa398924913c04eea3c2ddb769a4a6857fc3.tar.gz
deluge-d642fa398924913c04eea3c2ddb769a4a6857fc3.tar.bz2
deluge-d642fa398924913c04eea3c2ddb769a4a6857fc3.zip
Fix files to pass new Flake8 checkers
Some new flake8 checkers were added so fix these new warnings and any issues uncovered. Use add-trailing-comma to fix missing trailing commas. It does not format it as well as I would like however it was fast to change and helps with git changes in future. Removed pylint from tox due to large number of warnings.
Diffstat (limited to 'deluge/core/core.py')
-rw-r--r--deluge/core/core.py71
1 files changed, 43 insertions, 28 deletions
diff --git a/deluge/core/core.py b/deluge/core/core.py
index 10861c631..80c14f6a2 100644
--- a/deluge/core/core.py
+++ b/deluge/core/core.py
@@ -109,7 +109,8 @@ class Core(component.Component):
peer_id = self._create_peer_id(DELUGE_VER)
log.debug(
'Starting session (peer_id: %s, user_agent: %s)',
- peer_id, user_agent)
+ peer_id, user_agent,
+ )
settings_pack = {
'peer_fingerprint': peer_id,
'user_agent': user_agent,
@@ -390,7 +391,7 @@ class Core(component.Component):
try:
d = self.torrentmanager.add_async(
- filedump=filedump, options=options, filename=filename, save_state=save_state
+ filedump=filedump, options=options, filename=filename, save_state=save_state,
)
except RuntimeError as ex:
log.error('There was an error adding the torrent file %s: %s', filename, ex)
@@ -418,7 +419,8 @@ class Core(component.Component):
try:
return self.torrentmanager.add(
- filedump=filedump, options=options, filename=filename)
+ filedump=filedump, options=options, filename=filename,
+ )
except RuntimeError as ex:
log.error('There was an error adding the torrent file %s: %s', filename, ex)
raise
@@ -441,7 +443,8 @@ class Core(component.Component):
for idx, torrent in enumerate(torrent_files):
try:
yield self.add_torrent_file_async(
- torrent[0], torrent[1], torrent[2], save_state=idx == last_index)
+ torrent[0], torrent[1], torrent[2], save_state=idx == last_index,
+ )
except AddTorrentError as ex:
log.warn('Error when adding torrent: %s', ex)
errors.append(ex)
@@ -651,8 +654,10 @@ class Core(component.Component):
@export
def get_torrent_status(self, torrent_id, keys, diff=False):
torrent_keys, plugin_keys = self.torrentmanager.separate_keys(keys, [torrent_id])
- return self.create_torrent_status(torrent_id, torrent_keys, plugin_keys, diff=diff, update=True,
- all_keys=not keys)
+ return self.create_torrent_status(
+ torrent_id, torrent_keys, plugin_keys, diff=diff, update=True,
+ all_keys=not keys,
+ )
@export
def get_torrents_status(self, filter_dict, keys, diff=False):
@@ -699,7 +704,7 @@ class Core(component.Component):
@export
def get_config_values(self, keys):
"""Get the config values for the entered keys"""
- return dict((key, self.config.get(key)) for key in keys)
+ return {key: self.config.get(key) for key in keys}
@export
def set_config(self, config):
@@ -740,7 +745,7 @@ class Core(component.Component):
'port': proxy_port,
'proxy_hostnames': settings['proxy_hostnames'],
'proxy_peer_connections': settings['proxy_peer_connections'],
- 'proxy_tracker_connections': settings['proxy_tracker_connections']
+ 'proxy_tracker_connections': settings['proxy_tracker_connections'],
}
return proxy_dict
@@ -870,25 +875,32 @@ class Core(component.Component):
return deluge.common.get_path_size(path)
@export
- def create_torrent(self, path, tracker, piece_length, comment, target,
- webseeds, private, created_by, trackers, add_to_session):
+ def create_torrent(
+ self, path, tracker, piece_length, comment, target,
+ webseeds, private, created_by, trackers, add_to_session,
+ ):
log.debug('creating torrent..')
- threading.Thread(target=self._create_torrent_thread,
- args=(
- path,
- tracker,
- piece_length,
- comment,
- target,
- webseeds,
- private,
- created_by,
- trackers,
- add_to_session)).start()
-
- def _create_torrent_thread(self, path, tracker, piece_length, comment, target,
- webseeds, private, created_by, trackers, add_to_session):
+ threading.Thread(
+ target=self._create_torrent_thread,
+ args=(
+ path,
+ tracker,
+ piece_length,
+ comment,
+ target,
+ webseeds,
+ private,
+ created_by,
+ trackers,
+ add_to_session,
+ ),
+ ).start()
+
+ def _create_torrent_thread(
+ self, path, tracker, piece_length, comment, target,
+ webseeds, private, created_by, trackers, add_to_session,
+ ):
from deluge import metafile
metafile.make_meta_file(
path,
@@ -899,7 +911,8 @@ class Core(component.Component):
webseeds=webseeds,
private=private,
created_by=created_by,
- trackers=trackers)
+ trackers=trackers,
+ )
log.debug('torrent created!')
if add_to_session:
options = {}
@@ -1055,8 +1068,10 @@ class Core(component.Component):
:rtype: bool
"""
- d = getPage(b'http://deluge-torrent.org/test_port.php?port=%s' %
- self.get_listen_port(), timeout=30)
+ d = getPage(
+ b'http://deluge-torrent.org/test_port.php?port=%s' %
+ self.get_listen_port(), timeout=30,
+ )
def on_get_page(result):
return bool(int(result))