diff --git a/celerytask/tasks.py b/celerytask/tasks.py old mode 100755 new mode 100644 index 62d6734f..b4b19324 --- a/celerytask/tasks.py +++ b/celerytask/tasks.py @@ -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