viewer.py

#!/usr/bin/env python3
 
 
 
import numbers
import json
import time
from io import StringIO
from html import escape
 
from dateutil.relativedelta import relativedelta
 
 
class IPythonWidget:
    """
    A base class for widgets in the hep ipython projects.
    """
 
    def create(self):
        """
        Override this method!
        """
        return None
 
    def show(self):
        """
        Show the widget
        """
        from IPython.core.display import display
 
        a = self.createcreate()
        display(a)
 
 
class StylingWidget(IPythonWidget):
    """The css string for styling the notebook."""
 
    
    css_string = """
        #notebook-container {
            width: 90%;
        }
 
        #menubar-container {
            width: 90%;
        }
 
        #header-container {
            width: 90%;
        }
        """
 
    def create(self):
        """Create the styling widget."""
        from IPython.core.display import HTML
        html = HTML("<style>\n%s\n</style>" % self.css_stringcss_string)
        return html
 
 
class ProgressBarViewer(IPythonWidget):
    """
    Viewer Object used to print data to the IPython Notebook.
    Do not use it on your own.
    """
 
    def __init__(self):
        """
        Create a new progress bar viewer.
        """
        from IPython.core.display import display
        from ipywidgets import FloatProgress, VBox, Layout, Label
 
        
        self.last_timelast_time = time.time()
        
        self.last_percentagelast_percentage = 0
 
        
        self.progress_barprogress_bar = FloatProgress(value=0, min=0, max=1,
                                          layout=Layout(width="100%", height="40px"))
        
        self.progress_labelprogress_label = Label()
        
        self.progress_boxprogress_box = VBox([self.progress_barprogress_bar, self.progress_labelprogress_label])
 
        display(self.progress_boxprogress_box)
 
    def update(self, text_or_percentage):
        """
        Update the widget with a new event number
        """
 
        if isinstance(text_or_percentage, numbers.Number):
            # text_or_percentage is percentage fraction
            current_percentage = float(text_or_percentage)
            current_time = time.time()
 
            remaining_percentage = 1.0 - current_percentage
 
            time_delta = current_time - self.last_timelast_time
            percentage_delta = current_percentage - self.last_percentagelast_percentage
 
            if percentage_delta > 0:
                time_delta_per_percentage = 1.0 * time_delta / percentage_delta
 
                # creates a human-readable time delta like '3 minutes 34 seconds'
                attrs = ['years', 'months', 'days', 'hours', 'minutes', 'seconds']
 
                def human_readable(delta): return ['%d %s' % (getattr(delta, attr), getattr(delta, attr) > 1 and attr or attr[:-1])
                                                   for attr in attrs if getattr(delta, attr)]
 
                times_list = human_readable(relativedelta(seconds=time_delta_per_percentage * remaining_percentage))
                human_readable_str = " ".join(times_list)
 
                display_text = "%d %% Remaining time: %s" % (
                    100 * current_percentage, human_readable_str)
 
                self.progress_labelprogress_label.value = display_text
                self.progress_barprogress_bar.value = float(current_percentage)
        else:
            # text_or_percentage is status string
            self.progress_labelprogress_label.value = f"Status: {text_or_percentage}"
            if "finished" in str(text_or_percentage):
                self.progress_barprogress_bar.value = 1.0
                self.progress_barprogress_bar.bar_style = "success"
            elif "failed" in str(text_or_percentage):
                self.progress_barprogress_bar.bar_style = "danger"
                # color box red to see failure even when progress value is 0
                self.progress_boxprogress_box.box_style = "danger"
 
    def show(self):
        """
        Display the widget
        """
        from IPython.core.display import display
 
        display(self.progress_boxprogress_box)
 
 
