Show More
__init__.py
78 lines
| 2.5 KiB
| text/x-python
|
PythonLexer
r2487 | # Copyright (C) 2016-2018 RhodeCode GmbH | |||
r375 | # | |||
# 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/ | ||||
r428 | import logging | |||
r375 | from pyramid.threadlocal import get_current_registry | |||
r2921 | from rhodecode.events.base import RhodeCodeIntegrationEvent | |||
r1789 | ||||
r375 | ||||
Martin Bornhold
|
r504 | log = logging.getLogger(__name__) | ||
r428 | ||||
r375 | ||||
r411 | def trigger(event, registry=None): | |||
r375 | """ | |||
Helper method to send an event. This wraps the pyramid logic to send an | ||||
event. | ||||
""" | ||||
# For the first step we are using pyramids thread locals here. If the | ||||
# event mechanism works out as a good solution we should think about | ||||
# passing the registry as an argument to get rid of it. | ||||
r2930 | event_name = event.__class__ | |||
log.debug('event %s sent for execution', event_name) | ||||
r411 | registry = registry or get_current_registry() | |||
r375 | registry.notify(event) | |||
r2930 | log.debug('event %s triggered using registry %s', event_name, registry) | |||
r375 | ||||
r2921 | # Send the events to integrations directly | |||
r411 | from rhodecode.integrations import integrations_event_handler | |||
r2921 | if isinstance(event, RhodeCodeIntegrationEvent): | |||
r411 | integrations_event_handler(event) | |||
r2849 | ||||
Martin Bornhold
|
r556 | from rhodecode.events.user import ( # noqa | ||
r376 | UserPreCreate, | |||
r1094 | UserPostCreate, | |||
r376 | UserPreUpdate, | |||
r2849 | UserRegistered, | |||
UserPermissionsChange, | ||||
r375 | ) | |||
Martin Bornhold
|
r556 | from rhodecode.events.repo import ( # noqa | ||
r379 | RepoEvent, | |||
r411 | RepoPreCreateEvent, RepoCreateEvent, | |||
RepoPreDeleteEvent, RepoDeleteEvent, | ||||
r375 | RepoPrePushEvent, RepoPushEvent, | |||
RepoPrePullEvent, RepoPullEvent, | ||||
r376 | ) | |||
r378 | ||||
Martin Bornhold
|
r556 | from rhodecode.events.repo_group import ( # noqa | ||
RepoGroupEvent, | ||||
RepoGroupCreateEvent, | ||||
RepoGroupUpdateEvent, | ||||
RepoGroupDeleteEvent, | ||||
) | ||||
from rhodecode.events.pullrequest import ( # noqa | ||||
r379 | PullRequestEvent, | |||
r378 | PullRequestCreateEvent, | |||
PullRequestUpdateEvent, | ||||
r443 | PullRequestCommentEvent, | |||
r378 | PullRequestReviewEvent, | |||
PullRequestMergeEvent, | ||||
PullRequestCloseEvent, | ||||
r411 | ) | |||