ukamnya
/
plugin.video.torrenter
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

watched history

pull/15/head
DiMartinoXBMC 2016-12-11 01:13:58 +03:00
parent 12f1127b49
commit cd830f1667
5 changed files with 251 additions and 107 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
Core.py
View File

@ -523,7 +523,7 @@ class Core:
self.__settings__.setSetting("lastTorrent", path) self.__settings__.setSetting("lastTorrent", path)
xbmc.executebuiltin( xbmc.executebuiltin(
'XBMC.ActivateWindow(%s)' % 'Videos,plugin://plugin.video.torrenter/?action=%s&url=%s' 'XBMC.ActivateWindow(%s)' % 'Videos,plugin://plugin.video.torrenter/?action=%s&url=%s'
% ('torrentPlayer', path)) % ('torrentPlayer', path.encode('utf-8')))
if action2 == 'playnoseek' or action2 == 'playwithseek': if action2 == 'playnoseek' or action2 == 'playwithseek':
filename, path, url, seek, length, ind = db.get('filename, path, url, seek, length, ind', 'addtime', str(addtime)) filename, path, url, seek, length, ind = db.get('filename, path, url, seek, length, ind', 'addtime', str(addtime))
@ -1837,7 +1837,6 @@ class Core:
int(self.__settings__.getSetting("download_limit")) * 1000000 / 8) #MBits/second int(self.__settings__.getSetting("download_limit")) * 1000000 / 8) #MBits/second
torrent.downloadProcess(ind, encryption) torrent.downloadProcess(ind, encryption)
showMessage(self.localize('Download Status'), self.localize('Added!')) showMessage(self.localize('Download Status'), self.localize('Added!'))
xbmcplugin.endOfDirectory(handle=int(sys.argv[1]), succeeded=True)
def titleMake(self, seeds, leechers, size, title): def titleMake(self, seeds, leechers, size, title):

4
Localization.py
View File

