X-Git-Url: http://git.maemo.org/git/?p=python-purple;a=blobdiff_plain;f=nullclient-ecore.py;h=4691910e5b158626af696c47fca9bc7d3f68e3d3;hp=50e21a06640688b36043a65bf91a97d9ebf11364;hb=14e5eeb47b8ddc28b1d35fa74126e3cf18ace098;hpb=445c387d8067391f329186a13ce482dbb3c64c80 diff --git a/nullclient-ecore.py b/nullclient-ecore.py index 50e21a0..4691910 100644 --- a/nullclient-ecore.py +++ b/nullclient-ecore.py @@ -1,94 +1,16 @@ +#!/usr/bin/env python + import etk import ecore import purple - -cbs = {} -conn_cbs = {} -conv_cbs = {} -notify_cbs = {} -request_cbs = {} - -def account_callback(name): - print "---- account callback example: %s" % name - -def blist_callback(name): - print "---- blist callback example: %s" % name - -def conn_callback(name): - print "---- connection callback example: %s" % name - -def conn_progress_cb(data): - return "Connection in progress..." - -#conn_cbs["connect_progress"] = conn_progress_cb -#conn_cbs["connected"] = conn_callback -#conn_cbs["disconnected"] = conn_callback -conn_cbs["notice"] = conn_callback -conn_cbs["report_disconnect"] = conn_callback -conn_cbs["network_connected"] = conn_callback -conn_cbs["network_disconnected"] = conn_callback -conn_cbs["report_disconnect_reason"] = conn_callback - -cbs["connection"] = conn_cbs - -def conv_callback(name): - print "---- conversation callback example: %s" % name - -#conv_cbs["create_conversation"] = conv_callback -#conv_cbs["destroy_conversation"] = conv_callback -conv_cbs["write_chat"] = conv_callback -conv_cbs["write_conv"] = conv_callback -#conv_cbs["write_im"] = conv_callback -conv_cbs["chat_add_users"] = conv_callback -conv_cbs["chat_rename_user"] = conv_callback -conv_cbs["chat_remove_users"] = conv_callback -conv_cbs["chat_update_user"] = conv_callback -conv_cbs["present"] = conv_callback -conv_cbs["has_focus"] = conv_callback -conv_cbs["custom_smiley_add"] = conv_callback -conv_cbs["custom_smiley_write"] = conv_callback -conv_cbs["custom_smiley_close"] = conv_callback -conv_cbs["send_confirm"] = conv_callback - -cbs["conversation"] = conv_cbs - -def notify_callback(name): - print "---- notify callback example: %s" % name - -notify_cbs["notify_message"] = notify_callback -notify_cbs["notify_email"] = notify_callback -notify_cbs["notify_emails"] = notify_callback -notify_cbs["notify_formatted"] = notify_callback -notify_cbs["notify_searchresults"] = notify_callback -notify_cbs["notify_searchresults_new_rows"] = notify_callback -notify_cbs["notify_userinfo"] = notify_callback -notify_cbs["notify_uri"] = notify_callback -notify_cbs["close_notify"] = notify_callback - -cbs["notify"] = notify_cbs - -def request_callback(name): - print "---- request callback example: %s" % name - -request_cbs["request_input"] = request_callback -request_cbs["request_choice"] = request_callback -request_cbs["request_action"] = request_callback -request_cbs["request_fields"] = request_callback -request_cbs["request_file"] = request_callback -request_cbs["close_request"] = request_callback -request_cbs["request_folder"] = request_callback - -cbs["request"] = request_cbs +#from xml.dom import minidom class MainWindow: def __init__(self, quit_cb): - global conv_cbs - global signal_cbs self.bt_cbs = {} self.new_acc_bt_cbs = {} self.send_cbs = {} self.quit_cb = quit_cb - conv_cbs["write_im"] = self._write_im_cb def init_window(self): # Main vbox @@ -147,7 +69,6 @@ class MainWindow: self._window = etk.Window(title="NullClient-Etk", size_request=(600, 600), child=vbox) self._window.on_destroyed(self.quit_cb) - self.set_global_callbacks() self._window.show_all() def login_window(self, pointer): @@ -161,12 +82,6 @@ class MainWindow: child=vbox_login) self.login_win.show_all() - def set_global_callbacks(self): - global cbs - cbs["connection"]["connect_progress"] = self._purple_conn_status_cb - cbs["connection"]["disconnected"] = self._purple_disconnected_status_cb - cbs["connection"]["connected"] = self._purple_connected_cb - def _conn_bt_cb(self, pointer): if self.bt_cbs.has_key("on_clicked"): self.bt_cbs["on_clicked"](self.login_password.text) @@ -196,11 +111,6 @@ class MainWindow: if self.new_acc_bt_cbs.has_key("on_clicked"): self.new_acc_bt_cbs["on_clicked"]() - def _purple_conn_status_cb(self, txt, step, step_count): - self.lstatus.text = txt - - def _purple_connected_cb(self): - self.lstatus.text = "Connected" def new_buddy(self, b): if [b] not in self.blistmodel.elements: @@ -213,9 +123,6 @@ class MainWindow: if [a] not in self.accslistmodel.elements: self.accslistmodel.append([a]) - def _purple_disconnected_status_cb(self): - self.lstatus.text = "Disconnected" - def set_panel_text(self, txt): self.txt_area = txt @@ -235,38 +142,26 @@ class MainWindow: if callable(cb): self.quit_cb = cb - def _write_im_cb(self, sender, alias, message): - if alias: - self.txt_area.text += alias + ": " + message + "
" - else: - self.txt_area.text += sender + ": " + message + "
" - self._window.show_all() - + def show(self): + if self._window: + self._window.show_all() -class NullClientPurple: +class NullClientPurple(object): def __init__(self): - self.p = purple.Purple(debug_enabled=False) + self.purple = purple.Purple(debug_enabled=False) self.window = MainWindow(self.quit) self.buddies = {} #all buddies self.conversations = {} self.protocol_id = "prpl-jabber" self.account = None - self.accs = None + self.purple.add_callback("blist", "update", self.__purple_update_blist_cb) + self.purple.add_callback("connection", "connect-progress", self.__purple_conn_progress_cb) + self.purple.add_callback("connection", "connected", self.__purple_connected_cb) + self.purple.add_callback("connection", "disconnected", self.__purple_disconnected_cb) + self.purple.add_callback("conversation", "write-im", self.__purple_write_im_cb) - self.p.add_account_cb("notify_added", account_callback) - self.p.add_account_cb("status_changed", account_callback) - self.p.add_account_cb("request_add", account_callback) - self.p.add_account_cb("request_authorize", account_callback) - self.p.add_account_cb("close_account_request", account_callback) - - self.p.add_blist_cb("set_visible", blist_callback) - self.p.add_blist_cb("request_add_buddy", blist_callback) - self.p.add_blist_cb("request_add_chat", blist_callback) - self.p.add_blist_cb("request_add_group", blist_callback) - self.p.add_blist_cb("update", self._purple_update_blist_cb) - - self.p.purple_init(cbs) + self.purple.purple_init() #Initializing UI self.window.add_bt_conn_cb(self.connect) @@ -274,7 +169,7 @@ class NullClientPurple: self.window.add_account_cb(self.add_account) self.window.init_window() - def _purple_update_blist_cb(self, type, name=None, alias=None, \ + def __purple_update_blist_cb(self, type, name=None, alias=None, \ totalsize=None, currentsize=None, \ online=None): if self.account and name != None and type == 2: @@ -285,38 +180,73 @@ class NullClientPurple: elif self.buddies[name].online: self.window.new_buddy(name) - def _purple_signal_buddy_signed_off_cb(self, name, alias): + def __purple_conn_progress_cb(self, text, step, step_count): + if self.window: + self.window.lstatus.text = text + + def __purple_connected_cb(self, *data): + if self.window: + self.window.lstatus.text = "Connected" + + def __purple_disconnected_cb(self, *data): + if self.window: + self.window.lstatus.text = "Disconnected" + + def __purple_write_im_cb(self, username, name, alias, message): + if self.window: + if alias: + self.window.txt_area.text += alias + ": " + message + "
" + else: + self.window.txt_area.text += name + ": " + message + "
" + self.window.show() + + def __purple_signal_signed_on_cb(self, username, protocol_id): + print "[DEBUG] Signed on: %s %s" % (username, protocol_id) + + def __purple_signal_signed_off_cb(self, username, protocol_id): + print "[DEBUG] Signed off: %s %s" % (username, protocol_id) + + def __purple_signal_buddy_signed_on_cb(self, name, alias): + print "[DEBUG]: Buddy signed on: %s %s" % (name, alias) + + def __purple_signal_buddy_signed_off_cb(self, name, alias): if self.buddies.has_key(name): self.buddies[name] = None self.buddies.pop(name) - print "[DEBUG]: Buddy removed!" + print "[DEBUG]: Buddy signed off: %s %s" % (name, alias) self.window.remove_buddy(name) - def _purple_create_conv_cb(self, name, type): - bname = name.split("/")[0] - if bname in self.buddies and not self.conversations.has_key(name): - conv = purple.Conversation() - conv.initialize(self.account, "IM", bname) - self.conversations[bname] = conv + """ + def __purple_signal_jabber_receiving_xmlnode_cb(self, message): + xml = minidom.parse(message) + for msg in xml.getElementsByTagName("message"): + who = msg.getAttribute("from") + for geoloc in msg.getElementsByTagNameNS("http://jabber.org/protocol/geoloc", "geoloc"): + lat = geoloc.getElementsByTagName("lat")[0].childNodes[0].nodeValue + lon = geoloc.getElementsByTagName("lon")[0].childNodes[0].nodeValue + print "who: %s lat: %s lon: %s" % (who, lat, lon) + """ + + def add_account(self): + username = "carmanplugintest@gmail.com" + host = "172.18.216.211" + port = 8080 + self.purple.account_add(username, self.protocol_id, host, port) + for account in self.purple.accounts.keys(): + self.window.new_account(account) def connect(self, password): username_acc = self.window.selected_accs() if username_acc: - self.account = self.p.account_verify(username_acc) + self.account = self.purple.account_verify(username_acc) self.account.get_protocol_options() self.account.set_enabled("carman-purple-python", True) self.account.password = password - self.p.connect() - self.p.signal_connect("buddy-signed-off", self._purple_signal_buddy_signed_off_cb) - - def add_account(self): - username = "carmanplugintest@gmail.com" - host = "172.18.216.211" - port = 8080 - self.p.account_add(username, self.protocol_id, host, port) - self.accs = self.p.accounts - for acc in self.accs.keys(): - self.window.new_account(acc) + self.purple.signal_connect("signed-on", self.__purple_signal_signed_on_cb) + self.purple.signal_connect("signed-off", self.__purple_signal_signed_off_cb) + self.purple.signal_connect("buddy-signed-on", self.__purple_signal_buddy_signed_on_cb) + self.purple.signal_connect("buddy-signed-off", self.__purple_signal_buddy_signed_off_cb) + #self.purple.signal_connect("jabber-receiving-xmlnode", self.__purple_signal_jabber_receiving_xmlnode_cb) def send_msg(self, name, msg): if not self.conversations.has_key(name): @@ -331,7 +261,7 @@ class NullClientPurple: self.conversations[i].destroy() self.conversations[i] = None self.conversations = None - self.p.destroy() + self.purple.destroy() ecore.main_loop_quit() if __name__ == '__main__':