path: root/libempathy/empathy-tp-roomlist.c

/* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*- */
/*
 * Copyright (C) 2007-2008 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
 *
 * Authors: Xavier Claessens <xclaesse@gmail.com>
 */

#include <config.h>

#include <string.h>

#include <telepathy-glib/channel.h>
#include <telepathy-glib/dbus.h>
#include <telepathy-glib/util.h>
#include <telepathy-glib/interfaces.h>

#include "empathy-tp-roomlist.h"
#include "empathy-chatroom.h"
#include "empathy-utils.h"

#define DEBUG_FLAG EMPATHY_DEBUG_TP
#include "empathy-debug.h"

#define GET_PRIV(obj) EMPATHY_GET_PRIV (obj, EmpathyTpRoomlist)
typedef struct {
    TpConnection *connection;
    TpChannel    *channel;
    TpAccount    *account;
    gboolean      is_listing;
    gboolean      start_requested;
} EmpathyTpRoomlistPriv;

enum {
    NEW_ROOM,
    DESTROY,
    ERROR,
    LAST_SIGNAL
};

enum {
    PROP_0,
    PROP_ACCOUNT,
    PROP_IS_LISTING,
};

static guint signals[LAST_SIGNAL];

G_DEFINE_TYPE (EmpathyTpRoomlist, empathy_tp_roomlist, G_TYPE_OBJECT);

static void
tp_roomlist_listing_cb (TpChannel *channel,
            gboolean   listing,
            gpointer   user_data,
            GObject   *list)
{
    EmpathyTpRoomlistPriv *priv = GET_PRIV (list);

    DEBUG ("Listing: %s", listing ? "Yes" : "No");
    priv->is_listing = listing;
    g_object_notify (list, "is-listing");
}

static void
tp_roomlist_chatrooms_free (gpointer data)
{
    GSList *chatrooms = data;

    g_slist_foreach (chatrooms, (GFunc) g_object_unref, NULL);
    g_slist_free (chatrooms);
}

static void
tp_roomlist_inspect_handles_cb (TpConnection *connection,
                const gchar **names,
                const GError *error,
                gpointer      user_data,
                GObject      *list)
{
    GSList *chatrooms = user_data;

    if (error != NULL) {
        DEBUG ("Error: %s", error->message);
        return;
    }

    while (*names != NULL) {
        EmpathyChatroom *chatroom = chatrooms->data;

        empathy_chatroom_set_room (chatroom, *names);
        g_signal_emit (list, signals[NEW_ROOM], 0, chatroom);

        names++;
        chatrooms = chatrooms->next;
    }
}

