[gnome-builder/wip/libide: 199/237] libide: add gca diagnostic provider
- From: Christian Hergert <chergert src gnome org>
- To: commits-list gnome org
- Cc:
- Subject: [gnome-builder/wip/libide: 199/237] libide: add gca diagnostic provider
- Date: Tue, 17 Feb 2015 21:46:08 +0000 (UTC)
commit a811145970d42646e75e2c2ec12ad64789238320
Author: Christian Hergert <christian hergert me>
Date: Sun Feb 15 00:18:54 2015 -0800
libide: add gca diagnostic provider
This diagnostic provider is the fallback diagnostic provider. If we do not
have an inprocess one, this will be used for generic files. Such an example
would be python and css.
libide/Makefile.am | 7 +-
libide/gca/ide-gca-diagnostic-provider.c | 428 ++++++++++++++++++++++++++++++
libide/gca/ide-gca-diagnostic-provider.h | 33 +++
libide/gca/ide-gca-service.c | 34 +++-
4 files changed, 498 insertions(+), 4 deletions(-)
---
diff --git a/libide/Makefile.am b/libide/Makefile.am
index 9394df5..9a088ae 100644
--- a/libide/Makefile.am
+++ b/libide/Makefile.am
@@ -138,14 +138,17 @@ libide_la_SOURCES = \
$(libide_la_public_sources) \
libide/editorconfig/editorconfig-glib.c \
libide/editorconfig/editorconfig-glib.h \
- libide/gca/ide-gca-service.c \
- libide/gca/ide-gca-service.h \
libide/gca/gca-diagnostics.c \
libide/gca/gca-diagnostics.h \
libide/gca/gca-service.c \
libide/gca/gca-service.h \
libide/gca/gca-structs.c \
libide/gca/gca-structs.h \
+ libide/gca/ide-gca-diagnostic-provider.c \
+ libide/gca/ide-gca-diagnostic-provider.h \
+ libide/gca/ide-gca-service.c \
+ libide/gca/ide-gca-service.h \
+ libide/gca/ide-gca-service.h \
libide/gconstructor.h \
libide/ide-async-helper.c \
libide/ide-async-helper.h \
diff --git a/libide/gca/ide-gca-diagnostic-provider.c b/libide/gca/ide-gca-diagnostic-provider.c
new file mode 100644
index 0000000..7def515
--- /dev/null
+++ b/libide/gca/ide-gca-diagnostic-provider.c
@@ -0,0 +1,428 @@
+/* ide-gca-diagnostic-provider.c
+ *
+ * Copyright (C) 2015 Christian Hergert <christian hergert me>
+ *
+ * This file 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 3 of the
+ * License, or (at your option) any later version.
+ *
+ * This file 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 General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+#include <gca-diagnostics.h>
+#include <glib/gi18n.h>
+
+#include "ide-context.h"
+#include "ide-diagnostics.h"
+#include "ide-file.h"
+#include "ide-gca-diagnostic-provider.h"
+#include "ide-gca-service.h"
+#include "ide-internal.h"
+#include "ide-language.h"
+#include "ide-source-location.h"
+#include "ide-source-range.h"
+#include "ide-unsaved-file.h"
+#include "ide-unsaved-files.h"
+
+struct _IdeGcaDiagnosticProvider
+{
+ IdeDiagnosticProvider parent_instance;
+
+ GHashTable *document_cache;
+};
+
+typedef struct
+{
+ GTask *task; /* Integrity check backpointer */
+ IdeUnsavedFile *unsaved_file;
+ IdeFile *file;
+ gchar *language_id;
+} DiagnoseState;
+
+G_DEFINE_TYPE (IdeGcaDiagnosticProvider, ide_gca_diagnostic_provider,
+ IDE_TYPE_DIAGNOSTIC_PROVIDER)
+
+static void
+diagnose_state_free (gpointer data)
+{
+ DiagnoseState *state = data;
+
+ if (state)
+ {
+ g_clear_object (&state->file);
+ g_free (state->language_id);
+ g_clear_pointer (&state->unsaved_file, ide_unsaved_file_unref);
+ g_slice_free (DiagnoseState, state);
+ }
+}
+
+static IdeDiagnosticSeverity
+get_severity (guint val)
+{
+ /* these currently map one-to-one */
+ return (IdeDiagnosticSeverity)val;
+}
+
+static IdeDiagnostics *
+variant_to_diagnostics (DiagnoseState *state,
+ GVariant *variant)
+{
+
+ GPtrArray *ar;
+ GVariantIter iter;
+ GVariantIter *b;
+ GVariantIter *c;
+ gchar *d = NULL;
+ guint a;
+
+ g_assert (variant);
+
+ ar = g_ptr_array_new ();
+ g_ptr_array_set_free_func (ar, (GDestroyNotify)ide_diagnostic_unref);
+
+ g_variant_iter_init (&iter, variant);
+
+ while (g_variant_iter_loop (&iter, "(ua((x(xx)(xx))s)a(x(xx)(xx))s)",
+ &a, &b, &c, &d))
+ {
+ IdeDiagnosticSeverity severity;
+ IdeDiagnostic *diag;
+ gint64 x1, x2, x3, x4, x5;
+ gchar *e;
+
+ severity = get_severity (a);
+
+ while (g_variant_iter_next (b, "((x(xx)(xx))s)",
+ &x1, &x2, &x3, &x4, &x5, &e))
+ {
+ /*
+ * TODO: Add fixits back after we plumb them into IdeDiagnostic.
+ */
+ g_print ("!!! %s\n", e);
+#if 0
+ GcaFixit fixit = {{ 0 }};
+
+ fixit.range.file = x1;
+ fixit.range.begin.line = x2 - 1;
+ fixit.range.begin.column = x3 - 1;
+ fixit.range.end.line = x4 - 1;
+ fixit.range.end.column = x5 - 1;
+ fixit.value = g_strdup (e);
+
+ g_array_append_val (diag.fixits, fixit);
+#endif
+ }
+
+ diag = _ide_diagnostic_new (severity, d, NULL);
+
+ while (g_variant_iter_next (c, "(x(xx)(xx))", &x1, &x2, &x3, &x4, &x5))
+ {
+ IdeSourceRange *range;
+ IdeSourceLocation *begin;
+ IdeSourceLocation *end;
+ IdeFile *file = NULL;
+
+ /*
+ * FIXME:
+ *
+ * Not always true, but we can cheat for now and claim it is within
+ * the file we just parsed.
+ */
+ file = state->file;
+
+ begin = ide_source_location_new (file, x2 - 1, x3 - 1, 0);
+ end = ide_source_location_new (file, x4 - 1, x5 - 1, 0);
+
+ range = _ide_source_range_new (begin, end);
+ _ide_diagnostic_take_range (diag, range);
+
+ ide_source_location_unref (begin);
+ ide_source_location_unref (end);
+ }
+
+ g_ptr_array_add (ar, diag);
+ }
+
+ return _ide_diagnostics_new (ar);
+}
+
+static void
+diagnostics_cb (GObject *object,
+ GAsyncResult *result,
+ gpointer user_data)
+{
+ GcaDiagnostics *proxy = (GcaDiagnostics *)object;
+ g_autoptr(GTask) task = user_data;
+ g_autoptr(GVariant) var = NULL;
+ GError *error = NULL;
+ IdeDiagnostics *diagnostics;
+ DiagnoseState *state;
+
+ g_assert (G_IS_TASK (task));
+ g_assert (G_IS_ASYNC_RESULT (result));
+
+ if (!gca_diagnostics_call_diagnostics_finish (proxy, &var, result, &error))
+ {
+ g_task_return_error (task, error);
+ return;
+ }
+
+ state = g_task_get_task_data (task);
+ g_assert (state->task == task);
+
+ diagnostics = variant_to_diagnostics (state, var);
+
+ g_task_return_pointer (task, diagnostics,
+ (GDestroyNotify)ide_diagnostics_unref);
+}
+
+static void
+get_diag_proxy_cb (GObject *object,
+ GAsyncResult *result,
+ gpointer user_data)
+{
+ g_autoptr(GTask) task = user_data;
+ IdeGcaDiagnosticProvider *self;
+ GcaDiagnostics *proxy;
+ DiagnoseState *state;
+ GError *error = NULL;
+ const gchar *path;
+
+ g_assert (G_IS_TASK (task));
+ g_assert (G_IS_ASYNC_RESULT (result));
+
+ self = g_task_get_source_object (task);
+ state = g_task_get_task_data (task);
+
+ proxy = gca_diagnostics_proxy_new_finish (result, &error);
+
+ if (!proxy)
+ {
+ g_task_return_error (task, error);
+ return;
+ }
+
+ path = g_dbus_proxy_get_object_path (G_DBUS_PROXY (proxy));
+ g_hash_table_replace (self->document_cache, g_strdup (path), proxy);
+
+ gca_diagnostics_call_diagnostics (proxy,
+ g_task_get_cancellable (task),
+ diagnostics_cb,
+ g_object_ref (task));
+}
+
+static void
+parse_cb (GObject *object,
+ GAsyncResult *result,
+ gpointer user_data)
+{
+ GcaService *proxy = (GcaService *)object;
+ IdeGcaDiagnosticProvider *self;
+ DiagnoseState *state;
+ g_autoptr(GTask) task = user_data;
+ GcaDiagnostics *doc_proxy;
+ gboolean ret;
+ GError *error = NULL;
+ g_autoptr(gchar) document_path = NULL;
+
+ g_assert (GCA_IS_SERVICE (proxy));
+ g_assert (G_IS_TASK (task));
+
+ self = g_task_get_source_object (task);
+ state = g_task_get_task_data (task);
+
+ ret = gca_service_call_parse_finish (proxy, &document_path, result, &error);
+
+ if (!ret)
+ {
+ g_task_return_error (task, error);
+ return;
+ }
+
+ doc_proxy = g_hash_table_lookup (self->document_cache, document_path);
+
+ if (!doc_proxy)
+ {
+ g_autoptr(gchar) well_known_name = NULL;
+ GDBusConnection *conn;
+
+ well_known_name = g_strdup_printf ("org.gnome.CodeAssist.v1.%s",
+ state->language_id);
+ conn = g_dbus_proxy_get_connection (G_DBUS_PROXY (proxy));
+
+ gca_diagnostics_proxy_new (conn,
+ G_DBUS_PROXY_FLAGS_NONE,
+ well_known_name,
+ document_path,
+ g_task_get_cancellable (task),
+ get_diag_proxy_cb,
+ g_object_ref (task));
+ return;
+ }
+
+ gca_diagnostics_call_diagnostics (doc_proxy,
+ g_task_get_cancellable (task),
+ diagnostics_cb,
+ g_object_ref (task));
+}
+
+static void
+get_proxy_cb (GObject *object,
+ GAsyncResult *result,
+ gpointer user_data)
+{
+ g_autoptr(GTask) task = user_data;
+ IdeGcaService *service = (IdeGcaService *)object;
+ DiagnoseState *state;
+ GcaService *proxy;
+ const gchar *temp_path;
+ GError *error = NULL;
+ GFile *gfile;
+ g_autoptr(gchar) path = NULL;
+ GVariant *cursor = NULL;
+ GVariant *options = NULL;
+
+ g_assert (G_IS_TASK (task));
+ g_assert (IDE_IS_GCA_SERVICE (service));
+
+ state = g_task_get_task_data (task);
+ g_assert (state->task == task);
+
+ proxy = ide_gca_service_get_proxy_finish (service, result, &error);
+
+ if (!proxy)
+ {
+ g_task_return_error (task, error);
+ goto cleanup;
+ }
+
+ gfile = ide_file_get_file (state->file);
+ temp_path = path = g_file_get_path (gfile);
+
+ if (!path)
+ {
+ g_task_return_new_error (task,
+ G_IO_ERROR,
+ G_IO_ERROR_NOT_SUPPORTED,
+ _("Code assistance requires a local file."));
+ goto cleanup;
+ }
+
+ if (state->unsaved_file)
+ {
+ if (!ide_unsaved_file_persist (state->unsaved_file,
+ g_task_get_cancellable (task),
+ &error))
+ {
+ g_task_return_error (task, error);
+ goto cleanup;
+ }
+
+ temp_path = ide_unsaved_file_get_temp_path (state->unsaved_file);
+ }
+
+ /* TODO: Plumb support for cursors down to this level? */
+ cursor = g_variant_new ("(xx)", (gint64)0, (gint64)0);
+ options = g_variant_new ("a{sv}", 0);
+
+ gca_service_call_parse (proxy,
+ path,
+ temp_path,
+ cursor,
+ options,
+ g_task_get_cancellable (task),
+ parse_cb,
+ g_object_ref (task));
+
+cleanup:
+ g_clear_object (&proxy);
+}
+
+static void
+ide_gca_diagnostic_provider_diagnose_async (IdeDiagnosticProvider *provider,
+ IdeFile *file,
+ GCancellable *cancellable,
+ GAsyncReadyCallback callback,
+ gpointer user_data)
+{
+ IdeGcaDiagnosticProvider *self = (IdeGcaDiagnosticProvider *)provider;
+ g_autoptr(GTask) task = NULL;
+ IdeGcaService *service;
+ DiagnoseState *state;
+ IdeLanguage *language;
+ IdeContext *context;
+ IdeUnsavedFiles *files;
+ const gchar *language_id;
+ GFile *gfile;
+
+ g_return_if_fail (IDE_IS_GCA_DIAGNOSTIC_PROVIDER (self));
+
+ task = g_task_new (self, cancellable, callback, user_data);
+
+ context = ide_object_get_context (IDE_OBJECT (provider));
+ service = ide_context_get_service_typed (context, IDE_TYPE_GCA_SERVICE);
+ language = ide_file_get_language (file);
+ language_id = ide_language_get_id (language);
+ files = ide_context_get_unsaved_files (context);
+ gfile = ide_file_get_file (file);
+
+ state = g_slice_new0 (DiagnoseState);
+ state->task = task;
+ state->language_id = g_strdup (language_id);
+ state->file = g_object_ref (file);
+ state->unsaved_file = ide_unsaved_files_get_unsaved_file (files, gfile);
+
+ g_task_set_task_data (task, state, diagnose_state_free);
+
+ ide_gca_service_get_proxy_async (service, language_id, cancellable,
+ get_proxy_cb, g_object_ref (task));
+}
+
+static IdeDiagnostics *
+ide_gca_diagnostic_provider_diagnose_finish (IdeDiagnosticProvider *self,
+ GAsyncResult *result,
+ GError **error)
+{
+ GTask *task = (GTask *)result;
+
+ g_return_val_if_fail (IDE_IS_GCA_DIAGNOSTIC_PROVIDER (self), NULL);
+ g_return_val_if_fail (G_IS_TASK (task), NULL);
+
+ return g_task_propagate_pointer (task, error);
+}
+
+static void
+ide_gca_diagnostic_provider_finalize (GObject *object)
+{
+ IdeGcaDiagnosticProvider *self = (IdeGcaDiagnosticProvider *)object;
+
+ g_clear_pointer (&self->document_cache, g_hash_table_unref);
+
+ G_OBJECT_CLASS (ide_gca_diagnostic_provider_parent_class)->finalize (object);
+}
+
+static void
+ide_gca_diagnostic_provider_class_init (IdeGcaDiagnosticProviderClass *klass)
+{
+ GObjectClass *object_class = G_OBJECT_CLASS (klass);
+ IdeDiagnosticProviderClass *provider_class = IDE_DIAGNOSTIC_PROVIDER_CLASS (klass);
+
+ object_class->finalize = ide_gca_diagnostic_provider_finalize;
+
+ provider_class->diagnose_async = ide_gca_diagnostic_provider_diagnose_async;
+ provider_class->diagnose_finish = ide_gca_diagnostic_provider_diagnose_finish;
+}
+
+static void
+ide_gca_diagnostic_provider_init (IdeGcaDiagnosticProvider *self)
+{
+ self->document_cache = g_hash_table_new_full (g_str_hash, g_str_equal,
+ g_free, g_object_unref);
+}
diff --git a/libide/gca/ide-gca-diagnostic-provider.h b/libide/gca/ide-gca-diagnostic-provider.h
new file mode 100644
index 0000000..54fa9c0
--- /dev/null
+++ b/libide/gca/ide-gca-diagnostic-provider.h
@@ -0,0 +1,33 @@
+/* ide-gca-diagnostic-provider.h
+ *
+ * Copyright (C) 2015 Christian Hergert <christian hergert me>
+ *
+ * This file 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 3 of the
+ * License, or (at your option) any later version.
+ *
+ * This file 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 General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+#ifndef IDE_GCA_DIAGNOSTIC_PROVIDER_H
+#define IDE_GCA_DIAGNOSTIC_PROVIDER_H
+
+#include "ide-diagnostic-provider.h"
+
+G_BEGIN_DECLS
+
+#define IDE_TYPE_GCA_DIAGNOSTIC_PROVIDER (ide_gca_diagnostic_provider_get_type())
+
+G_DECLARE_FINAL_TYPE (IdeGcaDiagnosticProvider, ide_gca_diagnostic_provider,
+ IDE, GCA_DIAGNOSTIC_PROVIDER, IdeDiagnosticProvider)
+
+G_END_DECLS
+
+#endif /* IDE_GCA_DIAGNOSTIC_PROVIDER_H */
diff --git a/libide/gca/ide-gca-service.c b/libide/gca/ide-gca-service.c
index 9db06bc..fa0a655 100644
--- a/libide/gca/ide-gca-service.c
+++ b/libide/gca/ide-gca-service.c
@@ -23,7 +23,9 @@
struct _IdeGcaService
{
- IdeService parent_instance;
+ IdeService parent_instance;
+
+ GHashTable *proxy_cache;
};
static GDBusConnection *gDBus;
@@ -48,13 +50,17 @@ proxy_new_cb (GObject *object,
GAsyncResult *result,
gpointer user_data)
{
+ IdeGcaService *self;
g_autoptr(GTask) task = user_data;
+ const gchar *language_id;
GcaService *proxy;
GError *error = NULL;
g_assert (G_IS_TASK (task));
g_assert (G_IS_ASYNC_RESULT (result));
+ self = g_task_get_source_object (task);
+
proxy = gca_service_proxy_new_finish (result, &error);
if (!proxy)
@@ -63,6 +69,10 @@ proxy_new_cb (GObject *object,
return;
}
+ language_id = g_task_get_task_data (task);
+ g_hash_table_replace (self->proxy_cache, g_strdup (language_id),
+ g_object_ref (proxy));
+
g_task_return_pointer (task, g_object_ref (proxy), g_object_unref);
g_clear_object (&proxy);
@@ -78,11 +88,14 @@ ide_gca_service_get_proxy_async (IdeGcaService *self,
g_autoptr(GTask) task = NULL;
g_autoptr(gchar) name = NULL;
g_autoptr(gchar) object_path = NULL;
+ GcaService *proxy;
g_return_if_fail (IDE_IS_GCA_SERVICE (self));
g_return_if_fail (language_id);
g_return_if_fail (!cancellable || G_IS_CANCELLABLE (cancellable));
+ language_id = remap_language (language_id);
+
task = g_task_new (self, cancellable, callback, user_data);
if (!gDBus)
@@ -94,7 +107,13 @@ ide_gca_service_get_proxy_async (IdeGcaService *self,
return;
}
- language_id = remap_language (language_id);
+ if ((proxy = g_hash_table_lookup (self->proxy_cache, language_id)))
+ {
+ g_task_return_pointer (task, g_object_ref (proxy), g_object_unref);
+ return;
+ }
+
+ g_task_set_task_data (task, g_strdup (language_id), g_free);
name = g_strdup_printf ("org.gnome.CodeAssist.v1.%s", language_id);
object_path = g_strdup_printf ("/org/gnome/CodeAssist/v1/%s", language_id);
@@ -108,6 +127,13 @@ ide_gca_service_get_proxy_async (IdeGcaService *self,
g_object_ref (task));
}
+/**
+ * ide_gca_service_get_proxy_finish:
+ *
+ * Completes an asynchronous request to load a Gca proxy.
+ *
+ * Returns: (transfer full): A #GcaService or %NULL upon failure.
+ */
GcaService *
ide_gca_service_get_proxy_finish (IdeGcaService *self,
GAsyncResult *result,
@@ -126,6 +152,8 @@ ide_gca_service_finalize (GObject *object)
{
IdeGcaService *self = (IdeGcaService *)object;
+ g_clear_pointer (&self->proxy_cache, g_hash_table_unref);
+
G_OBJECT_CLASS (ide_gca_service_parent_class)->finalize (object);
}
@@ -152,4 +180,6 @@ ide_gca_service_class_init (IdeGcaServiceClass *klass)
static void
ide_gca_service_init (IdeGcaService *self)
{
+ self->proxy_cache = g_hash_table_new_full (g_str_hash, g_str_equal,
+ g_free, g_object_unref);
}
[
Date Prev][
Date Next] [
Thread Prev][
Thread Next]
[
Thread Index]
[
Date Index]
[
Author Index]
