mirror of
https://github.com/KeksPirates/SoftwareManager.git
synced 2026-08-03 17:39:42 +02:00
Vxrtrauter
101 lines
2.3 KiB
Python
101 lines
2.3 KiB
Python
import time
|
|
from core.utils.general.wrappers import run_thread
|
|
import threading
|
|
import libtorrent as lt
|
|
from core.utils.data.state import state
|
|
from core.utils.general.logs import consoleLog
|
|
|
|
|
|
global loop_running
|
|
loop_running = False
|
|
|
|
def init_session():
|
|
if state.dl_session is not None:
|
|
return
|
|
|
|
state.dl_session = lt.session()
|
|
|
|
settings = {
|
|
"upload_rate_limit": 0,
|
|
"download_rate_limit": 0,
|
|
"enable_dht": True,
|
|
"enable_lsd": True,
|
|
"enable_upnp": True,
|
|
"enable_natpmp": True,
|
|
"dht_bootstrap_nodes": "router.bittorrent.com:6881,dht.transmissionbt.com:6881",
|
|
"connections_limit": 200,
|
|
"active_downloads": 10
|
|
}
|
|
|
|
|
|
|
|
state.dl_session.apply_settings(settings)
|
|
|
|
consoleLog("Initialized Session")
|
|
|
|
|
|
def add_download(magnet_uri, dl_path=state.download_path):
|
|
|
|
if state.active_downloads is None:
|
|
state.active_downloads = {}
|
|
|
|
init_session()
|
|
|
|
if magnet_uri in state.active_downloads:
|
|
consoleLog("Skipping, download already running...")
|
|
return
|
|
|
|
consoleLog(f"Adding {magnet_uri} to downloads...")
|
|
|
|
magnetdl = lt.parse_magnet_uri(magnet_uri)
|
|
magnetdl.save_path = dl_path
|
|
|
|
consoleLog(f"Download Path: {dl_path}")
|
|
|
|
download = state.dl_session.add_torrent(magnetdl)
|
|
state.active_downloads[magnet_uri] = download
|
|
consoleLog("added download")
|
|
|
|
run_thread(threading.Thread(target=dl_status_loop))
|
|
|
|
|
|
|
|
def dl_status_loop():
|
|
global loop_running
|
|
|
|
if loop_running == True:
|
|
return
|
|
|
|
loop_running = True
|
|
completed = []
|
|
|
|
if not state.active_downloads:
|
|
consoleLog("No active downloads")
|
|
return
|
|
|
|
while state.active_downloads:
|
|
completed.clear()
|
|
|
|
for magnet_uri, magnetdl in list(state.active_downloads.items()):
|
|
status = magnetdl.status()
|
|
|
|
if status.state == lt.torrent_status.seeding:
|
|
completed.append(magnet_uri)
|
|
consoleLog(f"Download completed: {status.name}")
|
|
continue
|
|
|
|
for magnet_uri in completed:
|
|
magnetdl = state.active_downloads[magnet_uri]
|
|
state.dl_session.remove_torrent(magnetdl)
|
|
del state.active_downloads[magnet_uri]
|
|
|
|
if not state.active_downloads:
|
|
loop_running = False
|
|
break
|
|
|
|
time.sleep(1)
|
|
|
|
|
|
|
|
|