static void
tp_roomlist_got_rooms_cb (TpChannel       *channel,
              const GPtrArray *rooms,
              gpointer         user_data,
              GObject         *list)
{
    EmpathyTpRoomlistPriv *priv = GET_PRIV (list);
    EmpathyChatroom       *chatroom;
    guint                  i;
    GArray                *handles = NULL;
    GSList                *chatrooms = NULL;

    for (i = 0; i < rooms->len; i++) {
        const GValue *room_name_value;
        const GValue *handle_name_value;
        const GValue *room_members_value;
        const GValue *room_subject_value;
        const GValue *room_invite_value;
        const GValue *room_password_value;
        GValueArray  *room_struct;
        guint         handle;
        const gchar  *channel_type;
        GHashTable   *info;

        /* Get information */
        room_struct = g_ptr_array_index (rooms, i);
        handle = g_value_get_uint (g_value_array_get_nth (room_struct, 0));
        channel_type = g_value_get_string (g_value_array_get_nth (room_struct, 1));
        info = g_value_get_boxed (g_value_array_get_nth (room_struct, 2));
        room_name_value = g_hash_table_lookup (info, "name");
        handle_name_value = g_hash_table_lookup (info, "handle-name");
        room_subject_value = g_hash_table_lookup (info, "subject");
        room_members_value = g_hash_table_lookup (info, "members");
        room_invite_value = g_hash_table_lookup (info, "invite-only");
        room_password_value = g_hash_table_lookup (info, "password");

        if (tp_strdiff (channel_type, TP_IFACE_CHANNEL_TYPE_TEXT)) {
            continue;
        }

        chatroom = empathy_chatroom_new (priv->account);

        if (room_name_value != NULL) {
            empathy_chatroom_set_name (chatroom,
                           g_value_get_string (room_name_value));
        }

        if (room_members_value != NULL) {
            empathy_chatroom_set_members_count (chatroom,
                           g_value_get_uint (room_members_value));
        }

        if (room_subject_value != NULL) {
            empathy_chatroom_set_subject (chatroom,
                           g_value_get_string (room_subject_value));
        }

        if (room_invite_value != NULL) {
            empathy_chatroom_set_invite_only (chatroom,
                           g_value_get_boolean (room_invite_value));
        }

        if (room_password_value != NULL) {
            empathy_chatroom_set_need_password (chatroom,
                           g_value_get_boolean (room_password_value));
        }

        if (handle_name_value != NULL) {
            empathy_chatroom_set_room (chatroom,
                           g_value_get_string (handle_name_value));

            /* We have the room ID, we can directly emit it */
            g_signal_emit (list, signals[NEW_ROOM], 0, chatroom);
            g_object_unref (chatroom);
        } else {
            /* We don't have the room ID, we'll inspect all handles
             * at once and then emit rooms */
            if (handles == NULL) {
                handles = g_array_new (FALSE, FALSE, sizeof (guint));
            }

            g_array_append_val (handles, handle);
            chatrooms = g_slist_prepend (chatrooms, chatroom);
        }
    }

    if (handles != NULL) {
        chatrooms = g_slist_reverse (chatrooms);
        tp_cli_connection_call_inspect_handles (priv->connection, -1,
                               TP_HANDLE_TYPE_ROOM,
                               handles,
                               tp_roomlist_inspect_handles_cb,
                               chatrooms,
                               tp_roomlist_chatrooms_free,
                               list);
        g_array_unref (handles);
    }
}

static void
tp_roomlist_get_listing_rooms_cb (TpChannel    *channel,
                  gboolean      is_listing,
                  const GError *error,
                  gpointer      user_data,
                  GObject      *list)
{
    EmpathyTpRoomlistPriv *priv = GET_PRIV (list);

    if (error) {
        DEBUG ("Error geting listing rooms: %s", error->message);
        return;
    }

    priv->is_listing = is_listing;
    g_object_notify (list, "is-listing");
}

static void
tp_roomlist_invalidated_cb (TpChannel         *channel,
                guint              domain,
                gint               code,
                gchar             *message,
                EmpathyTpRoomlist *list)
{
    DEBUG ("Channel invalidated: %s", message);
    g_signal_emit (list, signals[DESTROY], 0);
}

static void
call_list_rooms_cb (TpChannel *proxy,
            const GError *error,
            gpointer list,
            GObject *weak_object)
{
    if (error != NULL) {
        DEBUG ("Error listing rooms: %s", error->message);
        g_signal_emit_by_name (list, "error::start", error);
    }
}

static void
stop_listing_cb (TpChannel *proxy,
         const GError *error,
         gpointer list,
         GObject *weak_object)
{
    if (error != NULL) {
        DEBUG ("Error on stop listing: %s", error->message);
        g_signal_emit_by_name (list, "error::stop", error);
    }
}

