Show More
@@ -0,0 +1,77 b'' | |||||
|
1 | # Copyright (C) 2016-2016 RhodeCode GmbH | |||
|
2 | # | |||
|
3 | # This program is free software: you can redistribute it and/or modify | |||
|
4 | # it under the terms of the GNU Affero General Public License, version 3 | |||
|
5 | # (only), as published by the Free Software Foundation. | |||
|
6 | # | |||
|
7 | # This program is distributed in the hope that it will be useful, | |||
|
8 | # but WITHOUT ANY WARRANTY; without even the implied warranty of | |||
|
9 | # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | |||
|
10 | # GNU General Public License for more details. | |||
|
11 | # | |||
|
12 | # You should have received a copy of the GNU Affero General Public License | |||
|
13 | # along with this program. If not, see <http://www.gnu.org/licenses/>. | |||
|
14 | # | |||
|
15 | # This program is dual-licensed. If you wish to learn more about the | |||
|
16 | # RhodeCode Enterprise Edition, including its added features, Support services, | |||
|
17 | # and proprietary license terms, please see https://rhodecode.com/licenses/ | |||
|
18 | ||||
|
19 | import logging | |||
|
20 | ||||
|
21 | from rhodecode.translation import lazy_ugettext | |||
|
22 | from rhodecode.events.base import RhodecodeEvent | |||
|
23 | ||||
|
24 | log = logging.getLogger() | |||
|
25 | ||||
|
26 | ||||
|
27 | class RepoGroupEvent(RhodecodeEvent): | |||
|
28 | """ | |||
|
29 | Base class for events acting on a repository group. | |||
|
30 | ||||
|
31 | :param repo: a :class:`RepositoryGroup` instance | |||
|
32 | """ | |||
|
33 | ||||
|
34 | def __init__(self, repo_group): | |||
|
35 | super(RepoGroupEvent, self).__init__() | |||
|
36 | self.repo_group = repo_group | |||
|
37 | ||||
|
38 | # TODO: Implement this | |||
|
39 | # def as_dict(self): | |||
|
40 | # from rhodecode.model.repo import RepoModel | |||
|
41 | # data = super(RepoGroupEvent, self).as_dict() | |||
|
42 | # data.update({ | |||
|
43 | # 'repo': { | |||
|
44 | # 'repo_id': self.repo.repo_id, | |||
|
45 | # 'repo_name': self.repo.repo_name, | |||
|
46 | # 'repo_type': self.repo.repo_type, | |||
|
47 | # 'url': RepoModel().get_url(self.repo) | |||
|
48 | # } | |||
|
49 | # }) | |||
|
50 | # return data | |||
|
51 | ||||
|
52 | ||||
|
53 | class RepoGroupCreateEvent(RepoGroupEvent): | |||
|
54 | """ | |||
|
55 | An instance of this class is emitted as an :term:`event` whenever a | |||
|
56 | repository group is created. | |||
|
57 | """ | |||
|
58 | name = 'repo-group-create' | |||
|
59 | display_name = lazy_ugettext('repository group created') | |||
|
60 | ||||
|
61 | ||||
|
62 | class RepoGroupDeleteEvent(RepoGroupEvent): | |||
|
63 | """ | |||
|
64 | An instance of this class is emitted as an :term:`event` whenever a | |||
|
65 | repository group is deleted. | |||
|
66 | """ | |||
|
67 | name = 'repo-group-delete' | |||
|
68 | display_name = lazy_ugettext('repository group deleted') | |||
|
69 | ||||
|
70 | ||||
|
71 | class RepoGroupUpdateEvent(RepoGroupEvent): | |||
|
72 | """ | |||
|
73 | An instance of this class is emitted as an :term:`event` whenever a | |||
|
74 | repository group is updated. | |||
|
75 | """ | |||
|
76 | name = 'repo-group-update' | |||
|
77 | display_name = lazy_ugettext('repository group update') |
@@ -1,71 +1,78 b'' | |||||
1 | # Copyright (C) 2016-2016 RhodeCode GmbH |
|
1 | # Copyright (C) 2016-2016 RhodeCode GmbH | |
2 | # |
|
2 | # | |
3 | # This program is free software: you can redistribute it and/or modify |
|
3 | # This program is free software: you can redistribute it and/or modify | |
4 | # it under the terms of the GNU Affero General Public License, version 3 |
|
4 | # it under the terms of the GNU Affero General Public License, version 3 | |
5 | # (only), as published by the Free Software Foundation. |
|
5 | # (only), as published by the Free Software Foundation. | |
6 | # |
|
6 | # | |
7 | # This program is distributed in the hope that it will be useful, |
|
7 | # This program is distributed in the hope that it will be useful, | |
8 | # but WITHOUT ANY WARRANTY; without even the implied warranty of |
|
8 | # but WITHOUT ANY WARRANTY; without even the implied warranty of | |
9 | # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|
9 | # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | |
10 | # GNU General Public License for more details. |
|
10 | # GNU General Public License for more details. | |
11 | # |
|
11 | # | |
12 | # You should have received a copy of the GNU Affero General Public License |
|
12 | # You should have received a copy of the GNU Affero General Public License | |
13 | # along with this program. If not, see <http://www.gnu.org/licenses/>. |
|
13 | # along with this program. If not, see <http://www.gnu.org/licenses/>. | |
14 | # |
|
14 | # | |
15 | # This program is dual-licensed. If you wish to learn more about the |
|
15 | # This program is dual-licensed. If you wish to learn more about the | |
16 | # RhodeCode Enterprise Edition, including its added features, Support services, |
|
16 | # RhodeCode Enterprise Edition, including its added features, Support services, | |
17 | # and proprietary license terms, please see https://rhodecode.com/licenses/ |
|
17 | # and proprietary license terms, please see https://rhodecode.com/licenses/ | |
18 |
|
18 | |||
19 | import logging |
|
19 | import logging | |
20 | from pyramid.threadlocal import get_current_registry |
|
20 | from pyramid.threadlocal import get_current_registry | |
21 |
|
21 | |||
22 | log = logging.getLogger(__name__) |
|
22 | log = logging.getLogger(__name__) | |
23 |
|
23 | |||
24 |
|
24 | |||
25 | def trigger(event, registry=None): |
|
25 | def trigger(event, registry=None): | |
26 | """ |
|
26 | """ | |
27 | Helper method to send an event. This wraps the pyramid logic to send an |
|
27 | Helper method to send an event. This wraps the pyramid logic to send an | |
28 | event. |
|
28 | event. | |
29 | """ |
|
29 | """ | |
30 | # For the first step we are using pyramids thread locals here. If the |
|
30 | # For the first step we are using pyramids thread locals here. If the | |
31 | # event mechanism works out as a good solution we should think about |
|
31 | # event mechanism works out as a good solution we should think about | |
32 | # passing the registry as an argument to get rid of it. |
|
32 | # passing the registry as an argument to get rid of it. | |
33 | registry = registry or get_current_registry() |
|
33 | registry = registry or get_current_registry() | |
34 | registry.notify(event) |
|
34 | registry.notify(event) | |
35 | log.debug('event %s triggered', event) |
|
35 | log.debug('event %s triggered', event) | |
36 |
|
36 | |||
37 | # Until we can work around the problem that VCS operations do not have a |
|
37 | # Until we can work around the problem that VCS operations do not have a | |
38 | # pyramid context to work with, we send the events to integrations directly |
|
38 | # pyramid context to work with, we send the events to integrations directly | |
39 |
|
39 | |||
40 | # Later it will be possible to use regular pyramid subscribers ie: |
|
40 | # Later it will be possible to use regular pyramid subscribers ie: | |
41 | # config.add_subscriber(integrations_event_handler, RhodecodeEvent) |
|
41 | # config.add_subscriber(integrations_event_handler, RhodecodeEvent) | |
42 | from rhodecode.integrations import integrations_event_handler |
|
42 | from rhodecode.integrations import integrations_event_handler | |
43 | if isinstance(event, RhodecodeEvent): |
|
43 | if isinstance(event, RhodecodeEvent): | |
44 | integrations_event_handler(event) |
|
44 | integrations_event_handler(event) | |
45 |
|
45 | |||
46 |
|
46 | |||
47 | from rhodecode.events.base import RhodecodeEvent |
|
47 | from rhodecode.events.base import RhodecodeEvent | |
48 |
|
48 | |||
49 | from rhodecode.events.user import ( |
|
49 | from rhodecode.events.user import ( # noqa | |
50 | UserPreCreate, |
|
50 | UserPreCreate, | |
51 | UserPreUpdate, |
|
51 | UserPreUpdate, | |
52 | UserRegistered |
|
52 | UserRegistered | |
53 | ) |
|
53 | ) | |
54 |
|
54 | |||
55 | from rhodecode.events.repo import ( |
|
55 | from rhodecode.events.repo import ( # noqa | |
56 | RepoEvent, |
|
56 | RepoEvent, | |
57 | RepoPreCreateEvent, RepoCreateEvent, |
|
57 | RepoPreCreateEvent, RepoCreateEvent, | |
58 | RepoPreDeleteEvent, RepoDeleteEvent, |
|
58 | RepoPreDeleteEvent, RepoDeleteEvent, | |
59 | RepoPrePushEvent, RepoPushEvent, |
|
59 | RepoPrePushEvent, RepoPushEvent, | |
60 | RepoPrePullEvent, RepoPullEvent, |
|
60 | RepoPrePullEvent, RepoPullEvent, | |
61 | ) |
|
61 | ) | |
62 |
|
62 | |||
63 |
from rhodecode.events. |
|
63 | from rhodecode.events.repo_group import ( # noqa | |
|
64 | RepoGroupEvent, | |||
|
65 | RepoGroupCreateEvent, | |||
|
66 | RepoGroupUpdateEvent, | |||
|
67 | RepoGroupDeleteEvent, | |||
|
68 | ) | |||
|
69 | ||||
|
70 | from rhodecode.events.pullrequest import ( # noqa | |||
64 | PullRequestEvent, |
|
71 | PullRequestEvent, | |
65 | PullRequestCreateEvent, |
|
72 | PullRequestCreateEvent, | |
66 | PullRequestUpdateEvent, |
|
73 | PullRequestUpdateEvent, | |
67 | PullRequestCommentEvent, |
|
74 | PullRequestCommentEvent, | |
68 | PullRequestReviewEvent, |
|
75 | PullRequestReviewEvent, | |
69 | PullRequestMergeEvent, |
|
76 | PullRequestMergeEvent, | |
70 | PullRequestCloseEvent, |
|
77 | PullRequestCloseEvent, | |
71 | ) |
|
78 | ) |
General Comments 0
You need to be logged in to leave comments.
Login now