rhodecode/config/rcextensions/hooks.py

# Copyright (C) 2016-2024 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/

import logging
from .utils import DotDict, HookResponse, has_kwargs

log = logging.getLogger('rhodecode.' + __name__)

# Config shortcut to keep, all configuration in one place
# Example:  api_key = CONFIG.my_config.api_key
CONFIG = DotDict(
    my_config=DotDict(
        api_key='<secret>',
    ),

)


@has_kwargs({
    'repo_name': '',
    'repo_type': '',
    'description': '',
    'private': '',
    'created_on': '',
    'enable_downloads': '',
    'repo_id': '',
    'user_id': '',
    'enable_statistics': '',
    'clone_uri': '',
    'fork_id': '',
    'group_id': '',
    'created_by': ''
})
def _create_repo_hook(*args, **kwargs):
    """
    POST CREATE REPOSITORY HOOK. This function will be executed after
    each repository is created. kwargs available:

    """
    return HookResponse(0, '')


@has_kwargs({
    'repo_name': '',
    'repo_type': '',
    'description': '',
    'private': '',
    'created_on': '',
    'enable_downloads': '',
    'repo_id': '',
    'user_id': '',
    'enable_statistics': '',
    'clone_uri': '',
    'fork_id': '',
    'group_id': '',
    'created_by': '',
    'repository': '',
    'comment': '',
    'commit': ''
})
def _comment_commit_repo_hook(*args, **kwargs):
    """
    POST CREATE REPOSITORY COMMENT ON COMMIT HOOK. This function will be executed after
    a comment is made on this repository commit.

    """
    return HookResponse(0, '')


@has_kwargs({
    'repo_name': '',
    'repo_type': '',
    'description': '',
    'private': '',
    'created_on': '',
    'enable_downloads': '',
    'repo_id': '',
    'user_id': '',
    'enable_statistics': '',
    'clone_uri': '',
    'fork_id': '',
    'group_id': '',
    'created_by': '',
    'repository': '',
    'comment': '',
    'commit': ''
})
def _comment_edit_commit_repo_hook(*args, **kwargs):
    """
    POST CREATE REPOSITORY COMMENT ON COMMIT HOOK. This function will be executed after
    a comment is made on this repository commit.

    """
    return HookResponse(0, '')


@has_kwargs({
    'group_name': '',
    'group_parent_id': '',
    'group_description': '',
    'group_id': '',
    'user_id': '',
    'created_by': '',
    'created_on': '',
    'enable_locking': ''
})
def _create_repo_group_hook(*args, **kwargs):
    """
    POST CREATE REPOSITORY GROUP HOOK, this function will be
    executed after each repository group is created. kwargs available:
    """
    return HookResponse(0, '')


@has_kwargs({
    'username': '',
    'password': '',
    'email': '',
    'firstname': '',
    'lastname': '',
    'active': '',
    'admin': '',
    'created_by': '',
})
def _pre_create_user_hook(*args, **kwargs):
    """
    PRE CREATE USER HOOK, this function will be executed before each
    user is created, it returns a tuple of bool, reason.
    If bool is False the user creation will be stopped and reason
    will be displayed to the user.

    Return HookResponse(1, reason) to block user creation

    """

    reason = 'allowed'
    return HookResponse(0, reason)


@has_kwargs({
    'username': '',
    'full_name_or_username': '',
    'full_contact': '',
    'user_id': '',
    'name': '',
    'firstname': '',
    'short_contact': '',
    'admin': '',
    'lastname': '',
    'ip_addresses': '',
    'extern_type': '',
    'extern_name': '',
    'email': '',
    'api_key': '',
    'api_keys': '',
    'last_login': '',
    'full_name': '',
    'active': '',
    'password': '',
    'emails': '',
    'inherit_default_permissions': '',
    'created_by': '',
    'created_on': '',
})
def _create_user_hook(*args, **kwargs):
    """
    POST CREATE USER HOOK, this function will be executed after each user is created
    """
    return HookResponse(0, '')


@has_kwargs({
    'repo_name': '',
    'repo_type': '',
    'description': '',
    'private': '',
    'created_on': '',
    'enable_downloads': '',
    'repo_id': '',
    'user_id': '',
    'enable_statistics': '',
    'clone_uri': '',
    'fork_id': '',
    'group_id': '',
    'deleted_by': '',
    'deleted_on': '',
})
def _delete_repo_hook(*args, **kwargs):
    """
    POST DELETE REPOSITORY HOOK, this function will be executed after
    each repository deletion
    """
    return HookResponse(0, '')


