x/solar
Code Issues Proposed changes

torrent transport resource improvements

Browse Source
This commit is contained in:
Jedrzej Nowak 2015-10-08 12:10:33 +02:00
parent d430097f1c
commit d45d026565
3 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
resources/transport_torrent/meta.yaml
View File

@ -1,5 +1,9 @@
id: transport_torrent
handler: ansible
input:
trackers:
schema: [str!]
value: []
name:
schema: str!
value: torrent

2
resources/transports/meta.yaml
View File

@ -1,7 +1,7 @@
id: transports
input:
transports:
schema: [{user: str, password: str, port: int!, key: str, name: str!}]
schema: [{user: str, password: str, port: int!, key: str, name: str!, trackers: [str]}]
value: []
transports_id:
schema: str!

8
solar/solar/core/transports/torrent.py
View File

@ -64,15 +64,15 @@ class TorrentSyncTransport(SyncTransport):
params=(_from, _to, use_sudo))
self.executors.append(executor)
def _create_single_torrent(self, _from, _to, use_sudo):
def _create_single_torrent(self, resource, _from, _to, use_sudo):
fs = lt.file_storage()
lt.add_files(fs, _from)
self._create_torrent(fs, _from)
self._create_torrent(resource, fs, _from)
def _create_torrent_name(self):
return os.path.join(self._torrent_path, uuid4().hex + '.torrent')
def _create_torrent(self, fs, root='.', use_sudo=False):
def _create_torrent(self, resource, fs, root='.', use_sudo=False):
t = lt.create_torrent(fs)
for tracker in TRACKERS:
t.add_tracker(tracker)
@ -124,7 +124,7 @@ class TorrentSyncTransport(SyncTransport):
def preprocess(self, executor):
_from, _to, use_sudo = executor.params
self._create_single_torrent(_from, _to, use_sudo)
self._create_single_torrent(executor.resource, _from, _to, use_sudo)
def run_all(self):
self._start_seeding()