2 Unix SMB/CIFS implementation.
4 Python interface to ldb.
6 Copyright (C) 2005,2006 Tim Potter <tpot@samba.org>
7 Copyright (C) 2006 Simo Sorce <idra@samba.org>
8 Copyright (C) 2007-2010 Jelmer Vernooij <jelmer@samba.org>
9 Copyright (C) 2009-2010 Matthias Dieter Wallnöfer
11 ** NOTE! The following LGPL license applies to the ldb
12 ** library. This does NOT imply that all of Samba is released
15 This library is free software; you can redistribute it and/or
16 modify it under the terms of the GNU Lesser General Public
17 License as published by the Free Software Foundation; either
18 version 3 of the License, or (at your option) any later version.
20 This library is distributed in the hope that it will be useful,
21 but WITHOUT ANY WARRANTY; without even the implied warranty of
22 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
23 Lesser General Public License for more details.
25 You should have received a copy of the GNU Lesser General Public
26 License along with this library; if not, see <http://www.gnu.org/licenses/>.
31 #include "ldb_private.h"
35 static PyObject
*PyLdbMessage_FromMessage(struct ldb_message
*msg
);
36 static PyObject
*PyExc_LdbError
;
38 staticforward PyTypeObject PyLdbControl
;
39 staticforward PyTypeObject PyLdbResult
;
40 staticforward PyTypeObject PyLdbMessage
;
41 staticforward PyTypeObject PyLdbModule
;
42 staticforward PyTypeObject PyLdbDn
;
43 staticforward PyTypeObject PyLdb
;
44 staticforward PyTypeObject PyLdbMessageElement
;
45 staticforward PyTypeObject PyLdbTree
;
46 static PyObject
*PyLdb_FromLdbContext(struct ldb_context
*ldb_ctx
);
47 static PyObject
*PyLdbModule_FromModule(struct ldb_module
*mod
);
48 static struct ldb_message_element
*PyObject_AsMessageElement(
52 const char *attr_name
);
54 /* There's no Py_ssize_t in 2.4, apparently */
55 #if PY_MAJOR_VERSION == 2 && PY_MINOR_VERSION < 5
56 typedef int Py_ssize_t
;
57 typedef inquiry lenfunc
;
58 typedef intargfunc ssizeargfunc
;
61 #ifndef Py_RETURN_NONE
62 #define Py_RETURN_NONE return Py_INCREF(Py_None), Py_None
65 #define SIGN(a) (((a) == 0)?0:((a) < 0?-1:1))
69 static PyObject
*py_ldb_control_str(PyLdbControlObject
*self
)
71 if (self
->data
!= NULL
) {
72 char* control
= ldb_control_to_string(self
->mem_ctx
, self
->data
);
73 if (control
== NULL
) {
77 return PyString_FromString(control
);
79 return PyString_FromFormat("ldb control");
83 static void py_ldb_control_dealloc(PyLdbControlObject
*self
)
85 if (self
->mem_ctx
!= NULL
) {
86 talloc_free(self
->mem_ctx
);
89 self
->ob_type
->tp_free(self
);
92 static PyObject
*py_ldb_control_get_oid(PyLdbControlObject
*self
)
94 return PyString_FromString(self
->data
->oid
);
97 static PyObject
*py_ldb_control_get_critical(PyLdbControlObject
*self
)
99 return PyBool_FromLong(self
->data
->critical
);
102 static PyObject
*py_ldb_control_set_critical(PyLdbControlObject
*self
, PyObject
*value
, void *closure
)
104 if (PyObject_IsTrue(value
)) {
105 self
->data
->critical
= true;
107 self
->data
->critical
= false;
112 static PyObject
*py_ldb_control_new(PyTypeObject
*type
, PyObject
*args
, PyObject
*kwargs
)
115 const char * const kwnames
[] = { "ldb", "data", NULL
};
116 struct ldb_control
*parsed_controls
;
117 PyLdbControlObject
*ret
;
120 struct ldb_context
*ldb_ctx
;
122 if (!PyArg_ParseTupleAndKeywords(args
, kwargs
, "Os",
123 discard_const_p(char *, kwnames
),
127 mem_ctx
= talloc_new(NULL
);
128 if (mem_ctx
== NULL
) {
133 ldb_ctx
= PyLdb_AsLdbContext(py_ldb
);
134 parsed_controls
= ldb_parse_control_from_string(ldb_ctx
, mem_ctx
, data
);
136 if (!parsed_controls
) {
137 talloc_free(mem_ctx
);
138 PyErr_SetString(PyExc_ValueError
, "unable to parse control string");
142 ret
= PyObject_New(PyLdbControlObject
, type
);
145 talloc_free(mem_ctx
);
149 ret
->mem_ctx
= mem_ctx
;
151 ret
->data
= talloc_move(mem_ctx
, &parsed_controls
);
152 if (ret
->data
== NULL
) {
155 talloc_free(mem_ctx
);
159 return (PyObject
*)ret
;
162 static PyGetSetDef py_ldb_control_getset
[] = {
163 { discard_const_p(char, "oid"), (getter
)py_ldb_control_get_oid
, NULL
, NULL
},
164 { discard_const_p(char, "critical"), (getter
)py_ldb_control_get_critical
, (setter
)py_ldb_control_set_critical
, NULL
},
168 static PyTypeObject PyLdbControl
= {
169 .tp_name
= "ldb.control",
170 .tp_dealloc
= (destructor
)py_ldb_control_dealloc
,
171 .tp_getattro
= PyObject_GenericGetAttr
,
172 .tp_basicsize
= sizeof(PyLdbControlObject
),
173 .tp_getset
= py_ldb_control_getset
,
174 .tp_doc
= "LDB control.",
175 .tp_str
= (reprfunc
)py_ldb_control_str
,
176 .tp_new
= py_ldb_control_new
,
177 .tp_flags
= Py_TPFLAGS_DEFAULT
|Py_TPFLAGS_BASETYPE
,
180 static void PyErr_SetLdbError(PyObject
*error
, int ret
, struct ldb_context
*ldb_ctx
)
182 if (ret
== LDB_ERR_PYTHON_EXCEPTION
)
183 return; /* Python exception should already be set, just keep that */
185 PyErr_SetObject(error
,
186 Py_BuildValue(discard_const_p(char, "(i,s)"), ret
,
187 ldb_ctx
== NULL
?ldb_strerror(ret
):ldb_errstring(ldb_ctx
)));
190 static PyObject
*PyObject_FromLdbValue(struct ldb_val
*val
)
192 return PyString_FromStringAndSize((const char *)val
->data
, val
->length
);
196 * Create a Python object from a ldb_result.
198 * @param result LDB result to convert
199 * @return Python object with converted result (a list object)
201 static PyObject
*PyLdbControl_FromControl(struct ldb_control
*control
)
203 TALLOC_CTX
*ctl_ctx
= talloc_new(NULL
);
204 PyLdbControlObject
*ctrl
;
205 if (ctl_ctx
== NULL
) {
210 ctrl
= (PyLdbControlObject
*)PyLdbControl
.tp_alloc(&PyLdbControl
, 0);
212 talloc_free(ctl_ctx
);
216 ctrl
->mem_ctx
= ctl_ctx
;
217 ctrl
->data
= talloc_steal(ctrl
->mem_ctx
, control
);
218 if (ctrl
->data
== NULL
) {
223 return (PyObject
*) ctrl
;
227 * Create a Python object from a ldb_result.
229 * @param result LDB result to convert
230 * @return Python object with converted result (a list object)
232 static PyObject
*PyLdbResult_FromResult(struct ldb_result
*result
)
234 PyLdbResultObject
*ret
;
235 PyObject
*list
, *controls
, *referals
;
238 if (result
== NULL
) {
242 ret
= (PyLdbResultObject
*)PyLdbResult
.tp_alloc(&PyLdbResult
, 0);
248 list
= PyList_New(result
->count
);
255 for (i
= 0; i
< result
->count
; i
++) {
256 PyList_SetItem(list
, i
, PyLdbMessage_FromMessage(result
->msgs
[i
]));
259 ret
->mem_ctx
= talloc_new(NULL
);
260 if (ret
->mem_ctx
== NULL
) {
269 if (result
->controls
) {
270 controls
= PyList_New(1);
271 if (controls
== NULL
) {
276 for (i
=0; result
->controls
[i
]; i
++) {
277 PyObject
*ctrl
= (PyObject
*) PyLdbControl_FromControl(result
->controls
[i
]);
284 PyList_SetItem(controls
, i
, ctrl
);
288 * No controls so we keep an empty list
290 controls
= PyList_New(0);
291 if (controls
== NULL
) {
298 ret
->controls
= controls
;
302 while (result
->refs
&& result
->refs
[i
]) {
306 referals
= PyList_New(i
);
307 if (referals
== NULL
) {
313 for (i
= 0;result
->refs
&& result
->refs
[i
]; i
++) {
314 PyList_SetItem(referals
, i
, PyString_FromString(result
->refs
[i
]));
316 ret
->referals
= referals
;
317 return (PyObject
*)ret
;
321 * Create a LDB Result from a Python object.
322 * If conversion fails, NULL will be returned and a Python exception set.
324 * @param mem_ctx Memory context in which to allocate the LDB Result
325 * @param obj Python object to convert
326 * @return a ldb_result, or NULL if the conversion failed
328 static struct ldb_result
*PyLdbResult_AsResult(TALLOC_CTX
*mem_ctx
,
331 struct ldb_result
*res
;
337 res
= talloc_zero(mem_ctx
, struct ldb_result
);
338 res
->count
= PyList_Size(obj
);
339 res
->msgs
= talloc_array(res
, struct ldb_message
*, res
->count
);
340 for (i
= 0; i
< res
->count
; i
++) {
341 PyObject
*item
= PyList_GetItem(obj
, i
);
342 res
->msgs
[i
] = PyLdbMessage_AsMessage(item
);
347 static PyObject
*py_ldb_dn_validate(PyLdbDnObject
*self
)
349 return PyBool_FromLong(ldb_dn_validate(self
->dn
));
352 static PyObject
*py_ldb_dn_is_valid(PyLdbDnObject
*self
)
354 return PyBool_FromLong(ldb_dn_is_valid(self
->dn
));
357 static PyObject
*py_ldb_dn_is_special(PyLdbDnObject
*self
)
359 return PyBool_FromLong(ldb_dn_is_special(self
->dn
));
362 static PyObject
*py_ldb_dn_is_null(PyLdbDnObject
*self
)
364 return PyBool_FromLong(ldb_dn_is_null(self
->dn
));
367 static PyObject
*py_ldb_dn_get_casefold(PyLdbDnObject
*self
)
369 return PyString_FromString(ldb_dn_get_casefold(self
->dn
));
372 static PyObject
*py_ldb_dn_get_linearized(PyLdbDnObject
*self
)
374 return PyString_FromString(ldb_dn_get_linearized(self
->dn
));
377 static PyObject
*py_ldb_dn_canonical_str(PyLdbDnObject
*self
)
379 return PyString_FromString(ldb_dn_canonical_string(self
->dn
, self
->dn
));
382 static PyObject
*py_ldb_dn_canonical_ex_str(PyLdbDnObject
*self
)
384 return PyString_FromString(ldb_dn_canonical_ex_string(self
->dn
, self
->dn
));
387 static PyObject
*py_ldb_dn_repr(PyLdbDnObject
*self
)
389 return PyString_FromFormat("Dn(%s)", PyObject_REPR(PyString_FromString(ldb_dn_get_linearized(self
->dn
))));
392 static PyObject
*py_ldb_dn_check_special(PyLdbDnObject
*self
, PyObject
*args
)
396 if (!PyArg_ParseTuple(args
, "s", &name
))
399 return ldb_dn_check_special(self
->dn
, name
)?Py_True
:Py_False
;
402 static int py_ldb_dn_compare(PyLdbDnObject
*dn1
, PyLdbDnObject
*dn2
)
405 ret
= ldb_dn_compare(dn1
->dn
, dn2
->dn
);
406 if (ret
< 0) ret
= -1;
407 if (ret
> 0) ret
= 1;
411 static PyObject
*py_ldb_dn_get_parent(PyLdbDnObject
*self
)
413 struct ldb_dn
*dn
= PyLdbDn_AsDn((PyObject
*)self
);
414 struct ldb_dn
*parent
;
415 PyLdbDnObject
*py_ret
;
416 TALLOC_CTX
*mem_ctx
= talloc_new(NULL
);
418 parent
= ldb_dn_get_parent(mem_ctx
, dn
);
419 if (parent
== NULL
) {
420 talloc_free(mem_ctx
);
424 py_ret
= (PyLdbDnObject
*)PyLdbDn
.tp_alloc(&PyLdbDn
, 0);
425 if (py_ret
== NULL
) {
427 talloc_free(mem_ctx
);
430 py_ret
->mem_ctx
= mem_ctx
;
432 return (PyObject
*)py_ret
;
435 #define dn_ldb_ctx(dn) ((struct ldb_context *)dn)
437 static PyObject
*py_ldb_dn_add_child(PyLdbDnObject
*self
, PyObject
*args
)
440 struct ldb_dn
*dn
, *other
;
441 if (!PyArg_ParseTuple(args
, "O", &py_other
))
444 dn
= PyLdbDn_AsDn((PyObject
*)self
);
446 if (!PyObject_AsDn(NULL
, py_other
, dn_ldb_ctx(dn
), &other
))
449 return ldb_dn_add_child(dn
, other
)?Py_True
:Py_False
;
452 static PyObject
*py_ldb_dn_add_base(PyLdbDnObject
*self
, PyObject
*args
)
455 struct ldb_dn
*other
, *dn
;
456 if (!PyArg_ParseTuple(args
, "O", &py_other
))
459 dn
= PyLdbDn_AsDn((PyObject
*)self
);
461 if (!PyObject_AsDn(NULL
, py_other
, dn_ldb_ctx(dn
), &other
))
464 return ldb_dn_add_base(dn
, other
)?Py_True
:Py_False
;
467 static PyMethodDef py_ldb_dn_methods
[] = {
468 { "validate", (PyCFunction
)py_ldb_dn_validate
, METH_NOARGS
,
469 "S.validate() -> bool\n"
470 "Validate DN is correct." },
471 { "is_valid", (PyCFunction
)py_ldb_dn_is_valid
, METH_NOARGS
,
472 "S.is_valid() -> bool\n" },
473 { "is_special", (PyCFunction
)py_ldb_dn_is_special
, METH_NOARGS
,
474 "S.is_special() -> bool\n"
475 "Check whether this is a special LDB DN." },
476 { "is_null", (PyCFunction
)py_ldb_dn_is_null
, METH_NOARGS
,
477 "Check whether this is a null DN." },
478 { "get_casefold", (PyCFunction
)py_ldb_dn_get_casefold
, METH_NOARGS
,
480 { "get_linearized", (PyCFunction
)py_ldb_dn_get_linearized
, METH_NOARGS
,
482 { "canonical_str", (PyCFunction
)py_ldb_dn_canonical_str
, METH_NOARGS
,
483 "S.canonical_str() -> string\n"
484 "Canonical version of this DN (like a posix path)." },
485 { "canonical_ex_str", (PyCFunction
)py_ldb_dn_canonical_ex_str
, METH_NOARGS
,
486 "S.canonical_ex_str() -> string\n"
487 "Canonical version of this DN (like a posix path, with terminating newline)." },
488 { "parent", (PyCFunction
)py_ldb_dn_get_parent
, METH_NOARGS
,
490 "Get the parent for this DN." },
491 { "add_child", (PyCFunction
)py_ldb_dn_add_child
, METH_VARARGS
,
492 "S.add_child(dn) -> None\n"
493 "Add a child DN to this DN." },
494 { "add_base", (PyCFunction
)py_ldb_dn_add_base
, METH_VARARGS
,
495 "S.add_base(dn) -> None\n"
496 "Add a base DN to this DN." },
497 { "check_special", (PyCFunction
)py_ldb_dn_check_special
, METH_VARARGS
,
498 "S.check_special(name) -> bool\n\n"
499 "Check if name is a special DN name"},
503 static Py_ssize_t
py_ldb_dn_len(PyLdbDnObject
*self
)
505 return ldb_dn_get_comp_num(PyLdbDn_AsDn((PyObject
*)self
));
508 static PyObject
*py_ldb_dn_concat(PyLdbDnObject
*self
, PyObject
*py_other
)
510 struct ldb_dn
*dn
= PyLdbDn_AsDn((PyObject
*)self
),
512 PyLdbDnObject
*py_ret
;
514 if (!PyObject_AsDn(NULL
, py_other
, NULL
, &other
))
517 py_ret
= (PyLdbDnObject
*)PyLdbDn
.tp_alloc(&PyLdbDn
, 0);
518 if (py_ret
== NULL
) {
522 py_ret
->mem_ctx
= talloc_new(NULL
);
523 py_ret
->dn
= ldb_dn_copy(py_ret
->mem_ctx
, dn
);
524 ldb_dn_add_child(py_ret
->dn
, other
);
525 return (PyObject
*)py_ret
;
528 static PySequenceMethods py_ldb_dn_seq
= {
529 .sq_length
= (lenfunc
)py_ldb_dn_len
,
530 .sq_concat
= (binaryfunc
)py_ldb_dn_concat
,
533 static PyObject
*py_ldb_dn_new(PyTypeObject
*type
, PyObject
*args
, PyObject
*kwargs
)
538 struct ldb_context
*ldb_ctx
;
540 PyLdbDnObject
*py_ret
;
541 const char * const kwnames
[] = { "ldb", "dn", NULL
};
543 if (!PyArg_ParseTupleAndKeywords(args
, kwargs
, "Os",
544 discard_const_p(char *, kwnames
),
548 ldb_ctx
= PyLdb_AsLdbContext(py_ldb
);
550 mem_ctx
= talloc_new(NULL
);
551 if (mem_ctx
== NULL
) {
556 ret
= ldb_dn_new(mem_ctx
, ldb_ctx
, str
);
557 if (!ldb_dn_validate(ret
)) {
558 talloc_free(mem_ctx
);
559 PyErr_SetString(PyExc_ValueError
, "unable to parse dn string");
563 py_ret
= (PyLdbDnObject
*)type
->tp_alloc(type
, 0);
565 talloc_free(mem_ctx
);
569 py_ret
->mem_ctx
= mem_ctx
;
571 return (PyObject
*)py_ret
;
574 static void py_ldb_dn_dealloc(PyLdbDnObject
*self
)
576 talloc_free(self
->mem_ctx
);
580 static PyTypeObject PyLdbDn
= {
582 .tp_methods
= py_ldb_dn_methods
,
583 .tp_str
= (reprfunc
)py_ldb_dn_get_linearized
,
584 .tp_repr
= (reprfunc
)py_ldb_dn_repr
,
585 .tp_compare
= (cmpfunc
)py_ldb_dn_compare
,
586 .tp_as_sequence
= &py_ldb_dn_seq
,
587 .tp_doc
= "A LDB distinguished name.",
588 .tp_new
= py_ldb_dn_new
,
589 .tp_dealloc
= (destructor
)py_ldb_dn_dealloc
,
590 .tp_basicsize
= sizeof(PyLdbDnObject
),
591 .tp_flags
= Py_TPFLAGS_DEFAULT
,
595 static void py_ldb_debug(void *context
, enum ldb_debug_level level
, const char *fmt
, va_list ap
) PRINTF_ATTRIBUTE(3, 0);
596 static void py_ldb_debug(void *context
, enum ldb_debug_level level
, const char *fmt
, va_list ap
)
598 PyObject
*fn
= (PyObject
*)context
;
599 PyObject_CallFunction(fn
, discard_const_p(char, "(i,O)"), level
, PyString_FromFormatV(fmt
, ap
));
602 static PyObject
*py_ldb_set_debug(PyLdbObject
*self
, PyObject
*args
)
606 if (!PyArg_ParseTuple(args
, "O", &cb
))
610 /* FIXME: Where do we DECREF cb ? */
611 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ldb_set_debug(self
->ldb_ctx
, py_ldb_debug
, cb
), PyLdb_AsLdbContext(self
));
616 static PyObject
*py_ldb_set_create_perms(PyTypeObject
*self
, PyObject
*args
)
619 if (!PyArg_ParseTuple(args
, "I", &perms
))
622 ldb_set_create_perms(PyLdb_AsLdbContext(self
), perms
);
627 static PyObject
*py_ldb_set_modules_dir(PyTypeObject
*self
, PyObject
*args
)
630 if (!PyArg_ParseTuple(args
, "s", &modules_dir
))
633 ldb_set_modules_dir(PyLdb_AsLdbContext(self
), modules_dir
);
638 static PyObject
*py_ldb_transaction_start(PyLdbObject
*self
)
640 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ldb_transaction_start(PyLdb_AsLdbContext(self
)), PyLdb_AsLdbContext(self
));
644 static PyObject
*py_ldb_transaction_commit(PyLdbObject
*self
)
646 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ldb_transaction_commit(PyLdb_AsLdbContext(self
)), PyLdb_AsLdbContext(self
));
650 static PyObject
*py_ldb_transaction_prepare_commit(PyLdbObject
*self
)
652 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ldb_transaction_prepare_commit(PyLdb_AsLdbContext(self
)), PyLdb_AsLdbContext(self
));
656 static PyObject
*py_ldb_transaction_cancel(PyLdbObject
*self
)
658 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ldb_transaction_cancel(PyLdb_AsLdbContext(self
)), PyLdb_AsLdbContext(self
));
662 static PyObject
*py_ldb_setup_wellknown_attributes(PyLdbObject
*self
)
664 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ldb_setup_wellknown_attributes(PyLdb_AsLdbContext(self
)), PyLdb_AsLdbContext(self
));
668 static PyObject
*py_ldb_repr(PyLdbObject
*self
)
670 return PyString_FromFormat("<ldb connection>");
673 static PyObject
*py_ldb_get_root_basedn(PyLdbObject
*self
)
675 struct ldb_dn
*dn
= ldb_get_root_basedn(PyLdb_AsLdbContext(self
));
678 return PyLdbDn_FromDn(dn
);
682 static PyObject
*py_ldb_get_schema_basedn(PyLdbObject
*self
)
684 struct ldb_dn
*dn
= ldb_get_schema_basedn(PyLdb_AsLdbContext(self
));
687 return PyLdbDn_FromDn(dn
);
690 static PyObject
*py_ldb_get_config_basedn(PyLdbObject
*self
)
692 struct ldb_dn
*dn
= ldb_get_config_basedn(PyLdb_AsLdbContext(self
));
695 return PyLdbDn_FromDn(dn
);
698 static PyObject
*py_ldb_get_default_basedn(PyLdbObject
*self
)
700 struct ldb_dn
*dn
= ldb_get_default_basedn(PyLdb_AsLdbContext(self
));
703 return PyLdbDn_FromDn(dn
);
706 static const char **PyList_AsStringList(TALLOC_CTX
*mem_ctx
, PyObject
*list
,
707 const char *paramname
)
711 if (!PyList_Check(list
)) {
712 PyErr_Format(PyExc_TypeError
, "%s is not a list", paramname
);
715 ret
= talloc_array(NULL
, const char *, PyList_Size(list
)+1);
721 for (i
= 0; i
< PyList_Size(list
); i
++) {
722 PyObject
*item
= PyList_GetItem(list
, i
);
723 if (!PyString_Check(item
)) {
724 PyErr_Format(PyExc_TypeError
, "%s should be strings", paramname
);
727 ret
[i
] = talloc_strndup(ret
, PyString_AsString(item
),
728 PyString_Size(item
));
734 static int py_ldb_init(PyLdbObject
*self
, PyObject
*args
, PyObject
*kwargs
)
736 const char * const kwnames
[] = { "url", "flags", "options", NULL
};
738 PyObject
*py_options
= Py_None
;
739 const char **options
;
740 unsigned int flags
= 0;
742 struct ldb_context
*ldb
;
744 if (!PyArg_ParseTupleAndKeywords(args
, kwargs
, "|zIO:Ldb.__init__",
745 discard_const_p(char *, kwnames
),
746 &url
, &flags
, &py_options
))
749 ldb
= PyLdb_AsLdbContext(self
);
751 if (py_options
== Py_None
) {
754 options
= PyList_AsStringList(ldb
, py_options
, "options");
760 ret
= ldb_connect(ldb
, url
, flags
, options
);
761 if (ret
!= LDB_SUCCESS
) {
762 PyErr_SetLdbError(PyExc_LdbError
, ret
, ldb
);
767 talloc_free(options
);
771 static PyObject
*py_ldb_new(PyTypeObject
*type
, PyObject
*args
, PyObject
*kwargs
)
774 struct ldb_context
*ldb
;
775 ret
= (PyLdbObject
*)type
->tp_alloc(type
, 0);
780 ret
->mem_ctx
= talloc_new(NULL
);
781 ldb
= ldb_init(ret
->mem_ctx
, NULL
);
789 return (PyObject
*)ret
;
792 static PyObject
*py_ldb_connect(PyLdbObject
*self
, PyObject
*args
, PyObject
*kwargs
)
795 unsigned int flags
= 0;
796 PyObject
*py_options
= Py_None
;
798 const char **options
;
799 const char * const kwnames
[] = { "url", "flags", "options", NULL
};
801 if (!PyArg_ParseTupleAndKeywords(args
, kwargs
, "|zIO",
802 discard_const_p(char *, kwnames
),
803 &url
, &flags
, &py_options
))
806 if (py_options
== Py_None
) {
809 options
= PyList_AsStringList(NULL
, py_options
, "options");
814 ret
= ldb_connect(PyLdb_AsLdbContext(self
), url
, flags
, options
);
815 talloc_free(options
);
817 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ret
, PyLdb_AsLdbContext(self
));
822 static PyObject
*py_ldb_modify(PyLdbObject
*self
, PyObject
*args
, PyObject
*kwargs
)
825 PyObject
*py_controls
= Py_None
;
826 struct ldb_context
*ldb_ctx
;
827 struct ldb_request
*req
;
828 struct ldb_control
**parsed_controls
;
829 struct ldb_message
*msg
;
833 const char * const kwnames
[] = { "message", "controls", "validate", NULL
};
835 if (!PyArg_ParseTupleAndKeywords(args
, kwargs
, "O|Ob",
836 discard_const_p(char *, kwnames
),
837 &py_msg
, &py_controls
, &validate
))
840 mem_ctx
= talloc_new(NULL
);
841 if (mem_ctx
== NULL
) {
845 ldb_ctx
= PyLdb_AsLdbContext(self
);
847 if (py_controls
== Py_None
) {
848 parsed_controls
= NULL
;
850 const char **controls
= PyList_AsStringList(mem_ctx
, py_controls
, "controls");
851 parsed_controls
= ldb_parse_control_strings(ldb_ctx
, mem_ctx
, controls
);
852 talloc_free(controls
);
855 if (!PyLdbMessage_Check(py_msg
)) {
856 PyErr_SetString(PyExc_TypeError
, "Expected Ldb Message");
857 talloc_free(mem_ctx
);
860 msg
= PyLdbMessage_AsMessage(py_msg
);
863 ret
= ldb_msg_sanity_check(ldb_ctx
, msg
);
864 if (ret
!= LDB_SUCCESS
) {
865 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ret
, ldb_ctx
);
866 talloc_free(mem_ctx
);
871 ret
= ldb_build_mod_req(&req
, ldb_ctx
, mem_ctx
, msg
, parsed_controls
,
872 NULL
, ldb_op_default_callback
, NULL
);
873 if (ret
!= LDB_SUCCESS
) {
874 PyErr_SetString(PyExc_TypeError
, "failed to build request");
875 talloc_free(mem_ctx
);
879 /* do request and autostart a transaction */
880 /* Then let's LDB handle the message error in case of pb as they are meaningful */
882 ret
= ldb_transaction_start(ldb_ctx
);
883 if (ret
!= LDB_SUCCESS
) {
884 talloc_free(mem_ctx
);
885 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ret
, ldb_ctx
);
888 ret
= ldb_request(ldb_ctx
, req
);
889 if (ret
== LDB_SUCCESS
) {
890 ret
= ldb_wait(req
->handle
, LDB_WAIT_ALL
);
893 if (ret
== LDB_SUCCESS
) {
894 ret
= ldb_transaction_commit(ldb_ctx
);
896 ldb_transaction_cancel(ldb_ctx
);
897 if (ldb_ctx
->err_string
== NULL
) {
898 /* no error string was setup by the backend */
899 ldb_asprintf_errstring(ldb_ctx
, "%s (%d)", ldb_strerror(ret
), ret
);
903 talloc_free(mem_ctx
);
904 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ret
, ldb_ctx
);
911 * Obtain a ldb message from a Python Dictionary object.
913 * @param mem_ctx Memory context
914 * @param py_obj Python Dictionary object
915 * @param ldb_ctx LDB context
916 * @param mod_flags Flags to be set on every message element
917 * @return ldb_message on success or NULL on failure
919 static struct ldb_message
*PyDict_AsMessage(TALLOC_CTX
*mem_ctx
,
921 struct ldb_context
*ldb_ctx
,
922 unsigned int mod_flags
)
924 struct ldb_message
*msg
;
925 unsigned int msg_pos
= 0;
926 Py_ssize_t dict_pos
= 0;
927 PyObject
*key
, *value
;
928 struct ldb_message_element
*msg_el
;
929 PyObject
*dn_value
= PyDict_GetItemString(py_obj
, "dn");
931 msg
= ldb_msg_new(mem_ctx
);
932 msg
->elements
= talloc_zero_array(msg
, struct ldb_message_element
, PyDict_Size(py_obj
));
935 if (!PyObject_AsDn(msg
, dn_value
, ldb_ctx
, &msg
->dn
)) {
936 PyErr_SetString(PyExc_TypeError
, "unable to import dn object");
939 if (msg
->dn
== NULL
) {
940 PyErr_SetString(PyExc_TypeError
, "dn set but not found");
944 PyErr_SetString(PyExc_TypeError
, "no dn set");
948 while (PyDict_Next(py_obj
, &dict_pos
, &key
, &value
)) {
949 char *key_str
= PyString_AsString(key
);
950 if (strcmp(key_str
, "dn") != 0) {
951 msg_el
= PyObject_AsMessageElement(msg
->elements
, value
,
953 if (msg_el
== NULL
) {
954 PyErr_SetString(PyExc_TypeError
, "unable to import element");
957 memcpy(&msg
->elements
[msg_pos
], msg_el
, sizeof(*msg_el
));
962 msg
->num_elements
= msg_pos
;
967 static PyObject
*py_ldb_add(PyLdbObject
*self
, PyObject
*args
, PyObject
*kwargs
)
971 struct ldb_context
*ldb_ctx
;
972 struct ldb_request
*req
;
973 struct ldb_message
*msg
= NULL
;
974 PyObject
*py_controls
= Py_None
;
976 struct ldb_control
**parsed_controls
;
977 const char * const kwnames
[] = { "message", "controls", NULL
};
979 if (!PyArg_ParseTupleAndKeywords(args
, kwargs
, "O|O",
980 discard_const_p(char *, kwnames
),
981 &py_obj
, &py_controls
))
984 mem_ctx
= talloc_new(NULL
);
985 if (mem_ctx
== NULL
) {
989 ldb_ctx
= PyLdb_AsLdbContext(self
);
991 if (py_controls
== Py_None
) {
992 parsed_controls
= NULL
;
994 const char **controls
= PyList_AsStringList(mem_ctx
, py_controls
, "controls");
995 parsed_controls
= ldb_parse_control_strings(ldb_ctx
, mem_ctx
, controls
);
996 talloc_free(controls
);
999 if (PyLdbMessage_Check(py_obj
)) {
1000 msg
= PyLdbMessage_AsMessage(py_obj
);
1001 } else if (PyDict_Check(py_obj
)) {
1002 msg
= PyDict_AsMessage(mem_ctx
, py_obj
, ldb_ctx
, LDB_FLAG_MOD_ADD
);
1004 PyErr_SetString(PyExc_TypeError
,
1005 "Dictionary or LdbMessage object expected!");
1009 /* we should have a PyErr already set */
1010 talloc_free(mem_ctx
);
1014 ret
= ldb_msg_sanity_check(ldb_ctx
, msg
);
1015 if (ret
!= LDB_SUCCESS
) {
1016 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ret
, ldb_ctx
);
1017 talloc_free(mem_ctx
);
1021 ret
= ldb_build_add_req(&req
, ldb_ctx
, mem_ctx
, msg
, parsed_controls
,
1022 NULL
, ldb_op_default_callback
, NULL
);
1023 if (ret
!= LDB_SUCCESS
) {
1024 PyErr_SetString(PyExc_TypeError
, "failed to build request");
1025 talloc_free(mem_ctx
);
1029 /* do request and autostart a transaction */
1030 /* Then let's LDB handle the message error in case of pb as they are meaningful */
1032 ret
= ldb_transaction_start(ldb_ctx
);
1033 if (ret
!= LDB_SUCCESS
) {
1034 talloc_free(mem_ctx
);
1035 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ret
, ldb_ctx
);
1038 ret
= ldb_request(ldb_ctx
, req
);
1039 if (ret
== LDB_SUCCESS
) {
1040 ret
= ldb_wait(req
->handle
, LDB_WAIT_ALL
);
1043 if (ret
== LDB_SUCCESS
) {
1044 ret
= ldb_transaction_commit(ldb_ctx
);
1046 ldb_transaction_cancel(ldb_ctx
);
1047 if (ldb_ctx
->err_string
== NULL
) {
1048 /* no error string was setup by the backend */
1049 ldb_asprintf_errstring(ldb_ctx
, "%s (%d)", ldb_strerror(ret
), ret
);
1053 talloc_free(mem_ctx
);
1054 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ret
, ldb_ctx
);
1059 static PyObject
*py_ldb_delete(PyLdbObject
*self
, PyObject
*args
, PyObject
*kwargs
)
1064 struct ldb_context
*ldb_ctx
;
1065 struct ldb_request
*req
;
1066 PyObject
*py_controls
= Py_None
;
1067 TALLOC_CTX
*mem_ctx
;
1068 struct ldb_control
**parsed_controls
;
1069 const char * const kwnames
[] = { "dn", "controls", NULL
};
1071 if (!PyArg_ParseTupleAndKeywords(args
, kwargs
, "O|O",
1072 discard_const_p(char *, kwnames
),
1073 &py_dn
, &py_controls
))
1076 mem_ctx
= talloc_new(NULL
);
1077 if (mem_ctx
== NULL
) {
1081 ldb_ctx
= PyLdb_AsLdbContext(self
);
1083 if (py_controls
== Py_None
) {
1084 parsed_controls
= NULL
;
1086 const char **controls
= PyList_AsStringList(mem_ctx
, py_controls
, "controls");
1087 parsed_controls
= ldb_parse_control_strings(ldb_ctx
, mem_ctx
, controls
);
1088 talloc_free(controls
);
1091 if (!PyObject_AsDn(mem_ctx
, py_dn
, ldb_ctx
, &dn
)) {
1092 talloc_free(mem_ctx
);
1096 ret
= ldb_build_del_req(&req
, ldb_ctx
, mem_ctx
, dn
, parsed_controls
,
1097 NULL
, ldb_op_default_callback
, NULL
);
1098 if (ret
!= LDB_SUCCESS
) {
1099 PyErr_SetString(PyExc_TypeError
, "failed to build request");
1100 talloc_free(mem_ctx
);
1104 /* do request and autostart a transaction */
1105 /* Then let's LDB handle the message error in case of pb as they are meaningful */
1107 ret
= ldb_transaction_start(ldb_ctx
);
1108 if (ret
!= LDB_SUCCESS
) {
1109 talloc_free(mem_ctx
);
1110 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ret
, ldb_ctx
);
1113 ret
= ldb_request(ldb_ctx
, req
);
1114 if (ret
== LDB_SUCCESS
) {
1115 ret
= ldb_wait(req
->handle
, LDB_WAIT_ALL
);
1118 if (ret
== LDB_SUCCESS
) {
1119 ret
= ldb_transaction_commit(ldb_ctx
);
1121 ldb_transaction_cancel(ldb_ctx
);
1122 if (ldb_ctx
->err_string
== NULL
) {
1123 /* no error string was setup by the backend */
1124 ldb_asprintf_errstring(ldb_ctx
, "%s (%d)", ldb_strerror(ret
), ret
);
1128 talloc_free(mem_ctx
);
1129 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ret
, ldb_ctx
);
1134 static PyObject
*py_ldb_rename(PyLdbObject
*self
, PyObject
*args
, PyObject
*kwargs
)
1136 PyObject
*py_dn1
, *py_dn2
;
1137 struct ldb_dn
*dn1
, *dn2
;
1139 struct ldb_context
*ldb
;
1140 TALLOC_CTX
*mem_ctx
;
1141 PyObject
*py_controls
= Py_None
;
1142 struct ldb_control
**parsed_controls
;
1143 struct ldb_context
*ldb_ctx
;
1144 struct ldb_request
*req
;
1145 const char * const kwnames
[] = { "dn1", "dn2", "controls", NULL
};
1147 ldb_ctx
= PyLdb_AsLdbContext(self
);
1149 if (!PyArg_ParseTupleAndKeywords(args
, kwargs
, "OO|O",
1150 discard_const_p(char *, kwnames
),
1151 &py_dn1
, &py_dn2
, &py_controls
))
1155 mem_ctx
= talloc_new(NULL
);
1156 if (mem_ctx
== NULL
) {
1160 ldb
= PyLdb_AsLdbContext(self
);
1162 if (py_controls
== Py_None
) {
1163 parsed_controls
= NULL
;
1165 const char **controls
= PyList_AsStringList(mem_ctx
, py_controls
, "controls");
1166 parsed_controls
= ldb_parse_control_strings(ldb_ctx
, mem_ctx
, controls
);
1167 talloc_free(controls
);
1171 if (!PyObject_AsDn(mem_ctx
, py_dn1
, ldb
, &dn1
)) {
1172 talloc_free(mem_ctx
);
1176 if (!PyObject_AsDn(mem_ctx
, py_dn2
, ldb
, &dn2
)) {
1177 talloc_free(mem_ctx
);
1181 ret
= ldb_build_rename_req(&req
, ldb_ctx
, mem_ctx
, dn1
, dn2
, parsed_controls
,
1182 NULL
, ldb_op_default_callback
, NULL
);
1183 if (ret
!= LDB_SUCCESS
) {
1184 PyErr_SetString(PyExc_TypeError
, "failed to build request");
1185 talloc_free(mem_ctx
);
1189 /* do request and autostart a transaction */
1190 /* Then let's LDB handle the message error in case of pb as they are meaningful */
1192 ret
= ldb_transaction_start(ldb_ctx
);
1193 if (ret
!= LDB_SUCCESS
) {
1194 talloc_free(mem_ctx
);
1195 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ret
, ldb_ctx
);
1198 ret
= ldb_request(ldb_ctx
, req
);
1199 if (ret
== LDB_SUCCESS
) {
1200 ret
= ldb_wait(req
->handle
, LDB_WAIT_ALL
);
1203 if (ret
== LDB_SUCCESS
) {
1204 ret
= ldb_transaction_commit(ldb_ctx
);
1206 ldb_transaction_cancel(ldb_ctx
);
1207 if (ldb_ctx
->err_string
== NULL
) {
1208 /* no error string was setup by the backend */
1209 ldb_asprintf_errstring(ldb_ctx
, "%s (%d)", ldb_strerror(ret
), ret
);
1213 talloc_free(mem_ctx
);
1214 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ret
, ldb_ctx
);
1219 static PyObject
*py_ldb_schema_attribute_remove(PyLdbObject
*self
, PyObject
*args
)
1222 if (!PyArg_ParseTuple(args
, "s", &name
))
1225 ldb_schema_attribute_remove(PyLdb_AsLdbContext(self
), name
);
1230 static PyObject
*py_ldb_schema_attribute_add(PyLdbObject
*self
, PyObject
*args
)
1232 char *attribute
, *syntax
;
1235 if (!PyArg_ParseTuple(args
, "sIs", &attribute
, &flags
, &syntax
))
1238 ret
= ldb_schema_attribute_add(PyLdb_AsLdbContext(self
), attribute
, flags
, syntax
);
1240 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ret
, PyLdb_AsLdbContext(self
));
1245 static PyObject
*ldb_ldif_to_pyobject(struct ldb_ldif
*ldif
)
1250 /* We don't want this attached to the 'ldb' any more */
1251 return Py_BuildValue(discard_const_p(char, "(iO)"),
1253 PyLdbMessage_FromMessage(ldif
->msg
));
1258 static PyObject
*py_ldb_write_ldif(PyLdbObject
*self
, PyObject
*args
)
1262 struct ldb_ldif ldif
;
1265 TALLOC_CTX
*mem_ctx
;
1267 if (!PyArg_ParseTuple(args
, "Oi", &py_msg
, &changetype
))
1270 if (!PyLdbMessage_Check(py_msg
)) {
1271 PyErr_SetString(PyExc_TypeError
, "Expected Ldb Message for msg");
1275 ldif
.msg
= PyLdbMessage_AsMessage(py_msg
);
1276 ldif
.changetype
= changetype
;
1278 mem_ctx
= talloc_new(NULL
);
1280 string
= ldb_ldif_write_string(PyLdb_AsLdbContext(self
), mem_ctx
, &ldif
);
1282 PyErr_SetString(PyExc_KeyError
, "Failed to generate LDIF");
1286 ret
= PyString_FromString(string
);
1288 talloc_free(mem_ctx
);
1293 static PyObject
*py_ldb_parse_ldif(PyLdbObject
*self
, PyObject
*args
)
1296 struct ldb_ldif
*ldif
;
1299 TALLOC_CTX
*mem_ctx
;
1301 if (!PyArg_ParseTuple(args
, "s", &s
))
1304 mem_ctx
= talloc_new(NULL
);
1309 list
= PyList_New(0);
1310 while (s
&& *s
!= '\0') {
1311 ldif
= ldb_ldif_read_string(self
->ldb_ctx
, &s
);
1312 talloc_steal(mem_ctx
, ldif
);
1314 PyList_Append(list
, ldb_ldif_to_pyobject(ldif
));
1316 PyErr_SetString(PyExc_ValueError
, "unable to parse ldif string");
1317 talloc_free(mem_ctx
);
1321 talloc_free(mem_ctx
); /* The pyobject already has a reference to the things it needs */
1322 return PyObject_GetIter(list
);
1325 static PyObject
*py_ldb_msg_diff(PyLdbObject
*self
, PyObject
*args
)
1328 PyObject
*py_msg_old
;
1329 PyObject
*py_msg_new
;
1330 struct ldb_message
*diff
;
1331 struct ldb_context
*ldb
;
1334 if (!PyArg_ParseTuple(args
, "OO", &py_msg_old
, &py_msg_new
))
1337 if (!PyLdbMessage_Check(py_msg_old
)) {
1338 PyErr_SetString(PyExc_TypeError
, "Expected Ldb Message for old message");
1342 if (!PyLdbMessage_Check(py_msg_new
)) {
1343 PyErr_SetString(PyExc_TypeError
, "Expected Ldb Message for new message");
1347 ldb
= PyLdb_AsLdbContext(self
);
1348 ldb_ret
= ldb_msg_difference(ldb
, ldb
,
1349 PyLdbMessage_AsMessage(py_msg_old
),
1350 PyLdbMessage_AsMessage(py_msg_new
),
1352 if (ldb_ret
!= LDB_SUCCESS
) {
1353 PyErr_SetString(PyExc_RuntimeError
, "Failed to generate the Ldb Message diff");
1357 py_ret
= PyLdbMessage_FromMessage(diff
);
1359 talloc_unlink(ldb
, diff
);
1364 static PyObject
*py_ldb_schema_format_value(PyLdbObject
*self
, PyObject
*args
)
1366 const struct ldb_schema_attribute
*a
;
1367 struct ldb_val old_val
;
1368 struct ldb_val new_val
;
1369 TALLOC_CTX
*mem_ctx
;
1374 if (!PyArg_ParseTuple(args
, "sO", &element_name
, &val
))
1377 mem_ctx
= talloc_new(NULL
);
1379 old_val
.data
= (uint8_t *)PyString_AsString(val
);
1380 old_val
.length
= PyString_Size(val
);
1382 a
= ldb_schema_attribute_by_name(PyLdb_AsLdbContext(self
), element_name
);
1388 if (a
->syntax
->ldif_write_fn(PyLdb_AsLdbContext(self
), mem_ctx
, &old_val
, &new_val
) != 0) {
1389 talloc_free(mem_ctx
);
1393 ret
= PyString_FromStringAndSize((const char *)new_val
.data
, new_val
.length
);
1395 talloc_free(mem_ctx
);
1400 static PyObject
*py_ldb_search(PyLdbObject
*self
, PyObject
*args
, PyObject
*kwargs
)
1402 PyObject
*py_base
= Py_None
;
1403 int scope
= LDB_SCOPE_DEFAULT
;
1405 PyObject
*py_attrs
= Py_None
;
1406 PyObject
*py_controls
= Py_None
;
1407 const char * const kwnames
[] = { "base", "scope", "expression", "attrs", "controls", NULL
};
1409 struct ldb_result
*res
;
1410 struct ldb_request
*req
;
1412 struct ldb_context
*ldb_ctx
;
1413 struct ldb_control
**parsed_controls
;
1414 struct ldb_dn
*base
;
1416 TALLOC_CTX
*mem_ctx
;
1418 /* type "int" rather than "enum" for "scope" is intentional */
1419 if (!PyArg_ParseTupleAndKeywords(args
, kwargs
, "|OizOO",
1420 discard_const_p(char *, kwnames
),
1421 &py_base
, &scope
, &expr
, &py_attrs
, &py_controls
))
1425 mem_ctx
= talloc_new(NULL
);
1426 if (mem_ctx
== NULL
) {
1430 ldb_ctx
= PyLdb_AsLdbContext(self
);
1432 if (py_attrs
== Py_None
) {
1435 attrs
= PyList_AsStringList(mem_ctx
, py_attrs
, "attrs");
1436 if (attrs
== NULL
) {
1437 talloc_free(mem_ctx
);
1442 if (py_base
== Py_None
) {
1443 base
= ldb_get_default_basedn(ldb_ctx
);
1445 if (!PyObject_AsDn(ldb_ctx
, py_base
, ldb_ctx
, &base
)) {
1451 if (py_controls
== Py_None
) {
1452 parsed_controls
= NULL
;
1454 const char **controls
= PyList_AsStringList(mem_ctx
, py_controls
, "controls");
1455 parsed_controls
= ldb_parse_control_strings(ldb_ctx
, mem_ctx
, controls
);
1456 talloc_free(controls
);
1459 res
= talloc_zero(mem_ctx
, struct ldb_result
);
1462 talloc_free(mem_ctx
);
1466 ret
= ldb_build_search_req(&req
, ldb_ctx
, mem_ctx
,
1473 ldb_search_default_callback
,
1476 if (ret
!= LDB_SUCCESS
) {
1477 talloc_free(mem_ctx
);
1478 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ret
, ldb_ctx
);
1482 talloc_steal(req
, attrs
);
1484 ret
= ldb_request(ldb_ctx
, req
);
1486 if (ret
== LDB_SUCCESS
) {
1487 ret
= ldb_wait(req
->handle
, LDB_WAIT_ALL
);
1490 if (ret
!= LDB_SUCCESS
) {
1491 talloc_free(mem_ctx
);
1492 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ret
, ldb_ctx
);
1496 py_ret
= PyLdbResult_FromResult(res
);
1498 talloc_free(mem_ctx
);
1503 static PyObject
*py_ldb_get_opaque(PyLdbObject
*self
, PyObject
*args
)
1508 if (!PyArg_ParseTuple(args
, "s", &name
))
1511 data
= ldb_get_opaque(PyLdb_AsLdbContext(self
), name
);
1516 /* FIXME: More interpretation */
1521 static PyObject
*py_ldb_set_opaque(PyLdbObject
*self
, PyObject
*args
)
1526 if (!PyArg_ParseTuple(args
, "sO", &name
, &data
))
1529 /* FIXME: More interpretation */
1531 ldb_set_opaque(PyLdb_AsLdbContext(self
), name
, data
);
1536 static PyObject
*py_ldb_modules(PyLdbObject
*self
)
1538 struct ldb_context
*ldb
= PyLdb_AsLdbContext(self
);
1539 PyObject
*ret
= PyList_New(0);
1540 struct ldb_module
*mod
;
1542 for (mod
= ldb
->modules
; mod
; mod
= mod
->next
) {
1543 PyList_Append(ret
, PyLdbModule_FromModule(mod
));
1549 static PyObject
*py_ldb_sequence_number(PyLdbObject
*self
, PyObject
*args
)
1551 struct ldb_context
*ldb
= PyLdb_AsLdbContext(self
);
1555 if (!PyArg_ParseTuple(args
, "i", &type
))
1558 /* FIXME: More interpretation */
1560 ret
= ldb_sequence_number(ldb
, type
, &value
);
1562 if (ret
!= LDB_SUCCESS
) {
1563 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ret
, ldb
);
1566 return PyLong_FromLongLong(value
);
1568 static PyMethodDef py_ldb_methods
[] = {
1569 { "set_debug", (PyCFunction
)py_ldb_set_debug
, METH_VARARGS
,
1570 "S.set_debug(callback) -> None\n"
1571 "Set callback for LDB debug messages.\n"
1572 "The callback should accept a debug level and debug text." },
1573 { "set_create_perms", (PyCFunction
)py_ldb_set_create_perms
, METH_VARARGS
,
1574 "S.set_create_perms(mode) -> None\n"
1575 "Set mode to use when creating new LDB files." },
1576 { "set_modules_dir", (PyCFunction
)py_ldb_set_modules_dir
, METH_VARARGS
,
1577 "S.set_modules_dir(path) -> None\n"
1578 "Set path LDB should search for modules" },
1579 { "transaction_start", (PyCFunction
)py_ldb_transaction_start
, METH_NOARGS
,
1580 "S.transaction_start() -> None\n"
1581 "Start a new transaction." },
1582 { "transaction_prepare_commit", (PyCFunction
)py_ldb_transaction_prepare_commit
, METH_NOARGS
,
1583 "S.transaction_prepare_commit() -> None\n"
1584 "prepare to commit a new transaction (2-stage commit)." },
1585 { "transaction_commit", (PyCFunction
)py_ldb_transaction_commit
, METH_NOARGS
,
1586 "S.transaction_commit() -> None\n"
1587 "commit a new transaction." },
1588 { "transaction_cancel", (PyCFunction
)py_ldb_transaction_cancel
, METH_NOARGS
,
1589 "S.transaction_cancel() -> None\n"
1590 "cancel a new transaction." },
1591 { "setup_wellknown_attributes", (PyCFunction
)py_ldb_setup_wellknown_attributes
, METH_NOARGS
,
1593 { "get_root_basedn", (PyCFunction
)py_ldb_get_root_basedn
, METH_NOARGS
,
1595 { "get_schema_basedn", (PyCFunction
)py_ldb_get_schema_basedn
, METH_NOARGS
,
1597 { "get_default_basedn", (PyCFunction
)py_ldb_get_default_basedn
, METH_NOARGS
,
1599 { "get_config_basedn", (PyCFunction
)py_ldb_get_config_basedn
, METH_NOARGS
,
1601 { "connect", (PyCFunction
)py_ldb_connect
, METH_VARARGS
|METH_KEYWORDS
,
1602 "S.connect(url, flags=0, options=None) -> None\n"
1603 "Connect to a LDB URL." },
1604 { "modify", (PyCFunction
)py_ldb_modify
, METH_VARARGS
|METH_KEYWORDS
,
1605 "S.modify(message, controls=None, validate=False) -> None\n"
1606 "Modify an entry." },
1607 { "add", (PyCFunction
)py_ldb_add
, METH_VARARGS
|METH_KEYWORDS
,
1608 "S.add(message, controls=None) -> None\n"
1610 { "delete", (PyCFunction
)py_ldb_delete
, METH_VARARGS
|METH_KEYWORDS
,
1611 "S.delete(dn, controls=None) -> None\n"
1612 "Remove an entry." },
1613 { "rename", (PyCFunction
)py_ldb_rename
, METH_VARARGS
|METH_KEYWORDS
,
1614 "S.rename(old_dn, new_dn, controls=None) -> None\n"
1615 "Rename an entry." },
1616 { "search", (PyCFunction
)py_ldb_search
, METH_VARARGS
|METH_KEYWORDS
,
1617 "S.search(base=None, scope=None, expression=None, attrs=None, controls=None) -> msgs\n"
1618 "Search in a database.\n"
1620 ":param base: Optional base DN to search\n"
1621 ":param scope: Search scope (SCOPE_BASE, SCOPE_ONELEVEL or SCOPE_SUBTREE)\n"
1622 ":param expression: Optional search expression\n"
1623 ":param attrs: Attributes to return (defaults to all)\n"
1624 ":param controls: Optional list of controls\n"
1625 ":return: Iterator over Message objects\n"
1627 { "schema_attribute_remove", (PyCFunction
)py_ldb_schema_attribute_remove
, METH_VARARGS
,
1629 { "schema_attribute_add", (PyCFunction
)py_ldb_schema_attribute_add
, METH_VARARGS
,
1631 { "schema_format_value", (PyCFunction
)py_ldb_schema_format_value
, METH_VARARGS
,
1633 { "parse_ldif", (PyCFunction
)py_ldb_parse_ldif
, METH_VARARGS
,
1634 "S.parse_ldif(ldif) -> iter(messages)\n"
1635 "Parse a string formatted using LDIF." },
1636 { "write_ldif", (PyCFunction
)py_ldb_write_ldif
, METH_VARARGS
,
1637 "S.write_ldif(message, changetype) -> ldif\n"
1638 "Print the message as a string formatted using LDIF." },
1639 { "msg_diff", (PyCFunction
)py_ldb_msg_diff
, METH_VARARGS
,
1640 "S.msg_diff(Message) -> Message\n"
1641 "Return an LDB Message of the difference between two Message objects." },
1642 { "get_opaque", (PyCFunction
)py_ldb_get_opaque
, METH_VARARGS
,
1643 "S.get_opaque(name) -> value\n"
1644 "Get an opaque value set on this LDB connection. \n"
1645 ":note: The returned value may not be useful in Python."
1647 { "set_opaque", (PyCFunction
)py_ldb_set_opaque
, METH_VARARGS
,
1648 "S.set_opaque(name, value) -> None\n"
1649 "Set an opaque value on this LDB connection. \n"
1650 ":note: Passing incorrect values may cause crashes." },
1651 { "modules", (PyCFunction
)py_ldb_modules
, METH_NOARGS
,
1652 "S.modules() -> list\n"
1653 "Return the list of modules on this LDB connection " },
1654 { "sequence_number", (PyCFunction
)py_ldb_sequence_number
, METH_VARARGS
,
1655 "S.sequence_number(type) -> value\n"
1656 "Return the value of the sequence according to the requested type" },
1660 static PyObject
*PyLdbModule_FromModule(struct ldb_module
*mod
)
1662 PyLdbModuleObject
*ret
;
1664 ret
= (PyLdbModuleObject
*)PyLdbModule
.tp_alloc(&PyLdbModule
, 0);
1669 ret
->mem_ctx
= talloc_new(NULL
);
1670 ret
->mod
= talloc_reference(ret
->mem_ctx
, mod
);
1671 return (PyObject
*)ret
;
1674 static PyObject
*py_ldb_get_firstmodule(PyLdbObject
*self
, void *closure
)
1676 return PyLdbModule_FromModule(PyLdb_AsLdbContext(self
)->modules
);
1679 static PyGetSetDef py_ldb_getset
[] = {
1680 { discard_const_p(char, "firstmodule"), (getter
)py_ldb_get_firstmodule
, NULL
, NULL
},
1684 static int py_ldb_contains(PyLdbObject
*self
, PyObject
*obj
)
1686 struct ldb_context
*ldb_ctx
= PyLdb_AsLdbContext(self
);
1688 struct ldb_result
*result
;
1692 if (!PyObject_AsDn(ldb_ctx
, obj
, ldb_ctx
, &dn
)) {
1696 ret
= ldb_search(ldb_ctx
, ldb_ctx
, &result
, dn
, LDB_SCOPE_BASE
, NULL
,
1698 if (ret
!= LDB_SUCCESS
) {
1699 PyErr_SetLdbError(PyExc_LdbError
, ret
, ldb_ctx
);
1703 count
= result
->count
;
1705 talloc_free(result
);
1708 PyErr_Format(PyExc_RuntimeError
,
1709 "Searching for [%s] dn gave %u results!",
1710 ldb_dn_get_linearized(dn
),
1718 static PySequenceMethods py_ldb_seq
= {
1719 .sq_contains
= (objobjproc
)py_ldb_contains
,
1722 static PyObject
*PyLdb_FromLdbContext(struct ldb_context
*ldb_ctx
)
1726 ret
= (PyLdbObject
*)PyLdb
.tp_alloc(&PyLdb
, 0);
1731 ret
->mem_ctx
= talloc_new(NULL
);
1732 ret
->ldb_ctx
= talloc_reference(ret
->mem_ctx
, ldb_ctx
);
1733 return (PyObject
*)ret
;
1736 static void py_ldb_dealloc(PyLdbObject
*self
)
1738 talloc_free(self
->mem_ctx
);
1739 self
->ob_type
->tp_free(self
);
1742 static PyTypeObject PyLdb
= {
1743 .tp_name
= "ldb.Ldb",
1744 .tp_methods
= py_ldb_methods
,
1745 .tp_repr
= (reprfunc
)py_ldb_repr
,
1746 .tp_new
= py_ldb_new
,
1747 .tp_init
= (initproc
)py_ldb_init
,
1748 .tp_dealloc
= (destructor
)py_ldb_dealloc
,
1749 .tp_getset
= py_ldb_getset
,
1750 .tp_getattro
= PyObject_GenericGetAttr
,
1751 .tp_basicsize
= sizeof(PyLdbObject
),
1752 .tp_doc
= "Connection to a LDB database.",
1753 .tp_as_sequence
= &py_ldb_seq
,
1754 .tp_flags
= Py_TPFLAGS_DEFAULT
|Py_TPFLAGS_BASETYPE
,
1757 static void py_ldb_result_dealloc(PyLdbResultObject
*self
)
1759 talloc_free(self
->mem_ctx
);
1760 Py_DECREF(self
->msgs
);
1761 Py_DECREF(self
->referals
);
1762 Py_DECREF(self
->controls
);
1763 self
->ob_type
->tp_free(self
);
1766 static PyObject
*py_ldb_result_get_msgs(PyLdbResultObject
*self
, void *closure
)
1768 Py_INCREF(self
->msgs
);
1772 static PyObject
*py_ldb_result_get_controls(PyLdbResultObject
*self
, void *closure
)
1774 Py_INCREF(self
->controls
);
1775 return self
->controls
;
1778 static PyObject
*py_ldb_result_get_referals(PyLdbResultObject
*self
, void *closure
)
1780 Py_INCREF(self
->referals
);
1781 return self
->referals
;
1784 static PyObject
*py_ldb_result_get_count(PyLdbResultObject
*self
, void *closure
)
1787 if (self
->msgs
== NULL
) {
1788 PyErr_SetString(PyExc_AttributeError
, "Count attribute is meaningless in this context");
1791 size
= PyList_Size(self
->msgs
);
1792 return PyInt_FromLong(size
);
1795 static PyGetSetDef py_ldb_result_getset
[] = {
1796 { discard_const_p(char, "controls"), (getter
)py_ldb_result_get_controls
, NULL
, NULL
},
1797 { discard_const_p(char, "msgs"), (getter
)py_ldb_result_get_msgs
, NULL
, NULL
},
1798 { discard_const_p(char, "referals"), (getter
)py_ldb_result_get_referals
, NULL
, NULL
},
1799 { discard_const_p(char, "count"), (getter
)py_ldb_result_get_count
, NULL
, NULL
},
1803 static PyObject
*py_ldb_result_iter(PyLdbResultObject
*self
)
1805 return PyObject_GetIter(self
->msgs
);
1808 static Py_ssize_t
py_ldb_result_len(PyLdbResultObject
*self
)
1810 return PySequence_Size(self
->msgs
);
1813 static PyObject
*py_ldb_result_find(PyLdbResultObject
*self
, Py_ssize_t idx
)
1815 return PySequence_GetItem(self
->msgs
, idx
);
1818 static PySequenceMethods py_ldb_result_seq
= {
1819 .sq_length
= (lenfunc
)py_ldb_result_len
,
1820 .sq_item
= (ssizeargfunc
)py_ldb_result_find
,
1823 static PyObject
*py_ldb_result_repr(PyLdbObject
*self
)
1825 return PyString_FromFormat("<ldb result>");
1829 static PyTypeObject PyLdbResult
= {
1830 .tp_name
= "ldb.Result",
1831 .tp_repr
= (reprfunc
)py_ldb_result_repr
,
1832 .tp_dealloc
= (destructor
)py_ldb_result_dealloc
,
1833 .tp_iter
= (getiterfunc
)py_ldb_result_iter
,
1834 .tp_getset
= py_ldb_result_getset
,
1835 .tp_getattro
= PyObject_GenericGetAttr
,
1836 .tp_basicsize
= sizeof(PyLdbResultObject
),
1837 .tp_as_sequence
= &py_ldb_result_seq
,
1838 .tp_doc
= "LDB result.",
1839 .tp_flags
= Py_TPFLAGS_DEFAULT
|Py_TPFLAGS_BASETYPE
,
1842 static PyObject
*py_ldb_module_repr(PyLdbModuleObject
*self
)
1844 return PyString_FromFormat("<ldb module '%s'>", PyLdbModule_AsModule(self
)->ops
->name
);
1847 static PyObject
*py_ldb_module_str(PyLdbModuleObject
*self
)
1849 return PyString_FromString(PyLdbModule_AsModule(self
)->ops
->name
);
1852 static PyObject
*py_ldb_module_start_transaction(PyLdbModuleObject
*self
)
1854 PyLdbModule_AsModule(self
)->ops
->start_transaction(PyLdbModule_AsModule(self
));
1858 static PyObject
*py_ldb_module_end_transaction(PyLdbModuleObject
*self
)
1860 PyLdbModule_AsModule(self
)->ops
->end_transaction(PyLdbModule_AsModule(self
));
1864 static PyObject
*py_ldb_module_del_transaction(PyLdbModuleObject
*self
)
1866 PyLdbModule_AsModule(self
)->ops
->del_transaction(PyLdbModule_AsModule(self
));
1870 static PyObject
*py_ldb_module_search(PyLdbModuleObject
*self
, PyObject
*args
, PyObject
*kwargs
)
1872 PyObject
*py_base
, *py_tree
, *py_attrs
, *py_ret
;
1874 struct ldb_request
*req
;
1875 const char * const kwnames
[] = { "base", "scope", "tree", "attrs", NULL
};
1876 struct ldb_module
*mod
;
1877 const char * const*attrs
;
1879 /* type "int" rather than "enum" for "scope" is intentional */
1880 if (!PyArg_ParseTupleAndKeywords(args
, kwargs
, "OiOO",
1881 discard_const_p(char *, kwnames
),
1882 &py_base
, &scope
, &py_tree
, &py_attrs
))
1887 if (py_attrs
== Py_None
) {
1890 attrs
= PyList_AsStringList(NULL
, py_attrs
, "attrs");
1895 ret
= ldb_build_search_req(&req
, mod
->ldb
, NULL
, PyLdbDn_AsDn(py_base
),
1896 scope
, NULL
/* expr */, attrs
,
1897 NULL
/* controls */, NULL
, NULL
, NULL
);
1899 talloc_steal(req
, attrs
);
1901 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ret
, mod
->ldb
);
1903 req
->op
.search
.res
= NULL
;
1905 ret
= mod
->ops
->search(mod
, req
);
1907 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ret
, mod
->ldb
);
1909 py_ret
= PyLdbResult_FromResult(req
->op
.search
.res
);
1917 static PyObject
*py_ldb_module_add(PyLdbModuleObject
*self
, PyObject
*args
)
1919 struct ldb_request
*req
;
1920 PyObject
*py_message
;
1922 struct ldb_module
*mod
;
1924 if (!PyArg_ParseTuple(args
, "O", &py_message
))
1927 req
= talloc_zero(NULL
, struct ldb_request
);
1928 req
->operation
= LDB_ADD
;
1929 req
->op
.add
.message
= PyLdbMessage_AsMessage(py_message
);
1931 mod
= PyLdbModule_AsModule(self
);
1932 ret
= mod
->ops
->add(mod
, req
);
1934 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ret
, mod
->ldb
);
1939 static PyObject
*py_ldb_module_modify(PyLdbModuleObject
*self
, PyObject
*args
)
1942 struct ldb_request
*req
;
1943 PyObject
*py_message
;
1944 struct ldb_module
*mod
;
1946 if (!PyArg_ParseTuple(args
, "O", &py_message
))
1949 req
= talloc_zero(NULL
, struct ldb_request
);
1950 req
->operation
= LDB_MODIFY
;
1951 req
->op
.mod
.message
= PyLdbMessage_AsMessage(py_message
);
1953 mod
= PyLdbModule_AsModule(self
);
1954 ret
= mod
->ops
->modify(mod
, req
);
1956 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ret
, mod
->ldb
);
1961 static PyObject
*py_ldb_module_delete(PyLdbModuleObject
*self
, PyObject
*args
)
1964 struct ldb_request
*req
;
1967 if (!PyArg_ParseTuple(args
, "O", &py_dn
))
1970 req
= talloc_zero(NULL
, struct ldb_request
);
1971 req
->operation
= LDB_DELETE
;
1972 req
->op
.del
.dn
= PyLdbDn_AsDn(py_dn
);
1974 ret
= PyLdbModule_AsModule(self
)->ops
->del(PyLdbModule_AsModule(self
), req
);
1976 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ret
, NULL
);
1981 static PyObject
*py_ldb_module_rename(PyLdbModuleObject
*self
, PyObject
*args
)
1984 struct ldb_request
*req
;
1985 PyObject
*py_dn1
, *py_dn2
;
1987 if (!PyArg_ParseTuple(args
, "OO", &py_dn1
, &py_dn2
))
1990 req
= talloc_zero(NULL
, struct ldb_request
);
1992 req
->operation
= LDB_RENAME
;
1993 req
->op
.rename
.olddn
= PyLdbDn_AsDn(py_dn1
);
1994 req
->op
.rename
.newdn
= PyLdbDn_AsDn(py_dn2
);
1996 ret
= PyLdbModule_AsModule(self
)->ops
->rename(PyLdbModule_AsModule(self
), req
);
1998 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ret
, NULL
);
2003 static PyMethodDef py_ldb_module_methods
[] = {
2004 { "search", (PyCFunction
)py_ldb_module_search
, METH_VARARGS
|METH_KEYWORDS
, NULL
},
2005 { "add", (PyCFunction
)py_ldb_module_add
, METH_VARARGS
, NULL
},
2006 { "modify", (PyCFunction
)py_ldb_module_modify
, METH_VARARGS
, NULL
},
2007 { "rename", (PyCFunction
)py_ldb_module_rename
, METH_VARARGS
, NULL
},
2008 { "delete", (PyCFunction
)py_ldb_module_delete
, METH_VARARGS
, NULL
},
2009 { "start_transaction", (PyCFunction
)py_ldb_module_start_transaction
, METH_NOARGS
, NULL
},
2010 { "end_transaction", (PyCFunction
)py_ldb_module_end_transaction
, METH_NOARGS
, NULL
},
2011 { "del_transaction", (PyCFunction
)py_ldb_module_del_transaction
, METH_NOARGS
, NULL
},
2015 static void py_ldb_module_dealloc(PyLdbModuleObject
*self
)
2017 talloc_free(self
->mem_ctx
);
2021 static PyTypeObject PyLdbModule
= {
2022 .tp_name
= "ldb.LdbModule",
2023 .tp_methods
= py_ldb_module_methods
,
2024 .tp_repr
= (reprfunc
)py_ldb_module_repr
,
2025 .tp_str
= (reprfunc
)py_ldb_module_str
,
2026 .tp_basicsize
= sizeof(PyLdbModuleObject
),
2027 .tp_dealloc
= (destructor
)py_ldb_module_dealloc
,
2028 .tp_flags
= Py_TPFLAGS_DEFAULT
,
2033 * Create a ldb_message_element from a Python object.
2035 * This will accept any sequence objects that contains strings, or
2038 * A reference to set_obj will be borrowed.
2040 * @param mem_ctx Memory context
2041 * @param set_obj Python object to convert
2042 * @param flags ldb_message_element flags to set
2043 * @param attr_name Name of the attribute
2044 * @return New ldb_message_element, allocated as child of mem_ctx
2046 static struct ldb_message_element
*PyObject_AsMessageElement(
2047 TALLOC_CTX
*mem_ctx
,
2050 const char *attr_name
)
2052 struct ldb_message_element
*me
;
2054 if (PyLdbMessageElement_Check(set_obj
)) {
2055 PyLdbMessageElementObject
*set_obj_as_me
= (PyLdbMessageElementObject
*)set_obj
;
2056 /* We have to talloc_reference() the memory context, not the pointer
2057 * which may not actually be it's own context */
2058 if (talloc_reference(mem_ctx
, set_obj_as_me
->mem_ctx
)) {
2059 return PyLdbMessageElement_AsMessageElement(set_obj
);
2064 me
= talloc(mem_ctx
, struct ldb_message_element
);
2070 me
->name
= talloc_strdup(me
, attr_name
);
2072 if (PyString_Check(set_obj
)) {
2074 me
->values
= talloc_array(me
, struct ldb_val
, me
->num_values
);
2075 me
->values
[0].length
= PyString_Size(set_obj
);
2076 me
->values
[0].data
= talloc_memdup(me
,
2077 (uint8_t *)PyString_AsString(set_obj
), me
->values
[0].length
+1);
2078 } else if (PySequence_Check(set_obj
)) {
2080 me
->num_values
= PySequence_Size(set_obj
);
2081 me
->values
= talloc_array(me
, struct ldb_val
, me
->num_values
);
2082 for (i
= 0; i
< me
->num_values
; i
++) {
2083 PyObject
*obj
= PySequence_GetItem(set_obj
, i
);
2084 if (!PyString_Check(obj
)) {
2085 PyErr_Format(PyExc_TypeError
,
2086 "Expected string as element %zd in list", i
);
2091 me
->values
[i
].length
= PyString_Size(obj
);
2092 me
->values
[i
].data
= talloc_memdup(me
,
2093 (uint8_t *)PyString_AsString(obj
), me
->values
[i
].length
+1);
2104 static PyObject
*ldb_msg_element_to_set(struct ldb_context
*ldb_ctx
,
2105 struct ldb_message_element
*me
)
2110 /* Python << 2.5 doesn't have PySet_New and PySet_Add. */
2111 result
= PyList_New(me
->num_values
);
2113 for (i
= 0; i
< me
->num_values
; i
++) {
2114 PyList_SetItem(result
, i
,
2115 PyObject_FromLdbValue(&me
->values
[i
]));
2121 static PyObject
*py_ldb_msg_element_get(PyLdbMessageElementObject
*self
, PyObject
*args
)
2124 if (!PyArg_ParseTuple(args
, "I", &i
))
2126 if (i
>= PyLdbMessageElement_AsMessageElement(self
)->num_values
)
2129 return PyObject_FromLdbValue(&(PyLdbMessageElement_AsMessageElement(self
)->values
[i
]));
2132 static PyObject
*py_ldb_msg_element_flags(PyLdbMessageElementObject
*self
, PyObject
*args
)
2134 struct ldb_message_element
*el
= PyLdbMessageElement_AsMessageElement(self
);
2135 return PyInt_FromLong(el
->flags
);
2138 static PyObject
*py_ldb_msg_element_set_flags(PyLdbMessageElementObject
*self
, PyObject
*args
)
2141 struct ldb_message_element
*el
;
2142 if (!PyArg_ParseTuple(args
, "I", &flags
))
2145 el
= PyLdbMessageElement_AsMessageElement(self
);
2150 static PyMethodDef py_ldb_msg_element_methods
[] = {
2151 { "get", (PyCFunction
)py_ldb_msg_element_get
, METH_VARARGS
, NULL
},
2152 { "set_flags", (PyCFunction
)py_ldb_msg_element_set_flags
, METH_VARARGS
, NULL
},
2153 { "flags", (PyCFunction
)py_ldb_msg_element_flags
, METH_NOARGS
, NULL
},
2157 static Py_ssize_t
py_ldb_msg_element_len(PyLdbMessageElementObject
*self
)
2159 return PyLdbMessageElement_AsMessageElement(self
)->num_values
;
2162 static PyObject
*py_ldb_msg_element_find(PyLdbMessageElementObject
*self
, Py_ssize_t idx
)
2164 struct ldb_message_element
*el
= PyLdbMessageElement_AsMessageElement(self
);
2165 if (idx
< 0 || idx
>= el
->num_values
) {
2166 PyErr_SetString(PyExc_IndexError
, "Out of range");
2169 return PyString_FromStringAndSize((char *)el
->values
[idx
].data
, el
->values
[idx
].length
);
2172 static PySequenceMethods py_ldb_msg_element_seq
= {
2173 .sq_length
= (lenfunc
)py_ldb_msg_element_len
,
2174 .sq_item
= (ssizeargfunc
)py_ldb_msg_element_find
,
2177 static int py_ldb_msg_element_cmp(PyLdbMessageElementObject
*self
, PyLdbMessageElementObject
*other
)
2179 int ret
= ldb_msg_element_compare(PyLdbMessageElement_AsMessageElement(self
),
2180 PyLdbMessageElement_AsMessageElement(other
));
2184 static PyObject
*py_ldb_msg_element_iter(PyLdbMessageElementObject
*self
)
2186 return PyObject_GetIter(ldb_msg_element_to_set(NULL
, PyLdbMessageElement_AsMessageElement(self
)));
2189 static PyObject
*PyLdbMessageElement_FromMessageElement(struct ldb_message_element
*el
, TALLOC_CTX
*mem_ctx
)
2191 PyLdbMessageElementObject
*ret
;
2192 ret
= PyObject_New(PyLdbMessageElementObject
, &PyLdbMessageElement
);
2197 ret
->mem_ctx
= talloc_new(NULL
);
2198 if (talloc_reference(ret
->mem_ctx
, mem_ctx
) == NULL
) {
2203 return (PyObject
*)ret
;
2206 static PyObject
*py_ldb_msg_element_new(PyTypeObject
*type
, PyObject
*args
, PyObject
*kwargs
)
2208 PyObject
*py_elements
= NULL
;
2209 struct ldb_message_element
*el
;
2210 unsigned int flags
= 0;
2212 const char * const kwnames
[] = { "elements", "flags", "name", NULL
};
2213 PyLdbMessageElementObject
*ret
;
2214 TALLOC_CTX
*mem_ctx
;
2216 if (!PyArg_ParseTupleAndKeywords(args
, kwargs
, "|OIs",
2217 discard_const_p(char *, kwnames
),
2218 &py_elements
, &flags
, &name
))
2221 mem_ctx
= talloc_new(NULL
);
2222 if (mem_ctx
== NULL
) {
2227 el
= talloc_zero(mem_ctx
, struct ldb_message_element
);
2230 talloc_free(mem_ctx
);
2234 if (py_elements
!= NULL
) {
2236 if (PyString_Check(py_elements
)) {
2238 el
->values
= talloc_array(el
, struct ldb_val
, 1);
2239 if (el
->values
== NULL
) {
2240 talloc_free(mem_ctx
);
2244 el
->values
[0].length
= PyString_Size(py_elements
);
2245 el
->values
[0].data
= talloc_memdup(el
->values
,
2246 (uint8_t *)PyString_AsString(py_elements
), el
->values
[0].length
+1);
2247 } else if (PySequence_Check(py_elements
)) {
2248 el
->num_values
= PySequence_Size(py_elements
);
2249 el
->values
= talloc_array(el
, struct ldb_val
, el
->num_values
);
2250 if (el
->values
== NULL
) {
2251 talloc_free(mem_ctx
);
2255 for (i
= 0; i
< el
->num_values
; i
++) {
2256 PyObject
*item
= PySequence_GetItem(py_elements
, i
);
2258 talloc_free(mem_ctx
);
2261 if (!PyString_Check(item
)) {
2262 PyErr_Format(PyExc_TypeError
,
2263 "Expected string as element %zd in list", i
);
2264 talloc_free(mem_ctx
);
2267 el
->values
[i
].length
= PyString_Size(item
);
2268 el
->values
[i
].data
= talloc_memdup(el
,
2269 (uint8_t *)PyString_AsString(item
), el
->values
[i
].length
+1);
2272 PyErr_SetString(PyExc_TypeError
,
2273 "Expected string or list");
2274 talloc_free(mem_ctx
);
2280 el
->name
= talloc_strdup(el
, name
);
2282 ret
= PyObject_New(PyLdbMessageElementObject
, type
);
2284 talloc_free(mem_ctx
);
2288 ret
->mem_ctx
= mem_ctx
;
2290 return (PyObject
*)ret
;
2293 static PyObject
*py_ldb_msg_element_repr(PyLdbMessageElementObject
*self
)
2295 char *element_str
= NULL
;
2297 struct ldb_message_element
*el
= PyLdbMessageElement_AsMessageElement(self
);
2300 for (i
= 0; i
< el
->num_values
; i
++) {
2301 PyObject
*o
= py_ldb_msg_element_find(self
, i
);
2302 if (element_str
== NULL
)
2303 element_str
= talloc_strdup(NULL
, PyObject_REPR(o
));
2305 element_str
= talloc_asprintf_append(element_str
, ",%s", PyObject_REPR(o
));
2308 if (element_str
!= NULL
) {
2309 ret
= PyString_FromFormat("MessageElement([%s])", element_str
);
2310 talloc_free(element_str
);
2312 ret
= PyString_FromString("MessageElement([])");
2318 static PyObject
*py_ldb_msg_element_str(PyLdbMessageElementObject
*self
)
2320 struct ldb_message_element
*el
= PyLdbMessageElement_AsMessageElement(self
);
2322 if (el
->num_values
== 1)
2323 return PyString_FromStringAndSize((char *)el
->values
[0].data
, el
->values
[0].length
);
2328 static void py_ldb_msg_element_dealloc(PyLdbMessageElementObject
*self
)
2330 talloc_free(self
->mem_ctx
);
2334 static PyTypeObject PyLdbMessageElement
= {
2335 .tp_name
= "ldb.MessageElement",
2336 .tp_basicsize
= sizeof(PyLdbMessageElementObject
),
2337 .tp_dealloc
= (destructor
)py_ldb_msg_element_dealloc
,
2338 .tp_repr
= (reprfunc
)py_ldb_msg_element_repr
,
2339 .tp_str
= (reprfunc
)py_ldb_msg_element_str
,
2340 .tp_methods
= py_ldb_msg_element_methods
,
2341 .tp_compare
= (cmpfunc
)py_ldb_msg_element_cmp
,
2342 .tp_iter
= (getiterfunc
)py_ldb_msg_element_iter
,
2343 .tp_as_sequence
= &py_ldb_msg_element_seq
,
2344 .tp_new
= py_ldb_msg_element_new
,
2345 .tp_flags
= Py_TPFLAGS_DEFAULT
,
2349 static PyObject
*py_ldb_msg_from_dict(PyTypeObject
*type
, PyObject
*args
)
2354 struct ldb_message
*msg
;
2355 struct ldb_context
*ldb_ctx
;
2356 unsigned int mod_flags
= LDB_FLAG_MOD_REPLACE
;
2358 if (!PyArg_ParseTuple(args
, "O!O!|I",
2359 &PyLdb
, &py_ldb
, &PyDict_Type
, &py_dict
,
2364 /* mask only flags we are going to use */
2365 mod_flags
= LDB_FLAG_MOD_TYPE(mod_flags
);
2367 PyErr_SetString(PyExc_ValueError
,
2368 "FLAG_MOD_ADD, FLAG_MOD_REPLACE or FLAG_MOD_DELETE"
2369 " expected as mod_flag value");
2373 ldb_ctx
= PyLdb_AsLdbContext(py_ldb
);
2375 msg
= PyDict_AsMessage(ldb_ctx
, py_dict
, ldb_ctx
, mod_flags
);
2380 py_ret
= PyLdbMessage_FromMessage(msg
);
2382 talloc_unlink(ldb_ctx
, msg
);
2387 static PyObject
*py_ldb_msg_remove_attr(PyLdbMessageObject
*self
, PyObject
*args
)
2390 if (!PyArg_ParseTuple(args
, "s", &name
))
2393 ldb_msg_remove_attr(self
->msg
, name
);
2398 static PyObject
*py_ldb_msg_keys(PyLdbMessageObject
*self
)
2400 struct ldb_message
*msg
= PyLdbMessage_AsMessage(self
);
2401 Py_ssize_t i
, j
= 0;
2402 PyObject
*obj
= PyList_New(msg
->num_elements
+(msg
->dn
!= NULL
?1:0));
2403 if (msg
->dn
!= NULL
) {
2404 PyList_SetItem(obj
, j
, PyString_FromString("dn"));
2407 for (i
= 0; i
< msg
->num_elements
; i
++) {
2408 PyList_SetItem(obj
, j
, PyString_FromString(msg
->elements
[i
].name
));
2414 static PyObject
*py_ldb_msg_getitem_helper(PyLdbMessageObject
*self
, PyObject
*py_name
)
2416 struct ldb_message_element
*el
;
2418 struct ldb_message
*msg
= PyLdbMessage_AsMessage(self
);
2419 if (!PyString_Check(py_name
)) {
2420 PyErr_SetNone(PyExc_TypeError
);
2423 name
= PyString_AsString(py_name
);
2424 if (!strcmp(name
, "dn"))
2425 return PyLdbDn_FromDn(msg
->dn
);
2426 el
= ldb_msg_find_element(msg
, name
);
2430 return (PyObject
*)PyLdbMessageElement_FromMessageElement(el
, msg
->elements
);
2433 static PyObject
*py_ldb_msg_getitem(PyLdbMessageObject
*self
, PyObject
*py_name
)
2435 PyObject
*ret
= py_ldb_msg_getitem_helper(self
, py_name
);
2437 PyErr_SetString(PyExc_KeyError
, "No such element");
2443 static PyObject
*py_ldb_msg_get(PyLdbMessageObject
*self
, PyObject
*args
)
2445 PyObject
*name
, *ret
, *retobj
;
2447 if (!PyArg_ParseTuple(args
, "O|O", &name
, &retobj
))
2450 ret
= py_ldb_msg_getitem_helper(self
, name
);
2452 if (PyErr_Occurred())
2454 if (retobj
!= NULL
) {
2463 static PyObject
*py_ldb_msg_items(PyLdbMessageObject
*self
)
2465 struct ldb_message
*msg
= PyLdbMessage_AsMessage(self
);
2466 Py_ssize_t i
, j
= 0;
2467 PyObject
*l
= PyList_New(msg
->num_elements
+ (msg
->dn
== NULL
?0:1));
2468 if (msg
->dn
!= NULL
) {
2469 PyList_SetItem(l
, 0, Py_BuildValue("(sO)", "dn", PyLdbDn_FromDn(msg
->dn
)));
2472 for (i
= 0; i
< msg
->num_elements
; i
++, j
++) {
2473 PyObject
*py_el
= PyLdbMessageElement_FromMessageElement(&msg
->elements
[i
], msg
->elements
);
2474 PyObject
*value
= Py_BuildValue("(sO)", msg
->elements
[i
].name
, py_el
);
2475 PyList_SetItem(l
, j
, value
);
2480 static PyObject
*py_ldb_msg_elements(PyLdbMessageObject
*self
)
2482 struct ldb_message
*msg
= PyLdbMessage_AsMessage(self
);
2484 PyObject
*l
= PyList_New(msg
->num_elements
);
2485 for (i
= 0; i
< msg
->num_elements
; i
++) {
2486 PyList_SetItem(l
, i
, PyLdbMessageElement_FromMessageElement(&msg
->elements
[i
], msg
->elements
));
2491 static PyObject
*py_ldb_msg_add(PyLdbMessageObject
*self
, PyObject
*args
)
2493 struct ldb_message
*msg
= PyLdbMessage_AsMessage(self
);
2494 PyLdbMessageElementObject
*py_element
;
2496 struct ldb_message_element
*el
;
2498 if (!PyArg_ParseTuple(args
, "O!", &PyLdbMessageElement
, &py_element
))
2501 el
= talloc_reference(msg
, py_element
->el
);
2507 ret
= ldb_msg_add(msg
, el
, el
->flags
);
2508 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ret
, NULL
);
2513 static PyMethodDef py_ldb_msg_methods
[] = {
2514 { "from_dict", (PyCFunction
)py_ldb_msg_from_dict
, METH_CLASS
| METH_VARARGS
,
2515 "Message.from_dict(ldb, dict, mod_flag=FLAG_MOD_REPLACE) -> ldb.Message\n"
2516 "Class method to create ldb.Message object from Dictionary.\n"
2517 "mod_flag is one of FLAG_MOD_ADD, FLAG_MOD_REPLACE or FLAG_MOD_DELETE."},
2518 { "keys", (PyCFunction
)py_ldb_msg_keys
, METH_NOARGS
,
2519 "S.keys() -> list\n\n"
2520 "Return sequence of all attribute names." },
2521 { "remove", (PyCFunction
)py_ldb_msg_remove_attr
, METH_VARARGS
,
2522 "S.remove(name)\n\n"
2523 "Remove all entries for attributes with the specified name."},
2524 { "get", (PyCFunction
)py_ldb_msg_get
, METH_VARARGS
, NULL
},
2525 { "items", (PyCFunction
)py_ldb_msg_items
, METH_NOARGS
, NULL
},
2526 { "elements", (PyCFunction
)py_ldb_msg_elements
, METH_NOARGS
, NULL
},
2527 { "add", (PyCFunction
)py_ldb_msg_add
, METH_VARARGS
,
2528 "S.append(element)\n\n"
2529 "Add an element to this message." },
2533 static PyObject
*py_ldb_msg_iter(PyLdbMessageObject
*self
)
2535 PyObject
*list
, *iter
;
2537 list
= py_ldb_msg_keys(self
);
2538 iter
= PyObject_GetIter(list
);
2543 static int py_ldb_msg_setitem(PyLdbMessageObject
*self
, PyObject
*name
, PyObject
*value
)
2547 if (!PyString_Check(name
)) {
2548 PyErr_SetNone(PyExc_TypeError
);
2552 attr_name
= PyString_AsString(name
);
2553 if (value
== NULL
) {
2555 ldb_msg_remove_attr(self
->msg
, attr_name
);
2557 struct ldb_message_element
*el
= PyObject_AsMessageElement(self
->msg
,
2558 value
, 0, attr_name
);
2561 ldb_msg_remove_attr(PyLdbMessage_AsMessage(self
), attr_name
);
2562 ldb_msg_add(PyLdbMessage_AsMessage(self
), el
, el
->flags
);
2567 static Py_ssize_t
py_ldb_msg_length(PyLdbMessageObject
*self
)
2569 return PyLdbMessage_AsMessage(self
)->num_elements
;
2572 static PyMappingMethods py_ldb_msg_mapping
= {
2573 .mp_length
= (lenfunc
)py_ldb_msg_length
,
2574 .mp_subscript
= (binaryfunc
)py_ldb_msg_getitem
,
2575 .mp_ass_subscript
= (objobjargproc
)py_ldb_msg_setitem
,
2578 static PyObject
*py_ldb_msg_new(PyTypeObject
*type
, PyObject
*args
, PyObject
*kwargs
)
2580 const char * const kwnames
[] = { "dn", NULL
};
2581 struct ldb_message
*ret
;
2582 TALLOC_CTX
*mem_ctx
;
2583 PyObject
*pydn
= NULL
;
2584 PyLdbMessageObject
*py_ret
;
2586 if (!PyArg_ParseTupleAndKeywords(args
, kwargs
, "|O",
2587 discard_const_p(char *, kwnames
),
2591 mem_ctx
= talloc_new(NULL
);
2592 if (mem_ctx
== NULL
) {
2597 ret
= ldb_msg_new(mem_ctx
);
2599 talloc_free(mem_ctx
);
2606 if (!PyObject_AsDn(NULL
, pydn
, NULL
, &dn
)) {
2607 talloc_free(mem_ctx
);
2610 ret
->dn
= talloc_reference(ret
, dn
);
2613 py_ret
= (PyLdbMessageObject
*)type
->tp_alloc(type
, 0);
2614 if (py_ret
== NULL
) {
2616 talloc_free(mem_ctx
);
2620 py_ret
->mem_ctx
= mem_ctx
;
2622 return (PyObject
*)py_ret
;
2625 static PyObject
*PyLdbMessage_FromMessage(struct ldb_message
*msg
)
2627 PyLdbMessageObject
*ret
;
2629 ret
= (PyLdbMessageObject
*)PyLdbMessage
.tp_alloc(&PyLdbMessage
, 0);
2634 ret
->mem_ctx
= talloc_new(NULL
);
2635 ret
->msg
= talloc_reference(ret
->mem_ctx
, msg
);
2636 return (PyObject
*)ret
;
2639 static PyObject
*py_ldb_msg_get_dn(PyLdbMessageObject
*self
, void *closure
)
2641 struct ldb_message
*msg
= PyLdbMessage_AsMessage(self
);
2642 return PyLdbDn_FromDn(msg
->dn
);
2645 static int py_ldb_msg_set_dn(PyLdbMessageObject
*self
, PyObject
*value
, void *closure
)
2647 struct ldb_message
*msg
= PyLdbMessage_AsMessage(self
);
2648 if (!PyLdbDn_Check(value
)) {
2649 PyErr_SetNone(PyExc_TypeError
);
2653 msg
->dn
= talloc_reference(msg
, PyLdbDn_AsDn(value
));
2657 static PyGetSetDef py_ldb_msg_getset
[] = {
2658 { discard_const_p(char, "dn"), (getter
)py_ldb_msg_get_dn
, (setter
)py_ldb_msg_set_dn
, NULL
},
2662 static PyObject
*py_ldb_msg_repr(PyLdbMessageObject
*self
)
2664 PyObject
*dict
= PyDict_New(), *ret
;
2665 if (PyDict_Update(dict
, (PyObject
*)self
) != 0)
2667 ret
= PyString_FromFormat("Message(%s)", PyObject_REPR(dict
));
2672 static void py_ldb_msg_dealloc(PyLdbMessageObject
*self
)
2674 talloc_free(self
->mem_ctx
);
2678 static int py_ldb_msg_compare(PyLdbMessageObject
*py_msg1
,
2679 PyLdbMessageObject
*py_msg2
)
2681 struct ldb_message
*msg1
= PyLdbMessage_AsMessage(py_msg1
),
2682 *msg2
= PyLdbMessage_AsMessage(py_msg2
);
2686 if ((msg1
->dn
!= NULL
) || (msg2
->dn
!= NULL
)) {
2687 ret
= ldb_dn_compare(msg1
->dn
, msg2
->dn
);
2693 ret
= msg1
->num_elements
- msg2
->num_elements
;
2698 for (i
= 0; i
< msg1
->num_elements
; i
++) {
2699 ret
= ldb_msg_element_compare_name(&msg1
->elements
[i
],
2700 &msg2
->elements
[i
]);
2705 ret
= ldb_msg_element_compare(&msg1
->elements
[i
],
2706 &msg2
->elements
[i
]);
2715 static PyTypeObject PyLdbMessage
= {
2716 .tp_name
= "ldb.Message",
2717 .tp_methods
= py_ldb_msg_methods
,
2718 .tp_getset
= py_ldb_msg_getset
,
2719 .tp_as_mapping
= &py_ldb_msg_mapping
,
2720 .tp_basicsize
= sizeof(PyLdbMessageObject
),
2721 .tp_dealloc
= (destructor
)py_ldb_msg_dealloc
,
2722 .tp_new
= py_ldb_msg_new
,
2723 .tp_repr
= (reprfunc
)py_ldb_msg_repr
,
2724 .tp_flags
= Py_TPFLAGS_DEFAULT
,
2725 .tp_iter
= (getiterfunc
)py_ldb_msg_iter
,
2726 .tp_compare
= (cmpfunc
)py_ldb_msg_compare
,
2729 static PyObject
*PyLdbTree_FromTree(struct ldb_parse_tree
*tree
)
2731 PyLdbTreeObject
*ret
;
2733 ret
= (PyLdbTreeObject
*)PyLdbTree
.tp_alloc(&PyLdbTree
, 0);
2739 ret
->mem_ctx
= talloc_new(NULL
);
2740 ret
->tree
= talloc_reference(ret
->mem_ctx
, tree
);
2741 return (PyObject
*)ret
;
2744 static void py_ldb_tree_dealloc(PyLdbTreeObject
*self
)
2746 talloc_free(self
->mem_ctx
);
2750 static PyTypeObject PyLdbTree
= {
2751 .tp_name
= "ldb.Tree",
2752 .tp_basicsize
= sizeof(PyLdbTreeObject
),
2753 .tp_dealloc
= (destructor
)py_ldb_tree_dealloc
,
2754 .tp_flags
= Py_TPFLAGS_DEFAULT
,
2758 static int py_module_search(struct ldb_module
*mod
, struct ldb_request
*req
)
2760 PyObject
*py_ldb
= (PyObject
*)mod
->private_data
;
2761 PyObject
*py_result
, *py_base
, *py_attrs
, *py_tree
;
2763 py_base
= PyLdbDn_FromDn(req
->op
.search
.base
);
2765 if (py_base
== NULL
)
2766 return LDB_ERR_OPERATIONS_ERROR
;
2768 py_tree
= PyLdbTree_FromTree(req
->op
.search
.tree
);
2770 if (py_tree
== NULL
)
2771 return LDB_ERR_OPERATIONS_ERROR
;
2773 if (req
->op
.search
.attrs
== NULL
) {
2777 for (len
= 0; req
->op
.search
.attrs
[len
]; len
++);
2778 py_attrs
= PyList_New(len
);
2779 for (i
= 0; i
< len
; i
++)
2780 PyList_SetItem(py_attrs
, i
, PyString_FromString(req
->op
.search
.attrs
[i
]));
2783 py_result
= PyObject_CallMethod(py_ldb
, discard_const_p(char, "search"),
2784 discard_const_p(char, "OiOO"),
2785 py_base
, req
->op
.search
.scope
, py_tree
, py_attrs
);
2787 Py_DECREF(py_attrs
);
2791 if (py_result
== NULL
) {
2792 return LDB_ERR_PYTHON_EXCEPTION
;
2795 req
->op
.search
.res
= PyLdbResult_AsResult(NULL
, py_result
);
2796 if (req
->op
.search
.res
== NULL
) {
2797 return LDB_ERR_PYTHON_EXCEPTION
;
2800 Py_DECREF(py_result
);
2805 static int py_module_add(struct ldb_module
*mod
, struct ldb_request
*req
)
2807 PyObject
*py_ldb
= (PyObject
*)mod
->private_data
;
2808 PyObject
*py_result
, *py_msg
;
2810 py_msg
= PyLdbMessage_FromMessage(discard_const_p(struct ldb_message
, req
->op
.add
.message
));
2812 if (py_msg
== NULL
) {
2813 return LDB_ERR_OPERATIONS_ERROR
;
2816 py_result
= PyObject_CallMethod(py_ldb
, discard_const_p(char, "add"),
2817 discard_const_p(char, "O"),
2822 if (py_result
== NULL
) {
2823 return LDB_ERR_PYTHON_EXCEPTION
;
2826 Py_DECREF(py_result
);
2831 static int py_module_modify(struct ldb_module
*mod
, struct ldb_request
*req
)
2833 PyObject
*py_ldb
= (PyObject
*)mod
->private_data
;
2834 PyObject
*py_result
, *py_msg
;
2836 py_msg
= PyLdbMessage_FromMessage(discard_const_p(struct ldb_message
, req
->op
.mod
.message
));
2838 if (py_msg
== NULL
) {
2839 return LDB_ERR_OPERATIONS_ERROR
;
2842 py_result
= PyObject_CallMethod(py_ldb
, discard_const_p(char, "modify"),
2843 discard_const_p(char, "O"),
2848 if (py_result
== NULL
) {
2849 return LDB_ERR_PYTHON_EXCEPTION
;
2852 Py_DECREF(py_result
);
2857 static int py_module_del(struct ldb_module
*mod
, struct ldb_request
*req
)
2859 PyObject
*py_ldb
= (PyObject
*)mod
->private_data
;
2860 PyObject
*py_result
, *py_dn
;
2862 py_dn
= PyLdbDn_FromDn(req
->op
.del
.dn
);
2865 return LDB_ERR_OPERATIONS_ERROR
;
2867 py_result
= PyObject_CallMethod(py_ldb
, discard_const_p(char, "delete"),
2868 discard_const_p(char, "O"),
2871 if (py_result
== NULL
) {
2872 return LDB_ERR_PYTHON_EXCEPTION
;
2875 Py_DECREF(py_result
);
2880 static int py_module_rename(struct ldb_module
*mod
, struct ldb_request
*req
)
2882 PyObject
*py_ldb
= (PyObject
*)mod
->private_data
;
2883 PyObject
*py_result
, *py_olddn
, *py_newdn
;
2885 py_olddn
= PyLdbDn_FromDn(req
->op
.rename
.olddn
);
2887 if (py_olddn
== NULL
)
2888 return LDB_ERR_OPERATIONS_ERROR
;
2890 py_newdn
= PyLdbDn_FromDn(req
->op
.rename
.newdn
);
2892 if (py_newdn
== NULL
)
2893 return LDB_ERR_OPERATIONS_ERROR
;
2895 py_result
= PyObject_CallMethod(py_ldb
, discard_const_p(char, "rename"),
2896 discard_const_p(char, "OO"),
2897 py_olddn
, py_newdn
);
2899 Py_DECREF(py_olddn
);
2900 Py_DECREF(py_newdn
);
2902 if (py_result
== NULL
) {
2903 return LDB_ERR_PYTHON_EXCEPTION
;
2906 Py_DECREF(py_result
);
2911 static int py_module_request(struct ldb_module
*mod
, struct ldb_request
*req
)
2913 PyObject
*py_ldb
= (PyObject
*)mod
->private_data
;
2914 PyObject
*py_result
;
2916 py_result
= PyObject_CallMethod(py_ldb
, discard_const_p(char, "request"),
2917 discard_const_p(char, ""));
2919 return LDB_ERR_OPERATIONS_ERROR
;
2922 static int py_module_extended(struct ldb_module
*mod
, struct ldb_request
*req
)
2924 PyObject
*py_ldb
= (PyObject
*)mod
->private_data
;
2925 PyObject
*py_result
;
2927 py_result
= PyObject_CallMethod(py_ldb
, discard_const_p(char, "extended"),
2928 discard_const_p(char, ""));
2930 return LDB_ERR_OPERATIONS_ERROR
;
2933 static int py_module_start_transaction(struct ldb_module
*mod
)
2935 PyObject
*py_ldb
= (PyObject
*)mod
->private_data
;
2936 PyObject
*py_result
;
2938 py_result
= PyObject_CallMethod(py_ldb
, discard_const_p(char, "start_transaction"),
2939 discard_const_p(char, ""));
2941 if (py_result
== NULL
) {
2942 return LDB_ERR_PYTHON_EXCEPTION
;
2945 Py_DECREF(py_result
);
2950 static int py_module_end_transaction(struct ldb_module
*mod
)
2952 PyObject
*py_ldb
= (PyObject
*)mod
->private_data
;
2953 PyObject
*py_result
;
2955 py_result
= PyObject_CallMethod(py_ldb
, discard_const_p(char, "end_transaction"),
2956 discard_const_p(char, ""));
2958 if (py_result
== NULL
) {
2959 return LDB_ERR_PYTHON_EXCEPTION
;
2962 Py_DECREF(py_result
);
2967 static int py_module_del_transaction(struct ldb_module
*mod
)
2969 PyObject
*py_ldb
= (PyObject
*)mod
->private_data
;
2970 PyObject
*py_result
;
2972 py_result
= PyObject_CallMethod(py_ldb
, discard_const_p(char, "del_transaction"),
2973 discard_const_p(char, ""));
2975 if (py_result
== NULL
) {
2976 return LDB_ERR_PYTHON_EXCEPTION
;
2979 Py_DECREF(py_result
);
2984 static int py_module_destructor(struct ldb_module
*mod
)
2986 Py_DECREF((PyObject
*)mod
->private_data
);
2990 static int py_module_init(struct ldb_module
*mod
)
2992 PyObject
*py_class
= (PyObject
*)mod
->ops
->private_data
;
2993 PyObject
*py_result
, *py_next
, *py_ldb
;
2995 py_ldb
= PyLdb_FromLdbContext(mod
->ldb
);
2998 return LDB_ERR_OPERATIONS_ERROR
;
3000 py_next
= PyLdbModule_FromModule(mod
->next
);
3002 if (py_next
== NULL
)
3003 return LDB_ERR_OPERATIONS_ERROR
;
3005 py_result
= PyObject_CallFunction(py_class
, discard_const_p(char, "OO"),
3008 if (py_result
== NULL
) {
3009 return LDB_ERR_PYTHON_EXCEPTION
;
3012 mod
->private_data
= py_result
;
3014 talloc_set_destructor(mod
, py_module_destructor
);
3016 return ldb_next_init(mod
);
3019 static PyObject
*py_register_module(PyObject
*module
, PyObject
*args
)
3022 struct ldb_module_ops
*ops
;
3025 if (!PyArg_ParseTuple(args
, "O", &input
))
3028 ops
= talloc_zero(talloc_autofree_context(), struct ldb_module_ops
);
3034 ops
->name
= talloc_strdup(ops
, PyString_AsString(PyObject_GetAttrString(input
, discard_const_p(char, "name"))));
3037 ops
->private_data
= input
;
3038 ops
->init_context
= py_module_init
;
3039 ops
->search
= py_module_search
;
3040 ops
->add
= py_module_add
;
3041 ops
->modify
= py_module_modify
;
3042 ops
->del
= py_module_del
;
3043 ops
->rename
= py_module_rename
;
3044 ops
->request
= py_module_request
;
3045 ops
->extended
= py_module_extended
;
3046 ops
->start_transaction
= py_module_start_transaction
;
3047 ops
->end_transaction
= py_module_end_transaction
;
3048 ops
->del_transaction
= py_module_del_transaction
;
3050 ret
= ldb_register_module(ops
);
3052 PyErr_LDB_ERROR_IS_ERR_RAISE(PyExc_LdbError
, ret
, NULL
);
3057 static PyObject
*py_timestring(PyObject
*module
, PyObject
*args
)
3059 /* most times "time_t" is a signed integer type with 32 or 64 bit:
3060 * http://stackoverflow.com/questions/471248/what-is-ultimately-a-time-t-typedef-to */
3064 if (!PyArg_ParseTuple(args
, "l", &t_val
))
3066 tresult
= ldb_timestring(NULL
, (time_t) t_val
);
3067 ret
= PyString_FromString(tresult
);
3068 talloc_free(tresult
);
3072 static PyObject
*py_string_to_time(PyObject
*module
, PyObject
*args
)
3075 if (!PyArg_ParseTuple(args
, "s", &str
))
3078 return PyInt_FromLong(ldb_string_to_time(str
));
3081 static PyObject
*py_valid_attr_name(PyObject
*self
, PyObject
*args
)
3084 if (!PyArg_ParseTuple(args
, "s", &name
))
3086 return PyBool_FromLong(ldb_valid_attr_name(name
));
3089 static PyMethodDef py_ldb_global_methods
[] = {
3090 { "register_module", py_register_module
, METH_VARARGS
,
3091 "S.register_module(module) -> None\n"
3092 "Register a LDB module."},
3093 { "timestring", py_timestring
, METH_VARARGS
,
3094 "S.timestring(int) -> string\n"
3095 "Generate a LDAP time string from a UNIX timestamp" },
3096 { "string_to_time", py_string_to_time
, METH_VARARGS
,
3097 "S.string_to_time(string) -> int\n"
3098 "Parse a LDAP time string into a UNIX timestamp." },
3099 { "valid_attr_name", py_valid_attr_name
, METH_VARARGS
,
3100 "S.valid_attr_name(name) -> bool\n"
3101 "Check whether the supplied name is a valid attribute name." },
3102 { "open", (PyCFunction
)py_ldb_new
, METH_VARARGS
|METH_KEYWORDS
,
3111 if (PyType_Ready(&PyLdbDn
) < 0)
3114 if (PyType_Ready(&PyLdbMessage
) < 0)
3117 if (PyType_Ready(&PyLdbMessageElement
) < 0)
3120 if (PyType_Ready(&PyLdb
) < 0)
3123 if (PyType_Ready(&PyLdbModule
) < 0)
3126 if (PyType_Ready(&PyLdbTree
) < 0)
3129 if (PyType_Ready(&PyLdbResult
) < 0)
3132 if (PyType_Ready(&PyLdbControl
) < 0)
3135 m
= Py_InitModule3("ldb", py_ldb_global_methods
,
3136 "An interface to LDB, a LDAP-like API that can either to talk an embedded database (TDB-based) or a standards-compliant LDAP server.");
3140 PyModule_AddObject(m
, "SEQ_HIGHEST_SEQ", PyInt_FromLong(LDB_SEQ_HIGHEST_SEQ
));
3141 PyModule_AddObject(m
, "SEQ_HIGHEST_TIMESTAMP", PyInt_FromLong(LDB_SEQ_HIGHEST_TIMESTAMP
));
3142 PyModule_AddObject(m
, "SEQ_NEXT", PyInt_FromLong(LDB_SEQ_NEXT
));
3143 PyModule_AddObject(m
, "SCOPE_DEFAULT", PyInt_FromLong(LDB_SCOPE_DEFAULT
));
3144 PyModule_AddObject(m
, "SCOPE_BASE", PyInt_FromLong(LDB_SCOPE_BASE
));
3145 PyModule_AddObject(m
, "SCOPE_ONELEVEL", PyInt_FromLong(LDB_SCOPE_ONELEVEL
));
3146 PyModule_AddObject(m
, "SCOPE_SUBTREE", PyInt_FromLong(LDB_SCOPE_SUBTREE
));
3148 PyModule_AddObject(m
, "CHANGETYPE_NONE", PyInt_FromLong(LDB_CHANGETYPE_NONE
));
3149 PyModule_AddObject(m
, "CHANGETYPE_ADD", PyInt_FromLong(LDB_CHANGETYPE_ADD
));
3150 PyModule_AddObject(m
, "CHANGETYPE_DELETE", PyInt_FromLong(LDB_CHANGETYPE_DELETE
));
3151 PyModule_AddObject(m
, "CHANGETYPE_MODIFY", PyInt_FromLong(LDB_CHANGETYPE_MODIFY
));
3153 PyModule_AddObject(m
, "FLAG_MOD_ADD", PyInt_FromLong(LDB_FLAG_MOD_ADD
));
3154 PyModule_AddObject(m
, "FLAG_MOD_REPLACE", PyInt_FromLong(LDB_FLAG_MOD_REPLACE
));
3155 PyModule_AddObject(m
, "FLAG_MOD_DELETE", PyInt_FromLong(LDB_FLAG_MOD_DELETE
));
3157 PyModule_AddObject(m
, "SUCCESS", PyInt_FromLong(LDB_SUCCESS
));
3158 PyModule_AddObject(m
, "ERR_OPERATIONS_ERROR", PyInt_FromLong(LDB_ERR_OPERATIONS_ERROR
));
3159 PyModule_AddObject(m
, "ERR_PROTOCOL_ERROR", PyInt_FromLong(LDB_ERR_PROTOCOL_ERROR
));
3160 PyModule_AddObject(m
, "ERR_TIME_LIMIT_EXCEEDED", PyInt_FromLong(LDB_ERR_TIME_LIMIT_EXCEEDED
));
3161 PyModule_AddObject(m
, "ERR_SIZE_LIMIT_EXCEEDED", PyInt_FromLong(LDB_ERR_SIZE_LIMIT_EXCEEDED
));
3162 PyModule_AddObject(m
, "ERR_COMPARE_FALSE", PyInt_FromLong(LDB_ERR_COMPARE_FALSE
));
3163 PyModule_AddObject(m
, "ERR_COMPARE_TRUE", PyInt_FromLong(LDB_ERR_COMPARE_TRUE
));
3164 PyModule_AddObject(m
, "ERR_AUTH_METHOD_NOT_SUPPORTED", PyInt_FromLong(LDB_ERR_AUTH_METHOD_NOT_SUPPORTED
));
3165 PyModule_AddObject(m
, "ERR_STRONG_AUTH_REQUIRED", PyInt_FromLong(LDB_ERR_STRONG_AUTH_REQUIRED
));
3166 PyModule_AddObject(m
, "ERR_REFERRAL", PyInt_FromLong(LDB_ERR_REFERRAL
));
3167 PyModule_AddObject(m
, "ERR_ADMIN_LIMIT_EXCEEDED", PyInt_FromLong(LDB_ERR_ADMIN_LIMIT_EXCEEDED
));
3168 PyModule_AddObject(m
, "ERR_UNSUPPORTED_CRITICAL_EXTENSION", PyInt_FromLong(LDB_ERR_UNSUPPORTED_CRITICAL_EXTENSION
));
3169 PyModule_AddObject(m
, "ERR_CONFIDENTIALITY_REQUIRED", PyInt_FromLong(LDB_ERR_CONFIDENTIALITY_REQUIRED
));
3170 PyModule_AddObject(m
, "ERR_SASL_BIND_IN_PROGRESS", PyInt_FromLong(LDB_ERR_SASL_BIND_IN_PROGRESS
));
3171 PyModule_AddObject(m
, "ERR_NO_SUCH_ATTRIBUTE", PyInt_FromLong(LDB_ERR_NO_SUCH_ATTRIBUTE
));
3172 PyModule_AddObject(m
, "ERR_UNDEFINED_ATTRIBUTE_TYPE", PyInt_FromLong(LDB_ERR_UNDEFINED_ATTRIBUTE_TYPE
));
3173 PyModule_AddObject(m
, "ERR_INAPPROPRIATE_MATCHING", PyInt_FromLong(LDB_ERR_INAPPROPRIATE_MATCHING
));
3174 PyModule_AddObject(m
, "ERR_CONSTRAINT_VIOLATION", PyInt_FromLong(LDB_ERR_CONSTRAINT_VIOLATION
));
3175 PyModule_AddObject(m
, "ERR_ATTRIBUTE_OR_VALUE_EXISTS", PyInt_FromLong(LDB_ERR_ATTRIBUTE_OR_VALUE_EXISTS
));
3176 PyModule_AddObject(m
, "ERR_INVALID_ATTRIBUTE_SYNTAX", PyInt_FromLong(LDB_ERR_INVALID_ATTRIBUTE_SYNTAX
));
3177 PyModule_AddObject(m
, "ERR_NO_SUCH_OBJECT", PyInt_FromLong(LDB_ERR_NO_SUCH_OBJECT
));
3178 PyModule_AddObject(m
, "ERR_ALIAS_PROBLEM", PyInt_FromLong(LDB_ERR_ALIAS_PROBLEM
));
3179 PyModule_AddObject(m
, "ERR_INVALID_DN_SYNTAX", PyInt_FromLong(LDB_ERR_INVALID_DN_SYNTAX
));
3180 PyModule_AddObject(m
, "ERR_ALIAS_DEREFERINCING_PROBLEM", PyInt_FromLong(LDB_ERR_ALIAS_DEREFERENCING_PROBLEM
));
3181 PyModule_AddObject(m
, "ERR_INAPPROPRIATE_AUTHENTICATION", PyInt_FromLong(LDB_ERR_INAPPROPRIATE_AUTHENTICATION
));
3182 PyModule_AddObject(m
, "ERR_INVALID_CREDENTIALS", PyInt_FromLong(LDB_ERR_INVALID_CREDENTIALS
));
3183 PyModule_AddObject(m
, "ERR_INSUFFICIENT_ACCESS_RIGHTS", PyInt_FromLong(LDB_ERR_INSUFFICIENT_ACCESS_RIGHTS
));
3184 PyModule_AddObject(m
, "ERR_BUSY", PyInt_FromLong(LDB_ERR_BUSY
));
3185 PyModule_AddObject(m
, "ERR_UNAVAILABLE", PyInt_FromLong(LDB_ERR_UNAVAILABLE
));
3186 PyModule_AddObject(m
, "ERR_UNWILLING_TO_PERFORM", PyInt_FromLong(LDB_ERR_UNWILLING_TO_PERFORM
));
3187 PyModule_AddObject(m
, "ERR_LOOP_DETECT", PyInt_FromLong(LDB_ERR_LOOP_DETECT
));
3188 PyModule_AddObject(m
, "ERR_NAMING_VIOLATION", PyInt_FromLong(LDB_ERR_NAMING_VIOLATION
));
3189 PyModule_AddObject(m
, "ERR_OBJECT_CLASS_VIOLATION", PyInt_FromLong(LDB_ERR_OBJECT_CLASS_VIOLATION
));
3190 PyModule_AddObject(m
, "ERR_NOT_ALLOWED_ON_NON_LEAF", PyInt_FromLong(LDB_ERR_NOT_ALLOWED_ON_NON_LEAF
));
3191 PyModule_AddObject(m
, "ERR_NOT_ALLOWED_ON_RDN", PyInt_FromLong(LDB_ERR_NOT_ALLOWED_ON_RDN
));
3192 PyModule_AddObject(m
, "ERR_ENTRY_ALREADY_EXISTS", PyInt_FromLong(LDB_ERR_ENTRY_ALREADY_EXISTS
));
3193 PyModule_AddObject(m
, "ERR_OBJECT_CLASS_MODS_PROHIBITED", PyInt_FromLong(LDB_ERR_OBJECT_CLASS_MODS_PROHIBITED
));
3194 PyModule_AddObject(m
, "ERR_AFFECTS_MULTIPLE_DSAS", PyInt_FromLong(LDB_ERR_AFFECTS_MULTIPLE_DSAS
));
3195 PyModule_AddObject(m
, "ERR_OTHER", PyInt_FromLong(LDB_ERR_OTHER
));
3197 PyModule_AddObject(m
, "FLG_RDONLY", PyInt_FromLong(LDB_FLG_RDONLY
));
3198 PyModule_AddObject(m
, "FLG_NOSYNC", PyInt_FromLong(LDB_FLG_NOSYNC
));
3199 PyModule_AddObject(m
, "FLG_RECONNECT", PyInt_FromLong(LDB_FLG_RECONNECT
));
3200 PyModule_AddObject(m
, "FLG_NOMMAP", PyInt_FromLong(LDB_FLG_NOMMAP
));
3202 PyModule_AddObject(m
, "__docformat__", PyString_FromString("restructuredText"));
3204 PyExc_LdbError
= PyErr_NewException(discard_const_p(char, "_ldb.LdbError"), NULL
, NULL
);
3205 PyModule_AddObject(m
, "LdbError", PyExc_LdbError
);
3208 Py_INCREF(&PyLdbDn
);
3209 Py_INCREF(&PyLdbModule
);
3210 Py_INCREF(&PyLdbMessage
);
3211 Py_INCREF(&PyLdbMessageElement
);
3212 Py_INCREF(&PyLdbTree
);
3213 Py_INCREF(&PyLdbResult
);
3214 Py_INCREF(&PyLdbControl
);
3216 PyModule_AddObject(m
, "Ldb", (PyObject
*)&PyLdb
);
3217 PyModule_AddObject(m
, "Dn", (PyObject
*)&PyLdbDn
);
3218 PyModule_AddObject(m
, "Message", (PyObject
*)&PyLdbMessage
);
3219 PyModule_AddObject(m
, "MessageElement", (PyObject
*)&PyLdbMessageElement
);
3220 PyModule_AddObject(m
, "Module", (PyObject
*)&PyLdbModule
);
3221 PyModule_AddObject(m
, "Tree", (PyObject
*)&PyLdbTree
);
3222 PyModule_AddObject(m
, "Control", (PyObject
*)&PyLdbControl
);
3224 PyModule_AddObject(m
, "__version__", PyString_FromString(PACKAGE_VERSION
));