# -*- coding: utf-8 -*- from ldap3 import Connection from django.shortcuts import render from django.http import Http404 from django.db.models import Q from django.conf import settings from django.contrib.auth.models import User from kfet.decorators import teamkfet_required from kfet.models import Account class Clipper(object): def __init__(self, clipper, fullname): self.clipper = clipper self.fullname = fullname @teamkfet_required def account_create(request): if "q" not in request.GET: raise Http404 q = request.GET.get("q") if (len(q) == 0): return render(request, "kfet/account_create_autocomplete.html") data = {'q': q} queries = {} search_words = q.split() # Fetching data from User, CofProfile and Account tables queries['kfet'] = Account.objects queries['users_cof'] = User.objects.filter(profile__cof__is_cof=True) queries['users_notcof'] = User.objects.filter(profile__cof__is_cof=False) for word in search_words: queries['kfet'] = queries['kfet'].filter( Q(profile__user__username__icontains=word) | Q(profile__user__first_name__icontains=word) | Q(profile__user__last_name__icontains=word) ) queries['users_cof'] = queries['users_cof'].filter( Q(username__icontains=word) | Q(first_name__icontains=word) | Q(last_name__icontains=word) ) queries['users_notcof'] = queries['users_notcof'].filter( Q(username__icontains=word) | Q(first_name__icontains=word) | Q(last_name__icontains=word) ) # Clearing redundancies queries['kfet'] = queries['kfet'].distinct() usernames = set( queries['kfet'].values_list('profile__user__username', flat=True)) queries['kfet'] = [ (account, account.profile.user) for account in queries['kfet'] ] queries['users_cof'] = \ queries['users_cof'].exclude(username__in=usernames).distinct() queries['users_notcof'] = \ queries['users_notcof'].exclude(username__in=usernames).distinct() usernames |= set( queries['users_cof'].values_list('username', flat=True)) usernames |= set( queries['users_notcof'].values_list('username', flat=True)) # Fetching data from the SPI if hasattr(settings, 'LDAP_SERVER_URL'): # Fetching ldap_query = '(|{:s})'.format(''.join( ['(cn=*{bit:s}*)(uid=*{bit:s}*)'.format(**{"bit": bit}) for bit in search_words] )) with Connection(settings.LDAP_SERVER_URL) as conn: conn.search( 'dc=spi,dc=ens,dc=fr', ldap_query, attributes=['uid', 'cn'] ) queries['clippers'] = conn.entries # Clearing redundancies queries['clippers'] = [ Clipper(clipper.uid, clipper.cn) for clipper in queries['clippers'] if str(clipper.uid) not in usernames ] # Resulting data data.update(queries) data['options'] = sum([len(query) for query in queries]) return render(request, "kfet/account_create_autocomplete.html", data)