[rhmessaging-commits] rhmessaging commits: r3066 - mgmt/trunk/cumin/python/cumin.
rhmessaging-commits at lists.jboss.org
rhmessaging-commits at lists.jboss.org
Thu Jan 22 11:41:49 EST 2009
Author: justi9
Date: 2009-01-22 11:41:49 -0500 (Thu, 22 Jan 2009)
New Revision: 3066
Modified:
mgmt/trunk/cumin/python/cumin/binding.py
Log:
Whitespace cleanup
Modified: mgmt/trunk/cumin/python/cumin/binding.py
===================================================================
--- mgmt/trunk/cumin/python/cumin/binding.py 2009-01-21 19:48:22 UTC (rev 3065)
+++ mgmt/trunk/cumin/python/cumin/binding.py 2009-01-22 16:41:49 UTC (rev 3066)
@@ -15,7 +15,7 @@
self.exchange = None
self.instance_data = None
-
+
self.name_tmpl = Template(self, "name_html")
self.key_tmpl = Template(self, "key_html")
@@ -30,7 +30,7 @@
def get_args(self, session):
return (self.exchange,)
-
+
def get_exchange_info(self, session, exchange):
binding_info = self.form.bindings.dict_param.get(session)
if str(exchange.id) in binding_info:
@@ -41,7 +41,7 @@
if exchange_info:
if key in exchange_info:
return exchange_info[key]
-
+
def render_exchange_name(self, session, exchange):
return exchange.name
@@ -50,16 +50,16 @@
def render_name_path(self, session, *args):
return DictParameter.sep().join((self.instance_data, "name"))
-
+
def render_exchange_type(self, session, exchange):
return exchange.type
def render_exchange_type_path(self, session, exchange):
return DictParameter.sep().join((self.instance_data, "type"))
-
+
def render_exchange_id(self, session, exchange):
return exchange.id
-
+
def render_exchange_checked(self, session, exchange):
exchange_info = self.get_exchange_info(session, exchange)
if exchange_info:
@@ -70,21 +70,21 @@
writer = Writer()
self.name_tmpl.render(writer, session, exchange)
return writer.to_string()
-
+
def render_exchange_key_input(self, session, exchange):
writer = Writer()
self.key_tmpl.render(writer, session, exchange)
return writer.to_string()
-
+
def render_onclick(self, session, exchange):
pass
-
+
def render_list_error(self, session, exchange):
errors = self.parent.binding_errors.get(session)
if exchange.name in errors:
return "<ul class=\"errors\" style=\"margin:0; float:left;\"><li>%s</li></ul>" % \
"</li><li>".join(errors[exchange.name])
-
+
def render_dict_error(self, session, exchange, key):
errors = self.parent.binding_errors.get(session)
if exchange.name in errors:
@@ -92,11 +92,11 @@
if key in exchange_errors:
return "<ul class=\"errors\" style=\"margin:0; float:left;\"><li>%s</li></ul>" % \
"</li><li>".join(exchange_errors[key])
-
+
def set_instance_data(self, exchange, dict_key):
self.exchange = exchange
self.instance_data = dict_key
-
+
class FanoutExchangeInput(ExchangeInput):
pass
@@ -109,10 +109,10 @@
def render_key_error(self, session, exchange):
return self.render_list_error(session, exchange)
-
+
def render_key_value(self, session, exchange):
return self.get_exchange_info_for(session, exchange, "key")
-
+
class DirectExchangeInput(BindingKeyExchangeInput):
pass
@@ -125,24 +125,24 @@
def render_xquery_path(self, session, exchange):
return DictParameter.sep().join((self.instance_data, "xquery"))
-
+
def render_headers_class(self, session, exchange):
exchange_info = self.get_exchange_info(session, exchange)
- if not exchange_info or not "name" in exchange_info:
+ if not exchange_info or not "name" in exchange_info:
return "initial_header_state"
def render_key_error(self, session, exchange):
return self.render_dict_error(session, exchange, "key")
-
+
def render_onclick(self, session, exchange):
return "onclick=\"toggle_row(this, 'xml_extra.%s')\"" % str(exchange.id)
def render_xml_extra(self, session, exchange):
return "xml_extra.%s" % str(exchange.id)
-
+
def render_xquery_error(self, session, exchange):
return self.render_dict_error(session, exchange, "xquery")
-
+
def render_xquery_value(self, session, exchange):
return self.get_exchange_info_for(session, exchange, "xquery")
@@ -159,24 +159,24 @@
def render_mkey_path(self, session, exchange):
return DictParameter.sep().join((self.instance_data, "mkey"))
-
+
def render_headers_class(self, session, exchange):
exchange_info = self.get_exchange_info(session, exchange)
- if not exchange_info or not "name" in exchange_info:
+ if not exchange_info or not "name" in exchange_info:
return "initial_header_state"
def render_all_checked(self, session, exchange):
checked = self.render_any_checked(session, exchange)
if not checked:
return "checked=\"checked\""
-
+
def render_any_checked(self, session, exchange):
exchange_info = self.get_exchange_info(session, exchange)
if exchange_info:
if "x-match" in exchange_info:
if exchange_info["x-match"] == "any":
return "checked=\"checked\""
-
+
def render_mkey1_value(self, session, exchange):
return self.get_exchange_info_for(session, exchange, "mkey.1")
@@ -188,16 +188,16 @@
def render_mnv1_value(self, session, exchange):
return self.get_exchange_info_for(session, exchange, "mkey.1.nv")
-
+
def render_mnv2_value(self, session, exchange):
return self.get_exchange_info_for(session, exchange, "mkey.2.nv")
def render_mnv3_value(self, session, exchange):
return self.get_exchange_info_for(session, exchange, "mkey.3.nv")
-
+
def render_key_error(self, session, exchange):
return self.render_dict_error(session, exchange, "key")
-
+
def render_mkey1_error(self, session, exchange):
return self.render_dict_error(session, exchange, "mkey.1")
@@ -235,15 +235,15 @@
for m_info in this_exchange:
if m_info.startswith(match_info):
if m_info.endswith("nv"):
- return this_exchange[m_info]
-
+ return this_exchange[m_info]
+
class ExchangeState(SubmitSwitch):
def __init__(self, app, name):
super(ExchangeState, self).__init__(app, name)
self.add_state("c", "Active", bm="phase")
self.add_state("a", "All", bm="phase")
-
+
def is_all(self, session):
return self.get(session) == "a"
@@ -256,7 +256,7 @@
self.dict_param = DictParameter(app, "exchange")
self.add_parameter(self.dict_param)
-
+
self.direct_input = DirectExchangeInput(app, "direct")
self.add_child(self.direct_input)
@@ -271,9 +271,9 @@
self.headers_input = HeadersExchangeInput(app, "headers")
self.add_child(self.headers_input)
-
+
self.title = title
-
+
self.binding_errors = self.Errors(self, "binding_errors")
self.add_attribute(self.binding_errors)
@@ -283,14 +283,14 @@
def get_args(self, session):
reg = self.frame.get_ancestor("broker").get_object(session)
return (reg.getDefaultVhost(),)
-
+
class Errors(Attribute):
def get_default(self, session):
return dict()
def render_title(self, session, vhost):
return self.title
-
+
def render_exchanges(self, session, vhost):
sortedExchanges = sorted_by(vhost.exchanges)
@@ -320,9 +320,9 @@
elif exchange.type == "headers":
self.headers_input.set_instance_data(exchange, instance_key)
writer.write(self.headers_input.render(session))
-
+
return writer.to_string()
-
+
def get_binding_errors(self, session, queue_name):
form_binding_info = self.process_binding_info(session, queue_name)
@@ -360,9 +360,9 @@
if not name in berrs:
berrs.setdefault(name, dict())
berrs[name]["xquery"] = ["Missing xquery"]
-
+
return (len(berrs), form_binding_info)
-
+
def process_binding_info(self, session, queue_name):
""" Processes the raw binding_info from the DictParameter into
a "form_binding_info" dictionary that contains four keys:
More information about the rhmessaging-commits
mailing list