From 2428a39f192564e3dd5397510848b3d1b6c1b93d Mon Sep 17 00:00:00 2001 From: Jan Dittberner Date: Thu, 25 Dec 2014 18:05:42 +0100 Subject: [PATCH] add stub tasks for file system operations --- gnuviechadmin/gnuviechadmin/settings/base.py | 1 + gnuviechadmin/osusers/tasks.py | 30 ++++++++++++++++++++ 2 files changed, 31 insertions(+) diff --git a/gnuviechadmin/gnuviechadmin/settings/base.py b/gnuviechadmin/gnuviechadmin/settings/base.py index c871d84..e4dc147 100644 --- a/gnuviechadmin/gnuviechadmin/settings/base.py +++ b/gnuviechadmin/gnuviechadmin/settings/base.py @@ -280,6 +280,7 @@ CELERY_RESULT_PERSISTENT = True CELERY_TASK_RESULT_EXPIRES = None CELERY_ROUTES = ( 'osusers.tasks.LdapRouter', + 'osusers.tasks.FileRouter', ) CELERY_ACCEPT_CONTENT = ['yaml'] CELERY_TASK_SERIALIZER = 'yaml' diff --git a/gnuviechadmin/osusers/tasks.py b/gnuviechadmin/osusers/tasks.py index 049eb65..7edd7c7 100644 --- a/gnuviechadmin/osusers/tasks.py +++ b/gnuviechadmin/osusers/tasks.py @@ -13,6 +13,16 @@ class LdapRouter(object): return None +class FileRouter(object): + + def route_for_task(self, task, args=None, kwargs=None): + if 'file' in task: + return {'exchange': 'file', + 'exchange_type': 'direct', + 'queue': 'file'} + return None + + @shared_task def create_ldap_group(groupname, gid, descr): pass @@ -41,3 +51,23 @@ def delete_ldap_user(username): @shared_task def delete_ldap_group_if_empty(groupname): pass + + +@shared_task +def setup_file_sftp_userdir(username): + pass + + +@shared_task +def delete_file_sftp_userdir(username): + pass + + +@shared_task +def setup_file_mail_userdir(username): + pass + + +@shared_task +def delete_file_mail_userdir(username): + pass