...
| Code Block | ||||||
|---|---|---|---|---|---|---|
| ||||||
CSS = "/home/ma/map/http/sms.css"
HEADER = '''<!DOCTYPE html>
<html>
<head>
<meta http-equiv="refresh" content="600">
<title>Status tree of {node_full_name} in {hostname}-{hostport}</title>
<link rel="stylesheet" type="text/css" href="file:{css}">
</head>
<body>
<table border=2 cellpadding=2> <tr>'''
FOOTER = '''</table>\n</body>\n</html>'''
class ObserverHtml(Observer):
""" simple ecflow watchdog class + html output """
def __init__(self, defs, node, port, path):
super(ObserverHtml, self).__init__(defs, node, port, path)
self.userdepth = 3
self.status_mask = ("queued", "complete", "unknown")
self.maxdepth = 100
self.openkids = True
def run(self):
import pprint
client = ec.Client(self.node, self.port)
path = self.path
while 1:
client.sync_local() # get changes, synced with local definition
node = client.get_defs().find_abs_node(path)
if 0: assert node is not None
if node is None: node = client.get_defs()
self.html_write(node)
time.sleep(90)
def header(self):
print >>self.fp, HEADER.format(node_full_name=self.path,
hostname= self.node,
css= CSS,
hostport=self.port)
def tail(self, node=None):
print >>self.fp, FOOTER
def countnext(self, anything, depth):
np = anything;
n = 0;
if np is not None and depth > self.maxdepth:
self.maxdepth = depth;
while np is not None:
n += 1
np = np.next()
return n;
def count(self, np=None, depth=1):
n = 0;
if np is None: return
if ("%s" % np.get_state() not in self.status_mask
or depth > self.userdepth):
return
if depth > self.maxdepth: self.maxdepth = depth;
def html_write(self, np, fpp=None):
if fpp is None:
# fpp = sys.stdout
fpp = open("example.html", "w")
# self.maxdepth = 0;
self.lineno = 0;
self.count(np,0);
self.fp = fpp;
self.header();
self.lineno = 0;
self.table(np,0);
self.tail(np);
fpp.close()
def write_link(self, node, horizontal, base, target):
print >>self.fp, '<base target="{target}">'.format(target=target)
for np in node.nodes:
print >>self.fp,' <td class="{status}">'.format(status="%s" % np.get_state())
print >>self.fp,'<a href="{base}/{name}.html">{name}</a>'.format(
base=base, name=np.name())
if horizontal and np.next():
print >>self.fp," </tr>"
print >>self.fp," <tr>"
print >>self.fp, " </tr>"
def img(self, name):
print >>self.fp, "<img src=\"../gifs/%s.gif\" alt=\"[%s]\">" % (name,name)
def decorations(self, node):
status = node.get_state()
if status == "halted": self.img("halted")
if status == "shutdown": self.img("shutdown")
# rerun
# messages
# late
# clock
def html_links(self, np, fpp=None, title=0, horizontal=0):
base = os.getenv("htmlbase");
target = os.getenv("htmltarget");
if base is not None: base = "od";
if target is not None: target = "level1";
self.fp = fpp;
self.header();
if title: printfprint >>self.fp," <th>{name}</th>".format(name=np.name())
if horizontal: print >>self.fp," </tr>"
if np.nodes: print >>self.fp, " <tr>"
self.write_link(np, horizontal, base, target);
self.tail();
def table(self, node, depth):
n = 0
if node is None: return 0
# if depth > self.userdepth: return 0 # depth
try: print node.get_abs_node_path()
except: pass
if 1:
try: status = "%s" % node.get_state() # node
except:
status = node.value() # attribute
print >>self.fp, "<td>%s:%s" % (node.name(),status),"</td>"
return 1
if status in self.status_mask: return 0
try:
print >>self.fp, "<td class='%s'>" % status, "%s" % node.name(),"</td>"
except:
for suite in node.suites: self.table(suite, depth) # Defs
return 0
# decorations?
if self.openkids:
# n += self.table(node.get_repeat(), depth+1)
for item in node.meters:
n += self.table(item, depth+1)
for item in node.events:
n += self.table(item, depth+1)
for item in node.labels:
n += self.table(item, depth+1)
i = 0
for kid in node.nodes:
if 1: print >>self.fp, "<tr>"
n += self.table(kid, depth+1)
i += 1
if n == 0: print >>self.fp, "</tr>"; n=1
return n |
...