1d0825bca7fe65beaee391d30da42e937db621564Steve Block# Copyright (C) 2009 Google Inc. All rights reserved. 2231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# 3231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# Redistribution and use in source and binary forms, with or without 4231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# modification, are permitted provided that the following conditions are 5231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# met: 6231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# 7231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# * Redistributions of source code must retain the above copyright 8231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# notice, this list of conditions and the following disclaimer. 9231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# * Redistributions in binary form must reproduce the above 10231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# copyright notice, this list of conditions and the following disclaimer 11231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# in the documentation and/or other materials provided with the 12231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# distribution. 13231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# * Neither the name of Google Inc. nor the names of its 14231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# contributors may be used to endorse or promote products derived from 15231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# this software without specific prior written permission. 16231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# 17231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS 18231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT 19231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR 20231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT 21231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, 22231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT 23231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, 24231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY 25231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 26231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE 27231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 28643ca7872b450ea4efacab6188849e5aac2ba161Steve Block 29dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdochimport datetime 30dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch 31d0825bca7fe65beaee391d30da42e937db621564Steve Blockfrom google.appengine.ext import webapp 32d0825bca7fe65beaee391d30da42e937db621564Steve Blockfrom google.appengine.ext.webapp import template 33231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 34a94275402997c11dd2e778633dacf4b7e630a35dBen Murdochfrom model.queues import Queue 35d0825bca7fe65beaee391d30da42e937db621564Steve Blockfrom model.queuestatus import QueueStatus 36dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdochfrom model.workitems import WorkItems 37dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch 38dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch 39dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdochclass QueueBubble(object): 40dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch """View support class for recentstatus.html""" 41a94275402997c11dd2e778633dacf4b7e630a35dBen Murdoch def __init__(self, queue): 42a94275402997c11dd2e778633dacf4b7e630a35dBen Murdoch self._queue = queue 43a94275402997c11dd2e778633dacf4b7e630a35dBen Murdoch self._work_items = queue.work_items() 44a94275402997c11dd2e778633dacf4b7e630a35dBen Murdoch self._last_status = QueueStatus.all().filter("queue_name =", queue.name()).order("-date").get() 45dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch 46a94275402997c11dd2e778633dacf4b7e630a35dBen Murdoch # FIXME: name and display_name should be replaced by a .queue() accessor. 47dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch def name(self): 48a94275402997c11dd2e778633dacf4b7e630a35dBen Murdoch return self._queue.name() 49dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch 50dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch def display_name(self): 51a94275402997c11dd2e778633dacf4b7e630a35dBen Murdoch return self._queue.display_name() 52dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch 53dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch def _last_status_date(self): 54dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch if not self._last_status: 55dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch return None 56dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch return self._last_status.date 57dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch 58dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch def last_heard_from(self): 59dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch if not self._work_items: 60dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch return self._last_status_date() 61dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch return max(self._last_status_date(), self._work_items.date) 62dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch 63dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch def is_alive(self): 64dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch if not self.last_heard_from(): 65dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch return False 66dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch return self.last_heard_from() > (datetime.datetime.now() - datetime.timedelta(minutes=30)) 67dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch 68dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch def status_class(self): 69dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch if not self.is_alive(): 70dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch return "dead" 71dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch if self.pending_items_count() > 1: 72dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch return "behind" 73dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch return "alive" 74dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch 75dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch def status_text(self): 76dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch if not self._work_items: 77dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch return "Offline" 78dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch if not self._work_items.item_ids: 79dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch return "Idle" 80dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch return self._last_status.message 81dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch 82dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch def pending_items_count(self): 83dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch if not self._work_items: 84dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch return 0 85dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch return len(self._work_items.item_ids) 86dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch 87231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 88dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdochclass QueuesOverview(webapp.RequestHandler): 89231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 90dd8bb3de4f353a81954234999f1fea748aee2ea9Ben Murdoch def get(self): 91d0825bca7fe65beaee391d30da42e937db621564Steve Block template_values = { 92a94275402997c11dd2e778633dacf4b7e630a35dBen Murdoch "queues": [QueueBubble(queue) for queue in Queue.all()], 93d0825bca7fe65beaee391d30da42e937db621564Steve Block } 94d0825bca7fe65beaee391d30da42e937db621564Steve Block self.response.out.write(template.render("templates/recentstatus.html", template_values)) 95