class CollectionsViewer(IPythonWidget):
    """
    Viewer object for the store entries.
    Do not use it on your own.
    """
 
    def __init__(self, collections):
        """
        Create a new collections viewer with the collections object from the process.
        Collections must be a StoreContentList with a list of StoreContents.
        """
        
        self.collectionscollections = collections
 
        
        self.table_row_htmltable_row_html = """<tr><td style="padding: 10px 0;">{content.name}</td>
                                 <td style="padding: 10px 0;">{content.number}</td></tr>"""
 
    def create(self):
        """
        Create the widget
        """
 
        import ipywidgets as widgets
 
        if self.collectionscollections is None:
            return widgets.HTML("")
 
        a = widgets.Tab()
        children = []
 
        for i, event in enumerate(self.collectionscollections):
            html = widgets.HTML()
            html.value = """<table style="border-collapse: separate; border-spacing: 50px 0;">"""
            for store_content in event.content:
                html.value += self.table_row_htmltable_row_html.format(content=store_content)
            html.value += "</table>"
            children.append(html)
            a.set_title(i, "Event " + str(event.event_number))
 
        a.children = children
 
        return a
 
 
class StatisticsViewer(IPythonWidget):
    """
    A viewer widget for displaying the
    statistics in a nicer way in ipython
    """
 
    def __init__(self, statistics):
        """ Init the widget with the statistics from the process.
        The statistics must be an instance of Statistics. """
        
        self.statisticsstatistics = statistics
 
        
        self.table_column_htmltable_column_html = """<td style="padding: 10px;">{content}</td>"""
        
        self.table_column_3_htmltable_column_3_html = """<td colspan="3" style="padding: 10px;">{content}</td>"""
        
        self.table_cell_htmltable_cell_html = """<td style="padding: 10px; text-align: left">{content}</td>"""
        
        self.table_cell_3_htmltable_cell_3_html = """<td style=\"text-align: right\">{content[0]}</td><td>{content[1]}</td><td>{content[2]}</td>"""
 
    def create(self):
        """
        Create the widget
        """
        import ipywidgets as widgets
 
        if self.statisticsstatistics is None:
            return widgets.HTML("")
 
        html = widgets.HTML()
        html.value = """<table style="border-collapse: collapsed; border: 1px solid black;">
                        <thead><tr style="background: #AAA; font-weight: bold">"""
 
        for column in self.statisticsstatistics.columns:
            if column.three_column_format:
                html.value += self.table_column_3_htmltable_column_3_html.format(content=column.display_name)
            else:
                html.value += self.table_column_htmltable_column_html.format(content=column.display_name)
        html.value += "</tr></thead><tbody>"
 
        for n, module in enumerate(self.statisticsstatistics.modules):
            if n % 2 == 1:
                html.value += """<tr style="background: #EEE;">"""
            else:
                html.value += """<tr>"""
 
            for column in self.statisticsstatistics.columns:
                if column.three_column_format:
                    html.value += self.table_cell_3_htmltable_cell_3_html.format(content=module[column.name])
                else:
                    html.value += self.table_cell_htmltable_cell_html.format(content=module[column.name])
 
            html.value += "</tr>"
 
        # SUMMARY html.value += """<tr style="border: 1px solid black; font-weight: bold">"""
 
        html.value += "</tbody></table>"
        html.margin = "10px"
        return html
 
 
class ProcessViewer:
    """
    A widget to summarize all the infromation from different processes.
    Must be filled with the widgets of the single processes
    """
 
    def __init__(self, children):
        """
        Create a process viewer
        """
 
        
        self.childrenchildren = children
 
    def create(self):
        """
        Create the widget
        """
        import ipywidgets as widgets
 
        a = widgets.Tab()
        for i in range(len(self.childrenchildren)):
            a.set_title(i, "Process " + str(i))
        a.children = [children.create() for children in self.childrenchildren if children is not None]
        return a
 
    def show(self):
        """
        Show the widget
        """
 
        import ipywidgets as widgets
        from IPython.core.display import display
 
        if len(self.childrenchildren) > 0:
            a = self.createcreate()
 
        else:
            a = widgets.HTML("<strong>Calculation list empty. Nothing to show.</strong>")
 
        display(a)
 
 