static void
tp_roomlist_create_channel_cb (GObject *source,
                GAsyncResult *result,
                gpointer      user_data)
{
    EmpathyTpRoomlist *self = user_data;
    EmpathyTpRoomlistPriv *priv = GET_PRIV (self);
    GError *error = NULL;

    priv->channel = tp_account_channel_request_create_and_handle_channel_finish (
        TP_ACCOUNT_CHANNEL_REQUEST (source), result, NULL, &error);

    if (priv->channel == NULL) {
        DEBUG ("Error creating channel: %s", error->message);
        g_error_free (error);
        goto out;
    }

    g_signal_connect (priv->channel, "invalidated",
              G_CALLBACK (tp_roomlist_invalidated_cb), self);

    tp_cli_channel_type_room_list_connect_to_listing_rooms (priv->channel,
                                tp_roomlist_listing_cb,
                                NULL, NULL,
                                G_OBJECT (self),
                                NULL);
    tp_cli_channel_type_room_list_connect_to_got_rooms (priv->channel,
                                tp_roomlist_got_rooms_cb,
                                NULL, NULL,
                                G_OBJECT (self),
                                NULL);

    tp_cli_channel_type_room_list_call_get_listing_rooms (priv->channel, -1,
                                  tp_roomlist_get_listing_rooms_cb,
                                  NULL, NULL,
                                  G_OBJECT (self));

    if (priv->start_requested == TRUE) {
        tp_cli_channel_type_room_list_call_list_rooms (priv->channel, -1,
            call_list_rooms_cb, self, NULL, G_OBJECT (self));
        priv->start_requested = FALSE;
    }

out:
    g_object_unref (self);
}

static void
tp_roomlist_finalize (GObject *object)
{
    EmpathyTpRoomlistPriv *priv = GET_PRIV (object);

    if (priv->channel) {
        DEBUG ("Closing channel...");
        g_signal_handlers_disconnect_by_func (priv->channel,
                              tp_roomlist_invalidated_cb,
                              object);
        tp_cli_channel_call_close (priv->channel, -1,
                       NULL, NULL, NULL, NULL);
        g_object_unref (priv->channel);
    }

    if (priv->account) {
        g_object_unref (priv->account);
    }
    if (priv->connection) {
        g_object_unref (priv->connection);
    }

    G_OBJECT_CLASS (empathy_tp_roomlist_parent_class)->finalize (object);
}

static void
tp_roomlist_constructed (GObject *list)
{
    EmpathyTpRoomlistPriv *priv = GET_PRIV (list);
    GHashTable *request;
    TpAccountChannelRequest *req;

    request = tp_asv_new (
        TP_PROP_CHANNEL_CHANNEL_TYPE, G_TYPE_STRING,
          TP_IFACE_CHANNEL_TYPE_ROOM_LIST,
        TP_PROP_CHANNEL_TARGET_HANDLE_TYPE, G_TYPE_UINT, TP_HANDLE_TYPE_NONE,
        NULL);

    priv->connection = tp_account_get_connection (priv->account);
    g_object_ref (priv->connection);

    req = tp_account_channel_request_new (priv->account, request,
        TP_USER_ACTION_TIME_CURRENT_TIME);

    /* Ensure we stay alive during the async call */
    g_object_ref (list);

    tp_account_channel_request_create_and_handle_channel_async (req, NULL,
        tp_roomlist_create_channel_cb, list);

    g_hash_table_unref (request);
    g_object_unref (req);
}

static void
tp_roomlist_get_property (GObject    *object,
              guint       param_id,
              GValue     *value,
              GParamSpec *pspec)
{
    EmpathyTpRoomlistPriv *priv = GET_PRIV (object);

    switch (param_id) {
    case PROP_ACCOUNT:
        g_value_set_object (value, priv->account);
        break;
    case PROP_IS_LISTING:
        g_value_set_boolean (value, priv->is_listing);
        break;
    default:
        G_OBJECT_WARN_INVALID_PROPERTY_ID (object, param_id, pspec);
        break;
    };
}

static void
tp_roomlist_set_property (GObject      *object,
              guint         param_id,
              const GValue *value,
              GParamSpec   *pspec)
{
    EmpathyTpRoomlistPriv *priv = GET_PRIV (object);

    switch (param_id) {
    case PROP_ACCOUNT:
        priv->account = g_value_dup_object (value);
        break;
    default:
        G_OBJECT_WARN_INVALID_PROPERTY_ID (object, param_id, pspec);
        break;
    };
}

