Author: eallen
Date: 2010-05-25 12:44:22 -0400 (Tue, 25 May 2010)
New Revision: 3987
Modified:
mgmt/newdata/cumin/python/cumin/objecttask.py
mgmt/newdata/cumin/python/cumin/objecttask.strings
Log:
Display list of selected items in SelectionTaskForm
Modified: mgmt/newdata/cumin/python/cumin/objecttask.py
===================================================================
--- mgmt/newdata/cumin/python/cumin/objecttask.py 2010-05-25 16:41:40 UTC (rev 3986)
+++ mgmt/newdata/cumin/python/cumin/objecttask.py 2010-05-25 16:44:22 UTC (rev 3987)
@@ -1,3 +1,6 @@
+from qpid.connection import *
+from qpid.util import *
+
from rosemary.model import *
from wooly.forms import *
from wooly.resources import *
@@ -85,6 +88,26 @@
def do_invoke(self, invoc, obj, *args):
pass
+ def amqp_call(self, vhost, callback):
+ db_conn = self.app.database.get_connection()
+ cursor = db_conn.cursor()
+
+ cls = self.app.model.org_apache_qpid_broker.Broker
+ broker = cls.get_object_by_id(cursor, vhost._brokerRef_id)
+ port = broker.port
+
+ cls = self.app.model.org_apache_qpid_broker.System
+ system = cls.get_object_by_id(cursor, broker._systemRef_id)
+ host = system.nodeName
+
+ sock = connect(host, port)
+ conn = Connection(sock)
+ conn.start()
+ sess = conn.session()
+
+ callback(sess)
+ conn.close()
+
def qmf_call(self, invoc, obj, meth, *args):
def completion(status_code, output_args):
invoc.status_code = status_code
@@ -92,8 +115,8 @@
invoc.end()
- agent = self.app.model.agents[obj._qmf_agent_id]
- agent.call_method(completion, obj, meth, *args)
+ session = self.app.session
+ session.call_method(completion, obj, meth, args)
def exception(self, invoc, e):
now = datetime.now()
@@ -302,17 +325,20 @@
self.selection = SessionAttribute(self, "selection")
+ self.content = self.SelectionList(app, "fields")
+ self.replace_child(self.content)
+
def do_process(self, session):
selection = list()
-
+
self.selection.set(session, selection)
for id in self.ids.get(session):
- item = self.cls.get_object(session.cursor, id)
+ item = self.cls.get_object_by_id(session.cursor, id)
selection.append(item)
super(SelectionTaskForm, self).do_process(session)
-
+
def process_submit(self, session):
selection = self.selection.get(session)
@@ -322,6 +348,16 @@
def render_title(self, session):
return self.task.get_title(session)
+ class SelectionList(ItemSet):
+ def do_get_items(self, session):
+ return self.parent.selection.get(session)
+
+ def render_item_content(self, session, item):
+ return item.name
+
+ def render_item_class(self, session, item):
+ return "item"
+
class ObjectTaskLink(Link):
def __init__(self, app, name, task):
assert isinstance(task, ObjectTask), task
Modified: mgmt/newdata/cumin/python/cumin/objecttask.strings
===================================================================
--- mgmt/newdata/cumin/python/cumin/objecttask.strings 2010-05-25 16:41:40 UTC (rev 3986)
+++ mgmt/newdata/cumin/python/cumin/objecttask.strings 2010-05-25 16:44:22 UTC (rev 3987)
@@ -7,3 +7,8 @@
margin: 0.5em auto 1em auto;
width: 80%;
}
+
+[SelectionList.css]
+ul.SelectionList {
+ list-style: none;
+}