Mercurial > libervia-backend
annotate frontends/quick_frontend/quick_app.py @ 25:53e921c8a357
new plugin: gateways plugin, and first implementation of findGateways
- test menu in Wix
- new actionResultExt method, for sending dictionary of dictionaries
- new getNextId method, for accessing sat ids from plugins.
| author | Goffi <goffi@goffi.org> |
|---|---|
| date | Fri, 04 Dec 2009 08:47:44 +0100 |
| parents | bb72c29f3432 |
| children | c2b131e4e262 |
| rev | line source |
|---|---|
| 0 | 1 #!/usr/bin/python |
| 2 # -*- coding: utf-8 -*- | |
| 3 | |
| 4 """ | |
| 5 helper class for making a SAT frontend | |
| 6 Copyright (C) 2009 Jérôme Poisson (goffi@goffi.org) | |
| 7 | |
| 8 This program is free software: you can redistribute it and/or modify | |
| 9 it under the terms of the GNU General Public License as published by | |
| 10 the Free Software Foundation, either version 3 of the License, or | |
| 11 (at your option) any later version. | |
| 12 | |
| 13 This program is distributed in the hope that it will be useful, | |
| 14 but WITHOUT ANY WARRANTY; without even the implied warranty of | |
| 15 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | |
| 16 GNU General Public License for more details. | |
| 17 | |
| 18 You should have received a copy of the GNU General Public License | |
| 19 along with this program. If not, see <http://www.gnu.org/licenses/>. | |
| 20 """ | |
| 21 | |
| 22 from logging import debug, info, error | |
| 23 from tools.jid import JID | |
| 24 from sat_bridge_frontend.DBus import DBusBridgeFrontend | |
| 25 from quick_frontend.quick_contact_management import QuickContactManagement | |
| 26 | |
| 27 | |
| 28 class QuickApp(): | |
| 29 """This class contain the main methods needed for the frontend""" | |
| 30 | |
| 31 def __init__(self): | |
| 32 self.rosterList = {} | |
| 33 self.CM = QuickContactManagement() #a short name if more handy | |
| 34 | |
| 35 ## bridge ## | |
| 36 self.bridge=DBusBridgeFrontend() | |
| 37 self.bridge.register("newContact", self.newContact) | |
| 38 self.bridge.register("newMessage", self.newMessage) | |
| 39 self.bridge.register("presenceUpdate", self.presenceUpdate) | |
| 40 self.bridge.register("paramUpdate", self.paramUpdate) | |
| 41 self.bridge.register("contactDeleted", self.contactDeleted) | |
| 42 self.bridge.register("askConfirmation", self.askConfirmation, "request") | |
|
22
bb72c29f3432
added action cb mechanism for buttons. Tested with a temporary new user registration button.
Goffi <goffi@goffi.org>
parents:
18
diff
changeset
|
43 self.bridge.register("actionResult", self.actionResult, "request") |
|
25
53e921c8a357
new plugin: gateways plugin, and first implementation of findGateways
Goffi <goffi@goffi.org>
parents:
22
diff
changeset
|
44 self.bridge.register("actionResultExt", self.actionResult, "request") |
| 0 | 45 |
| 46 ###now we get the essential params### | |
|
22
bb72c29f3432
added action cb mechanism for buttons. Tested with a temporary new user registration button.
Goffi <goffi@goffi.org>
parents:
18
diff
changeset
|
47 self.whoami=JID(self.bridge.getParamA("JabberID","Connection")) |
|
bb72c29f3432
added action cb mechanism for buttons. Tested with a temporary new user registration button.
Goffi <goffi@goffi.org>
parents:
18
diff
changeset
|
48 self.watched=self.bridge.getParamA("Watched", "Misc").split() #TODO: put this in a plugin |
| 0 | 49 |
| 50 ## misc ## | |
|
22
bb72c29f3432
added action cb mechanism for buttons. Tested with a temporary new user registration button.
Goffi <goffi@goffi.org>
parents:
18
diff
changeset
|
51 self.current_action_ids = set() |
| 0 | 52 self.onlineContact = set() #FIXME: temporary |
| 53 | |
| 54 if self.bridge.isConnected(): | |
| 55 self.setStatusOnline(True) | |
| 56 | |
| 57 ### now we fill the contact list ### | |
| 58 for contact in self.bridge.getContacts(): | |
| 59 self.newContact(contact[0], contact[1], contact[2]) | |
| 60 | |
| 61 for status in self.bridge.getPresenceStatus(): | |
| 62 self.presenceUpdate(status[0], status[1], status[2], status[3], status[4]) | |
| 63 | |
| 64 | |
| 65 def newContact(self, JabberId, attributes, groups): | |
| 66 jid=JID(JabberId) | |
| 67 self.rosterList[jid.short]=(dict(attributes), list(groups)) | |
| 68 | |
| 69 def newMessage(self, from_jid, msg, type, to_jid): | |
| 70 sender=JID(from_jid) | |
| 71 addr=JID(to_jid) | |
| 72 win = addr if sender.short == self.whoami.short else sender | |
| 73 self.chat_wins[win.short].printMessage(sender, msg) | |
| 74 | |
| 75 def setStatusOnline(self, online=True): | |
| 76 pass | |
| 77 | |
| 78 def presenceUpdate(self, jabber_id, type, show, status, priority): | |
| 79 debug ("presence update for %s (type=%s, show=%s, status=%s)", jabber_id, type, show, status); | |
| 80 jid=JID(jabber_id) | |
| 81 debug ("jid.short=%s whoami.short=%s", jid.short, self.whoami.short) | |
| 82 | |
| 83 ### subscription management ### | |
| 84 if type=="subscribed": | |
| 85 # this is a subscription confirmation, we just have to inform user | |
| 86 self.showDialog("The contact %s has accepted your subscription" % jid.short, 'Subscription confirmation') | |
| 87 return | |
| 88 elif type=="unsubscribed": | |
| 89 # this is a subscription refusal, we just have to inform user | |
| 90 self.showDialog("The contact %s has refused your subscription" % jid.short, 'Subscription refusal', 'error') | |
| 91 return | |
| 92 elif type=="subscribe": | |
| 93 # this is a subscrition request, we have to ask for user confirmation | |
| 94 answer = self.showDialog("The contact %s wants to subscribe to your presence.\nDo you accept ?" % jid.short, 'Subscription confirmation', 'question') | |
| 95 if answer: | |
| 96 self.bridge.setPresence(type="subscribed", to=jid.short) | |
| 97 else: | |
| 98 self.bridge.setPresence(type="unsubscribed", to=jid.short) | |
| 99 return | |
| 100 ### subscription management end ### | |
| 101 | |
| 102 if jid.short==self.whoami.short: | |
| 103 if not type: | |
| 104 self.setStatusOnline(True) | |
| 105 elif type=="unavailable": | |
| 106 self.setStatusOnline(False) | |
| 107 return | |
| 108 | |
| 109 if not type: | |
| 110 name="" | |
| 111 group="" | |
| 112 if self.rosterList.has_key(jid.short): | |
| 113 if self.rosterList[jid.short][0].has_key("name"): | |
| 114 name=self.rosterList[jid.short][0]["name"] | |
| 115 if self.rosterList[jid.short][0].has_key("show"): | |
| 116 name=self.rosterList[jid.short][0]["show"] | |
| 117 if self.rosterList[jid.short][0].has_key("status"): | |
| 118 name=self.rosterList[jid.short][0]["status"] | |
| 119 if len(self.rosterList[jid.short][1]): | |
| 120 group=self.rosterList[jid.short][1][0] | |
| 121 | |
| 122 #FIXME: must be moved in a plugin | |
| 123 if jid.short in self.watched and not jid.short in self.onlineContact: | |
| 124 self.showAlert("Watched jid [%s] is connected !" % jid.short) | |
| 125 | |
| 126 self.onlineContact.add(jid) #FIXME onlineContact is useless with CM, must be removed | |
| 127 self.CM.add(jid) | |
| 128 self.contactList.replace(jid, show=show, status=status, name=name, group=group) | |
| 129 | |
| 130 | |
|
13
bd9e9997d540
wokkel integration (not finished yet)
Goffi <goffi@goffi.org>
parents:
0
diff
changeset
|
131 if type=="unavailable" and jid in self.onlineContact: |
|
bd9e9997d540
wokkel integration (not finished yet)
Goffi <goffi@goffi.org>
parents:
0
diff
changeset
|
132 self.onlineContact.remove(jid) |
| 0 | 133 self.CM.remove(jid) |
| 134 self.contactList.remove(jid) | |
| 135 | |
| 136 | |
| 137 def showDialog(self, message, title, type="info"): | |
| 138 raise NotImplementedError | |
| 139 | |
| 140 def showAlert(self, message): | |
| 141 pass #FIXME | |
| 142 | |
| 143 def paramUpdate(self, name, value, namespace): | |
| 144 debug("param update: [%s] %s = %s", namespace, name, value) | |
| 145 if (namespace,name) == ("Connection", "JabberID"): | |
| 146 debug ("Changing ID to %s", value) | |
| 147 self.whoami=JID(value) | |
| 148 elif (namespace,name) == ("Misc", "Watched"): | |
| 149 self.watched=value.split() | |
| 150 | |
| 151 def contactDeleted(self, jid): | |
| 152 target = JID(jid) | |
| 153 try: | |
| 154 self.onlineContact.remove(target.short) | |
| 155 except KeyError: | |
| 156 pass | |
| 157 self.contactList.remove(self.CM.get_full(jid)) | |
| 158 self.CM.remove(target) | |
| 159 | |
| 160 def askConfirmation(self, type, id, data): | |
| 161 raise NotImplementedError | |
|
22
bb72c29f3432
added action cb mechanism for buttons. Tested with a temporary new user registration button.
Goffi <goffi@goffi.org>
parents:
18
diff
changeset
|
162 |
|
bb72c29f3432
added action cb mechanism for buttons. Tested with a temporary new user registration button.
Goffi <goffi@goffi.org>
parents:
18
diff
changeset
|
163 def actionResult(self, type, id, data): |
|
bb72c29f3432
added action cb mechanism for buttons. Tested with a temporary new user registration button.
Goffi <goffi@goffi.org>
parents:
18
diff
changeset
|
164 raise NotImplementedError |