]> git.0d.be Git - empathy.git/blobdiff - libempathy/empathy-utils.c
Replace empathy_connection_get_protocol by tp_connection_parse_object_path
[empathy.git] / libempathy / empathy-utils.c
index e354e940d64594138125490f036b29f6816975af..210c3504856b90d7eeec2587beb003f6c921009c 100644 (file)
@@ -1,7 +1,7 @@
 /* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*- */
 /*
  * Copyright (C) 2003-2007 Imendio AB
- * Copyright (C) 2007 Collabora Ltd.
+ * Copyright (C) 2007-2008 Collabora Ltd.
  *
  * This program is free software; you can redistribute it and/or
  * modify it under the terms of the GNU General Public License as
 #include <string.h>
 #include <time.h>
 #include <sys/types.h>
-#include <regex.h>
 
-#include <glib/gi18n.h>
+#include <glib/gi18n-lib.h>
 
 #include <libxml/uri.h>
-#include <libtelepathy/tp-helpers.h>
+#include <telepathy-glib/connection.h>
+#include <telepathy-glib/channel.h>
+#include <telepathy-glib/dbus.h>
 
-#include "empathy-debug.h"
 #include "empathy-utils.h"
 #include "empathy-contact-manager.h"
-#include "empathy-tp-group.h"
+#include "empathy-dispatcher.h"
+#include "empathy-dispatch-operation.h"
+#include "empathy-idle.h"
+#include "empathy-tp-call.h"
 
-#define DEBUG_DOMAIN "Utils"
+#include <extensions/extensions.h>
 
-static void regex_init (void);
+#define DEBUG_FLAG EMPATHY_DEBUG_OTHER
+#include "empathy-debug.h"
 
-gchar *
-empathy_substring (const gchar *str,
-                 gint         start,
-                 gint         end)
-{
-       return g_strndup (str + start, end - start);
-}
 
-/*
- * Regular Expression code to match urls.
- */
-#define USERCHARS "-A-Za-z0-9"
-#define PASSCHARS "-A-Za-z0-9,?;.:/!%$^*&~\"#'"
-#define HOSTCHARS "-A-Za-z0-9"
-#define PATHCHARS "-A-Za-z0-9_$.+!*(),;:@&=?/~#%"
-#define SCHEME    "(news:|telnet:|nntp:|file:/|https?:|ftps?:|webcal:)"
-#define USER      "[" USERCHARS "]+(:["PASSCHARS "]+)?"
-#define URLPATH   "/[" PATHCHARS "]*[^]'.}>) \t\r\n,\\\"]"
-
-static regex_t dingus[EMPATHY_REGEX_ALL];
-
-static void
-regex_init (void)
+void
+empathy_init (void)
 {
-       static gboolean  inited = FALSE;
-       const gchar     *expression;
-       gint             i;
+       static gboolean initialized = FALSE;
 
-       if (inited) {
+       if (initialized)
                return;
-       }
-
-       for (i = 0; i < EMPATHY_REGEX_ALL; i++) {
-               switch (i) {
-               case EMPATHY_REGEX_AS_IS:
-                       expression =
-                               SCHEME "//(" USER "@)?[" HOSTCHARS ".]+"
-                               "(:[0-9]+)?(" URLPATH ")?";
-                       break;
-               case EMPATHY_REGEX_BROWSER:
-                       expression =
-                               "(www|ftp)[" HOSTCHARS "]*\\.[" HOSTCHARS ".]+"
-                               "(:[0-9]+)?(" URLPATH ")?";
-                       break;
-               case EMPATHY_REGEX_EMAIL:
-                       expression =
-                               "(mailto:)?[a-z0-9][a-z0-9.-]*@[a-z0-9]"
-                               "[a-z0-9-]*(\\.[a-z0-9][a-z0-9-]*)+";
-                       break;
-               case EMPATHY_REGEX_OTHER:
-                       expression =
-                               "news:[-A-Z\\^_a-z{|}~!\"#$%&'()*+,./0-9;:=?`]+"
-                               "@[" HOSTCHARS ".]+(:[0-9]+)?";
-                       break;
-               default:
-                       /* Silence the compiler. */
-                       expression = NULL;
-                       continue;
-               }
 
-               memset (&dingus[i], 0, sizeof (regex_t));
-               regcomp (&dingus[i], expression, REG_EXTENDED | REG_ICASE);
-       }
-
-       inited = TRUE;
-}
-
-gint
-empathy_regex_match (EmpathyRegExType  type,
-                   const gchar     *msg,
-                   GArray          *start,
-                   GArray          *end)
-{
-       regmatch_t matches[1];
-       gint       ret = 0;
-       gint       num_matches = 0;
-       gint       offset = 0;
-       gint       i;
+       g_type_init ();
 
-       g_return_val_if_fail (type >= 0 || type <= EMPATHY_REGEX_ALL, 0);
+       /* Setup gettext */
+       bindtextdomain (GETTEXT_PACKAGE, LOCALEDIR);
+       bind_textdomain_codeset (GETTEXT_PACKAGE, "UTF-8");
 
-       regex_init ();
-
-       while (!ret && type != EMPATHY_REGEX_ALL) {
-               ret = regexec (&dingus[type], msg + offset, 1, matches, 0);
-               if (ret == 0) {
-                       gint s;
-
-                       num_matches++;
-
-                       s = matches[0].rm_so + offset;
-                       offset = matches[0].rm_eo + offset;
-
-                       g_array_append_val (start, s);
-                       g_array_append_val (end, offset);
-               }
+       /* Setup debug output for empathy and telepathy-glib */
+       if (g_getenv ("EMPATHY_TIMING") != NULL) {
+               g_log_set_default_handler (tp_debug_timestamped_log_handler, NULL);
        }
+       empathy_debug_set_flags (g_getenv ("EMPATHY_DEBUG"));
+       tp_debug_divert_messages (g_getenv ("EMPATHY_LOGFILE"));
 
-       if (type != EMPATHY_REGEX_ALL) {
-               empathy_debug (DEBUG_DOMAIN,
-                             "Found %d matches for regex type:%d",
-                             num_matches, type);
-               return num_matches;
-       }
+       emp_cli_init ();
 
-       /* If EMPATHY_REGEX_ALL then we run ALL regex's on the string. */
-       for (i = 0; i < EMPATHY_REGEX_ALL; i++, ret = 0) {
-               while (!ret) {
-                       ret = regexec (&dingus[i], msg + offset, 1, matches, 0);
-                       if (ret == 0) {
-                               gint s;
-
-                               num_matches++;
-
-                               s = matches[0].rm_so + offset;
-                               offset = matches[0].rm_eo + offset;
-
-                               g_array_append_val (start, s);
-                               g_array_append_val (end, offset);
-                       }
-               }
-       }
-
-       empathy_debug (DEBUG_DOMAIN,
-                     "Found %d matches for ALL regex types",
-                     num_matches);
+       initialized = TRUE;
+}
 
-       return num_matches;
+gchar *
+empathy_substring (const gchar *str,
+                 gint         start,
+                 gint         end)
+{
+       return g_strndup (str + start, end - start);
 }
 
 gint
@@ -199,82 +108,6 @@ empathy_strncasecmp (const gchar *s1,
        return ret_val;
 }
 
-/* Stolen from telepathy-glib */
-gboolean
-empathy_strdiff (const gchar *left, const gchar *right)
-{
-  if ((NULL == left) != (NULL == right))
-    return TRUE;
-
-  else if (left == right)
-    return FALSE;
-
-  else
-    return (0 != strcmp (left, right));
-}
-
-/* Stolen from telepathy-glib */
-static inline gboolean
-_esc_ident_bad (gchar c, gboolean is_first)
-{
-  return ((c < 'a' || c > 'z') &&
-          (c < 'A' || c > 'Z') &&
-          (c < '0' || c > '9' || is_first));
-}
-
-/* Stolen from telepathy-glib */
-gchar *
-empathy_escape_as_identifier (const gchar *name)
-{
-  gboolean bad = FALSE;
-  size_t len = 0;
-  GString *op;
-  const gchar *ptr, *first_ok;
-
-  g_return_val_if_fail (name != NULL, NULL);
-
-  for (ptr = name; *ptr; ptr++)
-    {
-      if (_esc_ident_bad (*ptr, ptr == name))
-        {
-          bad = TRUE;
-          len += 3;
-        }
-      else
-        len++;
-    }
-
-  /* fast path if it's clean */
-  if (!bad)
-    return g_strdup (name);
-
-  /* If strictly less than ptr, first_ok is the first uncopied safe character.
-   */
-  first_ok = name;
-  op = g_string_sized_new (len);
-  for (ptr = name; *ptr; ptr++)
-    {
-      if (_esc_ident_bad (*ptr, ptr == name))
-        {
-          /* copy preceding safe characters if any */
-          if (first_ok < ptr)
-            {
-              g_string_append_len (op, first_ok, ptr - first_ok);
-            }
-          /* escape the unsafe character */
-          g_string_append_printf (op, "_%02x", (unsigned char)(*ptr));
-          /* restart after it */
-          first_ok = ptr + 1;
-        }
-    }
-  /* copy trailing safe characters if any */
-  if (first_ok < ptr)
-    {
-      g_string_append_len (op, first_ok, ptr - first_ok);
-    }
-  return g_string_free (op, FALSE);
-}
-
 gboolean
 empathy_xml_validate (xmlDoc      *doc,
                     const gchar *dtd_filename)
@@ -284,11 +117,16 @@ empathy_xml_validate (xmlDoc      *doc,
        xmlDtd       *dtd;
        gboolean      ret;
 
-       path = g_build_filename (DATADIR, "empathy", dtd_filename, NULL);
+       path = g_build_filename (g_getenv ("EMPATHY_SRCDIR"), "libempathy",
+                                dtd_filename, NULL);
+       if (!g_file_test (path, G_FILE_TEST_EXISTS)) {
+               g_free (path);
+               path = g_build_filename (DATADIR, "empathy", dtd_filename, NULL);
+       }
+       DEBUG ("Loading dtd file %s", path);
 
        /* The list of valid chars is taken from libxml. */
        escaped = xmlURIEscapeStr (path, ":@&=+$,/?;");
-
        g_free (path);
 
        memset (&cvp, 0, sizeof (cvp));
@@ -391,7 +229,7 @@ empathy_account_equal (gconstpointer a,
 }
 
 MissionControl *
-empathy_mission_control_new (void)
+empathy_mission_control_dup_singleton (void)
 {
        static MissionControl *mc = NULL;
 
@@ -405,125 +243,139 @@ empathy_mission_control_new (void)
        return mc;
 }
 
-gchar *
-empathy_inspect_channel (McAccount *account,
-                        TpChan    *tp_chan)
+const gchar *
+empathy_presence_get_default_message (McPresence presence)
 {
-       g_return_val_if_fail (MC_IS_ACCOUNT (account), NULL);
-       g_return_val_if_fail (TELEPATHY_IS_CHAN (tp_chan), NULL);
+       switch (presence) {
+       case MC_PRESENCE_AVAILABLE:
+               return _("Available");
+       case MC_PRESENCE_DO_NOT_DISTURB:
+               return _("Busy");
+       case MC_PRESENCE_AWAY:
+       case MC_PRESENCE_EXTENDED_AWAY:
+               return _("Away");
+       case MC_PRESENCE_HIDDEN:
+               return _("Hidden");
+       case MC_PRESENCE_OFFLINE:
+       case MC_PRESENCE_UNSET:
+               return _("Offline");
+       default:
+               g_assert_not_reached ();
+       }
 
-       return empathy_inspect_handle (account,
-                                      tp_chan->handle,
-                                      tp_chan->handle_type);
+       return NULL;
+}
+
+const gchar *
+empathy_presence_to_str (McPresence presence)
+{
+       switch (presence) {
+       case MC_PRESENCE_AVAILABLE:
+               return "available";
+       case MC_PRESENCE_DO_NOT_DISTURB:
+               return "busy";
+       case MC_PRESENCE_AWAY:
+               return "away";
+       case MC_PRESENCE_EXTENDED_AWAY:
+               return "ext_away";
+       case MC_PRESENCE_HIDDEN:
+               return "hidden";
+       case MC_PRESENCE_OFFLINE:
+               return "offline";
+       case MC_PRESENCE_UNSET:
+               return "unset";
+       default:
+               g_assert_not_reached ();
+       }
+
+       return NULL;
+}
+
+McPresence
+empathy_presence_from_str (const gchar *str)
+{
+       if (strcmp (str, "available") == 0) {
+               return MC_PRESENCE_AVAILABLE;
+       } else if ((strcmp (str, "dnd") == 0) || (strcmp (str, "busy") == 0)) {
+               return MC_PRESENCE_DO_NOT_DISTURB;
+       } else if ((strcmp (str, "away") == 0) || (strcmp (str, "brb") == 0)) {
+               return MC_PRESENCE_AWAY;
+       } else if ((strcmp (str, "xa") == 0) || (strcmp (str, "ext_away") == 0)) {
+               return MC_PRESENCE_EXTENDED_AWAY;
+       } else if (strcmp (str, "hidden") == 0) {
+               return MC_PRESENCE_HIDDEN;
+       } else if (strcmp (str, "offline") == 0) {
+               return MC_PRESENCE_OFFLINE;
+       } else if (strcmp (str, "unset") == 0) {
+               return MC_PRESENCE_UNSET;
+       }
+
+       return MC_PRESENCE_UNSET;
 }
 
 gchar *
-empathy_inspect_handle (McAccount *account,
-                       guint      handle,
-                       guint      handle_type)
+empathy_file_lookup (const gchar *filename, const gchar *subdir)
 {
-       MissionControl  *mc;
-       TpConn          *tp_conn;
-       GArray          *handles;
-       gchar          **names;
-       gchar           *name;
-       GError          *error;
-
-       g_return_val_if_fail (MC_IS_ACCOUNT (account), NULL);
-       g_return_val_if_fail (handle != 0, NULL);
-       g_return_val_if_fail (handle_type != 0, NULL);
-
-       mc = empathy_mission_control_new ();
-       tp_conn = mission_control_get_connection (mc, account, NULL);
-       g_object_unref (mc);
-
-       if (!tp_conn) {
-               return NULL;
+       gchar *path;
+
+       if (!subdir) {
+               subdir = ".";
        }
 
-       /* Get the handle's name */
-       handles = g_array_new (FALSE, FALSE, sizeof (guint));
-       g_array_append_val (handles, handle);
-       if (!tp_conn_inspect_handles (DBUS_G_PROXY (tp_conn),
-                                     handle_type,
-                                     handles,
-                                     &names,
-                                     &error)) {
-               empathy_debug (DEBUG_DOMAIN, 
-                             "Couldn't get id: %s",
-                             error ? error->message : "No error given");
-
-               g_clear_error (&error);
-               g_array_free (handles, TRUE);
-               g_object_unref (tp_conn);
-               
-               return NULL;
+       path = g_build_filename (g_getenv ("EMPATHY_SRCDIR"), subdir, filename, NULL);
+       if (!g_file_test (path, G_FILE_TEST_EXISTS)) {
+               g_free (path);
+               path = g_build_filename (DATADIR, "empathy", filename, NULL);
        }
 
-       g_array_free (handles, TRUE);
-       name = *names;
-       g_free (names);
-       g_object_unref (tp_conn);
+       return path;
+}
+
+guint
+empathy_proxy_hash (gconstpointer key)
+{
+       TpProxy      *proxy = TP_PROXY (key);
+       TpProxyClass *proxy_class = TP_PROXY_GET_CLASS (key);
 
-       return name;
+       g_return_val_if_fail (TP_IS_PROXY (proxy), 0);
+       g_return_val_if_fail (proxy_class->must_have_unique_name, 0);
+
+       return g_str_hash (proxy->object_path) ^ g_str_hash (proxy->bus_name);
 }
 
-void
-empathy_call_contact (EmpathyContact *contact)
+gboolean
+empathy_proxy_equal (gconstpointer a,
+                    gconstpointer b)
 {
-#ifdef HAVE_VOIP
-       MissionControl *mc;
-       McAccount      *account;
-       TpConn         *tp_conn;
-       gchar          *object_path;
-       const gchar    *bus_name;
-       TpChan         *new_chan;
-       EmpathyTpGroup *group;
-       GError         *error;
-
-       g_return_if_fail (EMPATHY_IS_CONTACT (contact));
-
-       /* StreamedMedia channels must have handle=0 and handle_type=none.
-        * To call a contact we have to add him in the group interface of the
-        * channel. MissionControl will detect the channel creation and 
-        * dispatch it to the VoIP chandler automatically. */
-
-       mc = empathy_mission_control_new ();
-       account = empathy_contact_get_account (contact);
-       tp_conn = mission_control_get_connection (mc, account, NULL);
-       /* FIXME: Should be async */
-       if (!tp_conn_request_channel (DBUS_G_PROXY (tp_conn),
-                                     TP_IFACE_CHANNEL_TYPE_STREAMED_MEDIA,
-                                     TP_HANDLE_TYPE_NONE,
-                                     0,
-                                     FALSE,
-                                     &object_path,
-                                     &error)) {
-               empathy_debug (DEBUG_DOMAIN, 
-                             "Couldn't request channel: %s",
-                             error ? error->message : "No error given");
-               g_clear_error (&error);
-               g_object_unref (mc);
-               g_object_unref (tp_conn);
-               return;
+       TpProxy *proxy_a = TP_PROXY (a);
+       TpProxy *proxy_b = TP_PROXY (b);
+       TpProxyClass *proxy_a_class = TP_PROXY_GET_CLASS (a);
+       TpProxyClass *proxy_b_class = TP_PROXY_GET_CLASS (b);
+
+       g_return_val_if_fail (TP_IS_PROXY (proxy_a), FALSE);
+       g_return_val_if_fail (TP_IS_PROXY (proxy_b), FALSE);
+       g_return_val_if_fail (proxy_a_class->must_have_unique_name, 0);
+       g_return_val_if_fail (proxy_b_class->must_have_unique_name, 0);
+
+       return g_str_equal (proxy_a->object_path, proxy_b->object_path) &&
+              g_str_equal (proxy_a->bus_name, proxy_b->bus_name);
+}
+
+gboolean
+empathy_check_available_state (void)
+{
+       McPresence presence;
+       EmpathyIdle *idle;
+
+       idle = empathy_idle_dup_singleton ();
+       presence = empathy_idle_get_state (idle);
+       g_object_unref (idle);
+
+       if (presence != MC_PRESENCE_AVAILABLE &&
+               presence != MC_PRESENCE_UNSET) {
+               return FALSE;    
        }
 
-       bus_name = dbus_g_proxy_get_bus_name (DBUS_G_PROXY (tp_conn));
-       new_chan = tp_chan_new (tp_get_bus (),
-                               bus_name,
-                               object_path,
-                               TP_IFACE_CHANNEL_TYPE_STREAMED_MEDIA,
-                               TP_HANDLE_TYPE_NONE,
-                               0);
-
-       group = empathy_tp_group_new (account, new_chan);
-       empathy_tp_group_add_member (group, contact, "");
-
-       g_object_unref (group);
-       g_object_unref (mc);
-       g_object_unref (tp_conn);
-       g_object_unref (new_chan);
-       g_free (object_path);
-#endif
+       return TRUE;
 }