[gvfs] afp: implement directory creation

[Christian Kellner <gicmo src gnome org>]

commit 86e6f039c51162bf2e126b1b95b34b9995f1e819
Author: Carl-Anton Ingmarsson <ca ingmarsson gmail com>
Date:   Sun Jul 3 21:43:24 2011 +0200

    afp: implement directory creation

 daemon/gvfsafpconnection.h |    2 +
 daemon/gvfsbackendafp.c    |  106 ++++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 108 insertions(+), 0 deletions(-)
---
diff --git a/daemon/gvfsafpconnection.h b/daemon/gvfsafpconnection.h
index be21cb8..7a57ace 100644
--- a/daemon/gvfsafpconnection.h
+++ b/daemon/gvfsafpconnection.h
@@ -128,6 +128,7 @@ enum
 typedef enum
 {
   AFP_COMMAND_CLOSE_FORK         = 4,
+  AFP_COMMAND_CREATE_DIR         = 6,
   AFP_COMMAND_CREATE_FILE        = 7,
   AFP_COMMAND_DELETE             = 8,
   AFP_COMMAND_GET_FORK_PARMS     = 14,
@@ -156,6 +157,7 @@ typedef enum
   AFP_RESULT_DISK_FULL           = -5008,
   AFP_RESULT_EOF_ERR             = -5009,
   AFP_RESULT_FILE_BUSY           = -5010,
+  AFP_RESULT_FLAT_VOL            = -5011,
   AFP_RESULT_LOCK_ERR            = -5013,
   AFP_RESULT_OBJECT_EXISTS       = -5017,
   AFP_RESULT_OBJECT_NOT_FOUND    = -5018,
diff --git a/daemon/gvfsbackendafp.c b/daemon/gvfsbackendafp.c
index c035a5c..3024a36 100644
--- a/daemon/gvfsbackendafp.c
+++ b/daemon/gvfsbackendafp.c
@@ -40,6 +40,7 @@
 #include "gvfsjobseekread.h"
 #include "gvfsjobopenforwrite.h"
 #include "gvfsjobdelete.h"
+#include "gvfsjobmakedirectory.h"
 
 #include "gvfsafpserver.h"
 #include "gvfsafpconnection.h"
@@ -110,6 +111,21 @@ filename_to_afp_pathname (const char *filename)
   return g_vfs_afp_name_new (0x08000103, str, len);
 }
 
+static void
+put_pathname (GVfsAfpCommand *comm, const char *filename)
+{
+  GVfsAfpName *pathname;
+  
+  /* PathType */
+  g_data_output_stream_put_byte (G_DATA_OUTPUT_STREAM (comm), AFP_PATH_TYPE_UTF8_NAME,
+                                 NULL, NULL);
+
+  /* Pathname */
+  pathname = filename_to_afp_pathname (filename);
+  g_vfs_afp_command_put_afp_name (comm, pathname);
+  g_vfs_afp_name_unref (pathname);
+}
+
 typedef struct
 {
   gint16 fork_refnum;
@@ -257,6 +273,95 @@ static void fill_info (GVfsBackendAfp *afp_backend,
 }
 
 static void
+make_directory_cb (GVfsAfpConnection *afp_connection,
+                   GVfsAfpReply      *reply,
+                   GError            *error,
+                   gpointer           user_data)
+{
+  GVfsJobMakeDirectory *job = G_VFS_JOB_MAKE_DIRECTORY (user_data);
+
+  AfpResultCode res_code;
+  
+  if (!reply)
+  {
+    g_vfs_job_failed_from_error (G_VFS_JOB (job), error);
+    return;
+  }
+
+  res_code = g_vfs_afp_reply_get_result_code (reply);
+  if (res_code != AFP_RESULT_NO_ERROR)
+  {
+    g_object_unref (reply);
+
+    if (res_code == AFP_RESULT_ACCESS_DENIED)
+    {
+      g_vfs_job_failed_literal (G_VFS_JOB (job), G_IO_ERROR, G_IO_ERROR_PERMISSION_DENIED,
+                                _("Access denied"));
+    }
+    else if (res_code == AFP_RESULT_DISK_FULL)
+    {
+      g_vfs_job_failed_literal (G_VFS_JOB (job), G_IO_ERROR, G_IO_ERROR_NO_SPACE,
+                                _("Not enough space on volume"));
+    }
+    else if (res_code == AFP_RESULT_FLAT_VOL)
+    {
+            g_vfs_job_failed_literal (G_VFS_JOB (job), G_IO_ERROR, G_IO_ERROR_NOT_SUPPORTED,
+                                _("Volume is flat and doesn't support directories"));
+    }
+    else if (res_code == AFP_RESULT_OBJECT_NOT_FOUND)
+    {
+      g_vfs_job_failed_literal (G_VFS_JOB (job), G_IO_ERROR, G_IO_ERROR_NOT_FOUND,
+                                _("Ancestor directory doesn't exist"));
+    }
+    else if (res_code == AFP_RESULT_OBJECT_EXISTS)
+    {
+      g_vfs_job_failed_literal (G_VFS_JOB (job), G_IO_ERROR, G_IO_ERROR_EXISTS,
+                                _("Target directory already exists"));
+    }
+    else if (res_code == AFP_RESULT_VOL_LOCKED)
+    {
+      g_vfs_job_failed_literal (G_VFS_JOB (job), G_IO_ERROR, G_IO_ERROR_PERMISSION_DENIED,
+                                _("Volume is read-only"));
+    }
+    else
+    {
+      g_vfs_job_failed (G_VFS_JOB (job), G_IO_ERROR, G_IO_ERROR_FAILED,
+                        _("Got error code: %d from server"), res_code);
+    }
+    return;
+  }
+
+  g_vfs_job_succeeded (G_VFS_JOB (job));
+}
+
+static gboolean 
+try_make_directory (GVfsBackend *backend,
+                    GVfsJobMakeDirectory *job,
+                    const char *filename)
+{
+  GVfsBackendAfp *afp_backend = G_VFS_BACKEND_AFP (backend);
+
+  GVfsAfpCommand *comm;
+
+  comm = g_vfs_afp_command_new (AFP_COMMAND_CREATE_DIR);
+  /* pad byte */
+  g_data_output_stream_put_byte (G_DATA_OUTPUT_STREAM (comm), 0, NULL, NULL);
+  /* Volume ID */
+  g_data_output_stream_put_uint16 (G_DATA_OUTPUT_STREAM (comm),
+                                   afp_backend->volume_id, NULL, NULL);
+  /* Directory ID 2 == / */
+  g_data_output_stream_put_uint32 (G_DATA_OUTPUT_STREAM (comm), 2, NULL, NULL);
+  /* Pathname */
+  put_pathname (comm, filename);
+
+  g_vfs_afp_connection_queue_command (afp_backend->server->conn, comm, make_directory_cb,
+                                      G_VFS_JOB (job)->cancellable, job);
+  g_object_unref (comm);
+
+  return TRUE;
+}
+
+static void
 delete_cb (GVfsAfpConnection *afp_connection,
            GVfsAfpReply      *reply,
            GError            *error,
@@ -1485,6 +1590,7 @@ g_vfs_backend_afp_class_init (GVfsBackendAfpClass *klass)
   backend_class->try_seek_on_read = try_seek_on_read;
   backend_class->try_create = try_create;
   backend_class->try_delete = try_delete;
+  backend_class->try_make_directory = try_make_directory;
 }
 
 void