mirror of
https://github.com/moparisthebest/curl
synced 2024-12-21 23:58:49 -05:00
LDAP: properly implemented as a curl_handler
makes the LDAP code much cleaner, nicer and in general being a better libcurl citizen. If a new enough OpenLDAP version is detect, the new and shiny lib/openldap.c code is then used instead of the old cruft Code by Howard, minor cleanups by Daniel.
This commit is contained in:
parent
606b933a4f
commit
2e056353b0
6
CHANGES
6
CHANGES
@ -6,6 +6,12 @@
|
|||||||
|
|
||||||
Changelog
|
Changelog
|
||||||
|
|
||||||
|
Daniel Stenberg (25 May 2010)
|
||||||
|
- Howard Chu brought a patch that makes the LDAP code much cleaner, nicer and
|
||||||
|
in general being a better libcurl citizen. If a new enough OpenLDAP version
|
||||||
|
is detect, the new and shiny lib/openldap.c code is then used instead of the
|
||||||
|
old cruft.
|
||||||
|
|
||||||
Daniel Stenberg (21 May 2010)
|
Daniel Stenberg (21 May 2010)
|
||||||
- Eric Mertens posted bug #3003705: when we made TFTP use the correct timeout
|
- Eric Mertens posted bug #3003705: when we made TFTP use the correct timeout
|
||||||
option when sent to the server (fixed May 18th 2010) it became obvious that
|
option when sent to the server (fixed May 18th 2010) it became obvious that
|
||||||
|
@ -15,6 +15,7 @@ This release includes the following changes:
|
|||||||
o added support for PolarSSL
|
o added support for PolarSSL
|
||||||
o added support for FTP wildcard matching and downloads
|
o added support for FTP wildcard matching and downloads
|
||||||
o added support for RTMP
|
o added support for RTMP
|
||||||
|
o introducing new LDAP code for new enough OpenLDAP
|
||||||
|
|
||||||
This release includes the following bugfixes:
|
This release includes the following bugfixes:
|
||||||
|
|
||||||
|
@ -850,7 +850,7 @@ if test x$CURL_DISABLE_LDAP != x1 ; then
|
|||||||
fi
|
fi
|
||||||
|
|
||||||
if test x$CURL_DISABLE_LDAP != x1 ; then
|
if test x$CURL_DISABLE_LDAP != x1 ; then
|
||||||
AC_CHECK_FUNCS([ldap_url_parse])
|
AC_CHECK_FUNCS([ldap_url_parse ldap_init_fd])
|
||||||
|
|
||||||
if test "$LDAPLIBNAME" = "wldap32"; then
|
if test "$LDAPLIBNAME" = "wldap32"; then
|
||||||
curl_ldap_msg="enabled (winldap)"
|
curl_ldap_msg="enabled (winldap)"
|
||||||
@ -862,6 +862,9 @@ if test x$CURL_DISABLE_LDAP != x1 ; then
|
|||||||
esac
|
esac
|
||||||
else
|
else
|
||||||
curl_ldap_msg="enabled (OpenLDAP)"
|
curl_ldap_msg="enabled (OpenLDAP)"
|
||||||
|
if test "x$ac_cv_func_ldap_init_fd" = x""yes; then
|
||||||
|
AC_DEFINE(USE_OPENLDAP, 1, [Use OpenLDAP-specific code])
|
||||||
|
fi
|
||||||
fi
|
fi
|
||||||
fi
|
fi
|
||||||
|
|
||||||
|
@ -13,7 +13,7 @@ CSOURCES = file.c timeval.c base64.c hostip.c progress.c formdata.c \
|
|||||||
strdup.c socks.c ssh.c nss.c qssl.c rawstr.c curl_addrinfo.c \
|
strdup.c socks.c ssh.c nss.c qssl.c rawstr.c curl_addrinfo.c \
|
||||||
socks_gssapi.c socks_sspi.c curl_sspi.c slist.c nonblock.c \
|
socks_gssapi.c socks_sspi.c curl_sspi.c slist.c nonblock.c \
|
||||||
curl_memrchr.c imap.c pop3.c smtp.c pingpong.c rtsp.c curl_threads.c \
|
curl_memrchr.c imap.c pop3.c smtp.c pingpong.c rtsp.c curl_threads.c \
|
||||||
warnless.c hmac.c polarssl.c curl_rtmp.c
|
warnless.c hmac.c polarssl.c curl_rtmp.c openldap.c
|
||||||
|
|
||||||
HHEADERS = arpa_telnet.h netrc.h file.h timeval.h qssl.h hostip.h \
|
HHEADERS = arpa_telnet.h netrc.h file.h timeval.h qssl.h hostip.h \
|
||||||
progress.h formdata.h cookie.h http.h sendf.h ftp.h url.h dict.h \
|
progress.h formdata.h cookie.h http.h sendf.h ftp.h url.h dict.h \
|
||||||
|
@ -22,10 +22,10 @@
|
|||||||
* KIND, either express or implied.
|
* KIND, either express or implied.
|
||||||
*
|
*
|
||||||
***************************************************************************/
|
***************************************************************************/
|
||||||
#ifndef CURL_DISABLE_LDAP
|
#if !defined(CURL_DISABLE_LDAP) || defined(USE_OPENLDAP)
|
||||||
extern const struct Curl_handler Curl_handler_ldap;
|
extern const struct Curl_handler Curl_handler_ldap;
|
||||||
|
|
||||||
#ifdef HAVE_LDAP_SSL
|
#if defined(HAVE_LDAP_SSL) || defined(USE_OPENLDAP)
|
||||||
extern const struct Curl_handler Curl_handler_ldaps;
|
extern const struct Curl_handler Curl_handler_ldaps;
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
|
@ -22,7 +22,7 @@
|
|||||||
|
|
||||||
#include "setup.h"
|
#include "setup.h"
|
||||||
|
|
||||||
#ifndef CURL_DISABLE_LDAP
|
#if !defined(CURL_DISABLE_LDAP) && !defined(USE_OPENLDAP)
|
||||||
/* -- WIN32 approved -- */
|
/* -- WIN32 approved -- */
|
||||||
#include <stdio.h>
|
#include <stdio.h>
|
||||||
#include <string.h>
|
#include <string.h>
|
||||||
|
576
lib/openldap.c
Normal file
576
lib/openldap.c
Normal file
@ -0,0 +1,576 @@
|
|||||||
|
/***************************************************************************
|
||||||
|
* _ _ ____ _
|
||||||
|
* Project ___| | | | _ \| |
|
||||||
|
* / __| | | | |_) | |
|
||||||
|
* | (__| |_| | _ <| |___
|
||||||
|
* \___|\___/|_| \_\_____|
|
||||||
|
*
|
||||||
|
* Copyright (C) 2010, Howard Chu, <hyc@openldap.org>
|
||||||
|
*
|
||||||
|
* This software is licensed as described in the file COPYING, which
|
||||||
|
* you should have received as part of this distribution. The terms
|
||||||
|
* are also available at http://curl.haxx.se/docs/copyright.html.
|
||||||
|
*
|
||||||
|
* You may opt to use, copy, modify, merge, publish, distribute and/or sell
|
||||||
|
* copies of the Software, and permit persons to whom the Software is
|
||||||
|
* furnished to do so, under the terms of the COPYING file.
|
||||||
|
*
|
||||||
|
* This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
|
||||||
|
* KIND, either express or implied.
|
||||||
|
*
|
||||||
|
***************************************************************************/
|
||||||
|
|
||||||
|
#include "setup.h"
|
||||||
|
|
||||||
|
#ifdef USE_OPENLDAP
|
||||||
|
|
||||||
|
#include "urldata.h"
|
||||||
|
#include <curl/curl.h>
|
||||||
|
#include "sendf.h"
|
||||||
|
#include <ldap.h>
|
||||||
|
#include "sslgen.h"
|
||||||
|
#include "transfer.h"
|
||||||
|
#include "curl_base64.h"
|
||||||
|
|
||||||
|
#define _MPRINTF_REPLACE /* use our functions only */
|
||||||
|
#include <curl/mprintf.h>
|
||||||
|
|
||||||
|
#include "memdebug.h"
|
||||||
|
|
||||||
|
static CURLcode ldap_setup(struct connectdata *conn);
|
||||||
|
static CURLcode ldap_do(struct connectdata *conn, bool *done);
|
||||||
|
static CURLcode ldap_done(struct connectdata *conn, CURLcode, bool);
|
||||||
|
static CURLcode ldap_connect(struct connectdata *conn, bool *done);
|
||||||
|
static CURLcode ldap_connecting(struct connectdata *conn, bool *done);
|
||||||
|
static CURLcode ldap_disconnect(struct connectdata *conn);
|
||||||
|
|
||||||
|
static Curl_recv ldap_recv;
|
||||||
|
|
||||||
|
/*
|
||||||
|
* LDAP protocol handler.
|
||||||
|
*/
|
||||||
|
|
||||||
|
const struct Curl_handler Curl_handler_ldap = {
|
||||||
|
"LDAP", /* scheme */
|
||||||
|
ldap_setup, /* setup_connection */
|
||||||
|
ldap_do, /* do_it */
|
||||||
|
ldap_done, /* done */
|
||||||
|
ZERO_NULL, /* do_more */
|
||||||
|
ldap_connect, /* connect_it */
|
||||||
|
ldap_connecting, /* connecting */
|
||||||
|
ZERO_NULL, /* doing */
|
||||||
|
ZERO_NULL, /* proto_getsock */
|
||||||
|
ZERO_NULL, /* doing_getsock */
|
||||||
|
ZERO_NULL, /* perform_getsock */
|
||||||
|
ldap_disconnect, /* disconnect */
|
||||||
|
PORT_LDAP, /* defport */
|
||||||
|
PROT_LDAP /* protocol */
|
||||||
|
};
|
||||||
|
|
||||||
|
/*
|
||||||
|
* LDAPS protocol handler.
|
||||||
|
*/
|
||||||
|
|
||||||
|
const struct Curl_handler Curl_handler_ldaps = {
|
||||||
|
"LDAPS", /* scheme */
|
||||||
|
ldap_setup, /* setup_connection */
|
||||||
|
ldap_do, /* do_it */
|
||||||
|
ldap_done, /* done */
|
||||||
|
ZERO_NULL, /* do_more */
|
||||||
|
ldap_connect, /* connect_it */
|
||||||
|
ldap_connecting, /* connecting */
|
||||||
|
ZERO_NULL, /* doing */
|
||||||
|
ZERO_NULL, /* proto_getsock */
|
||||||
|
ZERO_NULL, /* doing_getsock */
|
||||||
|
ZERO_NULL, /* perform_getsock */
|
||||||
|
ldap_disconnect, /* disconnect */
|
||||||
|
PORT_LDAPS, /* defport */
|
||||||
|
PROT_LDAP | PROT_SSL /* protocol */
|
||||||
|
};
|
||||||
|
|
||||||
|
static const char *url_errs[] = {
|
||||||
|
"success",
|
||||||
|
"out of memory",
|
||||||
|
"bad parameter",
|
||||||
|
"unrecognized scheme",
|
||||||
|
"unbalanced delimiter",
|
||||||
|
"bad URL",
|
||||||
|
"bad host or port",
|
||||||
|
"bad or missing attributes",
|
||||||
|
"bad or missing scope",
|
||||||
|
"bad or missing filter",
|
||||||
|
"bad or missing extensions"
|
||||||
|
};
|
||||||
|
|
||||||
|
typedef struct ldapconninfo {
|
||||||
|
LDAP *ld;
|
||||||
|
Curl_recv *recv; /* for stacking SSL handler */
|
||||||
|
Curl_send *send;
|
||||||
|
int proto;
|
||||||
|
int msgid;
|
||||||
|
bool ssldone;
|
||||||
|
bool sslinst;
|
||||||
|
bool didbind;
|
||||||
|
} ldapconninfo;
|
||||||
|
|
||||||
|
typedef struct ldapreqinfo {
|
||||||
|
int msgid;
|
||||||
|
int nument;
|
||||||
|
} ldapreqinfo;
|
||||||
|
|
||||||
|
static CURLcode ldap_setup(struct connectdata *conn)
|
||||||
|
{
|
||||||
|
ldapconninfo *li;
|
||||||
|
LDAPURLDesc *lud;
|
||||||
|
struct SessionHandle *data=conn->data;
|
||||||
|
int rc, proto;
|
||||||
|
CURLcode status;
|
||||||
|
|
||||||
|
rc = ldap_url_parse(data->change.url, &lud);
|
||||||
|
if (rc != LDAP_URL_SUCCESS) {
|
||||||
|
const char *msg = "url parsing problem";
|
||||||
|
status = CURLE_URL_MALFORMAT;
|
||||||
|
if (rc > LDAP_URL_SUCCESS && rc <= LDAP_URL_ERR_BADEXTS) {
|
||||||
|
if (rc == LDAP_URL_ERR_MEM)
|
||||||
|
status = CURLE_OUT_OF_MEMORY;
|
||||||
|
msg = url_errs[rc];
|
||||||
|
}
|
||||||
|
failf(conn->data, "LDAP local: %s", msg);
|
||||||
|
return status;
|
||||||
|
}
|
||||||
|
proto = ldap_pvt_url_scheme2proto(lud->lud_scheme);
|
||||||
|
ldap_free_urldesc(lud);
|
||||||
|
|
||||||
|
li = calloc(1, sizeof(ldapconninfo));
|
||||||
|
li->proto = proto;
|
||||||
|
conn->proto.generic = li;
|
||||||
|
/* TODO:
|
||||||
|
* - provide option to choose SASL Binds instead of Simple
|
||||||
|
*/
|
||||||
|
return CURLE_OK;
|
||||||
|
}
|
||||||
|
|
||||||
|
static Sockbuf_IO ldapsb_tls;
|
||||||
|
|
||||||
|
static CURLcode ldap_connect(struct connectdata *conn, bool *done)
|
||||||
|
{
|
||||||
|
ldapconninfo *li = conn->proto.generic;
|
||||||
|
struct SessionHandle *data=conn->data;
|
||||||
|
int rc, proto = LDAP_VERSION3;
|
||||||
|
char hosturl[1024], *ptr;
|
||||||
|
|
||||||
|
strcpy(hosturl, "ldap");
|
||||||
|
ptr = hosturl+4;
|
||||||
|
if (conn->protocol & PROT_SSL)
|
||||||
|
*ptr++ = 's';
|
||||||
|
snprintf(ptr, sizeof(hosturl)-(ptr-hosturl), "://%s:%d",
|
||||||
|
conn->host.name, conn->port);
|
||||||
|
|
||||||
|
rc = ldap_init_fd(conn->sock[FIRSTSOCKET], li->proto, hosturl, &li->ld);
|
||||||
|
if (rc) {
|
||||||
|
failf(data, "LDAP local: Cannot connect to %s, %s",
|
||||||
|
hosturl, ldap_err2string(rc));
|
||||||
|
return CURLE_COULDNT_CONNECT;
|
||||||
|
}
|
||||||
|
|
||||||
|
ldap_set_option(li->ld, LDAP_OPT_PROTOCOL_VERSION, &proto);
|
||||||
|
|
||||||
|
if (conn->protocol & PROT_SSL) {
|
||||||
|
CURLcode res;
|
||||||
|
if (data->state.used_interface == Curl_if_easy) {
|
||||||
|
res = Curl_ssl_connect(conn, FIRSTSOCKET);
|
||||||
|
if (res)
|
||||||
|
return res;
|
||||||
|
li->ssldone = TRUE;
|
||||||
|
} else {
|
||||||
|
res = Curl_ssl_connect_nonblocking(conn, FIRSTSOCKET, &li->ssldone);
|
||||||
|
if (res)
|
||||||
|
return res;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (data->state.used_interface == Curl_if_easy)
|
||||||
|
return ldap_connecting(conn, done);
|
||||||
|
|
||||||
|
return CURLE_OK;
|
||||||
|
}
|
||||||
|
|
||||||
|
static CURLcode ldap_connecting(struct connectdata *conn, bool *done)
|
||||||
|
{
|
||||||
|
ldapconninfo *li = conn->proto.generic;
|
||||||
|
struct SessionHandle *data=conn->data;
|
||||||
|
LDAPMessage *result = NULL;
|
||||||
|
struct timeval tv = {0,1}, *tvp;
|
||||||
|
int rc, err;
|
||||||
|
char *info = NULL;
|
||||||
|
|
||||||
|
if (conn->protocol & PROT_SSL) {
|
||||||
|
/* Is the SSL handshake complete yet? */
|
||||||
|
if (!li->ssldone) {
|
||||||
|
CURLcode res = Curl_ssl_connect_nonblocking(conn, FIRSTSOCKET, &li->ssldone);
|
||||||
|
if (res || !li->ssldone)
|
||||||
|
return res;
|
||||||
|
}
|
||||||
|
/* Have we installed the libcurl SSL handlers into the sockbuf yet? */
|
||||||
|
if (!li->sslinst) {
|
||||||
|
Sockbuf *sb;
|
||||||
|
ldap_get_option(li->ld, LDAP_OPT_SOCKBUF, &sb);
|
||||||
|
ber_sockbuf_add_io(sb, &ldapsb_tls, LBER_SBIOD_LEVEL_TRANSPORT, conn);
|
||||||
|
li->sslinst = TRUE;
|
||||||
|
li->recv = conn->recv[FIRSTSOCKET];
|
||||||
|
li->send = conn->send[FIRSTSOCKET];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (data->state.used_interface == Curl_if_easy)
|
||||||
|
tvp = NULL; /* let ldap_result block indefinitely */
|
||||||
|
else
|
||||||
|
tvp = &tv;
|
||||||
|
|
||||||
|
retry:
|
||||||
|
if (!li->didbind) {
|
||||||
|
char *binddn;
|
||||||
|
struct berval passwd;
|
||||||
|
|
||||||
|
if (conn->bits.user_passwd) {
|
||||||
|
binddn = conn->user;
|
||||||
|
passwd.bv_val = conn->passwd;
|
||||||
|
passwd.bv_len = strlen(passwd.bv_val);
|
||||||
|
} else {
|
||||||
|
binddn = NULL;
|
||||||
|
passwd.bv_val = NULL;
|
||||||
|
passwd.bv_len = 0;
|
||||||
|
}
|
||||||
|
rc = ldap_sasl_bind(li->ld, binddn, LDAP_SASL_SIMPLE, &passwd,
|
||||||
|
NULL, NULL, &li->msgid);
|
||||||
|
if (rc)
|
||||||
|
return CURLE_LDAP_CANNOT_BIND;
|
||||||
|
li->didbind = TRUE;
|
||||||
|
if (tvp)
|
||||||
|
return CURLE_OK;
|
||||||
|
}
|
||||||
|
|
||||||
|
rc = ldap_result(li->ld, li->msgid, LDAP_MSG_ONE, tvp, &result);
|
||||||
|
if (rc < 0) {
|
||||||
|
failf(data, "LDAP local: bind ldap_result %s", ldap_err2string(rc));
|
||||||
|
return CURLE_LDAP_CANNOT_BIND;
|
||||||
|
}
|
||||||
|
if (rc == 0) {
|
||||||
|
/* timed out */
|
||||||
|
return CURLE_OK;
|
||||||
|
}
|
||||||
|
rc = ldap_parse_result(li->ld, result, &err, NULL, &info, NULL, NULL, 1);
|
||||||
|
if (rc) {
|
||||||
|
failf(data, "LDAP local: bind ldap_parse_result %s", ldap_err2string(rc));
|
||||||
|
return CURLE_LDAP_CANNOT_BIND;
|
||||||
|
}
|
||||||
|
/* Try to fallback to LDAPv2? */
|
||||||
|
if (err == LDAP_PROTOCOL_ERROR) {
|
||||||
|
int proto;
|
||||||
|
ldap_get_option(li->ld, LDAP_OPT_PROTOCOL_VERSION, &proto);
|
||||||
|
if (proto == LDAP_VERSION3) {
|
||||||
|
ldap_memfree(info);
|
||||||
|
proto = LDAP_VERSION2;
|
||||||
|
ldap_set_option(li->ld, LDAP_OPT_PROTOCOL_VERSION, &proto);
|
||||||
|
li->didbind = FALSE;
|
||||||
|
goto retry;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (err) {
|
||||||
|
failf(data, "LDAP remote: bind failed %s %s", ldap_err2string(rc),
|
||||||
|
info ? info : "");
|
||||||
|
return CURLE_LOGIN_DENIED;
|
||||||
|
}
|
||||||
|
conn->recv[FIRSTSOCKET] = ldap_recv;
|
||||||
|
*done = TRUE;
|
||||||
|
return CURLE_OK;
|
||||||
|
}
|
||||||
|
|
||||||
|
static CURLcode ldap_disconnect(struct connectdata *conn)
|
||||||
|
{
|
||||||
|
ldapconninfo *li = conn->proto.generic;
|
||||||
|
|
||||||
|
if (li) {
|
||||||
|
if (li->ld) {
|
||||||
|
ldap_unbind(li->ld);
|
||||||
|
li->ld = NULL;
|
||||||
|
}
|
||||||
|
conn->proto.generic = NULL;
|
||||||
|
free(li);
|
||||||
|
}
|
||||||
|
return CURLE_OK;
|
||||||
|
}
|
||||||
|
|
||||||
|
static CURLcode ldap_do(struct connectdata *conn, bool *done)
|
||||||
|
{
|
||||||
|
ldapconninfo *li = conn->proto.generic;
|
||||||
|
ldapreqinfo *lr;
|
||||||
|
CURLcode status = CURLE_OK;
|
||||||
|
int rc = 0;
|
||||||
|
LDAPURLDesc *ludp = NULL;
|
||||||
|
int msgid;
|
||||||
|
struct SessionHandle *data=conn->data;
|
||||||
|
|
||||||
|
conn->bits.close = FALSE;
|
||||||
|
|
||||||
|
infof(data, "LDAP local: %s\n", data->change.url);
|
||||||
|
|
||||||
|
rc = ldap_url_parse(data->change.url, &ludp);
|
||||||
|
if (rc != LDAP_URL_SUCCESS) {
|
||||||
|
const char *msg = "url parsing problem";
|
||||||
|
status = CURLE_URL_MALFORMAT;
|
||||||
|
if (rc > LDAP_URL_SUCCESS && rc <= LDAP_URL_ERR_BADEXTS) {
|
||||||
|
if (rc == LDAP_URL_ERR_MEM)
|
||||||
|
status = CURLE_OUT_OF_MEMORY;
|
||||||
|
msg = url_errs[rc];
|
||||||
|
}
|
||||||
|
failf(conn->data, "LDAP local: %s", msg);
|
||||||
|
return status;
|
||||||
|
}
|
||||||
|
|
||||||
|
rc = ldap_search_ext(li->ld, ludp->lud_dn, ludp->lud_scope,
|
||||||
|
ludp->lud_filter, ludp->lud_attrs, 0,
|
||||||
|
NULL, NULL, NULL, 0, &msgid);
|
||||||
|
ldap_free_urldesc(ludp);
|
||||||
|
if (rc != LDAP_SUCCESS) {
|
||||||
|
failf(data, "LDAP local: ldap_search_ext %s", ldap_err2string(rc));
|
||||||
|
return CURLE_LDAP_SEARCH_FAILED;
|
||||||
|
}
|
||||||
|
lr = calloc(1,sizeof(ldapreqinfo));
|
||||||
|
lr->msgid = msgid;
|
||||||
|
data->state.proto.generic = lr;
|
||||||
|
Curl_setup_transfer(conn, FIRSTSOCKET, -1, FALSE, NULL, -1, NULL);
|
||||||
|
*done = TRUE;
|
||||||
|
return CURLE_OK;
|
||||||
|
}
|
||||||
|
|
||||||
|
static CURLcode ldap_done(struct connectdata *conn, CURLcode res,
|
||||||
|
bool premature)
|
||||||
|
{
|
||||||
|
ldapreqinfo *lr = conn->data->state.proto.generic;
|
||||||
|
(void)res;
|
||||||
|
(void)premature;
|
||||||
|
|
||||||
|
if (lr) {
|
||||||
|
/* if there was a search in progress, abandon it */
|
||||||
|
if (lr->msgid) {
|
||||||
|
ldapconninfo *li = conn->proto.generic;
|
||||||
|
ldap_abandon(li->ld, lr->msgid);
|
||||||
|
lr->msgid = 0;
|
||||||
|
}
|
||||||
|
conn->data->state.proto.generic = NULL;
|
||||||
|
free(lr);
|
||||||
|
}
|
||||||
|
return CURLE_OK;
|
||||||
|
}
|
||||||
|
|
||||||
|
static ssize_t ldap_recv(struct connectdata *conn, int sockindex, char *buf,
|
||||||
|
size_t len, CURLcode *err)
|
||||||
|
{
|
||||||
|
ldapconninfo *li = conn->proto.generic;
|
||||||
|
struct SessionHandle *data=conn->data;
|
||||||
|
ldapreqinfo *lr = data->state.proto.generic;
|
||||||
|
int rc, ret;
|
||||||
|
LDAPMessage *result = NULL;
|
||||||
|
LDAPMessage *ent;
|
||||||
|
BerElement *ber = NULL;
|
||||||
|
struct timeval tv = {0,1};
|
||||||
|
(void)len;
|
||||||
|
(void)buf;
|
||||||
|
(void)sockindex;
|
||||||
|
|
||||||
|
rc = ldap_result(li->ld, lr->msgid, LDAP_MSG_RECEIVED, &tv, &result);
|
||||||
|
if (rc < 0) {
|
||||||
|
failf(data, "LDAP local: search ldap_result %s", ldap_err2string(rc));
|
||||||
|
*err = CURLE_RECV_ERROR;
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
|
|
||||||
|
*err = CURLE_AGAIN;
|
||||||
|
ret = -1;
|
||||||
|
|
||||||
|
/* timed out */
|
||||||
|
if (result == NULL)
|
||||||
|
return ret;
|
||||||
|
|
||||||
|
for (ent = ldap_first_message(li->ld, result); ent;
|
||||||
|
ent = ldap_next_message(li->ld, ent)) {
|
||||||
|
struct berval bv, *bvals, **bvp = &bvals;
|
||||||
|
int binary = 0, msgtype;
|
||||||
|
|
||||||
|
msgtype = ldap_msgtype(ent);
|
||||||
|
if (msgtype == LDAP_RES_SEARCH_RESULT) {
|
||||||
|
int code;
|
||||||
|
char *info = NULL;
|
||||||
|
rc = ldap_parse_result(li->ld, ent, &code, NULL, &info, NULL, NULL, 0);
|
||||||
|
if (rc) {
|
||||||
|
failf(data, "LDAP local: search ldap_parse_result %s", ldap_err2string(rc));
|
||||||
|
*err = CURLE_LDAP_SEARCH_FAILED;
|
||||||
|
} else if (code && code != LDAP_SIZELIMIT_EXCEEDED) {
|
||||||
|
failf(data, "LDAP remote: search failed %s %s", ldap_err2string(rc),
|
||||||
|
info ? info : "");
|
||||||
|
*err = CURLE_LDAP_SEARCH_FAILED;
|
||||||
|
} else {
|
||||||
|
/* successful */
|
||||||
|
if (code == LDAP_SIZELIMIT_EXCEEDED)
|
||||||
|
infof(data, "There are more than %d entries\n", lr->nument);
|
||||||
|
data->req.size = data->req.bytecount;
|
||||||
|
*err = CURLE_OK;
|
||||||
|
ret = 0;
|
||||||
|
}
|
||||||
|
lr->msgid = 0;
|
||||||
|
ldap_memfree(info);
|
||||||
|
break;
|
||||||
|
} else if (msgtype != LDAP_RES_SEARCH_ENTRY) {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
lr->nument++;
|
||||||
|
rc = ldap_get_dn_ber(li->ld, ent, &ber, &bv);
|
||||||
|
Curl_client_write(conn, CLIENTWRITE_BODY, (char *)"DN: ", 4);
|
||||||
|
Curl_client_write(conn, CLIENTWRITE_BODY, (char *)bv.bv_val, bv.bv_len);
|
||||||
|
Curl_client_write(conn, CLIENTWRITE_BODY, (char *)"\n", 1);
|
||||||
|
data->req.bytecount += bv.bv_len + 5;
|
||||||
|
|
||||||
|
for (rc = ldap_get_attribute_ber(li->ld, ent, ber, &bv, bvp);
|
||||||
|
rc == LDAP_SUCCESS;
|
||||||
|
rc = ldap_get_attribute_ber(li->ld, ent, ber, &bv, bvp)) {
|
||||||
|
int i;
|
||||||
|
|
||||||
|
if (bv.bv_val == NULL) break;
|
||||||
|
|
||||||
|
if (bv.bv_len > 7 && !strncmp(bv.bv_val + bv.bv_len - 7, ";binary", 7))
|
||||||
|
binary = 1;
|
||||||
|
|
||||||
|
for (i=0; bvals[i].bv_val != NULL; i++) {
|
||||||
|
int binval = 0;
|
||||||
|
Curl_client_write(conn, CLIENTWRITE_BODY, (char *)"\t", 1);
|
||||||
|
Curl_client_write(conn, CLIENTWRITE_BODY, (char *)bv.bv_val, bv.bv_len);
|
||||||
|
Curl_client_write(conn, CLIENTWRITE_BODY, (char *)":", 1);
|
||||||
|
data->req.bytecount += bv.bv_len + 2;
|
||||||
|
|
||||||
|
if (!binary) {
|
||||||
|
/* check for leading or trailing whitespace */
|
||||||
|
if (isspace(bvals[i].bv_val[0]) ||
|
||||||
|
isspace(bvals[i].bv_val[bvals[i].bv_len-1])) {
|
||||||
|
binval = 1;
|
||||||
|
} else {
|
||||||
|
/* check for unprintable characters */
|
||||||
|
unsigned int j;
|
||||||
|
for (j=0; j<bvals[i].bv_len; j++)
|
||||||
|
if (!isprint(bvals[i].bv_val[j])) {
|
||||||
|
binval = 1;
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if (binary || binval) {
|
||||||
|
char *val_b64;
|
||||||
|
/* Binary value, encode to base64. */
|
||||||
|
size_t val_b64_sz = Curl_base64_encode(data,
|
||||||
|
bvals[i].bv_val,
|
||||||
|
bvals[i].bv_len,
|
||||||
|
&val_b64);
|
||||||
|
Curl_client_write(conn, CLIENTWRITE_BODY, (char *)": ", 2);
|
||||||
|
data->req.bytecount += 2;
|
||||||
|
if(val_b64_sz > 0) {
|
||||||
|
Curl_client_write(conn, CLIENTWRITE_BODY, val_b64, val_b64_sz);
|
||||||
|
free(val_b64);
|
||||||
|
data->req.bytecount += val_b64_sz;
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
Curl_client_write(conn, CLIENTWRITE_BODY, (char *)" ", 1);
|
||||||
|
Curl_client_write(conn, CLIENTWRITE_BODY, bvals[i].bv_val,
|
||||||
|
bvals[i].bv_len);
|
||||||
|
data->req.bytecount += bvals[i].bv_len + 1;
|
||||||
|
}
|
||||||
|
Curl_client_write(conn, CLIENTWRITE_BODY, (char *)"\n", 0);
|
||||||
|
data->req.bytecount++;
|
||||||
|
}
|
||||||
|
ber_memfree(bvals);
|
||||||
|
Curl_client_write(conn, CLIENTWRITE_BODY, (char *)"\n", 0);
|
||||||
|
data->req.bytecount++;
|
||||||
|
}
|
||||||
|
Curl_client_write(conn, CLIENTWRITE_BODY, (char *)"\n", 0);
|
||||||
|
data->req.bytecount++;
|
||||||
|
ber_free(ber, 0);
|
||||||
|
}
|
||||||
|
ldap_msgfree(result);
|
||||||
|
return ret;
|
||||||
|
}
|
||||||
|
|
||||||
|
static int
|
||||||
|
ldapsb_tls_setup(Sockbuf_IO_Desc *sbiod, void *arg)
|
||||||
|
{
|
||||||
|
sbiod->sbiod_pvt = arg;
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
static int
|
||||||
|
ldapsb_tls_remove(Sockbuf_IO_Desc *sbiod)
|
||||||
|
{
|
||||||
|
sbiod->sbiod_pvt = NULL;
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
/* We don't need to do anything because libcurl does it already */
|
||||||
|
static int
|
||||||
|
ldapsb_tls_close(Sockbuf_IO_Desc *sbiod)
|
||||||
|
{
|
||||||
|
(void)sbiod;
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
static int
|
||||||
|
ldapsb_tls_ctrl(Sockbuf_IO_Desc *sbiod, int opt, void *arg)
|
||||||
|
{
|
||||||
|
(void)arg;
|
||||||
|
if (opt == LBER_SB_OPT_DATA_READY) {
|
||||||
|
struct connectdata *conn = sbiod->sbiod_pvt;
|
||||||
|
return Curl_ssl_data_pending(conn, FIRSTSOCKET);
|
||||||
|
}
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
static ber_slen_t
|
||||||
|
ldapsb_tls_read(Sockbuf_IO_Desc *sbiod, void *buf, ber_len_t len)
|
||||||
|
{
|
||||||
|
struct connectdata *conn = sbiod->sbiod_pvt;
|
||||||
|
ldapconninfo *li = conn->proto.generic;
|
||||||
|
ber_slen_t ret;
|
||||||
|
CURLcode err = CURLE_RECV_ERROR;
|
||||||
|
|
||||||
|
ret = li->recv(conn, FIRSTSOCKET, buf, len, &err);
|
||||||
|
if (ret < 0 && err == CURLE_AGAIN) {
|
||||||
|
SET_SOCKERRNO(EWOULDBLOCK);
|
||||||
|
}
|
||||||
|
return ret;
|
||||||
|
}
|
||||||
|
|
||||||
|
static ber_slen_t
|
||||||
|
ldapsb_tls_write(Sockbuf_IO_Desc *sbiod, void *buf, ber_len_t len)
|
||||||
|
{
|
||||||
|
struct connectdata *conn = sbiod->sbiod_pvt;
|
||||||
|
ldapconninfo *li = conn->proto.generic;
|
||||||
|
ber_slen_t ret;
|
||||||
|
CURLcode err = CURLE_SEND_ERROR;
|
||||||
|
|
||||||
|
ret = li->send(conn, FIRSTSOCKET, buf, len, &err);
|
||||||
|
if (ret < 0 && err == CURLE_AGAIN) {
|
||||||
|
SET_SOCKERRNO(EWOULDBLOCK);
|
||||||
|
}
|
||||||
|
return ret;
|
||||||
|
}
|
||||||
|
|
||||||
|
static Sockbuf_IO ldapsb_tls =
|
||||||
|
{
|
||||||
|
ldapsb_tls_setup,
|
||||||
|
ldapsb_tls_remove,
|
||||||
|
ldapsb_tls_ctrl,
|
||||||
|
ldapsb_tls_read,
|
||||||
|
ldapsb_tls_write,
|
||||||
|
ldapsb_tls_close
|
||||||
|
};
|
||||||
|
|
||||||
|
#endif /* USE_OPENLDAP */
|
@ -181,13 +181,12 @@ static const struct Curl_handler * const protocols[] = {
|
|||||||
&Curl_handler_dict,
|
&Curl_handler_dict,
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
#ifndef CURL_DISABLE_LDAP
|
#if !defined(CURL_DISABLE_LDAP) || defined(USE_OPENLDAP)
|
||||||
&Curl_handler_ldap,
|
&Curl_handler_ldap,
|
||||||
#endif
|
#if defined(HAVE_LDAP_SSL) || defined(USE_OPENLDAP)
|
||||||
|
|
||||||
#if !defined(CURL_DISABLE_LDAP) && defined(HAVE_LDAP_SSL)
|
|
||||||
&Curl_handler_ldaps,
|
&Curl_handler_ldaps,
|
||||||
#endif
|
#endif
|
||||||
|
#endif
|
||||||
|
|
||||||
#ifndef CURL_DISABLE_FILE
|
#ifndef CURL_DISABLE_FILE
|
||||||
&Curl_handler_file,
|
&Curl_handler_file,
|
||||||
|
@ -170,12 +170,12 @@ static const char * const protocols[] = {
|
|||||||
#if defined(USE_SSL) && !defined(CURL_DISABLE_IMAP)
|
#if defined(USE_SSL) && !defined(CURL_DISABLE_IMAP)
|
||||||
"imaps",
|
"imaps",
|
||||||
#endif
|
#endif
|
||||||
#ifndef CURL_DISABLE_LDAP
|
#if !defined(CURL_DISABLE_LDAP) || defined(USE_OPENLDAP)
|
||||||
"ldap",
|
"ldap",
|
||||||
#endif
|
#if defined(HAVE_LDAP_SSL) || defined(USE_OPENLDAP)
|
||||||
#if defined(HAVE_LDAP_SSL) && !defined(CURL_DISABLE_LDAP)
|
|
||||||
"ldaps",
|
"ldaps",
|
||||||
#endif
|
#endif
|
||||||
|
#endif
|
||||||
#ifndef CURL_DISABLE_POP3
|
#ifndef CURL_DISABLE_POP3
|
||||||
"pop3",
|
"pop3",
|
||||||
#endif
|
#endif
|
||||||
|
Loading…
Reference in New Issue
Block a user