@has_kwargs({
    'username': '',
    'full_name_or_username': '',
    'full_contact': '',
    'user_id': '',
    'name': '',
    'short_contact': '',
    'admin': '',
    'firstname': '',
    'lastname': '',
    'ip_addresses': '',
    'email': '',
    'api_key': '',
    'last_login': '',
    'full_name': '',
    'active': '',
    'password': '',
    'emails': '',
    'inherit_default_permissions': '',
    'deleted_by': '',
})
def _delete_user_hook(*args, **kwargs):
    """
    POST DELETE USER HOOK, this function will be executed after each
    user is deleted kwargs available:
    """
    return HookResponse(0, '')


# =============================================================================
# PUSH/PULL RELATED HOOKS
# =============================================================================
@has_kwargs({
    'server_url': 'url of instance that triggered this hook',
    'config': 'path to .ini config used',
    'scm': 'type of version control "git", "hg", "svn"',
    'username': 'username of actor who triggered this event',
    'ip': 'ip address of actor who triggered this hook',
    'action': '',
    'repository': 'repository name',
    'repo_store_path': 'full path to where repositories are stored',
    'commit_ids': 'pre transaction metadata for commit ids',
    'hook_type': '',
    'user_agent': 'Client user agent, e.g git or mercurial CLI version',
})
def _pre_push_hook(*args, **kwargs):
    """
    Post push hook
    To stop version control from storing the transaction and send a message to user
    use non-zero HookResponse with a message, e.g return HookResponse(1, 'Not allowed')

    This message will be shown back to client during PUSH operation

    Commit ids might look like that::

    [{u'hg_env|git_env': ...,
      u'multiple_heads': [],
      u'name': u'default',
      u'new_rev': u'd0befe0692e722e01d5677f27a104631cf798b69',
      u'old_rev': u'd0befe0692e722e01d5677f27a104631cf798b69',
      u'ref': u'',
      u'total_commits': 2,
      u'type': u'branch'}]
    """
    return HookResponse(0, '')


@has_kwargs({
    'server_url': 'url of instance that triggered this hook',
    'config': 'path to .ini config used',
    'scm': 'type of version control "git", "hg", "svn"',
    'username': 'username of actor who triggered this event',
    'ip': 'ip address of actor who triggered this hook',
    'action': '',
    'repository': 'repository name',
    'repo_store_path': 'full path to where repositories are stored',
    'commit_ids': 'list of pushed commit_ids (sha1)',
    'hook_type': '',
    'user_agent': 'Client user agent, e.g git or mercurial CLI version',
})
def _push_hook(*args, **kwargs):
    """
    POST PUSH HOOK, this function will be executed after each push it's
    executed after the build-in hook that RhodeCode uses for logging pushes
    """
    return HookResponse(0, '')


@has_kwargs({
    'server_url': 'url of instance that triggered this hook',
    'repo_store_path': 'full path to where repositories are stored',
    'config': 'path to .ini config used',
    'scm': 'type of version control "git", "hg", "svn"',
    'username': 'username of actor who triggered this event',
    'ip': 'ip address of actor who triggered this hook',
    'action': '',
    'repository': 'repository name',
    'hook_type': '',
    'user_agent': 'Client user agent, e.g git or mercurial CLI version',
})
def _pre_pull_hook(*args, **kwargs):
    """
    Post pull hook
    """
    return HookResponse(0, '')


@has_kwargs({
    'server_url': 'url of instance that triggered this hook',
    'repo_store_path': 'full path to where repositories are stored',
    'config': 'path to .ini config used',
    'scm': 'type of version control "git", "hg", "svn"',
    'username': 'username of actor who triggered this event',
    'ip': 'ip address of actor who triggered this hook',
    'action': '',
    'repository': 'repository name',
    'hook_type': '',
    'user_agent': 'Client user agent, e.g git or mercurial CLI version',
})
def _pull_hook(*args, **kwargs):
    """
    This hook will be executed after each code pull.
    """
    return HookResponse(0, '')


# =============================================================================
#  PULL REQUEST RELATED HOOKS
# =============================================================================
@has_kwargs({
    'server_url': 'url of instance that triggered this hook',
    'config': 'path to .ini config used',
    'scm': 'type of version control "git", "hg", "svn"',
    'username': 'username of actor who triggered this event',
    'ip': 'ip address of actor who triggered this hook',
    'action': '',
    'repository': 'repository name',
    'pull_request_id': '',
    'url': '',
    'title': '',
    'description': '',
    'status': '',
    'created_on': '',
    'updated_on': '',
    'commit_ids': '',
    'review_status': '',
    'mergeable': '',
    'source': '',
    'target': '',
    'author': '',
    'reviewers': '',
})
def _create_pull_request_hook(*args, **kwargs):
    """
    This hook will be executed after creation of a pull request.
    """
    return HookResponse(0, '')


