# HG changeset patch
# User Daniel Dourvaris <daniel@rhodecode.com>
# Date 2016-08-11 10:16:29
# Node ID 6c88399f5ead30cae704b0cc1075b85f4d8eb064
# Parent  c5c553d9699a027a6f33a2520782030e25d043bc

integrations: add email integration, fixes #4159

diff --git a/rhodecode/integrations/__init__.py b/rhodecode/integrations/__init__.py
--- a/rhodecode/integrations/__init__.py
+++ b/rhodecode/integrations/__init__.py
@@ -21,7 +21,7 @@
 import logging
 
 from rhodecode.integrations.registry import IntegrationTypeRegistry
-from rhodecode.integrations.types import webhook, slack, hipchat
+from rhodecode.integrations.types import webhook, slack, hipchat, email
 
 log = logging.getLogger(__name__)
 
@@ -37,6 +37,8 @@ integration_type_registry.register_integ
     slack.SlackIntegrationType)
 integration_type_registry.register_integration_type(
     hipchat.HipchatIntegrationType)
+integration_type_registry.register_integration_type(
+    email.EmailIntegrationType)
 
 
 def integrations_event_handler(event):
diff --git a/rhodecode/integrations/types/email.py b/rhodecode/integrations/types/email.py
new file mode 100644
--- /dev/null
+++ b/rhodecode/integrations/types/email.py
@@ -0,0 +1,127 @@
+# -*- coding: utf-8 -*-
+
+# Copyright (C) 2012-2016  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 <http://www.gnu.org/licenses/>.
+#
+# 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 _, lazy_ugettext
+from rhodecode.lib.celerylib import run_task
+from rhodecode.lib.celerylib import tasks
+from rhodecode.integrations.types.base import IntegrationTypeBase
+from rhodecode.integrations.schema import IntegrationSettingsSchemaBase
+
+
+log = logging.getLogger()
+
+
+
+class EmailSettingsSchema(IntegrationSettingsSchemaBase):
+    @colander.instantiate(validator=colander.Length(min=1))
+    class recipients(colander.SequenceSchema):
+        title = lazy_ugettext('Recipients')
+        description = lazy_ugettext('Email addresses to send push events to')
+        widget = deform.widget.SequenceWidget(min_len=1)
+
+        recipient = colander.SchemaNode(
+            colander.String(),
+            title=lazy_ugettext('Email address'),
+            description=lazy_ugettext('Email address'),
+            default='',
+            validator=colander.Email(),
+            widget=deform.widget.TextInputWidget(
+                placeholder='user@domain.com',
+            ),
+        )
+
+
+class EmailIntegrationType(IntegrationTypeBase):
+    key = 'email'
+    display_name = lazy_ugettext('Email')
+    SettingsSchema = EmailSettingsSchema
+
+    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):
+    for commit in data['push']['commits']:
+        email_body_plaintext = repo_push_template_plaintext.render(
+            data=data,
+            commit=commit,
+            commit_msg=commit['message'],
+        )
+        email_body_html = repo_push_template_html.render(
+            data=data,
+            commit=commit,
+            commit_msg=commit['message_html'],
+        )
+
+        subject = '[%(repo_name)s] %(commit_id)s: %(commit_msg)s' % {
+            'repo_name': data['repo']['repo_name'],
+            'commit_id': commit['short_id'],
+            'commit_msg': commit['message'].split('\n')[0][:150]
+        }
+        for email_address in settings['recipients']:
+            task = run_task(
+                tasks.send_email, email_address, subject,
+                email_body_plaintext, email_body_html)
+
+
+# TODO: dan: add changed files, make html pretty
+repo_push_template_plaintext = Template('''
+User: ${data['actor']['username']}
+Branches: ${', '.join(branch['name'] for branch in data['push']['branches'])}
+Repository: ${data['repo']['url']}
+Commit: ${commit['raw_id']}
+URL: ${commit['url']}
+Author: ${commit['author']}
+Date:   ${commit['date']}
+Commit Message:
+
+${commit_msg}
+''')
+
+repo_push_template_html = Template('''
+User: ${data['actor']['username']}<br>
+Branches: ${', '.join(branch['name'] for branch in data['push']['branches'])}<br>
+Repository: ${data['repo']['url']}<br>
+Commit: ${commit['raw_id']}<br>
+URL: ${commit['url']}<br>
+Author: ${commit['author']}<br>
+Date:   ${commit['date']}<br>
+Commit Message:<br>
+<p>${commit_msg}</p>
+''')
diff --git a/rhodecode/lib/celerylib/tasks.py b/rhodecode/lib/celerylib/tasks.py
--- a/rhodecode/lib/celerylib/tasks.py
+++ b/rhodecode/lib/celerylib/tasks.py
@@ -70,7 +70,7 @@ def send_email(recipients, subject, body
     """
     log = get_logger(send_email)
 
-    email_config = email_config or config
+    email_config = email_config or rhodecode.CONFIG
     subject = "%s %s" % (email_config.get('email_prefix', ''), subject)
     if not recipients:
         # if recipients are not defined we send to email_config + all admins
diff --git a/rhodecode/templates/forms/sequence_item.pt b/rhodecode/templates/forms/sequence_item.pt
--- a/rhodecode/templates/forms/sequence_item.pt
+++ b/rhodecode/templates/forms/sequence_item.pt
@@ -13,7 +13,7 @@
                 repeat="msg field.error.messages()">
       <p tal:condition="msg"
          id="${errstr if repeat.msg.index==0 else '%s-%s' % (errstr, repeat.msg.index)}"
-         class="${error_class} help-block"
+         class="${error_class} help-block error-block"
          i18n:translate="">${msg}</p>
     </tal:errors>
   </div>