/* TpProtocol * * Copyright © 2010-2012 Collabora Ltd. * * 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.1 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 St, Fifth Floor, Boston, MA 02110-1301 USA */ /** * SECTION:protocol * @title: TpProtocol * @short_description: proxy for a Telepathy Protocol object * @see_also: #TpConnectionManager * * #TpProtocol objects represent the protocols implemented by Telepathy * connection managers. In modern connection managers, each protocol is * represented by a D-Bus object; in older connection managers, the protocols * are represented by data structures, and this object merely emulates a D-Bus * object. * * Since: 0.11.11 */ #include "config.h" #include #include #include #include #define DEBUG_FLAG TP_DEBUG_PARAMS #include "telepathy-glib/capabilities-internal.h" #include "telepathy-glib/debug-internal.h" #include "telepathy-glib/proxy-internal.h" #include "telepathy-glib/util-internal.h" #include "telepathy-glib/variant-util-internal.h" #include "telepathy-glib/_gen/tp-cli-protocol-body.h" #include struct _TpProtocolClass { /**/ TpProxyClass parent_class; }; /** * TpProtocol: * * A base class for connection managers' protocols. * * Since: 0.11.11 */ /** * TpProtocolClass: * * The class of a #TpProtocol. * * Since: 0.11.11 */ G_DEFINE_TYPE(TpProtocol, tp_protocol, TP_TYPE_PROXY) /** * TP_PROTOCOL_FEATURE_PARAMETERS: * * Expands to a call to a function that returns a quark for the parameters * feature of a #TpProtocol. * * When this feature is prepared, the possible parameters for connections to * this protocol have been retrieved and are available for use. * * Unlike %TP_PROTOCOL_FEATURE_CORE, this feature can even be available on * connection managers that don't really have Protocol objects * (on these older connection managers, the #TpProtocol uses information from * ConnectionManager methods to provide the list of parameters). * * One can ask for a feature to be prepared using the * tp_proxy_prepare_async() function, and waiting for it to callback. * * Since: 0.11.11 */ GQuark tp_protocol_get_feature_quark_parameters (void) { return g_quark_from_static_string ("tp-protocol-feature-parameters"); } /** * TP_PROTOCOL_FEATURE_CORE: * * Expands to a call to a function that returns a quark for the core * feature of a #TpProtocol. * * When this feature is prepared, at least the following basic information * about the protocol is available: * * * possible parameters for connections to this protocol * interfaces expected on connections to this protocol * classes of channel that could be requested from connections * to this protocol * * * (This feature implies that %TP_PROTOCOL_FEATURE_PARAMETERS is also * available.) * * Unlike %TP_PROTOCOL_FEATURE_PARAMETERS, this feature can only become * available on connection managers that implement Protocol objects. * * One can ask for a feature to be prepared using the * tp_proxy_prepare_async() function, and waiting for it to callback. * * Since: 0.11.11 */ GQuark tp_protocol_get_feature_quark_core (void) { return g_quark_from_static_string ("tp-protocol-feature-core"); } struct _TpProtocolPrivate { TpConnectionManagerProtocol protocol_struct; GHashTable *protocol_properties; gchar *vcard_field; gchar *english_name; gchar *icon_name; GStrv authentication_types; TpCapabilities *capabilities; TpAvatarRequirements *avatar_req; gchar *cm_name; GStrv addressable_vcard_fields; GStrv addressable_uri_schemes; /* (transfer container) (element-type utf8 Simple_Status_Spec) */ GHashTable *presence_statuses; }; enum { PROP_PROTOCOL_NAME = 1, PROP_PROTOCOL_PROPERTIES, PROP_PROTOCOL_PROPERTIES_VARDICT, PROP_ENGLISH_NAME, PROP_VCARD_FIELD, PROP_ICON_NAME, PROP_CAPABILITIES, PROP_PARAM_NAMES, PROP_AUTHENTICATION_TYPES, PROP_AVATAR_REQUIREMENTS, PROP_CM_NAME, PROP_ADDRESSABLE_VCARD_FIELDS, PROP_ADDRESSABLE_URI_SCHEMES, N_PROPS }; /* this is NULL-safe for @parameters, and callers rely on this */ static TpConnectionManagerParam * tp_protocol_params_from_param_specs (const GPtrArray *parameters, const gchar *cm_debug_name, const gchar *protocol) { GArray *output; guint i; DEBUG ("Protocol name: %s", protocol); if (parameters == NULL) { return g_new0 (TpConnectionManagerParam, 1); } output = g_array_sized_new (TRUE, TRUE, sizeof (TpConnectionManagerParam), parameters->len); for (i = 0; i < parameters->len; i++) { GValue structure = { 0 }; GValue *tmp; TpConnectionManagerParam *param; g_value_init (&structure, TP_STRUCT_TYPE_PARAM_SPEC); g_value_set_static_boxed (&structure, g_ptr_array_index (parameters, i)); g_array_set_size (output, output->len + 1); /* point to the new last item */ param = &g_array_index (output, TpConnectionManagerParam, output->len - 1); if (!dbus_g_type_struct_get (&structure, 0, ¶m->name, 1, ¶m->flags, 2, ¶m->dbus_signature, 3, &tmp, G_MAXUINT)) { DEBUG ("Unparseable parameter #%d for %s, ignoring", i, protocol); /* *shrug* that one didn't work, let's skip it */ g_array_set_size (output, output->len - 1); continue; } if (!g_variant_type_string_is_valid (param->dbus_signature)) { DEBUG ("Parameter #%d for %s has type '%s' which is not a " "single complete type, ignoring", i, protocol, param->dbus_signature); g_array_set_size (output, output->len - 1); continue; } g_value_init (¶m->default_value, G_VALUE_TYPE (tmp)); g_value_copy (tmp, ¶m->default_value); g_value_unset (tmp); g_free (tmp); param->priv = NULL; DEBUG ("\tParam name: %s", param->name); DEBUG ("\tParam flags: 0x%x", param->flags); DEBUG ("\tParam sig: %s", param->dbus_signature); if ((!tp_strdiff (param->name, "password") || g_str_has_suffix (param->name, "-password")) && (param->flags & TP_CONN_MGR_PARAM_FLAG_SECRET) == 0) { DEBUG ("\tTreating as secret due to its name (please fix %s)", cm_debug_name); param->flags |= TP_CONN_MGR_PARAM_FLAG_SECRET; } #ifdef ENABLE_DEBUG { gchar *repr = g_strdup_value_contents (&(param->default_value)); DEBUG ("\tParam default value: %s of type %s", repr, G_VALUE_TYPE_NAME (&(param->default_value))); g_free (repr); } #endif } return (TpConnectionManagerParam *) g_array_free (output, FALSE); } static void tp_protocol_get_property (GObject *object, guint property_id, GValue *value, GParamSpec *pspec) { TpProtocol *self = (TpProtocol *) object; switch (property_id) { case PROP_PROTOCOL_NAME: g_value_set_string (value, self->priv->protocol_struct.name); break; case PROP_PROTOCOL_PROPERTIES: g_value_set_boxed (value, self->priv->protocol_properties); break; case PROP_PROTOCOL_PROPERTIES_VARDICT: g_value_take_variant (value, tp_protocol_dup_immutable_properties (self)); break; case PROP_ENGLISH_NAME: g_value_set_string (value, tp_protocol_get_english_name (self)); break; case PROP_VCARD_FIELD: g_value_set_string (value, tp_protocol_get_vcard_field (self)); break; case PROP_ICON_NAME: g_value_set_string (value, tp_protocol_get_icon_name (self)); break; case PROP_CAPABILITIES: g_value_set_object (value, tp_protocol_get_capabilities (self)); break; case PROP_PARAM_NAMES: g_value_take_boxed (value, tp_protocol_dup_param_names (self)); break; case PROP_AUTHENTICATION_TYPES: g_value_set_boxed (value, tp_protocol_get_authentication_types (self)); break; case PROP_AVATAR_REQUIREMENTS: g_value_set_pointer (value, tp_protocol_get_avatar_requirements (self)); break; case PROP_CM_NAME: g_value_set_string (value, tp_protocol_get_cm_name (self)); break; case PROP_ADDRESSABLE_VCARD_FIELDS: g_value_set_boxed (value, tp_protocol_get_addressable_vcard_fields ( self)); break; case PROP_ADDRESSABLE_URI_SCHEMES: g_value_set_boxed (value, tp_protocol_get_addressable_uri_schemes (self)); break; default: G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec); break; } } static void tp_protocol_set_property (GObject *object, guint property_id, const GValue *value, GParamSpec *pspec) { TpProtocol *self = (TpProtocol *) object; switch (property_id) { case PROP_PROTOCOL_NAME: g_assert (self->priv->protocol_struct.name == NULL); self->priv->protocol_struct.name = g_value_dup_string (value); break; case PROP_PROTOCOL_PROPERTIES: g_assert (self->priv->protocol_properties == NULL); self->priv->protocol_properties = g_value_dup_boxed (value); break; case PROP_CM_NAME: g_assert (self->priv->cm_name == NULL); self->priv->cm_name = g_value_dup_string (value); break; default: G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec); break; } } void _tp_connection_manager_param_free_contents (TpConnectionManagerParam *param) { g_free (param->name); g_free (param->dbus_signature); if (G_IS_VALUE (¶m->default_value)) g_value_unset (¶m->default_value); } void _tp_connection_manager_protocol_free_contents ( TpConnectionManagerProtocol *proto) { g_free (proto->name); if (proto->params != NULL) { TpConnectionManagerParam *param; for (param = proto->params; param->name != NULL; param++) _tp_connection_manager_param_free_contents (param); } g_free (proto->params); } static void tp_protocol_dispose (GObject *object) { TpProtocol *self = TP_PROTOCOL (object); GObjectFinalizeFunc dispose = ((GObjectClass *) tp_protocol_parent_class)->dispose; if (self->priv->capabilities != NULL) { g_object_unref (self->priv->capabilities); self->priv->capabilities = NULL; } if (self->priv->authentication_types) { g_strfreev (self->priv->authentication_types); self->priv->authentication_types = NULL; } tp_clear_pointer (&self->priv->avatar_req, tp_avatar_requirements_destroy); if (dispose != NULL) dispose (object); } static void tp_protocol_finalize (GObject *object) { TpProtocol *self = TP_PROTOCOL (object); GObjectFinalizeFunc finalize = ((GObjectClass *) tp_protocol_parent_class)->finalize; _tp_connection_manager_protocol_free_contents (&self->priv->protocol_struct); g_free (self->priv->vcard_field); g_free (self->priv->english_name); g_free (self->priv->icon_name); g_free (self->priv->cm_name); g_strfreev (self->priv->addressable_vcard_fields); g_strfreev (self->priv->addressable_uri_schemes); if (self->priv->presence_statuses != NULL) g_hash_table_unref (self->priv->presence_statuses); if (self->priv->protocol_properties != NULL) g_hash_table_unref (self->priv->protocol_properties); if (finalize != NULL) finalize (object); } static gboolean tp_protocol_check_for_core (TpProtocol *self) { const GHashTable *props = self->priv->protocol_properties; const GValue *value; /* this one can legitimately be NULL so we need to be more careful */ value = tp_asv_lookup (props, TP_PROP_PROTOCOL_CONNECTION_INTERFACES); if (value == NULL || !G_VALUE_HOLDS (value, G_TYPE_STRV)) { DEBUG ("Interfaces not found"); return FALSE; } if (tp_asv_get_boxed (props, TP_PROP_PROTOCOL_REQUESTABLE_CHANNEL_CLASSES, TP_ARRAY_TYPE_REQUESTABLE_CHANNEL_CLASS_LIST) == NULL) { DEBUG ("Requestable channel classes not found"); return FALSE; } /* Interfaces has a sensible default, the empty list. * VCardField, EnglishName and Icon have a sensible default, "". */ DEBUG ("Core feature ready"); return TRUE; } static gchar * title_case (const gchar *s) { gunichar u; /* 6 bytes are enough for any Unicode character, 7th byte remains '\0' */ gchar buf[7] = { 0 }; /* if s isn't UTF-8, give up and use it as-is */ if (!g_utf8_validate (s, -1, NULL)) return g_strdup (s); u = g_utf8_get_char (s); if (!g_unichar_islower (u)) return g_strdup (s); u = g_unichar_totitle (u); g_unichar_to_utf8 (u, buf); g_assert (buf [sizeof (buf) - 1] == '\0'); return g_strdup_printf ("%s%s", buf, g_utf8_next_char (s)); } static GStrv asv_strdupv_or_empty (const GHashTable *asv, const gchar *key) { const gchar * const *strings = tp_asv_get_boxed (asv, key, G_TYPE_STRV); static const gchar * const no_strings[] = { NULL }; if (strings != NULL) return g_strdupv ((GStrv) strings); else return g_strdupv ((GStrv) no_strings); } static void tp_protocol_constructed (GObject *object) { TpProtocol *self = (TpProtocol *) object; TpProxy *proxy = (TpProxy *) object; void (*chain_up) (GObject *) = ((GObjectClass *) tp_protocol_parent_class)->constructed; const gchar *s; const GPtrArray *rccs; gboolean had_immutables = TRUE; const gchar * const *interfaces; if (chain_up != NULL) chain_up (object); g_assert (self->priv->protocol_struct.name != NULL); DEBUG ("%s/%s: new Protocol", self->priv->cm_name, self->priv->protocol_struct.name); if (self->priv->protocol_properties == NULL) { DEBUG ("immutable properties not supplied"); had_immutables = FALSE; self->priv->protocol_properties = g_hash_table_new_full (g_str_hash, g_str_equal, g_free, (GDestroyNotify) tp_g_value_slice_free); } else { GHashTableIter iter; gpointer k, v; DEBUG ("immutable properties already supplied"); g_hash_table_iter_init (&iter, self->priv->protocol_properties); while (g_hash_table_iter_next (&iter, &k, &v)) { gchar *printed; printed = g_strdup_value_contents (v); DEBUG ("%s = %s", (const gchar *) k, printed); g_free (printed); } } self->priv->protocol_struct.params = tp_protocol_params_from_param_specs ( tp_asv_get_boxed (self->priv->protocol_properties, TP_PROP_PROTOCOL_PARAMETERS, TP_ARRAY_TYPE_PARAM_SPEC_LIST), tp_proxy_get_bus_name (self), self->priv->protocol_struct.name); /* force vCard field to lower case, even if the CM is spec-incompliant */ s = tp_asv_get_string (self->priv->protocol_properties, TP_PROP_PROTOCOL_VCARD_FIELD); if (tp_str_empty (s)) self->priv->vcard_field = NULL; else self->priv->vcard_field = g_utf8_strdown (s, -1); s = tp_asv_get_string (self->priv->protocol_properties, TP_PROP_PROTOCOL_ENGLISH_NAME); if (tp_str_empty (s)) self->priv->english_name = title_case (self->priv->protocol_struct.name); else self->priv->english_name = g_strdup (s); s = tp_asv_get_string (self->priv->protocol_properties, TP_PROP_PROTOCOL_ICON); if (tp_str_empty (s)) self->priv->icon_name = g_strdup_printf ("im-%s", self->priv->protocol_struct.name); else self->priv->icon_name = g_strdup (s); rccs = tp_asv_get_boxed (self->priv->protocol_properties, TP_PROP_PROTOCOL_REQUESTABLE_CHANNEL_CLASSES, TP_ARRAY_TYPE_REQUESTABLE_CHANNEL_CLASS_LIST); if (rccs != NULL) self->priv->capabilities = _tp_capabilities_new (rccs, FALSE); self->priv->authentication_types = asv_strdupv_or_empty ( self->priv->protocol_properties, TP_PROP_PROTOCOL_AUTHENTICATION_TYPES); interfaces = tp_asv_get_strv (self->priv->protocol_properties, TP_PROP_PROTOCOL_INTERFACES); tp_proxy_add_interfaces (proxy, interfaces); if (tp_proxy_has_interface_by_id (self, TP_IFACE_QUARK_PROTOCOL_INTERFACE_AVATARS)) { DEBUG ("%s/%s implements Avatars", self->priv->cm_name, self->priv->protocol_struct.name); self->priv->avatar_req = tp_avatar_requirements_new ( (GStrv) tp_asv_get_strv (self->priv->protocol_properties, TP_PROP_PROTOCOL_INTERFACE_AVATARS_SUPPORTED_AVATAR_MIME_TYPES), tp_asv_get_uint32 (self->priv->protocol_properties, TP_PROP_PROTOCOL_INTERFACE_AVATARS_MINIMUM_AVATAR_WIDTH, NULL), tp_asv_get_uint32 (self->priv->protocol_properties, TP_PROP_PROTOCOL_INTERFACE_AVATARS_MINIMUM_AVATAR_HEIGHT, NULL), tp_asv_get_uint32 (self->priv->protocol_properties, TP_PROP_PROTOCOL_INTERFACE_AVATARS_RECOMMENDED_AVATAR_WIDTH, NULL), tp_asv_get_uint32 (self->priv->protocol_properties, TP_PROP_PROTOCOL_INTERFACE_AVATARS_RECOMMENDED_AVATAR_HEIGHT, NULL), tp_asv_get_uint32 (self->priv->protocol_properties, TP_PROP_PROTOCOL_INTERFACE_AVATARS_MAXIMUM_AVATAR_WIDTH, NULL), tp_asv_get_uint32 (self->priv->protocol_properties, TP_PROP_PROTOCOL_INTERFACE_AVATARS_MAXIMUM_AVATAR_HEIGHT, NULL), tp_asv_get_uint32 (self->priv->protocol_properties, TP_PROP_PROTOCOL_INTERFACE_AVATARS_MAXIMUM_AVATAR_BYTES, NULL)); } if (tp_proxy_has_interface_by_id (self, TP_IFACE_QUARK_PROTOCOL_INTERFACE_ADDRESSING)) { DEBUG ("%s/%s implements Addressing", self->priv->cm_name, self->priv->protocol_struct.name); self->priv->addressable_vcard_fields = asv_strdupv_or_empty ( self->priv->protocol_properties, TP_PROP_PROTOCOL_INTERFACE_ADDRESSING_ADDRESSABLE_VCARD_FIELDS); self->priv->addressable_uri_schemes = asv_strdupv_or_empty ( self->priv->protocol_properties, TP_PROP_PROTOCOL_INTERFACE_ADDRESSING_ADDRESSABLE_URI_SCHEMES); } if (tp_proxy_has_interface_by_id (self, TP_IFACE_QUARK_PROTOCOL_INTERFACE_PRESENCE)) { DEBUG ("%s/%s implements Presence", self->priv->cm_name, self->priv->protocol_struct.name); self->priv->presence_statuses = tp_asv_get_boxed ( self->priv->protocol_properties, TP_PROP_PROTOCOL_INTERFACE_PRESENCE_STATUSES, TP_HASH_TYPE_SIMPLE_STATUS_SPEC_MAP); if (self->priv->presence_statuses != NULL) { GHashTableIter iter; gpointer k, v; g_hash_table_ref (self->priv->presence_statuses); DEBUG ("%s/%s presence statuses:", self->priv->cm_name, self->priv->protocol_struct.name); g_hash_table_iter_init (&iter, self->priv->presence_statuses); while (g_hash_table_iter_next (&iter, &k, &v)) { guint type; gboolean on_self, message; tp_value_array_unpack (v, 3, &type, &on_self, &message); DEBUG ("\tstatus '%s': type %u%s%s", (const gchar *) k, type, on_self ? ", can set on self" : "", message ? ", has message" : ""); } } } /* become ready immediately */ _tp_proxy_set_feature_prepared (proxy, TP_PROTOCOL_FEATURE_PARAMETERS, had_immutables); _tp_proxy_set_feature_prepared (proxy, TP_PROTOCOL_FEATURE_CORE, had_immutables && tp_protocol_check_for_core (self)); } enum { FEAT_PARAMETERS, FEAT_CORE, N_FEAT }; static const TpProxyFeature * tp_protocol_list_features (TpProxyClass *cls G_GNUC_UNUSED) { static TpProxyFeature features[N_FEAT + 1] = { { 0 } }; if (G_LIKELY (features[0].name != 0)) return features; /* we always try to prepare both of these features, and nothing else is * allowed to complete until they have succeeded or failed */ features[FEAT_PARAMETERS].name = TP_PROTOCOL_FEATURE_PARAMETERS; features[FEAT_PARAMETERS].core = TRUE; features[FEAT_CORE].name = TP_PROTOCOL_FEATURE_CORE; features[FEAT_CORE].core = TRUE; /* assert that the terminator at the end is there */ g_assert (features[N_FEAT].name == 0); return features; } static void tp_protocol_class_init (TpProtocolClass *klass) { TpProxyClass *proxy_class = (TpProxyClass *) klass; GObjectClass *object_class = (GObjectClass *) klass; g_type_class_add_private (klass, sizeof (TpProtocolPrivate)); object_class->constructed = tp_protocol_constructed; object_class->get_property = tp_protocol_get_property; object_class->set_property = tp_protocol_set_property; object_class->dispose = tp_protocol_dispose; object_class->finalize = tp_protocol_finalize; /** * TpProtocol:protocol-name: * * The machine-readable name of the protocol, taken from the Telepathy * D-Bus Interface Specification, such as "jabber" or "local-xmpp". * * Since: 0.11.11 */ g_object_class_install_property (object_class, PROP_PROTOCOL_NAME, g_param_spec_string ("protocol-name", "Name of this protocol", "The Protocol from telepathy-spec, such as 'jabber' or 'local-xmpp'", NULL, G_PARAM_CONSTRUCT_ONLY | G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS)); /** * TpProtocol:protocol-properties: * * The immutable properties of this Protocol, as provided at construction * time. This is a map from string to #GValue, which must not be modified. * * If the immutable properties were not provided at construction time, * the %TP_PROTOCOL_FEATURE_PARAMETERS and %TP_PROTOCOL_FEATURE_CORE features * will both be unavailable, and this #TpProtocol object will only be useful * as a way to access lower-level D-Bus calls. * * Since: 0.11.11 */ g_object_class_install_property (object_class, PROP_PROTOCOL_PROPERTIES, g_param_spec_boxed ("protocol-properties", "Protocol properties", "The immutable properties of this Protocol", TP_HASH_TYPE_QUALIFIED_PROPERTY_VALUE_MAP, G_PARAM_CONSTRUCT_ONLY | G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS)); /** * TpProtocol:protocol-properties-vardict: * * The immutable properties of this Protocol, as provided at construction * time. This is a #G_VARIANT_TYPE_VARDICT #GVariant, * which must not be modified. * * If the immutable properties were not provided at construction time, * the %TP_PROTOCOL_FEATURE_PARAMETERS and %TP_PROTOCOL_FEATURE_CORE features * will both be unavailable, and this #TpProtocol object will only be useful * as a way to access lower-level D-Bus calls. * * Since: 0.23.3 */ g_object_class_install_property (object_class, PROP_PROTOCOL_PROPERTIES_VARDICT, g_param_spec_variant ("protocol-properties-vardict", "Protocol properties", "The immutable properties of this Protocol", G_VARIANT_TYPE_VARDICT, NULL, G_PARAM_READABLE | G_PARAM_STATIC_STRINGS)); /** * TpProtocol:english-name: * * The name of the protocol in a form suitable for display to users, * such as "AIM" or "Yahoo!", or a string based on #TpProtocol:protocol-name * (currently constructed by putting the first character in title case, * but this is not guaranteed) if no better name is available or the * %TP_PROTOCOL_FEATURE_CORE feature has not been prepared. * * This is effectively in the C locale (international English); user * interfaces requiring a localized protocol name should look one up in their * own message catalog based on either #TpProtocol:protocol-name or * #TpProtocol:english-name, but should use this English version as a * fallback if no translated version can be found. * * Since: 0.11.11 */ g_object_class_install_property (object_class, PROP_ENGLISH_NAME, g_param_spec_string ("english-name", "English name", "A non-NULL English name for this Protocol", NULL, G_PARAM_READABLE | G_PARAM_STATIC_STRINGS)); /** * TpProtocol:vcard-field: * * The most common vCard field used for this protocol's contact * identifiers, normalized to lower case, or %NULL if there is no such field * or the %TP_PROTOCOL_FEATURE_CORE feature has not been prepared. * * Since: 0.11.11 */ g_object_class_install_property (object_class, PROP_VCARD_FIELD, g_param_spec_string ("vcard-field", "vCard field", "A lower-case vCard name for this Protocol, or NULL", NULL, G_PARAM_READABLE | G_PARAM_STATIC_STRINGS)); /** * TpProtocol:icon-name: * * The name of an icon in the system's icon theme. If none was supplied * by the Protocol, or the %TP_PROTOCOL_FEATURE_CORE feature has not been * prepared, a default is used; currently, this is "im-" plus * #TpProtocol:protocol-name. * * Since: 0.11.11 */ g_object_class_install_property (object_class, PROP_ICON_NAME, g_param_spec_string ("icon-name", "Icon name", "A non-NULL Icon name for this Protocol", NULL, G_PARAM_READABLE | G_PARAM_STATIC_STRINGS)); /** * TpProtocol:capabilities: * * The classes of channel that can be requested from connections to this * protocol, or %NULL if this is unknown or the %TP_PROTOCOL_FEATURE_CORE * feature has not been prepared. * * Since: 0.11.11 */ g_object_class_install_property (object_class, PROP_CAPABILITIES, g_param_spec_object ("capabilities", "Capabilities", "Requestable channel classes for this Protocol", TP_TYPE_CAPABILITIES, G_PARAM_READABLE | G_PARAM_STATIC_STRINGS)); /** * TpProtocol:param-names: * * A list of parameter names supported by this connection manager * for this protocol, or %NULL if %TP_PROTOCOL_FEATURE_PARAMETERS has not * been prepared. * * Since: 0.11.11 */ g_object_class_install_property (object_class, PROP_PARAM_NAMES, g_param_spec_boxed ("param-names", "Parameter names", "A list of parameter names", G_TYPE_STRV, G_PARAM_READABLE | G_PARAM_STATIC_STRINGS)); /** * TpProtocol:authentication-types: * * A non-%NULL #GStrv of interfaces which provide information as to * what kind of authentication channels can possibly appear before * the connection reaches the CONNECTED state, or %NULL if * %TP_PROTOCOL_FEATURE_CORE has not been prepared. * * Since: 0.13.9 */ g_object_class_install_property (object_class, PROP_AUTHENTICATION_TYPES, g_param_spec_boxed ("authentication-types", "AuthenticationTypes", "A list of authentication types", G_TYPE_STRV, G_PARAM_READABLE | G_PARAM_STATIC_STRINGS)); /** * TpProtocol:avatar-requirements: * * A #TpAvatarRequirements representing the avatar requirements on this * protocol, or %NULL if %TP_PROTOCOL_FEATURE_CORE has not been prepared or * if the protocol doesn't support avatars. * * Since: 0.15.6 */ g_object_class_install_property (object_class, PROP_AVATAR_REQUIREMENTS, g_param_spec_pointer ("avatar-requirements", "Avatars requirements", "Avatars requirements", G_PARAM_READABLE | G_PARAM_STATIC_STRINGS)); /** * TpProtocol:cm-name: * * The name of the connection manager this protocol is on. * * Since: 0.19.1 */ g_object_class_install_property (object_class, PROP_CM_NAME, g_param_spec_string ("cm-name", "Connection manager name", "Name of the CM this protocol is on", NULL, G_PARAM_CONSTRUCT_ONLY | G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS)); /** * TpProtocol:addressable-vcard-fields: * * A non-%NULL #GStrv of vCard fields supported by this protocol. * If this protocol does not support addressing contacts by a vCard field, * the list is empty. * * For instance, a SIP connection manager that supports calling contacts * by SIP URI (vCard field SIP) or telephone number (vCard field TEL) * might have { "sip", "tel", NULL }. * * Since: 0.23.1 */ g_object_class_install_property (object_class, PROP_ADDRESSABLE_VCARD_FIELDS, g_param_spec_boxed ("addressable-vcard-fields", "AddressableVCardFields", "A list of vCard fields", G_TYPE_STRV, G_PARAM_READABLE | G_PARAM_STATIC_STRINGS)); /** * TpProtocol:addressable-uri-schemes: * * A non-%NULL #GStrv of URI schemes supported by this protocol. * If this protocol does not support addressing contacts by URI, * the list is empty. * * For instance, a SIP connection manager that supports calling contacts * by SIP URI (sip:alice@example.com, sips:bob@example.com) * or telephone number (tel:+1-555-0123) might have * { "sip", "sips", "tel", NULL }. * * Since: 0.23.1 */ g_object_class_install_property (object_class, PROP_ADDRESSABLE_URI_SCHEMES, g_param_spec_boxed ("addressable-uri-schemes", "AddressableURISchemes", "A list of URI schemes", G_TYPE_STRV, G_PARAM_READABLE | G_PARAM_STATIC_STRINGS)); proxy_class->list_features = tp_protocol_list_features; proxy_class->must_have_unique_name = FALSE; proxy_class->interface = TP_IFACE_QUARK_PROTOCOL; tp_protocol_init_known_interfaces (); } static void tp_protocol_init (TpProtocol *self) { self->priv = G_TYPE_INSTANCE_GET_PRIVATE (self, TP_TYPE_PROTOCOL, TpProtocolPrivate); } /** * tp_protocol_new: * @dbus: proxy for the D-Bus daemon; may not be %NULL * @cm_name: the connection manager name (such as "gabble") * @protocol_name: the protocol name (such as "jabber") * @immutable_properties: the immutable D-Bus properties for this protocol * @error: used to indicate the error if %NULL is returned * * * * Returns: a new protocol proxy, or %NULL on invalid arguments * * Since: 0.11.11 */ TpProtocol * tp_protocol_new (TpDBusDaemon *dbus, const gchar *cm_name, const gchar *protocol_name, const GHashTable *immutable_properties, GError **error) { TpProtocol *ret = NULL; gchar *bus_name = NULL; gchar *object_path = NULL; g_return_val_if_fail (TP_IS_DBUS_DAEMON (dbus), NULL); if (!tp_connection_manager_check_valid_protocol_name (protocol_name, error)) goto finally; if (!tp_connection_manager_check_valid_name (cm_name, error)) goto finally; bus_name = g_strdup_printf ("%s%s", TP_CM_BUS_NAME_BASE, cm_name); object_path = g_strdup_printf ("%s%s/%s", TP_CM_OBJECT_PATH_BASE, cm_name, protocol_name); /* e.g. local-xmpp -> local_xmpp */ g_strdelimit (object_path, "-", '_'); ret = TP_PROTOCOL (g_object_new (TP_TYPE_PROTOCOL, "dbus-daemon", dbus, "bus-name", bus_name, "object-path", object_path, "protocol-name", protocol_name, "protocol-properties", immutable_properties, "cm-name", cm_name, NULL)); finally: g_free (bus_name); g_free (object_path); return ret; } /** * tp_protocol_new_vardict: * @dbus: proxy for the D-Bus daemon; may not be %NULL * @cm_name: the connection manager name (such as "gabble") * @protocol_name: the protocol name (such as "jabber") * @immutable_properties: the immutable D-Bus properties for this protocol * @error: used to indicate the error if %NULL is returned * * Create a new protocol proxy. * * If @immutable_properties is a floating reference, this function will * take ownership of it, much like g_variant_ref_sink(). See documentation of * that function for details. * * Returns: a new protocol proxy, or %NULL on invalid arguments * * Since: 0.23.3 */ TpProtocol * tp_protocol_new_vardict (TpDBusDaemon *dbus, const gchar *cm_name, const gchar *protocol_name, GVariant *immutable_properties, GError **error) { GHashTable *hash; TpProtocol *ret; g_return_val_if_fail (g_variant_is_of_type (immutable_properties, G_VARIANT_TYPE_VARDICT), NULL); g_variant_ref_sink (immutable_properties); hash = _tp_asv_from_vardict (immutable_properties); ret = tp_protocol_new (dbus, cm_name, protocol_name, hash, error); g_hash_table_unref (hash); g_variant_unref (immutable_properties); return ret; } /** * tp_protocol_init_known_interfaces: * * Ensure that the known interfaces for TpProtocol have been set up. * This is done automatically when necessary, but for correct * overriding of library interfaces by local extensions, you should * call this function before calling * tp_proxy_or_subclass_hook_on_interface_add() with first argument * %TP_TYPE_PROTOCOL. * * Since: 0.11.11 */ void tp_protocol_init_known_interfaces (void) { static gsize once = 0; if (g_once_init_enter (&once)) { GType type = TP_TYPE_PROTOCOL; tp_proxy_init_known_interfaces (); tp_proxy_or_subclass_hook_on_interface_add (type, tp_cli_protocol_add_signals); tp_proxy_subclass_add_error_mapping (type, TP_ERROR_PREFIX, TP_ERROR, TP_TYPE_ERROR); g_once_init_leave (&once, 1); } } TpConnectionManagerProtocol * _tp_protocol_get_struct (TpProtocol *self) { return &self->priv->protocol_struct; } /** * tp_protocol_get_name: * @self: a protocol object * * Return the same thing as the protocol-name property, for convenient use * in C code. The returned string is valid for as long as @self exists. * * Returns: the value of the #TpProtocol:protocol-name property * * Since: 0.11.11 */ const gchar * tp_protocol_get_name (TpProtocol *self) { g_return_val_if_fail (TP_IS_PROTOCOL (self), NULL); return self->priv->protocol_struct.name; } /** * tp_protocol_has_param: * @self: a protocol * @param: a parameter name * * * * Returns: %TRUE if @self supports the parameter @param. * * Since: 0.11.11 */ gboolean tp_protocol_has_param (TpProtocol *self, const gchar *param) { return (tp_protocol_get_param (self, param) != NULL); } /** * tp_protocol_get_param: * @self: a protocol * @param: a parameter name * * * * Returns: a structure representing the parameter @param, or %NULL if not * supported * * Since: 0.11.11 */ const TpConnectionManagerParam * tp_protocol_get_param (TpProtocol *self, const gchar *param) { g_return_val_if_fail (TP_IS_PROTOCOL (self), FALSE); G_GNUC_BEGIN_IGNORE_DEPRECATIONS return tp_connection_manager_protocol_get_param ( &self->priv->protocol_struct, param); G_GNUC_END_IGNORE_DEPRECATIONS } /** * tp_protocol_dup_param: * @self: a protocol * @param: a parameter name * * * * Returns: (transfer full): a structure representing the parameter @param, * or %NULL if not supported. Free with tp_connection_manager_param_free() * * Since: 0.17.6 */ TpConnectionManagerParam * tp_protocol_dup_param (TpProtocol *self, const gchar *param) { g_return_val_if_fail (TP_IS_PROTOCOL (self), NULL); return tp_connection_manager_param_copy (tp_protocol_get_param (self, param)); } /** * tp_protocol_can_register: * @self: a protocol * * Return whether a new account can be registered on this protocol, by setting * the special "register" parameter to %TRUE. * * Returns: %TRUE if @protocol supports the parameter "register" * * Since: 0.11.11 */ gboolean tp_protocol_can_register (TpProtocol *self) { return tp_protocol_has_param (self, "register"); } /** * tp_protocol_dup_param_names: * @self: a protocol * * Returns a list of parameter names supported by this connection manager * for this protocol. * * The result is copied and must be freed by the caller with g_strfreev(). * * Returns: (array zero-terminated=1) (transfer full): a copy of * #TpProtocol:param-names * * Since: 0.11.11 */ GStrv tp_protocol_dup_param_names (TpProtocol *self) { g_return_val_if_fail (TP_IS_PROTOCOL (self), NULL); G_GNUC_BEGIN_IGNORE_DEPRECATIONS return tp_connection_manager_protocol_dup_param_names ( &self->priv->protocol_struct); G_GNUC_END_IGNORE_DEPRECATIONS } /** * tp_protocol_borrow_params: (skip) * @self: a protocol * * Returns an array of parameters supported by this connection manager, * without additional memory allocations. The returned array is owned by * @self, and must not be used after @self has been freed. * * Returns: (transfer none): an array of #TpConnectionManagerParam structures, * terminated by one whose @name is %NULL * * Since: 0.17.6 * Deprecated: Since 0.19.9. New code should use tp_protocol_dup_params() * instead. */ const TpConnectionManagerParam * tp_protocol_borrow_params (TpProtocol *self) { g_return_val_if_fail (TP_IS_PROTOCOL (self), NULL); return self->priv->protocol_struct.params; } /** * tp_protocol_dup_params: * @self: a protocol * * Returns a list of parameters supported by this connection manager. * * The returned list must be freed by the caller, for instance with * g_list_free_full (l, * (GDestroyNotify) tp_connection_manager_param_free). * * Returns: (transfer full) (element-type TelepathyGLib.ConnectionManagerParam): * a list of #TpConnectionManagerParam structures, owned by the caller * * Since: 0.17.6 */ GList * tp_protocol_dup_params (TpProtocol *self) { guint i; GList *ret = NULL; g_return_val_if_fail (TP_IS_PROTOCOL (self), NULL); for (i = 0; self->priv->protocol_struct.params[i].name != NULL; i++) { ret = g_list_prepend (ret, tp_connection_manager_param_copy ( &(self->priv->protocol_struct.params[i]))); } return g_list_reverse (ret); } /** * tp_protocol_get_vcard_field: * @self: a protocol object * * * * Returns: the value of #TpProtocol:vcard-field * * Since: 0.11.11 */ const gchar * tp_protocol_get_vcard_field (TpProtocol *self) { g_return_val_if_fail (TP_IS_PROTOCOL (self), NULL); return self->priv->vcard_field; } /** * tp_protocol_get_english_name: * @self: a protocol object * * * * Returns: the non-%NULL, non-empty value of #TpProtocol:english-name * * Since: 0.11.11 */ const gchar * tp_protocol_get_english_name (TpProtocol *self) { g_return_val_if_fail (TP_IS_PROTOCOL (self), ""); return self->priv->english_name; } /** * tp_protocol_get_icon_name: * @self: a protocol object * * * * Returns: the non-%NULL, non-empty value of #TpProtocol:icon-name * * Since: 0.11.11 */ const gchar * tp_protocol_get_icon_name (TpProtocol *self) { g_return_val_if_fail (TP_IS_PROTOCOL (self), "dialog-error"); return self->priv->icon_name; } /** * tp_protocol_get_authentication_types: * @self: a protocol object * * * * Returns: (transfer none): the value of #TpProtocol:authentication-types * * Since: 0.13.9 */ const gchar * const * tp_protocol_get_authentication_types (TpProtocol *self) { g_return_val_if_fail (TP_IS_PROTOCOL (self), NULL); return (const gchar * const *) self->priv->authentication_types; } /** * tp_protocol_get_capabilities: * @self: a protocol object * * * * Returns: (transfer none): #TpProtocol:capabilities, which must be referenced * (if non-%NULL) if it will be kept * * Since: 0.11.11 */ TpCapabilities * tp_protocol_get_capabilities (TpProtocol *self) { g_return_val_if_fail (TP_IS_PROTOCOL (self), NULL); return self->priv->capabilities; } static gboolean init_gvalue_from_dbus_sig (const gchar *sig, GValue *value) { g_assert (!G_IS_VALUE (value)); switch (sig[0]) { case 'b': g_value_init (value, G_TYPE_BOOLEAN); return TRUE; case 's': g_value_init (value, G_TYPE_STRING); return TRUE; case 'q': case 'u': g_value_init (value, G_TYPE_UINT); return TRUE; case 'y': g_value_init (value, G_TYPE_UCHAR); return TRUE; case 'n': case 'i': g_value_init (value, G_TYPE_INT); return TRUE; case 'x': g_value_init (value, G_TYPE_INT64); return TRUE; case 't': g_value_init (value, G_TYPE_UINT64); return TRUE; case 'o': g_value_init (value, DBUS_TYPE_G_OBJECT_PATH); g_value_set_static_boxed (value, "/"); return TRUE; case 'd': g_value_init (value, G_TYPE_DOUBLE); return TRUE; case 'v': g_value_init (value, G_TYPE_VALUE); return TRUE; case 'a': switch (sig[1]) { case 's': g_value_init (value, G_TYPE_STRV); return TRUE; case 'o': g_value_init (value, TP_ARRAY_TYPE_OBJECT_PATH_LIST); return TRUE; case 'y': g_value_init (value, DBUS_TYPE_G_UCHAR_ARRAY); return TRUE; } } return FALSE; } static gboolean parse_default_value (GValue *value, const gchar *sig, gchar *raw_value, GKeyFile *file, const gchar *group, const gchar *key) { GError *error = NULL; gchar *s, *p; switch (sig[0]) { case 'b': g_value_set_boolean (value, g_key_file_get_boolean (file, group, key, &error)); if (error == NULL) return TRUE; /* In telepathy-glib < 0.7.26 we accepted true and false in * any case combination, 0, and 1. The desktop file spec specifies * "true" and "false" only, while GKeyFile currently accepts 0 and 1 too. * So, on error, let's fall back to more lenient parsing that explicitly * allows everything we historically allowed. */ g_error_free (error); if (raw_value == NULL) return FALSE; for (p = raw_value; *p != '\0'; p++) { *p = g_ascii_tolower (*p); } if (!tp_strdiff (raw_value, "1") || !tp_strdiff (raw_value, "true")) { g_value_set_boolean (value, TRUE); } else if (!tp_strdiff (raw_value, "0") || !tp_strdiff (raw_value, "false")) { g_value_set_boolean (value, TRUE); } else { return FALSE; } return TRUE; case 's': s = g_key_file_get_string (file, group, key, NULL); g_value_take_string (value, s); return (s != NULL); case 'y': case 'q': case 'u': case 't': { guint64 v = g_key_file_get_uint64 (file, group, key, &error); if (error != NULL) { g_error_free (error); return FALSE; } if (sig[0] == 't') { g_value_set_uint64 (value, v); return TRUE; } if (sig[0] == 'y') { if (v > G_MAXUINT8) { return FALSE; } g_value_set_uchar (value, v); return TRUE; } if (v > G_MAXUINT32 || (sig[0] == 'q' && v > G_MAXUINT16)) return FALSE; g_value_set_uint (value, v); return TRUE; } case 'n': case 'i': case 'x': if (raw_value[0] == '\0') { return FALSE; } else { gint64 v = g_key_file_get_int64 (file, group, key, &error); if (error != NULL) { g_error_free (error); return FALSE; } if (sig[0] == 'x') { g_value_set_int64 (value, v); return TRUE; } if (v > G_MAXINT32 || (sig[0] == 'q' && v > G_MAXINT16)) return FALSE; if (v < G_MININT32 || (sig[0] == 'n' && v < G_MININT16)) return FALSE; g_value_set_int (value, v); return TRUE; } case 'o': s = g_key_file_get_string (file, group, key, NULL); if (s == NULL || !tp_dbus_check_valid_object_path (s, NULL)) { g_free (s); return FALSE; } g_value_take_boxed (value, s); return TRUE; case 'd': g_value_set_double (value, g_key_file_get_double (file, group, key, &error)); if (error != NULL) { g_error_free (error); return FALSE; } return TRUE; case 'a': switch (sig[1]) { case 's': { g_value_take_boxed (value, g_key_file_get_string_list (file, group, key, NULL, &error)); if (error != NULL) { g_error_free (error); return FALSE; } return TRUE; } case 'o': { gsize len = 0; GStrv strv = g_key_file_get_string_list (file, group, key, &len, &error); gchar **iter; GPtrArray *arr; if (error != NULL) { g_error_free (error); return FALSE; } for (iter = strv; iter != NULL && *iter != NULL; iter++) { if (!g_variant_is_object_path (*iter)) { g_strfreev (strv); return FALSE; } } arr = g_ptr_array_sized_new (len); for (iter = strv; iter != NULL && *iter != NULL; iter++) { /* transfer ownership */ g_ptr_array_add (arr, *iter); } g_free (strv); g_value_take_boxed (value, arr); return TRUE; } } } if (G_IS_VALUE (value)) g_value_unset (value); return FALSE; } #define PROTOCOL_PREFIX "Protocol " #define PROTOCOL_PREFIX_LEN 9 tp_verify (sizeof (PROTOCOL_PREFIX) == PROTOCOL_PREFIX_LEN + 1); static gchar * replace_null_with_empty (gchar *in) { return (in == NULL ? g_strdup ("") : in); } static GHashTable * _tp_protocol_parse_channel_class (GKeyFile *file, const gchar *group) { GHashTable *ret; gchar **keys, **key; ret = g_hash_table_new_full (g_str_hash, g_str_equal, g_free, (GDestroyNotify) tp_g_value_slice_free); keys = g_key_file_get_keys (file, group, NULL, NULL); for (key = keys; key != NULL && *key != NULL; key++) { gchar *space = strchr (*key, ' '); gchar *value = NULL; gchar *property = NULL; const gchar *dbus_type; GValue *v = g_slice_new0 (GValue); value = g_key_file_get_value (file, group, *key, NULL); /* keys without a space are reserved */ if (space == NULL) { DEBUG ("\t'%s' isn't a fixed property", *key); goto cleanup; } property = g_strndup (*key, space - *key); dbus_type = space + 1; if (!init_gvalue_from_dbus_sig (dbus_type, v)) { DEBUG ("\tunable to parse D-Bus type '%s' for '%s' in a " ".manager file", dbus_type, property); goto cleanup; } if (!parse_default_value (v, dbus_type, value, file, group, *key)) { DEBUG ("\tunable to parse '%s' as a value of type '%s' for '%s'", value, dbus_type, property); goto cleanup; } DEBUG ("\tfixed: '%s' of type '%s' = '%s'", property, dbus_type, value); /* transfer ownership to @ret */ g_hash_table_insert (ret, property, v); property = NULL; v = NULL; cleanup: if (v != NULL) { if (G_IS_VALUE (v)) tp_g_value_slice_free (v); else g_slice_free (GValue, v); } g_free (property); g_free (value); } g_strfreev (keys); return ret; } static GValueArray * _tp_protocol_parse_rcc (const gchar *cm_debug_name, const gchar *protocol_debug_name, GKeyFile *file, const gchar *group) { GHashTable *fixed; GStrv allowed; GValueArray *ret; guint i; DEBUG ("%s/%s: parsing requestable channel class '%s'", cm_debug_name, protocol_debug_name, group); fixed = _tp_protocol_parse_channel_class (file, group); allowed = g_key_file_get_string_list (file, group, "allowed", NULL, NULL); for (i = 0; allowed != NULL && allowed[i] != NULL; i++) { DEBUG ("\tallowed: '%s'", allowed[i]); } ret = tp_value_array_build (2, TP_HASH_TYPE_CHANNEL_CLASS, fixed, G_TYPE_STRV, allowed, NULL); g_hash_table_unref (fixed); g_strfreev (allowed); return ret; } GHashTable * _tp_protocol_parse_manager_file (GKeyFile *file, const gchar *cm_debug_name, const gchar *group, gchar **protocol_name) { GHashTable *immutables; GHashTable *status_specs; GPtrArray *param_specs, *rccs; const gchar *name; gchar **rcc_groups, **rcc_group; gchar **keys, **key; guint i; if (!g_str_has_prefix (group, PROTOCOL_PREFIX)) return NULL; name = group + PROTOCOL_PREFIX_LEN; if (!tp_connection_manager_check_valid_protocol_name (name, NULL)) { DEBUG ("%s: protocol '%s' has an invalid name", cm_debug_name, name); return NULL; } DEBUG ("%s: reading protocol '%s' from manager file", cm_debug_name, name); keys = g_key_file_get_keys (file, group, NULL, NULL); i = 0; for (key = keys; key != NULL && *key != NULL; key++) { if (g_str_has_prefix (*key, "param-")) i++; } param_specs = g_ptr_array_new_full (i, tp_value_array_free); for (key = keys; key != NULL && *key != NULL; key++) { if (g_str_has_prefix (*key, "param-")) { gchar **strv, **iter; gchar *value, *def; TpConnectionManagerParam param = { NULL }; value = g_key_file_get_string (file, group, *key, NULL); if (value == NULL) continue; /* strlen ("param-") == 6 */ param.name = *key + 6; strv = g_strsplit (value, " ", 0); g_free (value); param.dbus_signature = strv[0]; param.flags = 0; for (iter = strv + 1; *iter != NULL; iter++) { if (!tp_strdiff (*iter, "required")) param.flags |= TP_CONN_MGR_PARAM_FLAG_REQUIRED; if (!tp_strdiff (*iter, "register")) param.flags |= TP_CONN_MGR_PARAM_FLAG_REGISTER; if (!tp_strdiff (*iter, "secret")) param.flags |= TP_CONN_MGR_PARAM_FLAG_SECRET; if (!tp_strdiff (*iter, "dbus-property")) param.flags |= TP_CONN_MGR_PARAM_FLAG_DBUS_PROPERTY; } if ((!tp_strdiff (param.name, "password") || g_str_has_suffix (param.name, "-password")) && (param.flags & TP_CONN_MGR_PARAM_FLAG_SECRET) == 0) { DEBUG ("\tTreating %s as secret due to its name (please " "fix %s.manager)", param.name, cm_debug_name); param.flags |= TP_CONN_MGR_PARAM_FLAG_SECRET; } def = g_strdup_printf ("default-%s", param.name); value = g_key_file_get_value (file, group, def, NULL); init_gvalue_from_dbus_sig (param.dbus_signature, ¶m.default_value); if (value != NULL && parse_default_value (¶m.default_value, param.dbus_signature, value, file, group, def)) param.flags |= TP_CONN_MGR_PARAM_FLAG_HAS_DEFAULT; DEBUG ("\tParam name: %s", param.name); DEBUG ("\tParam flags: 0x%x", param.flags); DEBUG ("\tParam sig: %s", param.dbus_signature); #ifdef ENABLE_DEBUG if (G_IS_VALUE (¶m.default_value)) { gchar *repr = g_strdup_value_contents (&(param.default_value)); DEBUG ("\tParam default value: %s of type %s", repr, G_VALUE_TYPE_NAME (&(param.default_value))); g_free (repr); } else { DEBUG ("\tParam default value: not set"); } #endif g_ptr_array_add (param_specs, tp_value_array_build (4, G_TYPE_STRING, param.name, G_TYPE_UINT, param.flags, G_TYPE_STRING, param.dbus_signature, G_TYPE_VALUE, ¶m.default_value, G_TYPE_INVALID)); if (G_IS_VALUE (¶m.default_value)) g_value_unset (¶m.default_value); g_free (value); g_free (def); g_strfreev (strv); } } immutables = tp_asv_new ( TP_PROP_PROTOCOL_PARAMETERS, TP_ARRAY_TYPE_PARAM_SPEC_LIST, param_specs, NULL); g_ptr_array_unref(param_specs); tp_asv_take_boxed (immutables, TP_PROP_PROTOCOL_INTERFACES, G_TYPE_STRV, g_key_file_get_string_list (file, group, "Interfaces", NULL, NULL)); tp_asv_take_boxed (immutables, TP_PROP_PROTOCOL_CONNECTION_INTERFACES, G_TYPE_STRV, g_key_file_get_string_list (file, group, "ConnectionInterfaces", NULL, NULL)); tp_asv_take_string (immutables, TP_PROP_PROTOCOL_VCARD_FIELD, replace_null_with_empty ( g_key_file_get_string (file, group, "VCardField", NULL))); tp_asv_take_string (immutables, TP_PROP_PROTOCOL_ENGLISH_NAME, replace_null_with_empty ( g_key_file_get_string (file, group, "EnglishName", NULL))); tp_asv_take_string (immutables, TP_PROP_PROTOCOL_ICON, replace_null_with_empty ( g_key_file_get_string (file, group, "Icon", NULL))); tp_asv_take_boxed (immutables, TP_PROP_PROTOCOL_AUTHENTICATION_TYPES, G_TYPE_STRV, g_key_file_get_string_list (file, group, "AuthenticationTypes", NULL, NULL)); /* Avatars */ tp_asv_take_boxed (immutables, TP_PROP_PROTOCOL_INTERFACE_AVATARS_SUPPORTED_AVATAR_MIME_TYPES, G_TYPE_STRV, g_key_file_get_string_list (file, group, "SupportedAvatarMIMETypes", NULL, NULL)); tp_asv_set_uint32 (immutables, TP_PROP_PROTOCOL_INTERFACE_AVATARS_MINIMUM_AVATAR_HEIGHT, g_key_file_get_uint64 (file, group, "MinimumAvatarHeight", NULL)); tp_asv_set_uint32 (immutables, TP_PROP_PROTOCOL_INTERFACE_AVATARS_MINIMUM_AVATAR_WIDTH, g_key_file_get_uint64 (file, group, "MinimumAvatarWidth", NULL)); tp_asv_set_uint32 (immutables, TP_PROP_PROTOCOL_INTERFACE_AVATARS_RECOMMENDED_AVATAR_HEIGHT, g_key_file_get_uint64 (file, group, "RecommendedAvatarHeight", NULL)); tp_asv_set_uint32 (immutables, TP_PROP_PROTOCOL_INTERFACE_AVATARS_RECOMMENDED_AVATAR_WIDTH, g_key_file_get_uint64 (file, group, "RecommendedAvatarWidth", NULL)); tp_asv_set_uint32 (immutables, TP_PROP_PROTOCOL_INTERFACE_AVATARS_MAXIMUM_AVATAR_HEIGHT, g_key_file_get_uint64 (file, group, "MaximumAvatarHeight", NULL)); tp_asv_set_uint32 (immutables, TP_PROP_PROTOCOL_INTERFACE_AVATARS_MAXIMUM_AVATAR_WIDTH, g_key_file_get_uint64 (file, group, "MaximumAvatarWidth", NULL)); tp_asv_set_uint32 (immutables, TP_PROP_PROTOCOL_INTERFACE_AVATARS_MAXIMUM_AVATAR_BYTES, g_key_file_get_uint64 (file, group, "MaximumAvatarBytes", NULL)); rccs = g_ptr_array_new (); rcc_groups = g_key_file_get_string_list (file, group, "RequestableChannelClasses", NULL, NULL); if (rcc_groups != NULL) { for (rcc_group = rcc_groups; *rcc_group != NULL; rcc_group++) g_ptr_array_add (rccs, _tp_protocol_parse_rcc (cm_debug_name, name, file, *rcc_group)); } g_strfreev (rcc_groups); /* Statuses */ status_specs = g_hash_table_new_full (g_str_hash, g_str_equal, g_free, (GDestroyNotify) tp_value_array_free); for (key = keys; key != NULL && *key != NULL; key++) { if (g_str_has_prefix (*key, "status-")) { GValueArray *ubb; gint64 type; gboolean on_self = FALSE, has_message = FALSE; gchar *value, *endptr; gchar **strv, **iter; if (!tp_strdiff (*key, "status-")) { DEBUG ("'status-' is not a valid status"); continue; } value = g_key_file_get_value (file, group, *key, NULL); strv = g_strsplit (value, " ", 0); g_free (value); type = g_ascii_strtoll (strv[0], &endptr, 10); if (endptr <= strv[0] || *endptr != '\0') { DEBUG ("invalid (non-numeric?) status type %s", strv[0]); goto next_status; } if (type == TP_CONNECTION_PRESENCE_TYPE_UNSET || type < 0 || type >= TP_NUM_CONNECTION_PRESENCE_TYPES) { DEBUG ("presence type out of range: %" G_GINT64_FORMAT, type); goto next_status; } for (iter = strv + 1; *iter != NULL; iter++) { if (!tp_strdiff (*iter, "settable")) on_self = TRUE; else if (!tp_strdiff (*iter, "message")) has_message = TRUE; else DEBUG ("unknown status modifier '%s'", *iter); } ubb = tp_value_array_build (3, G_TYPE_UINT, (guint) type, G_TYPE_BOOLEAN, on_self, G_TYPE_BOOLEAN, has_message, G_TYPE_INVALID); /* strlen ("status-") == 7 */ g_hash_table_insert (status_specs, g_strdup (*key + 7), ubb); DEBUG ("Status '%s': type %u%s%s", *key + 7, (guint) type, on_self ? ", can set on self" : "", has_message ? ", has message" : ""); next_status: g_strfreev (strv); } } if (g_hash_table_size (status_specs) > 0) tp_asv_take_boxed (immutables, TP_PROP_PROTOCOL_INTERFACE_PRESENCE_STATUSES, TP_HASH_TYPE_SIMPLE_STATUS_SPEC_MAP, status_specs); else g_hash_table_unref (status_specs); g_strfreev (keys); tp_asv_take_boxed (immutables, TP_PROP_PROTOCOL_REQUESTABLE_CHANNEL_CLASSES, TP_ARRAY_TYPE_REQUESTABLE_CHANNEL_CLASS_LIST, rccs); if (protocol_name != NULL) *protocol_name = g_strdup (name); return immutables; } /** * tp_protocol_get_avatar_requirements: * @self: a #TpProtocol * * Return the #TpProtocol:avatar-requirements property * * Returns: (transfer none): the value of #TpProtocol:avatar-requirements * * Since: 0.15.6 */ TpAvatarRequirements * tp_protocol_get_avatar_requirements (TpProtocol *self) { g_return_val_if_fail (TP_IS_PROTOCOL (self), NULL); return self->priv->avatar_req; } /** * tp_protocol_get_cm_name: * @self: a #TpProtocol * * Return the #TpProtocol:cm-name property. * * Returns: the value of #TpProtocol:cm-name * * Since: 0.19.1 */ const gchar * tp_protocol_get_cm_name (TpProtocol *self) { g_return_val_if_fail (TP_IS_PROTOCOL (self), NULL); return self->priv->cm_name; } /* * Handle the result from a tp_cli_protocol_* function that * returns one string. user_data is a #GTask. */ static void tp_protocol_async_string_cb (TpProxy *proxy, const gchar *normalized, const GError *error, gpointer user_data, GObject *weak_object G_GNUC_UNUSED) { if (error == NULL) g_task_return_pointer (user_data, g_strdup (normalized), g_free); else g_task_return_error (user_data, g_error_copy (error)); } /** * tp_protocol_normalize_contact_async: * @self: a protocol * @contact: a contact identifier, possibly invalid * @cancellable: (allow-none): may be used to cancel the async request * @callback: (scope async): a callback to call when * the request is satisfied * @user_data: (closure) (allow-none): data to pass to @callback * * Perform best-effort offline contact normalization. This does syntactic * normalization (e.g. transforming case-insensitive text to lower-case), * but does not query servers or anything similar. * * Since: 0.23.1 */ void tp_protocol_normalize_contact_async (TpProtocol *self, const gchar *contact, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GTask *task; g_return_if_fail (TP_IS_PROTOCOL (self)); g_return_if_fail (contact != NULL); /* this makes no sense to call for its side-effects */ g_return_if_fail (callback != NULL); task = g_task_new (self, cancellable, callback, user_data); g_task_set_source_tag (task, tp_protocol_normalize_contact_async); tp_cli_protocol_call_normalize_contact (self, -1, contact, tp_protocol_async_string_cb, task, g_object_unref, NULL); } /** * tp_protocol_normalize_contact_finish: * @self: a protocol * @result: a #GAsyncResult * @error: a #GError to fill * * Interpret the result of tp_protocol_normalize_contact_async(). * * Returns: (transfer full): the normalized form of @contact, * or %NULL on error * Since: 0.23.1 */ gchar * tp_protocol_normalize_contact_finish (TpProtocol *self, GAsyncResult *result, GError **error) { g_return_val_if_fail (g_task_is_valid (result, self), NULL); g_return_val_if_fail (g_async_result_is_tagged (result, tp_protocol_normalize_contact_async), NULL); return g_task_propagate_pointer (G_TASK (result), error); } /** * tp_protocol_identify_account_async: * @self: a protocol * @vardict: the account parameters as a #GVariant of * type %G_VARIANT_TYPE_VARDICT. If it is floating, ownership will * be taken, as if via g_variant_ref_sink(). * @cancellable: (allow-none): may be used to cancel the async request * @callback: (scope async): a callback to call when * the request is satisfied * @user_data: (closure) (allow-none): data to pass to @callback * * Return a string that could identify the account with the given * parameters. In most protocols that string is a normalized 'account' * parameter, but some protocols have more complex requirements; * for instance, on IRC, the 'account' (nickname) is insufficient, * and must be combined with a server or network name. * * Since: 0.23.1 */ void tp_protocol_identify_account_async (TpProtocol *self, GVariant *vardict, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GTask *task; GHashTable *asv; g_return_if_fail (TP_IS_PROTOCOL (self)); g_return_if_fail (vardict != NULL); g_return_if_fail (g_variant_is_of_type (vardict, G_VARIANT_TYPE_VARDICT)); /* this makes no sense to call for its side-effects */ g_return_if_fail (callback != NULL); task = g_task_new (self, cancellable, callback, user_data); g_task_set_source_tag (task, tp_protocol_identify_account_async); g_variant_ref_sink (vardict); asv = _tp_asv_from_vardict (vardict); tp_cli_protocol_call_identify_account (self, -1, asv, tp_protocol_async_string_cb, task, g_object_unref, NULL); g_hash_table_unref (asv); g_variant_unref (vardict); } /** * tp_protocol_identify_account_finish: * @self: a protocol * @result: a #GAsyncResult * @error: a #GError to fill * * Interpret the result of tp_protocol_identify_account_async(). * * Returns: (transfer full): a string identifying the account, * or %NULL on error * Since: 0.23.1 */ gchar * tp_protocol_identify_account_finish (TpProtocol *self, GAsyncResult *result, GError **error) { g_return_val_if_fail (g_task_is_valid (result, self), NULL); g_return_val_if_fail (g_async_result_is_tagged (result, tp_protocol_identify_account_async), NULL); return g_task_propagate_pointer (G_TASK (result), error); } /** * tp_protocol_normalize_contact_uri_async: * @self: a protocol * @uri: a contact URI, possibly invalid * @cancellable: (allow-none): may be used to cancel the async request * @callback: (scope async): a callback to call when the request is satisfied * @user_data: (closure) (allow-none): data to pass to @callback * * Perform best-effort offline contact normalization, for a contact in * the form of a URI. This method will fail if the URI is not in a * scheme supported by this protocol or connection manager. * * Since: 0.23.1 */ void tp_protocol_normalize_contact_uri_async (TpProtocol *self, const gchar *uri, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GTask *task; g_return_if_fail (TP_IS_PROTOCOL (self)); g_return_if_fail (uri != NULL); /* this makes no sense to call for its side-effects */ g_return_if_fail (callback != NULL); task = g_task_new (self, cancellable, callback, user_data); g_task_set_source_tag (task, tp_protocol_normalize_contact_uri_async); tp_cli_protocol_interface_addressing_call_normalize_contact_uri (self, -1, uri, tp_protocol_async_string_cb, task, g_object_unref, NULL); } /** * tp_protocol_normalize_contact_uri_finish: * @self: a protocol * @result: a #GAsyncResult * @error: a #GError to fill * * Interpret the result of tp_protocol_normalize_contact_uri_async(). * * Returns: (transfer full): the normalized form of @uri, * or %NULL on error * Since: 0.23.1 */ gchar * tp_protocol_normalize_contact_uri_finish (TpProtocol *self, GAsyncResult *result, GError **error) { g_return_val_if_fail (g_task_is_valid (result, self), NULL); g_return_val_if_fail (g_async_result_is_tagged (result, tp_protocol_normalize_contact_uri_async), NULL); return g_task_propagate_pointer (G_TASK (result), error); } /** * tp_protocol_normalize_vcard_address_async: * @self: a protocol * @field: a vCard field * @value: an address that is a value of @field * @cancellable: (allow-none): may be used to cancel the async request * @callback: (scope async): a callback to call when the request is satisfied * @user_data: (closure) (allow-none): data to pass to @callback * * Perform best-effort offline contact normalization, for a contact in * the form of a vCard field. This method will fail if the vCard field * is not supported by this protocol or connection manager. * * Since: 0.23.1 */ void tp_protocol_normalize_vcard_address_async (TpProtocol *self, const gchar *field, const gchar *value, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GTask *task; g_return_if_fail (TP_IS_PROTOCOL (self)); g_return_if_fail (!tp_str_empty (field)); g_return_if_fail (value != NULL); /* this makes no sense to call for its side-effects */ g_return_if_fail (callback != NULL); task = g_task_new (self, cancellable, callback, user_data); g_task_set_source_tag (task, tp_protocol_normalize_vcard_address_async); tp_cli_protocol_interface_addressing_call_normalize_vcard_address (self, -1, field, value, tp_protocol_async_string_cb, task, g_object_unref, NULL); } /** * tp_protocol_normalize_vcard_address_finish: * @self: a protocol * @result: a #GAsyncResult * @error: a #GError to fill * * Interpret the result of tp_protocol_normalize_vcard_address_async(). * * Returns: (transfer full): the normalized form of @value, * or %NULL on error * Since: 0.23.1 */ gchar * tp_protocol_normalize_vcard_address_finish (TpProtocol *self, GAsyncResult *result, GError **error) { g_return_val_if_fail (g_task_is_valid (result, self), NULL); g_return_val_if_fail (g_async_result_is_tagged (result, tp_protocol_normalize_vcard_address_async), NULL); return g_task_propagate_pointer (G_TASK (result), error); } /** * tp_protocol_get_addressable_vcard_fields: * @self: a protocol object * * * * Returns: (transfer none): the value of #TpProtocol:addressable-vcard-fields * Since: 0.23.1 */ const gchar * const * tp_protocol_get_addressable_vcard_fields (TpProtocol *self) { g_return_val_if_fail (TP_IS_PROTOCOL (self), NULL); return (const gchar * const *) self->priv->addressable_vcard_fields; } /** * tp_protocol_get_addressable_uri_schemes: * @self: a protocol object * * * * Returns: (transfer none): the value of #TpProtocol:addressable-uri-schemes * Since: 0.23.1 */ const gchar * const * tp_protocol_get_addressable_uri_schemes (TpProtocol *self) { g_return_val_if_fail (TP_IS_PROTOCOL (self), NULL); return (const gchar * const *) self->priv->addressable_uri_schemes; } /** * tp_protocol_dup_presence_statuses: * @self: a protocol object * * Return the presence statuses that might be supported by connections * to this protocol. * * It is possible that some of these statuses will not actually be supported * by a connection: for instance, an XMPP connection manager would * include "hidden" in this list, even though not all XMPP servers allow * users to be online-but-hidden. * * Returns: (transfer full) (element-type TelepathyGLib.PresenceStatusSpec): a * list of statuses, or %NULL if unknown */ GList * tp_protocol_dup_presence_statuses (TpProtocol *self) { GHashTableIter iter; gpointer k, v; GList *l = NULL; g_return_val_if_fail (TP_IS_PROTOCOL (self), NULL); if (self->priv->presence_statuses == NULL) return NULL; g_hash_table_iter_init (&iter, self->priv->presence_statuses); while (g_hash_table_iter_next (&iter, &k, &v)) { guint type; gboolean on_self, message; tp_value_array_unpack (v, 3, &type, &on_self, &message); l = g_list_prepend (l, tp_presence_status_spec_new (k, type, on_self, message)); } return g_list_reverse (l); } /** * tp_protocol_dup_immutable_properties: * @self: a #TpProtocol object * * Return the #TpProtocol:protocol-properties-vardict property. * * Returns: (transfer full): the value of * #TpProtocol:protocol-properties-vardict * Since: 0.23.3 */ GVariant * tp_protocol_dup_immutable_properties (TpProtocol *self) { return _tp_asv_to_vardict (self->priv->protocol_properties); }