Mathis/allianceauth
1
0
Fork 0
mirror of https://gitlab.com/allianceauth/allianceauth.git synced 2025-07-14 15:00:16 +02:00
Code Issues Packages Projects Releases Wiki Activity

Added global tasks to sync all user groups (#453)

Browse Source 
* Automatic rejection of old API IDs

* Added API ID fudge factor

* Added toggle-able options for api key rejection

* Clarified ValidationError message

* Allows automatic update of Discord avatar to EVE avatar

* Added global tasks to sync all user groups

* correct indentation

* Fixed typo

* Changed global tasks to async
This commit is contained in:
moriartyj 2016-06-07 12:57:31 -07:00 committed by Adarnof
parent 1af4b7e43c
commit 8abccfd1f2
1 changed files with 47 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

47
celerytask/tasks.py Executable file → Normal file
View File

@ -73,6 +73,12 @@ def update_jabber_groups(pk):
raise self.retry(countdown = 60 * 10)
logger.debug("Updated user %s jabber groups." % user)
@task
def update_all_jabber_groups():
logger.debug("Updating ALL jabber groups")
for user in AuthServicesInfo.objects.exclude(jabber_username__exact=''):
update_jabber_groups.delay(user.user_id)
@task
def update_mumble_groups(pk):
user = User.objects.get(pk=pk)
@ -91,6 +97,12 @@ def update_mumble_groups(pk):
raise self.retry(countdown = 60 * 10)
logger.debug("Updated user %s mumble groups." % user)
@task
def update_all_mumble_groups():
logger.debug("Updating ALL mumble groups")
for user in AuthServicesInfo.objects.exclude(mumble_username__exact=''):
update_mumble_groups.delay(user.user_id)
@task
def update_forum_groups(pk):
user = User.objects.get(pk=pk)
@ -109,6 +121,12 @@ def update_forum_groups(pk):
raise self.retry(countdown = 60 * 10)
logger.debug("Updated user %s forum groups." % user)
@task
def update_all_forum_groups():
logger.debug("Updating ALL forum groups")
for user in AuthServicesInfo.objects.exclude(forum_username__exact=''):
update_forum_groups.delay(user.user_id)
@task
def update_smf_groups(pk):
user = User.objects.get(pk=pk)
@ -127,6 +145,11 @@ def update_smf_groups(pk):
raise self.retry(countdown = 60 * 10)
logger.debug("Updated user %s smf groups." % user)
@task
def update_all_smf_groups():
logger.debug("Updating ALL smf groups")
for user in AuthServicesInfo.objects.exclude(smf_username__exact=''):
update_smf_groups.delay(user.user_id)
@task
def update_ipboard_groups(pk):
@ -146,6 +169,12 @@ def update_ipboard_groups(pk):
raise self.retry(countdown = 60 * 10)
logger.debug("Updated user %s ipboard groups." % user)
@task
def update_all_ipboard_groups():
logger.debug("Updating ALL ipboard groups")
for user in AuthServicesInfo.objects.exclude(ipboard_username__exact=''):
update_ipboard_groups.delay(user.user_id)
@task
def update_teamspeak3_groups(pk):
user = User.objects.get(pk=pk)
@ -163,6 +192,12 @@ def update_teamspeak3_groups(pk):
Teamspeak3Manager.update_groups(authserviceinfo.teamspeak3_uid, groups)
logger.debug("Updated user %s teamspeak3 groups." % user)
@task
def update_all_teamspeak3_groups():
logger.debug("Updating ALL teamspeak3 groups")
for user in AuthServicesInfo.objects.exclude(teamspeak3_uid__exact=''):
update_teamspeak3_groups.delay(user.user_id)
@task
def update_discord_groups(pk):
user = User.objects.get(pk=pk)
@ -182,6 +217,12 @@ def update_discord_groups(pk):
raise self.retry(countdown = 60 * 10)
logger.debug("Updated user %s discord groups." % user)
@task
def update_all_discord_groups():
logger.debug("Updating ALL discord groups")
for user in AuthServicesInfo.objects.exclude(discord_uid__exact=''):
update_discord_groups.delay(user.user_id)
@task
def update_discourse_groups(pk):
user = User.objects.get(pk=pk)
@ -201,6 +242,12 @@ def update_discourse_groups(pk):
raise self.retry(countdown = 60 * 10)
logger.debug("Updated user %s discord groups." % user)
@task
def update_all_discourse_groups():
logger.debug("Updating ALL discourse groups")
for user in AuthServicesInfo.objects.exclude(discourse_username__exact=''):
update_discourse_groups.delay(user.user_id)
def assign_corp_group(auth):
corp_group = None