@ -809,6 +809,8 @@ def localize(text):
'Play (from start)':'Lejátszás (az elejétől)', 'Play (from start)':'Lejátszás (az elejétől)',
}, },
'ru': { 'ru': {
'Clear History': 'Очистить Историю',
'Play (with seek)': 'Играть (перемотка)',
'Mass Control':'Массовое Управление', 'Mass Control':'Массовое Управление',
'Info':'Инфо', 'Info':'Инфо',
'Delete torrent with files?':'Вы уверены, что хотите удалить торрент с файлами?', 'Delete torrent with files?':'Вы уверены, что хотите удалить торрент с файлами?',
@ -900,7 +902,7 @@ def localize(text):
'Checking preloaded files...': 'Проверка файлов...', 'Checking preloaded files...': 'Проверка файлов...',
'Waiting for website response...': 'Ожидание ответа сайта...', 'Waiting for website response...': 'Ожидание ответа сайта...',
'Search and cache information for:': 'Поиск и кэширование информации для:', 'Search and cache information for:': 'Поиск и кэширование информации для:',
'Open Torrent': 'Открыть Список файлов', 'Open Torrent': 'Открыть Торрент',
'Torrent list is empty.': 'Список раздач пуст.', 'Torrent list is empty.': 'Список раздач пуст.',
'Content Lists': 'Списки Медиа', 'Content Lists': 'Списки Медиа',
'Canceled by User': 'Отменено пользователем', 'Canceled by User': 'Отменено пользователем',

19
SkorbaLoader.py
View File

@ -32,7 +32,7 @@ import xbmcgui
import xbmcvfs import xbmcvfs
import Localization import Localization
from functions import isSubtitle, DownloadDB, log, debug, is_writable,\ from functions import isSubtitle, DownloadDB, log, debug, is_writable,\
vista_check, windows_check, localize_path vista_check, windows_check, localize_path, decode_str
class SkorbaLoader: class SkorbaLoader:
magnetLink = None magnetLink = None
@ -127,7 +127,7 @@ class SkorbaLoader:
return return
if not xbmcvfs.exists(self.torrentFilesPath): if not xbmcvfs.exists(self.torrentFilesPath):
xbmcvfs.mkdirs(self.torrentFilesPath) xbmcvfs.mkdirs(self.torrentFilesPath)
newFile = self.torrentFilesPath + self.md5(torrentUrl) + '.torrent' newFile = localize_path(self.torrentFilesPath + self.md5(torrentUrl) + '.torrent')
if newFile != torrentFile: if newFile != torrentFile:
if xbmcvfs.exists(newFile): if xbmcvfs.exists(newFile):
xbmcvfs.delete(newFile) xbmcvfs.delete(newFile)
@ -285,12 +285,12 @@ class SkorbaLoader:
if len(ContentList) == 1 or contentId not in [None, -1]: if len(ContentList) == 1 or contentId not in [None, -1]:
if not contentId: contentId = 0 if not contentId: contentId = 0
title = os.path.basename(ContentList[contentId]['title']) title = os.path.basename(ContentList[contentId]['title'])
path = os.path.join(self.storageDirectory, localize_path(ContentList[contentId]['title'])) path = localize_path(os.path.join(self.storageDirectory, ContentList[contentId]['title']))
type = 'file' type = 'file'
else: else:
contentId = -1 contentId = -1
title = ContentList[0]['title'].split('\\')[0] title = ContentList[0]['title'].split('\\')[0]
path = os.path.join(self.storageDirectory, title) path = localize_path(os.path.join(self.storageDirectory, title))
type = 'folder' type = 'folder'
add = db.add(title, path, type, {'progress': 0}, 'downloading', self.torrentFile, contentId, add = db.add(title, path, type, {'progress': 0}, 'downloading', self.torrentFile, contentId,
@ -307,11 +307,18 @@ class SkorbaLoader:
thread.start_new_thread(self.downloadLoop, (title,)) thread.start_new_thread(self.downloadLoop, (title,))
def downloadLoop(self, title): def downloadLoop(self, title):
log(title)
db = DownloadDB() db = DownloadDB()
status = 'downloading' status = 'downloading'
while db.get(title) and status != 'stopped': while db.get(title) and status != 'stopped':
xbmc.sleep(3000) xbmc.sleep(3000)
log('status 1 '+status)
status = db.get_status(title) status = db.get_status(title)
log('status 2 ' + status)
if status == 'stopped':
xbmc.sleep(10000)
status = db.get_status(title)
log('status 3 ' + status)
if not self.paused: if not self.paused:
if status == 'pause': if status == 'pause':
self.paused = True self.paused = True
@ -329,7 +336,9 @@ class SkorbaLoader:
iterator = int(s.progress * 100) iterator = int(s.progress * 100)
info['progress'] = iterator info['progress'] = iterator
db.update(title, info) db.update(title, info)
#self.debug() log(title+str(info))
self.debug()
log('out of downloadLoop')
self.session.remove_torrent(self.torrentHandle) self.session.remove_torrent(self.torrentHandle)
return return

BIN
icons/searchwindow/button.psd
View File

Binary file not shown.

332
searchwindow.py
View File

@ -68,7 +68,8 @@ class SearchWindow(pyxbmct.AddonDialogWindow):
self.search(s_param=s_param) self.search(s_param=s_param)
else: else:
if __settings__.getSetting('debug') == 'true': if __settings__.getSetting('debug') == 'true':
self.downloadstatus() #self.downloadstatus()
self.watched()
else: else:
self.history() self.history()
@ -82,23 +83,26 @@ class SearchWindow(pyxbmct.AddonDialogWindow):
self.button_downloadstatus = pyxbmct.Button("OFF", textColor='0xFF0000FF', self.button_downloadstatus = pyxbmct.Button("OFF", textColor='0xFF0000FF',
focusTexture=self.icon % 'fdownloadstatus', focusTexture=self.icon % 'fdownloadstatus',
noFocusTexture=self.icon % 'nfdownloadstatus') noFocusTexture=self.icon % 'nfdownloadstatus')
self.placeControl(self.button_downloadstatus, 0, 2, 1, 1) self.placeControl(self.button_downloadstatus, 0, 1, 1, 1)
self.button_torrentclient = pyxbmct.Button("", self.button_torrentclient = pyxbmct.Button("",
focusTexture=self.icon_tc % 'f', focusTexture=self.icon_tc % 'f',
noFocusTexture=self.icon_tc % 'nf') noFocusTexture=self.icon_tc % 'nf')
self.placeControl(self.button_torrentclient, 0, 3, 1, 1) self.placeControl(self.button_torrentclient, 0, 2, 1, 1)
self.button_keyboard = pyxbmct.Button("", focusTexture=self.icon % 'fkeyboard', self.button_keyboard = pyxbmct.Button("", focusTexture=self.icon % 'fkeyboard',
noFocusTexture=self.icon % 'nfkeyboard') noFocusTexture=self.icon % 'nfkeyboard')
self.placeControl(self.button_keyboard, 0, 4, 1, 1) self.placeControl(self.button_keyboard, 0, 3, 1, 1)
self.input_search = pyxbmct.Edit("", _alignment=pyxbmct.ALIGN_CENTER_X | pyxbmct.ALIGN_CENTER_Y) self.input_search = pyxbmct.Edit("", _alignment=pyxbmct.ALIGN_CENTER_X | pyxbmct.ALIGN_CENTER_Y)
self.placeControl(self.input_search, 0, 5, 1, 5) self.placeControl(self.input_search, 0, 4, 1, 5)
self.button_search = pyxbmct.Button("", focusTexture=self.icon % 'fsearch', self.button_search = pyxbmct.Button("", focusTexture=self.icon % 'fsearch',
noFocusTexture=self.icon % 'nfsearch') noFocusTexture=self.icon % 'nfsearch')
self.placeControl(self.button_search, 0, 10, 1, 1) self.placeControl(self.button_search, 0, 9, 1, 1)
self.button_history = pyxbmct.Button("", focusTexture=self.icon % 'fhistory', self.button_history = pyxbmct.Button("", focusTexture=self.icon % 'fhistory',
noFocusTexture=self.icon % 'nfhistory') noFocusTexture=self.icon % 'nfhistory')
self.placeControl(self.button_history, 0, 11, 1, 1) self.placeControl(self.button_history, 0, 10, 1, 1)
self.button_watched = pyxbmct.Button("", focusTexture=self.icon % 'fwatched',
noFocusTexture=self.icon % 'nfwatched')
self.placeControl(self.button_watched, 0, 11, 1, 1)
self.button_controlcenter = pyxbmct.Button("", focusTexture=self.icon % 'fcontrolcenter', self.button_controlcenter = pyxbmct.Button("", focusTexture=self.icon % 'fcontrolcenter',
noFocusTexture=self.icon % 'nfcontrolcenter') noFocusTexture=self.icon % 'nfcontrolcenter')
self.placeControl(self.button_controlcenter, 0, 12, 1, 1) self.placeControl(self.button_controlcenter, 0, 12, 1, 1)
@ -118,6 +122,7 @@ class SearchWindow(pyxbmct.AddonDialogWindow):
self.connect(self.button_controlcenter, self.controlCenter) self.connect(self.button_controlcenter, self.controlCenter)
self.connect(self.button_torrentclient, self.browser) self.connect(self.button_torrentclient, self.browser)
self.connect(self.button_downloadstatus, self.downloadstatus) self.connect(self.button_downloadstatus, self.downloadstatus)
self.connect(self.button_watched, self.watched)
self.connect(pyxbmct.ACTION_NAV_BACK, self.close) self.connect(pyxbmct.ACTION_NAV_BACK, self.close)
self.connect(pyxbmct.ACTION_PREVIOUS_MENU, self.close) self.connect(pyxbmct.ACTION_PREVIOUS_MENU, self.close)
@ -139,8 +144,9 @@ class SearchWindow(pyxbmct.AddonDialogWindow):
self.button_keyboard.setNavigation(self.listing, self.listing, self.button_torrentclient, self.input_search) self.button_keyboard.setNavigation(self.listing, self.listing, self.button_torrentclient, self.input_search)
self.input_search.setNavigation(self.listing, self.listing, self.button_keyboard, self.button_search) self.input_search.setNavigation(self.listing, self.listing, self.button_keyboard, self.button_search)
self.button_search.setNavigation(self.listing, self.listing, self.input_search, self.button_history) self.button_search.setNavigation(self.listing, self.listing, self.input_search, self.button_history)
self.button_history.setNavigation(self.listing, self.listing, self.button_search, self.button_controlcenter) self.button_history.setNavigation(self.listing, self.listing, self.button_search, self.button_watched)
self.button_controlcenter.setNavigation(self.listing, self.listing, self.button_history, self.last_right_button) self.button_watched.setNavigation(self.listing, self.listing, self.button_history, self.button_controlcenter)
self.button_controlcenter.setNavigation(self.listing, self.listing, self.button_watched, self.last_right_button)
# Main # Main
self.listing.setNavigation(self.input_search, self.input_search, self.button_downloadstatus, self.listing.setNavigation(self.input_search, self.input_search, self.button_downloadstatus,
@ -242,6 +248,73 @@ class SearchWindow(pyxbmct.AddonDialogWindow):
self.history() self.history()
def watched(self):
self.right_menu('watched')
self.listing.reset()
self.reconnect(pyxbmct.ACTION_NAV_BACK, self.history)
db = WatchedHistoryDB()
items = db.get_all()
log('[WatchedHistory]: items - '+str(items))
if items:
ListString = 'XBMC.RunPlugin(%s)' % (sys.argv[0] + '?action=%s&action2=%s&%s=%s')
for addtime, filename, foldername, path, url, seek, length, ind, size in items:
seek = int(seek) if int(seek) > 3*60 else 0
watchedPercent = int((float(seek) / float(length)) * 100)
duration = '%02d:%02d:%02d' % ((length / (60*60)), (length / 60) % 60, length % 60)
title = '[%d%%][%s] %s [%d MB]' %\
(watchedPercent, duration, filename.encode('utf-8'), int(size))
clDimgray = '[COLOR FF696969]%s[/COLOR]'
clWhite = '[COLOR FFFFFFFF]%s[/COLOR]'
title = clWhite % title + chr(10) + clDimgray % '(%s)' % foldername.encode('utf-8')
if watchedPercent >= 85:
img = __root__ + '/icons/stop-icon.png'
else:
img = __root__ + '/icons/pause-icon.png'
link = {'mode': 'watched_item', 'addtime': str(addtime)}
self.drawItem(title, link, image=img)
def watched_action(self, action, addtime):
db = WatchedHistoryDB()
if action == 'delete':
db.delete(addtime)
showMessage(self.localize('Watched History'), self.localize('Deleted!'))
self.watched()
if action == 'open':
filename, foldername, path, url, seek, length, ind = db.get('filename, foldername, path, url, seek, length, ind', 'addtime', str(addtime))
self.reconnect(pyxbmct.ACTION_NAV_BACK, self.watched)
self.open_torrent(path.encode('utf-8'))
if action == 'playnoseek' or action == 'playwithseek':
filename, path, url, seek, length, ind = db.get('filename, path, url, seek, length, ind', 'addtime', str(addtime))
if action == 'playwithseek':
seek = int(seek)
else:
seek = 0
if os.path.exists(path):
__settings__.setSetting("lastTorrent", path)
else:
from Downloader import Downloader
torrent = Downloader.Torrent(self.userStorageDirectory, torrentFilesDirectory=self.torrentFilesDirectory)
__settings__.setSetting("lastTorrent", torrent.saveTorrent(url))
xbmc.executebuiltin('xbmc.RunPlugin("plugin://plugin.video.torrenter/?action=playTorrent&url='+str(ind)+'&seek='+str(seek)+'")')
self.close()
if action == 'clear':
db.clear()
showMessage(self.localize('Watched History'), self.localize('Clear!'))
self.watched()
def browser(self, hash = None, tdir = None): def browser(self, hash = None, tdir = None):
from resources.utorrent.net import Download from resources.utorrent.net import Download
self.listing.reset() self.listing.reset()
@ -345,8 +418,8 @@ class SearchWindow(pyxbmct.AddonDialogWindow):
folder = data['dir'] folder = data['dir']
break break
if isRemoteTorr(): if isRemoteTorr():
torrent_dir = self.__settings__.getSetting("torrent_dir") torrent_dir = __settings__.getSetting("torrent_dir")
torrent_replacement = self.__settings__.getSetting("torrent_replacement") torrent_replacement = __settings__.getSetting("torrent_replacement")
empty = [None, ''] empty = [None, '']
if torrent_dir in empty or torrent_replacement in empty: if torrent_dir in empty or torrent_replacement in empty:
if xbmcgui.Dialog().yesno( if xbmcgui.Dialog().yesno(
@ -355,7 +428,7 @@ class SearchWindow(pyxbmct.AddonDialogWindow):
self.localize('For example /media/dl_torr/ to smb://SERVER/dl_torr/. Setup now?')): self.localize('For example /media/dl_torr/ to smb://SERVER/dl_torr/. Setup now?')):
if torrent_dir in empty: if torrent_dir in empty:
torrent_dir() torrent_dir()
self.__settings__.openSettings() __settings__.openSettings()
return return
folder = folder.replace(torrent_dir, torrent_replacement) folder = folder.replace(torrent_dir, torrent_replacement)
@ -414,41 +487,41 @@ class SearchWindow(pyxbmct.AddonDialogWindow):
db = DownloadDB() db = DownloadDB()
items = db.get_all() items = db.get_all()
if items:
for addtime, title, path, type, info, status, torrent, ind, lastupdate, storage in items:
jsoninfo = json.loads(urllib.unquote_plus(info))
for addtime, title, path, type, info, status, torrent, ind, lastupdate, storage in items: if status != 'stopped' and int(lastupdate) < int(time.time()) - 10:
jsoninfo = json.loads(urllib.unquote_plus(info)) status = 'stopped'
db.update_status(addtime, status)
if status != 'stopped' and int(lastupdate) < int(time.time()) - 10: progress = int(jsoninfo.get('progress'))
status = 'stopped' if status == 'pause':
db.update_status(addtime, status) status_sign = '[||]'
img = os.path.join(__root__, 'icons', 'pause-icon.png')
progress = int(jsoninfo.get('progress')) elif status == 'stopped':
if status == 'pause': status_sign = '[X]'
status_sign = '[||]' img = os.path.join(__root__, 'icons', 'stop-icon.png')
img = os.path.join(__root__, 'icons', 'pause-icon.png')
elif status == 'stopped':
status_sign = '[X]'
img = os.path.join(__root__, 'icons', 'stop-icon.png')
else:
status_sign = '[>]'
if progress == 100:
img = os.path.join(__root__, 'icons', 'upload-icon.png')
else: else:
img = os.path.join(__root__, 'icons', 'download-icon.png') status_sign = '[>]'
if progress == 100:
img = os.path.join(__root__, 'icons', 'upload-icon.png')
else:
img = os.path.join(__root__, 'icons', 'download-icon.png')
title = '[%d%%]%s %s' % (progress, status_sign, title) title = '[%d%%]%s %s' % (progress, status_sign, title)
if jsoninfo.get('seeds') != None and jsoninfo.get('peers') != None and \ if jsoninfo.get('seeds') != None and jsoninfo.get('peers') != None and \
jsoninfo.get('download') != None and jsoninfo.get('upload') != None: jsoninfo.get('download') != None and jsoninfo.get('upload') != None:
d, u = float(jsoninfo['download']) / 1000000, float(jsoninfo['upload']) / 1000000 d, u = float(jsoninfo['download']) / 1000000, float(jsoninfo['upload']) / 1000000
s, p = str(jsoninfo['seeds']), str(jsoninfo['peers']) s, p = str(jsoninfo['seeds']), str(jsoninfo['peers'])
second = '[D/U %.2f/%.2f (MB/s)][S/L %s/%s]' % (d, u, s, p) second = '[D/U %.2f/%.2f (MB/s)][S/L %s/%s]' % (d, u, s, p)
title = dlstat_titleMake('[B]%s[/B]' % title if type == 'folder' else title, second) title = dlstat_titleMake('[B]%s[/B]' % title if type == 'folder' else title, second)
params = {'addtime': addtime, 'type': type, 'path': urllib.quote_plus(path.encode('utf-8')), params = {'addtime': addtime, 'type': type, 'path': path,
'status': status, 'progress': progress, 'storage': storage} 'status': status, 'progress': progress, 'storage': storage}
params['mode'] = 'downloadstatus_subfolder' if type == 'folder' else 'downloadstatus_file' params['mode'] = 'downloadstatus_subfolder' if type == 'folder' else 'downloadstatus_file'
self.drawItem(title, params, image=img, isFolder=type == 'folder') self.drawItem(title, params, image=img, isFolder=type == 'folder')
# def drawItem(self, title, params, image = None, isFolder = False): # def drawItem(self, title, params, image = None, isFolder = False):
if self.listing.size(): if self.listing.size():
@ -457,89 +530,121 @@ class SearchWindow(pyxbmct.AddonDialogWindow):
self.setFocus(self.button_downloadstatus) self.setFocus(self.button_downloadstatus)
return return
def file_browser(self, path, tdir):
self.listing.reset()
self.right_menu('file_browser')
self.reconnect(pyxbmct.ACTION_NAV_BACK, self.downloadstatus)
self.drawItem('..', {'mode': 'moveup', 'path': path, 'tdir': tdir}, isFolder=True)
path = urllib.unquote_plus(path)
dirs, files = xbmcvfs.listdir(path + os.sep)
if len(dirs) > 0:
for dir in dirs:
link = {'mode': 'subfolder', 'path': path, 'tdir': os.path.join(tdir, dir)}
self.drawItem(dir, link, isFolder=True)
for file in files:
link = {'mode': 'file', 'path': path, 'tdir': os.path.join(tdir, file)}
self.drawItem(file, link, isFolder=False)
def downloadstatus_action(self, action, addtime, path, type, progress, storage): def downloadstatus_action(self, action, addtime, path, type, progress, storage):
db = DownloadDB() db = DownloadDB()
if action == 'play': if action == 'play':
if type == 'file' and progress > 30: if type == 'file' and progress > 30 or progress == 100:
xbmc.Player().play(urllib.unquote_plus(path)) self.file_browser(type, path, path)
elif type == 'folder' and progress == 100:
self.file_browser(path, path)
else: else:
showMessage(self.localize('Download Status'), self.localize('Download has not finished yet')) showMessage(self.localize('Download Status'), self.localize('Download has not finished yet'))
if action == 'delete': elif action == 'delete':
db.delete(addtime) db.delete(addtime)
showMessage(self.localize('Download Status'), self.localize('Stopped and Deleted!')) showMessage(self.localize('Download Status'), self.localize('Stopped and Deleted!'))
if action == 'pause': elif action == 'pause':
db.update_status(addtime, 'pause') db.update_status(addtime, 'pause')
showMessage(self.localize('Download Status'), self.localize('Paused!')) showMessage(self.localize('Download Status'), self.localize('Paused!'))
if action == 'stop': elif action == 'stop':
db.update_status(addtime, 'stopped') db.update_status(addtime, 'stopped')
showMessage(self.localize('Download Status'), self.localize('Stopped!')) showMessage(self.localize('Download Status'), self.localize('Stopped!'))
if action == 'start': elif action == 'start':
if 'status' == 'pause': start = db.get_byaddtime(addtime)
if start[5] == 'pause':
db.update_status(addtime, 'downloading') db.update_status(addtime, 'downloading')
showMessage(self.localize('Download Status'), self.localize('Unpaused!')) showMessage(self.localize('Download Status'), self.localize('Unpaused!'))
else: else:
start = db.get_byaddtime(addtime)
torrent, ind = start[6], start[7] torrent, ind = start[6], start[7]
start_exec = 'XBMC.RunPlugin(%s)' % ('%s?action=%s&url=%s&ind=%s&storage=%s') % (
sys.argv[0], 'downloadLibtorrent', urllib.quote_plus(torrent.encode('utf-8')), str(ind), storage) from Core import Core
xbmc.executebuiltin(start_exec) params = {'url': torrent.encode('utf-8'),
'ind': str(ind), 'storage': storage.encode('utf-8')}
del db
import SkorbaLoader
__settings__.setSetting("lastTorrent", torrent.encode('utf-8'))
torrent = SkorbaLoader.SkorbaLoader(storage.encode('utf-8'), torrent.encode('utf-8'))
encryption = __settings__.getSetting('encryption') == 'true'
torrent.downloadProcess(str(ind), encryption)
#start_exec = self.form_link('downloadLibtorrent',
# {'url': torrent.encode('utf-8'),
# 'ind': str(ind), 'storage': storage.encode('utf-8')})
#log(start_exec)
#xbmc.executebuiltin('XBMC.RunPlugin(%s)' % start_exec)
showMessage(self.localize('Download Status'), self.localize('Started!')) showMessage(self.localize('Download Status'), self.localize('Started!'))
if action == 'startall': elif action == 'masscontrol':
items = db.get_all() dialog_items = [self.localize('Start All'), self.localize('Stop All'),
if items: self.localize('Clear %s') % self.localize('Download Status'), self.localize('Cancel')]
for addtime, title, path, type, info, status, torrent, ind, lastupdate, storage in items: ret = xbmcgui.Dialog().select(self.localize('Mass Control'), dialog_items)
start_exec = 'XBMC.RunPlugin(%s)' % ('%s?action=%s&url=%s&ind=%s&storage=%s') % ( if ret == 0:
sys.argv[0], 'downloadLibtorrent', urllib.quote_plus(torrent.encode('utf-8')), str(ind), items = db.get_all()
urllib.quote_plus(storage.encode('utf-8'))) if items:
xbmc.executebuiltin(start_exec) for addtime, title, path, type, info, status, torrent, ind, lastupdate, storage in items:
xbmc.sleep(1000) start_exec = self.form_link('downloadLibtorrent',
showMessage(self.localize('Download Status'), self.localize('Started All!')) {'url':torrent.encode('utf-8'),
'ind':str(ind), 'storage':storage.encode('utf-8')})
log(start_exec)
xbmc.executebuiltin('XBMC.RunScript(%s)' % start_exec)
xbmc.sleep(1000)
showMessage(self.localize('Download Status'), self.localize('Started All!'))
elif ret == 1:
items = db.get_all()
if items:
for addtime, title, path, type, info, status, torrent, ind, lastupdate, storage in items:
db.update_status(addtime, 'stopped')
xbmc.sleep(1000)
showMessage(self.localize('Download Status'), self.localize('Stopped All!'))
elif ret == 2:
db.clear()
showMessage(self.localize('Download Status'), self.localize('Clear!'))
if action == 'stopall': xbmc.sleep(1000)
items = db.get_all() self.downloadstatus()
if items:
for addtime, title, path, type, info, status, torrent, ind, lastupdate, storage in items:
db.update_status(addtime, 'stopped')
xbmc.sleep(1000)
showMessage(self.localize('Download Status'), self.localize('Stopped All!'))
if action == 'clear': def file_browser(self, mode, path, tdir):
db.clear()
showMessage(self.localize('Download Status'), self.localize('Clear!')) path = encode_msg(path)
tdir = encode_msg(tdir)
self.listing.reset()
if tdir == os.path.dirname(path):
self.downloadstatus()
elif mode == 'file':
xbmc.Player().play(localize_path(tdir))
self.close()
else:
self.right_menu('file_browser')
self.reconnect(pyxbmct.ACTION_NAV_BACK, self.downloadstatus)
self.drawItem('..', {'mode': 'moveup', 'path': path,
'tdir': os.path.dirname(tdir)}, isFolder=True)
dirs, files = xbmcvfs.listdir(tdir + os.sep)
if len(dirs) > 0:
for dir in dirs:
link = {'mode': 'subfolder', 'path': path, 'type': 'folder',
'tdir': os.path.join(tdir, dir)}
self.drawItem(dir, link, isFolder=True)
for file in files:
link = {'mode': 'file', 'path': path, 'type': 'file',
'tdir': os.path.join(tdir, file)}
self.drawItem(file, link, isFolder=False)
if self.listing.size():
self.setFocus(self.listing)
else:
self.setFocus(self.button_downloadstatus)
def open_torrent(self, link, tdir=None): def open_torrent(self, link, tdir=None):
# cache # cache
if link != self.last_link: if link != self.last_link:
self.contentList = get_contentList(link) self.contentList = get_contentList(link)
self.last_link = link self.last_link = link
self.reconnect(pyxbmct.ACTION_NAV_BACK, self.search)
dirList, contentListNew = cutFolder(self.contentList, tdir) dirList, contentListNew = cutFolder(self.contentList, tdir)
@ -585,7 +690,6 @@ class SearchWindow(pyxbmct.AddonDialogWindow):
self.localize('Individual Tracker Options'), self.localize('Individual Tracker Options'),
self.localize('Fav. / Unfav.'), self.localize('Fav. / Unfav.'),
self.localize('Delete')] self.localize('Delete')]
elif mode in ['browser', 'browser_item']: elif mode in ['browser', 'browser_item']:
label_list = [self.localize('Open'), self.localize('Start'), self.localize('Stop'), label_list = [self.localize('Open'), self.localize('Start'), self.localize('Stop'),
self.localize('Remove'), self.localize('High Priority'), self.localize('Remove'), self.localize('High Priority'),
@ -604,6 +708,9 @@ class SearchWindow(pyxbmct.AddonDialogWindow):
elif mode in ['downloadstatus_file']: elif mode in ['downloadstatus_file']:
label_list = [self.localize('Play'), self.localize('Start'), self.localize('Pause'), label_list = [self.localize('Play'), self.localize('Start'), self.localize('Pause'),
self.localize('Stop'), self.localize('Delete'), self.localize('Mass Control'),] self.localize('Stop'), self.localize('Delete'), self.localize('Mass Control'),]
elif mode in ['watched', 'watched_item']:
label_list = [self.localize('Open Torrent'), self.localize('Play (from start)'),
self.localize('Play (with seek)'), self.localize('Delete'), self.localize('Clear History'), ]
return label_list return label_list
def context(self): def context(self):
@ -738,6 +845,7 @@ class SearchWindow(pyxbmct.AddonDialogWindow):
tdir = params.get('tdir') tdir = params.get('tdir')
self.listing.reset() self.listing.reset()
if mode in ['search_item', 'torrent_subfolder']: if mode in ['search_item', 'torrent_subfolder']:
self.reconnect(pyxbmct.ACTION_NAV_BACK, self.search)
self.open_torrent(filename, tdir) self.open_torrent(filename, tdir)
elif mode == 'torrent_moveup': elif mode == 'torrent_moveup':
self.search() self.search()
@ -750,13 +858,18 @@ class SearchWindow(pyxbmct.AddonDialogWindow):
addtime = params.get('addtime') addtime = params.get('addtime')
self.input_search.setText(filename) self.input_search.setText(filename)
self.search(addtime) self.search(addtime)
elif mode in ['browser_item', 'browser_subfolder']: elif mode in ['browser_item', 'browser_subfolder', 'browser_moveup']:
self.browser(hash, tdir)
elif mode == 'browser_moveup':
self.browser(hash, tdir) self.browser(hash, tdir)
elif mode == 'browser_file': elif mode == 'browser_file':
self.browser_action(hash, 'play', tdir = tdir, ind = ind) self.browser_action(hash, 'play', tdir = tdir, ind = ind)
self.close() self.close()
elif mode in ['downloadstatus', 'downloadstatus_subfolder', 'downloadstatus_file']:
self.downloadstatus_action('play', params.get('addtime'), params.get('path'),
params.get('type'), params.get('progress'), params.get('storage'))
elif mode in ['moveup', 'subfolder', 'file']:
self.file_browser(params.get('type'), params.get('path'), tdir)
elif mode == 'watched_item':
self.watched_action('open', params.get('addtime'))
def right_press2(self): def right_press2(self):
item = self.listing.getSelectedItem() item = self.listing.getSelectedItem()
@ -785,6 +898,11 @@ class SearchWindow(pyxbmct.AddonDialogWindow):
self.browser_action(hash, '3', tdir=tdir, ind=ind) self.browser_action(hash, '3', tdir=tdir, ind=ind)
elif mode == 'browser_file': elif mode == 'browser_file':
self.browser_action(hash, '3', tdir=tdir, ind=ind) self.browser_action(hash, '3', tdir=tdir, ind=ind)
elif mode in ['downloadstatus', 'downloadstatus_subfolder', 'downloadstatus_file']:
self.downloadstatus_action('start', params.get('addtime'), params.get('path'),
params.get('type'), params.get('progress'), params.get('storage'))
elif mode == 'watched_item':
self.watched_action('playnoseek', params.get('addtime'))
def right_press3(self): def right_press3(self):
item = self.listing.getSelectedItem() item = self.listing.getSelectedItem()
@ -813,6 +931,11 @@ class SearchWindow(pyxbmct.AddonDialogWindow):
self.browser_action(hash, '0', tdir=tdir, ind=ind) self.browser_action(hash, '0', tdir=tdir, ind=ind)
elif mode == 'browser_file': elif mode == 'browser_file':
self.browser_action(hash, '0', tdir=tdir, ind=ind) self.browser_action(hash, '0', tdir=tdir, ind=ind)
elif mode in ['downloadstatus', 'downloadstatus_subfolder', 'downloadstatus_file']:
self.downloadstatus_action('pause', params.get('addtime'), params.get('path'),
params.get('type'), params.get('progress'), params.get('storage'))
elif mode == 'watched_item':
self.watched_action('playwithseek', params.get('addtime'))
def right_press4(self): def right_press4(self):
item = self.listing.getSelectedItem() item = self.listing.getSelectedItem()
@ -837,6 +960,11 @@ class SearchWindow(pyxbmct.AddonDialogWindow):
self.browser() self.browser()
elif mode == 'browser_subfolder': elif mode == 'browser_subfolder':
self.browser_action(hash, 'copy', tdir=tdir, ind=ind) self.browser_action(hash, 'copy', tdir=tdir, ind=ind)
elif mode in ['downloadstatus', 'downloadstatus_subfolder', 'downloadstatus_file']:
self.downloadstatus_action('stop', params.get('addtime'), params.get('path'),
params.get('type'), params.get('progress'), params.get('storage'))
elif mode == 'watched_item':
self.watched_action('delete', params.get('addtime'))
def right_press5(self): def right_press5(self):
item = self.listing.getSelectedItem() item = self.listing.getSelectedItem()
@ -850,6 +978,11 @@ class SearchWindow(pyxbmct.AddonDialogWindow):
self.history_action('delete', addtime, fav) self.history_action('delete', addtime, fav)
elif mode == 'browser_item': elif mode == 'browser_item':
self.browser_action(hash, '3') self.browser_action(hash, '3')
elif mode in ['downloadstatus', 'downloadstatus_subfolder', 'downloadstatus_file']:
self.downloadstatus_action('delete', params.get('addtime'), params.get('path'),
params.get('type'), params.get('progress'), params.get('storage'))
elif mode == 'watched_item':
self.watched_action('clear', params.get('addtime'))
def right_press6(self): def right_press6(self):
item = self.listing.getSelectedItem() item = self.listing.getSelectedItem()
@ -859,6 +992,9 @@ class SearchWindow(pyxbmct.AddonDialogWindow):
hash = params.get('hash') hash = params.get('hash')
if mode == 'browser_item': if mode == 'browser_item':
self.browser_action(hash, '0') self.browser_action(hash, '0')
elif mode in ['downloadstatus', 'downloadstatus_subfolder', 'downloadstatus_file']:
self.downloadstatus_action('masscontrol', params.get('addtime'), params.get('path'),
params.get('type'), params.get('progress'), params.get('storage'))
def right_press7(self): def right_press7(self):
item = self.listing.getSelectedItem() item = self.listing.getSelectedItem()
@ -955,7 +1091,6 @@ class InfoWindow(pyxbmct.AddonDialogWindow):
self.logoimg.setImage(meta.get('thumbnail')) self.logoimg.setImage(meta.get('thumbnail'))
self.plot.setText(meta.get('plot')) self.plot.setText(meta.get('plot'))
def log(msg): def log(msg):
try: try:
xbmc.log("### [%s]: %s" % (__plugin__, msg,), level=xbmc.LOGNOTICE) xbmc.log("### [%s]: %s" % (__plugin__, msg,), level=xbmc.LOGNOTICE)
@ -964,7 +1099,6 @@ def log(msg):
except: except:
xbmc.log("### [%s]: %s" % (__plugin__, 'ERROR LOG',), level=xbmc.LOGNOTICE) xbmc.log("### [%s]: %s" % (__plugin__, 'ERROR LOG',), level=xbmc.LOGNOTICE)
def titleMake(seeds, leechers, size, title): def titleMake(seeds, leechers, size, title):
# AARRGGBB # AARRGGBB
clGreen = '[COLOR FF008000]%s[/COLOR]' clGreen = '[COLOR FF008000]%s[/COLOR]'