mirror of
https://github.com/kakwa/ldapcherry
synced 2024-09-24 15:31:41 +02:00
110 lines
3.3 KiB
Python
110 lines
3.3 KiB
Python
# -*- coding: utf-8 -*-
|
|
# vim:set expandtab tabstop=4 shiftwidth=4:
|
|
#
|
|
# The MIT License (MIT)
|
|
# LdapCherry
|
|
# Copyright (c) 2014 Carpentier Pierre-Francois
|
|
|
|
import cherrypy
|
|
import ldap
|
|
import logging
|
|
import ldapcherry.backend
|
|
|
|
class Backend(ldapcherry.backend.Backend):
|
|
|
|
def __init__(self, config, logger, name):
|
|
self.config = config
|
|
self._logger = logger
|
|
self.backend_name = name
|
|
self.binddn = self.get_param(binddn)
|
|
self.ca = self.get_param(ca)
|
|
self.checkcert = self.get_param(checkcert)
|
|
self.starttls = self.get_param(starttls)
|
|
self.uri = self.get_param(uri)
|
|
self.user_filter_tmpl = self.get_param(user_filter_tmpl)
|
|
|
|
def auth(self, username, password):
|
|
|
|
binddn = get_user(username)
|
|
if binddn:
|
|
ldap_client = self._connect()
|
|
try:
|
|
ldap_client.simple_bind_s(binddn, password)
|
|
except ldap.INVALID_CREDENTIALS:
|
|
ldap_client.unbind_s()
|
|
return False
|
|
ldap_client.unbind_s()
|
|
return True
|
|
else:
|
|
return False
|
|
|
|
def add_to_group(self):
|
|
pass
|
|
|
|
def set_attrs(self, attrs):
|
|
pass
|
|
|
|
def rm_from_group(self):
|
|
pass
|
|
|
|
def add_user(self, username):
|
|
pass
|
|
|
|
def del_user(self, username):
|
|
pass
|
|
|
|
def get_user(self, username):
|
|
ldap_client = self._connect()
|
|
try:
|
|
ldap_client.simple_bind_s(self.binddn, self.bindpassword)
|
|
except ldap.INVALID_CREDENTIALS:
|
|
self._logger(
|
|
logging.ERROR,
|
|
"Configuration error, wrong credentials, unable to connect to ldap with '" + self.binddn + "'",
|
|
)
|
|
raise cherrypy.HTTPError("500", "Configuration Error, contact administrator")
|
|
except ldap.SERVER_DOWN:
|
|
self._logger(
|
|
logging.ERROR,
|
|
"Unable to contact ldap server '" + self.uri + "', check 'auth.ldap.uri' and ssl/tls configuration",
|
|
)
|
|
return False
|
|
|
|
user_filter = self.user_filter_tmpl % {
|
|
'login': username
|
|
}
|
|
|
|
r = ldap_client.search_s(self.userdn,
|
|
ldap.SCOPE_SUBTREE,
|
|
user_filter
|
|
)
|
|
if len(r) == 0:
|
|
ldap_client.unbind_s()
|
|
return False
|
|
|
|
dn_entry = r[0][0]
|
|
return dn_entry
|
|
|
|
def _connect(self):
|
|
ldap_client = ldap.initialize(self.uri)
|
|
ldap_client.set_option(ldap.OPT_REFERRALS, 0)
|
|
if self.starttls == 'on':
|
|
ldap.set_option(ldap.OPT_X_TLS_DEMAND, True)
|
|
if self.ca:
|
|
ldap.set_option(ldap.OPT_X_TLS_CACERTFILE, self.ca)
|
|
if self.checkcert == 'off':
|
|
ldap.set_option(ldap.OPT_X_TLS_REQUIRE_CERT, ldap.OPT_X_TLS_ALLOW)
|
|
else:
|
|
ldap.set_option(ldap.OPT_X_TLS_REQUIRE_CERT,ldap.OPT_X_TLS_DEMAND)
|
|
|
|
if self.starttls == 'on':
|
|
try:
|
|
ldap_client.start_tls_s()
|
|
except ldap.OPERATIONS_ERROR:
|
|
self._logger(
|
|
logging.ERROR,
|
|
"cannot use starttls with ldaps:// uri (uri: " + self.uri + ")",
|
|
)
|
|
raise cherrypy.HTTPError("500", "Configuration Error, contact administrator")
|
|
return ldap_client
|