__init__.py
74 lines
| 2.8 KiB
| text/x-python
|
PythonLexer
r5063 | ||||
r411 | ||||
r5088 | # Copyright (C) 2012-2023 RhodeCode GmbH | |||
r411 | # | |||
# 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/ | ||||
r3007 | import sys | |||
r411 | import logging | |||
r518 | ||||
r411 | from rhodecode.integrations.registry import IntegrationTypeRegistry | |||
r2138 | from rhodecode.integrations.types import webhook, slack, hipchat, email, base | |||
r3007 | from rhodecode.lib.exc_tracking import store_exception | |||
r411 | log = logging.getLogger(__name__) | |||
# TODO: dan: This is currently global until we figure out what to do about | ||||
# VCS's not having a pyramid context - move it to pyramid app configuration | ||||
# includeme level later to allow per instance integration setup | ||||
integration_type_registry = IntegrationTypeRegistry() | ||||
r444 | ||||
integration_type_registry.register_integration_type( | ||||
webhook.WebhookIntegrationType) | ||||
integration_type_registry.register_integration_type( | ||||
slack.SlackIntegrationType) | ||||
r550 | integration_type_registry.register_integration_type( | |||
hipchat.HipchatIntegrationType) | ||||
r640 | integration_type_registry.register_integration_type( | |||
email.EmailIntegrationType) | ||||
r444 | ||||
r411 | ||||
r2138 | # dummy EE integration to show users what we have in EE edition | |||
integration_type_registry.register_integration_type( | ||||
base.EEIntegration('Jira Issues integration', 'jira')) | ||||
integration_type_registry.register_integration_type( | ||||
base.EEIntegration('Redmine Tracker integration', 'redmine')) | ||||
r2578 | integration_type_registry.register_integration_type( | |||
base.EEIntegration('Jenkins CI integration', 'jenkins')) | ||||
r2138 | ||||
r411 | def integrations_event_handler(event): | |||
""" | ||||
Takes an event and passes it to all enabled integrations | ||||
""" | ||||
from rhodecode.model.integration import IntegrationModel | ||||
integration_model = IntegrationModel() | ||||
integrations = integration_model.get_for_event(event) | ||||
for integration in integrations: | ||||
try: | ||||
integration_model.send_event(integration, event) | ||||
except Exception: | ||||
r3007 | exc_info = sys.exc_info() | |||
store_exception(id(exc_info), exc_info) | ||||
r411 | log.exception( | |||
r3061 | 'failure occurred when sending event %s to integration %s', | |||
event, integration) | ||||
r411 | ||||
def includeme(config): | ||||
config.include('rhodecode.integrations.routes') | ||||