ldapdb/__init__.py

   1 # -*- coding: utf-8 -*-
   2 #
   3 # django-ldapdb
   4 # Copyright (C) 2009 Bolloré telecom
   5 # See AUTHORS file for a full list of contributors.
   6 #
   7 # This program is free software: you can redistribute it and/or modify
   8 # it under the terms of the GNU General Public License as published by
   9 # the Free Software Foundation, either version 3 of the License, or
  10 # (at your option) any later version.
  11 #
  12 # This program is distributed in the hope that it will be useful,
  13 # but WITHOUT ANY WARRANTY; without even the implied warranty of
  14 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  15 # GNU General Public License for more details.
  16 #
  17 # You should have received a copy of the GNU General Public License
  18 # along with this program.  If not, see <http://www.gnu.org/licenses/>.
  19 #
  20
  21 import ldap
  22
  23 from django.conf import settings
  24
  25 def convert(field, value, func):
  26     if not value or field == 'jpegPhoto':
  27         return value
  28     elif isinstance(value, int):
  29         return str(value)
  30     elif isinstance(value, list):
  31         return [ func(x) for x in value ]
  32     else:
  33         return func(value)
  34
  35 class LdapConnection(object):
  36     def __init__(self, server, bind_dn, bind_password):
  37         self.connection = ldap.initialize(server)
  38         self.connection.simple_bind_s(bind_dn, bind_password)
  39         self.charset = "utf-8"
  40
  41     def add_s(self, dn, modlist):
  42         mods = []
  43         for field, value in modlist:
  44             converted = convert(field, value, lambda x: x.encode(self.charset))
  45             if isinstance(converted, list):
  46                 mods.append((field, converted))
  47             else:
  48                 mods.append((field, [converted]))
  49         return self.connection.add_s(dn.encode(self.charset), mods)
  50
  51     def delete_s(self, dn):
  52         return self.connection.delete_s(dn.encode(self.charset))
  53
  54     def modify_s(self, dn, modlist):
  55         mods = []
  56         for op, field, value in modlist:
  57             mods.append((op, field, convert(field, value, lambda x: x.encode(self.charset))))
  58         return self.connection.modify_s(dn.encode(self.charset), mods)
  59
  60     def rename_s(self, dn, newrdn):
  61         return self.connection.rename_s(dn.encode(self.charset), newrdn.encode(self.charset))
  62
  63     def search_s(self, base, scope, filterstr, attrlist):
  64         results = self.connection.search_s(base, scope, filterstr.encode(self.charset), attrlist)
  65         output = []
  66         for dn, attrs in results:
  67             for field in attrs:
  68                 if field == "member" or field == "memberUid":
  69                     attrs[field] = convert(field, attrs[field], lambda x: x.decode(self.charset))
  70                 else:
  71                     attrs[field] = convert(field, attrs[field][0], lambda x: x.decode(self.charset))
  72             output.append((dn.decode(self.charset), attrs))
  73         return output
  74
  75 # FIXME: is this the right place to initialize the LDAP connection?
  76 connection = LdapConnection(settings.LDAPDB_SERVER_URI,
  77     settings.LDAPDB_BIND_DN,
  78     settings.LDAPDB_BIND_PASSWORD)
  79