pidgin/pidgin

facebook: Store sent message id in lastmid, to deduplicate echoed messages

This is crappy and error prone, just like the rest of the duplicate
message handling code. It works, but it's going to get some echoes now
and then, particularly in quick moving groupchats.

I'm pretty sure this is a bug in the server, but the official clients
have much more elaborate deduplication built-in, so they won't notice.
/*
* purple
*
* Purple is the legal property of its developers, whose names are too numerous
* to list here. Please refer to the COPYRIGHT file distributed with this
* source distribution.
*
* This program 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 2 of the License, or
* (at your option) any later version.
*
* This program 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
* along with this program; if not, write to the Free Software
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02111-1301 USA
*/
#include "internal.h"
#include "glibcompat.h"
#include "hmaccipher.h"
#include <string.h>
/*******************************************************************************
* Structs
******************************************************************************/
#define PURPLE_HMAC_CIPHER_GET_PRIVATE(obj) \
(G_TYPE_INSTANCE_GET_PRIVATE((obj), PURPLE_TYPE_HMAC_CIPHER, PurpleHMACCipherPrivate))
typedef struct {
PurpleHash *hash;
guchar *ipad;
guchar *opad;
} PurpleHMACCipherPrivate;
/******************************************************************************
* Enums
*****************************************************************************/
enum {
PROP_NONE,
PROP_HASH,
PROP_LAST,
};
/*******************************************************************************
* Globals
******************************************************************************/
static GObjectClass *parent_class = NULL;
static GParamSpec *properties[PROP_LAST];
/*******************************************************************************
* Helpers
******************************************************************************/
static void
purple_hmac_cipher_set_hash(PurpleCipher *cipher,
PurpleHash *hash)
{
PurpleHMACCipherPrivate *priv = PURPLE_HMAC_CIPHER_GET_PRIVATE(cipher);
priv->hash = g_object_ref(G_OBJECT(hash));
g_object_notify_by_pspec(G_OBJECT(cipher), properties[PROP_HASH]);
}
/*******************************************************************************
* Cipher Stuff
******************************************************************************/
static void
purple_hmac_cipher_reset(PurpleCipher *cipher) {
PurpleHMACCipherPrivate *priv = PURPLE_HMAC_CIPHER_GET_PRIVATE(cipher);
if(PURPLE_IS_HASH(priv->hash))
purple_hash_reset(priv->hash);
g_free(priv->ipad);
priv->ipad = NULL;
g_free(priv->opad);
priv->opad = NULL;
}
static void
purple_hmac_cipher_reset_state(PurpleCipher *cipher) {
PurpleHMACCipherPrivate *priv = PURPLE_HMAC_CIPHER_GET_PRIVATE(cipher);
if(PURPLE_IS_HASH(priv->hash)) {
purple_hash_reset_state(priv->hash);
purple_hash_append(priv->hash, priv->ipad,
purple_hash_get_block_size(priv->hash));
}
}
static void
purple_hmac_cipher_append(PurpleCipher *cipher, const guchar *d, size_t l) {
PurpleHMACCipherPrivate *priv = PURPLE_HMAC_CIPHER_GET_PRIVATE(cipher);
g_return_if_fail(PURPLE_IS_HASH(priv->hash));
purple_hash_append(priv->hash, d, l);
}
static gboolean
purple_hmac_cipher_digest(PurpleCipher *cipher, guchar *out, size_t len)
{
PurpleHMACCipherPrivate *priv = PURPLE_HMAC_CIPHER_GET_PRIVATE(cipher);
guchar *digest = NULL;
size_t hash_len, block_size;
gboolean result = FALSE;
g_return_val_if_fail(PURPLE_IS_HASH(priv->hash), FALSE);
hash_len = purple_hash_get_digest_size(priv->hash);
g_return_val_if_fail(hash_len > 0, FALSE);
block_size = purple_hash_get_block_size(priv->hash);
digest = g_malloc(hash_len);
/* get the digest of the data */
result = purple_hash_digest(priv->hash, digest, hash_len);
purple_hash_reset(priv->hash);
if(!result) {
g_free(digest);
return FALSE;
}
/* now append the opad and the digest from above */
purple_hash_append(priv->hash, priv->opad, block_size);
purple_hash_append(priv->hash, digest, hash_len);
/* do our last digest */
result = purple_hash_digest(priv->hash, out, len);
/* cleanup */
g_free(digest);
return result;
}
static size_t
purple_hmac_cipher_get_digest_size(PurpleCipher *cipher)
{
PurpleHMACCipherPrivate *priv = PURPLE_HMAC_CIPHER_GET_PRIVATE(cipher);
g_return_val_if_fail(priv->hash != NULL, 0);
return purple_hash_get_digest_size(priv->hash);
}
static void
purple_hmac_cipher_set_key(PurpleCipher *cipher, const guchar *key,
size_t key_len)
{
PurpleHMACCipherPrivate *priv = PURPLE_HMAC_CIPHER_GET_PRIVATE(cipher);
gsize block_size, i;
guchar *full_key;
g_return_if_fail(priv->hash);
g_free(priv->ipad);
g_free(priv->opad);
block_size = purple_hash_get_block_size(priv->hash);
priv->ipad = g_malloc(block_size);
priv->opad = g_malloc(block_size);
if (key_len > block_size) {
purple_hash_reset(priv->hash);
purple_hash_append(priv->hash, key, key_len);
key_len = purple_hash_get_digest_size(priv->hash);
full_key = g_malloc(key_len);
purple_hash_digest(priv->hash, full_key, key_len);
} else {
full_key = g_memdup(key, key_len);
}
if (key_len < block_size) {
full_key = g_realloc(full_key, block_size);
memset(full_key + key_len, 0, block_size - key_len);
}
for(i = 0; i < block_size; i++) {
priv->ipad[i] = 0x36 ^ full_key[i];
priv->opad[i] = 0x5c ^ full_key[i];
}
g_free(full_key);
purple_hash_reset(priv->hash);
purple_hash_append(priv->hash, priv->ipad, block_size);
}
static size_t
purple_hmac_cipher_get_block_size(PurpleCipher *cipher)
{
PurpleHMACCipherPrivate *priv = NULL;
g_return_val_if_fail(PURPLE_IS_HMAC_CIPHER(cipher), 0);
priv = PURPLE_HMAC_CIPHER_GET_PRIVATE(cipher);
return purple_hash_get_block_size(priv->hash);
}
/******************************************************************************
* Object Stuff
*****************************************************************************/
static void
purple_hmac_cipher_set_property(GObject *obj, guint param_id,
const GValue *value,
GParamSpec *pspec)
{
PurpleCipher *cipher = PURPLE_CIPHER(obj);
switch(param_id) {
case PROP_HASH:
purple_hmac_cipher_set_hash(cipher, g_value_get_object(value));
break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID(obj, param_id, pspec);
break;
}
}
static void
purple_hmac_cipher_get_property(GObject *obj, guint param_id, GValue *value,
GParamSpec *pspec)
{
PurpleHMACCipher *cipher = PURPLE_HMAC_CIPHER(obj);
switch(param_id) {
case PROP_HASH:
g_value_set_object(value,
purple_hmac_cipher_get_hash(cipher));
break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID(obj, param_id, pspec);
break;
}
}
static void
purple_hmac_cipher_finalize(GObject *obj) {
PurpleCipher *cipher = PURPLE_CIPHER(obj);
PurpleHMACCipherPrivate *priv = PURPLE_HMAC_CIPHER_GET_PRIVATE(cipher);
purple_hmac_cipher_reset(cipher);
if (priv->hash != NULL)
g_object_unref(priv->hash);
parent_class->finalize(obj);
}
static void
purple_hmac_cipher_class_init(PurpleHMACCipherClass *klass) {
GObjectClass *obj_class = G_OBJECT_CLASS(klass);
PurpleCipherClass *cipher_class = PURPLE_CIPHER_CLASS(klass);
parent_class = g_type_class_peek_parent(klass);
g_type_class_add_private(klass, sizeof(PurpleHMACCipherPrivate));
obj_class->finalize = purple_hmac_cipher_finalize;
obj_class->get_property = purple_hmac_cipher_get_property;
obj_class->set_property = purple_hmac_cipher_set_property;
cipher_class->reset = purple_hmac_cipher_reset;
cipher_class->reset_state = purple_hmac_cipher_reset_state;
cipher_class->append = purple_hmac_cipher_append;
cipher_class->digest = purple_hmac_cipher_digest;
cipher_class->get_digest_size = purple_hmac_cipher_get_digest_size;
cipher_class->set_key = purple_hmac_cipher_set_key;
cipher_class->get_block_size = purple_hmac_cipher_get_block_size;
properties[PROP_HASH] = g_param_spec_object("hash", "hash", "hash",
PURPLE_TYPE_HASH,
G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY |
G_PARAM_STATIC_STRINGS);
g_object_class_install_properties(obj_class, PROP_LAST, properties);
}
/******************************************************************************
* PurpleHMACCipher API
*****************************************************************************/
GType
purple_hmac_cipher_get_type(void) {
static GType type = 0;
if(type == 0) {
static const GTypeInfo info = {
sizeof(PurpleHMACCipherClass),
NULL,
NULL,
(GClassInitFunc)purple_hmac_cipher_class_init,
NULL,
NULL,
sizeof(PurpleHMACCipher),
0,
(GInstanceInitFunc)purple_cipher_reset,
NULL,
};
type = g_type_register_static(PURPLE_TYPE_CIPHER,
"PurpleHMACCipher",
&info, 0);
}
return type;
}
PurpleCipher *
purple_hmac_cipher_new(PurpleHash *hash) {
g_return_val_if_fail(PURPLE_IS_HASH(hash), NULL);
return g_object_new(PURPLE_TYPE_HMAC_CIPHER,
"hash", hash,
NULL);
}
PurpleHash *
purple_hmac_cipher_get_hash(const PurpleHMACCipher *cipher) {
PurpleHMACCipherPrivate *priv = NULL;
g_return_val_if_fail(PURPLE_IS_HMAC_CIPHER(cipher), NULL);
priv = PURPLE_HMAC_CIPHER_GET_PRIVATE(cipher);
if(priv && priv->hash)
return priv->hash;
return NULL;
}