mirror of
https://github.com/jazzband/django-auditlog.git
synced 2026-04-17 05:21:06 +00:00
655e02e806
the Django warning: site-packages/auditlog/middleware.py:9: RemovedInDjango19Warning: The utilities in django.db.models.loading are deprecated in favor of the new application loading system. from django.db.models.loading import get_model
74 lines
2.8 KiB
Python
74 lines
2.8 KiB
Python
from __future__ import unicode_literals
|
|
|
|
import threading
|
|
import time
|
|
|
|
from django.conf import settings
|
|
from django.db.models.signals import pre_save
|
|
from django.utils.functional import curry
|
|
from django.apps import apps
|
|
from auditlog.models import LogEntry
|
|
|
|
|
|
threadlocal = threading.local()
|
|
|
|
|
|
class AuditlogMiddleware(object):
|
|
"""
|
|
Middleware to couple the request's user to log items. This is accomplished by currying the signal receiver with the
|
|
user from the request (or None if the user is not authenticated).
|
|
"""
|
|
|
|
def process_request(self, request):
|
|
"""
|
|
Gets the current user from the request and prepares and connects a signal receiver with the user already
|
|
attached to it.
|
|
"""
|
|
# Initialize thread local storage
|
|
threadlocal.auditlog = {
|
|
'signal_duid': (self.__class__, time.time()),
|
|
'remote_addr': request.META.get('REMOTE_ADDR'),
|
|
}
|
|
|
|
# In case of proxy, set 'original' address
|
|
if request.META.get('HTTP_X_FORWARDED_FOR'):
|
|
threadlocal.auditlog['remote_addr'] = request.META.get('HTTP_X_FORWARDED_FOR').split(',')[0]
|
|
|
|
# Connect signal for automatic logging
|
|
if hasattr(request, 'user') and hasattr(request.user, 'is_authenticated') and request.user.is_authenticated():
|
|
set_actor = curry(self.set_actor, request.user)
|
|
pre_save.connect(set_actor, sender=LogEntry, dispatch_uid=threadlocal.auditlog['signal_duid'], weak=False)
|
|
|
|
def process_response(self, request, response):
|
|
"""
|
|
Disconnects the signal receiver to prevent it from staying active.
|
|
"""
|
|
if hasattr(threadlocal, 'auditlog'):
|
|
pre_save.disconnect(sender=LogEntry, dispatch_uid=threadlocal.auditlog['signal_duid'])
|
|
|
|
return response
|
|
|
|
def process_exception(self, request, exception):
|
|
"""
|
|
Disconnects the signal receiver to prevent it from staying active in case of an exception.
|
|
"""
|
|
if hasattr(threadlocal, 'auditlog'):
|
|
pre_save.disconnect(sender=LogEntry, dispatch_uid=threadlocal.auditlog['signal_duid'])
|
|
|
|
return None
|
|
|
|
@staticmethod
|
|
def set_actor(user, sender, instance, **kwargs):
|
|
"""
|
|
Signal receiver with an extra, required 'user' kwarg. This method becomes a real (valid) signal receiver when
|
|
it is curried with the actor.
|
|
"""
|
|
try:
|
|
app_label, model_name = settings.AUTH_USER_MODEL.split('.')
|
|
auth_user_model = apps.get_model(app_label, model_name)
|
|
except ValueError:
|
|
auth_user_model = apps.get_model('auth', 'user')
|
|
if sender == LogEntry and isinstance(user, auth_user_model) and instance.actor is None:
|
|
instance.actor = user
|
|
if hasattr(threadlocal, 'auditlog'):
|
|
instance.remote_addr = threadlocal.auditlog['remote_addr']
|