From 582e1a60b3f011d2e8b1f88a4d98174cf434c596 Mon Sep 17 00:00:00 2001
From: Michael Jumper <mike.jumper@guac-dev.org>
Date: Tue, 17 Sep 2013 15:17:35 -0700
Subject: [PATCH] Implement write.

---
 .../rdp/guac_rdpdr/rdpdr_fs_messages.c        | 62 ++++++++++++++++++-
 1 file changed, 60 insertions(+), 2 deletions(-)

diff --git a/src/protocols/rdp/guac_rdpdr/rdpdr_fs_messages.c b/src/protocols/rdp/guac_rdpdr/rdpdr_fs_messages.c
index 3e4b6540..f62848d8 100644
--- a/src/protocols/rdp/guac_rdpdr/rdpdr_fs_messages.c
+++ b/src/protocols/rdp/guac_rdpdr/rdpdr_fs_messages.c
@@ -203,8 +203,66 @@ void guac_rdpdr_fs_process_read(guac_rdpdr_device* device,
 
 void guac_rdpdr_fs_process_write(guac_rdpdr_device* device,
         wStream* input_stream, int file_id, int completion_id) {
-    /* STUB */
-    guac_client_log_error(device->rdpdr->client, "write: %i", file_id);
+
+    UINT32 length;
+    UINT64 offset;
+
+    wStream* output_stream;
+    guac_rdpdr_fs_file* file;
+
+    /* Get file */
+    file = guac_rdpdr_fs_get_file(device, file_id);
+    if (file == NULL)
+        return;
+
+    /* Read packet */
+    Stream_Read_UINT32(input_stream, length);
+    Stream_Read_UINT64(input_stream, offset);
+    Stream_Seek(input_stream, 20); /* Padding */
+
+    output_stream = Stream_New(NULL, 20);
+
+    /* Write header */
+    Stream_Write_UINT16(output_stream, RDPDR_CTYP_CORE);
+    Stream_Write_UINT16(output_stream, PAKID_CORE_DEVICE_IOCOMPLETION);
+
+    /* Write content */
+    Stream_Write_UINT32(output_stream, device->device_id);
+    Stream_Write_UINT32(output_stream, completion_id);
+
+    /* If file is a directory, fail */
+    if (file->attributes & FILE_ATTRIBUTE_DIRECTORY) {
+        guac_client_log_error(device->rdpdr->client,
+                "Refusing to write directory as a file");
+        Stream_Write_UINT32(output_stream, STATUS_FILE_IS_A_DIRECTORY);
+        Stream_Write_UINT32(output_stream, 0); /* Length */
+    }
+
+    /* Otherwise, perform write */
+    else {
+
+        int bytes_written;
+
+        /* Attempt read */
+        lseek(file->fd, offset, SEEK_SET);
+        bytes_written = write(file->fd, Stream_Pointer(input_stream), length);
+
+        /* If error, return invalid parameter */
+        if (bytes_written < 0) {
+            Stream_Write_UINT32(output_stream, STATUS_INVALID_PARAMETER);
+            Stream_Write_UINT32(output_stream, 0); /* Length */
+        }
+
+        /* Otherwise, send success */
+        else {
+            Stream_Write_UINT32(output_stream, STATUS_SUCCESS);
+            Stream_Write_UINT32(output_stream, bytes_written);  /* Length */
+        }
+
+    }
+
+    svc_plugin_send((rdpSvcPlugin*) device->rdpdr, output_stream);
+
 }
 
 void guac_rdpdr_fs_process_close(guac_rdpdr_device* device,