mirror of
https://github.com/zulip/zulip.git
synced 2025-11-04 14:03:30 +00:00
c32e6f4940
- Made the branch-filtering checks uniform across all the integrations, by adding a helper function to git.py, and re-using it. - Instead of checking if the name of the branch that generated the event is a substring of the "branches" parameter, we now check if there's an exact match. For example, if there are two branches named "main" and "release/v1.0-main", and the user wants to track pushes to only the "release/v1.0-main" branch, they wouldn't have been able to previously, it will always track pushes to both branches. There was no way to filter out the smaller named branch when there were overlaps.
68 lines
2.4 KiB
Python
68 lines
2.4 KiB
Python
from django.http import HttpRequest, HttpResponse
|
|
|
|
from zerver.decorator import authenticated_rest_api_view
|
|
from zerver.lib.response import json_success
|
|
from zerver.lib.typed_endpoint import JsonBodyPayload, typed_endpoint
|
|
from zerver.lib.validator import WildValue, check_string
|
|
from zerver.lib.webhooks.common import check_send_webhook_message
|
|
from zerver.lib.webhooks.git import (
|
|
TOPIC_WITH_BRANCH_TEMPLATE,
|
|
get_push_commits_event_message,
|
|
is_branch_name_notifiable,
|
|
)
|
|
from zerver.models import UserProfile
|
|
|
|
|
|
@authenticated_rest_api_view(webhook_client_name="Bitbucket")
|
|
@typed_endpoint
|
|
def api_bitbucket_webhook(
|
|
request: HttpRequest,
|
|
user_profile: UserProfile,
|
|
*,
|
|
payload: JsonBodyPayload[WildValue],
|
|
branches: str | None = None,
|
|
) -> HttpResponse:
|
|
repository = payload["repository"]
|
|
|
|
commits = [
|
|
{
|
|
"name": (
|
|
commit["author"].tame(check_string)
|
|
if "author" in commit
|
|
else payload.get("user", "Someone").tame(check_string)
|
|
),
|
|
"sha": commit["raw_node"].tame(check_string),
|
|
"message": commit["message"].tame(check_string),
|
|
"url": "{}{}commits/{}".format(
|
|
payload["canon_url"].tame(check_string),
|
|
repository["absolute_url"].tame(check_string),
|
|
commit["raw_node"].tame(check_string),
|
|
),
|
|
}
|
|
for commit in payload["commits"]
|
|
]
|
|
|
|
if len(commits) == 0:
|
|
# Bitbucket doesn't give us enough information to really give
|
|
# a useful message :/
|
|
topic_name = repository["name"].tame(check_string)
|
|
content = "{} [force pushed]({}).".format(
|
|
payload.get("user", "Someone").tame(check_string),
|
|
payload["canon_url"].tame(check_string) + repository["absolute_url"].tame(check_string),
|
|
)
|
|
else:
|
|
branch = payload["commits"][-1]["branch"].tame(check_string)
|
|
if not is_branch_name_notifiable(branch, branches):
|
|
return json_success(request)
|
|
|
|
committer = payload.get("user", "Someone").tame(check_string)
|
|
content = get_push_commits_event_message(committer, None, branch, commits)
|
|
topic_name = TOPIC_WITH_BRANCH_TEMPLATE.format(
|
|
repo=repository["name"].tame(check_string), branch=branch
|
|
)
|
|
|
|
check_send_webhook_message(
|
|
request, user_profile, topic_name, content, unquote_url_parameters=True
|
|
)
|
|
return json_success(request)
|