summaryrefslogtreecommitdiff
path: root/monitor/goa/goavolume.c
diff options
context:
space:
mode:
Diffstat (limited to 'monitor/goa/goavolume.c')
-rw-r--r--monitor/goa/goavolume.c585
1 files changed, 585 insertions, 0 deletions
diff --git a/monitor/goa/goavolume.c b/monitor/goa/goavolume.c
new file mode 100644
index 00000000..41334a96
--- /dev/null
+++ b/monitor/goa/goavolume.c
@@ -0,0 +1,585 @@
+/* -*- mode: C; c-file-style: "gnu"; indent-tabs-mode: nil; -*- */
+/* gvfs - extensions for gio
+ *
+ * Copyright (C) 2012, 2013 Red Hat, Inc.
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 2 of the License, or (at your option) any later version.
+ *
+ * This library 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
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General
+ * Public License along with this library; if not, write to the
+ * Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
+ * Boston, MA 02110-1301, USA.
+ *
+ * Author: Debarshi Ray <debarshir@gnome.org>
+ */
+
+#include <config.h>
+#include <string.h>
+#include <glib.h>
+#include <gio/gio.h>
+#include <glib/gi18n.h>
+
+#include "goavolume.h"
+
+struct _GVfsGoaVolume
+{
+ GObject parent;
+ GFile *root;
+ GMount *mount;
+ GoaObject *object;
+ gchar *uuid;
+ gchar *icon;
+ gchar *symbolic_icon;
+ gulong account_attention_needed_id;
+};
+
+struct _GVfsGoaVolumeClass
+{
+ GObjectClass parent_class;
+};
+
+enum
+{
+ PROP_0,
+ PROP_ACCOUNT,
+ PROP_UUID
+};
+
+static void g_vfs_goa_volume_iface_init (GVolumeIface *iface);
+
+G_DEFINE_TYPE_EXTENDED (GVfsGoaVolume, g_vfs_goa_volume, G_TYPE_OBJECT, 0,
+ G_IMPLEMENT_INTERFACE (G_TYPE_VOLUME,
+ g_vfs_goa_volume_iface_init))
+
+/* ---------------------------------------------------------------------------------------------------- */
+
+typedef struct
+{
+ GAsyncReadyCallback callback;
+ GCancellable *cancellable;
+ GMountOperation *mount_operation;
+ GSimpleAsyncResult *simple;
+ gchar *passwd;
+ gpointer user_data;
+} MountOp;
+
+static void
+mount_op_free (MountOp *data)
+{
+ g_clear_object (&data->cancellable);
+ g_clear_object (&data->mount_operation);
+ g_object_unref (data->simple);
+ g_free (data->passwd);
+ g_slice_free (MountOp, data);
+}
+
+static void
+mount_cb (GObject *source_object, GAsyncResult *res, gpointer user_data)
+{
+ MountOp *data = user_data;
+
+ if (data->callback != NULL)
+ data->callback (source_object, res, data->user_data);
+
+ mount_op_free (data);
+}
+
+/* ---------------------------------------------------------------------------------------------------- */
+
+static void
+account_attention_needed_cb (GObject *_object, GParamSpec *pspec, gpointer user_data)
+{
+ GoaAccount *account = GOA_ACCOUNT (_object);
+ GVfsGoaVolume *self = user_data;
+
+ if (goa_account_get_attention_needed (account))
+ {
+ if (self->mount != NULL)
+ {
+ g_mount_unmount_with_operation (self->mount, G_MOUNT_UNMOUNT_NONE, NULL, NULL, NULL, NULL);
+ g_clear_object (&self->mount);
+ }
+ }
+ else
+ g_volume_mount (G_VOLUME (self), G_MOUNT_MOUNT_NONE, NULL, NULL, NULL, NULL);
+}
+
+/* ---------------------------------------------------------------------------------------------------- */
+
+static void
+mount_operation_ask_password_cb (GMountOperation *op,
+ gchar *message,
+ gchar *default_user,
+ gchar *default_domain,
+ GAskPasswordFlags flags,
+ gpointer user_data)
+{
+ MountOp *data = user_data;
+
+ g_mount_operation_set_password (data->mount_operation, data->passwd);
+ g_mount_operation_reply (data->mount_operation, G_MOUNT_OPERATION_HANDLED);
+}
+
+/* ---------------------------------------------------------------------------------------------------- */
+
+static void
+find_enclosing_mount_cb (GObject *source_object, GAsyncResult *res, gpointer user_data)
+{
+ GFile *root = G_FILE (source_object);
+ GSimpleAsyncResult *simple = user_data;
+ GVfsGoaVolume *self;
+ GError *error;
+ MountOp *data;
+
+ self = G_VFS_GOA_VOLUME (g_async_result_get_source_object (G_ASYNC_RESULT (simple)));
+ data = g_async_result_get_user_data (G_ASYNC_RESULT (simple));
+
+ error = NULL;
+ g_clear_object (&self->mount);
+ self->mount = g_file_find_enclosing_mount_finish (root, res, &error);
+ if (self->mount == NULL)
+ g_simple_async_result_take_error (simple, error);
+
+ g_simple_async_result_complete_in_idle (simple);
+}
+
+static void
+mount_enclosing_volume_cb (GObject *source_object, GAsyncResult *res, gpointer user_data)
+{
+ GFile *root = G_FILE (source_object);
+ GSimpleAsyncResult *simple = user_data;
+ GVfsGoaVolume *self;
+ GError *error;
+ MountOp *data;
+
+ self = G_VFS_GOA_VOLUME (g_async_result_get_source_object (G_ASYNC_RESULT (simple)));
+ data = g_async_result_get_user_data (G_ASYNC_RESULT (simple));
+
+ error = NULL;
+ if (!g_file_mount_enclosing_volume_finish (root, res, &error))
+ {
+ if (error->code != G_IO_ERROR_ALREADY_MOUNTED)
+ {
+ g_simple_async_result_take_error (simple, error);
+ g_simple_async_result_complete_in_idle (simple);
+ return;
+ }
+ else
+ {
+ g_warning ("Already mounted %s: %s", g_file_get_uri (root), error->message);
+ g_error_free (error);
+ }
+ }
+
+ g_file_find_enclosing_mount_async (root, G_PRIORITY_DEFAULT, NULL, find_enclosing_mount_cb, simple);
+}
+
+static void
+get_password_cb (GObject *source_object, GAsyncResult *res, gpointer user_data)
+{
+ GoaPasswordBased *passwd_based = GOA_PASSWORD_BASED (source_object);
+ GSimpleAsyncResult *simple = user_data;
+ GVfsGoaVolume *self;
+ GError *error;
+ GoaAccount *account;
+ GoaFiles *files;
+ MountOp *data;
+
+ self = G_VFS_GOA_VOLUME (g_async_result_get_source_object (G_ASYNC_RESULT (simple)));
+ data = g_async_result_get_user_data (G_ASYNC_RESULT (simple));
+
+ error = NULL;
+ if (!goa_password_based_call_get_password_finish (passwd_based, &data->passwd, res, &error))
+ {
+ g_simple_async_result_take_error (simple, error);
+ g_simple_async_result_complete_in_idle (simple);
+ return;
+ }
+
+ account = goa_object_peek_account (self->object);
+ files = goa_object_peek_files (self->object);
+ if (files == NULL)
+ {
+ g_simple_async_result_set_error (simple,
+ G_IO_ERROR,
+ G_IO_ERROR_FAILED,
+ _("Failed to get org.gnome.OnlineAccounts.Files for %s"),
+ goa_account_get_id (account));
+ g_simple_async_result_complete_in_idle (simple);
+ return;
+ }
+
+ g_mount_operation_set_username (data->mount_operation, goa_account_get_identity (account));
+ g_file_mount_enclosing_volume (self->root,
+ G_MOUNT_MOUNT_NONE,
+ data->mount_operation,
+ data->cancellable,
+ mount_enclosing_volume_cb,
+ simple);
+}
+
+static void
+ensure_credentials_cb (GObject *source_object, GAsyncResult *res, gpointer user_data)
+{
+ GoaAccount *account = GOA_ACCOUNT (source_object);
+ GSimpleAsyncResult *simple = user_data;
+ GVfsGoaVolume *self;
+ GError *error;
+ GoaPasswordBased *passwd_based;
+ MountOp *data;
+ const gchar *id;
+
+ self = G_VFS_GOA_VOLUME (g_async_result_get_source_object (G_ASYNC_RESULT (simple)));
+ data = g_async_result_get_user_data (G_ASYNC_RESULT (simple));
+
+ error = NULL;
+ if (!goa_account_call_ensure_credentials_finish (account, NULL, res, &error))
+ {
+ if (error->domain == GOA_ERROR && error->code == GOA_ERROR_NOT_AUTHORIZED)
+ {
+ g_simple_async_result_set_error (simple,
+ G_IO_ERROR,
+ G_IO_ERROR_FAILED,
+ _("Invalid credentials for %s"),
+ goa_account_get_presentation_identity (account));
+ g_error_free (error);
+ }
+ else
+ g_simple_async_result_take_error (simple, error);
+
+ g_simple_async_result_complete_in_idle (simple);
+ return;
+ }
+
+ passwd_based = goa_object_peek_password_based (self->object);
+ if (passwd_based == NULL)
+ {
+ g_simple_async_result_set_error (simple,
+ G_IO_ERROR,
+ G_IO_ERROR_NOT_SUPPORTED,
+ _("Unsupported authentication method for %s"),
+ goa_account_get_presentation_identity (account));
+ g_simple_async_result_complete_in_idle (simple);
+ return;
+ }
+
+ id = goa_account_get_id (account);
+ goa_password_based_call_get_password (passwd_based, id, data->cancellable, get_password_cb, simple);
+}
+
+/* ---------------------------------------------------------------------------------------------------- */
+
+static gboolean
+g_vfs_goa_volume_can_eject (GVolume *_self)
+{
+ return FALSE;
+}
+
+static gboolean
+g_vfs_goa_volume_can_mount (GVolume *_self)
+{
+ return TRUE;
+}
+
+static char **
+g_vfs_goa_volume_enumerate_identifiers (GVolume *_self)
+{
+ GVfsGoaVolume *self = G_VFS_GOA_VOLUME (_self);
+ GPtrArray *res;
+
+ res = g_ptr_array_new ();
+ g_ptr_array_add (res, g_strdup (G_VOLUME_IDENTIFIER_KIND_CLASS));
+ g_ptr_array_add (res, g_strdup (G_VOLUME_IDENTIFIER_KIND_UUID));
+ g_ptr_array_add (res, NULL);
+
+ return (gchar **) g_ptr_array_free (res, FALSE);
+}
+
+static GFile *
+g_vfs_goa_volume_get_activation_root (GVolume *_self)
+{
+ /* Even though we know the activation root before mounting the
+ * volume we can not reveal it, because we do not want it to be
+ * handled as a GProxyVolume.
+ */
+ return NULL;
+}
+
+static GDrive *
+g_vfs_goa_volume_get_drive (GVolume *_self)
+{
+ return NULL;
+}
+
+static GIcon *
+g_vfs_goa_volume_get_icon (GVolume *_self)
+{
+ GVfsGoaVolume *self = G_VFS_GOA_VOLUME (_self);
+ return g_themed_icon_new_with_default_fallbacks (self->icon);
+}
+
+static char *
+g_vfs_goa_volume_get_identifier (GVolume *_self, const gchar *kind)
+{
+ GVfsGoaVolume *self = G_VFS_GOA_VOLUME (_self);
+
+ if (g_strcmp0 (kind, G_VOLUME_IDENTIFIER_KIND_CLASS) == 0)
+ return g_strdup ("network");
+ else if (g_strcmp0 (kind, G_VOLUME_IDENTIFIER_KIND_UUID) == 0)
+ return g_strdup (self->uuid);
+
+ return NULL;
+}
+
+static GMount *
+g_vfs_goa_volume_get_mount (GVolume *_self)
+{
+ GVfsGoaVolume *self = G_VFS_GOA_VOLUME (_self);
+ GMount *mount;
+
+ mount = NULL;
+
+ if (self->mount != NULL)
+ mount = g_object_ref (self->mount);
+
+ return mount;
+}
+
+static char *
+g_vfs_goa_volume_get_name (GVolume *_self)
+{
+ GVfsGoaVolume *self = G_VFS_GOA_VOLUME (_self);
+ GoaAccount *account;
+
+ account = goa_object_peek_account (self->object);
+ return goa_account_dup_presentation_identity (account);
+}
+
+static GIcon *
+g_vfs_goa_volume_get_symbolic_icon (GVolume *_self)
+{
+ GVfsGoaVolume *self = G_VFS_GOA_VOLUME (_self);
+ return g_themed_icon_new_with_default_fallbacks (self->symbolic_icon);
+}
+
+static char *
+g_vfs_goa_volume_get_uuid (GVolume *_self)
+{
+ GVfsGoaVolume *self = G_VFS_GOA_VOLUME (_self);
+ return g_strdup (self->uuid);
+}
+
+static void
+g_vfs_goa_volume_mount (GVolume *_self,
+ GMountMountFlags flags,
+ GMountOperation *mount_operation,
+ GCancellable *cancellable,
+ GAsyncReadyCallback callback,
+ gpointer user_data)
+{
+ GVfsGoaVolume *self = G_VFS_GOA_VOLUME (_self);
+ MountOp *data;
+ GSimpleAsyncResult *simple;
+ GoaAccount *account;
+
+ data = g_slice_new0 (MountOp);
+ simple = g_simple_async_result_new (G_OBJECT (self), mount_cb, data, g_vfs_goa_volume_mount);
+
+ data->simple = simple;
+ data->callback = callback;
+ data->user_data = user_data;
+
+ if (cancellable != NULL)
+ {
+ data->cancellable = g_object_ref (cancellable);
+ g_simple_async_result_set_check_cancellable (simple, cancellable);
+ }
+
+ /* We ignore the GMountOperation handed to us by the proxy volume
+ * monitor because it is set up to emit MountOpAskPassword on
+ * ask-password.
+ */
+ data->mount_operation = g_mount_operation_new ();
+ g_signal_connect (data->mount_operation, "ask-password", G_CALLBACK (mount_operation_ask_password_cb), data);
+
+ account = goa_object_peek_account (self->object);
+ goa_account_call_ensure_credentials (account, data->cancellable, ensure_credentials_cb, simple);
+}
+
+static gboolean
+g_vfs_goa_volume_mount_finish (GVolume *_self, GAsyncResult *res, GError **error)
+{
+ GSimpleAsyncResult *simple = G_SIMPLE_ASYNC_RESULT (res);
+
+ g_return_val_if_fail (g_simple_async_result_is_valid (res, G_OBJECT (_self), g_vfs_goa_volume_mount), FALSE);
+
+ if (g_simple_async_result_propagate_error (simple, error))
+ return FALSE;
+
+ return TRUE;
+}
+
+static void
+g_vfs_goa_volume_removed (GVolume *volume)
+{
+ GVfsGoaVolume *self = G_VFS_GOA_VOLUME (volume);
+
+ if (self->mount == NULL)
+ return;
+
+ g_mount_unmount_with_operation (self->mount, G_MOUNT_UNMOUNT_NONE, NULL, NULL, NULL, NULL);
+ g_clear_object (&self->mount);
+}
+
+static gboolean
+g_vfs_goa_volume_should_automount (GVolume *volume)
+{
+ return FALSE;
+}
+
+static void
+g_vfs_goa_volume_constructed (GObject *_self)
+{
+ GVfsGoaVolume *self = G_VFS_GOA_VOLUME (_self);
+ GoaAccount *account;
+
+ G_OBJECT_CLASS (g_vfs_goa_volume_parent_class)->constructed (_self);
+
+ self->root = g_file_new_for_uri (self->uuid);
+
+ account = goa_object_peek_account (self->object);
+ self->account_attention_needed_id = g_signal_connect (account,
+ "notify::attention-needed",
+ G_CALLBACK (account_attention_needed_cb),
+ self);
+}
+
+static void
+g_vfs_goa_volume_dispose (GObject *_self)
+{
+ GVfsGoaVolume *self = G_VFS_GOA_VOLUME (_self);
+
+ if (self->account_attention_needed_id != 0)
+ {
+ GoaAccount *account;
+
+ account = goa_object_peek_account (self->object);
+ g_signal_handler_disconnect (account, self->account_attention_needed_id);
+ self->account_attention_needed_id = 0;
+ }
+
+ g_clear_object (&self->root);
+ g_clear_object (&self->mount);
+ g_clear_object (&self->object);
+
+ G_OBJECT_CLASS (g_vfs_goa_volume_parent_class)->dispose (_self);
+}
+
+static void
+g_vfs_goa_volume_finalize (GObject *_self)
+{
+ GVfsGoaVolume *self = G_VFS_GOA_VOLUME (_self);
+
+ g_free (self->uuid);
+ g_free (self->icon);
+ g_free (self->symbolic_icon);
+
+ G_OBJECT_CLASS (g_vfs_goa_volume_parent_class)->finalize (_self);
+}
+
+static void
+g_vfs_goa_volume_set_property (GObject *_self, guint prop_id, const GValue *value, GParamSpec *pspec)
+{
+ GVfsGoaVolume *self = G_VFS_GOA_VOLUME (_self);
+
+ switch (prop_id)
+ {
+ case PROP_ACCOUNT:
+ self->object = g_value_dup_object (value);
+ break;
+
+ case PROP_UUID:
+ self->uuid = g_value_dup_string (value);
+ break;
+
+ default:
+ G_OBJECT_WARN_INVALID_PROPERTY_ID (_self, prop_id, pspec);
+ break;
+ }
+}
+
+static void
+g_vfs_goa_volume_class_init (GVfsGoaVolumeClass *klass)
+{
+ GObjectClass *gobject_class = G_OBJECT_CLASS (klass);
+
+ gobject_class->constructed = g_vfs_goa_volume_constructed;
+ gobject_class->dispose = g_vfs_goa_volume_dispose;
+ gobject_class->finalize = g_vfs_goa_volume_finalize;
+ gobject_class->set_property = g_vfs_goa_volume_set_property;
+
+ g_object_class_install_property (gobject_class,
+ PROP_ACCOUNT,
+ g_param_spec_object ("account",
+ "GoaObject object",
+ "The GOA account represented by the volume",
+ GOA_TYPE_OBJECT,
+ G_PARAM_CONSTRUCT_ONLY |
+ G_PARAM_STATIC_STRINGS |
+ G_PARAM_WRITABLE));
+
+ g_object_class_install_property (gobject_class,
+ PROP_UUID,
+ g_param_spec_string ("uuid",
+ "UUID",
+ "The UUID of the volume",
+ NULL,
+ G_PARAM_CONSTRUCT_ONLY |
+ G_PARAM_STATIC_STRINGS |
+ G_PARAM_WRITABLE));
+}
+
+static void
+g_vfs_goa_volume_init (GVfsGoaVolume *self)
+{
+ self->icon = g_strdup ("network-server");
+ self->symbolic_icon = g_strdup ("network-server-symbolic");
+}
+
+static void
+g_vfs_goa_volume_iface_init (GVolumeIface *iface)
+{
+ iface->removed = g_vfs_goa_volume_removed;
+
+ iface->can_eject = g_vfs_goa_volume_can_eject;
+ iface->can_mount = g_vfs_goa_volume_can_mount;
+ iface->enumerate_identifiers = g_vfs_goa_volume_enumerate_identifiers;
+ iface->get_activation_root = g_vfs_goa_volume_get_activation_root;
+ iface->get_drive = g_vfs_goa_volume_get_drive;
+ iface->get_icon = g_vfs_goa_volume_get_icon;
+ iface->get_identifier = g_vfs_goa_volume_get_identifier;
+ iface->get_mount = g_vfs_goa_volume_get_mount;
+ iface->get_name = g_vfs_goa_volume_get_name;
+ iface->get_symbolic_icon = g_vfs_goa_volume_get_symbolic_icon;
+ iface->get_uuid = g_vfs_goa_volume_get_uuid;
+ iface->mount_fn = g_vfs_goa_volume_mount;
+ iface->mount_finish = g_vfs_goa_volume_mount_finish;
+ iface->should_automount = g_vfs_goa_volume_should_automount;
+}
+
+GVolume *
+g_vfs_goa_volume_new (GoaObject *object, const gchar *uuid)
+{
+ return g_object_new (G_VFS_TYPE_GOA_VOLUME,
+ "account", object,
+ "uuid", uuid,
+ NULL);
+}
generated by cgit v1.2.3 (git 2.39.1) at 2024-12-18 07:50:04 +0000