Mercurial > libervia-backend
annotate sat.tac @ 6:5799493fa548
connection and disconnection management
| author | Goffi <goffi@goffi.org> |
|---|---|
| date | Fri, 23 Oct 2009 17:04:22 +0200 |
| parents | c0c92129a54b |
| children | ef8060d365cb |
| rev | line source |
|---|---|
| 0 | 1 #!/usr/bin/python |
| 2 # -*- coding: utf-8 -*- | |
| 3 | |
| 4 """ | |
| 5 SAT: a jabber client | |
| 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 | |
|
2
c49345fd7737
refactoring: moved sat to sat.tac, now a twisted application so we can use twistd.
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
23 from twisted.application import internet, service |
| 0 | 24 from twisted.internet import glib2reactor, protocol |
| 25 glib2reactor.install() | |
| 26 | |
| 27 from twisted.words.protocols.jabber import client, jid, xmlstream, error | |
| 28 from twisted.words.xish import domish | |
| 29 | |
| 30 from twisted.internet import reactor | |
| 31 import pdb | |
| 32 | |
| 33 from sat_bridge.DBus import DBusBridge | |
| 34 import logging | |
| 35 from logging import debug, info, error | |
| 36 | |
| 37 import signal, sys | |
| 38 import os.path | |
| 39 | |
| 40 from tools.memory import Memory | |
| 41 from glob import glob | |
| 42 | |
| 43 | |
| 44 ### logging configuration FIXME: put this elsewhere ### | |
| 45 logging.basicConfig(level=logging.DEBUG, | |
| 46 format='%(message)s') | |
| 47 ### | |
| 48 | |
| 49 | |
| 50 | |
| 51 | |
| 52 class SAT: | |
| 53 | |
| 54 def __init__(self): | |
|
2
c49345fd7737
refactoring: moved sat to sat.tac, now a twisted application so we can use twistd.
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
55 #self.reactor=reactor |
| 0 | 56 self.memory=Memory() |
| 57 self.server_features=[] #XXX: temp dic, need to be transfered into self.memory in the future | |
| 58 self.connected=False #FIXME: use twisted var instead | |
| 59 | |
| 60 self._iq_cb_map = {} #callback called when ns is found on IQ | |
| 61 self._waiting_conf = {} #callback called when a confirmation is received | |
| 62 self._progress_cb_map = {} #callback called when a progress is requested (key = progress id) | |
| 63 self.plugins = {} | |
| 64 | |
| 65 self.bridge=DBusBridge() | |
| 66 self.bridge.register("connect", self.connect) | |
| 1 | 67 self.bridge.register("disconnect", self.disconnect) |
| 0 | 68 self.bridge.register("getContacts", self.memory.getContacts) |
| 69 self.bridge.register("getPresenceStatus", self.memory.getPresenceStatus) | |
| 70 self.bridge.register("sendMessage", self.sendMessage) | |
| 71 self.bridge.register("setParam", self.setParam) | |
| 72 self.bridge.register("getParam", self.memory.getParam) | |
| 73 self.bridge.register("getParams", self.memory.getParams) | |
| 74 self.bridge.register("getParamsCategories", self.memory.getParamsCategories) | |
| 75 self.bridge.register("getHistory", self.memory.getHistory) | |
| 76 self.bridge.register("setPresence", self.setPresence) | |
| 77 self.bridge.register("addContact", self.addContact) | |
| 78 self.bridge.register("delContact", self.delContact) | |
| 79 self.bridge.register("isConnected", self.isConnected) | |
| 80 self.bridge.register("confirmationAnswer", self.confirmationAnswer) | |
| 81 self.bridge.register("getProgress", self.getProgress) | |
| 82 | |
| 83 self._import_plugins() | |
| 5 | 84 #self.connect() |
| 0 | 85 |
| 86 | |
| 87 def _import_plugins(self): | |
| 88 """Import all plugins found in plugins directory""" | |
| 89 #TODO: manage dependencies | |
| 90 plug_lst = [os.path.splitext(plugin)[0] for plugin in map(os.path.basename,glob ("plugins/plugin*.py"))] | |
| 91 | |
| 92 for plug in plug_lst: | |
| 93 plug_path = 'plugins.'+plug | |
| 94 __import__(plug_path) | |
| 95 mod = sys.modules[plug_path] | |
| 96 plug_info = mod.PLUGIN_INFO | |
| 97 info ("importing plugin: %s", plug_info['name']) | |
| 98 self.plugins[plug_info['import_name']] = getattr(mod, plug_info['main'])(self) | |
| 99 | |
| 100 def connect(self): | |
|
6
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
101 if (self.connected): |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
102 info("already connected !") |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
103 return |
|
2
c49345fd7737
refactoring: moved sat to sat.tac, now a twisted application so we can use twistd.
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
104 print "connecting..." |
| 5 | 105 reactor.connectTCP(self.memory.getParamV("Server", "Connection"), 5222, self.factory) |
|
2
c49345fd7737
refactoring: moved sat to sat.tac, now a twisted application so we can use twistd.
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
106 |
|
6
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
107 def disconnect(self): |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
108 if (not self.connected): |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
109 info("not connected !") |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
110 return |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
111 info("Disconnecting...") |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
112 self.factory.stopTrying() |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
113 if self.xmlstream: |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
114 self.xmlstream.sendFooter() |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
115 |
|
2
c49345fd7737
refactoring: moved sat to sat.tac, now a twisted application so we can use twistd.
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
116 def getService(self): |
|
c49345fd7737
refactoring: moved sat to sat.tac, now a twisted application so we can use twistd.
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
117 print "GetService !" |
|
c49345fd7737
refactoring: moved sat to sat.tac, now a twisted application so we can use twistd.
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
118 """if (self.connected): |
| 0 | 119 info("already connected !") |
|
2
c49345fd7737
refactoring: moved sat to sat.tac, now a twisted application so we can use twistd.
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
120 return""" |
| 5 | 121 info("Getting service...") |
| 0 | 122 self.me = jid.JID(self.memory.getParamV("JabberID", "Connection")) |
| 123 self.factory = client.XMPPClientFactory(self.me, self.memory.getParamV("Password", "Connection")) | |
|
6
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
124 self.factory.clientConnectionLost = self.connectionLost |
| 0 | 125 self.factory.addBootstrap(xmlstream.STREAM_AUTHD_EVENT,self.authd) |
| 126 self.factory.addBootstrap(xmlstream.INIT_FAILED_EVENT,self.failed) | |
|
2
c49345fd7737
refactoring: moved sat to sat.tac, now a twisted application so we can use twistd.
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
127 return internet.TCPClient(self.memory.getParamV("Server", "Connection"), 5222, self.factory) |
| 0 | 128 |
| 129 def run(self): | |
| 130 debug("running app") | |
| 131 reactor.run() | |
| 132 | |
| 133 def stop(self): | |
| 134 debug("stopping app") | |
| 135 reactor.stop() | |
| 136 | |
| 137 def authd(self,xmlstream): | |
|
6
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
138 self.xmlstream=xmlstream |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
139 roster=client.IQ(xmlstream,'get') |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
140 roster.addElement(('jabber:iq:roster', 'query')) |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
141 roster.addCallback(self.rosterCb) |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
142 roster.send() |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
143 debug("server = %s",self.memory.getParamV("Server", "Connection")) |
| 0 | 144 |
|
6
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
145 ###FIXME: tmp disco ### |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
146 self.memory.registerFeature("http://jabber.org/protocol/disco#info") |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
147 self.disco(self.memory.getParamV("Server", "Connection"), self.serverDisco) |
| 0 | 148 |
| 149 | |
|
6
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
150 #we now send our presence status |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
151 self.setPresence(status="Online") |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
152 |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
153 # add a callback for the messages |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
154 xmlstream.addObserver('/message', self.gotMessage) |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
155 xmlstream.addObserver('/presence', self.presenceCb) |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
156 xmlstream.addObserver("/iq[@type='set' or @type='get']", self.iqCb) |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
157 print "********** CONNECTED **********" |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
158 self.connected=True |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
159 #reactor.callLater(2,self.sendFile,"goffi2@jabber.goffi.int/Psi", "/tmp/fakefile") |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
160 |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
161 def connectionLost(self, connector, unused_reason): |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
162 print "********** DISCONNECTED **********" |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
163 self.connected=False |
|
5799493fa548
connection and disconnection management
Goffi <goffi@goffi.org>
parents:
5
diff
changeset
|
164 |
| 0 | 165 |
| 166 def sendMessage(self,to,msg,type='chat'): | |
| 167 #FIXME: check validity of recipient | |
| 168 debug("Sending jabber message to %s...", to) | |
| 169 message = domish.Element(('jabber:client','message')) | |
| 170 message["to"] = jid.JID(to).full() | |
| 171 message["from"] = self.me.full() | |
| 172 message["type"] = type | |
| 173 message.addElement("body", "jabber:client", msg) | |
| 174 self.xmlstream.send(message) | |
| 175 self.memory.addToHistory(self.me, self.me, jid.JID(to), message["type"], unicode(msg)) | |
| 176 self.bridge.newMessage(message['from'], unicode(msg), to=message['to']) #We send back the message, so all clients are aware of it | |
| 177 | |
| 178 def setParam(self, name, value, namespace): | |
| 179 """set wanted paramater and notice observers""" | |
| 180 info ("setting param: %s=%s in namespace %s", name, value, namespace) | |
| 181 self.memory.setParam(name, value, namespace) | |
| 182 self.bridge.paramUpdate(name, value, namespace) | |
| 183 | |
| 184 def setRoster(self, to): | |
| 185 """Add a contact to roster list""" | |
| 186 to_jid=jid.JID(to) | |
| 187 roster=client.IQ(self.xmlstream,'set') | |
| 188 query=roster.addElement(('jabber:iq:roster', 'query')) | |
| 189 item=query.addElement("item") | |
| 190 item.attributes["jid"]=to_jid.userhost() | |
| 191 roster.send() | |
| 192 #TODO: check IQ result | |
| 193 | |
| 194 def delRoster(self, to): | |
| 195 """Remove a contact from roster list""" | |
| 196 to_jid=jid.JID(to) | |
| 197 roster=client.IQ(self.xmlstream,'set') | |
| 198 query=roster.addElement(('jabber:iq:roster', 'query')) | |
| 199 item=query.addElement("item") | |
| 200 item.attributes["jid"]=to_jid.userhost() | |
| 201 item.attributes["subscription"]="remove" | |
| 202 roster.send() | |
| 203 #TODO: check IQ result | |
| 204 | |
| 205 | |
| 206 def failed(self,xmlstream): | |
| 207 debug("failed: %s", xmlstream.getErrorMessage()) | |
| 208 debug("failed: %s", dir(xmlstream)) | |
| 209 | |
| 210 def isConnected(self): | |
| 211 return self.connected | |
| 212 | |
| 213 ## jabber methods ## | |
| 214 | |
| 215 def disco (self, item, callback, node=None): | |
| 216 """XEP-0030 Service discovery Feature.""" | |
| 217 disco=client.IQ(self.xmlstream,'get') | |
| 218 disco["from"]=self.me.full() | |
| 219 disco["to"]=item | |
| 220 disco.addElement(('http://jabber.org/protocol/disco#info', 'query')) | |
| 221 disco.addCallback(callback) | |
| 222 disco.send() | |
| 223 | |
| 224 | |
| 225 def setPresence(self, to="", type="", show="", status="", priority=0): | |
| 226 """Send our presence information""" | |
| 227 presence = domish.Element(('jabber:client', 'presence')) | |
| 228 if not type in ["", "unavailable", "subscribed", "subscribe", | |
| 229 "unsubscribe", "unsubscribed", "prob", "error"]: | |
| 230 error("Type error !") | |
| 231 #TODO: throw an error | |
| 232 return | |
| 233 | |
| 234 if to: | |
| 235 presence.attributes["to"]=to | |
| 236 if type: | |
| 237 presence.attributes["type"]=type | |
| 238 | |
| 239 for element in ["show", "status", "priority"]: | |
| 240 if locals()[element]: | |
| 241 presence.addElement(element).addContent(unicode(locals()[element])) | |
| 242 | |
| 243 self.xmlstream.send(presence) | |
| 244 | |
| 245 def addContact(self, to): | |
| 246 """Add a contact in roster list""" | |
| 247 to_jid=jid.JID(to) | |
| 248 self.setRoster(to_jid.userhost()) | |
| 249 self.setPresence(to_jid.userhost(), "subscribe") | |
| 250 | |
| 251 def delContact(self, to): | |
| 252 """Remove contact from roster list""" | |
| 253 to_jid=jid.JID(to) | |
| 254 self.delRoster(to_jid.userhost()) | |
| 255 self.bridge.contactDeleted(to) | |
| 256 | |
| 257 def gotMessage(self,message): | |
| 258 debug (u"got_message from: %s", message["from"]) | |
| 259 for e in message.elements(): | |
| 260 if e.name == "body": | |
| 261 self.bridge.newMessage(message["from"], e.children[0]) | |
| 262 self.memory.addToHistory(self.me, jid.JID(message["from"]), self.me, "chat", e.children[0]) | |
| 263 break | |
| 264 | |
| 265 ## callbacks ## | |
| 266 | |
| 267 def add_IQ_cb(self, ns, cb): | |
| 268 """Add an IQ callback on namespace ns""" | |
| 269 debug ("Registered callback for namespace %s", ns) | |
| 270 self._iq_cb_map[ns]=cb | |
| 271 | |
| 272 def iqCb(self, stanza): | |
| 273 info ("iqCb") | |
| 274 debug ("="*20) | |
| 275 debug ("DEBUG:\n") | |
| 276 debug (stanza.toXml().encode('utf-8')) | |
| 277 debug ("="*20) | |
| 278 #FIXME: temporary ugly code | |
| 279 uri = stanza.firstChildElement().uri | |
| 280 if self._iq_cb_map.has_key(uri): | |
| 281 self._iq_cb_map[uri](stanza) | |
| 282 #TODO: manage errors stanza | |
| 283 | |
| 284 def presenceCb(self, elem): | |
| 285 info ("presence update for [%s]", elem.getAttribute("from")) | |
| 286 debug("\n\nXML=\n%s\n\n", elem.toXml()) | |
| 287 presence={} | |
| 288 presence["jid"]=elem.getAttribute("from") | |
| 289 presence["type"]=elem.getAttribute("type") or "" | |
| 290 presence["show"]="" | |
| 291 presence["status"]="" | |
| 292 presence["priority"]=0 | |
| 293 | |
| 294 for item in elem.elements(): | |
| 295 if presence.has_key(item.name): | |
| 296 presence[item.name]=item.children[0] | |
| 297 | |
| 298 ### we check if the status is not about subscription ### | |
| 299 #TODO: check that from jid is one we wants to subscribe (ie: check a recent subscription asking) | |
| 300 if jid.JID(presence["jid"]).userhost()!=self.me.userhost(): | |
| 301 if presence["type"]=="subscribed": | |
| 302 debug ("subscription answer") | |
| 303 elif presence["type"]=="unsubscribed": | |
| 304 debug ("unsubscription answer") | |
| 305 elif presence["type"]=="subscribe": | |
| 306 #FIXME: auto answer for subscribe request, must be checked ! | |
| 307 debug ("subscription request") | |
| 308 self.setPresence(to=presence["jid"], type="subscribed") | |
| 309 else: | |
| 310 #We keep presence information only if it is not for subscription | |
| 311 self.memory.addPresenceStatus(presence["jid"], presence["type"], presence["show"], | |
| 312 presence["status"], int(presence["priority"])) | |
| 313 | |
| 314 #now it's time to notify frontends | |
| 315 self.bridge.presenceUpdate(presence["jid"], presence["type"], presence["show"], | |
| 316 presence["status"], int(presence["priority"])) | |
| 317 | |
| 318 def rosterCb(self,roster): | |
| 319 for contact in roster.firstChildElement().elements(): | |
| 320 info ("new contact in roster list: %s", contact['jid']) | |
| 321 #and now the groups | |
| 322 groups=[] | |
| 323 for group in contact.elements(): | |
| 324 if group.name!="group": | |
| 325 error("Unexpected element !") | |
| 326 break | |
| 327 groups.append(str(group)) | |
| 328 self.memory.addContact(contact['jid'], contact.attributes, groups) | |
| 329 self.bridge.newContact(contact['jid'], contact.attributes, groups) | |
| 330 | |
| 331 def serverDisco(self, disco): | |
| 332 """xep-0030 Discovery Protocol.""" | |
| 333 for element in disco.firstChildElement().elements(): | |
| 334 if element.name=="feature": | |
| 335 debug ("Feature dectetee: %s",element["var"]) | |
| 336 self.server_features.append(element["var"]) | |
| 337 elif element.name=="identity": | |
| 338 debug ("categorie= %s",element["category"]) | |
| 339 debug ("features= %s",self.server_features) | |
| 340 | |
| 341 ## Generic HMI ## | |
| 342 | |
| 343 def askConfirmation(self, id, type, data, cb): | |
| 344 """Add a confirmation callback""" | |
| 345 if self._waiting_conf.has_key(id): | |
| 346 error ("Attempt to register two callbacks for the same confirmation") | |
| 347 else: | |
| 348 self._waiting_conf[id] = cb | |
| 349 self.bridge.askConfirmation(type, id, data) | |
| 350 | |
| 351 | |
| 352 def confirmationAnswer(self, id, accepted, data): | |
| 353 """Called by frontends to answer confirmation requests""" | |
| 354 debug ("Received confirmation answer for id [%s]: %s", id, "accepted" if accepted else "refused") | |
| 355 if not self._waiting_conf.has_key(id): | |
| 356 error ("Received an unknown confirmation") | |
| 357 else: | |
| 358 cb = self._waiting_conf[id] | |
| 359 del self._waiting_conf[id] | |
| 360 cb(id, accepted, data) | |
| 361 | |
| 362 def registerProgressCB(self, id, CB): | |
| 363 """Register a callback called when progress is requested for id""" | |
| 364 self._progress_cb_map[id] = CB | |
| 365 | |
| 366 def removeProgressCB(self, id): | |
| 367 """Remove a progress callback""" | |
| 368 if not self._progress_cb_map.has_key(id): | |
| 369 error ("Trying to remove an unknow progress callback") | |
| 370 else: | |
| 371 del self._progress_cb_map[id] | |
| 372 | |
| 373 def getProgress(self, id): | |
| 374 """Return a dict with progress information | |
| 375 data['position'] : current possition | |
| 376 data['size'] : end_position | |
| 377 """ | |
| 378 data = {} | |
| 379 try: | |
| 380 self._progress_cb_map[id](data) | |
| 381 except KeyError: | |
| 382 pass | |
| 383 #debug("Requested progress for unknown id") | |
| 384 return data | |
| 385 | |
| 386 | |
|
2
c49345fd7737
refactoring: moved sat to sat.tac, now a twisted application so we can use twistd.
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
387 application = service.Application('SàT') |
|
c49345fd7737
refactoring: moved sat to sat.tac, now a twisted application so we can use twistd.
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
388 sat = SAT() |
|
c49345fd7737
refactoring: moved sat to sat.tac, now a twisted application so we can use twistd.
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
389 service = sat.getService() |
|
c49345fd7737
refactoring: moved sat to sat.tac, now a twisted application so we can use twistd.
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
390 service.setServiceParent(application) |
| 0 | 391 |
|
2
c49345fd7737
refactoring: moved sat to sat.tac, now a twisted application so we can use twistd.
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
392 |
|
c49345fd7737
refactoring: moved sat to sat.tac, now a twisted application so we can use twistd.
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
393 #app.memory.save() #FIXME: not the best place |
|
c49345fd7737
refactoring: moved sat to sat.tac, now a twisted application so we can use twistd.
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
394 #debug("Good Bye") |