← Back to branch summary

~smoser/curtin/yakkety.lp1666986

« back to all changes in this revision

Viewing changes to curtin/reporter/handlers.py

  • Committer: Scott Moser
  • Date: 2016-07-12 16:28:59 UTC
  • mto: (58.1.1 pkg)
  • mto: This revision was merged to the branch mainline in revision 54.
  • Revision ID: smoser@ubuntu.com-20160712162859-f9jmixbnjsn3keu9
Tags: upstream-0.1.0~bzr399
Import upstream version 0.1.0~bzr399

Show diffs side-by-side

added added

removed removed

Lines of Context:
curtin/reporter/handlers.py
23
23
 
24
24
 
25
25
class LogHandler(ReportingHandler):
26
 
    """Publishes events to the cloud-init log at the ``INFO`` log level."""
 
26
    """Publishes events to the curtin log at the ``DEBUG`` log level."""
27
27
 
28
28
    def __init__(self, level="DEBUG"):
29
29
        super(LogHandler, self).__init__()
39
39
        self.level = level
40
40
 
41
41
    def publish_event(self, event):
42
 
        """Publish an event to the ``INFO`` log level."""
 
42
        """Publish an event to the ``DEBUG`` log level."""
43
43
        logger = logging.getLogger(
44
 
            '.'.join(['cloudinit', 'reporting', event.event_type, event.name]))
 
44
            '.'.join(['curtin', 'reporting', event.event_type, event.name]))
45
45
        logger.log(self.level, event.as_string())
46
46
 
47
47
 
55
55
class WebHookHandler(ReportingHandler):
56
56
    def __init__(self, endpoint, consumer_key=None, token_key=None,
57
57
                 token_secret=None, consumer_secret=None, timeout=None,
58
 
                 retries=None, level="INFO"):
 
58
                 retries=None, level="DEBUG"):
59
59
        super(WebHookHandler, self).__init__()
60
60
 
61
61
        self.oauth_helper = url_helper.OauthUrlHelper(
72
72
        self.headers = {'Content-Type': 'application/json'}
73
73
 
74
74
    def publish_event(self, event):
75
 
        if isinstance(event.level, int):
76
 
            ev_level = event.level
77
 
        else:
78
 
            try:
79
 
                ev_level = getattr(logging, event.level.upper())
80
 
            except:
81
 
                ev_level = logging.INFO
82
 
        if ev_level < self.level:
83
 
            return
84
75
        try:
85
76
            return self.oauth_helper.geturl(
86
77
                url=self.endpoint, data=event.as_dict(),