PublicMirrors/hydra
1
0
Fork 0
mirror of https://github.com/hydralauncher/hydra.git synced 2025-02-02 16:23:48 +03:00
Code Issues Actions 1 Packages Projects Releases 1 Wiki Activity

feat: set libtorrent flags

Browse Source
This commit is contained in:
Zamitto 2024-12-24 00:23:50 -03:00
parent 60e0b39f86
commit 538d3e5982
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
python_rpc/main.py
View File

@ -36,7 +36,7 @@ if start_download_payload:
if start_seeding_payload: if start_seeding_payload:
initial_seeding = json.loads(urllib.parse.unquote(start_seeding_payload)) initial_seeding = json.loads(urllib.parse.unquote(start_seeding_payload))
for seed in initial_seeding: for seed in initial_seeding:
torrent_downloader = TorrentDownloader(torrent_session) torrent_downloader = TorrentDownloader(torrent_session, lt.torrent_flags.upload_mode)
downloads[seed['game_id']] = torrent_downloader downloads[seed['game_id']] = torrent_downloader
torrent_downloader.start_download(seed['url'], seed['save_path'], "") torrent_downloader.start_download(seed['url'], seed['save_path'], "")
@ -156,7 +156,7 @@ def action():
if downloader: if downloader:
downloader.cancel_download() downloader.cancel_download()
elif action == 'resume_seeding': elif action == 'resume_seeding':
torrent_downloader = TorrentDownloader(torrent_session) torrent_downloader = TorrentDownloader(torrent_session, lt.torrent_flags.upload_mode)
downloads[game_id] = torrent_downloader downloads[game_id] = torrent_downloader
torrent_downloader.start_download(data['url'], data['save_path'], "") torrent_downloader.start_download(data['url'], data['save_path'], "")
elif action == 'pause_seeding': elif action == 'pause_seeding':

6
python_rpc/torrent_downloader.py
View File

@ -1,9 +1,10 @@
import libtorrent as lt import libtorrent as lt
class TorrentDownloader: class TorrentDownloader:
def __init__(self, torrent_session): def __init__(self, torrent_session, flags = lt.torrent_flags.auto_managed):
self.torrent_handle = None self.torrent_handle = None
self.session = torrent_session self.session = torrent_session
self.flags = flags
self.trackers = [ self.trackers = [
"udp://tracker.opentrackr.org:1337/announce", "udp://tracker.opentrackr.org:1337/announce",
"http://tracker.opentrackr.org:1337/announce", "http://tracker.opentrackr.org:1337/announce",
@ -102,9 +103,8 @@ class TorrentDownloader:
] ]
def start_download(self, magnet: str, save_path: str, header: str): def start_download(self, magnet: str, save_path: str, header: str):
params = {'url': magnet, 'save_path': save_path, 'trackers': self.trackers} params = {'url': magnet, 'save_path': save_path, 'trackers': self.trackers, 'flags': self.flags}
self.torrent_handle = self.session.add_torrent(params) self.torrent_handle = self.session.add_torrent(params)
self.torrent_handle.set_flags(lt.torrent_flags.auto_managed)
self.torrent_handle.resume() self.torrent_handle.resume()
def pause_download(self): def pause_download(self):