1
0
mirror of https://github.com/profanity-im/profanity.git synced 2024-12-04 14:46:46 -05:00
profanity/src/xmpp/roster.c

343 lines
10 KiB
C
Raw Normal View History

/*
* roster.c
2019-11-13 06:11:05 -05:00
* vim: expandtab:ts=4:sts=4:sw=4
*
2019-01-22 05:31:45 -05:00
* Copyright (C) 2012 - 2019 James Booth <boothj5@gmail.com>
*
* This file is part of Profanity.
*
* Profanity is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* Profanity 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 General Public License for more details.
*
* You should have received a copy of the GNU General Public License
2016-07-23 20:14:49 -04:00
* along with Profanity. If not, see <https://www.gnu.org/licenses/>.
*
* In addition, as a special exception, the copyright holders give permission to
* link the code of portions of this program with the OpenSSL library under
* certain conditions as described in each individual source file, and
* distribute linked combinations including the two.
*
* You must obey the GNU General Public License in all respects for all of the
* code used other than OpenSSL. If you modify file(s) with this exception, you
* may extend this exception to your version of the file(s), but you are not
* obligated to do so. If you do not wish to do so, delete this exception
* statement from your version. If you delete this exception statement from all
* source files in the program, then also delete it here.
*
*/
2016-03-31 16:05:02 -04:00
#include "config.h"
#include <assert.h>
#include <stdlib.h>
#include <string.h>
#include <glib.h>
2016-03-31 16:05:02 -04:00
#ifdef HAVE_LIBMESODE
#include <mesode.h>
#endif
2016-07-24 10:43:51 -04:00
2016-03-31 16:05:02 -04:00
#ifdef HAVE_LIBSTROPHE
#include <strophe.h>
#endif
2016-07-24 10:43:51 -04:00
#include "profanity.h"
#include "log.h"
2016-07-24 10:43:51 -04:00
#include "config/preferences.h"
#include "plugins/plugins.h"
2015-04-19 11:54:16 -04:00
#include "event/server_events.h"
2015-05-07 18:21:48 -04:00
#include "event/client_events.h"
#include "tools/autocomplete.h"
2016-07-24 10:43:51 -04:00
#include "ui/ui.h"
2016-05-05 17:10:10 -04:00
#include "xmpp/session.h"
2016-05-03 20:19:51 -04:00
#include "xmpp/iq.h"
2016-05-05 19:53:03 -04:00
#include "xmpp/connection.h"
#include "xmpp/roster.h"
2016-07-24 10:43:51 -04:00
#include "xmpp/roster_list.h"
#include "xmpp/stanza.h"
#include "xmpp/xmpp.h"
// callback data for group commands
typedef struct _group_data {
char *name;
char *group;
} GroupData;
// id handlers
static int _group_add_id_handler(xmpp_stanza_t *const stanza, void *const userdata);
static int _group_remove_id_handler(xmpp_stanza_t *const stanza, void *const userdata);
static void _free_group_data(GroupData *data);
2016-03-26 11:50:16 -04:00
void
roster_request(void)
{
xmpp_ctx_t * const ctx = connection_get_ctx();
xmpp_stanza_t *iq = stanza_create_roster_iq(ctx);
2016-05-03 20:19:51 -04:00
iq_send_stanza(iq);
xmpp_stanza_release(iq);
}
2014-12-22 17:13:42 -05:00
void
2015-10-25 20:14:23 -04:00
roster_send_add_new(const char *const barejid, const char *const name)
2013-06-01 18:48:24 -04:00
{
xmpp_ctx_t * const ctx = connection_get_ctx();
char *id = connection_create_stanza_id();
xmpp_stanza_t *iq = stanza_create_roster_set(ctx, id, barejid, name, NULL);
free(id);
2016-05-03 20:19:51 -04:00
iq_send_stanza(iq);
2013-06-01 18:48:24 -04:00
xmpp_stanza_release(iq);
}
2014-12-22 17:13:42 -05:00
void
2015-10-25 20:14:23 -04:00
roster_send_remove(const char *const barejid)
2013-06-01 19:06:05 -04:00
{
xmpp_ctx_t * const ctx = connection_get_ctx();
xmpp_stanza_t *iq = stanza_create_roster_remove_set(ctx, barejid);
2016-05-03 20:19:51 -04:00
iq_send_stanza(iq);
2013-06-01 19:06:05 -04:00
xmpp_stanza_release(iq);
}
2014-12-22 17:13:42 -05:00
void
2015-10-25 20:14:23 -04:00
roster_send_name_change(const char *const barejid, const char *const new_name, GSList *groups)
{
xmpp_ctx_t * const ctx = connection_get_ctx();
char *id = connection_create_stanza_id();
xmpp_stanza_t *iq = stanza_create_roster_set(ctx, id, barejid, new_name, groups);
free(id);
2016-05-03 20:19:51 -04:00
iq_send_stanza(iq);
xmpp_stanza_release(iq);
}
2014-12-22 17:13:42 -05:00
void
2015-10-25 20:14:23 -04:00
roster_send_add_to_group(const char *const group, PContact contact)
{
GSList *groups = p_contact_groups(contact);
GSList *new_groups = NULL;
2015-05-04 18:22:06 -04:00
while (groups) {
new_groups = g_slist_append(new_groups, strdup(groups->data));
groups = g_slist_next(groups);
2013-05-19 18:35:02 -04:00
}
new_groups = g_slist_append(new_groups, strdup(group));
// add an id handler to handle the response
char *unique_id = connection_create_stanza_id();
GroupData *data = malloc(sizeof(GroupData));
data->group = strdup(group);
2015-05-04 18:22:06 -04:00
if (p_contact_name(contact)) {
data->name = strdup(p_contact_name(contact));
} else {
data->name = strdup(p_contact_barejid(contact));
}
xmpp_ctx_t * const ctx = connection_get_ctx();
iq_id_handler_add(unique_id, _group_add_id_handler, (ProfIqFreeCallback)_free_group_data, data);
xmpp_stanza_t *iq = stanza_create_roster_set(ctx, unique_id, p_contact_barejid(contact),
p_contact_name(contact), new_groups);
2016-05-03 20:19:51 -04:00
iq_send_stanza(iq);
xmpp_stanza_release(iq);
free(unique_id);
}
static int
_group_add_id_handler(xmpp_stanza_t *const stanza, void *const userdata)
{
2015-05-04 18:22:06 -04:00
if (userdata) {
GroupData *data = userdata;
ui_group_added(data->name, data->group);
}
return 0;
}
2014-12-22 17:13:42 -05:00
void
2015-10-25 20:14:23 -04:00
roster_send_remove_from_group(const char *const group, PContact contact)
{
GSList *groups = p_contact_groups(contact);
GSList *new_groups = NULL;
2015-05-04 18:22:06 -04:00
while (groups) {
if (strcmp(groups->data, group) != 0) {
new_groups = g_slist_append(new_groups, strdup(groups->data));
}
groups = g_slist_next(groups);
}
xmpp_ctx_t * const ctx = connection_get_ctx();
// add an id handler to handle the response
char *unique_id = connection_create_stanza_id();
GroupData *data = malloc(sizeof(GroupData));
data->group = strdup(group);
2015-05-04 18:22:06 -04:00
if (p_contact_name(contact)) {
data->name = strdup(p_contact_name(contact));
} else {
data->name = strdup(p_contact_barejid(contact));
}
iq_id_handler_add(unique_id, _group_remove_id_handler, (ProfIqFreeCallback)_free_group_data, data);
xmpp_stanza_t *iq = stanza_create_roster_set(ctx, unique_id, p_contact_barejid(contact),
p_contact_name(contact), new_groups);
2016-05-03 20:19:51 -04:00
iq_send_stanza(iq);
xmpp_stanza_release(iq);
free(unique_id);
}
static int
_group_remove_id_handler(xmpp_stanza_t *const stanza, void *const userdata)
{
2015-05-04 18:22:06 -04:00
if (userdata) {
GroupData *data = userdata;
ui_group_removed(data->name, data->group);
}
return 0;
}
void
roster_set_handler(xmpp_stanza_t *const stanza)
2013-05-22 16:15:05 -04:00
{
xmpp_stanza_t *query =
xmpp_stanza_get_child_by_name(stanza, STANZA_NAME_QUERY);
xmpp_stanza_t *item =
xmpp_stanza_get_child_by_name(query, STANZA_NAME_ITEM);
if (item == NULL) {
return;
2013-05-22 16:15:05 -04:00
}
// if from attribute exists and it is not current users barejid, ignore push
2016-05-05 20:12:54 -04:00
Jid *my_jid = jid_create(connection_get_fulljid());
const char *from = xmpp_stanza_get_from(stanza);
2015-05-04 18:22:06 -04:00
if (from && (strcmp(from, my_jid->barejid) != 0)) {
log_warning("Received alleged roster push from: %s", from);
2013-05-22 16:15:05 -04:00
jid_destroy(my_jid);
return;
2013-05-22 16:15:05 -04:00
}
jid_destroy(my_jid);
const char *barejid = xmpp_stanza_get_attribute(item, STANZA_ATTR_JID);
gchar *barejid_lower = g_utf8_strdown(barejid, -1);
2013-05-22 16:15:05 -04:00
const char *name = xmpp_stanza_get_attribute(item, STANZA_ATTR_NAME);
const char *sub = xmpp_stanza_get_attribute(item, STANZA_ATTR_SUBSCRIPTION);
const char *ask = xmpp_stanza_get_attribute(item, STANZA_ATTR_ASK);
// do not set nickname to empty string, set to NULL instead
if (name && (strlen(name) == 0)) {
name = NULL;
}
2013-05-22 16:15:05 -04:00
// remove from roster
if (g_strcmp0(sub, "remove") == 0) {
// remove barejid and name
2013-06-01 19:06:05 -04:00
if (name == NULL) {
name = barejid_lower;
2013-06-01 19:06:05 -04:00
}
roster_remove(name, barejid_lower);
ui_roster_remove(barejid_lower);
2013-05-22 16:15:05 -04:00
// otherwise update local roster
} else {
// check for pending out subscriptions
gboolean pending_out = FALSE;
2015-05-04 18:22:06 -04:00
if (ask && (strcmp(ask, "subscribe") == 0)) {
2013-05-22 16:15:05 -04:00
pending_out = TRUE;
}
GSList *groups = roster_get_groups_from_item(item);
2013-05-22 16:15:05 -04:00
// update the local roster
PContact contact = roster_get_contact(barejid_lower);
2014-01-05 18:54:29 -05:00
if (contact == NULL) {
gboolean added = roster_add(barejid_lower, name, groups, sub, pending_out);
2014-01-05 18:54:29 -05:00
if (added) {
ui_roster_add(barejid_lower, name);
2014-01-05 18:54:29 -05:00
}
} else {
2015-04-28 18:38:56 -04:00
sv_ev_roster_update(barejid_lower, name, groups, sub, pending_out);
2014-01-05 18:54:29 -05:00
}
2013-05-22 16:15:05 -04:00
}
2015-02-23 18:44:34 -05:00
g_free(barejid_lower);
return;
2013-05-22 16:15:05 -04:00
}
void
roster_result_handler(xmpp_stanza_t *const stanza)
2013-05-22 16:15:05 -04:00
{
const char *id = xmpp_stanza_get_id(stanza);
2013-05-22 16:15:05 -04:00
2015-05-07 17:51:35 -04:00
if (g_strcmp0(id, "roster") != 0) {
return;
2015-05-07 17:51:35 -04:00
}
2013-05-22 16:15:05 -04:00
// handle initial roster response
2015-05-07 17:51:35 -04:00
xmpp_stanza_t *query = xmpp_stanza_get_child_by_name(stanza, STANZA_NAME_QUERY);
xmpp_stanza_t *item = xmpp_stanza_get_children(query);
2013-05-22 16:15:05 -04:00
2015-05-07 17:51:35 -04:00
while (item) {
const char *barejid = xmpp_stanza_get_attribute(item, STANZA_ATTR_JID);
gchar *barejid_lower = g_utf8_strdown(barejid, -1);
const char *name = xmpp_stanza_get_attribute(item, STANZA_ATTR_NAME);
const char *sub = xmpp_stanza_get_attribute(item, STANZA_ATTR_SUBSCRIPTION);
2013-05-22 16:15:05 -04:00
2015-05-07 17:51:35 -04:00
// do not set nickname to empty string, set to NULL instead
if (name && (strlen(name) == 0)) name = NULL;
2015-05-07 17:51:35 -04:00
gboolean pending_out = FALSE;
const char *ask = xmpp_stanza_get_attribute(item, STANZA_ATTR_ASK);
if (g_strcmp0(ask, "subscribe") == 0) {
pending_out = TRUE;
}
2013-05-22 16:15:05 -04:00
GSList *groups = roster_get_groups_from_item(item);
2013-05-22 16:15:05 -04:00
2015-05-07 17:51:35 -04:00
gboolean added = roster_add(barejid_lower, name, groups, sub, pending_out);
if (!added) {
log_warning("Attempt to add contact twice: %s", barejid_lower);
2013-05-22 16:15:05 -04:00
}
2015-05-07 17:51:35 -04:00
g_free(barejid_lower);
item = xmpp_stanza_get_next(item);
2013-05-22 16:15:05 -04:00
}
2015-05-07 17:51:35 -04:00
sv_ev_roster_received();
return;
2013-05-22 16:15:05 -04:00
}
2015-10-25 20:14:23 -04:00
GSList*
roster_get_groups_from_item(xmpp_stanza_t *item)
{
GSList *groups = NULL;
xmpp_stanza_t *group_element = xmpp_stanza_get_children(item);
2015-05-04 18:22:06 -04:00
while (group_element) {
if (strcmp(xmpp_stanza_get_name(group_element), STANZA_NAME_GROUP) == 0) {
char *groupname = xmpp_stanza_get_text(group_element);
2015-05-04 18:22:06 -04:00
if (groupname) {
groups = g_slist_append(groups, groupname);
}
}
group_element = xmpp_stanza_get_next(group_element);
}
return groups;
}
static void
_free_group_data(GroupData *data)
{
if (data) {
free(data->group);
free(data->name);
free(data);
}
}