This repository has been archived on 2024-05-31. You can view files and clone it, but cannot push or open issues or pull requests.
2019-10-11 11:43:35 +00:00
|
|
|
"""LDAP Sync tasks"""
|
2019-10-11 10:53:48 +00:00
|
|
|
from passbook.root.celery import CELERY_APP
|
|
|
|
|
from passbook.sources.ldap.connector import Connector
|
|
|
|
|
from passbook.sources.ldap.models import LDAPSource
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@CELERY_APP.task()
|
|
|
|
|
def sync_groups(source_pk: int):
|
|
|
|
|
"""Sync LDAP Groups on background worker"""
|
|
|
|
|
source = LDAPSource.objects.get(pk=source_pk)
|
|
|
|
|
connector = Connector(source)
|
|
|
|
|
connector.sync_groups()
|
|
|
|
|
|
2019-12-31 11:51:16 +00:00
|
|
|
|
2019-10-11 10:53:48 +00:00
|
|
|
@CELERY_APP.task()
|
|
|
|
|
def sync_users(source_pk: int):
|
|
|
|
|
"""Sync LDAP Users on background worker"""
|
|
|
|
|
source = LDAPSource.objects.get(pk=source_pk)
|
|
|
|
|
connector = Connector(source)
|
|
|
|
|
connector.sync_users()
|
|
|
|
|
|
2019-12-31 11:51:16 +00:00
|
|
|
|
2019-10-11 10:53:48 +00:00
|
|
|
@CELERY_APP.task()
|
|
|
|
|
def sync():
|
|
|
|
|
"""Sync all sources"""
|
|
|
|
|
for source in LDAPSource.objects.filter(enabled=True):
|
|
|
|
|
connector = Connector(source)
|
|
|
|
|
connector.sync_users()
|
|
|
|
|
connector.sync_groups()
|
|
|
|
|
connector.sync_membership()
|