@has_kwargs({
    'server_url': 'url of instance that triggered this hook',
    'config': 'path to .ini config used',
    'scm': 'type of version control "git", "hg", "svn"',
    'username': 'username of actor who triggered this event',
    'ip': 'ip address of actor who triggered this hook',
    'action': '',
    'repository': 'repository name',
    'pull_request_id': '',
    'url': '',
    'title': '',
    'description': '',
    'status': '',
    'created_on': '',
    'updated_on': '',
    'commit_ids': '',
    'review_status': '',
    'mergeable': '',
    'source': '',
    'target': '',
    'author': '',
    'reviewers': '',
})
def _review_pull_request_hook(*args, **kwargs):
    """
    This hook will be executed after review action was made on a pull request.
    """
    return HookResponse(0, '')


@has_kwargs({
    'server_url': 'url of instance that triggered this hook',
    'config': 'path to .ini config used',
    'scm': 'type of version control "git", "hg", "svn"',
    'username': 'username of actor who triggered this event',
    'ip': 'ip address of actor who triggered this hook',

    'action': '',
    'repository': 'repository name',
    'pull_request_id': '',
    'url': '',
    'title': '',
    'description': '',
    'status': '',
    'comment': '',
    'created_on': '',
    'updated_on': '',
    'commit_ids': '',
    'review_status': '',
    'mergeable': '',
    'source': '',
    'target': '',
    'author': '',
    'reviewers': '',
})
def _comment_pull_request_hook(*args, **kwargs):
    """
    This hook will be executed after comment is made on a pull request
    """
    return HookResponse(0, '')


@has_kwargs({
    'server_url': 'url of instance that triggered this hook',
    'config': 'path to .ini config used',
    'scm': 'type of version control "git", "hg", "svn"',
    'username': 'username of actor who triggered this event',
    'ip': 'ip address of actor who triggered this hook',

    'action': '',
    'repository': 'repository name',
    'pull_request_id': '',
    'url': '',
    'title': '',
    'description': '',
    'status': '',
    'comment': '',
    'created_on': '',
    'updated_on': '',
    'commit_ids': '',
    'review_status': '',
    'mergeable': '',
    'source': '',
    'target': '',
    'author': '',
    'reviewers': '',
})
def _comment_edit_pull_request_hook(*args, **kwargs):
    """
    This hook will be executed after comment is made on a pull request
    """
    return HookResponse(0, '')


@has_kwargs({
    'server_url': 'url of instance that triggered this hook',
    'config': 'path to .ini config used',
    'scm': 'type of version control "git", "hg", "svn"',
    'username': 'username of actor who triggered this event',
    'ip': 'ip address of actor who triggered this hook',
    'action': '',
    'repository': 'repository name',
    'pull_request_id': '',
    'url': '',
    'title': '',
    'description': '',
    'status': '',
    'created_on': '',
    'updated_on': '',
    'commit_ids': '',
    'review_status': '',
    'mergeable': '',
    'source': '',
    'target': '',
    'author': '',
    'reviewers': '',
})
def _update_pull_request_hook(*args, **kwargs):
    """
    This hook will be executed after pull requests has been updated with new commits.
    """
    return HookResponse(0, '')


@has_kwargs({
    'server_url': 'url of instance that triggered this hook',
    'config': 'path to .ini config used',
    'scm': 'type of version control "git", "hg", "svn"',
    'username': 'username of actor who triggered this event',
    'ip': 'ip address of actor who triggered this hook',
    'action': '',
    'repository': 'repository name',
    'pull_request_id': '',
    'url': '',
    'title': '',
    'description': '',
    'status': '',
    'created_on': '',
    'updated_on': '',
    'commit_ids': '',
    'review_status': '',
    'mergeable': '',
    'source': '',
    'target': '',
    'author': '',
    'reviewers': '',
})
def _merge_pull_request_hook(*args, **kwargs):
    """
    This hook will be executed after merge of a pull request.
    """
    return HookResponse(0, '')


@has_kwargs({
    'server_url': 'url of instance that triggered this hook',
    'config': 'path to .ini config used',
    'scm': 'type of version control "git", "hg", "svn"',
    'username': 'username of actor who triggered this event',
    'ip': 'ip address of actor who triggered this hook',
    'action': '',
    'repository': 'repository name',
    'pull_request_id': '',
    'url': '',
    'title': '',
    'description': '',
    'status': '',
    'created_on': '',
    'updated_on': '',
    'commit_ids': '',
    'review_status': '',
    'mergeable': '',
    'source': '',
    'target': '',
    'author': '',
    'reviewers': '',
})
def _close_pull_request_hook(*args, **kwargs):
    """
    This hook will be executed after close of a pull request.
    """
    return HookResponse(0, '')