stevazi/addon
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 3 Wiki Activity

initial background downloader support

Browse Source
This commit is contained in:
marco
2019-06-17 19:56:36 +02:00
parent deb0f20ecd
commit df94b062da
2 changed files with 15 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core/downloader.py
+3 -6
View File
@@ -102,9 +102,9 @@ class Downloader(object):
# Funciones # Funciones
def start_dialog(self, title=config.get_localized_string(60200)): def start_dialog(self, title=config.get_localized_string(60200)):
from platformcode import platformtools from platformcode import platformtools
progreso = platformtools.dialog_progress(title, config.get_localized_string(60201)) progreso = platformtools.dialog_progress_bg(title, config.get_localized_string(60201))
self.start() self.start()
while self.state == self.states.downloading and not progreso.iscanceled(): while self.state == self.states.downloading:
time.sleep(0.1) time.sleep(0.1)
line1 = "%s" % (self.filename) line1 = "%s" % (self.filename)
line2 = config.get_localized_string(59983) % ( line2 = config.get_localized_string(59983) % (
@@ -112,10 +112,7 @@ class Downloader(object):
self.speed[1], self.speed[2], self.connections[0], self.connections[1]) self.speed[1], self.speed[2], self.connections[0], self.connections[1])
line3 = config.get_localized_string(60202) % (self.remaining_time) line3 = config.get_localized_string(60202) % (self.remaining_time)
progreso.update(int(self.progress), line1, line2, line3) progreso.update(int(self.progress), line1, line2 + line3)
if self.state == self.states.downloading:
self.stop()
progreso.close()
def start(self): def start(self):
if self._state == self.states.error: return if self._state == self.states.error: return
specials/downloads.py
+6 -3
View File
@@ -14,6 +14,7 @@ from past.utils import old_div
import re import re
import time import time
import unicodedata import unicodedata
from threading import Thread
from core import filetools, jsontools, scraper, scrapertools, servertools, videolibrarytools, support from core import filetools, jsontools, scraper, scrapertools, servertools, videolibrarytools, support
@@ -21,6 +22,7 @@ from core.downloader import Downloader
from core.item import Item from core.item import Item
from platformcode import config, logger from platformcode import config, logger
from platformcode import platformtools from platformcode import platformtools
from platformcode.launcher import downloaderObj
STATUS_COLORS = {0: "orange", 1: "orange", 2: "green", 3: "red"} STATUS_COLORS = {0: "orange", 1: "orange", 2: "green", 3: "red"}
STATUS_CODES = type("StatusCode", (), {"stoped": 0, "canceled": 1, "completed": 2, "error": 3}) STATUS_CODES = type("StatusCode", (), {"stoped": 0, "canceled": 1, "completed": 2, "error": 3})
@@ -262,7 +264,8 @@ def menu(item):
# Opcion inicaiar descarga # Opcion inicaiar descarga
if opciones[seleccion] == op[0]: if opciones[seleccion] == op[0]:
start_download(item) th = Thread(target=start_download, args=(item,))
th.start()
# Elegir Servidor # Elegir Servidor
if opciones[seleccion] == op[3]: if opciones[seleccion] == op[3]:
@@ -733,14 +736,14 @@ def start_download(item):
def get_episodes(item): def get_episodes(item):
logger.info("contentAction: %s | contentChannel: %s | contentType: %s" % (item.contentAction, item.contentChannel, item.contentType)) logger.info("contentAction: %s | contentChannel: %s | contentType: %s" % (
item.contentAction, item.contentChannel, item.contentType))
if 'dlseason' in item: if 'dlseason' in item:
season = True season = True
season_number = item.dlseason season_number = item.dlseason
else: else:
season = False season = False
# El item que pretendemos descargar YA es un episodio # El item que pretendemos descargar YA es un episodio
if item.contentType == "episode": if item.contentType == "episode":
episodes = [item.clone()] episodes = [item.clone()]