gio/gdocumentportal.c

   1 /* GIO - GLib Input, Output and Streaming Library
   2  *
   3  * Copyright 2016 Endless Mobile, Inc.
   4  *
   5  * This library is free software; you can redistribute it and/or
   6  * modify it under the terms of the GNU Lesser General Public
   7  * License as published by the Free Software Foundation; either
   8  * version 2.1 of the License, or (at your option) any later version.
   9  *
  10  * This library is distributed in the hope that it will be useful,
  11  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13  * Lesser General Public License for more details.
  14  *
  15  * You should have received a copy of the GNU Lesser General
  16  * Public License along with this library; if not, see <http://www.gnu.org/licenses/>.
  17  */
  18
  19 #include "config.h"
  20
  21 #include <sys/stat.h>
  22 #include <fcntl.h>
  23 #include <errno.h>
  24 #include <string.h>
  25
  26 #include "gdocumentportal.h"
  27 #include "xdp-dbus.h"
  28 #include "gstdio.h"
  29
  30 #ifdef G_OS_UNIX
  31 #include "gunixfdlist.h"
  32 #endif
  33
  34 #ifndef O_PATH
  35 #define O_PATH 0
  36 #endif
  37 #ifndef O_CLOEXEC
  38 #define O_CLOEXEC 0
  39 #else
  40 #define HAVE_O_CLOEXEC 1
  41 #endif
  42
  43 static GXdpDocuments *documents;
  44 static char *documents_mountpoint;
  45
  46 static gboolean
  47 init_document_portal (void)
  48 {
  49   static gsize documents_inited = 0;
  50
  51   if (g_once_init_enter (&documents_inited))
  52     {
  53       GError *error = NULL;
  54       GDBusConnection *connection = g_bus_get_sync (G_BUS_TYPE_SESSION, NULL, &error);
  55
  56       if (connection != NULL)
  57         {
  58           documents = gxdp_documents_proxy_new_sync (connection, 0,
  59                                                      "org.freedesktop.portal.Documents",
  60                                                      "/org/freedesktop/portal/documents",
  61                                                      NULL, &error);
  62           if (documents != NULL)
  63             {
  64               gxdp_documents_call_get_mount_point_sync (documents,
  65                                                         &documents_mountpoint,
  66                                                         NULL, &error);
  67
  68               if (error != NULL)
  69                 {
  70                   g_warning ("Cannot get document portal mount point: %s", error->message);
  71                   g_error_free (error);
  72                 }
  73             }
  74           else
  75             {
  76               g_warning ("Cannot create document portal proxy: %s", error->message);
  77               g_error_free (error);
  78             }
  79
  80           g_object_unref (connection);
  81         }
  82       else
  83         {
  84           g_warning ("Cannot connect to session bus when initializing document portal: %s",
  85                      error->message);
  86           g_error_free (error);
  87         }
  88
  89       g_once_init_leave (&documents_inited, 1);
  90     }
  91
  92   return (documents != NULL && documents_mountpoint != NULL);
  93 }
  94
  95 char *
  96 g_document_portal_add_document (GFile   *file,
  97                                 GError **error)
  98 {
  99   char *doc_path, *basename;
 100   char *doc_id = NULL;
 101   char *doc_uri = NULL;
 102   char *path = NULL;
 103   GUnixFDList *fd_list = NULL;
 104   int fd, fd_in, errsv;
 105   gboolean ret;
 106
 107   if (!init_document_portal ())
 108     {
 109       g_set_error (error, G_IO_ERROR, G_IO_ERROR_NOT_INITIALIZED,
 110                    "Document portal is not available");
 111       goto out;
 112     }
 113
 114   path = g_file_get_path (file);
 115   fd = g_open (path, O_PATH | O_CLOEXEC);
 116   errsv = errno;
 117
 118   if (fd == -1)
 119     {
 120       g_set_error (error, G_IO_ERROR, g_io_error_from_errno (errsv),
 121                    "Failed to open %s", path);
 122       goto out;
 123     }
 124
 125 #ifndef HAVE_O_CLOEXEC
 126   fcntl (fd, F_SETFD, FD_CLOEXEC);
 127 #endif
 128
 129   fd_list = g_unix_fd_list_new ();
 130   fd_in = g_unix_fd_list_append (fd_list, fd, error);
 131   g_close (fd, NULL);
 132
 133   if (fd_in == -1)
 134     goto out;
 135
 136   ret = gxdp_documents_call_add_sync (documents,
 137                                       g_variant_new_handle (fd_in),
 138                                       TRUE,
 139                                       TRUE,
 140                                       fd_list,
 141                                       &doc_id,
 142                                       NULL,
 143                                       NULL,
 144                                       error);
 145
 146   if (!ret)
 147     goto out;
 148
 149   basename = g_path_get_basename (path);
 150   doc_path = g_build_filename (documents_mountpoint, doc_id, basename, NULL);
 151   g_free (basename);
 152
 153   doc_uri = g_filename_to_uri (doc_path, NULL, NULL);
 154   g_free (doc_path);
 155
 156  out:
 157   if (fd_list)
 158     g_object_unref (fd_list);
 159   g_free (path);
 160   g_free (doc_id);
 161
 162   return doc_uri;
 163 }
 164
 165 /* Flags accepted by org.freedesktop.portal.Documents.AddFull */
 166 enum {
 167   XDP_ADD_FLAGS_REUSE_EXISTING             =  (1 << 0),
 168   XDP_ADD_FLAGS_PERSISTENT                 =  (1 << 1),
 169   XDP_ADD_FLAGS_AS_NEEDED_BY_APP           =  (1 << 2),
 170   XDP_ADD_FLAGS_FLAGS_ALL                  = ((1 << 3) - 1)
 171 };
 172
 173 GList *
 174 g_document_portal_add_documents (GList       *uris,
 175                                  const char  *app_id,
 176                                  GError     **error)
 177 {
 178   int length;
 179   GList *ruris = NULL;
 180   gboolean *as_is;
 181   GVariantBuilder builder;
 182   GUnixFDList *fd_list = NULL;
 183   GList *l;
 184   gsize i, j;
 185   const char *permissions[] = { "read", "write", NULL };
 186   char **doc_ids = NULL;
 187   GVariant *extra_out = NULL;
 188
 189   if (!init_document_portal ())
 190     {
 191       g_set_error (error, G_IO_ERROR, G_IO_ERROR_NOT_INITIALIZED,
 192                    "Document portal is not available");
 193       return NULL;
 194     }
 195
 196   length = g_list_length (uris);
 197   as_is = g_new0 (gboolean, length);
 198
 199   g_variant_builder_init (&builder, G_VARIANT_TYPE ("ah"));
 200
 201   fd_list = g_unix_fd_list_new ();
 202   for (l = uris, i = 0; l; l = l->next, i++)
 203     {
 204       const char *uri = l->data;
 205       int idx = -1;
 206       char *path = NULL;
 207
 208       path = g_filename_from_uri (uri, NULL, NULL);
 209       if (path != NULL)
 210         {
 211           int fd;
 212
 213           fd = g_open (path, O_CLOEXEC | O_PATH);
 214           if (fd >= 0)
 215             {
 216 #ifndef HAVE_O_CLOEXEC
 217               fcntl (fd, F_SETFD, FD_CLOEXEC);
 218 #endif
 219               idx = g_unix_fd_list_append (fd_list, fd, NULL);
 220               close (fd);
 221             }
 222         }
 223
 224       g_free (path);
 225
 226       if (idx != -1)
 227         g_variant_builder_add (&builder, "h", idx);
 228       else
 229         as_is[i] = TRUE;
 230     }
 231
 232   if (g_unix_fd_list_get_length (fd_list) > 0)
 233     {
 234       if (!gxdp_documents_call_add_full_sync (documents,
 235                                               g_variant_builder_end (&builder),
 236                                               XDP_ADD_FLAGS_AS_NEEDED_BY_APP,
 237                                               app_id,
 238                                               permissions,
 239                                               fd_list,
 240                                               &doc_ids,
 241                                               &extra_out,
 242                                               NULL,
 243                                               NULL,
 244                                               error))
 245         goto out;
 246
 247       for (l = uris, i = 0, j = 0; l; l = l->next, i++)
 248         {
 249           const char *uri = l->data;
 250           char *ruri;
 251
 252           if (as_is[i]) /* use as-is, not a file uri */
 253             {
 254               ruri = g_strdup (uri);
 255             }
 256           else if (strcmp (doc_ids[j], "") == 0) /* not rewritten */
 257             {
 258               ruri = g_strdup (uri);
 259               j++;
 260             }
 261           else
 262             {
 263               char *basename = g_path_get_basename (uri + strlen ("file:"));
 264               char *doc_path = g_build_filename (documents_mountpoint, doc_ids[j], basename, NULL);
 265               ruri = g_strconcat ("file:", doc_path, NULL);
 266               g_free (basename);
 267               g_free (doc_path);
 268               j++;
 269             }
 270
 271           ruris = g_list_prepend (ruris, ruri);
 272         }
 273
 274       ruris = g_list_reverse (ruris);
 275     }
 276   else
 277     {
 278       ruris = g_list_copy_deep (uris, (GCopyFunc)g_strdup, NULL);
 279     }
 280
 281 out:
 282   g_clear_object (&fd_list);
 283   g_clear_pointer (&extra_out, g_variant_unref);
 284   g_clear_pointer (&doc_ids, g_strfreev);
 285   g_free (as_is);
 286
 287   return ruris;
 288 }