feat: integrated signals and moved user receiver logic there; added test for user cache functionality
This commit is contained in:
parent
61ab0d9bbb
commit
20015dab98
5 changed files with 31 additions and 15 deletions
|
|
@ -1,6 +1,8 @@
|
||||||
from django.apps import AppConfig
|
from django.apps import AppConfig
|
||||||
|
|
||||||
|
|
||||||
class UserAppConfig(AppConfig):
|
class UserAppConfig(AppConfig):
|
||||||
default_auto_field = 'django.db.models.BigAutoField'
|
default_auto_field = 'django.db.models.BigAutoField'
|
||||||
name = 'user_app'
|
name = 'user_app'
|
||||||
|
|
||||||
|
def ready(self):
|
||||||
|
import user_app.signals
|
||||||
|
|
@ -19,6 +19,7 @@ def get_cached_user(user_id):
|
||||||
if user:
|
if user:
|
||||||
user_data = serializers.serialize('json', [user])
|
user_data = serializers.serialize('json', [user])
|
||||||
cache.set(cache_key, user_data, timeout=3600)
|
cache.set(cache_key, user_data, timeout=3600)
|
||||||
|
|
||||||
return json.loads(user_data)[0]['fields']
|
return json.loads(user_data)[0]['fields']
|
||||||
else:
|
else:
|
||||||
return None
|
return None
|
||||||
|
|
|
||||||
|
|
@ -1,9 +1,6 @@
|
||||||
|
import uuid
|
||||||
from django.contrib.auth.models import AbstractBaseUser, BaseUserManager, PermissionsMixin, Group, Permission
|
from django.contrib.auth.models import AbstractBaseUser, BaseUserManager, PermissionsMixin, Group, Permission
|
||||||
from django.db import models
|
from django.db import models
|
||||||
from django.db.models.signals import post_save, post_delete
|
|
||||||
from django.dispatch import receiver
|
|
||||||
from django.core.cache import cache
|
|
||||||
import uuid
|
|
||||||
|
|
||||||
def generate_uuid_without_dashes():
|
def generate_uuid_without_dashes():
|
||||||
return uuid.uuid4().hex
|
return uuid.uuid4().hex
|
||||||
|
|
@ -54,11 +51,3 @@ class User(AbstractBaseUser, PermissionsMixin):
|
||||||
|
|
||||||
def __str__(self):
|
def __str__(self):
|
||||||
return self.email
|
return self.email
|
||||||
|
|
||||||
# Cache invalidation
|
|
||||||
@receiver(post_save, sender=User)
|
|
||||||
@receiver(post_delete, sender=User)
|
|
||||||
def clear_user_cache(sender, instance, **kwargs):
|
|
||||||
"""Invalidate cache for the affected user"""
|
|
||||||
cache_key = f"user_{instance.id}"
|
|
||||||
cache.delete(cache_key)
|
|
||||||
11
user_app/signals.py
Normal file
11
user_app/signals.py
Normal file
|
|
@ -0,0 +1,11 @@
|
||||||
|
from django.core.cache import cache
|
||||||
|
from django.db.models.signals import post_save, post_delete
|
||||||
|
from django.dispatch import receiver
|
||||||
|
from .models import User
|
||||||
|
|
||||||
|
@receiver(post_save, sender=User)
|
||||||
|
@receiver(post_delete, sender=User)
|
||||||
|
def clear_user_cache(sender, instance, **kwargs):
|
||||||
|
"""Invalidate cache for the affected user"""
|
||||||
|
cache_key = f"user_{instance.id}"
|
||||||
|
cache.delete(cache_key)
|
||||||
|
|
@ -1,3 +1,16 @@
|
||||||
from django.test import TestCase
|
from django.test import TestCase
|
||||||
|
from .models import User
|
||||||
|
from .caching import get_cached_user
|
||||||
|
|
||||||
# Create your tests here.
|
class UserCacheTest(TestCase):
|
||||||
|
def test_cache_invalidierung_nach_speichern(self):
|
||||||
|
user = User.objects.create(first_name="Test", last_name="User", email="test@example.com")
|
||||||
|
|
||||||
|
cached_user = get_cached_user(user.id)
|
||||||
|
self.assertIsNotNone(cached_user)
|
||||||
|
|
||||||
|
user.first_name = "Updated"
|
||||||
|
user.save()
|
||||||
|
|
||||||
|
cached_user_after_update = get_cached_user(user.id)
|
||||||
|
self.assertIsNotNone(cached_user_after_update)
|
||||||
Loading…
Reference in a new issue