s3:pylibsmb: Add .mkdir(), .rmdir() APIS to SMB py bindings

I kept these separate from the chkpath API because it's a nice way to
use the old s4 API in the tests to verify the new s3 API works
correctly.

BUG: https://bugzilla.samba.org/show_bug.cgi?id=13676

Signed-off-by: Tim Beale <timbeale@catalyst.net.nz>
Reviewed-by: Andrew Bartlett <abartlet@samba.org>

diff --git a/python/samba/tests/smb.py b/python/samba/tests/smb.py
index a74db3bd2d5664322e748964a480bec493165a43..25cca33926e0c74505d69b95c4fdc4ffae470726 100644 (file)
--- a/python/samba/tests/smb.py
+++ b/python/samba/tests/smb.py
@@ -53,7 +53,7 @@ class SMBTests(samba.tests.TestCase):
         self.smb_conn = libsmb_samba_internal.Conn(self.server, "sysvol",
                                                    lp, creds)
 
-        self.conn.mkdir(test_dir)
+        self.smb_conn.mkdir(test_dir)
 
     def tearDown(self):
         super(SMBTests, self).tearDown()
@@ -98,13 +98,13 @@ class SMBTests(samba.tests.TestCase):
         cur_dir = test_dir
         for subdir in ["subdir-X", "subdir-Y", "subdir-Z"]:
             path = self.make_sysvol_path(cur_dir, subdir)
-            self.conn.mkdir(path)
+            self.smb_conn.mkdir(path)
             dirpaths.append(path)
             cur_dir = path
 
             # create another empty dir just for kicks
             path = self.make_sysvol_path(cur_dir, "another")
-            self.conn.mkdir(path)
+            self.smb_conn.mkdir(path)
             empty_dirs.append(path)
 
         # create some files in these directories
@@ -188,9 +188,9 @@ class SMBTests(samba.tests.TestCase):
 
         # check correct result after creating and then deleting a new dir
         new_dir = self.make_sysvol_path(test_dir, 'test-new')
-        self.conn.mkdir(new_dir)
+        self.smb_conn.mkdir(new_dir)
         self.assertTrue(self.conn.chkpath(new_dir))
-        self.conn.rmdir(new_dir)
+        self.smb_conn.rmdir(new_dir)
         self.assertFalse(self.conn.chkpath(new_dir))
 
     def test_save_load_text(self):

diff --git a/source3/libsmb/pylibsmb.c b/source3/libsmb/pylibsmb.c
index ab7400a291e899bced96c144bc5ac87ac6e1efa2..ecd2acf58d0081fb0f3482dfbf6f05acaffa6047 100644 (file)
--- a/source3/libsmb/pylibsmb.c
+++ b/source3/libsmb/pylibsmb.c
@@ -1005,6 +1005,72 @@ static PyObject *py_smb_unlink(struct py_cli_state *self, PyObject *args)
        Py_RETURN_NONE;
 }
 
+/*
+ * Delete an empty directory
+ */
+static NTSTATUS remove_dir(struct py_cli_state *self, const char *dirname)
+{
+       NTSTATUS status;
+
+       if (self->is_smb1) {
+               struct tevent_req *req = NULL;
+
+               req = cli_rmdir_send(NULL, self->ev, self->cli, dirname);
+               if (!py_tevent_req_wait_exc(self, req)) {
+                       return NT_STATUS_INTERNAL_ERROR;
+               }
+               status = cli_rmdir_recv(req);
+               TALLOC_FREE(req);
+       } else {
+               status = cli_rmdir(self->cli, dirname);
+       }
+       return status;
+}
+
+static PyObject *py_smb_rmdir(struct py_cli_state *self, PyObject *args)
+{
+       NTSTATUS status;
+       const char *dirname;
+
+       if (!PyArg_ParseTuple(args, "s:rmdir", &dirname)) {
+               return NULL;
+       }
+
+       status = remove_dir(self, dirname);
+       PyErr_NTSTATUS_IS_ERR_RAISE(status);
+
+       Py_RETURN_NONE;
+}
+
+/*
+ * Create a directory
+ */
+static PyObject *py_smb_mkdir(struct py_cli_state *self, PyObject *args)
+{
+       NTSTATUS status;
+       const char *dirname;
+
+       if (!PyArg_ParseTuple(args, "s:mkdir", &dirname)) {
+               return NULL;
+       }
+
+       if (self->is_smb1) {
+               struct tevent_req *req = NULL;
+
+               req = cli_mkdir_send(NULL, self->ev, self->cli, dirname);
+               if (!py_tevent_req_wait_exc(self, req)) {
+                       return NULL;
+               }
+               status = cli_mkdir_recv(req);
+               TALLOC_FREE(req);
+       } else {
+               status = cli_mkdir(self->cli, dirname);
+       }
+       PyErr_NTSTATUS_IS_ERR_RAISE(status);
+
+       Py_RETURN_NONE;
+}
+
 static PyMethodDef py_cli_state_methods[] = {
        { "settimeout", (PyCFunction)py_cli_settimeout, METH_VARARGS,
          "settimeout(new_timeout_msecs) => return old_timeout_msecs" },
@@ -1030,6 +1096,10 @@ static PyMethodDef py_cli_state_methods[] = {
        { "unlink", (PyCFunction)py_smb_unlink,
          METH_VARARGS,
          "unlink(path) -> None\n\n \t\tDelete a file." },
+       { "mkdir", (PyCFunction)py_smb_mkdir, METH_VARARGS,
+         "mkdir(path) -> None\n\n \t\tCreate a directory." },
+       { "rmdir", (PyCFunction)py_smb_rmdir, METH_VARARGS,
+         "rmdir(path) -> None\n\n \t\tDelete a directory." },
        { NULL, NULL, 0, NULL }
 };