Added more functionality to gui

1 files changed, 59 insertions, 0 deletions

diff --git a/src/Gui/CCDBusBackend.py b/src/Gui/CCDBusBackend.py
new file mode 100644
index 0000000..ad3e82c
--- /dev/null
+++ b/src/Gui/CCDBusBackend.py
@@ -0,0 +1,59 @@
+#!/usr/bin/env python
+
+import dbus
+import gobject
+from dbus.mainloop.glib import DBusGMainLoop
+import gtk
+
+CC_IFACE = 'com.redhat.crash_catcher'
+CC_PATH = '/com/redhat/crash_catcher'
+        
+
+class DBusManager(gobject.GObject):
+    """ Class to provide communication with daemon over dbus """
+    # and later with policyKit
+    def __init__(self):
+        gobject.GObject.__init__(self)
+        # signal emited when new crash is detected
+        gobject.signal_new ("crash", self ,gobject.SIGNAL_RUN_FIRST,gobject.TYPE_NONE,())
+        # binds the dbus to glib mainloop
+        DBusGMainLoop(set_as_default=True)
+        self.proxy = None
+        self.connect_to_daemon()
+        if self.proxy:
+            self.cc = dbus.Interface(self.proxy, dbus_interface=CC_IFACE)
+            #intr = dbus.Interface(proxy, dbus_interface='org.freedesktop.DBus.Introspectable')
+            self.proxy.connect_to_signal("Crash",self.crash_cb,dbus_interface=CC_IFACE)
+        else:
+            raise Exception("Proxy object doesn't exist!")
+
+    # disconnect callback
+    def disconnected(*args):
+        print "disconnect"
+    
+    def crash_cb(self,*args):
+        #FIXME "got another crash, gui should reload!"
+        #for arg in args:
+        #    print arg
+        #emit a signal
+        #print "crash"
+        self.emit("crash")
+        
+    def connect_to_daemon(self):
+        bus = dbus.SystemBus()
+        if not bus:
+            raise Exception("Can't connect to dbus")
+        try:
+            self.proxy = bus.get_object(CC_IFACE, CC_PATH)
+        except Exception, e:
+            raise Exception(e.message + "\nPlease check if crash-catcher daemon is running.")
+
+    def getDumps(self):
+        row_dict = None
+        rows = []
+        for row in self.cc.GetCrashInfosMap(""):
+            row_dict = {}
+            for column in row:
+                row_dict[column] = row[column]
+            rows.append(row_dict);
+        return rows