testing: added webhook tests and fixed tags adding
This commit is contained in:
parent
137f5001fb
commit
2d75c988c1
9 changed files with 110 additions and 22 deletions
|
|
@ -77,14 +77,13 @@ class Command(object):
|
|||
assert self.process.returncode == 0
|
||||
|
||||
|
||||
def _add_files(vcs, dest, clone_url=None, tags=None, target_branch=None,
|
||||
new_branch=False, **kwargs):
|
||||
def _add_files(vcs, dest, clone_url=None, tags=None, target_branch=None, new_branch=False, **kwargs):
|
||||
git_ident = "git config user.name {} && git config user.email {}".format(
|
||||
'Marcin Kuźminski', 'me@email.com')
|
||||
cwd = path = jn(dest)
|
||||
|
||||
tags = tags or []
|
||||
added_file = jn(path, '%ssetup.py' % tempfile._RandomNameSequence().next())
|
||||
added_file = jn(path, '%s_setup.py' % tempfile._RandomNameSequence().next())
|
||||
Command(cwd).execute('touch %s' % added_file)
|
||||
Command(cwd).execute('%s add %s' % (vcs, added_file))
|
||||
author_str = 'Marcin Kuźminski <me@email.com>'
|
||||
|
|
@ -92,19 +91,20 @@ def _add_files(vcs, dest, clone_url=None, tags=None, target_branch=None,
|
|||
for i in range(kwargs.get('files_no', 3)):
|
||||
cmd = """echo 'added_line%s' >> %s""" % (i, added_file)
|
||||
Command(cwd).execute(cmd)
|
||||
|
||||
if vcs == 'hg':
|
||||
cmd = """hg commit -m 'commited new %s' -u '%s' %s """ % (
|
||||
cmd = """hg commit -m 'committed new %s' -u '%s' %s """ % (
|
||||
i, author_str, added_file
|
||||
)
|
||||
elif vcs == 'git':
|
||||
cmd = """%s && git commit -m 'commited new %s' %s""" % (
|
||||
cmd = """%s && git commit -m 'committed new %s' %s""" % (
|
||||
git_ident, i, added_file)
|
||||
Command(cwd).execute(cmd)
|
||||
|
||||
for tag in tags:
|
||||
if vcs == 'hg':
|
||||
Command(cwd).execute(
|
||||
'hg tag', tag['name'])
|
||||
'hg tag -m "{}" -u "{}" '.format(tag['commit'], author_str), tag['name'])
|
||||
elif vcs == 'git':
|
||||
if tag['commit']:
|
||||
# annotated tag
|
||||
|
|
|
|||
|
|
@ -31,6 +31,7 @@ import os
|
|||
import tempfile
|
||||
import textwrap
|
||||
import pytest
|
||||
import logging
|
||||
|
||||
from rhodecode import events
|
||||
from rhodecode.model.db import Integration, UserRepoToPerm, Permission, \
|
||||
|
|
@ -49,6 +50,8 @@ REPO_GROUP = 'a_repo_group'
|
|||
HG_REPO_WITH_GROUP = '%s/%s' % (REPO_GROUP, HG_REPO)
|
||||
GIT_REPO_WITH_GROUP = '%s/%s' % (REPO_GROUP, GIT_REPO)
|
||||
|
||||
log = logging.getLogger(__name__)
|
||||
|
||||
|
||||
@pytest.fixture(scope="module")
|
||||
def rcextensions(request, db_connection, tmpdir_factory):
|
||||
|
|
@ -126,10 +129,10 @@ def rc_web_server(
|
|||
Run the web server as a subprocess. with it's own instance of vcsserver
|
||||
"""
|
||||
rcweb_port = available_port_factory()
|
||||
print('Using rcweb ops test port {}'.format(rcweb_port))
|
||||
log.info('Using rcweb ops test port {}'.format(rcweb_port))
|
||||
|
||||
vcsserver_port = available_port_factory()
|
||||
print('Using vcsserver ops test port {}'.format(vcsserver_port))
|
||||
log.info('Using vcsserver ops test port {}'.format(vcsserver_port))
|
||||
|
||||
vcs_log = os.path.join(tempfile.gettempdir(), 'rc_op_vcs.log')
|
||||
vcsserver_factory(
|
||||
|
|
|
|||
|
|
@ -0,0 +1,80 @@
|
|||
# -*- coding: utf-8 -*-
|
||||
|
||||
# Copyright (C) 2010-2020 RhodeCode GmbH
|
||||
#
|
||||
# This program is free software: you can redistribute it and/or modify
|
||||
# it under the terms of the GNU Affero General Public License, version 3
|
||||
# (only), as published by the Free Software Foundation.
|
||||
#
|
||||
# This program is distributed in the hope that it will be useful,
|
||||
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
# GNU General Public License for more details.
|
||||
#
|
||||
# You should have received a copy of the GNU Affero General Public License
|
||||
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
#
|
||||
# This program is dual-licensed. If you wish to learn more about the
|
||||
# RhodeCode Enterprise Edition, including its added features, Support services,
|
||||
# and proprietary license terms, please see https://rhodecode.com/licenses/
|
||||
|
||||
"""
|
||||
Test suite for making push/pull operations, on specially modified INI files
|
||||
|
||||
.. important::
|
||||
|
||||
You must have git >= 1.8.5 for tests to work fine. With 68b939b git started
|
||||
to redirect things to stderr instead of stdout.
|
||||
"""
|
||||
|
||||
import pytest
|
||||
import requests
|
||||
|
||||
from rhodecode.tests import GIT_REPO, HG_REPO
|
||||
from rhodecode.tests.vcs_operations import Command, _add_files_and_push
|
||||
|
||||
|
||||
def check_connection():
|
||||
try:
|
||||
response = requests.get('http://httpbin.org')
|
||||
return response.status_code == 200
|
||||
except Exception as e:
|
||||
print(e)
|
||||
|
||||
return False
|
||||
|
||||
|
||||
connection_available = pytest.mark.skipif(
|
||||
not check_connection(), reason="No outside internet connection available")
|
||||
|
||||
|
||||
@pytest.mark.usefixtures("baseapp", "enable_webhook_push_integration")
|
||||
class TestVCSOperationsOnCustomIniConfig(object):
|
||||
|
||||
def test_push_with_webhook_hg(self, rc_web_server, tmpdir):
|
||||
clone_url = rc_web_server.repo_clone_url(HG_REPO)
|
||||
|
||||
stdout, stderr = Command('/tmp').execute(
|
||||
'hg clone', clone_url, tmpdir.strpath)
|
||||
|
||||
push_url = rc_web_server.repo_clone_url(HG_REPO)
|
||||
_add_files_and_push('hg', tmpdir.strpath, clone_url=push_url)
|
||||
|
||||
rc_log = rc_web_server.get_rc_log()
|
||||
assert 'ERROR' not in rc_log
|
||||
assert "executing task TASK:<@task: rhodecode.integrations.types.webhook.post_to_webhook" in rc_log
|
||||
assert "handling event repo-push with integration <rhodecode.integrations.types.webhook.WebhookIntegrationType" in rc_log
|
||||
|
||||
def test_push_with_webhook_gut(self, rc_web_server, tmpdir):
|
||||
clone_url = rc_web_server.repo_clone_url(GIT_REPO)
|
||||
|
||||
stdout, stderr = Command('/tmp').execute(
|
||||
'git clone', clone_url, tmpdir.strpath)
|
||||
|
||||
push_url = rc_web_server.repo_clone_url(GIT_REPO)
|
||||
_add_files_and_push('git', tmpdir.strpath, clone_url=push_url)
|
||||
|
||||
rc_log = rc_web_server.get_rc_log()
|
||||
assert 'ERROR' not in rc_log
|
||||
assert "executing task TASK:<@task: rhodecode.integrations.types.webhook.post_to_webhook" in rc_log
|
||||
assert "handling event repo-push with integration <rhodecode.integrations.types.webhook.WebhookIntegrationType" in rc_log
|
||||
Loading…
Add table
Add a link
Reference in a new issue