Show More
base.py
112 lines
| 3.2 KiB
| text/x-python
|
PythonLexer
r2487 | # Copyright (C) 2016-2018 RhodeCode GmbH | |||
r379 | # | |||
# 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/ | ||||
r1424 | import logging | |||
r1959 | import datetime | |||
r379 | ||||
r1959 | from zope.cachedescriptors.property import Lazy as LazyProperty | |||
r379 | from pyramid.threadlocal import get_current_request | |||
r1959 | ||||
r379 | from rhodecode.lib.utils2 import AttributeDict | |||
r391 | # this is a user object to be used for events caused by the system (eg. shell) | |||
r379 | SYSTEM_USER = AttributeDict(dict( | |||
r1709 | username='__SYSTEM__', | |||
user_id='__SYSTEM_ID__' | ||||
r379 | )) | |||
r1424 | log = logging.getLogger(__name__) | |||
r379 | ||||
class RhodecodeEvent(object): | ||||
""" | ||||
r1789 | Base event class for all RhodeCode events | |||
r379 | """ | |||
r649 | name = "RhodeCodeEvent" | |||
r1959 | no_url_set = '<no server_url available>' | |||
r649 | ||||
r1789 | def __init__(self, request=None): | |||
r1959 | self._request = request | |||
self.utc_timestamp = datetime.datetime.utcnow() | ||||
def get_request(self): | ||||
if self._request: | ||||
return self._request | ||||
return get_current_request() | ||||
@LazyProperty | ||||
def request(self): | ||||
return self.get_request() | ||||
r379 | ||||
@property | ||||
r1420 | def auth_user(self): | |||
if not self.request: | ||||
return | ||||
user = getattr(self.request, 'user', None) | ||||
if user: | ||||
return user | ||||
api_user = getattr(self.request, 'rpc_user', None) | ||||
if api_user: | ||||
return api_user | ||||
@property | ||||
r389 | def actor(self): | |||
r1420 | auth_user = self.auth_user | |||
if auth_user: | ||||
r1454 | instance = auth_user.get_instance() | |||
if not instance: | ||||
return AttributeDict(dict( | ||||
r1709 | username=auth_user.username, | |||
user_id=auth_user.user_id, | ||||
r1454 | )) | |||
r1466 | return instance | |||
r1454 | ||||
r379 | return SYSTEM_USER | |||
@property | ||||
r389 | def actor_ip(self): | |||
r1420 | auth_user = self.auth_user | |||
if auth_user: | ||||
return auth_user.ip_addr | ||||
r379 | return '<no ip available>' | |||
r649 | @property | |||
def server_url(self): | ||||
if self.request: | ||||
r1424 | try: | |||
r1789 | return self.request.route_url('home') | |||
r1424 | except Exception: | |||
log.exception('Failed to fetch URL for server') | ||||
r1959 | return self.no_url_set | |||
r1424 | ||||
r1959 | return self.no_url_set | |||
r649 | ||||
r379 | def as_dict(self): | |||
r411 | data = { | |||
'name': self.name, | ||||
'utc_timestamp': self.utc_timestamp, | ||||
'actor_ip': self.actor_ip, | ||||
'actor': { | ||||
r1709 | 'username': self.actor.username, | |||
'user_id': self.actor.user_id | ||||
r649 | }, | |||
'server_url': self.server_url | ||||
r411 | } | |||
r649 | return data | |||