Documentation: Use G_SOURCE_CONTINUE and G_SOURCE_REMOVE
[geeqie.git] / src / remote.cc
1 /*
2  * Copyright (C) 2004 John Ellis
3  * Copyright (C) 2008 - 2016 The Geeqie Team
4  *
5  * Author: John Ellis
6  *
7  * This program is free software; you can redistribute it and/or modify
8  * it under the terms of the GNU General Public License as published by
9  * the Free Software Foundation; either version 2 of the License, or
10  * (at your option) any later version.
11  *
12  * This program is distributed in the hope that it will be useful,
13  * but WITHOUT ANY WARRANTY; without even the implied warranty of
14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
15  * GNU General Public License for more details.
16  *
17  * You should have received a copy of the GNU General Public License along
18  * with this program; if not, write to the Free Software Foundation, Inc.,
19  * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
20  */
21
22 #include "main.h"
23 #include "remote.h"
24
25 #include "cache-maint.h"
26 #include "collect.h"
27 #include "collect-io.h"
28 #include "exif.h"
29 #include "filedata.h"
30 #include "filefilter.h"
31 #include "image.h"
32 #include "img-view.h"
33 #include "layout-image.h"
34 #include "layout-util.h"
35 #include "misc.h"
36 #include "pixbuf-renderer.h"
37 #include "slideshow.h"
38 #include "ui-fileops.h"
39 #include "rcfile.h"
40 #include "view-file.h"
41
42 #include <sys/socket.h>
43 #include <sys/un.h>
44 #include <signal.h>
45
46 #include "glua.h"
47
48 #define SERVER_MAX_CLIENTS 8
49
50 #define REMOTE_SERVER_BACKLOG 4
51
52
53 #ifndef UNIX_PATH_MAX
54 #define UNIX_PATH_MAX 108
55 #endif
56
57
58 static RemoteConnection *remote_client_open(const gchar *path);
59 static gint remote_client_send(RemoteConnection *rc, const gchar *text);
60 static void gr_raise(const gchar *text, GIOChannel *channel, gpointer data);
61
62 static LayoutWindow *lw_id = NULL; /* points to the window set by the --id option */
63
64 typedef struct _RemoteClient RemoteClient;
65 struct _RemoteClient {
66         gint fd;
67         guint channel_id; /* event source id */
68         RemoteConnection *rc;
69 };
70
71 typedef struct _RemoteData RemoteData;
72 struct _RemoteData {
73         CollectionData *command_collection;
74         GList *file_list;
75         gboolean single_dir;
76 };
77
78 /* To enable file names containing newlines to be processed correctly,
79  * the --print0 remote option sets returned data to be terminated with a null
80  * character rather a newline
81  */
82 static gboolean print0 = FALSE;
83
84 /* Remote commands from main.cc are prepended with the current dir the remote
85  * command was made from. Some remote commands require this. The
86  * value is stored here
87  */
88 static gchar *pwd = NULL;
89
90 /**
91  * @brief Ensures file path is absolute.
92  * @param[in] filename Filepath, absolute or relative to calling directory
93  * @returns absolute path
94  * 
95  * If first character of input filepath is not the directory
96  * separator, assume it as a relative path and prepend
97  * the directory the remote command was initiated from
98  * 
99  * Return value must be freed with g_free()
100  */
101 static gchar *set_pwd(gchar *filename)
102 {
103         gchar *temp;
104
105         if (strncmp(filename, G_DIR_SEPARATOR_S, 1) != 0)
106                 {
107                 temp = g_build_filename(pwd, filename, NULL);
108                 }
109         else
110                 {
111                 temp = g_strdup(filename);
112                 }
113
114         return temp;
115 }
116
117 static gboolean remote_server_client_cb(GIOChannel *source, GIOCondition condition, gpointer data)
118 {
119         RemoteClient *client = static_cast<RemoteClient *>(data);
120         RemoteConnection *rc;
121         GIOStatus status = G_IO_STATUS_NORMAL;
122
123         lw_id = NULL;
124         rc = client->rc;
125
126         if (condition & G_IO_IN)
127                 {
128                 gchar *buffer = NULL;
129                 GError *error = NULL;
130                 gsize termpos;
131                 /** @FIXME it should be possible to terminate the command with a null character */
132                 g_io_channel_set_line_term(source, "<gq_end_of_command>", -1);
133                 while ((status = g_io_channel_read_line(source, &buffer, NULL, &termpos, &error)) == G_IO_STATUS_NORMAL)
134                         {
135                         if (buffer)
136                                 {
137                                 buffer[termpos] = '\0';
138
139                                 if (strlen(buffer) > 0)
140                                         {
141                                         if (rc->read_func) rc->read_func(rc, buffer, source, rc->read_data);
142                                         g_io_channel_write_chars(source, "<gq_end_of_command>", -1, NULL, NULL); /* empty line finishes the command */
143                                         g_io_channel_flush(source, NULL);
144                                         }
145                                 g_free(buffer);
146
147                                 buffer = NULL;
148                                 }
149                         }
150
151                 if (error)
152                         {
153                         log_printf("error reading socket: %s\n", error->message);
154                         g_error_free(error);
155                         }
156                 }
157
158         if (condition & G_IO_HUP || status == G_IO_STATUS_EOF || status == G_IO_STATUS_ERROR)
159                 {
160                 rc->clients = g_list_remove(rc->clients, client);
161
162                 DEBUG_1("HUP detected, closing client.");
163                 DEBUG_1("client count %d", g_list_length(rc->clients));
164
165                 g_source_remove(client->channel_id);
166                 close(client->fd);
167                 g_free(client);
168                 }
169
170         return TRUE;
171 }
172
173 static void remote_server_client_add(RemoteConnection *rc, gint fd)
174 {
175         RemoteClient *client;
176         GIOChannel *channel;
177
178         if (g_list_length(rc->clients) > SERVER_MAX_CLIENTS)
179                 {
180                 log_printf("maximum remote clients of %d exceeded, closing connection\n", SERVER_MAX_CLIENTS);
181                 close(fd);
182                 return;
183                 }
184
185         client = g_new0(RemoteClient, 1);
186         client->rc = rc;
187         client->fd = fd;
188
189         channel = g_io_channel_unix_new(fd);
190         client->channel_id = g_io_add_watch_full(channel, G_PRIORITY_DEFAULT, static_cast<GIOCondition>(G_IO_IN | G_IO_HUP),
191                                                  remote_server_client_cb, client, NULL);
192         g_io_channel_unref(channel);
193
194         rc->clients = g_list_append(rc->clients, client);
195         DEBUG_1("client count %d", g_list_length(rc->clients));
196 }
197
198 static void remote_server_clients_close(RemoteConnection *rc)
199 {
200         while (rc->clients)
201                 {
202                 RemoteClient *client = static_cast<RemoteClient *>(rc->clients->data);
203
204                 rc->clients = g_list_remove(rc->clients, client);
205
206                 g_source_remove(client->channel_id);
207                 close(client->fd);
208                 g_free(client);
209                 }
210 }
211
212 static gboolean remote_server_read_cb(GIOChannel *UNUSED(source), GIOCondition UNUSED(condition), gpointer data)
213 {
214         RemoteConnection *rc = static_cast<RemoteConnection *>(data);
215         gint fd;
216         guint alen;
217
218         fd = accept(rc->fd, NULL, &alen);
219         if (fd == -1)
220                 {
221                 log_printf("error accepting socket: %s\n", strerror(errno));
222                 return TRUE;
223                 }
224
225         remote_server_client_add(rc, fd);
226
227         return TRUE;
228 }
229
230 gboolean remote_server_exists(const gchar *path)
231 {
232         RemoteConnection *rc;
233
234         /* verify server up */
235         rc = remote_client_open(path);
236         remote_close(rc);
237
238         if (rc) return TRUE;
239
240         /* unable to connect, remove socket file to free up address */
241         unlink(path);
242         return FALSE;
243 }
244
245 static RemoteConnection *remote_server_open(const gchar *path)
246 {
247         RemoteConnection *rc;
248         struct sockaddr_un addr;
249         gint sun_path_len;
250         gint fd;
251         GIOChannel *channel;
252
253         if (remote_server_exists(path))
254                 {
255                 log_printf("Address already in use: %s\n", path);
256                 return NULL;
257                 }
258
259         fd = socket(PF_UNIX, SOCK_STREAM, 0);
260         if (fd == -1) return NULL;
261
262         addr.sun_family = AF_UNIX;
263         sun_path_len = MIN(strlen(path) + 1, UNIX_PATH_MAX);
264         strncpy(addr.sun_path, path, sun_path_len);
265         if (bind(fd, (const struct sockaddr*)&addr, sizeof(addr)) == -1 ||
266             listen(fd, REMOTE_SERVER_BACKLOG) == -1)
267                 {
268                 log_printf("error subscribing to socket: %s\n", strerror(errno));
269                 close(fd);
270                 return NULL;
271                 }
272
273         rc = g_new0(RemoteConnection, 1);
274
275         rc->server = TRUE;
276         rc->fd = fd;
277         rc->path = g_strdup(path);
278
279         channel = g_io_channel_unix_new(rc->fd);
280         g_io_channel_set_flags(channel, G_IO_FLAG_NONBLOCK, NULL);
281
282         rc->channel_id = g_io_add_watch_full(channel, G_PRIORITY_DEFAULT, G_IO_IN,
283                                              remote_server_read_cb, rc, NULL);
284         g_io_channel_unref(channel);
285
286         return rc;
287 }
288
289 static void remote_server_subscribe(RemoteConnection *rc, RemoteReadFunc *func, gpointer data)
290 {
291         if (!rc || !rc->server) return;
292
293         rc->read_func = func;
294         rc->read_data = data;
295 }
296
297
298 static RemoteConnection *remote_client_open(const gchar *path)
299 {
300         RemoteConnection *rc;
301         struct stat st;
302         struct sockaddr_un addr;
303         gint sun_path_len;
304         gint fd;
305
306         if (stat(path, &st) != 0 || !S_ISSOCK(st.st_mode)) return NULL;
307
308         fd = socket(PF_UNIX, SOCK_STREAM, 0);
309         if (fd == -1) return NULL;
310
311         addr.sun_family = AF_UNIX;
312         sun_path_len = MIN(strlen(path) + 1, UNIX_PATH_MAX);
313         strncpy(addr.sun_path, path, sun_path_len);
314         if (connect(fd, (struct sockaddr*)&addr, sizeof(addr)) == -1)
315                 {
316                 DEBUG_1("error connecting to socket: %s", strerror(errno));
317                 close(fd);
318                 return NULL;
319                 }
320
321         rc = g_new0(RemoteConnection, 1);
322         rc->server = FALSE;
323         rc->fd = fd;
324         rc->path = g_strdup(path);
325
326         return rc;
327 }
328
329 static sig_atomic_t sigpipe_occurred = FALSE;
330
331 static void sighandler_sigpipe(gint UNUSED(sig))
332 {
333         sigpipe_occurred = TRUE;
334 }
335
336 static gboolean remote_client_send(RemoteConnection *rc, const gchar *text)
337 {
338         struct sigaction new_action, old_action;
339         gboolean ret = FALSE;
340         GError *error = NULL;
341         GIOChannel *channel;
342
343         if (!rc || rc->server) return FALSE;
344         if (!text) return TRUE;
345
346         sigpipe_occurred = FALSE;
347
348         new_action.sa_handler = sighandler_sigpipe;
349         sigemptyset(&new_action.sa_mask);
350         new_action.sa_flags = 0;
351
352         /* setup our signal handler */
353         sigaction(SIGPIPE, &new_action, &old_action);
354
355         channel = g_io_channel_unix_new(rc->fd);
356
357         g_io_channel_write_chars(channel, text, -1, NULL, &error);
358         g_io_channel_write_chars(channel, "<gq_end_of_command>", -1, NULL, &error);
359         g_io_channel_flush(channel, &error);
360
361         if (error)
362                 {
363                 log_printf("error reading socket: %s\n", error->message);
364                 g_error_free(error);
365                 ret = FALSE;;
366                 }
367         else
368                 {
369                 ret = TRUE;
370                 }
371
372         if (ret)
373                 {
374                 gchar *buffer = NULL;
375                 gsize termpos;
376                 g_io_channel_set_line_term(channel, "<gq_end_of_command>", -1);
377                 while (g_io_channel_read_line(channel, &buffer, NULL, &termpos, &error) == G_IO_STATUS_NORMAL)
378                         {
379                         if (buffer)
380                                 {
381                                 if (g_strstr_len(buffer, -1, "<gq_end_of_command>") == buffer) /* empty line finishes the command */
382                                         {
383                                         g_free(buffer);
384                                         fflush(stdout);
385                                         break;
386                                         }
387                                 buffer[termpos] = '\0';
388                                 if (g_strstr_len(buffer, -1, "print0") != 0)
389                                         {
390                                         print0 = TRUE;
391                                         }
392                                 else
393                                         {
394                                         if (print0)
395                                                 {
396                                                 printf("%s%c", buffer, 0);
397                                                 }
398                                         else
399                                                 {
400                                                 printf("%s\n", buffer);
401                                                 }
402                                         }
403                                 g_free(buffer);
404                                 buffer = NULL;
405                                 }
406                         }
407
408                 if (error)
409                         {
410                         log_printf("error reading socket: %s\n", error->message);
411                         g_error_free(error);
412                         ret = FALSE;
413                         }
414                 }
415
416
417         /* restore the original signal handler */
418         sigaction(SIGPIPE, &old_action, NULL);
419         g_io_channel_unref(channel);
420         return ret;
421 }
422
423 void remote_close(RemoteConnection *rc)
424 {
425         if (!rc) return;
426
427         if (rc->server)
428                 {
429                 remote_server_clients_close(rc);
430
431                 g_source_remove(rc->channel_id);
432                 unlink(rc->path);
433                 }
434
435         if (rc->read_data)
436                 g_free(rc->read_data);
437
438         close(rc->fd);
439
440         g_free(rc->path);
441         g_free(rc);
442 }
443
444 /*
445  *-----------------------------------------------------------------------------
446  * remote functions
447  *-----------------------------------------------------------------------------
448  */
449
450 static void gr_image_next(const gchar *UNUSED(text), GIOChannel *UNUSED(channel), gpointer UNUSED(data))
451 {
452         layout_image_next(lw_id);
453 }
454
455 static void gr_new_window(const gchar *UNUSED(text), GIOChannel *UNUSED(channel), gpointer UNUSED(data))
456 {
457         LayoutWindow *lw = NULL;
458
459         if (!layout_valid(&lw)) return;
460
461         lw_id = layout_new_from_default();
462
463         layout_set_path(lw_id, pwd);
464 }
465
466 static gboolean gr_close_window_cb(gpointer UNUSED(data))
467 {
468         if (!layout_valid(&lw_id)) return FALSE;
469
470         layout_menu_close_cb(NULL, lw_id);
471
472         return G_SOURCE_REMOVE;
473 }
474
475 static void gr_close_window(const gchar *UNUSED(text), GIOChannel *UNUSED(channel), gpointer UNUSED(data))
476 {
477         g_idle_add((gr_close_window_cb), NULL);
478 }
479
480 static void gr_image_prev(const gchar *UNUSED(text), GIOChannel *UNUSED(channel), gpointer UNUSED(data))
481 {
482         layout_image_prev(lw_id);
483 }
484
485 static void gr_image_first(const gchar *UNUSED(text), GIOChannel *UNUSED(channel), gpointer UNUSED(data))
486 {
487         layout_image_first(lw_id);
488 }
489
490 static void gr_image_last(const gchar *UNUSED(text), GIOChannel *UNUSED(channel), gpointer UNUSED(data))
491 {
492         layout_image_last(lw_id);
493 }
494
495 static void gr_fullscreen_toggle(const gchar *UNUSED(text), GIOChannel *UNUSED(channel), gpointer UNUSED(data))
496 {
497         layout_image_full_screen_toggle(lw_id);
498 }
499
500 static void gr_fullscreen_start(const gchar *UNUSED(text), GIOChannel *UNUSED(channel), gpointer UNUSED(data))
501 {
502         layout_image_full_screen_start(lw_id);
503 }
504
505 static void gr_fullscreen_stop(const gchar *UNUSED(text), GIOChannel *UNUSED(channel), gpointer UNUSED(data))
506 {
507         layout_image_full_screen_stop(lw_id);
508 }
509
510 static void gr_lw_id(const gchar *text, GIOChannel *UNUSED(channel), gpointer UNUSED(data))
511 {
512         lw_id = layout_find_by_layout_id(text);
513         if (!lw_id)
514                 {
515                 log_printf("remote sent window ID that does not exist:\"%s\"\n",text);
516                 }
517         layout_valid(&lw_id);
518 }
519
520 static void gr_slideshow_start_rec(const gchar *text, GIOChannel *UNUSED(channel), gpointer UNUSED(data))
521 {
522         GList *list;
523         gchar *tilde_filename;
524
525         tilde_filename = expand_tilde(text);
526
527         FileData *dir_fd = file_data_new_dir(tilde_filename);
528         g_free(tilde_filename);
529
530         layout_valid(&lw_id);
531         list = filelist_recursive_full(dir_fd, lw_id->sort_method, lw_id->sort_ascend);
532         file_data_unref(dir_fd);
533         if (!list) return;
534 //printf("length: %d\n", g_list_length(list));
535         layout_image_slideshow_stop(lw_id);
536         layout_image_slideshow_start_from_list(lw_id, list);
537 }
538
539 static void gr_cache_thumb(const gchar *text, GIOChannel *UNUSED(channel), gpointer UNUSED(data))
540 {
541         if (!g_strcmp0(text, "clear"))
542                 {
543                 cache_maintain_home_remote(FALSE, TRUE, NULL);
544                 }
545         else if (!g_strcmp0(text, "clean"))
546                 {
547                 cache_maintain_home_remote(FALSE, FALSE, NULL);
548                 }
549 }
550
551 static void gr_cache_shared(const gchar *text, GIOChannel *UNUSED(channel), gpointer UNUSED(data))
552 {
553         if (!g_strcmp0(text, "clear"))
554                 cache_manager_standard_process_remote(TRUE);
555         else if (!g_strcmp0(text, "clean"))
556                 cache_manager_standard_process_remote(FALSE);
557 }
558
559 static void gr_cache_metadata(const gchar *UNUSED(text), GIOChannel *UNUSED(channel), gpointer UNUSED(data))
560 {
561         cache_maintain_home_remote(TRUE, FALSE, NULL);
562 }
563
564 static void gr_cache_render(const gchar *text, GIOChannel *UNUSED(channel), gpointer UNUSED(data))
565 {
566         cache_manager_render_remote(text, FALSE, FALSE, NULL);
567 }
568
569 static void gr_cache_render_recurse(const gchar *text, GIOChannel *UNUSED(channel), gpointer UNUSED(data))
570 {
571         cache_manager_render_remote(text, TRUE, FALSE, NULL);
572 }
573
574 static void gr_cache_render_standard(const gchar *text, GIOChannel *UNUSED(channel), gpointer UNUSED(data))
575 {
576         if(options->thumbnails.spec_standard)
577                 {
578                 cache_manager_render_remote(text, FALSE, TRUE, NULL);
579                 }
580 }
581
582 static void gr_cache_render_standard_recurse(const gchar *text, GIOChannel *UNUSED(channel), gpointer UNUSED(data))
583 {
584         if(options->thumbnails.spec_standard)
585                 {
586                 cache_manager_render_remote(text, TRUE, TRUE, NULL);
587                 }
588 }
589
590 static void gr_slideshow_toggle(const gchar *UNUSED(text), GIOChannel *UNUSED(channel), gpointer UNUSED(data))
591 {
592         layout_image_slideshow_toggle(lw_id);
593 }
594
595 static void gr_slideshow_start(const gchar *UNUSED(text), GIOChannel *UNUSED(channel), gpointer UNUSED(data))
596 {
597         layout_image_slideshow_start(lw_id);
598 }
599
600 static void gr_slideshow_stop(const gchar *UNUSED(text), GIOChannel *UNUSED(channel), gpointer UNUSED(data))
601 {
602         layout_image_slideshow_stop(lw_id);
603 }
604
605 static void gr_slideshow_delay(const gchar *text, GIOChannel *UNUSED(channel), gpointer UNUSED(data))
606 {
607         gdouble t1, t2, t3, n;
608         gint res;
609
610         res = sscanf(text, "%lf:%lf:%lf", &t1, &t2, &t3);
611         if (res == 3)
612                 {
613                 n = (t1 * 3600) + (t2 * 60) + t3;
614                 if (n < SLIDESHOW_MIN_SECONDS || n > SLIDESHOW_MAX_SECONDS ||
615                                 t1 >= 24 || t2 >= 60 || t3 >= 60)
616                         {
617                         printf_term(TRUE, "Remote slideshow delay out of range (%.1f to %.1f)\n",
618                                                                 SLIDESHOW_MIN_SECONDS, SLIDESHOW_MAX_SECONDS);
619                         return;
620                         }
621                 }
622         else if (res == 2)
623                 {
624                 n = t1 * 60 + t2;
625                 if (n < SLIDESHOW_MIN_SECONDS || n > SLIDESHOW_MAX_SECONDS ||
626                                 t1 >= 60 || t2 >= 60)
627                         {
628                         printf_term(TRUE, "Remote slideshow delay out of range (%.1f to %.1f)\n",
629                                                                 SLIDESHOW_MIN_SECONDS, SLIDESHOW_MAX_SECONDS);
630                         return;
631                         }
632                 }
633         else if (res == 1)
634                 {
635                 n = t1;
636                 if (n < SLIDESHOW_MIN_SECONDS || n > SLIDESHOW_MAX_SECONDS)
637                         {
638                         printf_term(TRUE, "Remote slideshow delay out of range (%.1f to %.1f)\n",
639                                                                 SLIDESHOW_MIN_SECONDS, SLIDESHOW_MAX_SECONDS);
640                         return;
641                         }
642                 }
643         else
644                 {
645                 n = 0;
646                 }
647
648         options->slideshow.delay = (gint)(n * 10.0 + 0.01);
649 }
650
651 static void gr_tools_show(const gchar *UNUSED(text), GIOChannel *UNUSED(channel), gpointer UNUSED(data))
652 {
653         gboolean popped;
654         gboolean hidden;
655
656         if (layout_tools_float_get(lw_id, &popped, &hidden) && hidden)
657                 {
658                 layout_tools_float_set(lw_id, popped, FALSE);
659                 }
660 }
661
662 static void gr_tools_hide(const gchar *UNUSED(text), GIOChannel *UNUSED(channel), gpointer UNUSED(data))
663 {
664         gboolean popped;
665         gboolean hidden;
666
667         if (layout_tools_float_get(lw_id, &popped, &hidden) && !hidden)
668                 {
669                 layout_tools_float_set(lw_id, popped, TRUE);
670                 }
671 }
672
673 static gboolean gr_quit_idle_cb(gpointer UNUSED(data))
674 {
675         exit_program();
676
677         return G_SOURCE_REMOVE;
678 }
679
680 static void gr_quit(const gchar *UNUSED(text), GIOChannel *UNUSED(channel), gpointer UNUSED(data))
681 {
682         /* schedule exit when idle, if done from within a
683          * remote handler remote_close will crash
684          */
685         g_idle_add(gr_quit_idle_cb, NULL);
686 }
687
688 static void gr_file_load_no_raise(const gchar *text, GIOChannel *UNUSED(channel), gpointer UNUSED(data))
689 {
690         gchar *filename;
691         gchar *tilde_filename;
692
693         if (!download_web_file(text, TRUE, NULL))
694                 {
695                 tilde_filename = expand_tilde(text);
696                 filename = set_pwd(tilde_filename);
697
698                 if (isfile(filename))
699                         {
700                         if (file_extension_match(filename, GQ_COLLECTION_EXT))
701                                 {
702                                 collection_window_new(filename);
703                                 }
704                         else
705                                 {
706                                 layout_set_path(lw_id, filename);
707                                 }
708                         }
709                 else if (isdir(filename))
710                         {
711                         layout_set_path(lw_id, filename);
712                         }
713                 else
714                         {
715                         log_printf("remote sent filename that does not exist:\"%s\"\n", filename);
716                         layout_set_path(lw_id, homedir());
717                         }
718
719                 g_free(filename);
720                 g_free(tilde_filename);
721                 }
722 }
723
724 static void gr_file_load(const gchar *text, GIOChannel *channel, gpointer data)
725 {
726         gr_file_load_no_raise(text, channel, data);
727
728         gr_raise(text, channel, data);
729 }
730
731 static void gr_pixel_info(const gchar *UNUSED(text), GIOChannel *channel, gpointer UNUSED(data))
732 {
733         gchar *pixel_info;
734         gint x_pixel, y_pixel;
735         gint width, height;
736         gint r_mouse, g_mouse, b_mouse;
737         PixbufRenderer *pr;
738
739         if (!layout_valid(&lw_id)) return;
740
741         pr = (PixbufRenderer*)lw_id->image->pr;
742
743         if (pr)
744                 {
745                 pixbuf_renderer_get_image_size(pr, &width, &height);
746                 if (width < 1 || height < 1) return;
747
748                 pixbuf_renderer_get_mouse_position(pr, &x_pixel, &y_pixel);
749
750                 if (x_pixel >= 0 && y_pixel >= 0)
751                         {
752                         pixbuf_renderer_get_pixel_colors(pr, x_pixel, y_pixel,
753                                                          &r_mouse, &g_mouse, &b_mouse);
754
755                         pixel_info = g_strdup_printf(_("[%d,%d]: RGB(%3d,%3d,%3d)"),
756                                                  x_pixel, y_pixel,
757                                                  r_mouse, g_mouse, b_mouse);
758
759                         g_io_channel_write_chars(channel, pixel_info, -1, NULL, NULL);
760                         g_io_channel_write_chars(channel, "<gq_end_of_command>", -1, NULL, NULL);
761
762                         g_free(pixel_info);
763                         }
764                 else
765                         {
766                         return;
767                         }
768                 }
769         else
770                 {
771                 return;
772                 }
773 }
774
775 static void gr_rectangle(const gchar *UNUSED(text), GIOChannel *channel, gpointer UNUSED(data))
776 {
777         gchar *rectangle_info;
778         PixbufRenderer *pr;
779         gint x1, y1, x2, y2;
780
781         if (!options->draw_rectangle) return;
782         if (!layout_valid(&lw_id)) return;
783
784         pr = (PixbufRenderer*)lw_id->image->pr;
785
786         if (pr)
787                 {
788                 image_get_rectangle(&x1, &y1, &x2, &y2);
789                 rectangle_info = g_strdup_printf(_("%dx%d+%d+%d"),
790                                         (x2 > x1) ? x2 - x1 : x1 - x2,
791                                         (y2 > y1) ? y2 - y1 : y1 - y2,
792                                         (x2 > x1) ? x1 : x2,
793                                         (y2 > y1) ? y1 : y2);
794
795                 g_io_channel_write_chars(channel, rectangle_info, -1, NULL, NULL);
796                 g_io_channel_write_chars(channel, "<gq_end_of_command>", -1, NULL, NULL);
797
798                 g_free(rectangle_info);
799                 }
800 }
801
802 static void gr_render_intent(const gchar *UNUSED(text), GIOChannel *channel, gpointer UNUSED(data))
803 {
804         gchar *render_intent;
805
806         switch (options->color_profile.render_intent)
807                 {
808                 case 0:
809                         render_intent = g_strdup("Perceptual");
810                         break;
811                 case 1:
812                         render_intent = g_strdup("Relative Colorimetric");
813                         break;
814                 case 2:
815                         render_intent = g_strdup("Saturation");
816                         break;
817                 case 3:
818                         render_intent = g_strdup("Absolute Colorimetric");
819                         break;
820                 default:
821                         render_intent = g_strdup("none");
822                         break;
823                 }
824
825         g_io_channel_write_chars(channel, render_intent, -1, NULL, NULL);
826         g_io_channel_write_chars(channel, "<gq_end_of_command>", -1, NULL, NULL);
827
828         g_free(render_intent);
829 }
830
831 static void get_filelist(const gchar *text, GIOChannel *channel, gboolean recurse)
832 {
833         GList *list = NULL;
834         FileFormatClass format_class;
835         FileData *dir_fd;
836         FileData *fd;
837         GString *out_string = g_string_new(NULL);
838         GList *work;
839         gchar *tilde_filename;
840
841         if (strcmp(text, "") == 0)
842                 {
843                 if (layout_valid(&lw_id))
844                         {
845                         dir_fd = file_data_new_dir(lw_id->dir_fd->path);
846                         }
847                 else
848                         {
849                         return;
850                         }
851                 }
852         else
853                 {
854                 tilde_filename = expand_tilde(text);
855                 if (isdir(tilde_filename))
856                         {
857                         dir_fd = file_data_new_dir(tilde_filename);
858                         }
859                 else
860                         {
861                         g_free(tilde_filename);
862                         return;
863                         }
864                 g_free(tilde_filename);
865                 }
866
867         if (recurse)
868                 {
869                 list = filelist_recursive(dir_fd);
870                 }
871         else
872                 {
873                 filelist_read(dir_fd, &list, NULL);
874                 }
875
876         work = list;
877         while (work)
878                 {
879                 fd = static_cast<FileData *>(work->data);
880                 g_string_append_printf(out_string, "%s", fd->path);
881                 format_class = filter_file_get_class(fd->path);
882
883                 switch (format_class)
884                         {
885                         case FORMAT_CLASS_IMAGE:
886                                 out_string = g_string_append(out_string, "    Class: Image");
887                                 break;
888                         case FORMAT_CLASS_RAWIMAGE:
889                                 out_string = g_string_append(out_string, "    Class: RAW image");
890                                 break;
891                         case FORMAT_CLASS_META:
892                                 out_string = g_string_append(out_string, "    Class: Metadata");
893                                 break;
894                         case FORMAT_CLASS_VIDEO:
895                                 out_string = g_string_append(out_string, "    Class: Video");
896                                 break;
897                         case FORMAT_CLASS_COLLECTION:
898                                 out_string = g_string_append(out_string, "    Class: Collection");
899                                 break;
900                         case FORMAT_CLASS_DOCUMENT:
901                                 out_string = g_string_append(out_string, "    Class: Document");
902                                 break;
903                         case FORMAT_CLASS_ARCHIVE:
904                                 out_string = g_string_append(out_string, "    Class: Archive");
905                                 break;
906                         case FORMAT_CLASS_UNKNOWN:
907                                 out_string = g_string_append(out_string, "    Class: Unknown");
908                                 break;
909                         default:
910                                 out_string = g_string_append(out_string, "    Class: Unknown");
911                                 break;
912                         }
913                 out_string = g_string_append(out_string, "\n");
914                 work = work->next;
915                 }
916
917         g_io_channel_write_chars(channel, out_string->str, -1, NULL, NULL);
918         g_io_channel_write_chars(channel, "<gq_end_of_command>", -1, NULL, NULL);
919
920         g_string_free(out_string, TRUE);
921         filelist_free(list);
922         file_data_unref(dir_fd);
923 }
924
925 static void gr_get_selection(const gchar *UNUSED(text), GIOChannel *channel, gpointer UNUSED(data))
926 {
927         if (!layout_valid(&lw_id)) return;
928
929         GList *selected = layout_selection_list(lw_id);  // Keep copy to free.
930         GString *out_string = g_string_new(NULL);
931
932         GList *work = selected;
933         while (work)
934                 {
935                 FileData *fd = static_cast<FileData *>(work->data);
936                 g_assert(fd->magick == FD_MAGICK);
937
938                 g_string_append_printf(out_string, "%s    %s\n",
939                                        fd->path,
940                                        format_class_list[filter_file_get_class(fd->path)]);
941
942                 work = work->next;
943                 }
944
945         g_io_channel_write_chars(channel, out_string->str, -1, NULL, NULL);
946         g_io_channel_write_chars(channel, "<gq_end_of_command>", -1, NULL, NULL);
947
948         filelist_free(selected);
949         g_string_free(out_string, TRUE);
950 }
951
952 static void gr_selection_add(const gchar *text, GIOChannel *UNUSED(channel), gpointer UNUSED(data))
953 {
954         if (!layout_valid(&lw_id)) return;
955
956         FileData *fd_to_select = NULL;
957         if (strcmp(text, "") == 0)
958                 {
959                 // No file specified, use current fd.
960                 fd_to_select = layout_image_get_fd(lw_id);
961                 }
962         else
963                 {
964                 // Search through the current file list for a file matching the specified path.
965                 // "Match" is either a basename match or a file path match.
966                 gchar *path = expand_tilde(text);
967                 gchar *filename = g_path_get_basename(path);
968                 gchar *slash_plus_filename = g_strdup_printf("%s%s", G_DIR_SEPARATOR_S, filename);
969
970                 GList *file_list = layout_list(lw_id);
971                 for (GList *work = file_list; work && !fd_to_select; work = work->next)
972                         {
973                         FileData *fd = static_cast<FileData *>(work->data);
974                         if (!strcmp(path, fd->path) || g_str_has_suffix(fd->path, slash_plus_filename))
975                                 {
976                                 fd_to_select = file_data_ref(fd);
977                                 continue;  // will exit loop.
978                                 }
979
980                         for (GList *sidecar = fd->sidecar_files; sidecar && !fd_to_select; sidecar = sidecar->next)
981                                 {
982                                 FileData *side_fd = static_cast<FileData *>(sidecar->data);
983                                 if (!strcmp(path, side_fd->path)
984                                     || g_str_has_suffix(side_fd->path, slash_plus_filename))
985                                         {
986                                         fd_to_select = file_data_ref(side_fd);
987                                         continue;  // will exit both nested loops.
988                                         }
989                                 }
990                         }
991
992                 if (!fd_to_select)
993                         {
994                         log_printf("remote sent --selection-add filename that could not be found: \"%s\"\n",
995                                    filename);
996                         }
997
998                 filelist_free(file_list);
999                 g_free(slash_plus_filename);
1000                 g_free(filename);
1001                 g_free(path);
1002                 }
1003
1004         if (fd_to_select)
1005                 {
1006                 GList *to_select = g_list_append(NULL, fd_to_select);
1007                 // Using the "_list" variant doesn't clear the existing selection.
1008                 layout_select_list(lw_id, to_select);
1009                 filelist_free(to_select);
1010                 }
1011 }
1012
1013 static void gr_selection_clear(const gchar *UNUSED(text), GIOChannel *UNUSED(channel), gpointer UNUSED(data))
1014 {
1015         layout_select_none(lw_id);  // Checks lw_id validity internally.
1016 }
1017
1018 static void gr_selection_remove(const gchar *text, GIOChannel *UNUSED(channel), gpointer UNUSED(data))
1019 {
1020         if (!layout_valid(&lw_id)) return;
1021
1022         GList *selected = layout_selection_list(lw_id);  // Keep copy to free.
1023         if (!selected)
1024                 {
1025                 log_printf("remote sent --selection-remove with empty selection.");
1026                 return;
1027                 }
1028
1029         FileData *fd_to_deselect = NULL;
1030         gchar *path = NULL;
1031         gchar *filename = NULL;
1032         gchar *slash_plus_filename = NULL;
1033         if (strcmp(text, "") == 0)
1034                 {
1035                 // No file specified, use current fd.
1036                 fd_to_deselect = layout_image_get_fd(lw_id);
1037                 if (!fd_to_deselect)
1038                         {
1039                         log_printf("remote sent \"--selection-remove:\" with no current image");
1040                         filelist_free(selected);
1041                         return;
1042                         }
1043                 }
1044         else
1045                 {
1046                 // Search through the selection list for a file matching the specified path.
1047                 // "Match" is either a basename match or a file path match.
1048                 path = expand_tilde(text);
1049                 filename = g_path_get_basename(path);
1050                 slash_plus_filename = g_strdup_printf("%s%s", G_DIR_SEPARATOR_S, filename);
1051                 }
1052
1053         GList *prior_link = NULL;  // Stash base for link removal to avoid a second traversal.
1054         GList *link_to_remove = NULL;
1055         for (GList *work = selected; work; prior_link = work, work = work->next)
1056                 {
1057                 FileData *fd = static_cast<FileData *>(work->data);
1058                 if (fd_to_deselect)
1059                         {
1060                         if (fd == fd_to_deselect)
1061                                 {
1062                                 link_to_remove = work;
1063                                 break;
1064                                 }
1065                         }
1066                 else
1067                         {
1068                         // path, filename, and slash_plus_filename should be defined.
1069
1070                         if (!strcmp(path, fd->path) || g_str_has_suffix(fd->path, slash_plus_filename))
1071                                 {
1072                                 link_to_remove = work;
1073                                 break;
1074                                 }
1075                         }
1076                 }
1077
1078         if (!link_to_remove)
1079                 {
1080                 if (fd_to_deselect)
1081                         {
1082                         log_printf("remote sent \"--selection-remove:\" but current image is not selected");
1083                         }
1084                 else
1085                         {
1086                         log_printf("remote sent \"--selection-remove:%s\" but that filename is not selected",
1087                                    filename);
1088                         }
1089                 }
1090         else
1091                 {
1092                 if (link_to_remove == selected)
1093                         {
1094                         // Remove first link.
1095                         selected = g_list_remove_link(selected, link_to_remove);
1096                         filelist_free(link_to_remove);
1097                         link_to_remove = NULL;
1098                         }
1099                 else
1100                         {
1101                         // Remove a subsequent link.
1102                         prior_link = g_list_remove_link(prior_link, link_to_remove);
1103                         filelist_free(link_to_remove);
1104                         link_to_remove = NULL;
1105                         }
1106
1107                 // Re-select all but the deselected item.
1108                 layout_select_none(lw_id);
1109                 layout_select_list(lw_id, selected);
1110                 }
1111
1112         filelist_free(selected);
1113         file_data_unref(fd_to_deselect);
1114         g_free(slash_plus_filename);
1115         g_free(filename);
1116         g_free(path);
1117 }
1118
1119 static void gr_collection(const gchar *text, GIOChannel *channel, gpointer UNUSED(data))
1120 {
1121         GString *contents = g_string_new(NULL);
1122
1123         if (is_collection(text))
1124                 {
1125                 collection_contents(text, &contents);
1126                 }
1127         else
1128                 {
1129                 return;
1130                 }
1131
1132         g_io_channel_write_chars(channel, contents->str, -1, NULL, NULL);
1133         g_io_channel_write_chars(channel, "<gq_end_of_command>", -1, NULL, NULL);
1134
1135         g_string_free(contents, TRUE);
1136 }
1137
1138 static void gr_collection_list(const gchar *UNUSED(text), GIOChannel *channel, gpointer UNUSED(data))
1139 {
1140
1141         GList *collection_list = NULL;
1142         GList *work;
1143         GString *out_string = g_string_new(NULL);
1144
1145         collect_manager_list(&collection_list, NULL, NULL);
1146
1147         work = collection_list;
1148         while (work)
1149                 {
1150                 const gchar *collection_name = static_cast<const gchar *>(work->data);
1151                 out_string = g_string_append(out_string, g_strdup(collection_name));
1152                 out_string = g_string_append(out_string, "\n");
1153
1154                 work = work->next;
1155                 }
1156
1157         g_io_channel_write_chars(channel, out_string->str, -1, NULL, NULL);
1158         g_io_channel_write_chars(channel, "<gq_end_of_command>", -1, NULL, NULL);
1159
1160         string_list_free(collection_list);
1161         g_string_free(out_string, TRUE);
1162 }
1163
1164 static gboolean wait_cb(const gpointer data)
1165 {
1166         gint position = GPOINTER_TO_INT(data);
1167         gint x = position >> 16;
1168         gint y = position - (x << 16);
1169
1170         gtk_window_move(GTK_WINDOW(lw_id->window), x, y);
1171
1172         return G_SOURCE_REMOVE;
1173 }
1174
1175 static void gr_geometry(const gchar *text, GIOChannel *UNUSED(channel), gpointer UNUSED(data))
1176 {
1177         gchar **geometry;
1178
1179         if (!layout_valid(&lw_id) || !text)
1180                 {
1181                 return;
1182                 }
1183
1184         if (text[0] == '+')
1185                 {
1186                 geometry = g_strsplit_set(text, "+", 3);
1187                 if (geometry[1] != NULL && geometry[2] != NULL )
1188                         {
1189                         gtk_window_move(GTK_WINDOW(lw_id->window), atoi(geometry[1]), atoi(geometry[2]));
1190                         }
1191                 }
1192         else
1193                 {
1194                 geometry = g_strsplit_set(text, "+x", 4);
1195                 if (geometry[0] != NULL && geometry[1] != NULL)
1196                         {
1197                         gtk_window_resize(GTK_WINDOW(lw_id->window), atoi(geometry[0]), atoi(geometry[1]));
1198                         }
1199                 if (geometry[2] != NULL && geometry[3] != NULL)
1200                         {
1201                         /* There is an occasional problem with a window_move immediately after a window_resize */
1202                         g_idle_add(wait_cb, GINT_TO_POINTER((atoi(geometry[2]) << 16) + atoi(geometry[3])));
1203                         }
1204                 }
1205         g_strfreev(geometry);
1206 }
1207
1208 static void gr_filelist(const gchar *text, GIOChannel *channel, gpointer UNUSED(data))
1209 {
1210         get_filelist(text, channel, FALSE);
1211 }
1212
1213 static void gr_filelist_recurse(const gchar *text, GIOChannel *channel, gpointer UNUSED(data))
1214 {
1215         get_filelist(text, channel, TRUE);
1216 }
1217
1218 static void gr_file_tell(const gchar *UNUSED(text), GIOChannel *channel, gpointer UNUSED(data))
1219 {
1220         gchar *out_string;
1221         gchar *collection_name = NULL;
1222
1223         if (!layout_valid(&lw_id)) return;
1224
1225         if (image_get_path(lw_id->image))
1226                 {
1227                 if (lw_id->image->collection && lw_id->image->collection->name)
1228                         {
1229                         collection_name = remove_extension_from_path(lw_id->image->collection->name);
1230                         out_string = g_strconcat(image_get_path(lw_id->image), "    Collection: ", collection_name, NULL);
1231                         }
1232                 else
1233                         {
1234                         out_string = g_strconcat(image_get_path(lw_id->image), NULL);
1235                         }
1236                 }
1237         else
1238                 {
1239                 out_string = g_strconcat(lw_id->dir_fd->path, G_DIR_SEPARATOR_S, NULL);
1240                 }
1241
1242         g_io_channel_write_chars(channel, out_string, -1, NULL, NULL);
1243         g_io_channel_write_chars(channel, "<gq_end_of_command>", -1, NULL, NULL);
1244
1245         g_free(collection_name);
1246         g_free(out_string);
1247 }
1248
1249 static void gr_file_info(const gchar *UNUSED(text), GIOChannel *channel, gpointer UNUSED(data))
1250 {
1251         gchar *filename;
1252         FileData *fd;
1253         gchar *country_name;
1254         gchar *country_code;
1255         gchar *timezone;
1256         gchar *local_time;
1257         GString *out_string;
1258         FileFormatClass format_class;
1259
1260         if (!layout_valid(&lw_id)) return;
1261
1262         if (image_get_path(lw_id->image))
1263                 {
1264                 filename = g_strdup(image_get_path(lw_id->image));
1265                 fd = file_data_new_group(filename);
1266                 out_string = g_string_new(NULL);
1267
1268                 format_class = filter_file_get_class(image_get_path(lw_id->image));
1269                 if (format_class)
1270                         {
1271                         g_string_append_printf(out_string, _("Class: %s\n"), format_class_list[format_class]);
1272                         }
1273
1274                 if (fd->page_total > 1)
1275                         {
1276                         g_string_append_printf(out_string, _("Page no: %d/%d\n"), fd->page_num + 1, fd->page_total);
1277                         }
1278
1279                 if (fd->exif)
1280                         {
1281                         country_name = exif_get_data_as_text(fd->exif, "formatted.countryname");
1282                         if (country_name)
1283                                 {
1284                                 g_string_append_printf(out_string, _("Country name: %s\n"), country_name);
1285                                 g_free(country_name);
1286                                 }
1287
1288                         country_code = exif_get_data_as_text(fd->exif, "formatted.countrycode");
1289                         if (country_name)
1290                                 {
1291                                 g_string_append_printf(out_string, _("Country code: %s\n"), country_code);
1292                                 g_free(country_code);
1293                                 }
1294
1295                         timezone = exif_get_data_as_text(fd->exif, "formatted.timezone");
1296                         if (timezone)
1297                                 {
1298                                 g_string_append_printf(out_string, _("Timezone: %s\n"), timezone);
1299                                 g_free(timezone);
1300                                 }
1301
1302                         local_time = exif_get_data_as_text(fd->exif, "formatted.localtime");
1303                         if (local_time)
1304                                 {
1305                                 g_string_append_printf(out_string, ("Local time: %s\n"), local_time);
1306                                 g_free(local_time);
1307                                 }
1308                         }
1309
1310                 g_io_channel_write_chars(channel, out_string->str, -1, NULL, NULL);
1311                 g_io_channel_write_chars(channel, "<gq_end_of_command>", -1, NULL, NULL);
1312
1313                 g_string_free(out_string, TRUE);
1314                 file_data_unref(fd);
1315                 g_free(filename);
1316                 }
1317 }
1318
1319 static gchar *config_file_path(const gchar *param)
1320 {
1321         gchar *path = NULL;
1322         gchar *full_name = NULL;
1323
1324         if (file_extension_match(param, ".xml"))
1325                 {
1326                 path = g_build_filename(get_window_layouts_dir(), param, NULL);
1327                 }
1328         else if (file_extension_match(param, NULL))
1329                 {
1330                 full_name = g_strconcat(param, ".xml", NULL);
1331                 path = g_build_filename(get_window_layouts_dir(), full_name, NULL);
1332                 }
1333
1334         if (!isfile(path))
1335                 {
1336                 g_free(path);
1337                 path = NULL;
1338                 }
1339
1340         g_free(full_name);
1341         return path;
1342 }
1343
1344 static gboolean is_config_file(const gchar *param)
1345 {
1346         gchar *name = NULL;
1347
1348         name = config_file_path(param);
1349         if (name)
1350                 {
1351                 g_free(name);
1352                 return TRUE;
1353                 }
1354         return FALSE;
1355 }
1356
1357 static void gr_config_load(const gchar *text, GIOChannel *UNUSED(channel), gpointer UNUSED(data))
1358 {
1359         gchar *filename = expand_tilde(text);
1360
1361         if (!g_strstr_len(filename, -1, G_DIR_SEPARATOR_S))
1362                 {
1363                 if (is_config_file(filename))
1364                         {
1365                         gchar *tmp = config_file_path(filename);
1366                         g_free(filename);
1367                         filename = tmp;
1368                         }
1369                 }
1370
1371         if (isfile(filename))
1372                 {
1373                 load_config_from_file(filename, FALSE);
1374                 }
1375         else
1376                 {
1377                 log_printf("remote sent filename that does not exist:\"%s\"\n", filename);
1378                 layout_set_path(NULL, homedir());
1379                 }
1380
1381         g_free(filename);
1382 }
1383
1384 static void gr_get_sidecars(const gchar *text, GIOChannel *channel, gpointer UNUSED(data))
1385 {
1386         gchar *filename = expand_tilde(text);
1387         FileData *fd = file_data_new_group(filename);
1388
1389         GList *work;
1390         if (fd->parent) fd = fd->parent;
1391
1392         g_io_channel_write_chars(channel, fd->path, -1, NULL, NULL);
1393         g_io_channel_write_chars(channel, "<gq_end_of_command>", -1, NULL, NULL);
1394
1395         work = fd->sidecar_files;
1396
1397         while (work)
1398                 {
1399                 fd = static_cast<FileData *>(work->data);
1400                 work = work->next;
1401                 g_io_channel_write_chars(channel, fd->path, -1, NULL, NULL);
1402                 g_io_channel_write_chars(channel, "<gq_end_of_command>", -1, NULL, NULL);
1403                 }
1404         g_free(filename);
1405 }
1406
1407 static void gr_get_destination(const gchar *text, GIOChannel *channel, gpointer UNUSED(data))
1408 {
1409         gchar *filename = expand_tilde(text);
1410         FileData *fd = file_data_new_group(filename);
1411
1412         if (fd->change && fd->change->dest)
1413                 {
1414                 g_io_channel_write_chars(channel, fd->change->dest, -1, NULL, NULL);
1415                 g_io_channel_write_chars(channel, "<gq_end_of_command>", -1, NULL, NULL);
1416                 }
1417         g_free(filename);
1418 }
1419
1420 static void gr_file_view(const gchar *text, GIOChannel *UNUSED(channel), gpointer UNUSED(data))
1421 {
1422         gchar *filename;
1423         gchar *tilde_filename = expand_tilde(text);
1424
1425         filename = set_pwd(tilde_filename);
1426
1427         view_window_new(file_data_new_group(filename));
1428         g_free(filename);
1429         g_free(tilde_filename);
1430 }
1431
1432 static void gr_list_clear(const gchar *UNUSED(text), GIOChannel *UNUSED(channel), gpointer data)
1433 {
1434         RemoteData *remote_data = static_cast<RemoteData *>(data);
1435
1436         remote_data->command_collection = NULL;
1437         remote_data->file_list = NULL;
1438         remote_data->single_dir = TRUE;
1439 }
1440
1441 static void gr_list_add(const gchar *text, GIOChannel *UNUSED(channel), gpointer data)
1442 {
1443         RemoteData *remote_data = static_cast<RemoteData *>(data);
1444         gboolean is_new = TRUE;
1445         gchar *path = NULL;
1446         FileData *fd;
1447         FileData *first;
1448
1449         /** @FIXME Should check if file is in current dir, has tilde or is relative */
1450         if (!isfile(text))
1451                 {
1452                 log_printf("Warning: File does not exist --remote --list-add:%s", text);
1453
1454                 return;
1455                 }
1456
1457         /* If there is a files list on the command line
1458          * check if they are all in the same folder
1459          */
1460         if (remote_data->single_dir)
1461                 {
1462                 GList *work;
1463                 work = remote_data->file_list;
1464                 while (work && remote_data->single_dir)
1465                         {
1466                         gchar *dirname;
1467                         dirname = g_path_get_dirname(((FileData *)work->data)->path);
1468                         if (!path)
1469                                 {
1470                                 path = g_strdup(dirname);
1471                                 }
1472                         else
1473                                 {
1474                                 if (g_strcmp0(path, dirname) != 0)
1475                                         {
1476                                         remote_data->single_dir = FALSE;
1477                                         }
1478                                 }
1479                         g_free(dirname);
1480                         work = work->next;
1481                         }
1482                 g_free(path);
1483                 }
1484
1485         gchar *pathname = g_path_get_dirname(text);
1486         layout_set_path(lw_id, pathname);
1487         g_free(pathname);
1488
1489         fd = file_data_new_simple(text);
1490         remote_data->file_list = g_list_append(remote_data->file_list, fd);
1491         file_data_unref(fd);
1492
1493         vf_select_none(lw_id->vf);
1494         remote_data->file_list = g_list_reverse(remote_data->file_list);
1495
1496         layout_select_list(lw_id, remote_data->file_list);
1497         layout_refresh(lw_id);
1498         first = (FileData *)(g_list_first(vf_selection_get_list(lw_id->vf))->data);
1499         layout_set_fd(lw_id, first);
1500
1501                 CollectionData *cd;
1502                 CollectWindow *cw;
1503
1504         if (!remote_data->command_collection && !remote_data->single_dir)
1505                 {
1506                 cw = collection_window_new(NULL);
1507                 cd = cw->cd;
1508
1509                 collection_path_changed(cd);
1510
1511                 remote_data->command_collection = cd;
1512                 }
1513         else if (!remote_data->single_dir)
1514                 {
1515                 is_new = (!collection_get_first(remote_data->command_collection));
1516                 }
1517
1518         if (!remote_data->single_dir)
1519                 {
1520                 layout_image_set_collection(lw_id, remote_data->command_collection, collection_get_first(remote_data->command_collection));
1521                 if (collection_add(remote_data->command_collection, file_data_new_group(text), FALSE) && is_new)
1522                         {
1523                         layout_image_set_collection(lw_id, remote_data->command_collection, collection_get_first(remote_data->command_collection));
1524                         }
1525                 }
1526 }
1527
1528 static void gr_raise(const gchar *UNUSED(text), GIOChannel *UNUSED(channel), gpointer UNUSED(data))
1529 {
1530         if (layout_valid(&lw_id))
1531                 {
1532                 gtk_window_present(GTK_WINDOW(lw_id->window));
1533                 }
1534 }
1535
1536 static void gr_pwd(const gchar *text, GIOChannel *UNUSED(channel), gpointer UNUSED(data))
1537 {
1538         LayoutWindow *lw = NULL;
1539
1540         layout_valid(&lw);
1541
1542         g_free(pwd);
1543         pwd = g_strdup(text);
1544         lw_id = lw;
1545 }
1546
1547 static void gr_print0(const gchar *UNUSED(text), GIOChannel *channel, gpointer UNUSED(data))
1548 {
1549         g_io_channel_write_chars(channel, "print0", -1, NULL, NULL);
1550         g_io_channel_write_chars(channel, "<gq_end_of_command>", -1, NULL, NULL);
1551 }
1552
1553 #ifdef HAVE_LUA
1554 static void gr_lua(const gchar *text, GIOChannel *channel, gpointer UNUSED(data))
1555 {
1556         gchar *result = NULL;
1557         gchar **lua_command;
1558
1559         lua_command = g_strsplit(text, ",", 2);
1560
1561         if (lua_command[0] && lua_command[1])
1562                 {
1563                 FileData *fd = file_data_new_group(lua_command[0]);
1564                 result = g_strdup(lua_callvalue(fd, lua_command[1], NULL));
1565                 if (result)
1566                         {
1567                         g_io_channel_write_chars(channel, result, -1, NULL, NULL);
1568                         }
1569                 else
1570                         {
1571                         g_io_channel_write_chars(channel, N_("lua error: no data"), -1, NULL, NULL);
1572                         }
1573                 }
1574         else
1575                 {
1576                 g_io_channel_write_chars(channel, N_("lua error: no data"), -1, NULL, NULL);
1577                 }
1578
1579         g_io_channel_write_chars(channel, "<gq_end_of_command>", -1, NULL, NULL);
1580
1581         g_strfreev(lua_command);
1582         g_free(result);
1583 }
1584 #endif
1585
1586 typedef struct _RemoteCommandEntry RemoteCommandEntry;
1587 struct _RemoteCommandEntry {
1588         const gchar *opt_s;
1589         const gchar *opt_l;
1590         void (*func)(const gchar *text, GIOChannel *channel, gpointer data);
1591         gboolean needs_extra;
1592         gboolean prefer_command_line;
1593         const gchar *parameter;
1594         const gchar *description;
1595 };
1596
1597 static RemoteCommandEntry remote_commands[] = {
1598         /* short, long                  callback,               extra, prefer, parameter, description */
1599         { "-b", "--back",               gr_image_prev,          FALSE, FALSE, NULL, N_("previous image") },
1600         { NULL, "--close-window",       gr_close_window,        FALSE, FALSE, NULL, N_("close window") },
1601         { NULL, "--config-load:",       gr_config_load,         TRUE,  FALSE, N_("<FILE>|layout ID"), N_("load configuration from FILE") },
1602         { "-cm","--cache-metadata",      gr_cache_metadata,               FALSE, FALSE, NULL, N_("clean the metadata cache") },
1603         { "-cr:", "--cache-render:",    gr_cache_render,        TRUE, FALSE, N_("<folder>  "), N_(" render thumbnails") },
1604         { "-crr:", "--cache-render-recurse:", gr_cache_render_recurse, TRUE, FALSE, N_("<folder> "), N_("render thumbnails recursively") },
1605         { "-crs:", "--cache-render-shared:", gr_cache_render_standard, TRUE, FALSE, N_("<folder> "), N_(" render thumbnails (see Help)") },
1606         { "-crsr:", "--cache-render-shared-recurse:", gr_cache_render_standard_recurse, TRUE, FALSE, N_("<folder>"), N_(" render thumbnails recursively (see Help)") },
1607         { "-cs:", "--cache-shared:",    gr_cache_shared,        TRUE, FALSE, N_("clear|clean"), N_("clear or clean shared thumbnail cache") },
1608         { "-ct:", "--cache-thumbs:",    gr_cache_thumb,         TRUE, FALSE, N_("clear|clean"), N_("clear or clean thumbnail cache") },
1609         { "-d", "--delay=",             gr_slideshow_delay,     TRUE,  FALSE, N_("<[H:][M:][N][.M]>"), N_("set slide show delay to Hrs Mins N.M seconds") },
1610         { NULL, "--first",              gr_image_first,         FALSE, FALSE, NULL, N_("first image") },
1611         { "-f", "--fullscreen",         gr_fullscreen_toggle,   FALSE, TRUE,  NULL, N_("toggle full screen") },
1612         { NULL, "--file:",              gr_file_load,           TRUE,  FALSE, N_("<FILE>|<URL>"), N_("open FILE or URL, bring Geeqie window to the top") },
1613         { NULL, "file:",                gr_file_load,           TRUE,  FALSE, N_("<FILE>|<URL>"), N_("open FILE or URL, bring Geeqie window to the top") },
1614         { NULL, "--File:",              gr_file_load_no_raise,  TRUE,  FALSE, N_("<FILE>|<URL>"), N_("open FILE or URL, do not bring Geeqie window to the top") },
1615         { NULL, "File:",                gr_file_load_no_raise,  TRUE,  FALSE, N_("<FILE>|<URL>"), N_("open FILE or URL, do not bring Geeqie window to the top") },
1616         { "-fs","--fullscreen-start",   gr_fullscreen_start,    FALSE, FALSE, NULL, N_("start full screen") },
1617         { "-fS","--fullscreen-stop",    gr_fullscreen_stop,     FALSE, FALSE, NULL, N_("stop full screen") },
1618         { NULL, "--geometry=",          gr_geometry,            TRUE, FALSE, N_("<GEOMETRY>"), N_("set window geometry") },
1619         { NULL, "--get-collection:",    gr_collection,          TRUE,  FALSE, N_("<COLLECTION>"), N_("get collection content") },
1620         { NULL, "--get-collection-list", gr_collection_list,    FALSE, FALSE, NULL, N_("get collection list") },
1621         { NULL, "--get-destination:",   gr_get_destination,     TRUE,  FALSE, N_("<FILE>"), N_("get destination path of FILE (See Plugins Configuration)") },
1622         { NULL, "--get-file-info",      gr_file_info,           FALSE, FALSE, NULL, N_("get file info") },
1623         { NULL, "--get-filelist:",      gr_filelist,            TRUE,  FALSE, N_("[<FOLDER>]"), N_("get list of files and class") },
1624         { NULL, "--get-filelist-recurse:", gr_filelist_recurse, TRUE,  FALSE, N_("[<FOLDER>]"), N_("get list of files and class recursive") },
1625         { NULL, "--get-rectangle",      gr_rectangle,           FALSE, FALSE, NULL, N_("get rectangle co-ordinates") },
1626         { NULL, "--get-render-intent",  gr_render_intent,       FALSE, FALSE, NULL, N_("get render intent") },
1627         { NULL, "--get-selection",      gr_get_selection,       FALSE, FALSE, NULL, N_("get list of selected files") },
1628         { NULL, "--get-sidecars:",      gr_get_sidecars,        TRUE,  FALSE, N_("<FILE>"), N_("get list of sidecars of FILE") },
1629         { NULL, "--id:",                gr_lw_id,               TRUE, FALSE, N_("<ID>"), N_("window id for following commands") },
1630         { NULL, "--last",               gr_image_last,          FALSE, FALSE, NULL, N_("last image") },
1631         { NULL, "--list-add:",          gr_list_add,            TRUE,  FALSE, N_("<FILE>"), N_("add FILE to command line collection list") },
1632         { NULL, "--list-clear",         gr_list_clear,          FALSE, FALSE, NULL, N_("clear command line collection list") },
1633 #ifdef HAVE_LUA
1634         { NULL, "--lua:",               gr_lua,                 TRUE, FALSE, N_("<FILE>,<lua script>"), N_("run lua script on FILE") },
1635 #endif
1636         { NULL, "--new-window",         gr_new_window,          FALSE, FALSE, NULL, N_("new window") },
1637         { "-n", "--next",               gr_image_next,          FALSE, FALSE, NULL, N_("next image") },
1638         { NULL, "--pixel-info",         gr_pixel_info,          FALSE, FALSE, NULL, N_("print pixel info of mouse pointer on current image") },
1639         { NULL, "--print0",             gr_print0,              TRUE, FALSE, NULL, N_("terminate returned data with null character instead of newline") },
1640         { NULL, "--PWD:",               gr_pwd,                 TRUE, FALSE, N_("<PWD>"), N_("use PWD as working directory for following commands") },
1641         { "-q", "--quit",               gr_quit,                FALSE, FALSE, NULL, N_("quit") },
1642         { NULL, "--raise",              gr_raise,               FALSE, FALSE, NULL, N_("bring the Geeqie window to the top") },
1643         { NULL, "raise",                gr_raise,               FALSE, FALSE, NULL, N_("bring the Geeqie window to the top") },
1644         { NULL, "--selection-add:",     gr_selection_add,       TRUE,  FALSE, N_("[<FILE>]"), N_("adds the current file (or the specified file) to the current selection") },
1645         { NULL, "--selection-clear",    gr_selection_clear,     FALSE, FALSE, NULL, N_("clears the current selection") },
1646         { NULL, "--selection-remove:",  gr_selection_remove,    TRUE,  FALSE, N_("[<FILE>]"), N_("removes the current file (or the specified file) from the current selection") },
1647         { "-s", "--slideshow",          gr_slideshow_toggle,    FALSE, TRUE,  NULL, N_("toggle slide show") },
1648         { NULL, "--slideshow-recurse:", gr_slideshow_start_rec, TRUE,  FALSE, N_("<FOLDER>"), N_("start recursive slide show in FOLDER") },
1649         { "-ss","--slideshow-start",    gr_slideshow_start,     FALSE, FALSE, NULL, N_("start slide show") },
1650         { "-sS","--slideshow-stop",     gr_slideshow_stop,      FALSE, FALSE, NULL, N_("stop slide show") },
1651         { NULL, "--tell",               gr_file_tell,           FALSE, FALSE, NULL, N_("print filename [and Collection] of current image") },
1652         { "+t", "--tools-show",         gr_tools_show,          FALSE, TRUE,  NULL, N_("show tools") },
1653         { "-t", "--tools-hide",         gr_tools_hide,          FALSE, TRUE,  NULL, N_("hide tools") },
1654         { NULL, "--view:",              gr_file_view,           TRUE,  FALSE, N_("<FILE>"), N_("open FILE in new window") },
1655         { NULL, "view:",                gr_file_view,           TRUE,  FALSE, N_("<FILE>"), N_("open FILE in new window") },
1656         { NULL, NULL, NULL, FALSE, FALSE, NULL, NULL }
1657 };
1658
1659 static RemoteCommandEntry *remote_command_find(const gchar *text, const gchar **offset)
1660 {
1661         gboolean match = FALSE;
1662         gint i;
1663
1664         i = 0;
1665         while (!match && remote_commands[i].func != NULL)
1666                 {
1667                 if (remote_commands[i].needs_extra)
1668                         {
1669                         if (remote_commands[i].opt_s &&
1670                             strncmp(remote_commands[i].opt_s, text, strlen(remote_commands[i].opt_s)) == 0)
1671                                 {
1672                                 if (offset) *offset = text + strlen(remote_commands[i].opt_s);
1673                                 return &remote_commands[i];
1674                                 }
1675                         else if (remote_commands[i].opt_l &&
1676                                  strncmp(remote_commands[i].opt_l, text, strlen(remote_commands[i].opt_l)) == 0)
1677                                 {
1678                                 if (offset) *offset = text + strlen(remote_commands[i].opt_l);
1679                                 return &remote_commands[i];
1680                                 }
1681                         }
1682                 else
1683                         {
1684                         if ((remote_commands[i].opt_s && strcmp(remote_commands[i].opt_s, text) == 0) ||
1685                             (remote_commands[i].opt_l && strcmp(remote_commands[i].opt_l, text) == 0))
1686                                 {
1687                                 if (offset) *offset = text;
1688                                 return &remote_commands[i];
1689                                 }
1690                         }
1691
1692                 i++;
1693                 }
1694
1695         return NULL;
1696 }
1697
1698 static void remote_cb(RemoteConnection *UNUSED(rc), const gchar *text, GIOChannel *channel, gpointer data)
1699 {
1700         RemoteCommandEntry *entry;
1701         const gchar *offset;
1702
1703         entry = remote_command_find(text, &offset);
1704         if (entry && entry->func)
1705                 {
1706                 entry->func(offset, channel, data);
1707                 }
1708         else
1709                 {
1710                 log_printf("unknown remote command:%s\n", text);
1711                 }
1712 }
1713
1714 void remote_help(void)
1715 {
1716         gint i;
1717         gchar *s_opt_param;
1718         gchar *l_opt_param;
1719
1720         print_term(FALSE, _("Remote command list:\n"));
1721
1722         i = 0;
1723         while (remote_commands[i].func != NULL)
1724                 {
1725                 if (remote_commands[i].description)
1726                         {
1727                         s_opt_param = g_strdup(remote_commands[i].opt_s  ? remote_commands[i].opt_s : "" );
1728                         l_opt_param = g_strconcat(remote_commands[i].opt_l, remote_commands[i].parameter, NULL);
1729                         printf_term(FALSE, "  %-4s %-40s%-s\n",
1730                                         s_opt_param,
1731                                         l_opt_param,
1732                                         _(remote_commands[i].description));
1733                         g_free(s_opt_param);
1734                         g_free(l_opt_param);
1735                         }
1736                 i++;
1737                 }
1738         printf_term(FALSE, _("\n\n  All other command line parameters are used as plain files if they exist.\n\n  The name of a collection, with or without either path or extension (.gqv) may be used.\n"));
1739 }
1740
1741 GList *remote_build_list(GList *list, gint argc, gchar *argv[], GList **errors)
1742 {
1743         gint i;
1744
1745         i = 1;
1746         while (i < argc)
1747                 {
1748                 RemoteCommandEntry *entry;
1749
1750                 entry = remote_command_find(argv[i], NULL);
1751                 if (entry)
1752                         {
1753                         list = g_list_append(list, argv[i]);
1754                         }
1755                 else if (errors && !isname(argv[i]))
1756                         {
1757                         *errors = g_list_append(*errors, argv[i]);
1758                         }
1759                 i++;
1760                 }
1761
1762         return list;
1763 }
1764
1765 /**
1766  * @param arg_exec Binary (argv0)
1767  * @param remote_list Evaluated and recognized remote commands
1768  * @param path The current path
1769  * @param cmd_list List of all non collections in Path (gchar *path)
1770  * @param collection_list List of all collections in argv
1771  */
1772 void remote_control(const gchar *arg_exec, GList *remote_list, const gchar *path,
1773                     GList *cmd_list, GList *collection_list)
1774 {
1775         RemoteConnection *rc;
1776         gboolean started = FALSE;
1777         gchar *buf;
1778
1779         buf = g_build_filename(get_rc_dir(), ".command", NULL);
1780         rc = remote_client_open(buf);
1781         if (!rc)
1782                 {
1783                 GString *command;
1784                 GList *work;
1785                 gint retry_count = 12;
1786                 gboolean blank = FALSE;
1787
1788                 printf_term(FALSE, _("Remote %s not running, starting..."), GQ_APPNAME);
1789
1790                 command = g_string_new(arg_exec);
1791
1792                 work = remote_list;
1793                 while (work)
1794                         {
1795                         gchar *text;
1796                         RemoteCommandEntry *entry;
1797
1798                         text = static_cast<gchar *>(work->data);
1799                         work = work->next;
1800
1801                         entry = remote_command_find(text, NULL);
1802                         if (entry)
1803                                 {
1804                                 /* If Geeqie is not running, stop the --new-window command opening a second window */
1805                                 if (g_strcmp0(text, "--new-window") == 0)
1806                                         {
1807                                         remote_list = g_list_remove(remote_list, text);
1808                                         }
1809                                 if (entry->prefer_command_line)
1810                                         {
1811                                         remote_list = g_list_remove(remote_list, text);
1812                                         g_string_append(command, " ");
1813                                         g_string_append(command, text);
1814                                         }
1815                                 if (entry->opt_l && strcmp(entry->opt_l, "file:") == 0)
1816                                         {
1817                                         blank = TRUE;
1818                                         }
1819                                 }
1820                         }
1821
1822                 if (blank || cmd_list || path) g_string_append(command, " --blank");
1823                 if (get_debug_level()) g_string_append(command, " --debug");
1824
1825                 g_string_append(command, " &");
1826                 runcmd(command->str);
1827                 g_string_free(command, TRUE);
1828
1829                 while (!rc && retry_count > 0)
1830                         {
1831                         usleep((retry_count > 10) ? 500000 : 1000000);
1832                         rc = remote_client_open(buf);
1833                         if (!rc) print_term(FALSE, ".");
1834                         retry_count--;
1835                         }
1836
1837                 print_term(FALSE, "\n");
1838
1839                 started = TRUE;
1840                 }
1841         g_free(buf);
1842
1843         if (rc)
1844                 {
1845                 GList *work;
1846                 const gchar *prefix;
1847                 gboolean use_path = TRUE;
1848                 gboolean sent = FALSE;
1849
1850                 work = remote_list;
1851                 while (work)
1852                         {
1853                         gchar *text;
1854                         RemoteCommandEntry *entry;
1855
1856                         text = static_cast<gchar *>(work->data);
1857                         work = work->next;
1858
1859                         entry = remote_command_find(text, NULL);
1860                         if (entry &&
1861                             entry->opt_l &&
1862                             strcmp(entry->opt_l, "file:") == 0) use_path = FALSE;
1863
1864                         remote_client_send(rc, text);
1865
1866                         sent = TRUE;
1867                         }
1868
1869                 if (cmd_list && cmd_list->next)
1870                         {
1871                         prefix = "--list-add:";
1872                         remote_client_send(rc, "--list-clear");
1873                         }
1874                 else
1875                         {
1876                         prefix = "file:";
1877                         }
1878
1879                 work = cmd_list;
1880                 while (work)
1881                         {
1882                         gchar *text;
1883
1884                         text = g_strconcat(prefix, work->data, NULL);
1885                         remote_client_send(rc, text);
1886                         g_free(text);
1887                         work = work->next;
1888
1889                         sent = TRUE;
1890                         }
1891
1892                 if (path && !cmd_list && use_path)
1893                         {
1894                         gchar *text;
1895
1896                         text = g_strdup_printf("file:%s", path);
1897                         remote_client_send(rc, text);
1898                         g_free(text);
1899
1900                         sent = TRUE;
1901                         }
1902
1903                 work = collection_list;
1904                 while (work)
1905                         {
1906                         const gchar *name;
1907                         gchar *text;
1908
1909                         name = static_cast<const gchar *>(work->data);
1910                         work = work->next;
1911
1912                         text = g_strdup_printf("file:%s", name);
1913                         remote_client_send(rc, text);
1914                         g_free(text);
1915
1916                         sent = TRUE;
1917                         }
1918
1919                 if (!started && !sent)
1920                         {
1921                         remote_client_send(rc, "raise");
1922                         }
1923                 }
1924         else
1925                 {
1926                 print_term(TRUE, _("Remote not available\n"));
1927                 }
1928
1929         _exit(0);
1930 }
1931
1932 RemoteConnection *remote_server_init(gchar *path, CollectionData *command_collection)
1933 {
1934         RemoteConnection *remote_connection = remote_server_open(path);
1935         RemoteData *remote_data = g_new(RemoteData, 1);
1936
1937         remote_data->command_collection = command_collection;
1938
1939         remote_server_subscribe(remote_connection, remote_cb, remote_data);
1940         return remote_connection;
1941 }
1942 /* vim: set shiftwidth=8 softtabstop=0 cindent cinoptions={1s: */