class LogViewer(IPythonWidget):
    """
    A widget to show the log of a calculation.
    """
 
    def __init__(self, log_content):
        """
        Initialize the log viewer.
        """
 
        
        self.log_contentlog_content = log_content
 
        
        self.log_levelslog_levels = ["DEBUG", "INFO", "RESULT", "WARNING", "ERROR", "FATAL", "DEFAULT"]
 
        
        self.log_color_codeslog_color_codes = {"DEBUG": "gray", "ERROR": "red", "FATAL": "red", "INFO": "black", "RESULT": "green",
                                "WARNING": "orange", "DEFAULT": "black"}
 
        
        self.log_messagelog_message = """<pre class="log-line-{type_lower}" title="{info}">[{level}] {message}{var_output}</pre>"""
 
        
        self.toggle_button_linetoggle_button_line = """<a onclick="$('.log-line-{type_lower}').hide();
                                                 $('.log-line-{type_lower}-hide-button').hide();
                                                 $('.log-line-{type_lower}-show-button').show();"
                                        style="cursor: pointer; margin: 0px 10px;"
                                        class="log-line-{type_lower}-hide-button">Hide {type_upper}</a>
                                     <a onclick="$('.log-line-{type_lower}').show();
                                                 $('.log-line-{type_lower}-hide-button').show();
                                                 $('.log-line-{type_lower}-show-button').hide();"
                                        style="cursor: pointer; margin: 0px 10px; display: none;"
                                        class="log-line-{type_lower}-show-button">Show {type_upper}</a>"""
 
    def format_logmessage(self, buf, message, indent=4, base=0):
        """
        Format the json object of a logmessage as key: value list with recursion and indentation
        Funnily this is faster than json.dumps() and looks a bit better in the title attribute
        """
        for key, val in message.items():
            if not val:
                continue
            if isinstance(val, dict):
                buf.write(f"{key}:\n")
                self.format_logmessageformat_logmessage(buf, val, indent=indent, base=base + indent)
            else:
                buf.write(base * " ")
                buf.write(f"{key}: {val!r}\n")
 
    def create(self):
        """
        Create the log viewer.
        """
        from ipywidgets import HTML, HBox, VBox
 
        output = StringIO()
        output.write("<style scoped>\n")
        for level, color in self.log_color_codeslog_color_codes.items():
            level = level.lower()
            output.write(f".log-line-{level} {{margin:0; padding:0; line-height:normal; color: {color} !important;}}\n")
 
        output.write("""</style><div style="max-height: 400px; overflow-y: auto; width: 100%";>""")
 
        for line in self.log_contentlog_content.split("\n"):
            if line.startswith('{"level"'):
                try:
                    message = json.loads(line)
                    # ok, message is parsed. Prepare some info string which
                    # contains the info about the message in a indented
                    # format but don't completely json or pprint because it
                    # takes to much time
                    buf = StringIO()
                    self.format_logmessageformat_logmessage(buf, message)
                    info = escape(buf.getvalue())
                    # add variables if necessary
                    variables = message.get("variables", "")
                    if variables:
                        variables = "\n".join([""] + [f"\t{k} = {v}" for k, v in variables.items()])
                    # and write out
                    level = message["level"].lower()
                    output.write(self.log_messagelog_message.format(info=info, type_lower=level, var_output=variables, **message))
                    continue
                except json.JSONDecodeError:
                    # any error: treat as default output, not a log line
                    pass
 
            output.write('<pre class="log-line-default">')
            output.write(line)
            output.write('</pre>')
 
        output.write("</div>")
 
        html = HTML()
        html.value = output.getvalue()
        html.width = "100%"
        html.margin = "5px"
 
        buttons = []
        for type in self.log_levelslog_levels:
            buttons.append(HTML(self.toggle_button_linetoggle_button_line.format(type_lower=type.lower(), type_upper=type.upper())))
 
        buttons_view = HBox(buttons)
        buttons_view.margin = "10px 0px"
        result_vbox = VBox((buttons_view, html))
 
        return result_vbox