full and default gtk3 support, almost. the graph is disabled as the drawing api has changed quite a bit. yet another implementation to pass arguments, which made a cleanup of main.c necessary.

1 files changed, 192 insertions, 0 deletions

diff --git a/src/win32-mailslot.c b/src/win32-mailslot.c
new file mode 100644
index 0000000..50fadad
--- /dev/null
+++ b/src/win32-mailslot.c
@@ -0,0 +1,192 @@
+/*
+ * transmission-remote-gtk - A GTK RPC client to Transmission
+ * Copyright (C) 2011  Alan Fitton
+
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version.
+
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+
+ * You should have received a copy of the GNU General Public License along
+ * with this program; if not, write to the Free Software Foundation, Inc.,
+ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
+ */
+
+#define TRG_MAILSLOT_NAME "\\\\.\\mailslot\\TransmissionRemoteGTK"      //Name given to the Mailslot
+#define MAILSLOT_BUFFER_SIZE 1024*32
+
+#include <windows.h>
+#include <glib-object.h>
+#include <gtk/gtk.h>
+#include <json-glib/json-glib.h>
+
+#include "trg-main-window.h"
+#include "win32-mailslot.h"
+
+struct trg_mailslot_recv_args {
+    TrgMainWindow *win;
+    gchar **uris;
+    gboolean present;
+};
+
+/* to be queued into the glib main loop with g_idle_add() */
+
+static gboolean mailslot_recv_args(gpointer data)
+{
+    struct trg_mailslot_recv_args *args =
+        (struct trg_mailslot_recv_args *) data;
+
+    if (args->present) {
+        gtk_window_deiconify(GTK_WINDOW(args->win));
+        gtk_window_present(GTK_WINDOW(args->win));
+    }
+
+    if (args->uris)
+        trg_add_from_filename(args->win, args->uris);
+
+    g_free(args);
+
+    return FALSE;
+}
+
+static gpointer mailslot_recv_thread(gpointer data)
+{
+    TrgMainWindow *win = TRG_MAIN_WINDOW(data);
+    JsonParser *parser;
+    char szBuffer[MAILSLOT_BUFFER_SIZE];
+    HANDLE hMailslot;
+    DWORD cbBytes;
+    BOOL bResult;
+
+    hMailslot = CreateMailslot(TRG_MAILSLOT_NAME,       // mailslot name
+                               MAILSLOT_BUFFER_SIZE,    // input buffer size
+                               MAILSLOT_WAIT_FOREVER,   // no timeout
+                               NULL);   // default security attribute
+
+    if (INVALID_HANDLE_VALUE == hMailslot) {
+        g_error("\nError occurred while creating the mailslot: %d",
+                GetLastError());
+        return NULL;            //Error
+    }
+
+    while (1) {
+        bResult = ReadFile(hMailslot,   // handle to mailslot
+                           szBuffer,    // buffer to receive data
+                           sizeof(szBuffer),    // size of buffer
+                           &cbBytes,    // number of bytes read
+                           NULL);       // not overlapped I/O
+
+        if ((!bResult) || (0 == cbBytes)) {
+            g_error("Mailslot error from client: %d", GetLastError());
+            break;
+        }
+
+        parser = json_parser_new();
+
+        if (json_parser_load_from_data(parser, szBuffer, cbBytes, NULL)) {
+            JsonNode *node = json_parser_get_root(parser);
+            JsonObject *obj = json_node_get_object(node);
+            struct trg_mailslot_recv_args *args =
+                g_new0(struct trg_mailslot_recv_args, 1);
+
+            args->present = json_object_has_member(obj, "present")
+                && json_object_get_boolean_member(obj, "present");
+            args->win = win;
+
+            if (json_object_has_member(obj, "args")) {
+                JsonArray *array =
+                    json_object_get_array_member(obj, "args");
+                GList *arrayList = json_array_get_elements(array);
+
+                if (arrayList) {
+                    guint arrayLength = g_list_length(arrayList);
+                    guint i = 0;
+                    GList *li;
+
+                    args->uris = g_new0(gchar *, arrayLength + 1);
+
+                    for (li = arrayList; li; li = g_list_next(li)) {
+                        const gchar *liStr =
+                            json_node_get_string((JsonNode *) li->data);
+                        args->uris[i++] = g_strdup(liStr);
+                    }
+
+                    g_list_free(arrayList);
+                }
+            }
+
+            json_node_free(node);
+
+            g_idle_add(mailslot_recv_args, args);
+        }
+
+        g_object_unref(parser);
+    }
+
+    CloseHandle(hMailslot);
+    return NULL;                //Success
+}
+
+void mailslot_start_background_listener(TrgMainWindow * win)
+{
+    g_thread_create(mailslot_recv_thread, win, FALSE, NULL);
+}
+
+gboolean mailslot_send_message(gchar ** args)
+{
+    HANDLE hMailSlot = CreateFile(TRG_MAILSLOT_NAME,   // mailslot name
+                           GENERIC_WRITE,       // mailslot write only
+                           FILE_SHARE_READ,     // required for mailslots
+                           NULL,        // default security attributes
+                           OPEN_EXISTING,       // opens existing mailslot
+                           FILE_ATTRIBUTE_NORMAL,       // normal attributes
+                           NULL);       // no template file
+
+    if (hMailSlot != INVALID_HANDLE_VALUE) {
+        DWORD cbBytes;
+        JsonNode *node = json_node_new(JSON_NODE_OBJECT);
+        JsonObject *obj = json_object_new();
+        JsonArray *array = json_array_new();
+        JsonGenerator *generator;
+        gchar *msg;
+        int i;
+
+        if (args) {
+            for (i = 0; args[i]; i++)
+                json_array_add_string_element(array, args[i]);
+
+            json_object_set_array_member(obj, "args", array);
+
+            g_strfreev(args);
+        } else {
+            json_object_set_boolean_member(obj, "present", TRUE);
+        }
+
+        json_node_take_object(node, obj);
+
+        generator = json_generator_new();
+        json_generator_set_root(generator, node);
+        msg = json_generator_to_data(generator, NULL);
+
+        json_node_free(node);
+        g_object_unref(generator);
+
+        WriteFile(hMailSlot,            // handle to mailslot
+                  msg,          // buffer to write from
+                  strlen(msg) + 1,      // number of bytes to write, include the NULL
+                  &cbBytes,     // number of bytes written
+                  NULL);
+
+        CloseHandle(hMailSlot);
+        g_free(msg);
+
+        return TRUE;
+    }
+
+    return FALSE;
+}