#!/usr/bin/env python # # interface.py # # Copyright (C) Zach Tibbitts 2006 # # 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, os, os.path, urllib import core, common, dgtk, ipc_manager, dialogs import plugins, pref import pygtk pygtk.require('2.0') import gtk, gtk.glade, gobject import xdg, xdg.BaseDirectory import gettext, 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.update_queue = [] 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() # Load plugins after GTK is initialised self.update_queue.append(self.load_plugins) 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, ## 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_rate"), _("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_rate"), _("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")) rate_dialog = dialog_glade.get_widget("rate_dialog") spin_rate = dialog_glade.get_widget("spin_rate") spin_rate.set_value(self.config.get("max_download_rate")) spin_rate.select_region(0, -1) response = rate_dialog.run() if response == 1: # OK Response str_bwdown = spin_rate.get_value() else: rate_dialog.destroy() return rate_dialog.destroy() self.config.set("max_download_rate", 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")) rate_dialog = dialog_glade.get_widget("rate_dialog") spin_rate = dialog_glade.get_widget("spin_rate") spin_rate.set_value(self.config.get("max_upload_rate")) spin_rate.select_region(0, -1) response = rate_dialog.run() if response == 1: # OK Response str_bwup = spin_rate.get_value() else: rate_dialog.destroy() return rate_dialog.destroy() self.config.set("max_upload_rate", 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, int, gtk.gdk.Pixbuf, str, str, float, str, int, int, int, int, int, int, str, 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) self.torrent_selected = None 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 rate(column, cell, model, iter, data): rate = int(model.get_value(iter, data)) rate_str = common.frate(rate) cell.set_property('text', rate_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"), 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, _("Download"), rate, TORRENT_VIEW_COL_DOWNLOAD) self.ul_column = dgtk.add_func_column(self.torrent_view, _("Upload"), rate, 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) def long_sort(model, iter1, iter2, data): value1 = long(model.get_value(iter1, data)) value2 = long(model.get_value(iter2, data)) if value1 < value2: return -1 elif value1 > value2: return 1 else: return 0 self.torrent_model.set_sort_func(TORRENT_VIEW_COL_QUEUE, long_sort, TORRENT_VIEW_COL_QUEUE) self.torrent_model.set_sort_func(TORRENT_VIEW_COL_SIZE, long_sort, TORRENT_VIEW_COL_SIZE) self.torrent_model.set_sort_func(TORRENT_VIEW_COL_ETA, long_sort, TORRENT_VIEW_COL_ETA) 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 unique_id = model.get_value(model.get_iter(path), 0) state = self.manager.get_torrent_state(unique_id) # A new torrent has been selected, need to update parts of interface 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_tracker.set_text(str(state["tracker"])) # Now for the File tab self.file_store.clear() 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) assert(len(all_files) == len(file_filter)) i=0 for f in all_files: self.file_store.append([not file_filter[i], f['path'], common.fsize(f['size']), f['offset'], round(f['progress'],2)]) i=i+1 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_rate = self.wtree.get_widget("summary_download_rate") self.text_summary_upload_rate = self.wtree.get_widget("summary_upload_rate") 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") self.peer_store = gtk.ListStore(str, str, float, str, str) 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"), 0) self.peer_client_column = dgtk.add_text_column(self.peer_view, _("Client"), 1) self.peer_complete_column = dgtk.add_func_column(self.peer_view, _("Percent Complete"), percent, 2) self.peer_download_column = dgtk.add_text_column(self.peer_view, _("Download Rate"), 3) self.peer_upload_column = dgtk.add_text_column(self.peer_view, _("Upload Rate"), 4) 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, str, str, 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_text_column(self.file_view, _("Size"), 2) dgtk.add_text_column(self.file_view, _("Offset"), 3) dgtk.add_func_column(self.file_view, _("Progress"), percent, 4) 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 file_get_iter_from_name(self, name): iter = self.file_store.get_iter_first() while iter: if self.file_store.get_value(iter, 1) == name: return iter iter = self.file_store.iter_next(iter) return None 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_*_rate_bps prefs if self.config.get("max_upload_rate") < 0: self.config.set("max_upload_rate_bps", -1) else: self.config.set("max_upload_rate_bps", int(self.config.get("max_upload_rate") * 1024)) if self.config.get("max_download_rate") < 0: self.config.set("max_download_rate_bps", -1) else: self.config.set("max_download_rate_bps", int(self.config.get("max_download_rate") * 1024)) # Update the tray download speed limits if self.config.get("max_download_rate") not in self.config.get("tray_downloadspeedlist") and self.config.get("max_download_rate") >= 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_rate")) self.config.get("tray_downloadspeedlist").pop() # Do the same for the upload speed limits if self.config.get("max_upload_rate") not in self.config.get("tray_uploadspeedlist") and self.config.get("max_upload_rate") >= 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_rate")) 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']) dlrate = int(state['download_rate']) ulrate = 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), int(queue), status_icon, str(name), long(size), float(progress), str(message), int(seeds), int(seeds_t), int(peers), int(peers_t), int(dlrate), int(ulrate), int(eta), float(share)] return rlist ## Start the timer that updates the interface def start(self): if not (self.window.flags() & gtk.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 # self.torrent_model.append([0, 1, "Hello, World", 2048, 50.0, "Hi", 1, 2, 1, 2, 2048, 2048, 120, 1.0]) for uid in self.manager.get_unique_IDs(): self.torrent_model.append(self.get_list_from_unique_id(uid)) # 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): self.update_queue.reverse() while len(self.update_queue) > 0: f = self.update_queue.pop() f() # 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")) dlrate = common.frate(core_state['download_rate']) ulrate = common.frate(core_state['upload_rate']) if self.config.get("max_download_rate") < 0: dlrate_max = _("Unlimited") else: dlrate_max = common.frate(self.config.get("max_download_rate_bps")) if self.config.get("max_upload_rate") < 0: ulrate_max = _("Unlimited") else: ulrate_max = common.frate(self.config.get("max_upload_rate_bps")) self.statusbar_temp_msg = '%s: %s (%s) %s: %s (%s) %s: %s (%s)'%( _('Connections'), connections, max_connections, _('Download'), dlrate, dlrate_max, _('Upload'), ulrate, ulrate_max) if 'DHT_nodes' in core_state.keys(): 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" + _("Download") + ": " + \ dlrate + " (" + dlrate_max + ")" + "\n" + _("Upload") + ": " + ulrate + " (" + ulrate_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) # If no torrent is selected, select the first torrent: if self.torrent_selected is None: self.torrent_view.get_selection().select_path("0") #Torrent List itr = self.torrent_model.get_iter_first() if itr is None: return True while itr is not None: uid = self.torrent_model.get_value(itr, 0) try: 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) except core.InvalidUniqueIDError: self.torrent_model.remove(itr) if not self.torrent_model.iter_is_valid(itr): itr = None has_selected_torrents = self.torrent_view.get_selection().count_selected_rows() > 0 self.wtree.get_widget("menu_torrent").set_sensitive(has_selected_torrents) self.wtree.get_widget("toolbutton_remove").set_sensitive(has_selected_torrents) self.wtree.get_widget("toolbutton_pause").set_sensitive(has_selected_torrents) self.wtree.get_widget("toolbutton_up").set_sensitive(has_selected_torrents) self.wtree.get_widget("toolbutton_down").set_sensitive(has_selected_torrents) if not has_selected_torrents: return True try: if self.manager.get_torrent_state(self.get_selected_torrent())["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")) except KeyError: pass try: state = self.manager.get_torrent_state(self.get_selected_torrent()) except core.InvalidUniqueIDError: return True 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[self.get_selected_torrent()].uploaded_memory + state["total_payload_upload"]) + " (" + common.fsize(state["total_upload"]) + ")") self.text_summary_download_rate.set_text(common.frate(state["download_rate"])) self.text_summary_upload_rate.set_text(common.frate(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(self.get_selected_torrent(), 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): assert(model.get_value(iter, 0) not in dictionary.keys()) dictionary[model.get_value(iter, 0)] = 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, 0) not in data.new_ips: model.remove(iter) data.removed = True return True else: return False unique_id = self.get_selected_torrent() 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'] == "": assert(new_peer_info[index]['ip'] not in new_ips.keys()) new_ips[new_peer_info[index]['ip']] = index while True: data = remover_data(new_ips.keys()) self.peer_store.foreach(remover, data) if not data.removed: break curr_ips = {} self.peer_store.foreach(biographer, curr_ips) assert(self.peer_store.iter_n_children(None) == len(curr_ips.keys())) for peer in new_peer_info: if peer['ip'] in curr_ips.keys(): self.peer_store.set(self.peer_store.get_iter_from_string(curr_ips[peer['ip']]), 1, unicode(peer['client'], "latin-1"), 2, round(peer["peer_has"],2), 3, common.frate(peer["download_speed"]), 4, common.frate(peer["upload_speed"])) if peer['ip'] not in curr_ips.keys() and peer['client'] is not "": self.peer_store.append([peer["ip"], unicode(peer["client"], "latin-1"), round(peer["peer_has"],2), common.frate(peer["download_speed"]), common.frate(peer["upload_speed"])]) del new_peer_info del new_ips del curr_ips elif tab == 2: #file tab unique_id = self.get_selected_torrent() new_file_info = self.manager.get_torrent_file_info(unique_id) for file in new_file_info: iter = self.file_get_iter_from_name(file['path']) if (iter != None) and (round(self.file_store.get_value(iter, 4),2) != round(file['progress'],2)): self.file_store.set_value(iter, 4, round(file['progress'],2)) return True else: pass return True 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: self.torrent_selected = self.torrent_view.get_selection().get_selected_rows()[1][0] selected_torrent = self.torrent_model.get_value(self.torrent_model.get_iter(self.torrent_selected), 0) return selected_torrent except TypeError, ValueError: 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 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() 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: torrent_list = self.get_selected_torrent_rows() self.clear_details_pane() self.torrent_selected = None for torrent in torrent_list: self.manager.remove_torrent(torrent, data_also.get_active(), torrent_also.get_active()) 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_rate.set_text("") self.text_summary_upload_rate.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("" + _("Warning - all downloaded files for this torrent will be deleted!") + "") 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): torrent = self.get_selected_torrent() if torrent is not None: self.manager.queue_up(torrent) self.update() def q_torrent_down(self, obj=None): torrent = self.get_selected_torrent() if torrent is not None: self.manager.queue_down(torrent) self.update() def q_to_bottom(self, widget): torrent = self.get_selected_torrent() if torrent is not None: self.manager.queue_bottom(torrent) self.update() def q_to_top(self, widget): torrent = self.get_selected_torrent() if torrent is not None: 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()