get_commits_stats(repo_name, ts_min_y, ts_max_y, recurse_limit - 1)

        elif recurse_limit <= 0:

            log.debug('Not recursing - limit has been reached')

        else:

            log.debug('Not recursing')

    except celerylib.LockHeld:

        log.info('Task with key %s already running', lockkey)

        return 'Task with key %s already running' % lockkey

@celerylib.task

@celerylib.dbsession

    """

    Sends an email with defined parameters from the .ini files.

    :param recipients: list of recipients, if this is None, the defined email

        address from field 'email_to' and all admins is used instead

    :param subject: subject of the mail

    :param body: body of the mail

    :param html_body: html version of body

    :param headers: dictionary of prepopulated e-mail headers

    """

    assert isinstance(recipients, list), recipients

    if headers is None:

        headers = {}

    else:

        # do not modify the original headers object passed by the caller

        headers = headers.copy()

    email_config = config

    email_prefix = email_config.get('email_prefix', '')

    if email_prefix:

        subject = "%s %s" % (email_prefix, subject)

        # If there are still no recipients, there are no admins and no address

        # configured in email_to, so return.

        if not recipients:

            log.error("No recipients specified and no fallback available.")

            return False

        log.warning("No recipients specified for '%s' - sending to admins %s", subject, ' '.join(recipients))

    # SMTP sender

    envelope_from = email_config.get('app_email_from', 'Kallithea')

    # 'From' header

        # In case app_email_from is in "Some Name <e-mail>" format, we first

        # extract the e-mail address.

        envelope_addr = author_email(envelope_from)

        headers['From'] = '"%s" <%s>' % (

            envelope_addr)

    user = email_config.get('smtp_username')

    passwd = email_config.get('smtp_password')

    mail_server = email_config.get('smtp_server')

    mail_port = email_config.get('smtp_port')

    tls = str2bool(email_config.get('smtp_use_tls'))

    ssl = str2bool(email_config.get('smtp_use_ssl'))

    debug = str2bool(email_config.get('debug'))

    smtp_auth = email_config.get('smtp_auth')

    logmsg = ("Mail details:\n"

                            .get_email_description(type_, **txt_kwargs)

        email_txt_body = EmailNotificationModel() \

                            .get_email_tmpl(type_, 'txt', **txt_kwargs)

        email_html_body = EmailNotificationModel() \

                            .get_email_tmpl(type_, 'html', **html_kwargs)

        # don't send email to person who created this comment

        rec_objs = set(recipients_objs).difference(set([created_by_obj]))

        # send email with notification to all other participants

        for rec in rec_objs:

            tasks.send_email([rec.email], email_subject, email_txt_body,

class EmailNotificationModel(object):

    TYPE_CHANGESET_COMMENT = NotificationModel.TYPE_CHANGESET_COMMENT

    TYPE_MESSAGE = NotificationModel.TYPE_MESSAGE # only used for testing

    # NotificationModel.TYPE_MENTION is not used

    TYPE_PASSWORD_RESET = 'password_link'

    TYPE_REGISTRATION = NotificationModel.TYPE_REGISTRATION

    TYPE_PULL_REQUEST = NotificationModel.TYPE_PULL_REQUEST

    TYPE_PULL_REQUEST_COMMENT = NotificationModel.TYPE_PULL_REQUEST_COMMENT

    TYPE_DEFAULT = 'default'

        new.password = password

        new.email = email

        new.name = name

        new.lastname = lastname

        new.api_key = generate_api_key()

        Session().add(new)

        Session().commit()

        token = UserModel().get_reset_password_token(

            User.get_by_username(username), timestamp, self.session_csrf_secret_token())

        collected = []

            collected.append((recipients, subject, body, html_body))

        with mock.patch.object(kallithea.lib.celerylib.tasks, 'send_email', mock_send_email), \

                mock.patch.object(time, 'time', lambda: timestamp):

            response = self.app.post(base.url(controller='login',

                                         action='password_reset'),

                                     {'email': email,

                                      '_session_csrf_secret_token': self.session_csrf_secret_token()})

        self.checkSessionFlash(response, 'A password reset confirmation code has been sent')

        ((recipients, subject, body, html_body),) = collected

<!doctype html>

<html lang="en">

<head><title>Notifications</title><meta http-equiv="Content-Type" content="text/html; charset=UTF-8"></head>

<body>

<hr/>

<h1>cs_comment, is_mention=False, status_change=None</h1>

<pre>

To: u2@example.com

Subject: [Comment] repo/name changeset cafe1234 "This changeset did something cl..." on brunch

</pre>

<hr/>

<pre>http://comment.org

Comment on Changeset "This changeset did something clever which is hard to explain"

Opinionated User (jsmith):

This is the new 'comment'.

                </tr>

            </table>

        </td>

        <td width="30px" style="width:30px"></td>

    </tr>

</table>

<!--/body-->

<!--/html-->

<hr/>

<hr/>

<h1>cs_comment, is_mention=True, status_change=None</h1>

<pre>

To: u2@example.com

Subject: [Comment] repo/name changeset cafe1234 "This changeset did something cl..." on brunch

</pre>

<hr/>

<pre>http://comment.org

Mention in Comment on Changeset "This changeset did something clever which is hard to explain"

Opinionated User (jsmith):

This is the new 'comment'.

                </tr>

            </table>

        </td>

        <td width="30px" style="width:30px"></td>

    </tr>

</table>

<!--/body-->

<!--/html-->

<hr/>

<hr/>

<h1>cs_comment, is_mention=False, status_change='Approved'</h1>

<pre>

To: u2@example.com

Subject: [Approved: Comment] repo/name changeset cafe1234 "This changeset did something cl..." on brunch

</pre>

<hr/>

<pre>http://comment.org

Comment on Changeset "This changeset did something clever which is hard to explain"

Opinionated User (jsmith):

Status change: Approved

                </tr>

            </table>

        </td>

        <td width="30px" style="width:30px"></td>

    </tr>

</table>

<!--/body-->

<!--/html-->

<hr/>

<hr/>

<h1>cs_comment, is_mention=True, status_change='Approved'</h1>

<pre>

To: u2@example.com

Subject: [Approved: Comment] repo/name changeset cafe1234 "This changeset did something cl..." on brunch

</pre>

<hr/>

<pre>http://comment.org

Mention in Comment on Changeset "This changeset did something clever which is hard to explain"

Opinionated User (jsmith):

Status change: Approved

                </tr>

            </table>

        </td>

        <td width="30px" style="width:30px"></td>

    </tr>

</table>

<!--/body-->

<!--/html-->

<hr/>

<hr/>

<h1>message</h1>

<pre>

To: u2@example.com

Subject: Test Message

</pre>

<hr/>

<pre>This is the 'body' of the "test" message

 - nothing interesting here except indentation.</pre>

<hr/>

<!--!doctype html-->

<!--html lang="en"-->

<!--head-->

    <!--title--><!--/title-->

    <!--meta name="viewport" content="width=device-width"-->

                </tr>

            </table>

        </td>

        <td width="30px" style="width:30px"></td>

    </tr>

</table>

<!--/body-->

<!--/html-->

<hr/>

<hr/>

<h1>registration</h1>

<pre>

To: u2@example.com

Subject: New user newbie registered

</pre>

<hr/>

<pre>http://newbie.org

New User Registration

Username: newbie

Full Name: New Full Name

                </tr>

            </table>

        </td>

        <td width="30px" style="width:30px"></td>

    </tr>

</table>

<!--/body-->

<!--/html-->

<hr/>

<hr/>

<h1>pull_request, is_mention=False</h1>

<pre>

To: u2@example.com

Subject: [Review] repo/name PR #7 "The Title" from devbranch by u2

</pre>

<hr/>

<pre>http://pr.org/7

Added as Reviewer of Pull Request #7 "The Title" by Requesting User (root)

Pull request #7 "The Title" by u2 u3 (u2)

from https://dev.org/repo branch devbranch

to http://mainline.com/repo branch trunk

                </tr>

            </table>

        </td>

        <td width="30px" style="width:30px"></td>

    </tr>

</table>

<!--/body-->

<!--/html-->

<hr/>

<hr/>

<h1>pull_request, is_mention=True</h1>

<pre>

To: u2@example.com

Subject: [Review] repo/name PR #7 "The Title" from devbranch by u2

</pre>

<hr/>

<pre>http://pr.org/7

Mention on Pull Request #7 "The Title" by Requesting User (root)

Pull request #7 "The Title" by u2 u3 (u2)

from https://dev.org/repo branch devbranch

to http://mainline.com/repo branch trunk

                </tr>

            </table>

        </td>

        <td width="30px" style="width:30px"></td>

    </tr>

</table>

<!--/body-->

<!--/html-->

<hr/>

<hr/>

<h1>pull_request_comment, is_mention=False, status_change=None, closing_pr=False</h1>

<pre>

To: u2@example.com

Subject: [Comment] repo/name PR #7 "The Title" from devbranch by u2

</pre>

<hr/>

<pre>http://pr.org/comment

Comment on Pull Request #7 "The Title"

Opinionated User (jsmith):

Me too!

                </tr>

            </table>

        </td>

        <td width="30px" style="width:30px"></td>

    </tr>

</table>

<!--/body-->

<!--/html-->

<hr/>

<hr/>

<h1>pull_request_comment, is_mention=True, status_change=None, closing_pr=False</h1>

<pre>

To: u2@example.com

Subject: [Comment] repo/name PR #7 "The Title" from devbranch by u2

</pre>

<hr/>

<pre>http://pr.org/comment

Mention in Comment on Pull Request #7 "The Title"

Opinionated User (jsmith):

Me too!

                </tr>

            </table>

        </td>

        <td width="30px" style="width:30px"></td>

    </tr>

</table>

<!--/body-->

<!--/html-->

<hr/>

<hr/>

<h1>pull_request_comment, is_mention=False, status_change='Under Review', closing_pr=False</h1>

<pre>

To: u2@example.com

Subject: [Under Review: Comment] repo/name PR #7 "The Title" from devbranch by u2

</pre>

<hr/>

<pre>http://pr.org/comment

Comment on Pull Request #7 "The Title"

Opinionated User (jsmith):

Status change: Under Review

                </tr>

            </table>

        </td>

        <td width="30px" style="width:30px"></td>

    </tr>

</table>

<!--/body-->

<!--/html-->

<hr/>

<hr/>

<h1>pull_request_comment, is_mention=True, status_change='Under Review', closing_pr=False</h1>

<pre>

To: u2@example.com

Subject: [Under Review: Comment] repo/name PR #7 "The Title" from devbranch by u2

</pre>

<hr/>

<pre>http://pr.org/comment

Mention in Comment on Pull Request #7 "The Title"

Opinionated User (jsmith):

Status change: Under Review

                </tr>

            </table>

        </td>

        <td width="30px" style="width:30px"></td>

    </tr>

</table>

<!--/body-->

<!--/html-->

<hr/>

<hr/>

<h1>pull_request_comment, is_mention=False, status_change=None, closing_pr=True</h1>

<pre>

To: u2@example.com

Subject: [Closing: Comment] repo/name PR #7 "The Title" from devbranch by u2

</pre>

<hr/>

<pre>http://pr.org/comment

Pull Request #7 "The Title" Closed

Opinionated User (jsmith):

The pull request has been closed.

                </tr>

            </table>

        </td>

        <td width="30px" style="width:30px"></td>

    </tr>

</table>

<!--/body-->

<!--/html-->

<hr/>

<hr/>

<h1>pull_request_comment, is_mention=True, status_change=None, closing_pr=True</h1>

<pre>

To: u2@example.com

Subject: [Closing: Comment] repo/name PR #7 "The Title" from devbranch by u2

</pre>

<hr/>

<pre>http://pr.org/comment

Mention in Comment on Pull Request #7 "The Title"

Opinionated User (jsmith):

The pull request has been closed.

                </tr>

            </table>

        </td>

        <td width="30px" style="width:30px"></td>

    </tr>

</table>

<!--/body-->

<!--/html-->

<hr/>

<hr/>

<h1>pull_request_comment, is_mention=False, status_change='Under Review', closing_pr=True</h1>

<pre>

To: u2@example.com

Subject: [Under Review, Closing: Comment] repo/name PR #7 "The Title" from devbranch by u2

</pre>

<hr/>

<pre>http://pr.org/comment

Pull Request #7 "The Title" Closed

Opinionated User (jsmith):

Status change: Under Review

                </tr>

            </table>

        </td>

        <td width="30px" style="width:30px"></td>

    </tr>

</table>

<!--/body-->

<!--/html-->

<hr/>

<hr/>

<h1>pull_request_comment, is_mention=True, status_change='Under Review', closing_pr=True</h1>

<pre>

To: u2@example.com

Subject: [Under Review, Closing: Comment] repo/name PR #7 "The Title" from devbranch by u2

</pre>

<hr/>

<pre>http://pr.org/comment

Mention in Comment on Pull Request #7 "The Title"

Opinionated User (jsmith):

Status change: Under Review

                </tr>

            </table>

        </td>

        <td width="30px" style="width:30px"></td>

    </tr>

</table>

<!--/body-->

<!--/html-->

<hr/>

<hr/>

<h1>TYPE_PASSWORD_RESET</h1>

<pre>

To: john@doe.com

Subject: Password reset link

</pre>

<hr/>

<pre>Password Reset Request

Hello John Doe,

We have received a request to reset the password for your account.

To set a new password, click the following link:

        u3 = UserModel().create_or_update(username='u3',

                                        password='qweqwe',

                                        email='u3@example.com',

                                        firstname='u3', lastname='u3')

        Session().commit()

        self.u3 = u3.user_id

    def test_create_notification(self):

        with test_context(self.app):

            usrs = [self.u1, self.u2]

                assert recipients == ['u2@example.com']

                assert subject == 'Test Message'

                assert body == "hi there"

                assert '>hi there<' in html_body

            with mock.patch.object(kallithea.lib.celerylib.tasks, 'send_email', send_email):

                NotificationModel().create(created_by=self.u1,

                                                   subject='subj', body='hi there',

                                                   recipients=usrs)

    @mock.patch.object(h, 'canonical_url', (lambda arg, **kwargs: 'http://%s/?%s' % (arg, '&'.join('%s=%s' % (k, v) for (k, v) in sorted(kwargs.items())))))

    def test_dump_html_mails(self):

        # Exercise all notification types and dump them to one big html file

        l = []

            l.append('<hr/>\n')

            l.append('<h1>%s</h1>\n' % desc) # desc is from outer scope

            l.append('<pre>\n')

            l.append('To: %s\n' % ' '.join(recipients))

            l.append('Subject: %s\n' % subject)

            l.append('</pre>\n')

            l.append('<hr/>\n')

            l.append('<pre>%s</pre>\n' % body)

            l.append('<hr/>\n')

            l.append(html_body)

            l.append('<hr/>\n')

        with test_context(self.app):

            with mock.patch.object(kallithea.lib.celerylib.tasks, 'send_email', send_email):

                pr_kwargs = dict(

                        # desc is used as "global" variable

                        NotificationModel().create(created_by=self.u1,

                                                           subject='unused', body=body, email_kwargs=kwargs,

                                                           recipients=[self.u2], type_=type_)

                # Email type TYPE_PASSWORD_RESET has no corresponding notification type - test it directly:

                desc = 'TYPE_PASSWORD_RESET'

                kwargs = dict(user='John Doe', reset_token='decbf64715098db5b0bd23eab44bd792670ab746', reset_url='http://reset.com/decbf64715098db5b0bd23eab44bd792670ab746')

                kallithea.lib.celerylib.tasks.send_email(['john@doe.com'],

                    "Password reset link",

                    EmailNotificationModel().get_email_tmpl(EmailNotificationModel.TYPE_PASSWORD_RESET, 'txt', **kwargs),

                    EmailNotificationModel().get_email_tmpl(EmailNotificationModel.TYPE_PASSWORD_RESET, 'html', **kwargs),

        out = '<!doctype html>\n<html lang="en">\n<head><title>Notifications</title><meta http-equiv="Content-Type" content="text/html; charset=UTF-8"></head>\n<body>\n%s\n</body>\n</html>\n' % \

            re.sub(r'<(/?(?:!doctype|html|head|title|meta|body)\b[^>]*)>', r'<!--\1-->', ''.join(l))

        outfn = os.path.join(os.path.dirname(__file__), 'test_dump_html_mails.out.html')

        reffn = os.path.join(os.path.dirname(__file__), 'test_dump_html_mails.ref.html')

        with open(outfn, 'w') as f:

            f.write(out)

        with open(reffn) as f:

            ref = f.read()

        assert ref == out # copy test_dump_html_mails.out.html to test_dump_html_mails.ref.html to update expectations

        os.unlink(outfn)

        recipients = ['rcpt1', 'rcpt2']

        envelope_from = 'noreply@mailserver.org'

        subject = 'subject'

        body = 'body'

        html_body = 'html_body'

        author = User.get_by_username(base.TEST_USER_REGULAR_LOGIN)

        config_mock = {

            'smtp_server': mailserver,

            'app_email_from': envelope_from,

        }

        with mock.patch('kallithea.lib.celerylib.tasks.config', config_mock):

        assert smtplib_mock.lastdest == set(recipients)

        assert smtplib_mock.lastsender == envelope_from

        assert 'From: "Kallithea Admin (no-reply)" <%s>' % envelope_from in smtplib_mock.lastmsg

        assert 'Subject: %s' % subject in smtplib_mock.lastmsg

        assert body in smtplib_mock.lastmsg

        assert html_body in smtplib_mock.lastmsg

    def test_send_mail_with_author_full_mail_from(self):

        mailserver = 'smtp.mailserver.org'

        recipients = ['ræcpt1', 'receptor2 <rcpt2@example.com>', 'tæst@example.com', 'Tæst <test@example.com>']

        envelope_addr = 'noreply@mailserver.org'

        envelope_from = 'Söme Næme <%s>' % envelope_addr

        subject = 'subject'

        body = 'body'

        html_body = 'html_body'

        author = User.get_by_username(base.TEST_USER_REGULAR_LOGIN)

        config_mock = {

            'smtp_server': mailserver,

            'app_email_from': envelope_from,

        }

        with mock.patch('kallithea.lib.celerylib.tasks.config', config_mock):

        assert smtplib_mock.lastdest == set(recipients)

        assert smtplib_mock.lastsender == envelope_from

        assert 'From: "Kallithea Admin (no-reply)" <%s>' % envelope_addr in smtplib_mock.lastmsg

        assert 'Subject: %s' % subject in smtplib_mock.lastmsg

        assert body in smtplib_mock.lastmsg

        assert html_body in smtplib_mock.lastmsg

    def test_send_mail_extra_headers(self):

        mailserver = 'smtp.mailserver.org'

        recipients = ['rcpt1', 'rcpt2']

        envelope_from = 'noreply@mailserver.org'

        subject = 'subject'

        body = 'body'

        html_body = 'html_body'

        author = User(name='foo', lastname='(fubar) "baz"')

        headers = {'extra': 'yes'}

        config_mock = {

            'smtp_server': mailserver,

            'app_email_from': envelope_from,

        }

        with mock.patch('kallithea.lib.celerylib.tasks.config', config_mock):

            kallithea.lib.celerylib.tasks.send_email(recipients, subject, body, html_body,

        assert smtplib_mock.lastdest == set(recipients)

        assert smtplib_mock.lastsender == envelope_from

        assert r'From: "foo (fubar) \"baz\" (no-reply)" <%s>' % envelope_from in smtplib_mock.lastmsg

        assert 'Subject: %s' % subject in smtplib_mock.lastmsg

        assert body in smtplib_mock.lastmsg

        assert html_body in smtplib_mock.lastmsg

        assert 'Extra: yes' in smtplib_mock.lastmsg

        # verify that headers dict hasn't mutated by send_email

        assert headers == {'extra': 'yes'}