mirror of https://github.com/zulip/zulip.git
Split test_hooks file into one test file per hook.
This commit is contained in:
Tomasz Kolek
Tim Abbott
parent
9197c82d8f
commit
d4da60fbe2
File diff suppressed because it is too large
Load Diff
|
|
@ -0,0 +1,13 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class IFTTTHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'ifttt'
|
||||
URL_TEMPLATE = "/api/v1/external/ifttt?stream={stream}&api_key={api_key}"
|
||||
FIXTURE_DIR_NAME = 'ifttt'
|
||||
|
||||
def test_ifttt_when_subject_and_body_are_correct(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"Email sent from email@email.com"
|
||||
expected_message = u"Email subject: Subject"
|
||||
self.send_and_test_stream_message('correct_subject_and_body', expected_subject, expected_message)
|
||||
|
|
@ -0,0 +1,13 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class AirbrakeHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'airbrake'
|
||||
URL_TEMPLATE = u"/api/v1/external/airbrake?stream={stream}&api_key={api_key}"
|
||||
FIXTURE_DIR_NAME = 'airbrake'
|
||||
|
||||
def test_airbrake_error_message(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"ZulipIntegrationTest"
|
||||
expected_message = u"[ZeroDivisionError](https://zulip.airbrake.io/projects/125209/groups/1705190192091077626): \"Error message from logger\" occurred."
|
||||
self.send_and_test_stream_message('error_message', expected_subject, expected_message)
|
||||
|
|
@ -0,0 +1,55 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from six import text_type
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class BeanstalkHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'commits'
|
||||
URL_TEMPLATE = u"/api/v1/external/beanstalk"
|
||||
|
||||
def test_git_single(self):
|
||||
# type: () -> None
|
||||
expected_subject = "work-test"
|
||||
expected_message = """Leo Franchi [pushed](http://lfranchi-svn.beanstalkapp.com/work-test) to branch master
|
||||
|
||||
* [e50508d](http://lfranchi-svn.beanstalkapp.com/work-test/changesets/e50508df): add some stuff
|
||||
"""
|
||||
self.send_and_test_stream_message('git_singlecommit', expected_subject, expected_message,
|
||||
content_type=None,
|
||||
**self.api_auth(self.TEST_USER_EMAIL))
|
||||
|
||||
def test_git_multiple(self):
|
||||
# type: () -> None
|
||||
expected_subject = "work-test"
|
||||
expected_message = """Leo Franchi [pushed](http://lfranchi-svn.beanstalkapp.com/work-test) to branch master
|
||||
|
||||
* [edf529c](http://lfranchi-svn.beanstalkapp.com/work-test/changesets/edf529c7): Added new file
|
||||
* [c2a191b](http://lfranchi-svn.beanstalkapp.com/work-test/changesets/c2a191b9): Filled in new file with some stuff
|
||||
* [2009815](http://lfranchi-svn.beanstalkapp.com/work-test/changesets/20098158): More work to fix some bugs
|
||||
"""
|
||||
self.send_and_test_stream_message('git_multiple', expected_subject, expected_message,
|
||||
content_type=None,
|
||||
**self.api_auth(self.TEST_USER_EMAIL))
|
||||
|
||||
def test_svn_addremove(self):
|
||||
# type: () -> None
|
||||
expected_subject = "svn r3"
|
||||
expected_message = """Leo Franchi pushed [revision 3](http://lfranchi-svn.beanstalkapp.com/work-test/changesets/3):
|
||||
|
||||
> Removed a file and added another one!"""
|
||||
self.send_and_test_stream_message('svn_addremove', expected_subject, expected_message,
|
||||
content_type=None,
|
||||
**self.api_auth(self.TEST_USER_EMAIL))
|
||||
|
||||
def test_svn_changefile(self):
|
||||
# type: () -> None
|
||||
expected_subject = "svn r2"
|
||||
expected_message = """Leo Franchi pushed [revision 2](http://lfranchi-svn.beanstalkapp.com/work-test/changesets/2):
|
||||
|
||||
> Added some code"""
|
||||
self.send_and_test_stream_message('svn_changefile', expected_subject, expected_message,
|
||||
content_type=None,
|
||||
**self.api_auth(self.TEST_USER_EMAIL))
|
||||
|
||||
def get_body(self, fixture_name):
|
||||
# type: (text_type) -> Dict[str, text_type]
|
||||
return {'payload': self.fixture_data('beanstalk', fixture_name)}
|
||||
|
|
@ -0,0 +1,115 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class Bitbucket2HookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'bitbucket2'
|
||||
URL_TEMPLATE = "/api/v1/external/bitbucket2?stream={stream}&api_key={api_key}"
|
||||
FIXTURE_DIR_NAME = 'bitbucket2'
|
||||
EXPECTED_SUBJECT = u"Repository name"
|
||||
|
||||
def test_bitbucket2_on_push_event(self):
|
||||
# type: () -> None
|
||||
expected_message = u"User Tomasz(login: kolaszek) pushed [1 commit](https://bitbucket.org/kolaszek/repository-name/branch/master) into master branch."
|
||||
self.send_and_test_stream_message('push', self.EXPECTED_SUBJECT, expected_message)
|
||||
|
||||
def test_bitbucket2_on_fork_event(self):
|
||||
# type: () -> None
|
||||
expected_message = u"User Tomasz(login: kolaszek) forked the repository into [kolaszek/repository-name2](https://bitbucket.org/kolaszek/repository-name2)."
|
||||
self.send_and_test_stream_message('fork', self.EXPECTED_SUBJECT, expected_message)
|
||||
|
||||
def test_bitbucket2_on_commit_comment_created_event(self):
|
||||
# type: () -> None
|
||||
expected_message = u"User Tomasz(login: kolaszek) added [comment](https://bitbucket.org/kolaszek/repository-name/commits/32c4ea19aa3af10acd08e419e2c354941a365d74#comment-3354963) to commit."
|
||||
self.send_and_test_stream_message('commit_comment_created', self.EXPECTED_SUBJECT, expected_message)
|
||||
|
||||
def test_bitbucket2_on_commit_status_changed_event(self):
|
||||
# type: () -> None
|
||||
expected_message = u"[System mybuildtool](https://my-build-tool.com/builds/MY-PROJECT/BUILD-777) changed status of https://bitbucket.org/kolaszek/repository-name/9fec847784abb10b2fa567ee63b85bd238955d0e to SUCCESSFUL."
|
||||
self.send_and_test_stream_message('commit_status_changed', self.EXPECTED_SUBJECT, expected_message)
|
||||
|
||||
def test_bitbucket2_on_issue_created_event(self):
|
||||
# type: () -> None
|
||||
expected_message = u"User Tomasz(login: kolaszek) created [an issue](https://bitbucket.org/kolaszek/repository-name/issues/2/bug)"
|
||||
self.send_and_test_stream_message('issue_created', self.EXPECTED_SUBJECT, expected_message)
|
||||
|
||||
def test_bitbucket2_on_issue_updated_event(self):
|
||||
# type: () -> None
|
||||
expected_message = u"User Tomasz(login: kolaszek) updated [an issue](https://bitbucket.org/kolaszek/repository-name/issues/2/bug)"
|
||||
self.send_and_test_stream_message('issue_updated', self.EXPECTED_SUBJECT, expected_message)
|
||||
|
||||
def test_bitbucket2_on_issue_commented_event(self):
|
||||
# type: () -> None
|
||||
expected_message = u"User Tomasz(login: kolaszek) commented [an issue](https://bitbucket.org/kolaszek/repository-name/issues/2/bug)"
|
||||
self.send_and_test_stream_message('issue_commented', self.EXPECTED_SUBJECT, expected_message)
|
||||
|
||||
def test_bitbucket2_on_pull_request_created_event(self):
|
||||
# type: () -> None
|
||||
expected_message = u"User Tomasz(login: kolaszek) created [\"new commit\" pull request](https://bitbucket.org/kolaszek/repository-name/pull-requests/1)"
|
||||
kwargs = {
|
||||
"HTTP_X_EVENT_KEY": 'pullrequest:created'
|
||||
}
|
||||
self.send_and_test_stream_message('pull_request_created_or_updated', self.EXPECTED_SUBJECT, expected_message, **kwargs)
|
||||
|
||||
def test_bitbucket2_on_pull_request_updated_event(self):
|
||||
# type: () -> None
|
||||
expected_message = u"User Tomasz(login: kolaszek) updated [\"new commit\" pull request](https://bitbucket.org/kolaszek/repository-name/pull-requests/1)"
|
||||
kwargs = {
|
||||
"HTTP_X_EVENT_KEY": 'pullrequest:updated'
|
||||
}
|
||||
self.send_and_test_stream_message('pull_request_created_or_updated', self.EXPECTED_SUBJECT, expected_message, **kwargs)
|
||||
|
||||
def test_bitbucket2_on_pull_request_approved_event(self):
|
||||
# type: () -> None
|
||||
expected_message = u"User Tomasz(login: kolaszek) approved [\"new commit\" pull request](https://bitbucket.org/kolaszek/repository-name/pull-requests/1)"
|
||||
kwargs = {
|
||||
"HTTP_X_EVENT_KEY": 'pullrequest:approved'
|
||||
}
|
||||
self.send_and_test_stream_message('pull_request_approved_or_unapproved', self.EXPECTED_SUBJECT, expected_message, **kwargs)
|
||||
|
||||
def test_bitbucket2_on_pull_request_unapproved_event(self):
|
||||
# type: () -> None
|
||||
expected_message = u"User Tomasz(login: kolaszek) unapproved [\"new commit\" pull request](https://bitbucket.org/kolaszek/repository-name/pull-requests/1)"
|
||||
kwargs = {
|
||||
"HTTP_X_EVENT_KEY": 'pullrequest:unapproved'
|
||||
}
|
||||
self.send_and_test_stream_message('pull_request_approved_or_unapproved', self.EXPECTED_SUBJECT, expected_message, **kwargs)
|
||||
|
||||
def test_bitbucket2_on_pull_request_declined_event(self):
|
||||
# type: () -> None
|
||||
expected_message = u"User Tomasz(login: kolaszek) rejected [\"new commit\" pull request](https://bitbucket.org/kolaszek/repository-name/pull-requests/1)"
|
||||
kwargs = {
|
||||
"HTTP_X_EVENT_KEY": 'pullrequest:rejected'
|
||||
}
|
||||
self.send_and_test_stream_message('pull_request_merged_or_rejected', self.EXPECTED_SUBJECT, expected_message, **kwargs)
|
||||
|
||||
def test_bitbucket2_on_pull_request_merged_event(self):
|
||||
# type: () -> None
|
||||
expected_message = u"User Tomasz(login: kolaszek) merged [\"new commit\" pull request](https://bitbucket.org/kolaszek/repository-name/pull-requests/1)"
|
||||
kwargs = {
|
||||
"HTTP_X_EVENT_KEY": 'pullrequest:merged'
|
||||
}
|
||||
self.send_and_test_stream_message('pull_request_merged_or_rejected', self.EXPECTED_SUBJECT, expected_message, **kwargs)
|
||||
|
||||
def test_bitbucket2_on_pull_request_comment_created_event(self):
|
||||
# type: () -> None
|
||||
expected_message = u"User Tomasz(login: kolaszek) created [comment](https://bitbucket.org/kolaszek/repository-name/pull-requests/3/_/diff#comment-20576503 in [\"a\" pull request](https://bitbucket.org/kolaszek/repository-name/pull-requests/3)"
|
||||
kwargs = {
|
||||
"HTTP_X_EVENT_KEY": 'pullrequest:comment_created'
|
||||
}
|
||||
self.send_and_test_stream_message('pull_request_comment_action', self.EXPECTED_SUBJECT, expected_message, **kwargs)
|
||||
|
||||
def test_bitbucket2_on_pull_request_comment_updated_event(self):
|
||||
# type: () -> None
|
||||
expected_message = u"User Tomasz(login: kolaszek) updated [comment](https://bitbucket.org/kolaszek/repository-name/pull-requests/3/_/diff#comment-20576503 in [\"a\" pull request](https://bitbucket.org/kolaszek/repository-name/pull-requests/3)"
|
||||
kwargs = {
|
||||
"HTTP_X_EVENT_KEY": 'pullrequest:comment_updated'
|
||||
}
|
||||
self.send_and_test_stream_message('pull_request_comment_action', self.EXPECTED_SUBJECT, expected_message, **kwargs)
|
||||
|
||||
def test_bitbucket2_on_pull_request_comment_deleted_event(self):
|
||||
# type: () -> None
|
||||
expected_message = u"User Tomasz(login: kolaszek) deleted [comment](https://bitbucket.org/kolaszek/repository-name/pull-requests/3/_/diff#comment-20576503 in [\"a\" pull request](https://bitbucket.org/kolaszek/repository-name/pull-requests/3)"
|
||||
kwargs = {
|
||||
"HTTP_X_EVENT_KEY": 'pullrequest:comment_deleted'
|
||||
}
|
||||
self.send_and_test_stream_message('pull_request_comment_action', self.EXPECTED_SUBJECT, expected_message, **kwargs)
|
||||
|
|
@ -0,0 +1,31 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class CircleCiHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'circleci'
|
||||
URL_TEMPLATE = u"/api/v1/external/circleci?stream={stream}&api_key={api_key}"
|
||||
FIXTURE_DIR_NAME = 'circleci'
|
||||
|
||||
def test_circleci_build_in_success_status(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"RepoName"
|
||||
expected_message = u"[Build](https://circleci.com/gh/username/project/build_number) triggered by username on master branch succeeded."
|
||||
self.send_and_test_stream_message('build_passed', expected_subject, expected_message)
|
||||
|
||||
def test_circleci_build_in_failed_status(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"RepoName"
|
||||
expected_message = u"[Build](https://circleci.com/gh/username/project/build_number) triggered by username on master branch failed."
|
||||
self.send_and_test_stream_message('build_failed', expected_subject, expected_message)
|
||||
|
||||
def test_circleci_build_in_failed_status_when_previous_build_failed_too(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"RepoName"
|
||||
expected_message = u"[Build](https://circleci.com/gh/username/project/build_number) triggered by username on master branch is still failing."
|
||||
self.send_and_test_stream_message('build_failed_when_previous_build_failed', expected_subject, expected_message)
|
||||
|
||||
def test_circleci_build_in_success_status_when_previous_build_failed_too(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"RepoName"
|
||||
expected_message = u"[Build](https://circleci.com/gh/username/project/build_number) triggered by username on master branch fixed."
|
||||
self.send_and_test_stream_message('build_passed_when_previous_build_failed', expected_subject, expected_message)
|
||||
|
|
@ -0,0 +1,40 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class CodeshipHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'codeship'
|
||||
URL_TEMPLATE = u"/api/v1/external/codeship?stream={stream}&api_key={api_key}"
|
||||
SUBJECT = u"codeship/docs"
|
||||
FIXTURE_DIR_NAME = 'codeship'
|
||||
|
||||
def test_codeship_build_in_testing_status_message(self):
|
||||
# type: () -> None
|
||||
"""
|
||||
Tests if codeship testing status is mapped correctly
|
||||
"""
|
||||
expected_message = u"[Build](https://www.codeship.com/projects/10213/builds/973711) triggered by beanieboi on master branch started."
|
||||
self.send_and_test_stream_message('testing_build', self.SUBJECT, expected_message)
|
||||
|
||||
def test_codeship_build_in_error_status_message(self):
|
||||
# type: () -> None
|
||||
"""
|
||||
Tests if codeship error status is mapped correctly
|
||||
"""
|
||||
expected_message = u"[Build](https://www.codeship.com/projects/10213/builds/973711) triggered by beanieboi on master branch failed."
|
||||
self.send_and_test_stream_message('error_build', self.SUBJECT, expected_message)
|
||||
|
||||
def test_codeship_build_in_success_status_message(self):
|
||||
# type: () -> None
|
||||
"""
|
||||
Tests if codeship success status is mapped correctly
|
||||
"""
|
||||
expected_message = u"[Build](https://www.codeship.com/projects/10213/builds/973711) triggered by beanieboi on master branch succeeded."
|
||||
self.send_and_test_stream_message('success_build', self.SUBJECT, expected_message)
|
||||
|
||||
def test_codeship_build_in_other_status_status_message(self):
|
||||
# type: () -> None
|
||||
"""
|
||||
Tests if codeship other status is mapped correctly
|
||||
"""
|
||||
expected_message = u"[Build](https://www.codeship.com/projects/10213/builds/973711) triggered by beanieboi on master branch has some_other_status status."
|
||||
self.send_and_test_stream_message('other_status_build', self.SUBJECT, expected_message)
|
||||
|
|
@ -0,0 +1,23 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class CrashlyticsHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'crashlytics'
|
||||
URL_TEMPLATE = u"/api/v1/external/crashlytics?stream={stream}&api_key={api_key}"
|
||||
FIXTURE_DIR_NAME = 'crashlytics'
|
||||
|
||||
def test_crashlytics_verification_message(self):
|
||||
# type: () -> None
|
||||
last_message_before_request = self.get_last_message()
|
||||
payload = self.get_body('verification')
|
||||
url = self.build_webhook_url()
|
||||
result = self.client_post(url, payload, content_type="application/json")
|
||||
last_message_after_request = self.get_last_message()
|
||||
self.assert_json_success(result)
|
||||
self.assertEqual(last_message_after_request.pk, last_message_before_request.pk)
|
||||
|
||||
def test_crashlytics_build_in_success_status(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"123: Issue Title"
|
||||
expected_message = u"[Issue](http://crashlytics.com/full/url/to/issue) impacts at least 16 device(s)."
|
||||
self.send_and_test_stream_message('issue_message', expected_subject, expected_message)
|
||||
|
|
@ -0,0 +1,94 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from six import text_type
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class FreshdeskHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'freshdesk'
|
||||
URL_TEMPLATE = u"/api/v1/external/freshdesk?stream={stream}"
|
||||
|
||||
def test_ticket_creation(self):
|
||||
# type: () -> None
|
||||
"""
|
||||
Messages are generated on ticket creation through Freshdesk's
|
||||
"Dispatch'r" service.
|
||||
"""
|
||||
expected_subject = u"#11: Test ticket subject ☃"
|
||||
expected_message = u"""Requester ☃ Bob <requester-bob@example.com> created [ticket #11](http://test1234zzz.freshdesk.com/helpdesk/tickets/11):
|
||||
|
||||
~~~ quote
|
||||
Test ticket description ☃.
|
||||
~~~
|
||||
|
||||
Type: **Incident**
|
||||
Priority: **High**
|
||||
Status: **Pending**"""
|
||||
self.send_and_test_stream_message('ticket_created', expected_subject, expected_message, content_type="application/x-www-form-urlencoded", **self.api_auth(self.TEST_USER_EMAIL))
|
||||
|
||||
def test_status_change(self):
|
||||
# type: () -> None
|
||||
"""
|
||||
Messages are generated when a ticket's status changes through
|
||||
Freshdesk's "Observer" service.
|
||||
"""
|
||||
expected_subject = u"#11: Test ticket subject ☃"
|
||||
expected_message = """Requester Bob <requester-bob@example.com> updated [ticket #11](http://test1234zzz.freshdesk.com/helpdesk/tickets/11):
|
||||
|
||||
Status: **Resolved** => **Waiting on Customer**"""
|
||||
self.send_and_test_stream_message('status_changed', expected_subject, expected_message,
|
||||
content_type="application/x-www-form-urlencoded",
|
||||
**self.api_auth(self.TEST_USER_EMAIL))
|
||||
|
||||
def test_priority_change(self):
|
||||
# type: () -> None
|
||||
"""
|
||||
Messages are generated when a ticket's priority changes through
|
||||
Freshdesk's "Observer" service.
|
||||
"""
|
||||
expected_subject = u"#11: Test ticket subject"
|
||||
expected_message = """Requester Bob <requester-bob@example.com> updated [ticket #11](http://test1234zzz.freshdesk.com/helpdesk/tickets/11):
|
||||
|
||||
Priority: **High** => **Low**"""
|
||||
self.send_and_test_stream_message('priority_changed', expected_subject, expected_message,
|
||||
content_type="application/x-www-form-urlencoded",
|
||||
**self.api_auth(self.TEST_USER_EMAIL))
|
||||
|
||||
def note_change(self, fixture, note_type):
|
||||
# type: (text_type, text_type) -> None
|
||||
"""
|
||||
Messages are generated when a note gets added to a ticket through
|
||||
Freshdesk's "Observer" service.
|
||||
"""
|
||||
expected_subject = u"#11: Test ticket subject"
|
||||
expected_message = """Requester Bob <requester-bob@example.com> added a {} note to [ticket #11](http://test1234zzz.freshdesk.com/helpdesk/tickets/11).""".format(note_type)
|
||||
self.send_and_test_stream_message(fixture, expected_subject, expected_message,
|
||||
content_type="application/x-www-form-urlencoded",
|
||||
**self.api_auth(self.TEST_USER_EMAIL))
|
||||
|
||||
def test_private_note_change(self):
|
||||
# type: () -> None
|
||||
self.note_change("private_note", "private")
|
||||
|
||||
def test_public_note_change(self):
|
||||
# type: () -> None
|
||||
self.note_change("public_note", "public")
|
||||
|
||||
def test_inline_image(self):
|
||||
# type: () -> None
|
||||
"""
|
||||
Freshdesk sends us descriptions as HTML, so we have to make the
|
||||
descriptions Zulip markdown-friendly while still doing our best to
|
||||
preserve links and images.
|
||||
"""
|
||||
expected_subject = u"#12: Not enough ☃ guinea pigs"
|
||||
expected_message = u"Requester \u2603 Bob <requester-bob@example.com> created [ticket #12](http://test1234zzz.freshdesk.com/helpdesk/tickets/12):\n\n~~~ quote\nThere are too many cat pictures on the internet \u2603. We need more guinea pigs. Exhibit 1:\n\n \n\n\n[guinea_pig.png](http://cdn.freshdesk.com/data/helpdesk/attachments/production/12744808/original/guinea_pig.png)\n~~~\n\nType: **Problem**\nPriority: **Urgent**\nStatus: **Open**"
|
||||
self.send_and_test_stream_message("inline_images", expected_subject, expected_message,
|
||||
content_type="application/x-www-form-urlencoded",
|
||||
**self.api_auth(self.TEST_USER_EMAIL))
|
||||
|
||||
def build_webhook_url(self):
|
||||
# type: () -> text_type
|
||||
return self.URL_TEMPLATE.format(stream=self.STREAM_NAME)
|
||||
|
||||
def get_body(self, fixture_name):
|
||||
# type: (text_type) -> text_type
|
||||
return self.fixture_data("freshdesk", fixture_name, file_type="json")
|
||||
|
|
@ -0,0 +1,270 @@
|
|||
import ujson
|
||||
from six import text_type
|
||||
from typing import Dict, Optional
|
||||
|
||||
from zerver.models import Message
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class GithubV1HookTests(WebhookTestCase):
|
||||
STREAM_NAME = None # type: Optional[text_type]
|
||||
URL_TEMPLATE = u"/api/v1/external/github"
|
||||
FIXTURE_DIR_NAME = 'github'
|
||||
SEND_STREAM = False
|
||||
BRANCHES = None # type: Optional[text_type]
|
||||
|
||||
push_content = """zbenjamin [pushed](https://github.com/zbenjamin/zulip-test/compare/4f9adc4777d5...b95449196980) to branch master
|
||||
|
||||
* [48c329a](https://github.com/zbenjamin/zulip-test/commit/48c329a0b68a9a379ff195ee3f1c1f4ab0b2a89e): Add baz
|
||||
* [06ebe5f](https://github.com/zbenjamin/zulip-test/commit/06ebe5f472a32f6f31fd2a665f0c7442b69cce72): Baz needs to be longer
|
||||
* [b954491](https://github.com/zbenjamin/zulip-test/commit/b95449196980507f08209bdfdc4f1d611689b7a8): Final edit to baz, I swear
|
||||
"""
|
||||
|
||||
def test_spam_branch_is_ignored(self):
|
||||
# type: () -> None
|
||||
self.SEND_STREAM = True
|
||||
self.STREAM_NAME = 'commits'
|
||||
self.BRANCHES = 'dev,staging'
|
||||
data = self.get_body('push')
|
||||
|
||||
# We subscribe to the stream in this test, even though
|
||||
# it won't get written, to avoid failing for the wrong
|
||||
# reason.
|
||||
self.subscribe_to_stream(self.TEST_USER_EMAIL, self.STREAM_NAME)
|
||||
|
||||
prior_count = Message.objects.count()
|
||||
|
||||
result = self.client_post(self.URL_TEMPLATE, data)
|
||||
self.assert_json_success(result)
|
||||
|
||||
after_count = Message.objects.count()
|
||||
self.assertEqual(prior_count, after_count)
|
||||
|
||||
def get_body(self, fixture_name):
|
||||
# type: (text_type) -> Dict[str, text_type]
|
||||
api_key = self.get_api_key(self.TEST_USER_EMAIL)
|
||||
data = ujson.loads(self.fixture_data(self.FIXTURE_DIR_NAME, 'v1_' + fixture_name))
|
||||
data.update({'email': self.TEST_USER_EMAIL,
|
||||
'api-key': api_key,
|
||||
'payload': ujson.dumps(data['payload'])})
|
||||
if self.SEND_STREAM:
|
||||
data['stream'] = self.STREAM_NAME
|
||||
|
||||
if self.BRANCHES is not None:
|
||||
data['branches'] = self.BRANCHES
|
||||
return data
|
||||
|
||||
def basic_test(self, fixture_name, stream_name, expected_subject, expected_content, send_stream=False, branches=None):
|
||||
# type: (text_type, text_type, text_type, text_type, bool, Optional[text_type]) -> None
|
||||
self.STREAM_NAME = stream_name
|
||||
self.SEND_STREAM = send_stream
|
||||
self.BRANCHES = branches
|
||||
self.send_and_test_stream_message(fixture_name, expected_subject, expected_content, content_type=None)
|
||||
|
||||
def test_user_specified_branches(self):
|
||||
# type: () -> None
|
||||
self.basic_test('push', 'my_commits', 'zulip-test', self.push_content,
|
||||
send_stream=True, branches="master,staging")
|
||||
|
||||
def test_user_specified_stream(self):
|
||||
# type: () -> None
|
||||
"""Around May 2013 the github webhook started to specify the stream.
|
||||
Before then, the stream was hard coded to "commits"."""
|
||||
self.basic_test('push', 'my_commits', 'zulip-test', self.push_content,
|
||||
send_stream=True)
|
||||
|
||||
def test_legacy_hook(self):
|
||||
# type: () -> None
|
||||
self.basic_test('push', 'commits', 'zulip-test', self.push_content)
|
||||
|
||||
def test_issues_opened(self):
|
||||
# type: () -> None
|
||||
self.basic_test('issues_opened', 'issues',
|
||||
"zulip-test: issue 5: The frobnicator doesn't work",
|
||||
"zbenjamin opened [issue 5](https://github.com/zbenjamin/zulip-test/issues/5)\n\n~~~ quote\nI tried changing the widgets, but I got:\r\n\r\nPermission denied: widgets are immutable\n~~~")
|
||||
|
||||
def test_issue_comment(self):
|
||||
# type: () -> None
|
||||
self.basic_test('issue_comment', 'issues',
|
||||
"zulip-test: issue 5: The frobnicator doesn't work",
|
||||
"zbenjamin [commented](https://github.com/zbenjamin/zulip-test/issues/5#issuecomment-23374280) on [issue 5](https://github.com/zbenjamin/zulip-test/issues/5)\n\n~~~ quote\nWhoops, I did something wrong.\r\n\r\nI'm sorry.\n~~~")
|
||||
|
||||
def test_issues_closed(self):
|
||||
# type: () -> None
|
||||
self.basic_test('issues_closed', 'issues',
|
||||
"zulip-test: issue 5: The frobnicator doesn't work",
|
||||
"zbenjamin closed [issue 5](https://github.com/zbenjamin/zulip-test/issues/5)")
|
||||
|
||||
def test_pull_request_opened(self):
|
||||
# type: () -> None
|
||||
self.basic_test('pull_request_opened', 'commits',
|
||||
"zulip-test: pull request 7: Counting is hard.",
|
||||
"lfaraone opened [pull request 7](https://github.com/zbenjamin/zulip-test/pull/7)\n\n~~~ quote\nOmitted something I think?\n~~~")
|
||||
|
||||
def test_pull_request_closed(self):
|
||||
# type: () -> None
|
||||
self.basic_test('pull_request_closed', 'commits',
|
||||
"zulip-test: pull request 7: Counting is hard.",
|
||||
"zbenjamin closed [pull request 7](https://github.com/zbenjamin/zulip-test/pull/7)")
|
||||
|
||||
def test_pull_request_synchronize(self):
|
||||
# type: () -> None
|
||||
self.basic_test('pull_request_synchronize', 'commits',
|
||||
"zulip-test: pull request 13: Even more cowbell.",
|
||||
"zbenjamin synchronized [pull request 13](https://github.com/zbenjamin/zulip-test/pull/13)")
|
||||
|
||||
def test_pull_request_comment(self):
|
||||
# type: () -> None
|
||||
self.basic_test('pull_request_comment', 'commits',
|
||||
"zulip-test: pull request 9: Less cowbell.",
|
||||
"zbenjamin [commented](https://github.com/zbenjamin/zulip-test/pull/9#issuecomment-24771110) on [pull request 9](https://github.com/zbenjamin/zulip-test/pull/9)\n\n~~~ quote\nYeah, who really needs more cowbell than we already have?\n~~~")
|
||||
|
||||
def test_pull_request_comment_user_specified_stream(self):
|
||||
# type: () -> None
|
||||
self.basic_test('pull_request_comment', 'my_commits',
|
||||
"zulip-test: pull request 9: Less cowbell.",
|
||||
"zbenjamin [commented](https://github.com/zbenjamin/zulip-test/pull/9#issuecomment-24771110) on [pull request 9](https://github.com/zbenjamin/zulip-test/pull/9)\n\n~~~ quote\nYeah, who really needs more cowbell than we already have?\n~~~",
|
||||
send_stream=True)
|
||||
|
||||
def test_commit_comment(self):
|
||||
# type: () -> None
|
||||
self.basic_test('commit_comment', 'commits',
|
||||
"zulip-test: commit 7c994678d2f98797d299abed852d3ff9d0834533",
|
||||
"zbenjamin [commented](https://github.com/zbenjamin/zulip-test/commit/7c994678d2f98797d299abed852d3ff9d0834533#commitcomment-4252302)\n\n~~~ quote\nAre we sure this is enough cowbell?\n~~~")
|
||||
|
||||
def test_commit_comment_line(self):
|
||||
# type: () -> None
|
||||
self.basic_test('commit_comment_line', 'commits',
|
||||
"zulip-test: commit 7c994678d2f98797d299abed852d3ff9d0834533",
|
||||
"zbenjamin [commented](https://github.com/zbenjamin/zulip-test/commit/7c994678d2f98797d299abed852d3ff9d0834533#commitcomment-4252307) on `cowbell`, line 13\n\n~~~ quote\nThis line adds /unlucky/ cowbell (because of its line number). We should remove it.\n~~~")
|
||||
|
||||
class GithubV2HookTests(WebhookTestCase):
|
||||
STREAM_NAME = None # type: Optional[text_type]
|
||||
URL_TEMPLATE = u"/api/v1/external/github"
|
||||
FIXTURE_DIR_NAME = 'github'
|
||||
SEND_STREAM = False
|
||||
BRANCHES = None # type: Optional[text_type]
|
||||
|
||||
push_content = """zbenjamin [pushed](https://github.com/zbenjamin/zulip-test/compare/4f9adc4777d5...b95449196980) to branch master
|
||||
|
||||
* [48c329a](https://github.com/zbenjamin/zulip-test/commit/48c329a0b68a9a379ff195ee3f1c1f4ab0b2a89e): Add baz
|
||||
* [06ebe5f](https://github.com/zbenjamin/zulip-test/commit/06ebe5f472a32f6f31fd2a665f0c7442b69cce72): Baz needs to be longer
|
||||
* [b954491](https://github.com/zbenjamin/zulip-test/commit/b95449196980507f08209bdfdc4f1d611689b7a8): Final edit to baz, I swear
|
||||
"""
|
||||
|
||||
def test_spam_branch_is_ignored(self):
|
||||
# type: () -> None
|
||||
self.SEND_STREAM = True
|
||||
self.STREAM_NAME = 'commits'
|
||||
self.BRANCHES = 'dev,staging'
|
||||
data = self.get_body('push')
|
||||
|
||||
# We subscribe to the stream in this test, even though
|
||||
# it won't get written, to avoid failing for the wrong
|
||||
# reason.
|
||||
self.subscribe_to_stream(self.TEST_USER_EMAIL, self.STREAM_NAME)
|
||||
|
||||
prior_count = Message.objects.count()
|
||||
|
||||
result = self.client_post(self.URL_TEMPLATE, data)
|
||||
self.assert_json_success(result)
|
||||
|
||||
after_count = Message.objects.count()
|
||||
self.assertEqual(prior_count, after_count)
|
||||
|
||||
def get_body(self, fixture_name):
|
||||
# type: (text_type) -> Dict[str, text_type]
|
||||
api_key = self.get_api_key(self.TEST_USER_EMAIL)
|
||||
data = ujson.loads(self.fixture_data(self.FIXTURE_DIR_NAME, 'v2_' + fixture_name))
|
||||
data.update({'email': self.TEST_USER_EMAIL,
|
||||
'api-key': api_key,
|
||||
'payload': ujson.dumps(data['payload'])})
|
||||
if self.SEND_STREAM:
|
||||
data['stream'] = self.STREAM_NAME
|
||||
|
||||
if self.BRANCHES is not None:
|
||||
data['branches'] = self.BRANCHES
|
||||
return data
|
||||
|
||||
def basic_test(self, fixture_name, stream_name, expected_subject, expected_content, send_stream=False, branches=None):
|
||||
# type: (text_type, text_type, text_type, text_type, bool, Optional[text_type]) -> None
|
||||
self.STREAM_NAME = stream_name
|
||||
self.SEND_STREAM = send_stream
|
||||
self.BRANCHES = branches
|
||||
self.send_and_test_stream_message(fixture_name, expected_subject, expected_content, content_type=None)
|
||||
|
||||
def test_user_specified_branches(self):
|
||||
# type: () -> None
|
||||
self.basic_test('push', 'my_commits', 'zulip-test', self.push_content,
|
||||
send_stream=True, branches="master,staging")
|
||||
|
||||
def test_user_specified_stream(self):
|
||||
# type: () -> None
|
||||
"""Around May 2013 the github webhook started to specify the stream.
|
||||
Before then, the stream was hard coded to "commits"."""
|
||||
self.basic_test('push', 'my_commits', 'zulip-test', self.push_content,
|
||||
send_stream=True)
|
||||
|
||||
def test_legacy_hook(self):
|
||||
# type: () -> None
|
||||
self.basic_test('push', 'commits', 'zulip-test', self.push_content)
|
||||
|
||||
def test_issues_opened(self):
|
||||
# type: () -> None
|
||||
self.basic_test('issues_opened', 'issues',
|
||||
"zulip-test: issue 5: The frobnicator doesn't work",
|
||||
"zbenjamin opened [issue 5](https://github.com/zbenjamin/zulip-test/issues/5)\n\n~~~ quote\nI tried changing the widgets, but I got:\r\n\r\nPermission denied: widgets are immutable\n~~~")
|
||||
|
||||
def test_issue_comment(self):
|
||||
# type: () -> None
|
||||
self.basic_test('issue_comment', 'issues',
|
||||
"zulip-test: issue 5: The frobnicator doesn't work",
|
||||
"zbenjamin [commented](https://github.com/zbenjamin/zulip-test/issues/5#issuecomment-23374280) on [issue 5](https://github.com/zbenjamin/zulip-test/issues/5)\n\n~~~ quote\nWhoops, I did something wrong.\r\n\r\nI'm sorry.\n~~~")
|
||||
|
||||
def test_issues_closed(self):
|
||||
# type: () -> None
|
||||
self.basic_test('issues_closed', 'issues',
|
||||
"zulip-test: issue 5: The frobnicator doesn't work",
|
||||
"zbenjamin closed [issue 5](https://github.com/zbenjamin/zulip-test/issues/5)")
|
||||
|
||||
def test_pull_request_opened(self):
|
||||
# type: () -> None
|
||||
self.basic_test('pull_request_opened', 'commits',
|
||||
"zulip-test: pull request 7: Counting is hard.",
|
||||
"lfaraone opened [pull request 7](https://github.com/zbenjamin/zulip-test/pull/7)\n\n~~~ quote\nOmitted something I think?\n~~~")
|
||||
|
||||
def test_pull_request_closed(self):
|
||||
# type: () -> None
|
||||
self.basic_test('pull_request_closed', 'commits',
|
||||
"zulip-test: pull request 7: Counting is hard.",
|
||||
"zbenjamin closed [pull request 7](https://github.com/zbenjamin/zulip-test/pull/7)")
|
||||
|
||||
def test_pull_request_synchronize(self):
|
||||
# type: () -> None
|
||||
self.basic_test('pull_request_synchronize', 'commits',
|
||||
"zulip-test: pull request 13: Even more cowbell.",
|
||||
"zbenjamin synchronized [pull request 13](https://github.com/zbenjamin/zulip-test/pull/13)")
|
||||
|
||||
def test_pull_request_comment(self):
|
||||
# type: () -> None
|
||||
self.basic_test('pull_request_comment', 'commits',
|
||||
"zulip-test: pull request 9: Less cowbell.",
|
||||
"zbenjamin [commented](https://github.com/zbenjamin/zulip-test/pull/9#issuecomment-24771110) on [pull request 9](https://github.com/zbenjamin/zulip-test/pull/9)\n\n~~~ quote\nYeah, who really needs more cowbell than we already have?\n~~~")
|
||||
|
||||
def test_pull_request_comment_user_specified_stream(self):
|
||||
# type: () -> None
|
||||
self.basic_test('pull_request_comment', 'my_commits',
|
||||
"zulip-test: pull request 9: Less cowbell.",
|
||||
"zbenjamin [commented](https://github.com/zbenjamin/zulip-test/pull/9#issuecomment-24771110) on [pull request 9](https://github.com/zbenjamin/zulip-test/pull/9)\n\n~~~ quote\nYeah, who really needs more cowbell than we already have?\n~~~",
|
||||
send_stream=True)
|
||||
|
||||
def test_commit_comment(self):
|
||||
# type: () -> None
|
||||
self.basic_test('commit_comment', 'commits',
|
||||
"zulip-test: commit 7c994678d2f98797d299abed852d3ff9d0834533",
|
||||
"zbenjamin [commented](https://github.com/zbenjamin/zulip-test/commit/7c994678d2f98797d299abed852d3ff9d0834533#commitcomment-4252302)\n\n~~~ quote\nAre we sure this is enough cowbell?\n~~~")
|
||||
|
||||
def test_commit_comment_line(self):
|
||||
# type: () -> None
|
||||
self.basic_test('commit_comment_line', 'commits',
|
||||
"zulip-test: commit 7c994678d2f98797d299abed852d3ff9d0834533",
|
||||
"zbenjamin [commented](https://github.com/zbenjamin/zulip-test/commit/7c994678d2f98797d299abed852d3ff9d0834533#commitcomment-4252307) on `cowbell`, line 13\n\n~~~ quote\nThis line adds /unlucky/ cowbell (because of its line number). We should remove it.\n~~~")
|
||||
|
|
@ -0,0 +1,242 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class GitlabHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'gitlab'
|
||||
URL_TEMPLATE = "/api/v1/external/gitlab?&api_key={api_key}"
|
||||
FIXTURE_DIR_NAME = 'gitlab'
|
||||
|
||||
def test_push_event_message(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"Repository: my-awesome-project"
|
||||
expected_message = u"Tomasz Kolek pushed [2 commits](https://gitlab.com/tomaszkolek0/my-awesome-project/compare/5fcdd5551fc3085df79bece2c32b1400802ac407...eb6ae1e591e0819dc5bf187c6bfe18ec065a80e9) to tomek branch."
|
||||
|
||||
self.send_and_test_stream_message('push', expected_subject, expected_message, HTTP_X_GITLAB_EVENT="Push Hook")
|
||||
|
||||
def test_add_tag_event_message(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"Repository: my-awesome-project"
|
||||
expected_message = u"Tomasz Kolek pushed xyz tag."
|
||||
|
||||
self.send_and_test_stream_message(
|
||||
'add_tag',
|
||||
expected_subject,
|
||||
expected_message,
|
||||
HTTP_X_GITLAB_EVENT="Tag Push Hook",
|
||||
)
|
||||
|
||||
def test_remove_tag_event_message(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"Repository: my-awesome-project"
|
||||
expected_message = u"Tomasz Kolek removed xyz tag."
|
||||
|
||||
self.send_and_test_stream_message(
|
||||
'remove_tag',
|
||||
expected_subject,
|
||||
expected_message,
|
||||
HTTP_X_GITLAB_EVENT="Tag Push Hook"
|
||||
)
|
||||
|
||||
def test_create_issue_without_assignee_event_message(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"Repository: my-awesome-project"
|
||||
expected_message = u"Tomasz Kolek created [Issue #1](https://gitlab.com/tomaszkolek0/my-awesome-project/issues/1)."
|
||||
|
||||
self.send_and_test_stream_message(
|
||||
'issue_created_without_assignee',
|
||||
expected_subject,
|
||||
expected_message,
|
||||
HTTP_X_GITLAB_EVENT="Issue Hook"
|
||||
)
|
||||
|
||||
def test_create_issue_with_assignee_event_message(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"Repository: my-awesome-project"
|
||||
expected_message = u"Tomasz Kolek created [Issue #1](https://gitlab.com/tomaszkolek0/my-awesome-project/issues/1) (assigned to Tomasz Kolek)."
|
||||
|
||||
self.send_and_test_stream_message(
|
||||
'issue_created_with_assignee',
|
||||
expected_subject,
|
||||
expected_message,
|
||||
HTTP_X_GITLAB_EVENT="Issue Hook"
|
||||
)
|
||||
|
||||
def test_update_issue_event_message(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"Repository: my-awesome-project"
|
||||
expected_message = u"Tomasz Kolek updated [Issue #1](https://gitlab.com/tomaszkolek0/my-awesome-project/issues/1)."
|
||||
|
||||
self.send_and_test_stream_message(
|
||||
'issue_updated',
|
||||
expected_subject,
|
||||
expected_message,
|
||||
HTTP_X_GITLAB_EVENT="Issue Hook"
|
||||
)
|
||||
|
||||
def test_close_issue_event_message(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"Repository: my-awesome-project"
|
||||
expected_message = u"Tomasz Kolek closed [Issue #1](https://gitlab.com/tomaszkolek0/my-awesome-project/issues/1)."
|
||||
|
||||
self.send_and_test_stream_message(
|
||||
'issue_closed',
|
||||
expected_subject,
|
||||
expected_message,
|
||||
HTTP_X_GITLAB_EVENT="Issue Hook"
|
||||
)
|
||||
|
||||
def test_reopen_issue_event_message(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"Repository: my-awesome-project"
|
||||
expected_message = u"Tomasz Kolek reopened [Issue #1](https://gitlab.com/tomaszkolek0/my-awesome-project/issues/1)."
|
||||
|
||||
self.send_and_test_stream_message(
|
||||
'issue_reopened',
|
||||
expected_subject,
|
||||
expected_message,
|
||||
HTTP_X_GITLAB_EVENT="Issue Hook"
|
||||
)
|
||||
|
||||
def test_note_commit_event_message(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"Repository: my-awesome-project"
|
||||
expected_message = u"Tomasz Kolek added [comment](https://gitlab.com/tomaszkolek0/my-awesome-project/commit/66abd2da28809ffa128ed0447965cf11d7f863a7#note_14169211) to [Commit](https://gitlab.com/tomaszkolek0/my-awesome-project/commit/66abd2da28809ffa128ed0447965cf11d7f863a7)."
|
||||
|
||||
self.send_and_test_stream_message(
|
||||
'commit_note',
|
||||
expected_subject,
|
||||
expected_message,
|
||||
HTTP_X_GITLAB_EVENT="Note Hook"
|
||||
)
|
||||
|
||||
def test_note_merge_request_event_message(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"Repository: my-awesome-project"
|
||||
expected_message = u"Tomasz Kolek added [comment](https://gitlab.com/tomaszkolek0/my-awesome-project/merge_requests/1#note_14171860) to [Merge Request #1](https://gitlab.com/tomaszkolek0/my-awesome-project/merge_requests/1)."
|
||||
|
||||
self.send_and_test_stream_message(
|
||||
'merge_request_note',
|
||||
expected_subject,
|
||||
expected_message,
|
||||
HTTP_X_GITLAB_EVENT="Note Hook"
|
||||
)
|
||||
|
||||
def test_note_issue_event_message(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"Repository: my-awesome-project"
|
||||
expected_message = u"Tomasz Kolek added [comment](https://gitlab.com/tomaszkolek0/my-awesome-project/issues/2#note_14172057) to [Issue #2](https://gitlab.com/tomaszkolek0/my-awesome-project/issues/2)."
|
||||
|
||||
self.send_and_test_stream_message(
|
||||
'issue_note',
|
||||
expected_subject,
|
||||
expected_message,
|
||||
HTTP_X_GITLAB_EVENT="Note Hook"
|
||||
)
|
||||
|
||||
def test_note_snippet_event_message(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"Repository: my-awesome-project"
|
||||
expected_message = u"Tomasz Kolek added [comment](https://gitlab.com/tomaszkolek0/my-awesome-project/snippets/2#note_14172058) to [Snippet #2](https://gitlab.com/tomaszkolek0/my-awesome-project/snippets/2)."
|
||||
|
||||
self.send_and_test_stream_message(
|
||||
'snippet_note',
|
||||
expected_subject,
|
||||
expected_message,
|
||||
HTTP_X_GITLAB_EVENT="Note Hook"
|
||||
)
|
||||
|
||||
def test_merge_request_created_without_assignee_event_message(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"Repository: my-awesome-project"
|
||||
expected_message = u"Tomasz Kolek created [Merge Request #2](https://gitlab.com/tomaszkolek0/my-awesome-project/merge_requests/2)."
|
||||
|
||||
self.send_and_test_stream_message(
|
||||
'merge_request_created_without_assignee',
|
||||
expected_subject,
|
||||
expected_message,
|
||||
HTTP_X_GITLAB_EVENT="Merge Request Hook"
|
||||
)
|
||||
|
||||
def test_merge_request_created_with_assignee_event_message(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"Repository: my-awesome-project"
|
||||
expected_message = u"Tomasz Kolek created [Merge Request #3](https://gitlab.com/tomaszkolek0/my-awesome-project/merge_requests/3) (assigned to Tomasz Kolek)."
|
||||
|
||||
self.send_and_test_stream_message(
|
||||
'merge_request_created_with_assignee',
|
||||
expected_subject,
|
||||
expected_message,
|
||||
HTTP_X_GITLAB_EVENT="Merge Request Hook"
|
||||
)
|
||||
|
||||
def test_merge_request_closed_event_message(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"Repository: my-awesome-project"
|
||||
expected_message = u"Tomasz Kolek closed [Merge Request #2](https://gitlab.com/tomaszkolek0/my-awesome-project/merge_requests/2)."
|
||||
|
||||
self.send_and_test_stream_message(
|
||||
'merge_request_closed',
|
||||
expected_subject,
|
||||
expected_message,
|
||||
HTTP_X_GITLAB_EVENT="Merge Request Hook"
|
||||
)
|
||||
|
||||
def test_merge_request_updated_event_message(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"Repository: my-awesome-project"
|
||||
expected_message = u"Tomasz Kolek updated [Merge Request #3](https://gitlab.com/tomaszkolek0/my-awesome-project/merge_requests/3)."
|
||||
|
||||
self.send_and_test_stream_message(
|
||||
'merge_request_updated',
|
||||
expected_subject,
|
||||
expected_message,
|
||||
HTTP_X_GITLAB_EVENT="Merge Request Hook"
|
||||
)
|
||||
|
||||
def test_merge_request_added_commit_event_message(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"Repository: my-awesome-project"
|
||||
expected_message = u"Tomasz Kolek added commit to [Merge Request #3](https://gitlab.com/tomaszkolek0/my-awesome-project/merge_requests/3)."
|
||||
|
||||
self.send_and_test_stream_message(
|
||||
'merge_request_added_commit',
|
||||
expected_subject,
|
||||
expected_message,
|
||||
HTTP_X_GITLAB_EVENT="Merge Request Hook"
|
||||
)
|
||||
|
||||
def test_merge_request_merged_event_message(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"Repository: my-awesome-project"
|
||||
expected_message = u"Tomasz Kolek merged [Merge Request #3](https://gitlab.com/tomaszkolek0/my-awesome-project/merge_requests/3)."
|
||||
|
||||
self.send_and_test_stream_message(
|
||||
'merge_request_merged',
|
||||
expected_subject,
|
||||
expected_message,
|
||||
HTTP_X_GITLAB_EVENT="Merge Request Hook"
|
||||
)
|
||||
|
||||
def test_wiki_page_opened_event_message(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"Repository: my-awesome-project"
|
||||
expected_message = u"Tomasz Kolek created [Wiki Page \"how to\"](https://gitlab.com/tomaszkolek0/my-awesome-project/wikis/how-to)."
|
||||
|
||||
self.send_and_test_stream_message(
|
||||
'wiki_page_opened',
|
||||
expected_subject,
|
||||
expected_message,
|
||||
HTTP_X_GITLAB_EVENT="Wiki Page Hook"
|
||||
)
|
||||
|
||||
def test_wiki_page_edited_event_message(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"Repository: my-awesome-project"
|
||||
expected_message = u"Tomasz Kolek updated [Wiki Page \"how to\"](https://gitlab.com/tomaszkolek0/my-awesome-project/wikis/how-to)."
|
||||
|
||||
self.send_and_test_stream_message(
|
||||
'wiki_page_edited',
|
||||
expected_subject,
|
||||
expected_message,
|
||||
HTTP_X_GITLAB_EVENT="Wiki Page Hook"
|
||||
)
|
||||
|
|
@ -0,0 +1,31 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from six import text_type
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class HelloWorldHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'test'
|
||||
URL_TEMPLATE = "/api/v1/external/helloworld?&api_key={api_key}"
|
||||
FIXTURE_DIR_NAME = 'hello'
|
||||
|
||||
# Note: Include a test function per each distinct message condition your integration supports
|
||||
def test_hello_message(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"Hello World";
|
||||
expected_message = u"Hello! I am happy to be here! :smile:\nThe Wikipedia featured article for today is **[Marilyn Monroe](https://en.wikipedia.org/wiki/Marilyn_Monroe)**";
|
||||
|
||||
# use fixture named helloworld_hello
|
||||
self.send_and_test_stream_message('hello', expected_subject, expected_message,
|
||||
content_type="application/x-www-form-urlencoded")
|
||||
|
||||
def test_goodbye_message(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"Hello World";
|
||||
expected_message = u"Hello! I am happy to be here! :smile:\nThe Wikipedia featured article for today is **[Goodbye](https://en.wikipedia.org/wiki/Goodbye)**";
|
||||
|
||||
# use fixture named helloworld_goodbye
|
||||
self.send_and_test_stream_message('goodbye', expected_subject, expected_message,
|
||||
content_type="application/x-www-form-urlencoded")
|
||||
|
||||
def get_body(self, fixture_name):
|
||||
# type: (text_type) -> text_type
|
||||
return self.fixture_data("helloworld", fixture_name, file_type="json")
|
||||
|
|
@ -0,0 +1,151 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from six import text_type
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class JiraHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'jira'
|
||||
URL_TEMPLATE = u"/api/v1/external/jira?api_key={api_key}"
|
||||
|
||||
def test_unknown(self):
|
||||
# type: () -> None
|
||||
url = self.build_webhook_url()
|
||||
|
||||
result = self.client_post(url,
|
||||
self.get_body('unknown'),
|
||||
stream_name="jira",
|
||||
content_type="application/json")
|
||||
|
||||
self.assert_json_error(result, 'Unknown JIRA event type')
|
||||
|
||||
def test_custom_stream(self):
|
||||
# type: () -> None
|
||||
api_key = self.get_api_key(self.TEST_USER_EMAIL)
|
||||
url = "/api/v1/external/jira?api_key=%s&stream=jira_custom" % (api_key,)
|
||||
msg = self.send_json_payload(self.TEST_USER_EMAIL,
|
||||
url,
|
||||
self.get_body('created'),
|
||||
stream_name="jira_custom",
|
||||
content_type="application/json")
|
||||
self.assertEqual(msg.topic_name(), "BUG-15: New bug with hook")
|
||||
self.assertEqual(msg.content, """Leo Franchi **created** [BUG-15](http://lfranchi.com:8080/browse/BUG-15) priority Major, assigned to @**no one**:
|
||||
|
||||
> New bug with hook""")
|
||||
|
||||
def test_created(self):
|
||||
# type: () -> None
|
||||
expected_subject = "BUG-15: New bug with hook"
|
||||
expected_message = """Leo Franchi **created** [BUG-15](http://lfranchi.com:8080/browse/BUG-15) priority Major, assigned to @**no one**:
|
||||
|
||||
> New bug with hook"""
|
||||
self.send_and_test_stream_message('created', expected_subject, expected_message)
|
||||
|
||||
def test_created_assignee(self):
|
||||
# type: () -> None
|
||||
expected_subject = "TEST-4: Test Created Assignee"
|
||||
expected_message = """Leonardo Franchi [Administrator] **created** [TEST-4](https://zulipp.atlassian.net/browse/TEST-4) priority Major, assigned to @**Leonardo Franchi [Administrator]**:
|
||||
|
||||
> Test Created Assignee"""
|
||||
self.send_and_test_stream_message('created_assignee', expected_subject, expected_message)
|
||||
|
||||
def test_commented(self):
|
||||
# type: () -> None
|
||||
expected_subject = "BUG-15: New bug with hook"
|
||||
expected_message = """Leo Franchi **updated** [BUG-15](http://lfranchi.com:8080/browse/BUG-15) (assigned to @**Othello, the Moor of Venice**):
|
||||
|
||||
|
||||
Adding a comment. Oh, what a comment it is!
|
||||
"""
|
||||
self.send_and_test_stream_message('commented', expected_subject, expected_message)
|
||||
|
||||
def test_commented_markup(self):
|
||||
# type: () -> None
|
||||
expected_subject = "TEST-7: Testing of rich text"
|
||||
expected_message = """Leonardo Franchi [Administrator] **updated** [TEST-7](https://zulipp.atlassian.net/browse/TEST-7):\n\n\nThis is a comment that likes to **exercise** a lot of _different_ `conventions` that `jira uses`.\r\n\r\n~~~\n\r\nthis code is not highlighted, but monospaced\r\n\n~~~\r\n\r\n~~~\n\r\ndef python():\r\n print "likes to be formatted"\r\n\n~~~\r\n\r\n[http://www.google.com](http://www.google.com) is a bare link, and [Google](http://www.google.com) is given a title.\r\n\r\nThanks!\r\n\r\n~~~ quote\n\r\nSomeone said somewhere\r\n\n~~~\n"""
|
||||
self.send_and_test_stream_message('commented_markup', expected_subject, expected_message)
|
||||
|
||||
def test_deleted(self):
|
||||
# type: () -> None
|
||||
expected_subject = "BUG-15: New bug with hook"
|
||||
expected_message = "Leo Franchi **deleted** [BUG-15](http://lfranchi.com:8080/browse/BUG-15)!"
|
||||
self.send_and_test_stream_message('deleted', expected_subject, expected_message)
|
||||
|
||||
def test_reassigned(self):
|
||||
# type: () -> None
|
||||
expected_subject = "BUG-15: New bug with hook"
|
||||
expected_message = """Leo Franchi **updated** [BUG-15](http://lfranchi.com:8080/browse/BUG-15) (assigned to @**Othello, the Moor of Venice**):
|
||||
|
||||
* Changed assignee from **None** to @**Othello, the Moor of Venice**
|
||||
"""
|
||||
self.send_and_test_stream_message('reassigned', expected_subject, expected_message)
|
||||
|
||||
def test_reopened(self):
|
||||
# type: () -> None
|
||||
expected_subject = "BUG-7: More cowbell polease"
|
||||
expected_message = """Leo Franchi **updated** [BUG-7](http://lfranchi.com:8080/browse/BUG-7) (assigned to @**Othello, the Moor of Venice**):
|
||||
|
||||
* Changed resolution from **Fixed** to **None**
|
||||
* Changed status from **Resolved** to **Reopened**
|
||||
|
||||
Re-opened yeah!
|
||||
"""
|
||||
self.send_and_test_stream_message('reopened', expected_subject, expected_message)
|
||||
|
||||
def test_resolved(self):
|
||||
# type: () -> None
|
||||
expected_subject = "BUG-13: Refreshing the page loses the user's current posi..."
|
||||
expected_message = """Leo Franchi **updated** [BUG-13](http://lfranchi.com:8080/browse/BUG-13) (assigned to @**Othello, the Moor of Venice**):
|
||||
|
||||
* Changed status from **Open** to **Resolved**
|
||||
* Changed assignee from **None** to @**Othello, the Moor of Venice**
|
||||
* Changed resolution from **None** to **Fixed**
|
||||
|
||||
Fixed it, finally!
|
||||
"""
|
||||
self.send_and_test_stream_message('resolved', expected_subject, expected_message)
|
||||
|
||||
def test_workflow_postfuncion(self):
|
||||
# type: () -> None
|
||||
expected_subject = "TEST-5: PostTest"
|
||||
expected_message = """Leo Franchi [Administrator] **transitioned** [TEST-5](https://lfranchi-test.atlassian.net/browse/TEST-5) from Resolved to Reopened"""
|
||||
self.send_and_test_stream_message('postfunction_hook', expected_subject, expected_message)
|
||||
|
||||
def test_workflow_postfunction(self):
|
||||
# type: () -> None
|
||||
expected_subject = "TEST-5: PostTest"
|
||||
expected_message = """Leo Franchi [Administrator] **transitioned** [TEST-5](https://lfranchi-test.atlassian.net/browse/TEST-5) from Resolved to Reopened"""
|
||||
self.send_and_test_stream_message('postfunction_hook', expected_subject, expected_message)
|
||||
|
||||
def test_workflow_postfunction_started(self):
|
||||
# type: () -> None
|
||||
expected_subject = "TEST-7: Gluttony of Post Functions"
|
||||
expected_message = """Leo Franchi [Administrator] **transitioned** [TEST-7](https://lfranchi-test.atlassian.net/browse/TEST-7) from Open to Underway"""
|
||||
self.send_and_test_stream_message('postfunction_started', expected_subject, expected_message)
|
||||
|
||||
def test_workflow_postfunction_resolved(self):
|
||||
# type: () -> None
|
||||
expected_subject = "TEST-7: Gluttony of Post Functions"
|
||||
expected_message = """Leo Franchi [Administrator] **transitioned** [TEST-7](https://lfranchi-test.atlassian.net/browse/TEST-7) from Open to Resolved"""
|
||||
self.send_and_test_stream_message('postfunction_resolved', expected_subject, expected_message)
|
||||
|
||||
def test_mention(self):
|
||||
# type: () -> None
|
||||
expected_subject = "TEST-5: Lunch Decision Needed"
|
||||
expected_message = """Leonardo Franchi [Administrator] **updated** [TEST-5](https://zulipp.atlassian.net/browse/TEST-5) (assigned to @**Othello, the Moor of Venice**):
|
||||
|
||||
|
||||
Making a comment, @**Othello, the Moor of Venice** is watching this issue
|
||||
"""
|
||||
self.send_and_test_stream_message('watch_mention_updated', expected_subject, expected_message)
|
||||
|
||||
def test_priority_updated(self):
|
||||
# type: () -> None
|
||||
expected_subject = "TEST-1: Fix That"
|
||||
expected_message = """Leonardo Franchi [Administrator] **updated** [TEST-1](https://zulipp.atlassian.net/browse/TEST-1) (assigned to **leo@zulip.com**):
|
||||
|
||||
* Changed priority from **Critical** to **Major**
|
||||
"""
|
||||
self.send_and_test_stream_message('updated_priority', expected_subject, expected_message)
|
||||
|
||||
def get_body(self, fixture_name):
|
||||
# type: (text_type) -> text_type
|
||||
return self.fixture_data('jira', fixture_name)
|
||||
|
|
@ -0,0 +1,58 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from six import text_type
|
||||
from six.moves import urllib
|
||||
from typing import Optional
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class LibratoHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'librato'
|
||||
URL_TEMPLATE = u"/api/v1/external/librato?api_key={api_key}&stream=librato"
|
||||
FIXTURE_DIR_NAME = 'librato'
|
||||
IS_ATTACHMENT = False
|
||||
|
||||
def get_body(self, fixture_name):
|
||||
# type: (text_type) -> text_type
|
||||
if self.IS_ATTACHMENT:
|
||||
return self.fixture_data("librato", fixture_name, file_type='json')
|
||||
return urllib.parse.urlencode({'payload': self.fixture_data("librato", fixture_name, file_type='json')})
|
||||
|
||||
def build_webhook_url(self, topic=None):
|
||||
# type: (Optional[text_type]) -> text_type
|
||||
api_key = self.get_api_key(self.TEST_USER_EMAIL)
|
||||
url = self.URL_TEMPLATE.format(stream=self.STREAM_NAME, api_key=api_key)
|
||||
if topic:
|
||||
url = u"{}&topic={}".format(url, topic)
|
||||
return url
|
||||
|
||||
def test_alert_message_with_default_topic(self):
|
||||
# type: () -> None
|
||||
expected_subject = 'Alert alert.name'
|
||||
expected_message = "Alert [alert_name](https://metrics.librato.com/alerts#/6294535) has triggered! [Reaction steps](http://www.google.pl)\n>Metric `librato.cpu.percent.idle`, sum was below 44 by 300s, recorded at 2016-03-31 05:11:42\n>Metric `librato.swap.swap.cached`, average was absent by 300s, recorded at 2016-03-31 05:11:42\n>Metric `librato.swap.swap.cached`, derivative was above 9 by 300s, recorded at 2016-03-31 05:11:42"
|
||||
self.send_and_test_stream_message('alert', expected_subject, expected_message, content_type="application/x-www-form-urlencoded")
|
||||
|
||||
def test_alert_message_with_custom_topic(self):
|
||||
# type: () -> None
|
||||
custom_topic = 'custom_name'
|
||||
self.url = self.build_webhook_url(custom_topic)
|
||||
expected_message = "Alert [alert_name](https://metrics.librato.com/alerts#/6294535) has triggered! [Reaction steps](http://www.google.pl)\n>Metric `librato.cpu.percent.idle`, sum was below 44 by 300s, recorded at 2016-03-31 05:11:42\n>Metric `librato.swap.swap.cached`, average was absent by 300s, recorded at 2016-03-31 05:11:42\n>Metric `librato.swap.swap.cached`, derivative was above 9 by 300s, recorded at 2016-03-31 05:11:42"
|
||||
self.send_and_test_stream_message('alert', custom_topic, expected_message, content_type="application/x-www-form-urlencoded")
|
||||
|
||||
def test_three_conditions_alert_message(self):
|
||||
# type: () -> None
|
||||
expected_message = "Alert [alert_name](https://metrics.librato.com/alerts#/6294535) has triggered! [Reaction steps](http://www.use.water.pl)\n>Metric `collectd.interface.eth0.if_octets.tx`, absolute_value was above 4 by 300s, recorded at 2016-04-11 16:40:14\n>Metric `collectd.load.load.longterm`, max was above 99, recorded at 2016-04-11 16:40:14\n>Metric `librato.swap.swap.cached`, average was absent by 60s, recorded at 2016-04-11 16:40:14"
|
||||
expected_subject = 'Alert ToHighTemeprature'
|
||||
self.send_and_test_stream_message('three_conditions_alert', expected_subject, expected_message, content_type="application/x-www-form-urlencoded")
|
||||
|
||||
def test_alert_clear(self):
|
||||
# type: () -> None
|
||||
expected_subject = 'Alert Alert_name'
|
||||
expected_message = "Alert [alert_name](https://metrics.librato.com/alerts#/6309313) has cleared at 2016-04-12 09:11:44!"
|
||||
self.send_and_test_stream_message('alert_cleared', expected_subject, expected_message, content_type="application/x-www-form-urlencoded")
|
||||
|
||||
def test_snapshot(self):
|
||||
# type: () -> None
|
||||
self.IS_ATTACHMENT = True
|
||||
expected_subject = 'Snapshots'
|
||||
expected_message = "**Hamlet** sent a [snapshot](http://snapshots.librato.com/chart/nr5l3n0c-82162.png) of [metric](https://metrics.librato.com/s/spaces/167315/explore/1731491?duration=72039&end_time=1460569409)"
|
||||
self.send_and_test_stream_message('snapshot', expected_subject, expected_message, content_type="application/x-www-form-urlencoded")
|
||||
self.IS_ATTACHMENT = False
|
||||
|
|
@ -0,0 +1,27 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from six import text_type
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class NewRelicHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'newrelic'
|
||||
URL_TEMPLATE = u"/api/v1/external/newrelic?stream={stream}&api_key={api_key}"
|
||||
|
||||
def test_alert(self):
|
||||
# type: () -> None
|
||||
expected_subject = "Apdex score fell below critical level of 0.90"
|
||||
expected_message = 'Alert opened on [application name]: \
|
||||
Apdex score fell below critical level of 0.90\n\
|
||||
[View alert](https://rpm.newrelc.com/accounts/[account_id]/applications/[application_id]/incidents/[incident_id])'
|
||||
self.send_and_test_stream_message('alert', expected_subject, expected_message,
|
||||
content_type="application/x-www-form-urlencoded")
|
||||
def test_deployment(self):
|
||||
# type: () -> None
|
||||
expected_subject = 'Test App deploy'
|
||||
expected_message = '`1242` deployed by **Zulip Test**\n\
|
||||
Description sent via curl\n\nChangelog string'
|
||||
self.send_and_test_stream_message('deployment', expected_subject, expected_message,
|
||||
content_type="application/x-www-form-urlencoded")
|
||||
|
||||
def get_body(self, fixture_name):
|
||||
# type: (text_type) -> text_type
|
||||
return self.fixture_data("newrelic", fixture_name, file_type="txt")
|
||||
|
|
@ -0,0 +1,48 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from six import text_type
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class PagerDutyHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'pagerduty'
|
||||
URL_TEMPLATE = u"/api/v1/external/pagerduty?api_key={api_key}&stream={stream}"
|
||||
FIXTURE_DIR_NAME = 'pagerduty'
|
||||
|
||||
def test_trigger(self):
|
||||
# type: () -> None
|
||||
expected_message = ':imp: Incident [3](https://zulip-test.pagerduty.com/incidents/P140S4Y) triggered by [Test service](https://zulip-test.pagerduty.com/services/PIL5CUQ) and assigned to [armooo@](https://zulip-test.pagerduty.com/users/POBCFRJ)\n\n>foo'
|
||||
self.send_and_test_stream_message('trigger', u"incident 3", expected_message)
|
||||
|
||||
def test_unacknowledge(self):
|
||||
# type: () -> None
|
||||
expected_message = ':imp: Incident [3](https://zulip-test.pagerduty.com/incidents/P140S4Y) unacknowledged by [Test service](https://zulip-test.pagerduty.com/services/PIL5CUQ) and assigned to [armooo@](https://zulip-test.pagerduty.com/users/POBCFRJ)\n\n>foo'
|
||||
self.send_and_test_stream_message('unacknowledge', u"incident 3", expected_message)
|
||||
|
||||
def test_resolved(self):
|
||||
# type: () -> None
|
||||
expected_message = ':grinning: Incident [1](https://zulip-test.pagerduty.com/incidents/PO1XIJ5) resolved by [armooo@](https://zulip-test.pagerduty.com/users/POBCFRJ)\n\n>It is on fire'
|
||||
self.send_and_test_stream_message('resolved', u"incident 1", expected_message)
|
||||
|
||||
def test_auto_resolved(self):
|
||||
# type: () -> None
|
||||
expected_message = ':grinning: Incident [2](https://zulip-test.pagerduty.com/incidents/PX7K9J2) resolved\n\n>new'
|
||||
self.send_and_test_stream_message('auto_resolved', u"incident 2", expected_message)
|
||||
|
||||
def test_acknowledge(self):
|
||||
# type: () -> None
|
||||
expected_message = ':no_good: Incident [1](https://zulip-test.pagerduty.com/incidents/PO1XIJ5) acknowledged by [armooo@](https://zulip-test.pagerduty.com/users/POBCFRJ)\n\n>It is on fire'
|
||||
self.send_and_test_stream_message('acknowledge', u"incident 1", expected_message)
|
||||
|
||||
def test_no_subject(self):
|
||||
# type: () -> None
|
||||
expected_message = u':grinning: Incident [48219](https://dropbox.pagerduty.com/incidents/PJKGZF9) resolved\n\n>mp_error_block_down_critical\u2119\u01b4'
|
||||
self.send_and_test_stream_message('mp_fail', u"incident 48219", expected_message)
|
||||
|
||||
def test_bad_message(self):
|
||||
# type: () -> None
|
||||
expected_message = 'Unknown pagerduty message\n```\n{\n "type":"incident.triggered"\n}\n```'
|
||||
self.send_and_test_stream_message('bad_message_type', u"pagerduty", expected_message)
|
||||
|
||||
def test_unknown_message_type(self):
|
||||
# type: () -> None
|
||||
expected_message = 'Unknown pagerduty message\n```\n{\n "type":"foo"\n}\n```'
|
||||
self.send_and_test_stream_message('unknown_message_type', u"pagerduty", expected_message)
|
||||
|
|
@ -0,0 +1,39 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class PingdomHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'pingdom'
|
||||
URL_TEMPLATE = u"/api/v1/external/pingdom?stream={stream}&api_key={api_key}"
|
||||
FIXTURE_DIR_NAME = 'pingdom'
|
||||
|
||||
def test_pingdom_from_up_to_down_http_check_message(self):
|
||||
# type: () -> None
|
||||
"""
|
||||
Tests if pingdom http check from up to down is handled correctly
|
||||
"""
|
||||
expected_message = u"Service someurl.com changed its HTTP status from UP to DOWN.\nDescription: Non-recoverable failure in name resolution."
|
||||
self.send_and_test_stream_message('http_up_to_down', u"Test check status.", expected_message)
|
||||
|
||||
def test_pingdom_from_up_to_down_smtp_check_message(self):
|
||||
# type: () -> None
|
||||
"""
|
||||
Tests if pingdom smtp check from up to down is handled correctly
|
||||
"""
|
||||
expected_message = u"Service smtp.someurl.com changed its SMTP status from UP to DOWN.\nDescription: Connection refused."
|
||||
self.send_and_test_stream_message('smtp_up_to_down', u"SMTP check status.", expected_message)
|
||||
|
||||
def test_pingdom_from_up_to_down_imap_check_message(self):
|
||||
# type: () -> None
|
||||
"""
|
||||
Tests if pingdom imap check from up to down is handled correctly
|
||||
"""
|
||||
expected_message = u"Service imap.someurl.com changed its IMAP status from UP to DOWN.\nDescription: Invalid hostname, address or socket."
|
||||
self.send_and_test_stream_message('imap_up_to_down', u"IMAP check status.", expected_message)
|
||||
|
||||
def test_pingdom_from_down_to_up_imap_check_message(self):
|
||||
# type: () -> None
|
||||
"""
|
||||
Tests if pingdom imap check from down to up is handled correctly
|
||||
"""
|
||||
expected_message = u"Service imap.someurl.com changed its IMAP status from DOWN to UP."
|
||||
self.send_and_test_stream_message('imap_down_to_up', u"IMAP check status.", expected_message)
|
||||
|
|
@ -0,0 +1,177 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from six import text_type
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class PivotalV3HookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'pivotal'
|
||||
URL_TEMPLATE = u"/api/v1/external/pivotal?stream={stream}&api_key={api_key}"
|
||||
|
||||
def test_accepted(self):
|
||||
# type: () -> None
|
||||
expected_subject = 'My new Feature story'
|
||||
expected_message = 'Leo Franchi accepted "My new Feature story" \
|
||||
[(view)](https://www.pivotaltracker.com/s/projects/807213/stories/48276573)'
|
||||
self.send_and_test_stream_message('accepted', expected_subject, expected_message, content_type="application/xml")
|
||||
|
||||
def test_commented(self):
|
||||
# type: () -> None
|
||||
expected_subject = 'Comment added'
|
||||
expected_message = 'Leo Franchi added comment: "FIX THIS NOW" \
|
||||
[(view)](https://www.pivotaltracker.com/s/projects/807213/stories/48276573)'
|
||||
self.send_and_test_stream_message('commented', expected_subject, expected_message, content_type="application/xml")
|
||||
|
||||
def test_created(self):
|
||||
# type: () -> None
|
||||
expected_subject = 'My new Feature story'
|
||||
expected_message = 'Leo Franchi added "My new Feature story" \
|
||||
(unscheduled feature):\n\n~~~ quote\nThis is my long description\n~~~\n\n \
|
||||
[(view)](https://www.pivotaltracker.com/s/projects/807213/stories/48276573)'
|
||||
self.send_and_test_stream_message('created', expected_subject, expected_message, content_type="application/xml")
|
||||
|
||||
def test_delivered(self):
|
||||
# type: () -> None
|
||||
expected_subject = 'Another new story'
|
||||
expected_message = 'Leo Franchi delivered "Another new story" \
|
||||
[(view)](https://www.pivotaltracker.com/s/projects/807213/stories/48278289)'
|
||||
self.send_and_test_stream_message('delivered', expected_subject, expected_message, content_type="application/xml")
|
||||
|
||||
def test_finished(self):
|
||||
# type: () -> None
|
||||
expected_subject = 'Another new story'
|
||||
expected_message = 'Leo Franchi finished "Another new story" \
|
||||
[(view)](https://www.pivotaltracker.com/s/projects/807213/stories/48278289)'
|
||||
self.send_and_test_stream_message('finished', expected_subject, expected_message, content_type="application/xml")
|
||||
|
||||
def test_moved(self):
|
||||
# type: () -> None
|
||||
expected_subject = 'My new Feature story'
|
||||
expected_message = 'Leo Franchi edited "My new Feature story" \
|
||||
[(view)](https://www.pivotaltracker.com/s/projects/807213/stories/48276573)'
|
||||
self.send_and_test_stream_message('moved', expected_subject, expected_message, content_type="application/xml")
|
||||
|
||||
def test_rejected(self):
|
||||
# type: () -> None
|
||||
expected_subject = 'Another new story'
|
||||
expected_message = 'Leo Franchi rejected "Another new story" with comments: \
|
||||
"Not good enough, sorry" [(view)](https://www.pivotaltracker.com/s/projects/807213/stories/48278289)'
|
||||
self.send_and_test_stream_message('rejected', expected_subject, expected_message, content_type="application/xml")
|
||||
|
||||
def test_started(self):
|
||||
# type: () -> None
|
||||
expected_subject = 'Another new story'
|
||||
expected_message = 'Leo Franchi started "Another new story" \
|
||||
[(view)](https://www.pivotaltracker.com/s/projects/807213/stories/48278289)'
|
||||
self.send_and_test_stream_message('started', expected_subject, expected_message, content_type="application/xml")
|
||||
|
||||
def test_created_estimate(self):
|
||||
# type: () -> None
|
||||
expected_subject = 'Another new story'
|
||||
expected_message = 'Leo Franchi added "Another new story" \
|
||||
(unscheduled feature worth 2 story points):\n\n~~~ quote\nSome loong description\n~~~\n\n \
|
||||
[(view)](https://www.pivotaltracker.com/s/projects/807213/stories/48278289)'
|
||||
self.send_and_test_stream_message('created_estimate', expected_subject, expected_message, content_type="application/xml")
|
||||
|
||||
def test_type_changed(self):
|
||||
# type: () -> None
|
||||
expected_subject = 'My new Feature story'
|
||||
expected_message = 'Leo Franchi edited "My new Feature story" \
|
||||
[(view)](https://www.pivotaltracker.com/s/projects/807213/stories/48276573)'
|
||||
self.send_and_test_stream_message('type_changed', expected_subject, expected_message, content_type="application/xml")
|
||||
|
||||
def get_body(self, fixture_name):
|
||||
# type: (text_type) -> text_type
|
||||
return self.fixture_data('pivotal', fixture_name, file_type='xml')
|
||||
|
||||
class PivotalV5HookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'pivotal'
|
||||
URL_TEMPLATE = u"/api/v1/external/pivotal?stream={stream}&api_key={api_key}"
|
||||
|
||||
def test_accepted(self):
|
||||
# type: () -> None
|
||||
expected_subject = '#63486316: Story of the Year'
|
||||
expected_message = """Leo Franchi updated [Hard Code](https://www.pivotaltracker.com/s/projects/807213): [Story of the Year](http://www.pivotaltracker.com/story/show/63486316):
|
||||
* state changed from **unstarted** to **accepted**
|
||||
"""
|
||||
self.send_and_test_stream_message('accepted', expected_subject, expected_message, content_type="application/xml")
|
||||
|
||||
def test_commented(self):
|
||||
# type: () -> None
|
||||
expected_subject = '#63486316: Story of the Year'
|
||||
expected_message = """Leo Franchi added a comment to [Hard Code](https://www.pivotaltracker.com/s/projects/807213): [Story of the Year](http://www.pivotaltracker.com/story/show/63486316):
|
||||
~~~quote
|
||||
A comment on the story
|
||||
~~~"""
|
||||
self.send_and_test_stream_message('commented', expected_subject, expected_message, content_type="application/xml")
|
||||
|
||||
def test_created(self):
|
||||
# type: () -> None
|
||||
expected_subject = '#63495662: Story that I created'
|
||||
expected_message = """Leo Franchi created bug: [Hard Code](https://www.pivotaltracker.com/s/projects/807213): [Story that I created](http://www.pivotaltracker.com/story/show/63495662)
|
||||
* State is **unscheduled**
|
||||
* Description is
|
||||
|
||||
> What a description"""
|
||||
self.send_and_test_stream_message('created', expected_subject, expected_message, content_type="application/xml")
|
||||
|
||||
def test_delivered(self):
|
||||
# type: () -> None
|
||||
expected_subject = '#63486316: Story of the Year'
|
||||
expected_message = """Leo Franchi updated [Hard Code](https://www.pivotaltracker.com/s/projects/807213): [Story of the Year](http://www.pivotaltracker.com/story/show/63486316):
|
||||
* state changed from **accepted** to **delivered**
|
||||
"""
|
||||
self.send_and_test_stream_message('delivered', expected_subject, expected_message, content_type="application/xml")
|
||||
|
||||
def test_finished(self):
|
||||
# type: () -> None
|
||||
expected_subject = '#63486316: Story of the Year'
|
||||
expected_message = """Leo Franchi updated [Hard Code](https://www.pivotaltracker.com/s/projects/807213): [Story of the Year](http://www.pivotaltracker.com/story/show/63486316):
|
||||
* state changed from **delivered** to **accepted**
|
||||
"""
|
||||
self.send_and_test_stream_message('finished', expected_subject, expected_message, content_type="application/xml")
|
||||
|
||||
def test_moved(self):
|
||||
# type: () -> None
|
||||
expected_subject = '#63496066: Pivotal Test'
|
||||
expected_message = """Leo Franchi moved [Hard Code](https://www.pivotaltracker.com/s/projects/807213): [Pivotal Test](http://www.pivotaltracker.com/story/show/63496066) from **unstarted** to **unscheduled**"""
|
||||
self.send_and_test_stream_message('moved', expected_subject, expected_message, content_type="application/xml")
|
||||
|
||||
def test_rejected(self):
|
||||
# type: () -> None
|
||||
expected_subject = '#63486316: Story of the Year'
|
||||
expected_message = """Leo Franchi updated [Hard Code](https://www.pivotaltracker.com/s/projects/807213): [Story of the Year](http://www.pivotaltracker.com/story/show/63486316):
|
||||
* Comment added:
|
||||
~~~quote
|
||||
Try again next time
|
||||
~~~
|
||||
* state changed from **delivered** to **rejected**
|
||||
"""
|
||||
self.send_and_test_stream_message('rejected', expected_subject, expected_message, content_type="application/xml")
|
||||
|
||||
def test_started(self):
|
||||
# type: () -> None
|
||||
expected_subject = '#63495972: Fresh Story'
|
||||
expected_message = """Leo Franchi updated [Hard Code](https://www.pivotaltracker.com/s/projects/807213): [Fresh Story](http://www.pivotaltracker.com/story/show/63495972):
|
||||
* state changed from **unstarted** to **started**
|
||||
"""
|
||||
self.send_and_test_stream_message('started', expected_subject, expected_message, content_type="application/xml")
|
||||
|
||||
def test_created_estimate(self):
|
||||
# type: () -> None
|
||||
expected_subject = '#63496066: Pivotal Test'
|
||||
expected_message = """Leo Franchi updated [Hard Code](https://www.pivotaltracker.com/s/projects/807213): [Pivotal Test](http://www.pivotaltracker.com/story/show/63496066):
|
||||
* estimate is now **3 points**
|
||||
"""
|
||||
self.send_and_test_stream_message('created_estimate', expected_subject, expected_message, content_type="application/xml")
|
||||
|
||||
def test_type_changed(self):
|
||||
# type: () -> None
|
||||
expected_subject = '#63496066: Pivotal Test'
|
||||
expected_message = """Leo Franchi updated [Hard Code](https://www.pivotaltracker.com/s/projects/807213): [Pivotal Test](http://www.pivotaltracker.com/story/show/63496066):
|
||||
* estimate changed from 3 to **0 points**
|
||||
* type changed from **feature** to **bug**
|
||||
"""
|
||||
self.send_and_test_stream_message('type_changed', expected_subject, expected_message, content_type="application/xml")
|
||||
|
||||
def get_body(self, fixture_name):
|
||||
# type: (text_type) -> text_type
|
||||
return self.fixture_data('pivotal', "v5_{}".format(fixture_name), file_type='json')
|
||||
|
|
@ -0,0 +1,31 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from six import text_type
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class SemaphoreHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'semaphore'
|
||||
URL_TEMPLATE = "/api/v1/external/semaphore?stream={stream}&api_key={api_key}"
|
||||
|
||||
# Messages are generated by Semaphore on git push. The subject lines below
|
||||
# contain information on the repo and branch, and the message has links and
|
||||
# details about the build, deploy, server, author, and commit
|
||||
|
||||
def test_semaphore_build(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"knighthood/master" # repo/branch
|
||||
expected_message = u"""[build 314](https://semaphoreci.com/donquixote/knighthood/branches/master/builds/314): passed
|
||||
!avatar(don@lamancha.com) [`a490b8d`](https://github.com/donquixote/knighthood/commit/a490b8d508ebbdab1d77a5c2aefa35ceb2d62daf): Create user account for Rocinante :horse:."""
|
||||
self.send_and_test_stream_message('build', expected_subject, expected_message,
|
||||
content_type="application/x-www-form-urlencoded")
|
||||
|
||||
def test_semaphore_deploy(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"knighthood/master"
|
||||
expected_message = u"""[deploy 17](https://semaphoreci.com/donquixote/knighthood/servers/lamancha-271/deploys/17) of [build 314](https://semaphoreci.com/donquixote/knighthood/branches/master/builds/314) on server lamancha-271: passed
|
||||
!avatar(don@lamancha.com) [`a490b8d`](https://github.com/donquixote/knighthood/commit/a490b8d508ebbdab1d77a5c2aefa35ceb2d62daf): Create user account for Rocinante :horse:."""
|
||||
self.send_and_test_stream_message('deploy', expected_subject, expected_message,
|
||||
content_type="application/x-www-form-urlencoded")
|
||||
|
||||
def get_body(self, fixture_name):
|
||||
# type: (text_type) -> text_type
|
||||
return self.fixture_data("semaphore", fixture_name, file_type="json")
|
||||
|
|
@ -0,0 +1,17 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class SentryHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'sentry'
|
||||
URL_TEMPLATE = "/api/v1/external/sentry?&api_key={api_key}"
|
||||
FIXTURE_DIR_NAME = 'sentry'
|
||||
|
||||
def test_error_issue_message(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"zulip"
|
||||
expected_message = u"New ERROR [issue](https://sentry.io/zulip/zulip/issues/156699934/): This is an example python exception."
|
||||
self.send_and_test_stream_message(
|
||||
'exception_message',
|
||||
expected_subject,
|
||||
expected_message
|
||||
)
|
||||
|
|
@ -0,0 +1,27 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from six import text_type
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class StashHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'stash'
|
||||
URL_TEMPLATE = u"/api/v1/external/stash?stream={stream}"
|
||||
|
||||
def test_stash_message(self):
|
||||
# type: () -> None
|
||||
"""
|
||||
Messages are generated by Stash on a `git push`.
|
||||
|
||||
The subject describes the repo and Stash "project". The
|
||||
content describes the commits pushed.
|
||||
"""
|
||||
expected_subject = u"Secret project/Operation unicorn: master"
|
||||
expected_message = """`f259e90` was pushed to **master** in **Secret project/Operation unicorn** with:
|
||||
|
||||
* `f259e90`: Updating poms ..."""
|
||||
self.send_and_test_stream_message('push', expected_subject, expected_message,
|
||||
content_type="application/x-www-form-urlencoded",
|
||||
**self.api_auth(self.TEST_USER_EMAIL))
|
||||
|
||||
def get_body(self, fixture_name):
|
||||
# type: (text_type) -> text_type
|
||||
return self.fixture_data("stash", fixture_name, file_type="json")
|
||||
|
|
@ -0,0 +1,219 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from six import text_type
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class TaigaHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'taiga'
|
||||
TOPIC = "subject"
|
||||
URL_TEMPLATE = u"/api/v1/external/taiga?stream={stream}&api_key={api_key}&topic={topic}"
|
||||
FIXTURE_DIR_NAME = 'taiga'
|
||||
|
||||
def build_webhook_url(self):
|
||||
# type: () -> text_type
|
||||
api_key = self.get_api_key(self.TEST_USER_EMAIL)
|
||||
return self.URL_TEMPLATE.format(stream=self.STREAM_NAME, api_key=api_key, topic=self.TOPIC)
|
||||
|
||||
def test_taiga_userstory_deleted(self):
|
||||
# type: () -> None
|
||||
message = u':x: Antek deleted user story **A newer hope**.\n'
|
||||
self.send_and_test_stream_message("userstory_deleted", u'subject', message)
|
||||
|
||||
def test_taiga_userstory_created(self):
|
||||
# type: () -> None
|
||||
message = u':package: Antek created user story **A new hope**.\n'
|
||||
self.send_and_test_stream_message("userstory_created", u'subject', message)
|
||||
|
||||
def test_taiga_userstory_changed_unblocked(self):
|
||||
# type: () -> None
|
||||
message = u':unlock: Antek unblocked user story **A newer hope**.\n'
|
||||
self.send_and_test_stream_message("userstory_changed_unblocked", u'subject', message)
|
||||
|
||||
def test_taiga_userstory_changed_subject(self):
|
||||
# type: () -> None
|
||||
message = u':notebook: Antek renamed user story from A new hope to **A newer hope**.\n'
|
||||
self.send_and_test_stream_message("userstory_changed_subject", u'subject', message)
|
||||
|
||||
def test_taiga_userstory_changed_status(self):
|
||||
# type: () -> None
|
||||
message = u':chart_with_upwards_trend: Antek changed status of user story **A new hope** from New to Done.\n'
|
||||
self.send_and_test_stream_message("userstory_changed_status", u'subject', message)
|
||||
|
||||
def test_taiga_userstory_changed_reassigned(self):
|
||||
# type: () -> None
|
||||
message = u':busts_in_silhouette: Antek reassigned user story **Great US** from Antek to Han Solo.\n'
|
||||
self.send_and_test_stream_message("userstory_changed_reassigned", u'subject', message)
|
||||
|
||||
def test_taiga_userstory_changed_points(self):
|
||||
# type: () -> None
|
||||
message = u':game_die: Antek changed estimation of user story **A new hope**.\n'
|
||||
self.send_and_test_stream_message("userstory_changed_points", u'subject', message)
|
||||
|
||||
def test_taiga_userstory_changed_new_milestone(self):
|
||||
# type: () -> None
|
||||
message = u':calendar: Antek added user story **A newer hope** to sprint New sprint.\n'
|
||||
self.send_and_test_stream_message("userstory_changed_new_milestone", u'subject', message)
|
||||
|
||||
def test_taiga_userstory_changed_milestone(self):
|
||||
# type: () -> None
|
||||
message = u':calendar: Antek changed sprint of user story **A newer hope** from Old sprint to New sprint.\n'
|
||||
self.send_and_test_stream_message("userstory_changed_milestone", u'subject', message)
|
||||
|
||||
def test_taiga_userstory_changed_description(self):
|
||||
# type: () -> None
|
||||
message = u':notebook: Antek updated description of user story **A newer hope**.\n'
|
||||
self.send_and_test_stream_message("userstory_changed_description", u'subject', message)
|
||||
|
||||
def test_taiga_userstory_changed_closed(self):
|
||||
# type: () -> None
|
||||
message = u':chart_with_upwards_trend: Antek changed status of user story **A newer hope** from New to Done.\n:checkered_flag: Antek closed user story **A newer hope**.\n'
|
||||
self.send_and_test_stream_message("userstory_changed_closed", u'subject', message)
|
||||
|
||||
def test_taiga_userstory_changed_reopened(self):
|
||||
# type: () -> None
|
||||
message = u':chart_with_upwards_trend: Antek changed status of user story **A newer hope** from Done to New.\n:package: Antek reopened user story **A newer hope**.\n'
|
||||
self.send_and_test_stream_message("userstory_changed_reopened", u'subject', message)
|
||||
|
||||
def test_taiga_userstory_changed_blocked(self):
|
||||
# type: () -> None
|
||||
message = u':lock: Antek blocked user story **A newer hope**.\n'
|
||||
self.send_and_test_stream_message("userstory_changed_blocked", u'subject', message)
|
||||
|
||||
def test_taiga_userstory_changed_assigned(self):
|
||||
# type: () -> None
|
||||
message = u':busts_in_silhouette: Antek assigned user story **Great US** to Antek.\n'
|
||||
self.send_and_test_stream_message("userstory_changed_assigned", u'subject', message)
|
||||
|
||||
def test_taiga_task_created(self):
|
||||
# type: () -> None
|
||||
message = u':clipboard: Antek created task **New task assigned and in progress**.\n'
|
||||
self.send_and_test_stream_message("task_created", u'subject', message)
|
||||
|
||||
def test_taiga_task_changed_status(self):
|
||||
# type: () -> None
|
||||
message = u':chart_with_upwards_trend: Antek changed status of task **New task assigned and in progress** from Ready for test to New.\n'
|
||||
self.send_and_test_stream_message("task_changed_status", u'subject', message)
|
||||
|
||||
def test_taiga_task_changed_blocked(self):
|
||||
# type: () -> None
|
||||
message = u':lock: Antek blocked task **A new task**.\n'
|
||||
self.send_and_test_stream_message("task_changed_blocked", u'subject', message)
|
||||
|
||||
def test_taiga_task_changed_unblocked(self):
|
||||
# type: () -> None
|
||||
message = u':unlock: Antek unblocked task **A new task**.\n'
|
||||
self.send_and_test_stream_message("task_changed_unblocked", u'subject', message)
|
||||
|
||||
def test_taiga_task_changed_assigned(self):
|
||||
# type: () -> None
|
||||
message = u':busts_in_silhouette: Antek assigned task **Aaaa** to Antek.\n'
|
||||
self.send_and_test_stream_message("task_changed_assigned", u'subject', message)
|
||||
|
||||
def test_taiga_task_changed_reassigned(self):
|
||||
# type: () -> None
|
||||
message = u':busts_in_silhouette: Antek reassigned task **Aaaa** from Han Solo to Antek.\n'
|
||||
self.send_and_test_stream_message("task_changed_reassigned", u'subject', message)
|
||||
|
||||
def test_taiga_task_changed_subject(self):
|
||||
# type: () -> None
|
||||
message = u':notebook: Antek renamed task New task to **Even newer task**.\n'
|
||||
self.send_and_test_stream_message("task_changed_subject", u'subject', message)
|
||||
|
||||
def test_taiga_task_changed_description(self):
|
||||
# type: () -> None
|
||||
message = u':notebook: Antek updated description of task **Even newer task.**.\n'
|
||||
self.send_and_test_stream_message("task_changed_description", u'subject', message)
|
||||
|
||||
def test_taiga_task_changed_us(self):
|
||||
# type: () -> None
|
||||
message = u':clipboard: Antek moved task **A new task** from user story #3 Great US to #6 Greater US.\n'
|
||||
self.send_and_test_stream_message("task_changed_us", u'subject', message)
|
||||
|
||||
def test_taiga_task_deleted(self):
|
||||
# type: () -> None
|
||||
message = u':x: Antek deleted task **hhh**.\n'
|
||||
self.send_and_test_stream_message("task_deleted", u'subject', message)
|
||||
|
||||
def test_taiga_milestone_created(self):
|
||||
# type: () -> None
|
||||
message = u':calendar: Antek created sprint **New sprint**.\n'
|
||||
self.send_and_test_stream_message("milestone_created", u'subject', message)
|
||||
|
||||
def test_taiga_milestone_deleted(self):
|
||||
# type: () -> None
|
||||
message = u':x: Antek deleted sprint **Newer sprint**.\n'
|
||||
self.send_and_test_stream_message("milestone_deleted", u'subject', message)
|
||||
|
||||
def test_taiga_milestone_changed_time(self):
|
||||
# type: () -> None
|
||||
message = u':calendar: Antek changed estimated finish of sprint **New sprint** from 2016-04-27 to 2016-04-30.\n'
|
||||
self.send_and_test_stream_message("milestone_changed_time", u'subject', message)
|
||||
|
||||
def test_taiga_milestone_changed_name(self):
|
||||
# type: () -> None
|
||||
message = u':notebook: Antek renamed sprint from New sprint to **Newer sprint**.\n'
|
||||
self.send_and_test_stream_message("milestone_changed_name", u'subject', message)
|
||||
|
||||
def test_taiga_issue_created(self):
|
||||
# type: () -> None
|
||||
message = u':bulb: Antek created issue **A new issue**.\n'
|
||||
self.send_and_test_stream_message("issue_created", u'subject', message)
|
||||
|
||||
def test_taiga_issue_deleted(self):
|
||||
# type: () -> None
|
||||
message = u':x: Antek deleted issue **Aaaa**.\n'
|
||||
self.send_and_test_stream_message("issue_deleted", u'subject', message)
|
||||
|
||||
def test_taiga_issue_changed_assigned(self):
|
||||
# type: () -> None
|
||||
message = u':busts_in_silhouette: Antek assigned issue **Aaaa** to Antek.\n'
|
||||
self.send_and_test_stream_message("issue_changed_assigned", u'subject', message)
|
||||
|
||||
def test_taiga_issue_changed_reassigned(self):
|
||||
# type: () -> None
|
||||
message = u':busts_in_silhouette: Antek reassigned issue **Aaaa** from Antek to Han Solo.\n'
|
||||
self.send_and_test_stream_message("issue_changed_reassigned", u'subject', message)
|
||||
|
||||
def test_taiga_issue_changed_subject(self):
|
||||
# type: () -> None
|
||||
message = u':notebook: Antek renamed issue Aaaa to **More descriptive name**.\n'
|
||||
self.send_and_test_stream_message("issue_changed_subject", u'subject', message)
|
||||
|
||||
def test_taiga_issue_changed_description(self):
|
||||
# type: () -> None
|
||||
message = u':notebook: Antek updated description of issue **More descriptive name**.\n'
|
||||
self.send_and_test_stream_message("issue_changed_description", u'subject', message)
|
||||
|
||||
def test_taiga_issue_changed_type(self):
|
||||
# type: () -> None
|
||||
message = u':bulb: Antek changed type of issue **A new issue** from Bug to Enhancement.\n'
|
||||
self.send_and_test_stream_message("issue_changed_type", u'subject', message)
|
||||
|
||||
def test_taiga_issue_changed_status(self):
|
||||
# type: () -> None
|
||||
message = u':chart_with_upwards_trend: Antek changed status of issue **A new issue** from New to Rejected.\n'
|
||||
self.send_and_test_stream_message("issue_changed_status", u'subject', message)
|
||||
|
||||
def test_taiga_issue_changed_severity(self):
|
||||
# type: () -> None
|
||||
message = u':warning: Antek changed severity of issue **A new issue** from Important to Critical.\n'
|
||||
self.send_and_test_stream_message("issue_changed_severity", u'subject', message)
|
||||
|
||||
def test_taiga_issue_changed_priority(self):
|
||||
# type: () -> None
|
||||
message = u':rocket: Antek changed priority of issue **A new issue** from Normal to High.\n'
|
||||
self.send_and_test_stream_message("issue_changed_priority", u'subject', message)
|
||||
|
||||
def test_taiga_userstory_comment_added(self):
|
||||
# type: () -> None
|
||||
message = u':thought_balloon: Han Solo commented on user story **Great US**.\n'
|
||||
self.send_and_test_stream_message("userstory_changed_comment_added", u'subject', message)
|
||||
|
||||
def test_taiga_task_changed_comment_added(self):
|
||||
# type: () -> None
|
||||
message = u':thought_balloon: Antek commented on task **New task assigned and in progress**.\n'
|
||||
self.send_and_test_stream_message("task_changed_comment_added", u'subject', message)
|
||||
|
||||
def test_taiga_issue_changed_comment_added(self):
|
||||
# type: () -> None
|
||||
message = u':thought_balloon: Antek commented on issue **Aaaa**.\n'
|
||||
self.send_and_test_stream_message("issue_changed_comment_added", u'subject', message)
|
||||
|
|
@ -0,0 +1,40 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
import ujson
|
||||
from zerver.models import Recipient
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class TeamcityHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'teamcity'
|
||||
URL_TEMPLATE = u"/api/v1/external/teamcity?stream={stream}&api_key={api_key}"
|
||||
SUBJECT = u"Project :: Compile"
|
||||
FIXTURE_DIR_NAME = 'teamcity'
|
||||
|
||||
def test_teamcity_success(self):
|
||||
# type: () -> None
|
||||
expected_message = u"Project :: Compile build 5535 - CL 123456 was successful! :thumbsup:\nDetails: [changes](http://teamcity/viewLog.html?buildTypeId=Project_Compile&buildId=19952&tab=buildChangesDiv), [build log](http://teamcity/viewLog.html?buildTypeId=Project_Compile&buildId=19952)"
|
||||
self.send_and_test_stream_message('success', self.SUBJECT, expected_message)
|
||||
|
||||
def test_teamcity_broken(self):
|
||||
# type: () -> None
|
||||
expected_message = u"Project :: Compile build 5535 - CL 123456 is broken with status Exit code 1 (new)! :thumbsdown:\nDetails: [changes](http://teamcity/viewLog.html?buildTypeId=Project_Compile&buildId=19952&tab=buildChangesDiv), [build log](http://teamcity/viewLog.html?buildTypeId=Project_Compile&buildId=19952)"
|
||||
self.send_and_test_stream_message('broken', self.SUBJECT, expected_message)
|
||||
|
||||
def test_teamcity_failure(self):
|
||||
# type: () -> None
|
||||
expected_message = u"Project :: Compile build 5535 - CL 123456 is still broken with status Exit code 1! :thumbsdown:\nDetails: [changes](http://teamcity/viewLog.html?buildTypeId=Project_Compile&buildId=19952&tab=buildChangesDiv), [build log](http://teamcity/viewLog.html?buildTypeId=Project_Compile&buildId=19952)"
|
||||
self.send_and_test_stream_message('failure', self.SUBJECT, expected_message)
|
||||
|
||||
def test_teamcity_fixed(self):
|
||||
# type: () -> None
|
||||
expected_message = u"Project :: Compile build 5535 - CL 123456 has been fixed! :thumbsup:\nDetails: [changes](http://teamcity/viewLog.html?buildTypeId=Project_Compile&buildId=19952&tab=buildChangesDiv), [build log](http://teamcity/viewLog.html?buildTypeId=Project_Compile&buildId=19952)"
|
||||
self.send_and_test_stream_message('fixed', self.SUBJECT, expected_message)
|
||||
|
||||
def test_teamcity_personal(self):
|
||||
# type: () -> None
|
||||
expected_message = u"Your personal build of Project :: Compile build 5535 - CL 123456 is broken with status Exit code 1 (new)! :thumbsdown:\nDetails: [changes](http://teamcity/viewLog.html?buildTypeId=Project_Compile&buildId=19952&tab=buildChangesDiv), [build log](http://teamcity/viewLog.html?buildTypeId=Project_Compile&buildId=19952)"
|
||||
payload = ujson.dumps(ujson.loads(self.fixture_data(self.FIXTURE_DIR_NAME, 'personal')))
|
||||
self.client_post(self.url, payload, content_type="application/json")
|
||||
msg = self.get_last_message()
|
||||
|
||||
self.assertEqual(msg.content, expected_message)
|
||||
self.assertEqual(msg.recipient.type, Recipient.PERSONAL)
|
||||
|
|
@ -0,0 +1,49 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from six import text_type
|
||||
from typing import Any, Dict
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class TransifexHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'transifex'
|
||||
URL_TEMPLATE = u"/api/v1/external/transifex?stream={stream}&api_key={api_key}&{data_template}"
|
||||
URL_DATA_TEMPLATE = "project={project}&language={language}&resource={resource}&{method}"
|
||||
URL_REVIEWED_METHOD_TEMPLATE = "reviewed=100"
|
||||
URL_TRANSLATED_METHOD_TEMPLATE = "translated=100"
|
||||
FIXTURE_DIR_NAME = 'transifex'
|
||||
|
||||
PROJECT = 'project-title'
|
||||
LANGUAGE = 'en'
|
||||
RESOURCE = 'file'
|
||||
REVIEWED = True
|
||||
|
||||
def test_transifex_reviewed_message(self):
|
||||
# type: () -> None
|
||||
self.REVIEWED = True
|
||||
expected_subject = "{} in {}".format(self.PROJECT, self.LANGUAGE)
|
||||
expected_message = "Resource {} fully reviewed.".format(self.RESOURCE)
|
||||
self.url = self.build_webhook_url()
|
||||
self.send_and_test_stream_message(None, expected_subject, expected_message)
|
||||
|
||||
def test_transifex_translated_message(self):
|
||||
# type: () -> None
|
||||
self.REVIEWED = False
|
||||
expected_subject = "{} in {}".format(self.PROJECT, self.LANGUAGE)
|
||||
expected_message = "Resource {} fully translated.".format(self.RESOURCE)
|
||||
self.url = self.build_webhook_url()
|
||||
self.send_and_test_stream_message(None, expected_subject, expected_message)
|
||||
self.REVIEWED = True
|
||||
|
||||
def build_webhook_url(self):
|
||||
# type: () -> text_type
|
||||
url_data = self.URL_DATA_TEMPLATE.format(
|
||||
project=self.PROJECT,
|
||||
language=self.LANGUAGE,
|
||||
resource=self.RESOURCE,
|
||||
method=self.URL_REVIEWED_METHOD_TEMPLATE if self.REVIEWED else self.URL_TRANSLATED_METHOD_TEMPLATE
|
||||
)
|
||||
api_key = self.get_api_key(self.TEST_USER_EMAIL)
|
||||
return self.URL_TEMPLATE.format(api_key=api_key, stream=self.STREAM_NAME, data_template=url_data)
|
||||
|
||||
def get_body(self, fixture_name):
|
||||
# type: (text_type) -> Dict[str, Any]
|
||||
return {}
|
||||
|
|
@ -0,0 +1,33 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from six import text_type
|
||||
from six.moves import urllib
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class TravisHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'travis'
|
||||
URL_TEMPLATE = u"/api/v1/external/travis?stream={stream}&api_key={api_key}&topic=builds"
|
||||
FIXTURE_DIR_NAME = 'travis'
|
||||
|
||||
def test_travis_message(self):
|
||||
# type: () -> None
|
||||
"""
|
||||
Build notifications are generated by Travis after build completes.
|
||||
|
||||
The subject describes the repo and Stash "project". The
|
||||
content describes the commits pushed.
|
||||
"""
|
||||
expected_message = (u"Author: josh_mandel\nBuild status: Passed :thumbsup:\n"
|
||||
u"Details: [changes](https://github.com/hl7-fhir/fhir-sv"
|
||||
u"n/compare/6dccb98bcfd9...6c457d366a31), [build log](ht"
|
||||
u"tps://travis-ci.org/hl7-fhir/fhir-svn/builds/92495257)")
|
||||
|
||||
self.send_and_test_stream_message(
|
||||
'build',
|
||||
'builds',
|
||||
expected_message,
|
||||
content_type="application/x-www-form-urlencoded"
|
||||
)
|
||||
|
||||
def get_body(self, fixture_name):
|
||||
# type: (text_type) -> text_type
|
||||
return urllib.parse.urlencode({'payload': self.fixture_data("travis", fixture_name, file_type="json")})
|
||||
|
|
@ -0,0 +1,102 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class TrelloHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'trello'
|
||||
URL_TEMPLATE = u"/api/v1/external/trello?stream={stream}&api_key={api_key}"
|
||||
FIXTURE_DIR_NAME = 'trello'
|
||||
|
||||
def test_trello_webhook_when_card_was_moved_to_another_list(self):
|
||||
# type: () -> None
|
||||
expected_message = u"TomaszKolek moved [This is a card.](https://trello.com/c/r33ylX2Z) from Basics to Intermediate."
|
||||
self.send_and_test_stream_message('changing_cards_list', u"Welcome Board.", expected_message)
|
||||
|
||||
def test_trello_webhook_when_card_was_renamed(self):
|
||||
# type: () -> None
|
||||
expected_message = u"TomaszKolek renamed the card from \"Old name\" to [New name](https://trello.com/c/r33ylX2Z)."
|
||||
self.send_and_test_stream_message('renaming_card', u"Welcome Board.", expected_message)
|
||||
|
||||
def test_trello_webhook_when_label_was_added_to_card(self):
|
||||
# type: () -> None
|
||||
expected_message = u"TomaszKolek added a green label with \"text value\" to [Card name](https://trello.com/c/r33ylX2Z)."
|
||||
self.send_and_test_stream_message('adding_label_to_card', u"Welcome Board.", expected_message)
|
||||
|
||||
def test_trello_webhook_when_label_was_removing_from_card(self):
|
||||
# type: () -> None
|
||||
expected_message = u"TomaszKolek removed a green label with \"text value\" from [New Card](https://trello.com/c/r33ylX2Z)."
|
||||
self.send_and_test_stream_message('removing_label_from_card', u"Welcome Board.", expected_message)
|
||||
|
||||
def test_trello_webhook_when_member_was_added_to_card(self):
|
||||
# type: () -> None
|
||||
expected_message = u"TomaszKolek added TomaszKolek to [Card name](https://trello.com/c/9BduUcVQ)."
|
||||
self.send_and_test_stream_message('adding_member_to_card', u"Welcome Board.", expected_message)
|
||||
|
||||
def test_trello_webhook_when_member_was_removed_from_card(self):
|
||||
# type: () -> None
|
||||
expected_message = u"TomaszKolek removed Trello from [Card name](https://trello.com/c/9BduUcVQ)."
|
||||
self.send_and_test_stream_message('removing_member_from_card', u"Welcome Board.", expected_message)
|
||||
|
||||
def test_trello_webhook_when_due_date_was_set(self):
|
||||
# type: () -> None
|
||||
expected_message = u"TomaszKolek set due date for [Card name](https://trello.com/c/9BduUcVQ) to 05/11/2016 10:00AM."
|
||||
self.send_and_test_stream_message('setting_due_date_to_card', u"Welcome Board.", expected_message)
|
||||
|
||||
def test_trello_webhook_when_due_date_was_changed(self):
|
||||
# type: () -> None
|
||||
expected_message = u"TomaszKolek changed due date for [Card name](https://trello.com/c/9BduUcVQ) from 05/11/2016 10:00AM to 05/24/2016 10:00AM."
|
||||
self.send_and_test_stream_message('changing_due_date_on_card', u"Welcome Board.", expected_message)
|
||||
|
||||
def test_trello_webhook_when_due_date_was_removed(self):
|
||||
# type: () -> None
|
||||
expected_message = u"TomaszKolek removed the due date from [Card name](https://trello.com/c/9BduUcVQ)."
|
||||
self.send_and_test_stream_message('removing_due_date_from_card', u"Welcome Board.", expected_message)
|
||||
|
||||
def test_trello_webhook_when_card_was_archived(self):
|
||||
# type: () -> None
|
||||
expected_message = u"TomaszKolek archived [Card name](https://trello.com/c/9BduUcVQ)."
|
||||
self.send_and_test_stream_message('archiving_card', u"Welcome Board.", expected_message)
|
||||
|
||||
def test_trello_webhook_when_card_was_reopened(self):
|
||||
# type: () -> None
|
||||
expected_message = u"TomaszKolek reopened [Card name](https://trello.com/c/9BduUcVQ)."
|
||||
self.send_and_test_stream_message('reopening_card', u"Welcome Board.", expected_message)
|
||||
|
||||
def test_trello_webhook_when_card_was_created(self):
|
||||
# type: () -> None
|
||||
expected_message = u"TomaszKolek created [New card](https://trello.com/c/5qrgGdD5)."
|
||||
self.send_and_test_stream_message('creating_card', u"Welcome Board.", expected_message)
|
||||
|
||||
def test_trello_webhook_when_attachment_was_added_to_card(self):
|
||||
# type: () -> None
|
||||
expected_message = u"TomaszKolek added [attachment_name](http://url.com) to [New card](https://trello.com/c/xPKXoSTQ)."
|
||||
self.send_and_test_stream_message('adding_attachment_to_card', u"Welcome Board.", expected_message)
|
||||
|
||||
def test_trello_webhook_when_checklist_was_added_to_card(self):
|
||||
# type: () -> None
|
||||
expected_message = u"TomaszKolek added the Checklist checklist to [New card](https://trello.com/c/xPKXoSTQ)."
|
||||
self.send_and_test_stream_message('adding_checklist_to_card', u"Welcome Board.", expected_message)
|
||||
|
||||
def test_trello_webhook_when_member_was_removed_from_board(self):
|
||||
# type: () -> None
|
||||
expected_message = u"TomaszKolek removed Trello from [Welcome Board](https://trello.com/b/iqXXzYEj)."
|
||||
self.send_and_test_stream_message('removing_member_from_board', u"Welcome Board.", expected_message)
|
||||
|
||||
def test_trello_webhook_when_member_was_added_to_board(self):
|
||||
# type: () -> None
|
||||
expected_message = u"TomaszKolek added Trello to [Welcome Board](https://trello.com/b/iqXXzYEj)."
|
||||
self.send_and_test_stream_message('adding_member_to_board', u"Welcome Board.", expected_message)
|
||||
|
||||
def test_trello_webhook_when_list_was_added_to_board(self):
|
||||
# type: () -> None
|
||||
expected_message = u"TomaszKolek added New list list to [Welcome Board](https://trello.com/b/iqXXzYEj)."
|
||||
self.send_and_test_stream_message('adding_new_list_to_board', u"Welcome Board.", expected_message)
|
||||
|
||||
def test_trello_webhook_when_comment_was_added_to_card(self):
|
||||
# type: () -> None
|
||||
expected_message = u"TomaszKolek commented on [New card](https://trello.com/c/xPKXoSTQ)."
|
||||
self.send_and_test_stream_message('adding_comment_to_card', u"Welcome Board.", expected_message)
|
||||
|
||||
def test_trello_webhook_when_board_was_renamed(self):
|
||||
# type: () -> None
|
||||
expected_message = u"TomaszKolek renamed the board from Welcome Board to [New name](https://trello.com/b/iqXXzYEj)."
|
||||
self.send_and_test_stream_message('renaming_board', u"New name.", expected_message)
|
||||
|
|
@ -0,0 +1,42 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class UpdownHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'updown'
|
||||
URL_TEMPLATE = u"/api/v1/external/updown?stream={stream}&api_key={api_key}"
|
||||
FIXTURE_DIR_NAME = 'updown'
|
||||
|
||||
def test_updown_check_down_event(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"https://updown.io"
|
||||
expected_message = u"Service is `down`. It returned \"500\" error at 07-02-2016 13:11."
|
||||
self.send_and_test_stream_message('check_down_one_event', expected_subject, expected_message)
|
||||
|
||||
def test_updown_check_up_again_event(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"https://updown.io"
|
||||
expected_message = u"Service is `up` again after 4 minutes 25 seconds."
|
||||
self.send_and_test_stream_message('check_up_again_one_event', expected_subject, expected_message)
|
||||
|
||||
def test_updown_check_up_event(self):
|
||||
# type: () -> None
|
||||
expected_subject = u"https://updown.io"
|
||||
expected_message = u"Service is `up`."
|
||||
self.send_and_test_stream_message('check_up_first_time', expected_subject, expected_message)
|
||||
|
||||
def test_updown_check_up_multiple_events(self):
|
||||
# type: () -> None
|
||||
first_message_expected_subject = u"https://updown.io"
|
||||
first_message_expected_message = u"Service is `up` again after 1 second."
|
||||
|
||||
second_message_expected_subject = u"https://updown.io"
|
||||
second_message_expected_message = u"Service is `down`. It returned \"500\" error at 07-02-2016 13:11."
|
||||
|
||||
self.send_and_test_stream_message('check_multiple_events')
|
||||
last_message = self.get_last_message()
|
||||
self.do_test_subject(last_message, first_message_expected_subject)
|
||||
self.do_test_message(last_message, first_message_expected_message)
|
||||
|
||||
second_to_last_message = self.get_second_to_last_message()
|
||||
self.do_test_subject(second_to_last_message, second_message_expected_subject)
|
||||
self.do_test_message(second_to_last_message, second_message_expected_message)
|
||||
|
|
@ -0,0 +1,30 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from six import text_type
|
||||
from typing import Any, Dict
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class YoHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'yo'
|
||||
URL_TEMPLATE = u"/api/v1/external/yo?email={email}&api_key={api_key}&username={username}&user_ip={ip}"
|
||||
FIXTURE_DIR_NAME = 'yo'
|
||||
|
||||
def test_yo_message(self):
|
||||
# type: () -> None
|
||||
"""
|
||||
Yo App sends notification whenever user receives a new Yo from another user.
|
||||
"""
|
||||
expected_message = u"Yo from IAGO"
|
||||
self.send_and_test_private_message('', expected_message=expected_message,
|
||||
content_type="application/x-www-form-urlencoded")
|
||||
|
||||
def get_body(self, fixture_name):
|
||||
# type: (text_type) -> Dict[str, Any]
|
||||
return {}
|
||||
|
||||
def build_webhook_url(self):
|
||||
# type: () -> text_type
|
||||
api_key = self.get_api_key(self.TEST_USER_EMAIL)
|
||||
email = "cordelia@zulip.com"
|
||||
username = "IAGO"
|
||||
ip = "127.0.0.1"
|
||||
return self.URL_TEMPLATE.format(email=email, api_key=api_key, username=username, ip=ip)
|
||||
|
|
@ -0,0 +1,52 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
from six import text_type
|
||||
from typing import Any, Optional
|
||||
|
||||
from zerver.lib.test_helpers import WebhookTestCase
|
||||
|
||||
class ZenDeskHookTests(WebhookTestCase):
|
||||
STREAM_NAME = 'zendesk'
|
||||
URL_TEMPLATE = u"/api/v1/external/zendesk"
|
||||
|
||||
DEFAULT_TICKET_TITLE = 'User can\'t login'
|
||||
TICKET_TITLE = DEFAULT_TICKET_TITLE
|
||||
|
||||
DEFAULT_TICKET_ID = 54
|
||||
TICKET_ID = DEFAULT_TICKET_ID
|
||||
|
||||
DEFAULT_MESSAGE = 'Message'
|
||||
MESSAGE = DEFAULT_MESSAGE
|
||||
|
||||
def get_body(self, fixture_name):
|
||||
# type: (text_type) -> Dict[str, Any]
|
||||
return {
|
||||
'ticket_title': self.TICKET_TITLE,
|
||||
'ticket_id': self.TICKET_ID,
|
||||
'message': self.MESSAGE,
|
||||
'stream': self.STREAM_NAME,
|
||||
}
|
||||
|
||||
def do_test(self, expected_subject=None, expected_message=None):
|
||||
# type: (Optional[text_type], Optional[text_type]) -> None
|
||||
self.send_and_test_stream_message(None, expected_subject, expected_message,
|
||||
content_type=None, **self.api_auth(self.TEST_USER_EMAIL))
|
||||
self.TICKET_TITLE = self.DEFAULT_TICKET_TITLE
|
||||
self.TICKET_ID = self.DEFAULT_TICKET_ID
|
||||
self.MESSAGE = self.DEFAULT_MESSAGE
|
||||
|
||||
def test_subject(self):
|
||||
# type: () -> None
|
||||
self.TICKET_ID = 4
|
||||
self.TICKET_TITLE = "Test ticket"
|
||||
self.do_test(expected_subject='#4: Test ticket')
|
||||
|
||||
def test_long_subject(self):
|
||||
# type: () -> None
|
||||
self.TICKET_ID = 4
|
||||
self.TICKET_TITLE = "Test ticket" + '!' * 80
|
||||
self.do_test(expected_subject='#4: Test ticket' + '!' * 42 + '...')
|
||||
|
||||
def test_content(self):
|
||||
# type: () -> None
|
||||
self.MESSAGE = 'New comment:\n> It is better\n* here'
|
||||
self.do_test(expected_message='New comment:\n> It is better\n* here')
|
||||
Loading…
Reference in New Issue