Some code style cleanup
darcs-hash:20070531171427-86b55-e463f2d01197ee792909f41c6e71205624de1676.gz
This commit is contained in:
@@ -52,8 +52,8 @@ if __name__ == '__main__':
|
|||||||
coverage.analysis(jcl.lang)
|
coverage.analysis(jcl.lang)
|
||||||
coverage.analysis(jcl.model.account)
|
coverage.analysis(jcl.model.account)
|
||||||
|
|
||||||
coverage.report([jcl.jabber.component, \
|
coverage.report([jcl.jabber.component,
|
||||||
jcl.jabber.feeder, \
|
jcl.jabber.feeder,
|
||||||
jcl.lang, \
|
jcl.lang,
|
||||||
jcl.model.account])
|
jcl.model.account])
|
||||||
|
|
||||||
|
|||||||
@@ -255,7 +255,7 @@ class JCLComponent(Component, object):
|
|||||||
self.send_stanzas(result)
|
self.send_stanzas(result)
|
||||||
return result
|
return result
|
||||||
|
|
||||||
def apply_registered_behavior(self, handlers, stanza, apply_all = False):
|
def apply_registered_behavior(self, handlers, stanza, apply_all=False):
|
||||||
"""Execute handler if their filter method does not return None"""
|
"""Execute handler if their filter method does not return None"""
|
||||||
result = []
|
result = []
|
||||||
self.db_connect()
|
self.db_connect()
|
||||||
@@ -280,15 +280,17 @@ class JCLComponent(Component, object):
|
|||||||
def disco_get_info(self, node, info_query):
|
def disco_get_info(self, node, info_query):
|
||||||
"""Discovery get info handler
|
"""Discovery get info handler
|
||||||
"""
|
"""
|
||||||
return self.apply_behavior(info_query, \
|
return self.apply_behavior(\
|
||||||
lambda name, from_jid, account_type, lang_class: \
|
info_query,
|
||||||
self.account_manager.account_disco_get_info(), \
|
lambda name, from_jid, account_type, lang_class: \
|
||||||
lambda name, from_jid, account_type, lang_class: \
|
self.account_manager.account_disco_get_info(),
|
||||||
self.account_manager.account_type_disco_get_info(), \
|
lambda name, from_jid, account_type, lang_class: \
|
||||||
lambda name, from_jid, account_type, lang_class: \
|
self.account_manager.account_type_disco_get_info(),
|
||||||
self.account_manager.root_disco_get_info(self.name, \
|
lambda name, from_jid, account_type, lang_class: \
|
||||||
self.disco_identity.category, \
|
self.account_manager.root_disco_get_info(
|
||||||
self.disco_identity.type))
|
self.name,
|
||||||
|
self.disco_identity.category,
|
||||||
|
self.disco_identity.type))
|
||||||
|
|
||||||
def disco_get_items(self, node, info_query):
|
def disco_get_items(self, node, info_query):
|
||||||
"""Discovery get nested nodes handler
|
"""Discovery get nested nodes handler
|
||||||
@@ -338,7 +340,7 @@ class JCLComponent(Component, object):
|
|||||||
"""
|
"""
|
||||||
self.__logger.debug("SET_REGISTER")
|
self.__logger.debug("SET_REGISTER")
|
||||||
lang_class = \
|
lang_class = \
|
||||||
self.lang.get_lang_class_from_node(info_query.get_node())
|
self.lang.get_lang_class_from_node(info_query.get_node())
|
||||||
from_jid = info_query.get_from()
|
from_jid = info_query.get_from()
|
||||||
base_from_jid = unicode(from_jid.bare())
|
base_from_jid = unicode(from_jid.bare())
|
||||||
remove = info_query.xpath_eval("r:query/r:remove", \
|
remove = info_query.xpath_eval("r:query/r:remove", \
|
||||||
@@ -1207,6 +1209,6 @@ class PasswordMessageHandler(Handler):
|
|||||||
_account.waiting_password_reply = False
|
_account.waiting_password_reply = False
|
||||||
return [Message(from_jid = _account.jid, \
|
return [Message(from_jid = _account.jid, \
|
||||||
to_jid = stanza.get_from(), \
|
to_jid = stanza.get_from(), \
|
||||||
subject = lang_class.password_saved_for_session, \
|
subject = lang.password_saved_for_session, \
|
||||||
body = lang_class.password_saved_for_session)]
|
body = lang.password_saved_for_session)]
|
||||||
|
|
||||||
|
|||||||
@@ -41,7 +41,9 @@ from pyxmpp.presence import Presence
|
|||||||
from pyxmpp.message import Message
|
from pyxmpp.message import Message
|
||||||
from pyxmpp.jabber.dataforms import Form, Field, Option
|
from pyxmpp.jabber.dataforms import Form, Field, Option
|
||||||
|
|
||||||
from jcl.jabber.component import JCLComponent, Handler, PasswordMessageHandler, DefaultSubscribeHandler, DefaultUnsubscribeHandler, DefaultPresenceHandler
|
from jcl.jabber.component import JCLComponent, Handler, \
|
||||||
|
PasswordMessageHandler, DefaultSubscribeHandler, \
|
||||||
|
DefaultUnsubscribeHandler, DefaultPresenceHandler
|
||||||
from jcl.model import account
|
from jcl.model import account
|
||||||
from jcl.model.account import Account
|
from jcl.model.account import Account
|
||||||
from jcl.lang import Lang
|
from jcl.lang import Lang
|
||||||
@@ -55,12 +57,12 @@ else:
|
|||||||
DB_URL = DB_PATH# + "?debug=1&debugThreading=1"
|
DB_URL = DB_PATH# + "?debug=1&debugThreading=1"
|
||||||
|
|
||||||
class MockStream(object):
|
class MockStream(object):
|
||||||
def __init__(self, \
|
def __init__(self,
|
||||||
jid = "",
|
jid="",
|
||||||
secret = "",
|
secret="",
|
||||||
server = "",
|
server="",
|
||||||
port = "",
|
port="",
|
||||||
keepalive = True):
|
keepalive=True):
|
||||||
self.sent = []
|
self.sent = []
|
||||||
self.connection_started = False
|
self.connection_started = False
|
||||||
self.connection_stopped = False
|
self.connection_stopped = False
|
||||||
@@ -73,9 +75,9 @@ class MockStream(object):
|
|||||||
def set_iq_set_handler(self, iq_type, ns, handler):
|
def set_iq_set_handler(self, iq_type, ns, handler):
|
||||||
if not iq_type in ["query"]:
|
if not iq_type in ["query"]:
|
||||||
raise Exception("IQ type unknown: " + iq_type)
|
raise Exception("IQ type unknown: " + iq_type)
|
||||||
if not ns in ["jabber:iq:version", \
|
if not ns in ["jabber:iq:version",
|
||||||
"jabber:iq:register", \
|
"jabber:iq:register",
|
||||||
"http://jabber.org/protocol/disco#items", \
|
"http://jabber.org/protocol/disco#items",
|
||||||
"http://jabber.org/protocol/disco#info"]:
|
"http://jabber.org/protocol/disco#info"]:
|
||||||
raise Exception("Unknown namespace: " + ns)
|
raise Exception("Unknown namespace: " + ns)
|
||||||
if handler is None:
|
if handler is None:
|
||||||
@@ -84,12 +86,12 @@ class MockStream(object):
|
|||||||
set_iq_get_handler = set_iq_set_handler
|
set_iq_get_handler = set_iq_set_handler
|
||||||
|
|
||||||
def set_presence_handler(self, status, handler):
|
def set_presence_handler(self, status, handler):
|
||||||
if not status in ["available", \
|
if not status in ["available",
|
||||||
"unavailable", \
|
"unavailable",
|
||||||
"probe", \
|
"probe",
|
||||||
"subscribe", \
|
"subscribe",
|
||||||
"subscribed", \
|
"subscribed",
|
||||||
"unsubscribe", \
|
"unsubscribe",
|
||||||
"unsubscribed"]:
|
"unsubscribed"]:
|
||||||
raise Exception("Status unknown: " + status)
|
raise Exception("Status unknown: " + status)
|
||||||
if handler is None:
|
if handler is None:
|
||||||
|
|||||||
Reference in New Issue
Block a user