static void
empathy_tp_roomlist_class_init (EmpathyTpRoomlistClass *klass)
{
    GObjectClass *object_class = G_OBJECT_CLASS (klass);

    object_class->finalize = tp_roomlist_finalize;
    object_class->constructed = tp_roomlist_constructed;
    object_class->get_property = tp_roomlist_get_property;
    object_class->set_property = tp_roomlist_set_property;

    g_object_class_install_property (object_class,
                     PROP_ACCOUNT,
                     g_param_spec_object ("account",
                                  "The Account",
                                  "The account on which it lists rooms",
                                  TP_TYPE_ACCOUNT,
                                  G_PARAM_READWRITE |
                                  G_PARAM_CONSTRUCT_ONLY));
    g_object_class_install_property (object_class,
                     PROP_IS_LISTING,
                     g_param_spec_boolean ("is-listing",
                                   "Is listing",
                                   "Are we listing rooms",
                                   FALSE,
                                   G_PARAM_READABLE));

    signals[NEW_ROOM] =
        g_signal_new ("new-room",
                  G_TYPE_FROM_CLASS (klass),
                  G_SIGNAL_RUN_LAST,
                  0,
                  NULL, NULL,
                  g_cclosure_marshal_generic,
                  G_TYPE_NONE,
                  1, EMPATHY_TYPE_CHATROOM);

    signals[DESTROY] =
        g_signal_new ("destroy",
                  G_TYPE_FROM_CLASS (klass),
                  G_SIGNAL_RUN_LAST,
                  0,
                  NULL, NULL,
                  g_cclosure_marshal_generic,
                  G_TYPE_NONE,
                  0);

    signals[ERROR] =
        g_signal_new ("error",
                  G_TYPE_FROM_CLASS (klass),
                  G_SIGNAL_RUN_LAST | G_SIGNAL_DETAILED,
                  0,
                  NULL, NULL,
                  g_cclosure_marshal_generic,
                  G_TYPE_NONE,
                  1, G_TYPE_POINTER);

    g_type_class_add_private (object_class, sizeof (EmpathyTpRoomlistPriv));
}

static void
empathy_tp_roomlist_init (EmpathyTpRoomlist *list)
{
    EmpathyTpRoomlistPriv *priv = G_TYPE_INSTANCE_GET_PRIVATE (list,
        EMPATHY_TYPE_TP_ROOMLIST, EmpathyTpRoomlistPriv);

    list->priv = priv;
    priv->start_requested = FALSE;
    priv->is_listing = FALSE;
}

EmpathyTpRoomlist *
empathy_tp_roomlist_new (TpAccount *account)
{
    EmpathyTpRoomlist *list;

    list = g_object_new (EMPATHY_TYPE_TP_ROOMLIST,
                 "account", account,
                 NULL);

    return list;
}

gboolean
empathy_tp_roomlist_is_listing (EmpathyTpRoomlist *list)
{
    EmpathyTpRoomlistPriv *priv = GET_PRIV (list);

    g_return_val_if_fail (EMPATHY_IS_TP_ROOMLIST (list), FALSE);

    return priv->is_listing;
}

void
empathy_tp_roomlist_start (EmpathyTpRoomlist *list)
{
    EmpathyTpRoomlistPriv *priv = GET_PRIV (list);

    g_return_if_fail (EMPATHY_IS_TP_ROOMLIST (list));
    if (priv->channel != NULL) {
        tp_cli_channel_type_room_list_call_list_rooms (priv->channel, -1,
            call_list_rooms_cb, list, NULL, NULL);
    } else {
        priv->start_requested = TRUE;
    }
}

void
empathy_tp_roomlist_stop (EmpathyTpRoomlist *list)
{
    EmpathyTpRoomlistPriv *priv = GET_PRIV (list);

    g_return_if_fail (EMPATHY_IS_TP_ROOMLIST (list));

    if (priv->channel == NULL)
        return;

    g_return_if_fail (TP_IS_CHANNEL (priv->channel));

    tp_cli_channel_type_room_list_call_stop_listing (priv->channel, -1,
                             stop_listing_cb, list, NULL, NULL);
}