# HG changeset patch # User Marcin Kuzminski # Date 2017-11-30 13:39:26 # Node ID af8ad23268ab014aaf25b7cba7362b0e3cff72aa # Parent 36eff123f7905903db28af9bed7bb632394e80e3 webhook: execute via celery for async. diff --git a/rhodecode/integrations/types/webhook.py b/rhodecode/integrations/types/webhook.py --- a/rhodecode/integrations/types/webhook.py +++ b/rhodecode/integrations/types/webhook.py @@ -34,7 +34,7 @@ import rhodecode from rhodecode import events from rhodecode.translation import _ from rhodecode.integrations.types.base import IntegrationTypeBase -from rhodecode.lib.celerylib import async_task, RequestContextTask +from rhodecode.lib.celerylib import run_task, async_task, RequestContextTask log = logging.getLogger(__name__) @@ -313,11 +313,47 @@ class WebhookIntegrationType(Integration url_calls = handler(event, data) log.debug('webhook: calling following urls: %s', [x[0] for x in url_calls]) - post_to_webhook(url_calls, self.settings) + + run_task(post_to_webhook, url_calls, self.settings) @async_task(ignore_result=True, base=RequestContextTask) def post_to_webhook(url_calls, settings): + """ + Example data:: + + {'actor': {'user_id': 2, 'username': u'admin'}, + 'actor_ip': u'192.168.157.1', + 'name': 'repo-push', + 'push': {'branches': [{'name': u'default', + 'url': 'http://rc.local:8080/hg-repo/changelog?branch=default'}], + 'commits': [{'author': u'Marcin Kuzminski ', + 'branch': u'default', + 'date': datetime.datetime(2017, 11, 30, 12, 59, 48), + 'issues': [], + 'mentions': [], + 'message': u'commit Thu 30 Nov 2017 13:59:48 CET', + 'message_html': u'commit Thu 30 Nov 2017 13:59:48 CET', + 'message_html_title': u'commit Thu 30 Nov 2017 13:59:48 CET', + 'parents': [{'raw_id': '431b772a5353dad9974b810dd3707d79e3a7f6e0'}], + 'permalink_url': u'http://rc.local:8080/_7/changeset/a815cc738b9651eb5ffbcfb1ce6ccd7c701a5ddf', + 'raw_id': 'a815cc738b9651eb5ffbcfb1ce6ccd7c701a5ddf', + 'refs': {'bookmarks': [], 'branches': [u'default'], 'tags': [u'tip']}, + 'reviewers': [], + 'revision': 9L, + 'short_id': 'a815cc738b96', + 'url': u'http://rc.local:8080/hg-repo/changeset/a815cc738b9651eb5ffbcfb1ce6ccd7c701a5ddf'}], + 'issues': {}}, + 'repo': {'extra_fields': '', + 'permalink_url': u'http://rc.local:8080/_7', + 'repo_id': 7, + 'repo_name': u'hg-repo', + 'repo_type': u'hg', + 'url': u'http://rc.local:8080/hg-repo'}, + 'server_url': u'http://rc.local:8080', + 'utc_timestamp': datetime.datetime(2017, 11, 30, 13, 0, 1, 569276) + + """ max_retries = 3 retries = Retry( total=max_retries, @@ -342,6 +378,7 @@ def post_to_webhook(url_calls, settings) log.debug('calling Webhook with method: %s, and auth:%s', call_method, auth) + resp = call_method(url, json={ 'token': token, 'event': data