def output()

in output/webhook.py [0:0]
52 lines of code
12 McCabe index (conditional complexity)

    def output(self):
        if 'url' not in self.output_config:
            raise NotConfiguredException('No URL defined in webhook.')

        url_template = self.jinja_environment.from_string(
            self.output_config['url'])
        url_template.name = 'url'
        url = url_template.render()

        method = 'GET'
        if 'method' in self.output_config:
            method = self.output_config['method']

        body = None
        if 'body' in self.output_config:
            body_template = self.jinja_environment.from_string(
                self.output_config['body'])
            body_template.name = 'body'
            body = body_template.render()

        http = httplib2.Http()
        if 'addBearerToken' in self.output_config and self.output_config[
                'addBearerToken']:
            credentials = GoogleCredentials.get_application_default()
            http = credentials.authorize(http)

        headers = {'User-agent': self._get_user_agent()}
        if body:
            headers['Content-type'] = 'application/x-www-form-urlencoded'
        if 'headers' in self.output_config:
            for header in self.output_config['headers']:
                header_template = self.jinja_environment.from_string(
                    header['value'])
                header_template.name = 'header'
                header_value = header_template.render()
                headers[header['name']] = header_value

        response, content = http.request(
            url,
            method,
            headers=headers,
            body=urllib.parse.quote(body) if body else None)
        if int(response['status']) >= 200 and int(response['status']) <= 399:
            self.logger.info('Webhook sent!',
                             extra={
                                 'status': response['status'],
                                 'content': content,
                                 'url': url,
                                 'method': method
                             })
        else:
            self.logger.error('Invalid status code from webhook.',
                              extra={
                                  'status': response['status'],
                                  'content': content,
                                  'url': url,
                                  'method': method
                              })