mirror of
https://gitlab.com/allianceauth/allianceauth.git
synced 2025-12-07 13:21:41 +01:00
a6b340c179
- update string format method - remove redundant default arguments from function calls - remove unused imports - remove unicode identifier from strings, it's default in py3 (see: https://stackoverflow.com/a/4182635/12201331)
50 lines
1.7 KiB
Python
50 lines
1.7 KiB
Python
import logging
|
|
|
|
from django.db import transaction
|
|
from django.db.models.signals import m2m_changed
|
|
from django.db.models.signals import post_delete
|
|
from django.db.models.signals import post_save
|
|
from django.dispatch import receiver
|
|
from allianceauth.authentication.signals import state_changed
|
|
from .tasks import Teamspeak3Tasks
|
|
from .models import AuthTS, StateGroup
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
def trigger_all_ts_update():
|
|
logger.debug("Triggering update_all_groups")
|
|
Teamspeak3Tasks.update_all_groups()
|
|
|
|
|
|
@receiver(m2m_changed, sender=AuthTS.ts_group.through)
|
|
def m2m_changed_authts_group(sender, instance, action, *args, **kwargs):
|
|
logger.debug(f"Received m2m_changed from {instance} ts_group with action {action}")
|
|
if action == "post_add" or action == "post_remove":
|
|
transaction.on_commit(trigger_all_ts_update)
|
|
|
|
|
|
@receiver(post_save, sender=AuthTS)
|
|
def post_save_authts(sender, instance, *args, **kwargs):
|
|
logger.debug("Received post_save from %s" % instance)
|
|
transaction.on_commit(trigger_all_ts_update)
|
|
|
|
|
|
@receiver(post_delete, sender=AuthTS)
|
|
def post_delete_authts(sender, instance, *args, **kwargs):
|
|
logger.debug("Received post_delete signal from %s" % instance)
|
|
transaction.on_commit(trigger_all_ts_update)
|
|
|
|
|
|
# it's literally the same logic so just recycle the receiver
|
|
post_save.connect(post_save_authts, sender=StateGroup)
|
|
post_delete.connect(post_delete_authts, sender=StateGroup)
|
|
|
|
|
|
@receiver(state_changed)
|
|
def check_groups_on_state_change(sender, user, state, **kwargs):
|
|
def trigger_update():
|
|
Teamspeak3Tasks.update_groups.delay(user.pk)
|
|
logger.debug(f"Received state_changed signal from {user}")
|
|
transaction.on_commit(trigger_update)
|