ipc_manager

src/delugegtk.py

@@ -21,7 +21,7 @@
 # 	Boston, MA  02110-1301, USA.
 
 import sys, os, os.path, gettext, urllib
-import deluge, dcommon, dgtk
+import deluge, dcommon, dgtk, ipc_manager
 import delugeplugins, pref
 import pygtk
 pygtk.require('2.0')
@@ -39,34 +39,12 @@ elif dbus_version >= (0,80,0):
 else:
 	pass
 
-class DelugeDBus(dbus.service.Object):
-	def __init__(self, interface, object_path='/org/deluge_torrent/DelugeObject'):
-		self.interface = interface
-		self.bus = dbus.SessionBus()
-		bus_name = dbus.service.BusName("org.deluge_torrent.Deluge", bus=self.bus)
-		dbus.service.Object.__init__(self, bus_name, object_path)
-
-	## external_add_torrent should only be called from outside the class	
-	@dbus.service.method('org.deluge_torrent.Deluge')
-	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.interface.is_running:
-			print "\t\tthe client seems to already be running, i'll try and add the torrent"
-			uid = self.interface.interactive_add_torrent(torrent_file)
-		else:
-			print "\t\tthe client hasn't started yet, I'll queue the torrent"
-			self.interface.torrent_file_queue.append(torrent_file)
-
-	
 
 class DelugeGTK:
 
 	def __init__(self):
 		self.is_running = False
-		self.dbus_object = DelugeDBus(self)
+		self.ipc_manager = ipc_manager.Manager(self)
 		self.torrent_file_queue = []
 		#Load up a config file:
 		self.conf_file = dcommon.CONFIG_DIR + '/deluge.conf'
@@ -125,6 +103,18 @@ class DelugeGTK:
 			except KeyError:
 				pass
 		self.apply_prefs()
+
+	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({

src/ipc_manager.py

@@ -0,0 +1,45 @@
+# ipc_manager.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.
+
+import dbus, dbus.service
+dbus_version = getattr(dbus, 'version', (0,0,0))
+if dbus_version >= (0,41,0) and dbus_version < (0,80,0):
+	dbus.SessionBus()
+	import dbus.glib
+elif dbus_version >= (0,80,0):
+	from dbus.mainloop.glib import DBusGMainLoop
+	DBusGMainLoop(set_as_default=True)
+	dbus.SessionBus()
+else:
+	pass
+	
+class Manager(dbus.service.Object):
+	def __init__(self, interface, object_path='/org/deluge_torrent/DelugeObject'):
+		self.interface = interface
+		self.bus = dbus.SessionBus()
+		bus_name = dbus.service.BusName("org.deluge_torrent.Deluge", bus=self.bus)
+		dbus.service.Object.__init__(self, bus_name, object_path)
+
+	## external_add_torrent should only be called from outside the class	
+	@dbus.service.method('org.deluge_torrent.Deluge')
+	def external_add_torrent(self, torrent_file):
+		self.interface.external_add_torrent(torrent_file)
+
+