1408 lines
64 KiB
Python
1408 lines
64 KiB
Python
#!/usr/bin/env python
|
|
#
|
|
# interface.py
|
|
#
|
|
# Copyright (C) Zach Tibbitts 2006 <zach@collegegeek.org>
|
|
#
|
|
# This program is free software; you can redistribute it and/or modify
|
|
# it under the terms of the GNU General Public License as published by
|
|
# the Free Software Foundation; either version 2, or (at your option)
|
|
# any later version.
|
|
#
|
|
# This program is distributed in the hope that it will be useful,
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
# GNU General Public License for more details.
|
|
#
|
|
# You should have received a copy of the GNU General Public License
|
|
# along with this program. If not, write to:
|
|
# The Free Software Foundation, Inc.,
|
|
# 51 Franklin Street, Fifth Floor
|
|
# Boston, MA 02110-1301, USA.
|
|
#
|
|
# In addition, as a special exception, the copyright holders give
|
|
# permission to link the code of portions of this program with the OpenSSL
|
|
# library.
|
|
# You must obey the GNU General Public License in all respects for all of
|
|
# the code used other than OpenSSL. If you modify file(s) with this
|
|
# exception, you may extend this exception to your version of the file(s),
|
|
# but you are not obligated to do so. If you do not wish to do so, delete
|
|
# this exception statement from your version. If you delete this exception
|
|
# statement from all source files in the program, then also delete it here.
|
|
|
|
import sys
|
|
import os
|
|
import os.path
|
|
import urllib
|
|
from itertools import izip
|
|
import core
|
|
import common
|
|
import dgtk
|
|
import ipc_manager
|
|
import dialogs
|
|
import plugins
|
|
import pref
|
|
import pygtk
|
|
pygtk.require('2.0')
|
|
import gtk
|
|
import gtk.glade
|
|
import gobject
|
|
import xdg
|
|
import xdg.BaseDirectory
|
|
import gettext
|
|
import locale
|
|
|
|
class DelugeGTK:
|
|
def __init__(self):
|
|
APP = 'deluge'
|
|
DIR = os.path.join(common.INSTALL_PREFIX, 'share', 'locale')
|
|
locale.setlocale(locale.LC_ALL, '')
|
|
locale.bindtextdomain(APP, DIR)
|
|
locale.textdomain(APP)
|
|
gettext.bindtextdomain(APP, DIR)
|
|
gettext.textdomain(APP)
|
|
gettext.install(APP, DIR)
|
|
|
|
self.is_running = False
|
|
self.ipc_manager = ipc_manager.Manager(self)
|
|
self.torrent_file_queue = []
|
|
#Start the Deluge Manager:
|
|
self.manager = core.Manager(common.CLIENT_CODE, common.CLIENT_VERSION,
|
|
'%s %s'%(common.PROGRAM_NAME, common.PROGRAM_VERSION), common.CONFIG_DIR)
|
|
self.something_screwed_up = False
|
|
self.plugins = plugins.PluginManager(self.manager, self)
|
|
self.plugins.add_plugin_dir(common.PLUGIN_DIR)
|
|
if os.path.isdir(os.path.join(common.CONFIG_DIR , 'plugins')):
|
|
self.plugins.add_plugin_dir(os.path.join(common.CONFIG_DIR, 'plugins'))
|
|
self.plugins.scan_for_plugins()
|
|
self.config = self.manager.get_config()
|
|
#Set up the interface:
|
|
self.wtree = gtk.glade.XML(common.get_glade_file("delugegtk.glade"), domain=APP)
|
|
self.window = self.wtree.get_widget("main_window")
|
|
self.toolbar = self.wtree.get_widget("tb_middle")
|
|
self.window.drag_dest_set(gtk.DEST_DEFAULT_ALL,[('text/uri-list', 0, 80)], gtk.gdk.ACTION_COPY)
|
|
self.window.connect("delete_event", self.close)
|
|
self.window.connect("drag_data_received", self.on_drag_data)
|
|
self.window.connect("window-state-event", self.window_state_event)
|
|
self.window.connect("configure-event", self.window_configure_event)
|
|
self.window.set_title(common.PROGRAM_NAME)
|
|
self.window.set_icon_from_file(common.get_pixmap("deluge32.png"))
|
|
self.notebook = self.wtree.get_widget("torrent_info")
|
|
self.notebook.connect("change-current-page", self.notebook_change_page_event)
|
|
self.statusbar = self.wtree.get_widget("statusbar")
|
|
|
|
## Construct the Interface
|
|
try:
|
|
self.build_tray_icon()
|
|
except AttributeError:
|
|
#python-pygtk is < 2.9
|
|
self.tray_icon = dgtk.StupidTray()
|
|
self.has_tray = False
|
|
else:
|
|
self.has_tray = True
|
|
|
|
self.preferences_dialog = dialogs.PreferencesDlg(self, self.config)
|
|
self.plugin_dialog = dialogs.PluginDlg(self, self.plugins)
|
|
self.build_torrent_table()
|
|
self.build_summary_tab()
|
|
self.build_file_tab()
|
|
self.build_peer_tab()
|
|
|
|
# Set the Torrent menu bar sub-menu to the same as the right-click Torrent pop-up menu
|
|
self.wtree.get_widget("menu_torrent").set_submenu(self.torrent_menu)
|
|
self.wtree.get_widget("menu_torrent").set_sensitive(False)
|
|
|
|
self.connect_signals()
|
|
|
|
try:
|
|
self.load_window_settings()
|
|
except KeyError:
|
|
pass
|
|
|
|
self.apply_prefs()
|
|
self.load_window_geometry()
|
|
|
|
def external_add_torrent(self, torrent_file):
|
|
print "Ding!"
|
|
print "Got torrent externally:", os.path.basename(torrent_file)
|
|
print "Here's the raw data:", torrent_file
|
|
print "\tNow, what to do with it?"
|
|
if self.is_running:
|
|
print "\t\tthe client seems to already be running, i'll try and add the torrent"
|
|
uid = self.interactive_add_torrent(torrent_file)
|
|
else:
|
|
print "\t\tthe client hasn't started yet, I'll queue the torrent"
|
|
self.torrent_file_queue.append(torrent_file)
|
|
|
|
def connect_signals(self):
|
|
self.wtree.signal_autoconnect({
|
|
## File Menu
|
|
"add_torrent": self.add_torrent_clicked,
|
|
"add_torrent_url": self.add_torrent_url_clicked,
|
|
"remove_torrent": self.remove_torrent_clicked,
|
|
"menu_quit": self.quit,
|
|
## Edit Menu
|
|
"pref_clicked": self.show_pref_dialog,
|
|
"plugins_clicked": self.show_plugin_dialog,
|
|
## View Menu
|
|
"toolbar_toggle": self.toolbar_toggle,
|
|
"infopane_toggle": self.infopane_toggle,
|
|
"size_toggle": self.size_toggle,
|
|
"status_toggle": self.status_toggle,
|
|
"seeders_toggle": self.seeders_toggle,
|
|
"peers_toggle": self.peers_toggle,
|
|
"dl_toggle": self.dl_toggle,
|
|
"ul_toggle": self.ul_toggle,
|
|
"eta_toggle": self.eta_toggle,
|
|
"share_toggle": self.share_toggle,
|
|
## Help Menu
|
|
"show_about_dialog": self.show_about_dialog,
|
|
"launchpad": self.launchpad,
|
|
## Toolbar
|
|
"start_pause": self.start_pause,
|
|
"update_tracker": self.update_tracker,
|
|
"clear_finished": self.clear_finished,
|
|
"queue_up": self.q_torrent_up,
|
|
"queue_down": self.q_torrent_down
|
|
})
|
|
|
|
def notebook_change_page_event(self, widget):
|
|
# Force an update when user changes the notebook tab
|
|
self.update()
|
|
|
|
def build_tray_icon(self):
|
|
self.tray_icon = gtk.status_icon_new_from_file(common.get_pixmap("deluge32.png"))
|
|
|
|
self.tray_glade = gtk.glade.XML(common.get_glade_file("tray_menu.glade"), domain='deluge')
|
|
self.tray_menu = self.tray_glade.get_widget("tray_menu")
|
|
self.tray_glade.signal_autoconnect({
|
|
"quit": self.quit,
|
|
"plugins": self.show_plugin_dialog,
|
|
"preferences": self.show_pref_dialog,
|
|
"add_torrent": self.add_torrent_clicked,
|
|
"clear_finished": self.clear_finished,
|
|
"show_hide_window_toggled": self.show_hide_window_toggled
|
|
})
|
|
|
|
self.tray_glade.get_widget("download-limit-image").set_from_file(common.get_pixmap('downloading16.png'))
|
|
self.tray_glade.get_widget("upload-limit-image").set_from_file(common.get_pixmap('seeding16.png'))
|
|
self.build_tray_bwsetsubmenu()
|
|
|
|
self.tray_icon.connect("activate", self.tray_clicked)
|
|
self.tray_icon.connect("popup-menu", self.tray_popup)
|
|
|
|
def tray_popup(self, status_icon, button, activate_time):
|
|
if self.window.get_property("visible"):
|
|
self.tray_glade.get_widget("show_hide_window").set_active(True)
|
|
else:
|
|
self.tray_glade.get_widget("show_hide_window").set_active(False)
|
|
|
|
self.tray_menu.popup(None, None, gtk.status_icon_position_menu,
|
|
button, activate_time, status_icon)
|
|
|
|
def build_tray_bwsetsubmenu(self):
|
|
# Create the Download speed list sub-menu
|
|
self.submenu_bwdownset = self.build_menu_radio_list(
|
|
self.config.get("tray_downloadspeedlist"), self.tray_setbwdown,
|
|
self.config.get("max_download_speed"), _("KiB/s"),
|
|
show_notset=True)
|
|
|
|
# Create the Upload speed list sub-menu
|
|
self.submenu_bwupset = self.build_menu_radio_list(
|
|
self.config.get("tray_uploadspeedlist"), self.tray_setbwup,
|
|
self.config.get("max_upload_speed"), _("KiB/s"),
|
|
show_notset=True)
|
|
|
|
# Add the sub-menus to the tray menu
|
|
self.tray_glade.get_widget("download_limit").set_submenu(self.submenu_bwdownset)
|
|
self.tray_glade.get_widget("upload_limit").set_submenu(self.submenu_bwupset)
|
|
|
|
# Show the sub-menus for all to see
|
|
self.submenu_bwdownset.show_all()
|
|
self.submenu_bwupset.show_all()
|
|
|
|
def build_menu_radio_list(self, value_list, callback, pref_value=None,
|
|
suffix=None, show_notset=False,
|
|
notset_label="Unlimited", notset_lessthan=0):
|
|
# Build a menu with radio menu items from a list and connect them to the callback
|
|
# The pref_value is what you would like to test for the default active radio item
|
|
# Setting show_unlimited will include an Unlimited radio item
|
|
|
|
menu = gtk.Menu()
|
|
|
|
group = None
|
|
for value in sorted(value_list):
|
|
if suffix != None:
|
|
menuitem = gtk.RadioMenuItem(group, str(value) + " " + suffix)
|
|
else:
|
|
menuitem = gtk.RadioMenuItem(group, str(value))
|
|
|
|
group = menuitem
|
|
|
|
if value == pref_value and pref_value != None:
|
|
menuitem.set_active(True)
|
|
|
|
if callback != None:
|
|
menuitem.connect("toggled", callback)
|
|
|
|
menu.append(menuitem)
|
|
|
|
if show_notset:
|
|
menuitem = gtk.RadioMenuItem(group, _(notset_label))
|
|
if pref_value < notset_lessthan and pref_value != None:
|
|
menuitem.set_active(True)
|
|
menuitem.connect("toggled", callback)
|
|
menu.append(menuitem)
|
|
|
|
# Add the Other... menuitem
|
|
menuitem = gtk.SeparatorMenuItem()
|
|
menu.append(menuitem)
|
|
menuitem = gtk.MenuItem(_("Other..."))
|
|
menuitem.connect("activate", callback)
|
|
menu.append(menuitem)
|
|
|
|
return menu
|
|
|
|
def tray_setbwdown(self, widget, data=None):
|
|
str_bwdown = widget.get_children()[0].get_text().rstrip(" "+_("KiB/s"))
|
|
if str_bwdown == _("Unlimited"):
|
|
str_bwdown = -1
|
|
|
|
if str_bwdown == _("Other..."):
|
|
dialog_glade = gtk.glade.XML(common.get_glade_file("dgtkpopups.glade"))
|
|
speed_dialog = dialog_glade.get_widget("speed_dialog")
|
|
spin_speed = dialog_glade.get_widget("spin_speed")
|
|
spin_speed.set_value(self.config.get("max_download_speed"))
|
|
spin_speed.select_region(0, -1)
|
|
response = speed_dialog.run()
|
|
if response == 1: # OK Response
|
|
str_bwdown = spin_speed.get_value()
|
|
else:
|
|
speed_dialog.destroy()
|
|
return
|
|
speed_dialog.destroy()
|
|
|
|
self.config.set("max_download_speed", float(str_bwdown))
|
|
self.apply_prefs()
|
|
|
|
def tray_setbwup(self, widget, data=None):
|
|
str_bwup = widget.get_children()[0].get_text().rstrip(" "+_("KiB/s"))
|
|
if str_bwup == _("Unlimited"):
|
|
str_bwup = -1
|
|
|
|
if str_bwup == _("Other..."):
|
|
dialog_glade = gtk.glade.XML(common.get_glade_file("dgtkpopups.glade"))
|
|
speed_dialog = dialog_glade.get_widget("speed_dialog")
|
|
spin_speed = dialog_glade.get_widget("spin_speed")
|
|
spin_speed.set_value(self.config.get("max_upload_speed"))
|
|
spin_speed.select_region(0, -1)
|
|
response = speed_dialog.run()
|
|
if response == 1: # OK Response
|
|
str_bwup = spin_speed.get_value()
|
|
else:
|
|
speed_dialog.destroy()
|
|
return
|
|
speed_dialog.destroy()
|
|
|
|
self.config.set("max_upload_speed", float(str_bwup))
|
|
self.apply_prefs()
|
|
|
|
def unlock_tray(self,comingnext):
|
|
entered_pass = gtk.Entry(25)
|
|
entered_pass.set_activates_default(True)
|
|
entered_pass.set_width_chars(25)
|
|
entered_pass.set_visibility(False)
|
|
entered_pass.show()
|
|
tray_lock = gtk.Dialog(title=_("Deluge is locked"), parent=self.window,
|
|
buttons=(gtk.STOCK_CANCEL, gtk.RESPONSE_REJECT, gtk.STOCK_OK, gtk.RESPONSE_ACCEPT))
|
|
label = gtk.Label(_("Deluge is password protected.\nTo show the Deluge window, please enter your password"))
|
|
label.set_line_wrap(True)
|
|
label.set_justify(gtk.JUSTIFY_CENTER)
|
|
tray_lock.set_position(gtk.WIN_POS_CENTER_ALWAYS)
|
|
tray_lock.set_size_request(400, 200)
|
|
tray_lock.set_default_response(gtk.RESPONSE_ACCEPT)
|
|
tray_lock.vbox.pack_start(label)
|
|
tray_lock.vbox.pack_start(entered_pass)
|
|
tray_lock.show_all()
|
|
if tray_lock.run() == gtk.RESPONSE_ACCEPT:
|
|
if self.config.get("tray_passwd") == entered_pass.get_text():
|
|
if comingnext == "mainwinshow":
|
|
self.window.show()
|
|
elif comingnext == "prefwinshow":
|
|
self.preferences_dialog.show()
|
|
self.apply_prefs()
|
|
self.config.save_to_file()
|
|
elif comingnext == "quitus":
|
|
self.window.hide()
|
|
self.shutdown()
|
|
|
|
tray_lock.destroy()
|
|
return True
|
|
|
|
def list_of_trackers(self,obj=None):
|
|
torrent = self.get_selected_torrent()
|
|
if torrent is not None:
|
|
trackerslist = self.manager.get_trackers(torrent)
|
|
self.show_edit_tracker_dialog(trackerslist)
|
|
|
|
def cancel_edit_window(self,arg=None):
|
|
self.edit_window.destroy()
|
|
|
|
def accept_edit_window(self,arg=None):
|
|
torrent = self.get_selected_torrent()
|
|
self.textlist = self.textbuffer.get_text(self.textbuffer.get_start_iter(), self.textbuffer.get_end_iter(), include_hidden_chars=False).strip()
|
|
self.manager.replace_trackers(torrent, self.textlist)
|
|
self.edit_window.destroy()
|
|
|
|
def show_edit_tracker_dialog(self,list):
|
|
self.textbuffer = gtk.TextBuffer(table=None)
|
|
self.textbuffer.set_text(list)
|
|
self.edit_glade = gtk.glade.XML(common.get_glade_file("edit_trackers.glade"))
|
|
self.edit_list = self.edit_glade.get_widget("txt_tracker_list")
|
|
self.edit_list.set_buffer(self.textbuffer)
|
|
self.edit_window = self.edit_glade.get_widget("edittrackers")
|
|
self.edit_window.set_position(gtk.WIN_POS_CENTER_ALWAYS)
|
|
self.edit_window.set_size_request(400, 200)
|
|
self.edit_glade.signal_autoconnect({"cancel_button_clicked": self.cancel_edit_window,
|
|
"ok_button_clicked": self.accept_edit_window
|
|
})
|
|
|
|
self.edit_window.show_all()
|
|
|
|
return True
|
|
|
|
|
|
def tray_clicked(self, status_icon):
|
|
if self.window.get_property("visible"):
|
|
if self.window.is_active():
|
|
self.window.hide()
|
|
else:
|
|
self.window.present()
|
|
else:
|
|
if self.config.get("lock_tray") == True:
|
|
self.unlock_tray("mainwinshow")
|
|
else:
|
|
self.load_window_geometry()
|
|
self.window.show()
|
|
|
|
def show_hide_window_toggled(self, widget):
|
|
if widget.get_active() and not self.window.get_property("visible"):
|
|
if self.config.get("lock_tray") == True:
|
|
self.unlock_tray("mainwinshow")
|
|
else:
|
|
self.window.show()
|
|
elif not widget.get_active() and self.window.get_property("visible"):
|
|
self.window.hide()
|
|
|
|
def build_torrent_table(self):
|
|
## Create the torrent listview
|
|
self.torrent_view = self.wtree.get_widget("torrent_view")
|
|
self.torrent_glade = gtk.glade.XML(common.get_glade_file("torrent_menu.glade"), domain='deluge')
|
|
self.torrent_menu = self.torrent_glade.get_widget("torrent_menu")
|
|
self.torrent_glade.signal_autoconnect({ "remove_torrent": self.remove_torrent_clicked,
|
|
"edit_trackers": self.list_of_trackers,
|
|
"start_pause": self.start_pause,
|
|
"update_tracker": self.update_tracker,
|
|
"clear_finished": self.clear_finished,
|
|
"queue_up": self.q_torrent_up,
|
|
"queue_down": self.q_torrent_down,
|
|
"queue_bottom": self.q_to_bottom,
|
|
"queue_top": self.q_to_top,
|
|
})
|
|
self.torrent_menu.connect("focus", self.torrent_menu_focus)
|
|
# UID, Q#, Status Icon, Name, Size, Progress, Message, Seeders, Peers,
|
|
# DL, UL, ETA, Share
|
|
self.torrent_model = gtk.ListStore(int, gobject.TYPE_UINT,
|
|
gtk.gdk.Pixbuf, str, gobject.TYPE_UINT64, float, str, int, int,
|
|
int, int, int, int, gobject.TYPE_UINT, float)
|
|
self.torrent_view.set_model(self.torrent_model)
|
|
self.torrent_view.set_rules_hint(True)
|
|
self.torrent_view.set_reorderable(True)
|
|
self.torrent_view.get_selection().set_mode(gtk.SELECTION_MULTIPLE)
|
|
|
|
def size(column, cell, model, iter, data):
|
|
size = long(model.get_value(iter, data))
|
|
size_str = common.fsize(size)
|
|
cell.set_property('text', size_str)
|
|
|
|
def peer(column, cell, model, iter, data):
|
|
c1, c2 = data
|
|
a = int(model.get_value(iter, c1))
|
|
b = int(model.get_value(iter, c2))
|
|
cell.set_property('text', '%d (%d)'%(a, b))
|
|
|
|
def time(column, cell, model, iter, data):
|
|
time = int(model.get_value(iter, data))
|
|
if time < 0 or time == 0:
|
|
time_str = _("Infinity")
|
|
else:
|
|
time_str = common.ftime(time)
|
|
cell.set_property('text', time_str)
|
|
|
|
def ratio(column, cell, model, iter, data):
|
|
ratio = float(model.get_value(iter, data))
|
|
if ratio == -1:
|
|
ratio_str = _("Unknown")
|
|
else:
|
|
ratio_str = "%.3f"%ratio
|
|
cell.set_property('text', ratio_str)
|
|
|
|
|
|
## Initializes the columns for the torrent_view
|
|
(TORRENT_VIEW_COL_UID, TORRENT_VIEW_COL_QUEUE, TORRENT_VIEW_COL_STATUSICON, TORRENT_VIEW_COL_NAME,
|
|
TORRENT_VIEW_COL_SIZE, TORRENT_VIEW_COL_PROGRESS, TORRENT_VIEW_COL_STATUS,
|
|
TORRENT_VIEW_COL_CONNECTED_SEEDS, TORRENT_VIEW_COL_SEEDS,
|
|
TORRENT_VIEW_COL_CONNECTED_PEERS, TORRENT_VIEW_COL_PEERS, TORRENT_VIEW_COL_DOWNLOAD,
|
|
TORRENT_VIEW_COL_UPLOAD, TORRENT_VIEW_COL_ETA, TORRENT_VIEW_COL_RATIO) = range(15)
|
|
|
|
self.queue_column = dgtk.add_text_column(self.torrent_view, "#", TORRENT_VIEW_COL_QUEUE)
|
|
self.name_column = dgtk.add_texticon_column(self.torrent_view, _("Name"), TORRENT_VIEW_COL_STATUSICON, TORRENT_VIEW_COL_NAME)
|
|
self.size_column = dgtk.add_func_column(self.torrent_view, _("Size"), dgtk.cell_data_size, TORRENT_VIEW_COL_SIZE)
|
|
self.status_column = dgtk.add_progress_column(self.torrent_view, _("Status"), TORRENT_VIEW_COL_PROGRESS, TORRENT_VIEW_COL_STATUS)
|
|
self.seed_column = dgtk.add_func_column(self.torrent_view, _("Seeders"), peer, (TORRENT_VIEW_COL_CONNECTED_SEEDS, TORRENT_VIEW_COL_SEEDS))
|
|
self.peer_column = dgtk.add_func_column(self.torrent_view, _("Peers"), peer, (TORRENT_VIEW_COL_CONNECTED_PEERS, TORRENT_VIEW_COL_PEERS))
|
|
self.dl_column = dgtk.add_func_column(self.torrent_view, _("Down Speed"), dgtk.cell_data_speed, TORRENT_VIEW_COL_DOWNLOAD)
|
|
self.ul_column = dgtk.add_func_column(self.torrent_view, _("Up Speed"), dgtk.cell_data_speed, TORRENT_VIEW_COL_UPLOAD)
|
|
self.eta_column = dgtk.add_func_column(self.torrent_view, _("ETA"), time, TORRENT_VIEW_COL_ETA)
|
|
self.share_column = dgtk.add_func_column(self.torrent_view, _("Ratio"), ratio, TORRENT_VIEW_COL_RATIO)
|
|
|
|
self.status_column.set_expand(True)
|
|
self.name_column.set_sort_column_id(TORRENT_VIEW_COL_NAME)
|
|
self.seed_column.set_sort_column_id(TORRENT_VIEW_COL_CONNECTED_SEEDS)
|
|
self.peer_column.set_sort_column_id(TORRENT_VIEW_COL_CONNECTED_PEERS)
|
|
|
|
self.torrent_model.set_sort_column_id(TORRENT_VIEW_COL_QUEUE, gtk.SORT_ASCENDING)
|
|
|
|
try:
|
|
self.torrent_view.get_selection().set_select_function(self.torrent_clicked, full=True)
|
|
except TypeError:
|
|
self.torrent_view.get_selection().set_select_function(self.old_t_click)
|
|
self.torrent_view.connect("button-press-event", self.torrent_view_clicked)
|
|
self.right_click = False
|
|
|
|
def old_t_click(self, path):
|
|
return self.torrent_clicked(self.torrent_view.get_selection(), self.torrent_model, path, False)
|
|
|
|
def torrent_clicked(self, selection, model, path, is_selected):
|
|
if is_selected:
|
|
# Torrent is already selected, we don't need to do anything
|
|
return not self.right_click
|
|
|
|
self.peer_store.clear()
|
|
self.file_store.clear()
|
|
|
|
unique_id = model.get_value(model.get_iter(path), 0)
|
|
self.update_torrent_info_widget(unique_id)
|
|
|
|
return True
|
|
|
|
def torrent_view_clicked(self, widget, event):
|
|
if event.button == 3:
|
|
x = int(event.x)
|
|
y = int(event.y)
|
|
data = self.torrent_view.get_path_at_pos(x, y)
|
|
if data is None:
|
|
return True
|
|
path, col, cellx, celly = data
|
|
self.right_click = self.torrent_view.get_selection().path_is_selected(path)
|
|
self.torrent_view.grab_focus()
|
|
self.torrent_view.set_cursor(path, col, 0)
|
|
unique_id = self.torrent_model.get_value(self.torrent_model.get_iter(path), 0)
|
|
# Get the torrent state so we can check if the torrent is paused.
|
|
torrent_state = self.manager.get_torrent_state(unique_id)
|
|
widget = self.torrent_glade.get_widget("menu_pause")
|
|
if torrent_state["is_paused"]:
|
|
widget.set_image(gtk.image_new_from_stock(gtk.STOCK_MEDIA_PLAY, gtk.ICON_SIZE_MENU))
|
|
widget.get_children()[0].set_text(_("Resume"))
|
|
else:
|
|
widget.set_image(gtk.image_new_from_stock(gtk.STOCK_MEDIA_PAUSE, gtk.ICON_SIZE_MENU))
|
|
widget.get_children()[0].set_text(_("Pause"))
|
|
|
|
self.torrent_menu.popup(None, None, None, event.button, event.time)
|
|
|
|
return True
|
|
else:
|
|
self.right_click = False
|
|
return False
|
|
|
|
def start_pause(self, widget):
|
|
unique_ids = self.get_selected_torrent_rows()
|
|
try:
|
|
for uid in unique_ids:
|
|
self.manager.set_user_pause(uid, not self.manager.is_user_paused(uid))
|
|
|
|
# We need to force an update so the GUI looks more responsive
|
|
self.update()
|
|
|
|
except KeyError:
|
|
pass
|
|
|
|
def torrent_menu_focus(self, widget, direction):
|
|
menuitem = self.torrent_glade.get_widget("menu_pause")
|
|
# Check if we are selecting multiple torrents
|
|
if len(self.get_selected_torrent_rows()) > 1:
|
|
menuitem.set_image(gtk.image_new_from_stock(gtk.STOCK_MEDIA_PAUSE, gtk.ICON_SIZE_MENU))
|
|
menuitem.get_children()[0].set_text(_("Pause/Resume"))
|
|
return
|
|
|
|
# Get the selected torrent state so we can check if the torrent is paused.
|
|
unique_id = self.get_selected_torrent()
|
|
if unique_id is None:
|
|
return
|
|
torrent_state = self.manager.get_torrent_state(unique_id)
|
|
if torrent_state["is_paused"]:
|
|
menuitem.set_image(gtk.image_new_from_stock(gtk.STOCK_MEDIA_PLAY, gtk.ICON_SIZE_MENU))
|
|
menuitem.get_children()[0].set_text(_("Resume"))
|
|
else:
|
|
menuitem.set_image(gtk.image_new_from_stock(gtk.STOCK_MEDIA_PAUSE, gtk.ICON_SIZE_MENU))
|
|
menuitem.get_children()[0].set_text(_("Pause"))
|
|
|
|
def build_summary_tab(self):
|
|
#Torrent Summary tab
|
|
# Look into glade's widget prefix function
|
|
self.text_summary_name = self.wtree.get_widget("summary_name")
|
|
self.text_summary_total_size = self.wtree.get_widget("summary_total_size")
|
|
self.text_summary_pieces = self.wtree.get_widget("summary_pieces")
|
|
self.text_summary_total_downloaded = self.wtree.get_widget("summary_total_downloaded")
|
|
self.text_summary_total_uploaded = self.wtree.get_widget("summary_total_uploaded")
|
|
self.text_summary_download_speed = self.wtree.get_widget("summary_download_speed")
|
|
self.text_summary_upload_speed = self.wtree.get_widget("summary_upload_speed")
|
|
self.text_summary_seeders = self.wtree.get_widget("summary_seeders")
|
|
self.text_summary_peers = self.wtree.get_widget("summary_peers")
|
|
self.text_summary_percentage_done = self.wtree.get_widget("summary_percentage_done")
|
|
self.text_summary_share_ratio = self.wtree.get_widget("summary_share_ratio")
|
|
self.text_summary_downloaded_this_session = self.wtree.get_widget("summary_downloaded_this_session")
|
|
self.text_summary_uploaded_this_session = self.wtree.get_widget("summary_uploaded_this_session")
|
|
self.text_summary_tracker = self.wtree.get_widget("summary_tracker")
|
|
self.text_summary_tracker_status = self.wtree.get_widget("summary_tracker_status")
|
|
self.text_summary_next_announce = self.wtree.get_widget("summary_next_announce")
|
|
self.text_summary_eta = self.wtree.get_widget("summary_eta")
|
|
|
|
|
|
def build_peer_tab(self):
|
|
self.peer_view = self.wtree.get_widget("peer_view")
|
|
# IP int, IP string, Client, Percent Complete, Down Speed, Up Speed
|
|
# IP int is for faster sorting
|
|
self.peer_store = gtk.ListStore(gobject.TYPE_UINT, str, str, float, int, int)
|
|
def percent(column, cell, model, iter, data):
|
|
percent = float(model.get_value(iter, data))
|
|
percent_str = "%.2f%%"%percent
|
|
cell.set_property("text", percent_str)
|
|
|
|
self.peer_view.set_model(self.peer_store)
|
|
|
|
self.peer_ip_column = dgtk.add_text_column(self.peer_view, _("IP Address"), 1)
|
|
self.peer_client_column = dgtk.add_text_column(self.peer_view, _("Client"), 2)
|
|
self.peer_complete_column = dgtk.add_func_column(self.peer_view, _("Percent Complete"), percent, 3)
|
|
self.peer_download_column = dgtk.add_func_column(self.peer_view, _("Down Speed"), dgtk.cell_data_speed, 4)
|
|
self.peer_upload_column = dgtk.add_func_column(self.peer_view, _("Up Speed"), dgtk.cell_data_speed, 5)
|
|
|
|
self.peer_ip_column.set_sort_column_id(0)
|
|
|
|
def build_file_tab(self):
|
|
def percent(column, cell, model, iter, data):
|
|
percent = float(model.get_value(iter, data))
|
|
percent_str = "%.2f%%"%percent
|
|
cell.set_property("text", percent_str)
|
|
|
|
|
|
self.file_view = self.wtree.get_widget("file_view")
|
|
self.file_glade = gtk.glade.XML(common.get_glade_file("file_tab_menu.glade"), domain='deluge')
|
|
self.file_menu = self.file_glade.get_widget("file_tab_menu")
|
|
self.file_glade.signal_autoconnect({ "select_all": self.file_select_all,
|
|
"unselect_all": self.file_unselect_all,
|
|
"check_selected": self.file_check_selected,
|
|
"uncheck_selected": self.file_uncheck_selected,
|
|
})
|
|
self.file_store = gtk.ListStore(bool, str, gobject.TYPE_UINT64, float)
|
|
self.file_view.set_model(self.file_store)
|
|
self.file_view.get_selection().set_mode(gtk.SELECTION_MULTIPLE)
|
|
self.file_view.get_selection().set_select_function(self.file_clicked)
|
|
self.file_selected = []
|
|
self.file_view.connect("button-press-event", self.file_view_clicked)
|
|
|
|
dgtk.add_toggle_column(self.file_view, _("Download"), 0, toggled_signal=self.file_toggled)
|
|
dgtk.add_text_column(self.file_view, _("Filename"), 1).set_expand(True)
|
|
dgtk.add_func_column(self.file_view, _("Size"), dgtk.cell_data_size, 2)
|
|
dgtk.add_func_column(self.file_view, _("Progress"), percent, 3)
|
|
|
|
def file_select_all(self, widget):
|
|
self.file_view.get_selection().select_all()
|
|
|
|
def file_unselect_all(self, widget):
|
|
self.file_view.get_selection().unselect_all()
|
|
|
|
def file_check_selected(self, widget):
|
|
self.file_view.get_selection().selected_foreach(self.file_toggle_selected, True)
|
|
|
|
def file_uncheck_selected(self, widget):
|
|
self.file_view.get_selection().selected_foreach(self.file_toggle_selected, False)
|
|
|
|
def file_clicked(self, path):
|
|
return not self.file_selected
|
|
|
|
def file_view_clicked(self, widget, event):
|
|
if event.button == 3:
|
|
self.file_menu.popup(None, None, None, event.button, event.time)
|
|
return True
|
|
else:
|
|
self.file_selected = False
|
|
return False
|
|
|
|
def file_toggle_selected(self, treemodel, path, selected_iter, value):
|
|
self.file_store.set_value(selected_iter, 0, value)
|
|
|
|
def file_toggled(self, renderer, path):
|
|
self.file_selected = True
|
|
file_iter = self.file_store.get_iter_from_string(path)
|
|
value = not renderer.get_active()
|
|
selection = self.file_view.get_selection()
|
|
if selection.iter_is_selected(file_iter):
|
|
selection.selected_foreach(self.file_toggle_selected, value)
|
|
else:
|
|
self.file_store.set_value(file_iter, 0, value)
|
|
file_filter = []
|
|
itr = self.file_store.get_iter_first()
|
|
while itr is not None:
|
|
file_filter.append(not self.file_store.get_value(itr, 0))
|
|
itr = self.file_store.iter_next(itr)
|
|
self.manager.set_file_filter(self.get_selected_torrent(), file_filter)
|
|
|
|
def show_about_dialog(self, arg=None):
|
|
dialogs.show_about_dialog()
|
|
|
|
def show_pref_dialog(self, arg=None):
|
|
if self.window.get_property("visible"):
|
|
# Only apply the prefs if the user pressed OK in the prefs dialog
|
|
if self.preferences_dialog.show() == 1:
|
|
self.apply_prefs()
|
|
self.config.save()
|
|
|
|
else:
|
|
if self.config.get("lock_tray") == True:
|
|
self.unlock_tray("prefwinshow")
|
|
else:
|
|
# Only apply the prefs if the user pressed OK in the prefs dialog
|
|
if self.preferences_dialog.show() == 1:
|
|
self.apply_prefs()
|
|
self.config.save()
|
|
|
|
def show_plugin_dialog(self, arg=None):
|
|
self.plugin_dialog.show()
|
|
|
|
def apply_prefs(self):
|
|
# Show tray icon if necessary
|
|
self.tray_icon.set_visible(self.config.get("enable_system_tray"))
|
|
|
|
# Update the max_*_speed_bps prefs
|
|
if self.config.get("max_upload_speed") < 0:
|
|
self.config.set("max_upload_speed_bps", -1)
|
|
else:
|
|
self.config.set("max_upload_speed_bps",
|
|
int(self.config.get("max_upload_speed") * 1024))
|
|
|
|
if self.config.get("max_download_speed") < 0:
|
|
self.config.set("max_download_speed_bps", -1)
|
|
else:
|
|
self.config.set("max_download_speed_bps",
|
|
int(self.config.get("max_download_speed") * 1024))
|
|
|
|
# Update the tray download speed limits
|
|
if self.config.get("max_download_speed") not in self.config.get("tray_downloadspeedlist") and \
|
|
self.config.get("max_download_speed") >= 0:
|
|
# We need to prepend this value and remove the last value in the list
|
|
self.config.get("tray_downloadspeedlist").insert(0, self.config.get("max_download_speed"))
|
|
self.config.get("tray_downloadspeedlist").pop()
|
|
|
|
# Do the same for the upload speed limits
|
|
if self.config.get("max_upload_speed") not in self.config.get("tray_uploadspeedlist") and \
|
|
self.config.get("max_upload_speed") >= 0:
|
|
# We need to prepend this value and remove the last value in the list
|
|
self.config.get("tray_uploadspeedlist").insert(0, self.config.get("max_upload_speed"))
|
|
self.config.get("tray_uploadspeedlist").pop()
|
|
|
|
# Re-build the tray sub-menu to display the correct active radio item
|
|
self.build_tray_bwsetsubmenu()
|
|
|
|
# Apply the preferences in the core
|
|
self.manager.apply_prefs()
|
|
self.manager.pe_settings(self.config.get("encout_state"), self.config.get("encin_state"), self.config.get("enclevel_type"), self.config.get("pref_rc4"))
|
|
self.manager.proxy_settings(self.config.get("proxy_hostname"), self.config.get("proxy_username"), self.config.get("proxy_password"), int(self.config.get("proxy_port")), self.config.get("proxy_type"), self.config.get("peer_proxy"), self.config.get("tracker_proxy"), self.config.get("dht_proxy"))
|
|
|
|
def get_message_from_state(self, torrent_state):
|
|
state = torrent_state['state']
|
|
is_paused = torrent_state['is_paused']
|
|
progress = torrent_state['progress']
|
|
progress = '%d%%'%int(progress * 100)
|
|
if is_paused:
|
|
message = _("Paused %s")%progress
|
|
else:
|
|
try:
|
|
message = _(core.STATE_MESSAGES[state])
|
|
if state in (1, 3, 4, 7):
|
|
message = '%s %s'%(message, progress)
|
|
except IndexError:
|
|
message = ''
|
|
return message
|
|
|
|
# UID, Q#, Name, Size, Progress, Message, Seeders, Peers, DL, UL, ETA, Share
|
|
def get_list_from_unique_id(self, unique_id):
|
|
state = self.manager.get_torrent_state(unique_id)
|
|
|
|
queue = int(state['queue_pos']) + 1
|
|
name = state['name']
|
|
size = long(state['total_size'])
|
|
progress = float(state['progress'] * 100)
|
|
message = self.get_message_from_state(state)
|
|
seeds = int(state['num_seeds'])
|
|
seeds_t = int(state['total_seeds'])
|
|
peers = int(state['num_peers'])
|
|
peers_t = int(state['total_peers'])
|
|
dl_speed = int(state['download_rate'])
|
|
ul_speed = int(state['upload_rate'])
|
|
try:
|
|
eta = common.get_eta(state["total_size"], state["total_done"], state["download_rate"])
|
|
except ZeroDivisionError:
|
|
eta = 0
|
|
share = float(self.calc_share_ratio(unique_id, state))
|
|
|
|
# Set the appropriate status icon
|
|
if state["is_paused"]:
|
|
status_icon = gtk.gdk.pixbuf_new_from_file(common.get_pixmap("inactive16.png"))
|
|
elif state["is_seed"]:
|
|
status_icon = gtk.gdk.pixbuf_new_from_file(common.get_pixmap("seeding16.png"))
|
|
else:
|
|
status_icon = gtk.gdk.pixbuf_new_from_file(common.get_pixmap("downloading16.png"))
|
|
|
|
rlist = [int(unique_id), queue, status_icon, name, size, progress, message,
|
|
seeds, seeds_t, peers, peers_t, dl_speed, ul_speed, int(eta), share]
|
|
|
|
return rlist
|
|
|
|
|
|
## Start the timer that updates the interface
|
|
def start(self, start_in_tray=False):
|
|
if not(start_in_tray and self.config.get("enable_system_tray") and
|
|
self.has_tray) and not self.window.get_property("visible"):
|
|
print "Showing window"
|
|
self.window.show()
|
|
# go through torrent files to add
|
|
#dummy preferences values:
|
|
use_default_download_location = True
|
|
default_download_location = "."
|
|
for torrent_file in self.torrent_file_queue:
|
|
print "adding torrent", torrent_file
|
|
try:
|
|
self.interactive_add_torrent(torrent_file, append=False)
|
|
except core.DelugeError:
|
|
print "duplicate torrent found, ignoring", torrent_file
|
|
## add torrents in manager to interface
|
|
for uid in self.manager.get_unique_IDs():
|
|
self.torrent_model.append(self.get_list_from_unique_id(uid))
|
|
|
|
# Load plugins after we showed main window (if not started in tray)
|
|
self.load_plugins()
|
|
|
|
# Call update now so everything is up-to-date when the window gains focus on startup
|
|
self.update()
|
|
|
|
gobject.timeout_add(1000, self.update)
|
|
try:
|
|
self.is_running = True
|
|
gtk.main()
|
|
except KeyboardInterrupt:
|
|
self.manager.quit()
|
|
|
|
def load_plugins(self):
|
|
enable_plugins = self.config.get('enabled_plugins').split(':')
|
|
for plugin in enable_plugins:
|
|
try:
|
|
self.plugins.enable_plugin(plugin)
|
|
except KeyError:
|
|
pass
|
|
|
|
## Call via a timer to update the interface
|
|
def update(self):
|
|
# We need to apply the queue changes
|
|
self.manager.apply_queue()
|
|
|
|
# Handle the events
|
|
self.manager.handle_events()
|
|
|
|
# Make sure that the interface still exists
|
|
try:
|
|
tab = self.wtree.get_widget("torrent_info").get_current_page()
|
|
except AttributeError:
|
|
return False
|
|
|
|
if self.something_screwed_up:
|
|
dialogs.show_popup_warning(self.window,
|
|
_("For some reason, the previous state could not be loaded, so a blank state has been loaded for you."))
|
|
restore_torrents = dialogs.show_popup_question(self.window,
|
|
_("Would you like to attempt to reload the previous session's downloads?"))
|
|
if restore_torrents:
|
|
torrent_subdir = os.path.join(self.manager.base_dir, core.TORRENTS_SUBDIR)
|
|
for torrent in os.listdir(torrent_subdir):
|
|
if torrent.endswith('.torrent'):
|
|
self.interactive_add_torrent(torrent)
|
|
self.something_screwed_up = False
|
|
|
|
# Update Statusbar and Tray Tips
|
|
core_state = self.manager.get_state()
|
|
connections = core_state['num_peers']
|
|
if self.config.get("max_connections") < 0 :
|
|
max_connections = _("Unlimited")
|
|
else:
|
|
max_connections = int(self.config.get("max_connections"))
|
|
dlspeed = common.fspeed(core_state['download_rate'])
|
|
ulspeed = common.fspeed(core_state['upload_rate'])
|
|
if self.config.get("max_download_speed") < 0:
|
|
dlspeed_max = _("Unlimited")
|
|
else:
|
|
dlspeed_max = common.fspeed(self.config.get("max_download_speed_bps"))
|
|
if self.config.get("max_upload_speed") < 0:
|
|
ulspeed_max = _("Unlimited")
|
|
else:
|
|
ulspeed_max = common.fspeed(self.config.get("max_upload_speed_bps"))
|
|
|
|
# Use self.statusbar_temp_msg instance var to allow plugins access it
|
|
self.statusbar_temp_msg = '%s: %s (%s) %s: %s (%s) %s: %s (%s)'%(
|
|
_('Connections'), connections, max_connections, _('Down Speed'),
|
|
dlspeed, dlspeed_max, _('Up Speed'), ulspeed, ulspeed_max)
|
|
|
|
if 'DHT_nodes' in core_state:
|
|
dht_peers = core_state['DHT_nodes']
|
|
if dht_peers == -1:
|
|
dht_peers = '?'
|
|
else:
|
|
dht_peers = str(dht_peers)
|
|
self.statusbar_temp_msg = self.statusbar_temp_msg + ' [DHT: %s]'%(dht_peers)
|
|
|
|
msg = _("Deluge Bittorrent Client") + "\n" + \
|
|
_("Connections") + ": " + str(connections) + " (" + str(max_connections) + ")" + "\n" + _("Down Speed") + ": " + \
|
|
dlspeed + " (" + dlspeed_max + ")" + "\n" + _("Up Speed") + ": " + ulspeed + " (" + ulspeed_max + ")"
|
|
|
|
self.tray_icon.set_tooltip(msg)
|
|
|
|
#Update any active plugins
|
|
self.plugins.update_active_plugins()
|
|
|
|
# Put the generated message into the statusbar
|
|
# This gives plugins a chance to write to the
|
|
# statusbar if they want
|
|
self.statusbar.pop(1)
|
|
self.statusbar.push(1, self.statusbar_temp_msg)
|
|
|
|
#Torrent List
|
|
itr = self.torrent_model.get_iter_first()
|
|
|
|
# Disable torrent options if there are no torrents
|
|
self.wtree.get_widget("menu_torrent").set_sensitive(itr is not None)
|
|
self.wtree.get_widget("toolbutton_remove").set_sensitive(itr is not None)
|
|
self.wtree.get_widget("toolbutton_pause").set_sensitive(itr is not None)
|
|
self.wtree.get_widget("toolbutton_up").set_sensitive(itr is not None)
|
|
self.wtree.get_widget("toolbutton_down").set_sensitive(itr is not None)
|
|
|
|
if itr is None:
|
|
return True
|
|
|
|
while itr is not None:
|
|
uid = self.torrent_model.get_value(itr, 0)
|
|
state = self.manager.get_torrent_state(uid)
|
|
tlist = self.get_list_from_unique_id(uid)
|
|
for i in range(len(tlist)):
|
|
try:
|
|
self.torrent_model.set_value(itr, i, tlist[i])
|
|
except:
|
|
print "ERR", i, type(tlist[i]), tlist[i]
|
|
itr = self.torrent_model.iter_next(itr)
|
|
|
|
# Disable moving top torrents up or bottom torrents down
|
|
top_torrents_selected = True
|
|
bottom_torrents_selected = True
|
|
|
|
torrent_selection = self.torrent_view.get_selection()
|
|
selection_count = torrent_selection.count_selected_rows()
|
|
|
|
# If no torrent is selected, select the first torrent:
|
|
if selection_count == 0:
|
|
torrent_selection.select_path("0")
|
|
selection_count = 1
|
|
|
|
for i in range(selection_count):
|
|
if not torrent_selection.path_is_selected(i):
|
|
top_torrents_selected = False
|
|
|
|
if not torrent_selection.path_is_selected(len(self.torrent_model) - 1 - i):
|
|
bottom_torrents_selected = False
|
|
|
|
self.torrent_glade.get_widget("menu_queue_top").set_sensitive(not top_torrents_selected)
|
|
self.torrent_glade.get_widget("menu_queue_up").set_sensitive(not top_torrents_selected)
|
|
self.torrent_glade.get_widget("menu_queue_down").set_sensitive(not bottom_torrents_selected)
|
|
self.torrent_glade.get_widget("menu_queue_bottom").set_sensitive(not bottom_torrents_selected)
|
|
self.wtree.get_widget("toolbutton_up").set_sensitive(not top_torrents_selected)
|
|
self.wtree.get_widget("toolbutton_down").set_sensitive(not bottom_torrents_selected)
|
|
|
|
unique_id = None
|
|
if selection_count == 1:
|
|
unique_id = self.get_selected_torrent()
|
|
self.update_torrent_info_widget(unique_id)
|
|
else: # selection_count > 1
|
|
self.clear_details_pane()
|
|
|
|
# Update tool buttons below based on the first selected torrent's state
|
|
path = torrent_selection.get_selected_rows()[1][0]
|
|
unique_id = self.torrent_model.get_value(self.torrent_model.get_iter(path), 0)
|
|
|
|
if self.manager.get_torrent_state(unique_id)["is_paused"]:
|
|
self.wtree.get_widget("toolbutton_pause").set_stock_id(gtk.STOCK_MEDIA_PLAY)
|
|
self.wtree.get_widget("toolbutton_pause").set_label(_("Resume"))
|
|
else:
|
|
self.wtree.get_widget("toolbutton_pause").set_stock_id(gtk.STOCK_MEDIA_PAUSE)
|
|
self.wtree.get_widget("toolbutton_pause").set_label(_("Pause"))
|
|
|
|
return True
|
|
|
|
def update_torrent_info_widget(self, unique_id):
|
|
tab = self.wtree.get_widget("torrent_info").get_current_page()
|
|
state = self.manager.get_torrent_state(unique_id)
|
|
|
|
if tab == 0: #Details Pane
|
|
self.wtree.get_widget("summary_name").set_text(state['name'])
|
|
self.text_summary_total_size.set_text(common.fsize(state["total_size"]))
|
|
self.text_summary_pieces.set_text(str(state["num_pieces"]))
|
|
self.text_summary_total_downloaded.set_text(common.fsize(state["total_done"]) + " (" + common.fsize(state["total_download"]) + ")")
|
|
self.text_summary_total_uploaded.set_text(common.fsize(self.manager.unique_IDs[unique_id].uploaded_memory + state["total_payload_upload"]) + " (" + common.fsize(state["total_upload"]) + ")")
|
|
self.text_summary_download_speed.set_text(common.fspeed(state["download_rate"]))
|
|
self.text_summary_upload_speed.set_text(common.fspeed(state["upload_rate"]))
|
|
self.text_summary_seeders.set_text(common.fseed(state))
|
|
self.text_summary_peers.set_text(common.fpeer(state))
|
|
self.wtree.get_widget("progressbar").set_fraction(float(state['progress']))
|
|
self.wtree.get_widget("progressbar").set_text(common.fpcnt(state["progress"]))
|
|
self.text_summary_share_ratio.set_text('%.3f'%(self.calc_share_ratio(unique_id, state)))
|
|
self.text_summary_tracker.set_text(str(state["tracker"]))
|
|
self.text_summary_tracker_status.set_text(str(state["tracker_ok"]))
|
|
self.text_summary_next_announce.set_text(str(state["next_announce"]))
|
|
self.text_summary_eta.set_text(common.estimate_eta(state))
|
|
elif tab == 1: #Peers List
|
|
def biographer(model, path, iter, dictionary):
|
|
dictionary[model.get_value(iter, 1)] = model.get_string_from_iter(iter)
|
|
|
|
class remover_data:
|
|
def __init__(self, new_ips):
|
|
self.new_ips = new_ips
|
|
self.removed = False
|
|
|
|
def remover(model, path, iter, data):
|
|
if model.get_value(iter, 1) not in data.new_ips:
|
|
model.remove(iter)
|
|
data.removed = True
|
|
return True
|
|
else:
|
|
return False
|
|
|
|
new_peer_info = self.manager.get_torrent_peer_info(unique_id)
|
|
|
|
new_ips = {}
|
|
|
|
for index in range(len(new_peer_info)):
|
|
if not new_peer_info[index]['client'] == "":
|
|
new_ips[new_peer_info[index]['ip']] = index
|
|
|
|
while True:
|
|
data = remover_data(new_ips)
|
|
self.peer_store.foreach(remover, data)
|
|
if not data.removed:
|
|
break
|
|
|
|
curr_ips = {}
|
|
|
|
self.peer_store.foreach(biographer, curr_ips)
|
|
|
|
for peer in new_peer_info:
|
|
if peer['ip'] in curr_ips:
|
|
self.peer_store.set(self.peer_store.get_iter_from_string(curr_ips[peer['ip']]),
|
|
2, unicode(peer['client'], "latin-1"),
|
|
3, round(peer["peer_has"], 2),
|
|
4, peer["download_speed"],
|
|
5, peer["upload_speed"])
|
|
|
|
if peer['ip'] not in curr_ips and peer['client'] is not "":
|
|
# convert IP adrress to int for sorting purposes
|
|
ip_int = sum([int(byte) << shift
|
|
for byte, shift in izip(peer["ip"].split("."), (24, 16, 8, 0))])
|
|
|
|
self.peer_store.append([ip_int, peer["ip"],
|
|
unicode(peer["client"], "latin-1"),
|
|
round(peer["peer_has"], 2),
|
|
peer["download_speed"],
|
|
peer["upload_speed"]])
|
|
elif tab == 2: #file tab
|
|
# Fill self.file_store with files only once and only when we click to
|
|
# file tab or it's already open
|
|
if not self.file_store.iter_n_children(None):
|
|
all_files = self.manager.get_torrent_file_info(unique_id)
|
|
file_filter = self.manager.get_file_filter(unique_id)
|
|
if file_filter is None:
|
|
file_filter = [False] * len(all_files)
|
|
for file, filt in izip(all_files, file_filter):
|
|
self.file_store.append([not filt, file['path'],
|
|
file['size'],
|
|
round(file['progress'], 2)])
|
|
|
|
def biographer(model, path, iter, dictionary):
|
|
dictionary[model.get_value(iter, 1)] = model.get_string_from_iter(iter)
|
|
|
|
new_file_info = self.manager.get_torrent_file_info(unique_id)
|
|
|
|
curr_files = {}
|
|
|
|
self.file_store.foreach(biographer, curr_files)
|
|
|
|
for file in new_file_info:
|
|
iter = self.file_store.get_iter_from_string(curr_files[file['path']])
|
|
if file['path'] in curr_files and \
|
|
self.file_store.get_value(iter, 3) != round(file['progress'], 2):
|
|
self.file_store.set(iter, 3, file['progress'])
|
|
|
|
|
|
def calc_share_ratio(self, unique_id, torrent_state):
|
|
r = float(self.manager.calc_ratio(unique_id, torrent_state))
|
|
return r
|
|
|
|
# Return the id of the last single selected torrent
|
|
def get_selected_torrent(self):
|
|
try:
|
|
if self.torrent_view.get_selection().count_selected_rows() == 1:
|
|
selected_path = self.torrent_view.get_selection().\
|
|
get_selected_rows()[1][0]
|
|
selected_torrent = self.torrent_model.get_value(self.torrent_model.get_iter(selected_path), 0)
|
|
return selected_torrent
|
|
except (TypeError, ValueError):
|
|
pass
|
|
|
|
return None
|
|
|
|
# Return a list of ids of the selected torrents
|
|
def get_selected_torrent_rows(self):
|
|
selected_ids = []
|
|
selected_paths = self.torrent_view.get_selection().get_selected_rows()[1]
|
|
|
|
try:
|
|
for path in selected_paths:
|
|
selected_ids.append(self.torrent_model.get_value(self.torrent_model.get_iter(path), 0))
|
|
return selected_ids
|
|
except ValueError:
|
|
return None
|
|
|
|
def on_drag_data(self, widget, drag_context, x, y, selection_data, info, timestamp):
|
|
uri_split = selection_data.data.strip().split()
|
|
for uri in uri_split:
|
|
path = urllib.url2pathname(uri).strip('\r\n\x00')
|
|
if path.startswith('file:\\\\\\'):
|
|
path = path[8:]
|
|
elif path.startswith('file://'):
|
|
path = path[7:]
|
|
elif path.startswith('file:'):
|
|
path = path[5:]
|
|
if path.endswith('.torrent'):
|
|
self.interactive_add_torrent(path)
|
|
|
|
def interactive_add_torrent(self, torrent, append=True):
|
|
if self.config.get('use_default_dir'):
|
|
path = self.config.get('default_download_path')
|
|
else:
|
|
path = dialogs.show_directory_chooser_dialog(self.window)
|
|
if path is None:
|
|
return
|
|
try:
|
|
unique_id = self.manager.add_torrent(torrent, path, self.config.get('use_compact_storage'))
|
|
|
|
if append:
|
|
self.torrent_model.append(self.get_list_from_unique_id(unique_id))
|
|
except core.InvalidEncodingError, e:
|
|
print "InvalidEncodingError", e
|
|
dialogs.show_popup_warning(self.window, _("An error occured while trying to add the torrent. It's possible your .torrent file is corrupted."))
|
|
except core.DuplicateTorrentError, e:
|
|
dialogs.show_popup_warning(self.window, _("The torrent you've added seems to already be in Deluge."))
|
|
except core.InsufficientFreeSpaceError, e:
|
|
nice_need = common.fsize(e.needed_space)
|
|
nice_free = common.fsize(e.free_space)
|
|
dialogs.show_popup_warning(self.window, _("There is not enough free disk space to complete your download.") + "\n" + \
|
|
_("Space Needed:") + " " + nice_need + "\n" + \
|
|
_("Available Space:") + " " + nice_free)
|
|
|
|
def launchpad(self, obj=None):
|
|
common.open_url_in_browser('self', 'https://translations.launchpad.net/deluge/trunk/+pots/deluge')
|
|
|
|
def add_torrent_clicked(self, obj=None):
|
|
torrent = dialogs.show_file_open_dialog()
|
|
if torrent is not None:
|
|
for single in torrent:
|
|
self.interactive_add_torrent(single)
|
|
|
|
def add_torrent_url_clicked(self, obj=None):
|
|
dlg = gtk.Dialog(title=_("Add torrent from URL"), parent=self.window,
|
|
buttons=(gtk.STOCK_CANCEL, 0, gtk.STOCK_OK, 1))
|
|
dlg.set_icon_from_file(common.get_pixmap("deluge32.png"))
|
|
|
|
label = gtk.Label(_("Enter the URL of the .torrent to download"))
|
|
entry = gtk.Entry()
|
|
dlg.vbox.pack_start(label)
|
|
dlg.vbox.pack_start(entry)
|
|
clip = gtk.clipboard_get(selection='PRIMARY')
|
|
text = clip.wait_for_text()
|
|
#watch out for an empty clipboard, TODO check for non url garbage
|
|
if text:
|
|
entry.set_text(text)
|
|
dlg.show_all()
|
|
result = dlg.run()
|
|
url = entry.get_text()
|
|
dlg.destroy()
|
|
|
|
if result == 1:
|
|
self.add_torrent_url(url)
|
|
|
|
def external_add_url(self, url):
|
|
print "Got URL externally:", url
|
|
if self.is_running:
|
|
print "\t\tthe client seems to already be running, i'll try and add the URL"
|
|
self.add_torrent_url(url)
|
|
else:
|
|
print "\t\tthe client hasn't started yet, I'll queue the URL torrent file"
|
|
self.queue_torrent_url(url)
|
|
|
|
def add_torrent_url(self, url):
|
|
filename, headers = self.fetch_url(url)
|
|
if filename:
|
|
self.interactive_add_torrent(filename)
|
|
|
|
def queue_torrent_url(self, url):
|
|
filename, headers = self.fetch_url(url)
|
|
if filename:
|
|
self.torrent_file_queue.append(filename)
|
|
|
|
def fetch_url(self, url):
|
|
filename, headers = urllib.urlretrieve(url)
|
|
if filename.endswith(".torrent") or headers["content-type"]=="application/x-bittorrent":
|
|
return filename, headers
|
|
else:
|
|
print "URL doesn't appear to be a valid torrent file:", url
|
|
return None, None
|
|
|
|
|
|
def remove_torrent_clicked(self, obj=None):
|
|
glade = gtk.glade.XML(common.get_glade_file("dgtkpopups.glade"), domain='deluge')
|
|
asker = glade.get_widget("remove_torrent_dlg")
|
|
|
|
asker.set_icon_from_file(common.get_pixmap("deluge32.png"))
|
|
|
|
warning = glade.get_widget("warning")
|
|
warning.set_text(" ")
|
|
|
|
torrent_also = glade.get_widget("torrent_also")
|
|
data_also = glade.get_widget("data_also")
|
|
data_also.connect("toggled", self.remove_toggle_warning, warning)
|
|
|
|
response = asker.run()
|
|
asker.destroy()
|
|
if response == 1:
|
|
self.clear_details_pane()
|
|
|
|
torrents = self.get_selected_torrent_rows()
|
|
paths = self.torrent_view.get_selection().get_selected_rows()[1]
|
|
row_references = [gtk.TreeRowReference(self.torrent_model, x)
|
|
for x in paths]
|
|
|
|
for unique_id, row_ref in izip(torrents, row_references):
|
|
self.manager.remove_torrent(unique_id, data_also.get_active(),
|
|
torrent_also.get_active())
|
|
iter = self.torrent_model.get_iter(row_ref.get_path())
|
|
self.torrent_model.remove(iter)
|
|
|
|
self.update()
|
|
|
|
def clear_details_pane(self):
|
|
self.wtree.get_widget("progressbar").set_text("")
|
|
self.wtree.get_widget("summary_name").set_text("")
|
|
self.text_summary_total_size.set_text("")
|
|
self.text_summary_pieces.set_text("")
|
|
self.text_summary_total_downloaded.set_text("")
|
|
self.text_summary_total_uploaded.set_text("")
|
|
self.text_summary_download_speed.set_text("")
|
|
self.text_summary_upload_speed.set_text("")
|
|
self.text_summary_seeders.set_text("")
|
|
self.text_summary_peers.set_text("")
|
|
self.wtree.get_widget("progressbar").set_fraction(0.0)
|
|
self.text_summary_share_ratio.set_text("")
|
|
self.text_summary_tracker.set_text("")
|
|
self.text_summary_tracker_status.set_text("")
|
|
self.text_summary_next_announce.set_text("")
|
|
self.text_summary_eta.set_text("")
|
|
self.peer_store.clear()
|
|
self.file_store.clear()
|
|
|
|
|
|
def remove_toggle_warning(self, args, warning):
|
|
if not args.get_active():
|
|
warning.set_text(" ")
|
|
else:
|
|
warning.set_markup("<i>" + _("Warning - all downloaded files for this torrent will be deleted!") + "</i>")
|
|
return False
|
|
|
|
def update_tracker(self, obj=None):
|
|
torrent = self.get_selected_torrent()
|
|
if torrent is not None:
|
|
self.manager.update_tracker(torrent)
|
|
|
|
def clear_finished(self, obj=None):
|
|
print "Clearing Completed Torrents"
|
|
self.manager.clear_completed()
|
|
self.update()
|
|
|
|
def q_torrent_up(self, obj=None):
|
|
for torrent in self.get_selected_torrent_rows():
|
|
self.manager.queue_up(torrent)
|
|
self.update()
|
|
|
|
def q_torrent_down(self, obj=None):
|
|
for torrent in reversed(self.get_selected_torrent_rows()):
|
|
self.manager.queue_down(torrent)
|
|
self.update()
|
|
|
|
def q_to_bottom(self, widget):
|
|
for torrent in self.get_selected_torrent_rows():
|
|
self.manager.queue_bottom(torrent)
|
|
self.update()
|
|
|
|
def q_to_top(self, widget):
|
|
for torrent in reversed(self.get_selected_torrent_rows()):
|
|
self.manager.queue_top(torrent)
|
|
self.update()
|
|
|
|
def toolbar_toggle(self, widget):
|
|
if widget.get_active():
|
|
self.wtree.get_widget("tb_left").show()
|
|
self.wtree.get_widget("tb_middle").show()
|
|
self.wtree.get_widget("tb_right").show()
|
|
else:
|
|
self.wtree.get_widget("tb_left").hide()
|
|
self.wtree.get_widget("tb_middle").hide()
|
|
self.wtree.get_widget("tb_right").hide()
|
|
|
|
def infopane_toggle(self, widget):
|
|
if widget.get_active():
|
|
self.wtree.get_widget("torrent_info").show()
|
|
else:
|
|
self.wtree.get_widget("torrent_info").hide()
|
|
|
|
def size_toggle(self, obj):
|
|
self.size_column.set_visible(obj.get_active())
|
|
|
|
|
|
def status_toggle(self, obj):
|
|
self.status_column.set_visible(obj.get_active())
|
|
|
|
def seeders_toggle(self, obj):
|
|
self.seed_column.set_visible(obj.get_active())
|
|
|
|
def peers_toggle(self, obj):
|
|
self.peer_column.set_visible(obj.get_active())
|
|
|
|
def dl_toggle(self, obj):
|
|
self.dl_column.set_visible(obj.get_active())
|
|
|
|
def ul_toggle(self, obj):
|
|
self.ul_column.set_visible(obj.get_active())
|
|
|
|
def eta_toggle(self, obj):
|
|
self.eta_column.set_visible(obj.get_active())
|
|
|
|
def share_toggle(self, obj):
|
|
self.share_column.set_visible(obj.get_active())
|
|
|
|
def load_window_settings(self):
|
|
self.wtree.get_widget("chk_infopane").set_active(self.config.get("show_infopane"))
|
|
self.wtree.get_widget("chk_toolbar").set_active(self.config.get("show_toolbar"))
|
|
self.wtree.get_widget("chk_size").set_active(self.config.get("show_size"))
|
|
self.wtree.get_widget("chk_status").set_active(self.config.get("show_status"))
|
|
self.wtree.get_widget("chk_seed").set_active(self.config.get("show_seeders"))
|
|
self.wtree.get_widget("chk_peer").set_active(self.config.get("show_peers"))
|
|
self.wtree.get_widget("chk_download").set_active(self.config.get("show_dl"))
|
|
self.wtree.get_widget("chk_upload").set_active(self.config.get("show_ul"))
|
|
self.wtree.get_widget("chk_eta").set_active(self.config.get("show_eta"))
|
|
self.wtree.get_widget("chk_ratio").set_active(self.config.get("show_share"))
|
|
self.wtree.get_widget("vpaned1").set_position(self.config.get("window_height") - self.config.get("window_pane_position"))
|
|
|
|
def save_window_settings(self):
|
|
self.config.set("show_infopane", self.wtree.get_widget("chk_infopane").get_active())
|
|
self.config.set("show_toolbar", self.wtree.get_widget("chk_toolbar").get_active())
|
|
self.config.set("show_size", self.size_column.get_visible())
|
|
self.config.set("show_status", self.status_column.get_visible())
|
|
self.config.set("show_seeders", self.seed_column.get_visible())
|
|
self.config.set("show_peers", self.peer_column.get_visible())
|
|
self.config.set("show_dl", self.dl_column.get_visible())
|
|
self.config.set("show_ul", self.ul_column.get_visible())
|
|
self.config.set("show_eta", self.eta_column.get_visible())
|
|
self.config.set("show_share", self.share_column.get_visible())
|
|
self.config.set("window_pane_position", self.config.get("window_height") - self.wtree.get_widget("vpaned1").get_position())
|
|
|
|
def window_configure_event(self, widget, event):
|
|
if self.config.get("window_maximized") == False:
|
|
self.config.set("window_x_pos", self.window.get_position()[0])
|
|
self.config.set("window_y_pos", self.window.get_position()[1])
|
|
self.config.set("window_width", event.width)
|
|
self.config.set("window_height", event.height)
|
|
|
|
def window_state_event(self, widget, event):
|
|
if event.changed_mask & gtk.gdk.WINDOW_STATE_MAXIMIZED:
|
|
if event.new_window_state & gtk.gdk.WINDOW_STATE_MAXIMIZED:
|
|
self.config.set("window_maximized", True)
|
|
else:
|
|
self.config.set("window_maximized", False)
|
|
return False
|
|
|
|
|
|
def load_window_geometry(self):
|
|
x = self.config.get('window_x_pos')
|
|
y = self.config.get('window_y_pos')
|
|
w = self.config.get('window_width')
|
|
h = self.config.get('window_height')
|
|
self.window.move(x, y)
|
|
self.window.resize(w, h)
|
|
if self.config.get("window_maximized") == True:
|
|
self.window.maximize()
|
|
|
|
def close(self, widget, event):
|
|
if self.config.get("close_to_tray") and self.config.get("enable_system_tray") and self.has_tray:
|
|
self.window.hide()
|
|
return True
|
|
else:
|
|
self.quit()
|
|
|
|
def quit(self, widget=None):
|
|
if self.window.get_property("visible"):
|
|
self.window.hide()
|
|
self.shutdown()
|
|
else:
|
|
if self.config.get("lock_tray") == True:
|
|
self.unlock_tray("quitus")
|
|
else:
|
|
self.window.hide()
|
|
self.shutdown()
|
|
|
|
def shutdown(self):
|
|
enabled_plugins = ':'.join(self.plugins.get_enabled_plugins())
|
|
self.config.set('enabled_plugins', enabled_plugins)
|
|
self.save_window_settings()
|
|
self.config.save()
|
|
self.plugins.shutdown_all_plugins()
|
|
self.manager.quit()
|
|
gtk.main_quit()
|
|
|
|
|
|
## For testing purposes, create a copy of the interface
|
|
if __name__ == "__main__":
|
|
interface = DelugeGTK()
|
|
interface.start()
|