git.maemo.org Git - python-purple/blob - nullclient-ecore.py

   1 import etk
   2 import ecore
   3 import purple
   4
   5 cbs = {}
   6 conn_cbs = {}
   7 conv_cbs = {}
   8 notify_cbs = {}
   9 request_cbs = {}
  10
  11 def account_callback(name):
  12     print "---- account callback example: %s" % name
  13
  14 def blist_callback(name):
  15     print "---- blist callback example: %s" % name
  16
  17 def conn_callback(name):
  18     print "---- connection callback example: %s" % name
  19
  20 def conn_progress_cb(data):
  21     return "Connection in progress..."
  22
  23 #conn_cbs["connect_progress"] = conn_progress_cb
  24 #conn_cbs["connected"] = conn_callback
  25 #conn_cbs["disconnected"] = conn_callback
  26 conn_cbs["notice"] = conn_callback
  27 conn_cbs["report_disconnect"] = conn_callback
  28 conn_cbs["network_connected"] = conn_callback
  29 conn_cbs["network_disconnected"] = conn_callback
  30 conn_cbs["report_disconnect_reason"] = conn_callback
  31
  32 cbs["connection"] = conn_cbs
  33
  34 def conv_callback(name):
  35     print "---- conversation callback example: %s" % name
  36
  37 #conv_cbs["create_conversation"] = conv_callback
  38 #conv_cbs["destroy_conversation"] = conv_callback
  39 conv_cbs["write_chat"] = conv_callback
  40 conv_cbs["write_conv"] = conv_callback
  41 #conv_cbs["write_im"] = conv_callback
  42 conv_cbs["chat_add_users"] = conv_callback
  43 conv_cbs["chat_rename_user"] = conv_callback
  44 conv_cbs["chat_remove_users"] = conv_callback
  45 conv_cbs["chat_update_user"] = conv_callback
  46 conv_cbs["present"] = conv_callback
  47 conv_cbs["has_focus"] = conv_callback
  48 conv_cbs["custom_smiley_add"] = conv_callback
  49 conv_cbs["custom_smiley_write"] = conv_callback
  50 conv_cbs["custom_smiley_close"] = conv_callback
  51 conv_cbs["send_confirm"] = conv_callback
  52
  53 cbs["conversation"] = conv_cbs
  54
  55 def notify_callback(name):
  56     print "----  notify callback example: %s" % name
  57
  58 notify_cbs["notify_message"] = notify_callback
  59 notify_cbs["notify_email"] = notify_callback
  60 notify_cbs["notify_emails"] = notify_callback
  61 notify_cbs["notify_formatted"] = notify_callback
  62 notify_cbs["notify_searchresults"] = notify_callback
  63 notify_cbs["notify_searchresults_new_rows"] = notify_callback
  64 notify_cbs["notify_userinfo"] = notify_callback
  65 notify_cbs["notify_uri"] = notify_callback
  66 notify_cbs["close_notify"] = notify_callback
  67
  68 cbs["notify"] = notify_cbs
  69
  70 def request_callback(name):
  71     print "---- request callback example: %s" % name
  72
  73 request_cbs["request_input"] = request_callback
  74 request_cbs["request_choice"] = request_callback
  75 request_cbs["request_action"] = request_callback
  76 request_cbs["request_fields"] = request_callback
  77 request_cbs["request_file"] = request_callback
  78 request_cbs["close_request"] = request_callback
  79 request_cbs["request_folder"] = request_callback
  80
  81 cbs["request"] = request_cbs
  82
  83 class MainWindow:
  84     def __init__(self, quit_cb):
  85         global conv_cbs
  86         global signal_cbs
  87         self.bt_cbs = {}
  88         self.new_acc_bt_cbs = {}
  89         self.send_cbs = {}
  90         self.quit_cb = quit_cb
  91         conv_cbs["write_im"] = self._write_im_cb
  92
  93     def init_window(self):
  94         # Main vbox
  95         vbox = etk.VBox(homogeneous=False)
  96
  97         hbox_cmd = etk.HBox(homogeneous=False)
  98         self.cmd_entry = etk.Entry()
  99         self.lcmd = etk.Label(text="Type your message: ")
 100         hbox_cmd.append(self.lcmd, etk.HBox.START, etk.HBox.START, 0)
 101         hbox_cmd.append(self.cmd_entry, etk.HBox.START, etk.HBox.EXPAND_FILL, 0)
 102
 103         vbox_accs = etk.VBox()
 104         self.accslistmodel = etk.ListModel()
 105         self.accslist = etk.List(model=self.accslistmodel,\
 106                 columns=[(10, etk.TextRenderer(slot=0),\
 107                 False)], selectable=True,\
 108                 animated_changes=True)
 109         vbox_accs.append(self.accslist, etk.VBox.START, etk.VBox.EXPAND_FILL, 0)
 110
 111         hbox_buttons = etk.HBox(homogeneous=False)
 112         send_bt = etk.Button(label="Send")
 113         send_bt.on_clicked(self._send_bt_cb)
 114         conn_bt = etk.Button(label="Connect")
 115         conn_bt.on_clicked(self.login_window)
 116         new_account_bt = etk.Button(label="New Account")
 117         new_account_bt.on_clicked(self._new_account)
 118         hbox_buttons.append(send_bt, etk.HBox.START, etk.HBox.NONE, 0)
 119         hbox_buttons.append(conn_bt, etk.HBox.START, etk.HBox.NONE, 0)
 120         hbox_buttons.append(new_account_bt, etk.HBox.START, etk.HBox.NONE, 0)
 121
 122         hbox_panel = etk.HBox()
 123
 124         vbox_buddies = etk.VBox()
 125         self.blistmodel = etk.ListModel()
 126         self.blist = etk.List(model=self.blistmodel,\
 127                                      columns=[(10, etk.TextRenderer(slot=0), False)],\
 128                                      selectable=True, animated_changes=True)
 129         vbox_buddies.append(self.blist, etk.VBox.START, etk.VBox.EXPAND_FILL, 0)
 130
 131         vbox_txt_area = etk.VBox()
 132         self.txt_area = etk.Label()
 133         self.txt_area.text = "<br> "
 134
 135         vbox_txt_area.append(self.txt_area, etk.VBox.START, etk.VBox.EXPAND_FILL, 0)
 136
 137         hbox_panel.append(vbox_txt_area, etk.HBox.START, etk.HBox.EXPAND_FILL, 0)
 138         hbox_panel.append(vbox_buddies, etk.HBox.END, etk.HBox.EXPAND_FILL, 0)
 139         hbox_panel.append(vbox_accs, etk.HBox.END, etk.HBox.EXPAND_FILL, 0)
 140
 141         self.lstatus = etk.Label(text="Connection status")
 142
 143         vbox.append(hbox_panel, etk.VBox.START, etk.VBox.EXPAND_FILL, 0)
 144         vbox.append(hbox_cmd, etk.VBox.END, etk.VBox.FILL, 0)
 145         vbox.append(hbox_buttons, etk.VBox.END, etk.VBox.NONE, 5)
 146         vbox.append(self.lstatus, etk.VBox.END, etk.VBox.FILL, 0)
 147
 148         self._window = etk.Window(title="NullClient-Etk", size_request=(600, 600), child=vbox)
 149         self._window.on_destroyed(self.quit_cb)
 150         self.set_global_callbacks()
 151         self._window.show_all()
 152
 153     def login_window(self, pointer):
 154         self.login_password = etk.Entry()
 155         confirm_login_bt = etk.Button(label="Ok")
 156         confirm_login_bt.on_clicked(self._conn_bt_cb)
 157         vbox_login =  etk.VBox()
 158         vbox_login.append(self.login_password, etk.VBox.START, etk.VBox.FILL, 0)
 159         vbox_login.append(confirm_login_bt, etk.VBox.END, etk.VBox.NONE, 0)
 160         self.login_win = etk.Window(title="Password", size_request=(190, 80),
 161                 child=vbox_login)
 162         self.login_win.show_all()
 163
 164     def set_global_callbacks(self):
 165         global cbs
 166         cbs["connection"]["connect_progress"] = self._purple_conn_status_cb
 167         cbs["connection"]["disconnected"] = self._purple_disconnected_status_cb
 168         cbs["connection"]["connected"] = self._purple_connected_cb
 169
 170     def _conn_bt_cb(self, pointer):
 171         if self.bt_cbs.has_key("on_clicked"):
 172             self.bt_cbs["on_clicked"](self.login_password.text)
 173             self.login_win.destroy()
 174
 175     def _send_bt_cb(self, pointer):
 176         bname = self.blist.selected_rows[0][0]
 177         msg = self.cmd_entry.text
 178         if bname and msg != "":
 179             if self.send_cbs.has_key("on_clicked"):
 180                 self.send_cbs["on_clicked"](bname, msg)
 181         else:
 182             print "Buddy not selected!"
 183         self.cmd_entry.text = ""
 184
 185     def selected_accs(self):
 186         try:
 187             acc = self.accslist.selected_rows[0][0]
 188             if acc:
 189                 return acc
 190             else:
 191                 return None
 192         except:
 193             return None
 194
 195     def _new_account(self, pointer):
 196         if self.new_acc_bt_cbs.has_key("on_clicked"):
 197             self.new_acc_bt_cbs["on_clicked"]()
 198
 199     def _purple_conn_status_cb(self, txt, step, step_count):
 200             self.lstatus.text = txt
 201
 202     def _purple_connected_cb(self):
 203         self.lstatus.text = "Connected"
 204
 205     def new_buddy(self, b):
 206             if [b] not in self.blistmodel.elements:
 207                 self.blistmodel.append([b])
 208
 209     def remove_buddy(self, bname):
 210         self.blistmodel.remove([bname])
 211
 212     def new_account(self, a):
 213         if [a] not in self.accslistmodel.elements:
 214             self.accslistmodel.append([a])
 215
 216     def _purple_disconnected_status_cb(self):
 217         self.lstatus.text = "Disconnected"
 218
 219     def set_panel_text(self, txt):
 220         self.txt_area = txt
 221
 222     def add_bt_conn_cb(self, cb):
 223         if callable(cb):
 224             self.bt_cbs["on_clicked"] = cb
 225
 226     def add_account_cb(self, cb):
 227         if callable(cb):
 228             self.new_acc_bt_cbs["on_clicked"] = cb
 229
 230     def add_send_cb(self, cb):
 231         if callable(cb):
 232             self.send_cbs["on_clicked"] = cb
 233
 234     def add_quit_cb(self, cb):
 235         if callable(cb):
 236             self.quit_cb = cb
 237
 238     def _write_im_cb(self, sender, alias, message):
 239         if alias:
 240             self.txt_area.text += alias + ": " + message + "<br> "
 241         else:
 242             self.txt_area.text += sender + ": " + message + "<br> "
 243         self._window.show_all()
 244
 245
 246 class NullClientPurple:
 247     def __init__(self):
 248         self.p = purple.Purple(debug_enabled=False)
 249         self.window = MainWindow(self.quit)
 250         self.buddies = {} #all buddies
 251         self.conversations = {}
 252         self.protocol_id = "prpl-jabber"
 253         self.account = None
 254         self.accs = None
 255
 256
 257         self.p.add_account_cb("notify_added", account_callback)
 258         self.p.add_account_cb("status_changed", account_callback)
 259         self.p.add_account_cb("request_add", account_callback)
 260         self.p.add_account_cb("request_authorize", account_callback)
 261         self.p.add_account_cb("close_account_request", account_callback)
 262
 263         self.p.add_blist_cb("set_visible", blist_callback)
 264         self.p.add_blist_cb("request_add_buddy", blist_callback)
 265         self.p.add_blist_cb("request_add_chat", blist_callback)
 266         self.p.add_blist_cb("request_add_group", blist_callback)
 267         self.p.add_blist_cb("update", self._purple_update_blist_cb)
 268
 269         self.p.purple_init(cbs)
 270
 271         #Initializing UI
 272         self.window.add_bt_conn_cb(self.connect)
 273         self.window.add_send_cb(self.send_msg)
 274         self.window.add_account_cb(self.add_account)
 275         self.window.init_window()
 276
 277     def _purple_update_blist_cb(self, type, name=None, alias=None, \
 278                                 totalsize=None, currentsize=None, \
 279                                 online=None):
 280         if self.account and name != None and type == 2:
 281             if not self.buddies.has_key(name):
 282                 b = purple.Buddy()
 283                 b.new_buddy(self.account, name, alias)
 284                 self.buddies[name] = b
 285             elif self.buddies[name].online:
 286                 self.window.new_buddy(name)
 287
 288     def _purple_signal_buddy_signed_off_cb(self, name, alias):
 289         if self.buddies.has_key(name):
 290             self.buddies[name] = None
 291             self.buddies.pop(name)
 292             print "[DEBUG]: Buddy removed!"
 293         self.window.remove_buddy(name)
 294
 295     def _purple_create_conv_cb(self, name, type):
 296         bname = name.split("/")[0]
 297         if bname in self.buddies and not self.conversations.has_key(name):
 298             conv = purple.Conversation()
 299             conv.initialize(self.account, "IM", bname)
 300             self.conversations[bname] = conv
 301
 302     def connect(self, password):
 303         username_acc = self.window.selected_accs()
 304         if username_acc:
 305             self.account = self.p.account_verify(username_acc)
 306             self.account.get_protocol_options()
 307             self.account.set_enabled("carman-purple-python", True)
 308             self.account.password = password
 309             self.p.connect()
 310             self.p.signal_connect("buddy-signed-off", self._purple_signal_buddy_signed_off_cb)
 311
 312     def add_account(self):
 313         username = "carmanplugintest@gmail.com"
 314         host = "172.18.216.211"
 315         port = 8080
 316         self.p.account_add(username, self.protocol_id, host, port)
 317         self.accs = self.p.accounts
 318         for acc in self.accs.keys():
 319             self.window.new_account(acc)
 320
 321     def send_msg(self, name, msg):
 322         if not self.conversations.has_key(name):
 323             conv = purple.Conversation()
 324             conv.initialize(self.account, "IM", name)
 325             self.conversations[name] = conv
 326         self.conversations[name].write(msg)
 327
 328     def quit(self, o):
 329         print "[DEBUG]: quitting"
 330         for i in self.conversations:
 331             self.conversations[i].destroy()
 332             self.conversations[i] = None
 333         self.conversations = None
 334         self.p.destroy()
 335         ecore.main_loop_quit()
 336
 337 if __name__ == '__main__':
 338     nullpurple = NullClientPurple()
 339     ecore.main_loop_begin()