${subject}

# -*- coding: utf-8 -*- # Copyright (C) 2012-2018 RhodeCode GmbH # # This program is free software: you can redistribute it and/or modify # it under the terms of the GNU Affero General Public License, version 3 # (only), as published by the Free Software Foundation. # # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU General Public License for more details. # # You should have received a copy of the GNU Affero General Public License # along with this program. If not, see . # # This program is dual-licensed. If you wish to learn more about the # RhodeCode Enterprise Edition, including its added features, Support services, # and proprietary license terms, please see https://rhodecode.com/licenses/ from __future__ import unicode_literals import deform import logging import colander from mako.template import Template from rhodecode import events from rhodecode.translation import _ from rhodecode.lib.celerylib import run_task from rhodecode.lib.celerylib import tasks from rhodecode.integrations.types.base import ( IntegrationTypeBase, render_with_traceback) log = logging.getLogger(__name__) repo_push_template_plaintext = Template(''' Commits: % for commit in data['push']['commits']: ${commit['url']} by ${commit['author']} at ${commit['date']} ${commit['message']} ---- % endfor ''') ## TODO (marcink): think about putting this into a file, or use base.mako email template repo_push_template_html = Template(''' ${subject}

${'RhodeCode'}

% if data['push']['commits']: % for commit in data['push']['commits']: ${commit['short_id']} by ${commit['author']} at ${commit['date']}
${commit['message_html']}

% endfor % else: No commit data % endif

${'This is a notification from RhodeCode. %(instance_url)s' % {'instance_url': instance_url}}

''') class EmailSettingsSchema(colander.Schema): @colander.instantiate(validator=colander.Length(min=1)) class recipients(colander.SequenceSchema): title = _('Recipients') description = _('Email addresses to send push events to') widget = deform.widget.SequenceWidget(min_len=1) recipient = colander.SchemaNode( colander.String(), title=_('Email address'), description=_('Email address'), default='', validator=colander.Email(), widget=deform.widget.TextInputWidget( placeholder='user@domain.com', ), ) class EmailIntegrationType(IntegrationTypeBase): key = 'email' display_name = _('Email') description = _('Send repo push summaries to a list of recipients via email') @classmethod def icon(cls): return ''' ''' def settings_schema(self): schema = EmailSettingsSchema() return schema def send_event(self, event): data = event.as_dict() log.debug('got event: %r', event) if isinstance(event, events.RepoPushEvent): repo_push_handler(data, self.settings) else: log.debug('ignoring event: %r', event) def repo_push_handler(data, settings): commit_num = len(data['push']['commits']) server_url = data['server_url'] if commit_num == 1: if data['push']['branches']: _subject = '[{repo_name}] {author} pushed {commit_num} commit on branches: {branches}' else: _subject = '[{repo_name}] {author} pushed {commit_num} commit' subject = _subject.format( author=data['actor']['username'], repo_name=data['repo']['repo_name'], commit_num=commit_num, branches=', '.join( branch['name'] for branch in data['push']['branches']) ) else: if data['push']['branches']: _subject = '[{repo_name}] {author} pushed {commit_num} commits on branches: {branches}' else: _subject = '[{repo_name}] {author} pushed {commit_num} commits' subject = _subject.format( author=data['actor']['username'], repo_name=data['repo']['repo_name'], commit_num=commit_num, branches=', '.join( branch['name'] for branch in data['push']['branches'])) email_body_plaintext = render_with_traceback( repo_push_template_plaintext, data=data, subject=subject, instance_url=server_url) email_body_html = render_with_traceback( repo_push_template_html, data=data, subject=subject, instance_url=server_url) for email_address in settings['recipients']: run_task( tasks.send_email, email_address, subject, email_body_plaintext, email_body_html)