Remove the SIMPLE protocol plugin
Remove the SIMPLE plugin as we will be replacing it with a full SIP plugin in the near future.
Testing Done:
Built, ran unit tests, made sure the pot file still built.
Reviewed at https://reviews.imfreedom.org/r/177/
--- a/libpurple/protocols/meson.build Mon Oct 26 20:18:35 2020 -0500
+++ b/libpurple/protocols/meson.build Thu Oct 29 21:44:26 2020 -0500
@@ -7,5 +7,4 @@
--- a/libpurple/protocols/simple/http.c Mon Oct 26 20:18:35 2020 -0500
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,99 +0,0 @@
- * 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- * 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-simple_http_digest_calculate_session_key(const gchar *username,- g_return_val_if_fail(username != NULL, NULL);- g_return_val_if_fail(realm != NULL, NULL);- g_return_val_if_fail(password != NULL, NULL);- g_return_val_if_fail(nonce != NULL, NULL);- hasher = g_checksum_new(G_CHECKSUM_MD5);- g_return_val_if_fail(hasher != NULL, NULL);- g_checksum_update(hasher, (guchar *)username, -1);- g_checksum_update(hasher, (guchar *)":", -1);- g_checksum_update(hasher, (guchar *)realm, -1);- g_checksum_update(hasher, (guchar *)":", -1);- g_checksum_update(hasher, (guchar *)password, -1);- hash = g_strdup(g_checksum_get_string(hasher));- g_checksum_free(hasher);-simple_http_digest_calculate_response(const gchar *method,- const gchar *digest_uri,- const gchar *nonce_count,- const gchar *session_key)- g_return_val_if_fail(method != NULL, NULL);- g_return_val_if_fail(digest_uri != NULL, NULL);- g_return_val_if_fail(nonce != NULL, NULL);- g_return_val_if_fail(session_key != NULL, NULL);- hash = g_checksum_new(G_CHECKSUM_MD5);- g_return_val_if_fail(hash != NULL, NULL);- g_checksum_update(hash, (guchar *)method, -1);- g_checksum_update(hash, (guchar *)":", -1);- g_checksum_update(hash, (guchar *)digest_uri, -1);- hash2 = g_strdup(g_checksum_get_string(hash));- g_checksum_reset(hash);- g_return_val_if_reached(NULL);- g_checksum_update(hash, (guchar *)session_key, -1);- g_checksum_update(hash, (guchar *)":", -1);- g_checksum_update(hash, (guchar *)nonce, -1);- g_checksum_update(hash, (guchar *)":", -1);- g_checksum_update(hash, (guchar *)hash2, -1);- hash2 = g_strdup(g_checksum_get_string(hash));--- a/libpurple/protocols/simple/http.h Mon Oct 26 20:18:35 2020 -0500
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,71 +0,0 @@
- * 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- * 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- * simple_http_digest_calculate_session_key:- * @username: The username provided by the user- * @realm: The authentication realm provided by the server- * @password: The password provided by the user- * @nonce: The nonce provided by the server- * @client_nonce: The nonce provided by the client- * Calculates a session key for HTTP Digest authentation- * See RFC 2617 for more information.- * Returns: The session key, or %NULL if an error occurred.-gchar *simple_http_digest_calculate_session_key(const gchar *username,- * simple_http_digest_calculate_response:- * @method: The HTTP method in use- * @digest_uri: The URI from the initial request- * @nonce: The nonce provided by the server- * @nonce_count: The nonce count- * @session_key: The session key from simple_http_digest_calculate_session_key()- * Calculate a response for HTTP Digest authentication- * See RFC 2617 for more information.- * Returns: The hashed response, or %NULL if an error occurred.-gchar *simple_http_digest_calculate_response(const gchar *method,- const gchar *digest_uri,- const gchar *nonce_count,- const gchar *session_key);-#endif /* SIMPLE_HTTP_H */--- a/libpurple/protocols/simple/meson.build Mon Oct 26 20:18:35 2020 -0500
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,16 +0,0 @@
- simple_prpl = shared_library('simple', SIMPLESOURCES,- dependencies : [libpurple_dep, nettle, glib, gio, ws2_32],- install : true, install_dir : PURPLE_PLUGINDIR)--- a/libpurple/protocols/simple/ntlm.c Mon Oct 26 20:18:35 2020 -0500
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,333 +0,0 @@
- * Copyright (C) 2005 Thomas Butter <butter@uni-mannheim.de>- * hashing done according to description of NTLM on- * http://www.innovation.ch/java/ntlm.html- * 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 <nettle/yarrow.h>-#define NTLM_NEGOTIATE_NTLM2_KEY 0x00080000- guint8 protocol[8]; /* 'N', 'T', 'L', 'M', 'S', 'S', 'P', '\0'*/- guint32 type; /* 0x00000002 */- guint16 msg_len1; /* target name length */- guint16 msg_len2; /* target name length */- guint32 flags; /* 0x00008201 */- guint8 nonce[8]; /* nonce */- guint8 protocol[8]; /* 'N', 'T', 'L', 'M', 'S', 'S', 'P', '\0'*/- guint32 type; /* 0x00000003 */- guint16 lm_resp_len1; /* LanManager response length (always 0x18)*/- guint16 lm_resp_len2; /* LanManager response length (always 0x18)*/- guint32 lm_resp_off; /* LanManager response offset */- guint16 nt_resp_len1; /* NT response length (always 0x18) */- guint16 nt_resp_len2; /* NT response length (always 0x18) */- guint32 nt_resp_off; /* NT response offset */- guint16 dom_len1; /* domain string length */- guint16 dom_len2; /* domain string length */- guint32 dom_off; /* domain string offset (always 0x00000040) */- guint16 user_len1; /* username string length */- guint16 user_len2; /* username string length */- guint32 user_off; /* username string offset */- guint16 host_len1; /* host string length */- guint16 host_len2; /* host string length */- guint32 host_off; /* host string offset */- guint32 sess_off; /* message length */- guint32 flags; /* 0x00008201 */- /* guint32 flags2; */ /* unknown, used in windows messenger */-purple_ntlm_parse_type2(const gchar *type2, guint32 *flags)- struct type2_message tmsg;- static guint8 nonce[8];- buff = g_base64_decode(type2, &retlen);- if (buff != NULL && retlen >= (sizeof(struct type2_message) - 1)) {- memcpy(&tmsg, buff, MIN(retlen, sizeof(tmsg)));- memcpy(nonce, tmsg.nonce, 8);- *flags = GUINT16_FROM_LE(tmsg.flags);- purple_debug_error("ntlm", "Unable to parse type2 message - returning empty nonce.\n");- * Create a 64bit DES key by taking a 56bit key and adding- * a parity bit after every 7th bit.-setup_des_key(const guint8 key_56[], guint8 *key)- key[1] = ((key_56[0] << 7) & 0xFF) | (key_56[1] >> 1);- key[2] = ((key_56[1] << 6) & 0xFF) | (key_56[2] >> 2);- key[3] = ((key_56[2] << 5) & 0xFF) | (key_56[3] >> 3);- key[4] = ((key_56[3] << 4) & 0xFF) | (key_56[4] >> 4);- key[5] = ((key_56[4] << 3) & 0xFF) | (key_56[5] >> 5);- key[6] = ((key_56[5] << 2) & 0xFF) | (key_56[6] >> 6);- key[7] = (key_56[6] << 1) & 0xFF;- * helper function for des encryption-des_ecb_encrypt(const guint8 *plaintext, guint8 *result, const guint8 *key)- des_set_key(&ctx, key);- des_encrypt(&ctx, DES_BLOCK_SIZE, result, plaintext);- * takes a 21 byte array and treats it as 3 56-bit DES keys. The- * 8 byte plaintext is encrypted with each key and the resulting 24- * bytes are stored in the results array.-calc_resp(guint8 *keys, const guint8 *plaintext, unsigned char *results)- setup_des_key(keys, key);- des_ecb_encrypt(plaintext, results, key);- setup_des_key(keys + 7, key);- des_ecb_encrypt(plaintext, results + 8, key);- setup_des_key(keys + 14, key);- des_ecb_encrypt(plaintext, results + 16, key);-gensesskey(char *buffer)- ssize_t bytes_seeded = 0;- uint8_t seed[YARROW256_SEED_FILE_SIZE];- struct yarrow256_ctx ctx;- fd = open("/dev/urandom", O_RDONLY);- bytes_seeded = read(fd, seed, YARROW256_SEED_FILE_SIZE);- if (bytes_seeded < 0) {- for (i = bytes_seeded; i < YARROW256_SEED_FILE_SIZE; i++) {- seed[i] = (char)(g_random_int() & 0xff);- yarrow256_init(&ctx, 0, NULL);- yarrow256_seed(&ctx, YARROW256_SEED_FILE_SIZE, seed);- yarrow256_random(&ctx, YARROW256_SEED_FILE_SIZE, seed);- yarrow256_random(&ctx, 16, (uint8_t *)buffer);-#endif /* HAVE_NETTLE */-purple_ntlm_gen_type3(const gchar *username, const gchar *passw, const gchar *hostname, const gchar *domain, const guint8 *nonce, guint32 *flags)- unsigned char lm_hpw[21];- struct type3_message *tmsg;- unsigned char lm_resp[24], nt_resp[24];- unsigned char magic[] = { 0x4B, 0x47, 0x53, 0x21, 0x40, 0x23, 0x24, 0x25 };- unsigned char nt_hpw[21];- domainlen = strlen(domain) * 2;- usernamelen = strlen(username) * 2;- hostnamelen = strlen(hostname) * 2;- msglen = sizeof(struct type3_message) + domainlen +- usernamelen + hostnamelen + 0x18 + 0x18 + ((flags) ? 0x10 : 0);- tmsg = g_malloc0(msglen);- passwlen = strlen(passw);- /* type3 message initialization */- tmsg->protocol[0] = 'N';- tmsg->protocol[1] = 'T';- tmsg->protocol[2] = 'L';- tmsg->protocol[3] = 'M';- tmsg->protocol[4] = 'S';- tmsg->protocol[5] = 'S';- tmsg->protocol[6] = 'P';- tmsg->type = GUINT32_TO_LE(0x00000003);- tmsg->lm_resp_len1 = tmsg->lm_resp_len2 = GUINT16_TO_LE(0x18);- tmsg->lm_resp_off = GUINT32_TO_LE(sizeof(struct type3_message) + domainlen + usernamelen + hostnamelen);- tmsg->nt_resp_len1 = tmsg->nt_resp_len2 = GUINT16_TO_LE(0x18);- tmsg->nt_resp_off = GUINT32_TO_LE(sizeof(struct type3_message) + domainlen + usernamelen + hostnamelen + 0x18);- tmsg->dom_len1 = tmsg->dom_len2 = GUINT16_TO_LE(domainlen);- tmsg->dom_off = GUINT32_TO_LE(sizeof(struct type3_message));- tmsg->user_len1 = tmsg->user_len2 = GUINT16_TO_LE(usernamelen);- tmsg->user_off = GUINT32_TO_LE(sizeof(struct type3_message) + domainlen);- tmsg->host_len1 = tmsg->host_len2 = GUINT16_TO_LE(hostnamelen);- tmsg->host_off = GUINT32_TO_LE(sizeof(struct type3_message) + domainlen + usernamelen);- tmsg->sess_off = GUINT32_TO_LE(sizeof(struct type3_message) + domainlen + usernamelen + hostnamelen + 0x18 + 0x18);- tmsg->sess_len1 = tmsg->sess_len2 = GUINT16_TO_LE(0x0010);- tmsg->flags = GUINT32_TO_LE(0x00008201);- tmp = (char *)tmsg + sizeof(struct type3_message);- ucs2le = g_convert(domain, -1, "UTF-16LE", "UTF-8", NULL, NULL, NULL);- memcpy(tmp, ucs2le, domainlen);- purple_debug_info("ntlm", "Unable to encode domain in UTF-16LE.\n");- ucs2le = g_convert(username, -1, "UTF-16LE", "UTF-8", NULL, NULL, NULL);- memcpy(tmp, ucs2le, usernamelen);- purple_debug_info("ntlm", "Unable to encode username in UTF-16LE.\n");- ucs2le = g_convert(hostname, -1, "UTF-16LE", "UTF-8", NULL, NULL, NULL);- memcpy(tmp, ucs2le, hostnamelen);- purple_debug_info("ntlm", "Unable to encode hostname in UTF-16LE.\n");- for (idx = 0; idx < passwlen; idx++)- lm_pw[idx] = g_ascii_toupper(passw[idx]);- for (; idx < 14; idx++)- setup_des_key((unsigned char*)lm_pw, key);- des_ecb_encrypt(magic, lm_hpw, key);- setup_des_key((unsigned char*)(lm_pw + 7), key);- des_ecb_encrypt(magic, lm_hpw + 8, key);- memset(lm_hpw + 16, 0, 5);- calc_resp(lm_hpw, nonce, lm_resp);- memcpy(tmp, lm_resp, 0x18);- /* Convert the password to UTF-16LE */- for (idx = 0; idx < lennt; idx++)- nt_pw[2 * idx] = passw[idx];- nt_pw[2 * idx + 1] = 0;- md4_update(&ctx, 2 * lennt, (uint8_t *)nt_pw);- md4_digest(&ctx, MD4_DIGEST_SIZE, nt_hpw);- memset(nt_hpw + 16, 0, 5);- calc_resp(nt_hpw, nonce, nt_resp);- memcpy(tmp, nt_resp, 0x18);- tmsg->flags = GUINT32_TO_LE(0x409082d4);- memcpy(tmp, sesskey, 0x10);- /*tmsg->flags2 = 0x0a280105;- tmsg->flags3 = 0x0f000000;*/- tmp = g_base64_encode((guchar *)tmsg, msglen);- /* Used without support enabled */- g_return_val_if_reached(NULL);-#endif /* HAVE_NETTLE */--- a/libpurple/protocols/simple/ntlm.h Mon Oct 26 20:18:35 2020 -0500
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,59 +0,0 @@
- * Copyright (C) 2005, Thomas Butter <butter@uni-mannheim.de>- * ntlm structs are taken from NTLM description on- * http://www.innovation.ch/java/ntlm.html- * 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-#ifndef PURPLE_SIMPLE_NTLM_H-#define PURPLE_SIMPLE_NTLM_H- * purple_ntlm_parse_type2:- * @type2: String containing the base64 encoded type2 message- * @flags: If not %NULL, this will store the flags for the message- * Parses the ntlm type 2 message- * Returns: The nonce for use in message type3. This is a statically- * allocated 8 byte binary string.-guint8 *purple_ntlm_parse_type2(const gchar *type2, guint32 *flags);- * purple_ntlm_gen_type3:- * @username: The username- * @hostname: The hostname- * @domain: The domain to authenticate against- * @nonce: The nonce returned by purple_ntlm_parse_type2- * @flags: Pointer to the flags returned by purple_ntlm_parse_type2- * Generates a type3 message- * Returns: A base64 encoded type3 message. This should be g_free'd by-gchar *purple_ntlm_gen_type3(const gchar *username, const gchar *passw, const gchar *hostname, const gchar *domain, const guint8 *nonce, guint32 *flags);-#endif /* PURPLE_SIMPLE_NTLM_H */--- a/libpurple/protocols/simple/simple.c Mon Oct 26 20:18:35 2020 -0500
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,2292 +0,0 @@
- * Copyright (C) 2005 Thomas Butter <butter@uni-mannheim.de>- * Thanks to Google's Summer of Code Program and the helpful mentors- * 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 <glib/gi18n-lib.h>-static PurpleProtocol *my_protocol = NULL;-static gchar *gentag(void) {- return g_strdup_printf("%04d%04d", g_random_int(), g_random_int());-static char *genbranch(void) {- return g_strdup_printf("z9hG4bK%04X%04X%04X%04X%04X",- g_random_int(), g_random_int(), g_random_int(),- g_random_int(), g_random_int());-static char *gencallid(void) {- return g_strdup_printf("%04Xg%04Xa%04Xi%04Xm%04Xt%04Xb%04Xx%04Xx",- g_random_int(), g_random_int(), g_random_int(),- g_random_int(), g_random_int(), g_random_int(),- g_random_int(), g_random_int());-static const char *simple_list_icon(PurpleAccount *a, PurpleBuddy *b) {-simple_uri_handler_find_account(PurpleAccount *account,- G_GNUC_UNUSED gconstpointer data)- const gchar *protocol_id;- protocol_id = purple_account_get_protocol_id(account);- if (purple_strequal(protocol_id, "prpl-simple") &&- purple_account_is_connected(account)) {-simple_uri_handler(const gchar *scheme, const gchar *screenname,- PurpleIMConversation *im;- g_return_val_if_fail(screenname != NULL, FALSE);- if (!purple_strequal(scheme, "sip")) {- if (screenname[0] == '\0') {- purple_debug_warning("simple",- "Invalid empty screenname in URI");- /* Find online SIMPLE account */- accounts = purple_accounts_get_all();- account_node = g_list_find_custom(- accounts, NULL, (GCompareFunc)simple_uri_handler_find_account);- if (account_node == NULL) {- im = purple_im_conversation_new(account_node->data, screenname);- purple_conversation_present(PURPLE_CONVERSATION(im));-static void simple_keep_alive(PurpleConnection *gc) {- struct simple_account_data *sip = purple_connection_get_protocol_data(gc);- if(sip->udp) { /* in case of UDP send a packet only with a 0 byte to- remain in the NAT table */- purple_debug_info("simple", "sending keep alive\n");- if (sendto(sip->fd, buf, 1, 0,- (struct sockaddr*)&sip->serveraddr,- sizeof(struct sockaddr_in)) != 1)- purple_debug_error("simple", "failed sending keep alive\n");-static gboolean process_register_response(struct simple_account_data *sip, struct sipmsg *msg, struct transaction *tc);-static void send_notify(struct simple_account_data *sip, struct simple_watcher *);-static void send_open_publish(struct simple_account_data *sip);-static void send_closed_publish(struct simple_account_data *sip);-static void do_notifies(struct simple_account_data *sip) {- GSList *tmp = sip->watcher;- purple_debug_info("simple", "do_notifies()\n");- if((sip->republish != -1) || sip->republish < time(NULL)) {- if(purple_account_get_bool(sip->account, "dopublish", TRUE)) {- send_open_publish(sip);- purple_debug_info("simple", "notifying %s\n", ((struct simple_watcher*)tmp->data)->name);- send_notify(sip, tmp->data);-static void simple_set_status(PurpleAccount *account, PurpleStatus *status) {- PurpleConnection *gc = purple_account_get_connection(account);- PurpleStatusPrimitive primitive = purple_status_type_get_primitive(purple_status_get_status_type(status));- struct simple_account_data *sip = NULL;- if (!purple_status_is_active(status))- sip = purple_connection_get_protocol_data(gc);- if (primitive == PURPLE_STATUS_AVAILABLE)- sip->status = g_strdup("available");- sip->status = g_strdup("busy");-static struct simple_watcher *watcher_find(struct simple_account_data *sip,- struct simple_watcher *watcher;- GSList *entry = sip->watcher;- if(purple_strequal(name, watcher->name)) return watcher;-static struct simple_watcher *watcher_create(struct simple_account_data *sip,- const gchar *name, const gchar *callid, const gchar *ourtag,- const gchar *theirtag, gboolean needsxpidf) {- struct simple_watcher *watcher = g_new0(struct simple_watcher, 1);- watcher->name = g_strdup(name);- watcher->dialog.callid = g_strdup(callid);- watcher->dialog.ourtag = g_strdup(ourtag);- watcher->dialog.theirtag = g_strdup(theirtag);- watcher->needsxpidf = needsxpidf;- sip->watcher = g_slist_append(sip->watcher, watcher);-watcher_destroy(struct simple_watcher *watcher)- g_free(watcher->dialog.callid);- g_free(watcher->dialog.ourtag);- g_free(watcher->dialog.theirtag);-static struct sip_connection *-connection_create(struct simple_account_data *sip, GSocketConnection *sockconn)- struct sip_connection *ret = g_new0(struct sip_connection, 1);- ret->sockconn = sockconn;- sip->openconns = g_slist_append(sip->openconns, ret);-connection_destroy(struct sip_connection *conn)- if (conn->inputhandler) {- g_source_remove(conn->inputhandler);- g_clear_pointer(&conn->inbuf, g_free);- g_clear_object(&conn->sockconn);-static struct sip_connection *-connection_find(struct simple_account_data *sip, GInputStream *input)- struct sip_connection *ret = NULL;- GSList *entry = sip->openconns;- if (g_io_stream_get_input_stream(G_IO_STREAM(ret->sockconn)) == input) {-connection_remove(struct simple_account_data *sip, GInputStream *input)- struct sip_connection *conn = connection_find(sip, input);- sip->openconns = g_slist_remove(sip->openconns, conn);- connection_destroy(conn);-static void simple_add_buddy(PurpleConnection *gc, PurpleBuddy *buddy, PurpleGroup *group, const char *message)- struct simple_account_data *sip = purple_connection_get_protocol_data(gc);- struct simple_buddy *b;- const char *name = purple_buddy_get_name(buddy);- if(strncmp(name, "sip:", 4)) {- gchar *buf = g_strdup_printf("sip:%s", name);- purple_buddy_set_name(buddy, buf);- if(!g_hash_table_lookup(sip->buddies, name)) {- b = g_new0(struct simple_buddy, 1);- purple_debug_info("simple", "simple_add_buddy %s\n", name);- b->name = g_strdup(name);- g_hash_table_insert(sip->buddies, b->name, b);- purple_debug_info("simple", "buddy %s already in internal list\n", name);-static void simple_get_buddies(PurpleConnection *gc) {- PurpleAccount *account;- purple_debug_info("simple", "simple_get_buddies\n");- account = purple_connection_get_account(gc);- buddies = purple_blist_find_buddies(account, NULL);- PurpleBuddy *buddy = buddies->data;- simple_add_buddy(gc, buddy, purple_buddy_get_group(buddy), NULL);- buddies = g_slist_delete_link(buddies, buddies);-static void simple_remove_buddy(PurpleConnection *gc, PurpleBuddy *buddy, PurpleGroup *group)- const char *name = purple_buddy_get_name(buddy);- struct simple_account_data *sip = purple_connection_get_protocol_data(gc);- struct simple_buddy *b = g_hash_table_lookup(sip->buddies, name);- g_hash_table_remove(sip->buddies, name);-static GList *simple_status_types(PurpleAccount *acc) {- PurpleStatusType *type;- type = purple_status_type_new_with_attrs(- PURPLE_STATUS_AVAILABLE, NULL, NULL, TRUE, TRUE, FALSE,- "message", _("Message"), purple_value_new(G_TYPE_STRING),- types = g_list_append(types, type);- type = purple_status_type_new_full(- PURPLE_STATUS_OFFLINE, NULL, NULL, TRUE, TRUE, FALSE);- types = g_list_append(types, type);-static gchar *auth_header(struct simple_account_data *sip,- struct sip_auth *auth, const gchar *method, const gchar *target) {- authuser = purple_account_get_string(sip->account, "authuser", sip->username);- if(!authuser || strlen(authuser) < 1) {- authuser = sip->username;- if(auth->type == 1) { /* Digest */- sprintf(noncecount, "%08d", auth->nc++);- response = simple_http_digest_calculate_response(- method, target, auth->nonce, noncecount,- auth->digest_session_key);- purple_debug(PURPLE_DEBUG_MISC, "simple", "response %s\n", response);- ret = g_strdup_printf("Digest username=\"%s\", realm=\"%s\", nonce=\"%s\", uri=\"%s\", nc=\"%s\", response=\"%s\"", authuser, auth->realm, auth->nonce, target, noncecount, response);- } else if(auth->type == 2) { /* NTLM */- const gchar *authdomain;- authdomain = purple_account_get_string(sip->account,- if(auth->nc == 3 && auth->nonce) {- /* TODO: Don't hardcode "purple" as the hostname */- ret = purple_ntlm_gen_type3(authuser, sip->password, "purple", authdomain, (const guint8 *)auth->nonce, &auth->flags);- tmp = g_strdup_printf("NTLM qop=\"auth\", opaque=\"%s\", realm=\"%s\", targetname=\"%s\", gssapi-data=\"%s\"", auth->opaque, auth->realm, auth->target, ret);- tmp = g_strdup_printf("NTLM qop=\"auth\", realm=\"%s\", targetname=\"%s\", gssapi-data=\"\"", auth->realm, auth->target);- /* Used without support enabled */- g_return_val_if_reached(NULL);-#endif /* HAVE_NETTLE */- sprintf(noncecount, "%08d", auth->nc++);- response = simple_http_digest_calculate_response(- method, target, auth->nonce, noncecount,- auth->digest_session_key);- purple_debug(PURPLE_DEBUG_MISC, "simple", "response %s\n", response);- ret = g_strdup_printf("Digest username=\"%s\", realm=\"%s\", nonce=\"%s\", uri=\"%s\", nc=\"%s\", response=\"%s\"", authuser, auth->realm, auth->nonce, target, noncecount, response);-static char *parse_attribute(const char *attrname, const char *source) {- const char *tmp, *tmp2;- int len = strlen(attrname);- /* we know that source is NULL-terminated.- * Therefore this loop won't be infinite.- while (source[0] == ' ')- if(!strncmp(source, attrname, len)) {- tmp2 = g_strstr_len(tmp, strlen(tmp), "\"");- retval = g_strndup(tmp, tmp2 - tmp);- retval = g_strdup(tmp);-static void fill_auth(struct simple_account_data *sip, const gchar *hdr, struct sip_auth *auth) {- authuser = purple_account_get_string(sip->account, "authuser", sip->username);- if(!authuser || strlen(authuser) < 1) {- authuser = sip->username;- purple_debug_error("simple", "fill_auth: hdr==NULL\n");- if(!g_ascii_strncasecmp(hdr, "NTLM", 4)) {- purple_debug_info("simple", "found NTLM\n");- parts = g_strsplit(hdr+5, "\",", 0);- purple_debug_info("simple", "parts[i] %s\n", parts[i]);- if((tmp = parse_attribute("gssapi-data=\"", parts[i]))) {- auth->nonce = g_memdup(purple_ntlm_parse_type2(tmp, &auth->flags), 8);- if((tmp = parse_attribute("targetname=\"",- else if((tmp = parse_attribute("realm=\"",- else if((tmp = parse_attribute("opaque=\"", parts[i]))) {- if(!strstr(hdr, "gssapi-data")) {- purple_debug_error("simple", "NTLM auth unsupported without "- "libnettle support. Please rebuild with "- "libnettle support for this feature.\n");-#endif /* HAVE_NETTLE */- } else if(!g_ascii_strncasecmp(hdr, "DIGEST", 6)) {- purple_debug_info("simple", "found DIGEST\n");- parts = g_strsplit(hdr+7, ",", 0);- if((tmp = parse_attribute("nonce=\"", parts[i]))) {- else if((tmp = parse_attribute("realm=\"", parts[i]))) {- purple_debug(PURPLE_DEBUG_MISC, "simple", "nonce: %s realm: %s\n",- auth->nonce ? auth->nonce : "(null)",- auth->realm ? auth->realm : "(null)");- auth->digest_session_key =- simple_http_digest_calculate_session_key(- authuser, auth->realm, sip->password,- purple_debug_error("simple", "Unsupported or bad WWW-Authenticate header (%s).\n", hdr);-simple_push_bytes_cb(GObject *sender, GAsyncResult *res, gpointer data)- PurpleQueuedOutputStream *stream = PURPLE_QUEUED_OUTPUT_STREAM(sender);- struct simple_account_data *sip = data;- result = purple_queued_output_stream_push_bytes_finish(stream, res, &error);- purple_queued_output_stream_clear_queue(stream);- if (g_error_matches(error, G_IO_ERROR, G_IO_ERROR_CANCELLED)) {- g_prefix_error(&error, "%s", _("Lost connection with server: "));- purple_connection_take_error(sip->gc, error);-static gboolean simple_input_cb(GObject *stream, gpointer data);-send_later_cb(GObject *sender, GAsyncResult *res, gpointer data)- PurpleConnection *gc = data;- struct simple_account_data *sip;- struct sip_connection *conn;- GSocketConnection *sockconn;- sockconn = g_socket_client_connect_to_host_finish(G_SOCKET_CLIENT(sender),- if (sockconn == NULL) {- if (g_error_matches(error, G_IO_ERROR, G_IO_ERROR_CANCELLED)) {- purple_connection_take_error(gc, error);- sip = purple_connection_get_protocol_data(gc);- sip->input = g_io_stream_get_input_stream(G_IO_STREAM(sockconn));- sip->output = purple_queued_output_stream_new(- g_io_stream_get_output_stream(G_IO_STREAM(sockconn)));- sip->connecting = FALSE;- writelen = purple_circular_buffer_get_max_read(sip->txbuf);- buf = purple_circular_buffer_get_output(sip->txbuf);- output = g_bytes_new(buf, writelen);- purple_queued_output_stream_push_bytes_async(- sip->output, output, G_PRIORITY_DEFAULT, sip->cancellable,- simple_push_bytes_cb, sip);- purple_circular_buffer_mark_read(sip->txbuf, writelen);- conn = connection_create(sip, sockconn);- source = g_pollable_input_stream_create_source(- G_POLLABLE_INPUT_STREAM(sip->input), sip->cancellable);- g_source_set_callback(source, (GSourceFunc)simple_input_cb, gc, NULL);- conn->inputhandler = g_source_attach(source, NULL);- g_source_unref(source);-static void sendlater(PurpleConnection *gc, const char *buf) {- struct simple_account_data *sip = purple_connection_get_protocol_data(gc);- GSocketClient *client = NULL;- client = purple_gio_socket_client_new(sip->account, &error);- purple_connection_take_error(sip->gc, error);- purple_debug_info("simple", "connecting to %s port %d",- sip->realhostname ? sip->realhostname : "{NULL}",- g_socket_client_connect_to_host_async(client, sip->realhostname,- sip->realport, sip->cancellable,- g_object_unref(client);- sip->connecting = TRUE;- if(purple_circular_buffer_get_max_read(sip->txbuf) > 0)- purple_circular_buffer_append(sip->txbuf, "\r\n", 2);- purple_circular_buffer_append(sip->txbuf, buf, strlen(buf));-static void sendout_pkt(PurpleConnection *gc, const char *buf) {- struct simple_account_data *sip = purple_connection_get_protocol_data(gc);- time_t currtime = time(NULL);- int writelen = strlen(buf);- purple_debug(PURPLE_DEBUG_MISC, "simple", "\n\nsending - %s\n######\n%s\n######\n\n", ctime(&currtime), buf);- if(sendto(sip->fd, buf, writelen, 0, (struct sockaddr*)&sip->serveraddr, sizeof(struct sockaddr_in)) < writelen) {- purple_debug_info("simple", "could not send packet\n");- if (sip->output == NULL) {- output = g_bytes_new(buf, writelen);- purple_queued_output_stream_push_bytes_async(- sip->output, output, G_PRIORITY_DEFAULT, sip->cancellable,- simple_push_bytes_cb, sip);-static int simple_send_raw(PurpleConnection *gc, const char *buf, int len)-send_sip_response(PurpleConnection *gc, struct sipmsg *msg, gint code,- const gchar *text, const gchar *body)- /* When sending the acknowlegements and errors, the content length from the original- message is still here, but there is no body; we need to make sure we're sending the- correct content length */- sipmsg_remove_header(msg, "Content-Length");- g_clear_pointer(&msg->body, g_free);- msg->bodylen = strlen(body);- sprintf(len, "%d", msg->bodylen);- sipmsg_add_header(msg, "Content-Length", len);- msg->body = g_strdup(body);- sipmsg_add_header(msg, "Content-Length", "0");- outstr = sipmsg_to_string(msg, text);- sendout_pkt(gc, outstr);-transactions_destroy(struct transaction *trans)- sipmsg_free(trans->msg);-static void transactions_add_buf(struct simple_account_data *sip, const gchar *buf, void *callback) {- struct transaction *trans = g_new0(struct transaction, 1);- trans->time = time(NULL);- trans->msg = sipmsg_parse_msg(buf);- trans->cseq = sipmsg_find_header(trans->msg, "CSeq");- trans->callback = callback;- sip->transactions = g_slist_append(sip->transactions, trans);-static struct transaction *transactions_find(struct simple_account_data *sip, struct sipmsg *msg) {- struct transaction *trans;- GSList *transactions = sip->transactions;- const gchar *cseq = sipmsg_find_header(msg, "CSeq");- trans = transactions->data;- if(purple_strequal(trans->cseq, cseq)) {- transactions = transactions->next;- purple_debug(PURPLE_DEBUG_MISC, "simple", "Received message contains no CSeq header.\n");-static void send_sip_request(PurpleConnection *gc, const gchar *method,- const gchar *url, const gchar *to, const gchar *addheaders,- const gchar *body, struct sip_dialog *dialog, TransCallback tc) {- struct simple_account_data *sip = purple_connection_get_protocol_data(gc);- char *callid = dialog ? g_strdup(dialog->callid) : gencallid();- gchar *branch = genbranch();- if(purple_strequal(method, "REGISTER")) {- callid = g_strdup(sip->regcallid);- else sip->regcallid = g_strdup(callid);- if(addheaders) addh = addheaders;- if(sip->registrar.type && purple_strequal(method, "REGISTER")) {- buf = auth_header(sip, &sip->registrar, method, url);- auth = g_strdup_printf("Authorization: %s\r\n", buf);- purple_debug(PURPLE_DEBUG_MISC, "simple", "header %s", auth);- } else if(sip->proxy.type && !purple_strequal(method, "REGISTER")) {- buf = auth_header(sip, &sip->proxy, method, url);- auth = g_strdup_printf("Proxy-Authorization: %s\r\n", buf);- purple_debug(PURPLE_DEBUG_MISC, "simple", "header %s", auth);- buf = g_strdup_printf("%s %s SIP/2.0\r\n"- "Via: SIP/2.0/%s %s:%d;branch=%s\r\n"- /* Don't know what epid is, but LCS wants it */- "From: <sip:%s@%s>;tag=%s;epid=1234567890\r\n"- "User-Agent: Purple/" VERSION "\r\n"- "Content-Length: %" G_GSIZE_FORMAT "\r\n\r\n%s",- sip->udp ? "UDP" : "TCP",- purple_network_get_my_ip(-1),- dialog ? dialog->ourtag : tag,- dialog ? dialog->theirtag : "",- /* add to ongoing transactions */- transactions_add_buf(sip, buf, tc);-static char *get_contact(struct simple_account_data *sip) {- return g_strdup_printf("<sip:%s@%s:%d;transport=%s>;methods=\"MESSAGE, SUBSCRIBE, NOTIFY\"",- sip->username, purple_network_get_my_ip(-1),- sip->udp ? "udp" : "tcp");-static void do_register_exp(struct simple_account_data *sip, int expire) {- char *uri, *to, *contact, *hdr;- sip->reregister = time(NULL) + expire - 50;- uri = g_strdup_printf("sip:%s", sip->servername);- to = g_strdup_printf("sip:%s@%s", sip->username, sip->servername);- contact = get_contact(sip);- hdr = g_strdup_printf("Contact: %s\r\nExpires: %d\r\n", contact, expire);- sip->registerstatus = SIMPLE_REGISTER_SENT;- send_sip_request(sip->gc, "REGISTER", uri, to, hdr, "", NULL,- process_register_response);-static void do_register(struct simple_account_data *sip) {- do_register_exp(sip, sip->registerexpire);-static gchar *parse_from(const gchar *hdr) {- const gchar *tmp, *tmp2 = hdr;- purple_debug_info("simple", "parsing address out of %s\n", hdr);- tmp = strchr(hdr, '<');- /* i hate the different SIP UA behaviours... */- if(tmp) { /* sip address in <...> */- tmp = strchr(tmp2, '>');- from = g_strndup(tmp2, tmp - tmp2);- purple_debug_info("simple", "found < without > in From\n");- tmp = strchr(tmp2, ';');- from = g_strndup(tmp2, tmp - tmp2);- purple_debug_info("simple", "got %s\n", from);-static gchar *find_tag(const gchar *);-static gboolean process_subscribe_response(struct simple_account_data *sip, struct sipmsg *msg, struct transaction *tc) {- struct simple_buddy *b = NULL;- gchar *theirtag = NULL, *ourtag = NULL;- const gchar *callid = NULL;- purple_debug_info("simple", "process subscribe response\n");- if(msg->response == 200 || msg->response == 202) {- if ( (to = parse_from(sipmsg_find_header(msg, "To"))) &&- (b = g_hash_table_lookup(sip->buddies, to)) &&- purple_debug_info("simple", "creating dialog"- " information for a subscription.\n");- theirtag = find_tag(sipmsg_find_header(msg, "To"));- ourtag = find_tag(sipmsg_find_header(msg, "From"));- callid = sipmsg_find_header(msg, "Call-ID");- if (theirtag && ourtag && callid)- b->dialog = g_new0(struct sip_dialog, 1);- b->dialog->ourtag = g_strdup(ourtag);- b->dialog->theirtag = g_strdup(theirtag);- b->dialog->callid = g_strdup(callid);- purple_debug_info("simple", "ourtag: %s\n",- purple_debug_info("simple", "theirtag: %s\n",- purple_debug_info("simple", "callid: %s\n",- purple_debug_info("simple", "cannot create dialog!\n");- to = parse_from(sipmsg_find_header(tc->msg, "To")); /* cant be NULL since it is our own msg */- /* we can not subscribe -> user is offline (TODO unknown status?) */- purple_protocol_got_user_status(sip->account, to, "offline", NULL);-static void simple_subscribe_exp(struct simple_account_data *sip, struct simple_buddy *buddy, int expiration) {- gchar *contact, *to, *tmp, *tmp2;- tmp2 = g_strdup_printf(- "Accept: application/pidf+xml, application/xpidf+xml\r\n"- if(strncmp(buddy->name, "sip:", 4))- to = g_strdup_printf("sip:%s", buddy->name);- to = g_strdup(buddy->name);- tmp = get_contact(sip);- contact = g_strdup_printf("%sContact: %s\r\n", tmp2, tmp);- send_sip_request(sip->gc, "SUBSCRIBE", to, to, contact,"",buddy->dialog,- (expiration > 0) ? process_subscribe_response : NULL);- /* resubscribe before subscription expires */- buddy->resubscribe = time(NULL) + (expiration - 60) + (g_random_int_range(0, 50));- else if (expiration > 0)- buddy->resubscribe = time(NULL) + ((int) (expiration / 2));-static void simple_subscribe(struct simple_account_data *sip, struct simple_buddy *buddy) {- simple_subscribe_exp(sip, buddy, SUBSCRIBE_EXPIRATION);-static void simple_unsubscribe(char *name, struct simple_buddy *buddy, struct simple_account_data *sip) {- purple_debug_info("simple", "Unsubscribing from %s\n", name);- simple_subscribe_exp(sip, buddy, 0);-static gboolean simple_add_lcs_contacts(struct simple_account_data *sip, struct sipmsg *msg, struct transaction *tc) {- PurpleXmlNode *item, *group, *isc;- const char *name_group;- struct simple_buddy *bs;- int len = msg->bodylen;- tmp = sipmsg_find_header(msg, "Event");- if(tmp && !strncmp(tmp, "vnd-microsoft-roaming-contacts", 30)){- purple_debug_info("simple", "simple_add_lcs_contacts->%s-%d\n", msg->body, len);- /*Convert the contact from XML to Purple Buddies*/- isc = purple_xmlnode_from_str(msg->body, len);- /* ToDo. Find for all groups */- if ((group = purple_xmlnode_get_child(isc, "group"))) {- name_group = purple_xmlnode_get_attrib(group, "name");- purple_debug_info("simple", "name_group->%s\n", name_group);- g = purple_blist_find_group(name_group);- g = purple_group_new(name_group);- g = purple_blist_get_default_group();- for(item = purple_xmlnode_get_child(isc, "contact"); item; item = purple_xmlnode_get_next_twin(item))- uri = purple_xmlnode_get_attrib(item, "uri");- /*name = purple_xmlnode_get_attrib(item, "name");- groups = purple_xmlnode_get_attrib(item, "groups");*/- purple_debug_info("simple", "URI->%s\n", uri);- buddy_name = g_strdup_printf("sip:%s", uri);- b = purple_blist_find_buddy(sip->account, buddy_name);- b = purple_buddy_new(sip->account, buddy_name, uri);- purple_blist_add_buddy(b, NULL, g, NULL);- purple_buddy_set_local_alias(b, uri);- bs = g_new0(struct simple_buddy, 1);- bs->name = g_strdup(purple_buddy_get_name(b));- g_hash_table_insert(sip->buddies, bs->name, bs);- purple_xmlnode_free(isc);-static void simple_subscribe_buddylist(struct simple_account_data *sip) {- gchar *contact = "Event: vnd-microsoft-roaming-contacts\r\nAccept: application/vnd-microsoft-roaming-contacts+xml\r\nSupported: com.microsoft.autoextend\r\nSupported: ms-benotify\r\nProxy-Require: ms-benotify\r\nSupported: ms-piggyback-first-notify\r\n";- to = g_strdup_printf("sip:%s@%s", sip->username, sip->servername);- tmp = get_contact(sip);- contact = g_strdup_printf("%sContact: %s\r\n", contact, tmp);- send_sip_request(sip->gc, "SUBSCRIBE", to, to, contact, "", NULL, simple_add_lcs_contacts);-static void simple_buddy_resub(char *name, struct simple_buddy *buddy, struct simple_account_data *sip) {- time_t curtime = time(NULL);- purple_debug_info("simple", "buddy resub\n");- if(buddy->resubscribe < curtime) {- purple_debug(PURPLE_DEBUG_MISC, "simple", "simple_buddy_resub %s\n", name);- simple_subscribe(sip, buddy);-static gboolean resend_timeout(struct simple_account_data *sip) {- GSList *tmp = sip->transactions;- time_t currtime = time(NULL);- struct transaction *trans = tmp->data;- purple_debug_info("simple", "have open transaction age: %lu\n", currtime- trans->time);- if((currtime - trans->time > 5) && trans->retries >= 1) {- if((currtime - trans->time > 2) && trans->retries == 0) {- outstr = sipmsg_to_string(trans->msg, NULL);- sendout_pkt(sip->gc, outstr);-static gboolean subscribe_timeout(struct simple_account_data *sip) {- time_t curtime = time(NULL);- /* register again if first registration expires */- if(sip->reregister < curtime) {- /* publish status again if our last update is about to expire. */- if (sip->republish != -1 &&- sip->republish < curtime &&- purple_account_get_bool(sip->account, "dopublish", TRUE))- purple_debug_info("simple", "subscribe_timeout: republishing status.\n");- send_open_publish(sip);- /* check for every subscription if we need to resubscribe */- g_hash_table_foreach(sip->buddies, (GHFunc)simple_buddy_resub, (gpointer)sip);- /* remove a timed out suscriber */- GSList *next = tmp->next;- struct simple_watcher *watcher = tmp->data;- if(watcher->expire < curtime) {- sip->watcher = g_slist_delete_link(sip->watcher, tmp);- watcher_destroy(watcher);-static void simple_send_message(struct simple_account_data *sip, const char *to, const char *msg, const char *type) {- if(strncmp(to, "sip:", 4))- fullto = g_strdup_printf("sip:%s", to);- hdr = g_strdup_printf("Content-Type: %s\r\n", type);- hdr = g_strdup("Content-Type: text/plain\r\n");- send_sip_request(sip->gc, "MESSAGE", fullto, fullto, hdr, msg, NULL, NULL);-static int simple_im_send(PurpleProtocolIM *im, PurpleConnection *gc, PurpleMessage *msg) {- struct simple_account_data *sip = purple_connection_get_protocol_data(gc);- char *to = g_strdup(purple_message_get_recipient(msg));- char *text = purple_unescape_html(purple_message_get_contents(msg));- simple_send_message(sip, to, text, NULL);-static void process_incoming_message(struct simple_account_data *sip, struct sipmsg *msg) {- const gchar *contenttype;- gboolean found = FALSE;- from = parse_from(sipmsg_find_header(msg, "From"));- purple_debug(PURPLE_DEBUG_MISC, "simple", "got message from %s: %s\n", from, msg->body);- contenttype = sipmsg_find_header(msg, "Content-Type");- if(!contenttype || !strncmp(contenttype, "text/plain", 10) || !strncmp(contenttype, "text/html", 9)) {- purple_serv_got_im(sip->gc, from, msg->body, 0, time(NULL));- send_sip_response(sip->gc, msg, 200, "OK", NULL);- else if(!strncmp(contenttype, "application/im-iscomposing+xml", 30)) {- PurpleXmlNode *isc = purple_xmlnode_from_str(msg->body, msg->bodylen);- purple_debug_info("simple", "process_incoming_message: can not parse iscomposing\n");- state = purple_xmlnode_get_child(isc, "state");- purple_debug_info("simple", "process_incoming_message: no state found\n");- purple_xmlnode_free(isc);- statedata = purple_xmlnode_get_data(state);- if(strstr(statedata, "active"))- purple_serv_got_typing(sip->gc, from, 0, PURPLE_IM_TYPING);- purple_serv_got_typing_stopped(sip->gc, from);- purple_xmlnode_free(isc);- send_sip_response(sip->gc, msg, 200, "OK", NULL);- purple_debug_info("simple", "got unknown mime-type\n");- send_sip_response(sip->gc, msg, 415, "Unsupported media type", NULL);-gboolean process_register_response(struct simple_account_data *sip, struct sipmsg *msg, struct transaction *tc) {- purple_debug(PURPLE_DEBUG_MISC, "simple", "in process register response response: %d\n", msg->response);- switch (msg->response) {- if(sip->registerstatus < SIMPLE_REGISTER_COMPLETE) { /* registered */- if(purple_account_get_bool(sip->account, "dopublish", TRUE)) {- send_open_publish(sip);- sip->registerstatus = SIMPLE_REGISTER_COMPLETE;- purple_connection_set_state(sip->gc, PURPLE_CONNECTION_CONNECTED);- /* get buddies from blist */- simple_get_buddies(sip->gc);- subscribe_timeout(sip);- tmp = sipmsg_find_header(msg, "Allow-Events");- if(tmp && strstr(tmp, "vnd-microsoft-provisioning")){- simple_subscribe_buddylist(sip);- if(sip->registerstatus != SIMPLE_REGISTER_RETRY) {- purple_debug_info("simple", "REGISTER retries %d\n", sip->registrar.retries);- if(sip->registrar.retries > SIMPLE_REGISTER_RETRY_MAX) {- if (!purple_account_get_remember_password(purple_connection_get_account(sip->gc)))- purple_account_set_password(purple_connection_get_account(sip->gc), NULL, NULL, NULL);- purple_connection_error(sip->gc,- PURPLE_CONNECTION_ERROR_AUTHENTICATION_FAILED,- _("Incorrect password"));- tmp = sipmsg_find_header(msg, "WWW-Authenticate");- fill_auth(sip, tmp, &sip->registrar);- sip->registerstatus = SIMPLE_REGISTER_RETRY;- if (sip->registerstatus != SIMPLE_REGISTER_RETRY) {- purple_debug_info("simple", "Unrecognized return code for REGISTER.\n");- if (sip->registrar.retries > SIMPLE_REGISTER_RETRY_MAX) {- purple_connection_error(sip->gc,- PURPLE_CONNECTION_ERROR_OTHER_ERROR,- _("Unknown server response"));- sip->registerstatus = SIMPLE_REGISTER_RETRY;-static gboolean dialog_match(struct sip_dialog *dialog, struct sipmsg *msg)- gchar *ourtag, *theirtag;- gboolean match = FALSE;- fromhdr = sipmsg_find_header(msg, "From");- tohdr = sipmsg_find_header(msg, "To");- callid = sipmsg_find_header(msg, "Call-ID");- if (!fromhdr || !tohdr || !callid)- ourtag = find_tag(tohdr);- theirtag = find_tag(fromhdr);- if (ourtag && theirtag &&- purple_strequal(dialog->callid, callid) &&- purple_strequal(dialog->ourtag, ourtag) &&- purple_strequal(dialog->theirtag, theirtag))-static void process_incoming_notify(struct simple_account_data *sip, struct sipmsg *msg) {- gchar *basicstatus_data;- PurpleXmlNode *basicstatus = NULL, *tuple, *status;- gboolean isonline = FALSE;- struct simple_buddy *b = NULL;- const gchar *sshdr = NULL;- fromhdr = sipmsg_find_header(msg, "From");- from = parse_from(fromhdr);- b = g_hash_table_lookup(sip->buddies, from);- purple_debug_info("simple", "Could not find the buddy.\n");- if (b->dialog && !dialog_match(b->dialog, msg))- /* We only accept notifies from people that- * we already have a dialog with.- purple_debug_info("simple","No corresponding dialog for notify--discard\n");- pidf = purple_xmlnode_from_str(msg->body, msg->bodylen);- purple_debug_info("simple", "process_incoming_notify: no parseable pidf\n");- sshdr = sipmsg_find_header(msg, "Subscription-State");- gchar **ssparts = g_strsplit(sshdr, ":", 0);- if (g_str_has_prefix(ssparts[i], "terminated")) {- purple_debug_info("simple", "Subscription expired!");- g_free(b->dialog->ourtag);- g_free(b->dialog->theirtag);- g_free(b->dialog->callid);- purple_protocol_got_user_status(sip->account, from, "offline", NULL);- send_sip_response(sip->gc, msg, 200, "OK", NULL);- if ((tuple = purple_xmlnode_get_child(pidf, "tuple")))- if ((status = purple_xmlnode_get_child(tuple, "status")))- basicstatus = purple_xmlnode_get_child(status, "basic");- purple_debug_info("simple", "process_incoming_notify: no basic found\n");- purple_xmlnode_free(pidf);- basicstatus_data = purple_xmlnode_get_data(basicstatus);- if(!basicstatus_data) {- purple_debug_info("simple", "process_incoming_notify: no basic data found\n");- purple_xmlnode_free(pidf);- if(strstr(basicstatus_data, "open"))- purple_protocol_got_user_status(sip->account, from, "available", NULL);- purple_protocol_got_user_status(sip->account, from, "offline", NULL);- purple_xmlnode_free(pidf);- g_free(basicstatus_data);- send_sip_response(sip->gc, msg, 200, "OK", NULL);-static unsigned int simple_typing(PurpleProtocolIM *im, PurpleConnection *gc, const char *name, PurpleIMTypingState state) {- struct simple_account_data *sip = purple_connection_get_protocol_data(gc);- gchar *xml = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n"- "<isComposing xmlns=\"urn:ietf:params:xml:ns:im-iscomposing\"\n"- "xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\"\n"- "xsi:schemaLocation=\"urn:ietf:params:xml:ns:im-composing iscomposing.xsd\">\n"- "<contenttype>text/plain</contenttype>\n"- "<refresh>60</refresh>\n"- gchar *recv = g_strdup(name);- if(state == PURPLE_IM_TYPING) {- gchar *msg = g_strdup_printf(xml, "active");- simple_send_message(sip, recv, msg, "application/im-iscomposing+xml");- } else /* TODO: Only if (state == PURPLE_IM_TYPED) ? */ {- gchar *msg = g_strdup_printf(xml, "idle");- simple_send_message(sip, recv, msg, "application/im-iscomposing+xml");- * TODO: Is this right? It will cause the core to call- * purple_serv_send_typing(gc, who, PURPLE_IM_TYPING) once every second- * until the user stops typing. If that's not desired,- * then return 0 instead.-static gchar *find_tag(const gchar *hdr) {- const gchar *tmp = strstr(hdr, ";tag="), *tmp2;- if((tmp2 = strchr(tmp, ';'))) {- return g_strndup(tmp, tmp2 - tmp);-static gchar* gen_xpidf(struct simple_account_data *sip) {- gchar *doc = g_strdup_printf("<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n"- "<presentity uri=\"sip:%s@%s;method=SUBSCRIBE\"/>\n"- "<display name=\"sip:%s@%s\"/>\n"- "<address uri=\"sip:%s@%s\">\n"- "<status status=\"%s\"/>\n"-static gchar* gen_pidf(struct simple_account_data *sip, gboolean open) {- gchar *doc = g_strdup_printf("<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n"- "<presence xmlns=\"urn:ietf:params:xml:ns:pidf\"\n"- "xmlns:im=\"urn:ietf:params:xml:ns:pidf:im\"\n"- "entity=\"sip:%s@%s\">\n"- "<tuple id=\"bs35r9f\">\n"- (open == TRUE) ? "open" : "closed",- (open == TRUE) ? sip->status : "");-static void send_notify(struct simple_account_data *sip, struct simple_watcher *watcher) {- gchar *doc = watcher->needsxpidf ? gen_xpidf(sip) : gen_pidf(sip, TRUE);- gchar *hdr = watcher->needsxpidf ? "Event: presence\r\nContent-Type: application/xpidf+xml\r\n" : "Event: presence\r\nContent-Type: application/pidf+xml\r\n";- send_sip_request(sip->gc, "NOTIFY", watcher->name, watcher->name, hdr, doc, &watcher->dialog, NULL);-static gboolean process_publish_response(struct simple_account_data *sip, struct sipmsg *msg, struct transaction *tc) {- const gchar *etag = NULL;- if(msg->response != 200 && msg->response != 408) {- etag = sipmsg_find_header(msg, "SIP-Etag");- /* we must store the etag somewhere. */- g_free(sip->publish_etag);- sip->publish_etag = g_strdup(etag);-static void send_open_publish(struct simple_account_data *sip) {- gchar *add_headers = NULL;- gchar *uri = g_strdup_printf("sip:%s@%s", sip->username, sip->servername);- gchar *doc = gen_pidf(sip, TRUE);- add_headers = g_strdup_printf("%s%s%s%s%d\r\n%s",- sip->publish_etag ? "SIP-If-Match: " : "",- sip->publish_etag ? sip->publish_etag : "",- sip->publish_etag ? "\r\n" : "",- "Expires: ", PUBLISH_EXPIRATION,- "Content-Type: application/pidf+xml\r\n");- send_sip_request(sip->gc, "PUBLISH", uri, uri,- add_headers, doc, NULL, process_publish_response);- sip->republish = time(NULL) + PUBLISH_EXPIRATION - 50;-static void send_closed_publish(struct simple_account_data *sip) {- gchar *uri = g_strdup_printf("sip:%s@%s", sip->username, sip->servername);- gchar *add_headers, *doc;- add_headers = g_strdup_printf("%s%s%s%s",- sip->publish_etag ? "SIP-If-Match: " : "",- sip->publish_etag ? sip->publish_etag : "",- sip->publish_etag ? "\r\n" : "",- "Content-Type: application/pidf+xml\r\n");- doc = gen_pidf(sip, FALSE);- send_sip_request(sip->gc, "PUBLISH", uri, uri, add_headers,- doc, NULL, process_publish_response);- /*sip->republish = time(NULL) + 500;*/-static void process_incoming_subscribe(struct simple_account_data *sip, struct sipmsg *msg) {- const char *from_hdr = sipmsg_find_header(msg, "From");- gchar *from = parse_from(from_hdr);- gchar *theirtag = find_tag(from_hdr);- gchar *ourtag = find_tag(sipmsg_find_header(msg, "To"));- gboolean tagadded = FALSE;- const gchar *callid = sipmsg_find_header(msg, "Call-ID");- const gchar *expire = sipmsg_find_header(msg, "Expire");- struct simple_watcher *watcher = watcher_find(sip, from);- if(!watcher) { /* new subscription */- const gchar *acceptheader = sipmsg_find_header(msg, "Accept");- gboolean needsxpidf = FALSE;- if(!purple_account_privacy_check(sip->account, from)) {- send_sip_response(sip->gc, msg, 202, "Ok", NULL);- const gchar *tmp = acceptheader;- gboolean foundpidf = FALSE;- gboolean foundxpidf = FALSE;- while(tmp && tmp < acceptheader + strlen(acceptheader)) {- gchar *tmp2 = strchr(tmp, ',');- if(!g_ascii_strcasecmp("application/pidf+xml", tmp))- if(!g_ascii_strcasecmp("application/xpidf+xml", tmp))- while(*tmp == ' ') tmp++;- if(!foundpidf && foundxpidf) needsxpidf = TRUE;- watcher = watcher_create(sip, from, callid, ourtag, theirtag, needsxpidf);- gchar *to = g_strdup_printf("%s;tag=%s", sipmsg_find_header(msg, "To"), ourtag);- sipmsg_remove_header(msg, "To");- sipmsg_add_header(msg, "To", to);- watcher->expire = time(NULL) + strtol(expire, NULL, 10);- watcher->expire = time(NULL) + 600;- sipmsg_remove_header(msg, "Contact");- tmp = get_contact(sip);- sipmsg_add_header(msg, "Contact", tmp);- purple_debug_info("simple", "got subscribe: name %s ourtag %s theirtag %s callid %s\n", watcher->name, watcher->dialog.ourtag, watcher->dialog.theirtag, watcher->dialog.callid);- send_sip_response(sip->gc, msg, 200, "Ok", NULL);- send_notify(sip, watcher);-static void process_input_message(struct simple_account_data *sip, struct sipmsg *msg) {- gboolean found = FALSE;- if(msg->response == 0) { /* request */- if(purple_strequal(msg->method, "MESSAGE")) {- process_incoming_message(sip, msg);- } else if(purple_strequal(msg->method, "NOTIFY")) {- process_incoming_notify(sip, msg);- } else if(purple_strequal(msg->method, "SUBSCRIBE")) {- process_incoming_subscribe(sip, msg);- send_sip_response(sip->gc, msg, 501, "Not implemented", NULL);- } else { /* response */- struct transaction *trans = transactions_find(sip, msg);- if(msg->response == 407) {- if(sip->proxy.retries > 3) return;- /* do proxy authentication */- ptmp = sipmsg_find_header(msg, "Proxy-Authenticate");- fill_auth(sip, ptmp, &sip->proxy);- auth = auth_header(sip, &sip->proxy, trans->msg->method, trans->msg->target);- sipmsg_remove_header(trans->msg, "Proxy-Authorization");- sipmsg_add_header(trans->msg, "Proxy-Authorization", auth);- resend = sipmsg_to_string(trans->msg, NULL);- sendout_pkt(sip->gc, resend);- if(msg->response == 100) {- /* ignore provisional response */- purple_debug_info("simple", "got trying response\n");- sip->proxy.retries = 0;- if(purple_strequal(trans->msg->method, "REGISTER")) {- /* This is encountered when a REGISTER request was ...- if(msg->response == 401) {- /* denied until further authentication was provided. */- sip->registrar.retries++;- else if (msg->response != 200) {- /* denied for some other reason! */- sip->registrar.retries++;- sip->registrar.retries = 0;- if(msg->response == 401) {- /* This is encountered when a generic (MESSAGE, NOTIFY, etc)- * was denied until further authorization is provided.- if(sip->registrar.retries > SIMPLE_REGISTER_RETRY_MAX) return;- sip->registrar.retries++;- ptmp = sipmsg_find_header(msg, "WWW-Authenticate");- fill_auth(sip, ptmp, &sip->registrar);- auth = auth_header(sip, &sip->registrar, trans->msg->method, trans->msg->target);- sipmsg_remove_header(trans->msg, "Authorization");- sipmsg_add_header(trans->msg, "Authorization", auth);- resend = sipmsg_to_string(trans->msg, NULL);- sendout_pkt(sip->gc, resend);- /* Reset any count of retries that may have- * accumulated in the above branch.- sip->registrar.retries = 0;- /* call the callback to process response*/- (trans->callback)(sip, msg, trans);- g_slist_remove(sip->transactions, trans);- transactions_destroy(trans);- purple_debug(PURPLE_DEBUG_MISC, "simple", "received response to unknown transaction");- purple_debug(PURPLE_DEBUG_MISC, "simple", "received a unknown sip message with method %s and response %d\n", msg->method, msg->response);-static void process_input(struct simple_account_data *sip, struct sip_connection *conn)- /* according to the RFC remove CRLF at the beginning */- while(*cur == '\r' || *cur == '\n') {- if(cur != conn->inbuf) {- memmove(conn->inbuf, cur, conn->inbufused - (cur - conn->inbuf));- conn->inbufused = strlen(conn->inbuf);- /* Received a full Header? */- if((cur = strstr(conn->inbuf, "\r\n\r\n")) != NULL) {- time_t currtime = time(NULL);- purple_debug_info("simple", "\n\nreceived - %s\n######\n%s\n#######\n\n", ctime(&currtime), conn->inbuf);- msg = sipmsg_parse_header(conn->inbuf);- /* Should we re-use this error message (from lower in the function)? */- purple_debug_misc("simple", "received a incomplete sip msg: %s\n", conn->inbuf);- restlen = conn->inbufused - (cur - conn->inbuf);- if(restlen >= msg->bodylen) {- dummy = g_new(char, msg->bodylen + 1);- memcpy(dummy, cur, msg->bodylen);- dummy[msg->bodylen] = '\0';- memmove(conn->inbuf, cur, conn->inbuflen - (cur - conn->inbuf));- conn->inbufused = strlen(conn->inbuf);- purple_debug(PURPLE_DEBUG_MISC, "simple", "in process response response: %d\n", msg->response);- process_input_message(sip, msg);- purple_debug(PURPLE_DEBUG_MISC, "simple", "received a incomplete sip msg: %s\n", conn->inbuf);-static void simple_udp_process(gpointer data, gint source, PurpleInputCondition con) {- PurpleConnection *gc = data;- struct simple_account_data *sip = purple_connection_get_protocol_data(gc);- time_t currtime = time(NULL);- static char buffer[65536];- if((len = recv(source, buffer, sizeof(buffer) - 1, 0)) > 0) {- purple_debug_info("simple", "\n\nreceived - %s\n######\n%s\n#######\n\n", ctime(&currtime), buffer);- msg = sipmsg_parse_msg(buffer);- process_input_message(sip, msg);-simple_input_cb(GObject *stream, gpointer data)- GInputStream *input = G_INPUT_STREAM(stream);- PurpleConnection *gc = data;- struct simple_account_data *sip = purple_connection_get_protocol_data(gc);- struct sip_connection *conn = connection_find(sip, input);- purple_debug_error("simple", "Connection not found!\n");- return G_SOURCE_REMOVE;- if(conn->inbuflen < conn->inbufused + SIMPLE_BUF_INC) {- conn->inbuflen += SIMPLE_BUF_INC;- conn->inbuf = g_realloc(conn->inbuf, conn->inbuflen);- len = g_pollable_input_stream_read_nonblocking(- G_POLLABLE_INPUT_STREAM(stream), conn->inbuf + conn->inbufused,- SIMPLE_BUF_INC - 1, sip->cancellable, &error);- if (error->code == G_IO_ERROR_WOULD_BLOCK) {- return G_SOURCE_CONTINUE;- } else if (error->code != G_IO_ERROR_CANCELLED) {- /* There has been an error reading from the socket */- purple_debug_info("simple", "simple_input_cb: read error");- if (sip->input == input) {- g_clear_object(&sip->input);- g_clear_object(&sip->output);- connection_remove(sip, input);- return G_SOURCE_REMOVE;- } else if (len == 0) { /* The other end has closed the socket */- purple_debug_warning("simple", "simple_input_cb: connection closed");- if (sip->input == input) {- g_clear_object(&sip->input);- g_clear_object(&sip->output);- connection_remove(sip, input);- return G_SOURCE_REMOVE;- purple_connection_update_last_received(gc);- conn->inbufused += len;- conn->inbuf[conn->inbufused] = '\0';- process_input(sip, conn);- return G_SOURCE_CONTINUE;-/* Callback for new connections on incoming TCP port */-simple_newconn_cb(G_GNUC_UNUSED GSocketService *service,- GSocketConnection *connection, GObject *source_object,- G_GNUC_UNUSED gpointer data)- PurpleConnection *gc = PURPLE_CONNECTION(source_object);- struct simple_account_data *sip = purple_connection_get_protocol_data(gc);- struct sip_connection *conn;- conn = connection_create(sip, g_object_ref(connection));- source = g_pollable_input_stream_create_source(- G_POLLABLE_INPUT_STREAM(sip->input), sip->cancellable);- g_source_set_callback(source, (GSourceFunc)simple_input_cb, gc, NULL);- conn->inputhandler = g_source_attach(source, NULL);- g_source_unref(source);-login_cb(GObject *sender, GAsyncResult *res, gpointer data)- PurpleConnection *gc = data;- struct simple_account_data *sip;- struct sip_connection *conn;- GSocketConnection *sockconn;- sockconn = g_socket_client_connect_to_host_finish(G_SOCKET_CLIENT(sender),- if (sockconn == NULL) {- if (g_error_matches(error, G_IO_ERROR, G_IO_ERROR_CANCELLED)) {- purple_connection_take_error(gc, error);- sip = purple_connection_get_protocol_data(gc);- sip->input = g_io_stream_get_input_stream(G_IO_STREAM(sockconn));- sip->output = purple_queued_output_stream_new(- g_io_stream_get_output_stream(G_IO_STREAM(sockconn)));- conn = connection_create(sip, sockconn);- sip->registertimeout = g_timeout_add_seconds(- g_random_int_range(10, 100), (GSourceFunc)subscribe_timeout, sip);- source = g_pollable_input_stream_create_source(- G_POLLABLE_INPUT_STREAM(sip->input), sip->cancellable);- g_source_set_callback(source, (GSourceFunc)simple_input_cb, gc, NULL);- conn->inputhandler = g_source_attach(source, NULL);- g_source_unref(source);-static guint simple_ht_hash_nick(const char *nick) {- char *lc = g_utf8_strdown(nick, -1);- guint bucket = g_str_hash(lc);-static gboolean simple_ht_equals_nick(const char *nick1, const char *nick2) {- return (purple_utf8_strcasecmp(nick1, nick2) == 0);-static void simple_udp_host_resolved_listen_cb(int listenfd, gpointer data) {- struct simple_account_data *sip = (struct simple_account_data*) data;- sip->listen_data = NULL;- purple_connection_error(sip->gc,- PURPLE_CONNECTION_ERROR_NETWORK_ERROR,- _("Unable to create listen socket"));- * TODO: Is it correct to set sip->fd to the listenfd? For the TCP- * listener we set sip->listenfd, but maybe UDP is different?- * Maybe we use the same fd for outgoing data or something?- sip->listenport = purple_network_get_port_from_fd(sip->fd);- sip->listenpa = purple_input_add(sip->fd, PURPLE_INPUT_READ, simple_udp_process, sip->gc);- sip->resendtimeout = g_timeout_add(2500, (GSourceFunc) resend_timeout, sip);- sip->registertimeout = g_timeout_add_seconds(- g_random_int_range(10, 100), (GSourceFunc)subscribe_timeout, sip);-simple_udp_host_resolved(GObject *sender, GAsyncResult *result, gpointer data) {- GList *addresses = NULL;- GInetAddress *inet_address = NULL;- GSocketAddress *socket_address = NULL;- struct simple_account_data *sip = (struct simple_account_data*) data;- addresses = g_resolver_lookup_by_name_finish(G_RESOLVER(sender),- gchar *msg = g_strdup_printf(_("Unable to resolve hostname : %s"),- purple_connection_error(sip->gc,- PURPLE_CONNECTION_ERROR_NETWORK_ERROR,- inet_address = G_INET_ADDRESS(addresses->data);- socket_address = g_inet_socket_address_new(inet_address, sip->realport);- g_object_unref(G_OBJECT(inet_address));- g_socket_address_to_native(socket_address,- g_socket_address_get_native_size(socket_address),- g_object_unref(G_OBJECT(socket_address));- g_resolver_free_addresses(addresses);- /* create socket for incoming connections */- sip->listen_data = purple_network_listen_range(5060, 5160, AF_UNSPEC, SOCK_DGRAM, TRUE,- simple_udp_host_resolved_listen_cb, sip);- if (sip->listen_data == NULL) {- purple_connection_error(sip->gc,- PURPLE_CONNECTION_ERROR_NETWORK_ERROR,- _("Unable to create listen socket"));-srvresolved(GObject *sender, GAsyncResult *result, gpointer data) {- struct simple_account_data *sip;- targets = g_resolver_lookup_service_finish(G_RESOLVER(sender),- purple_debug_info("simple",- "srv lookup failed, continuing with configured settings : %s",- if(!purple_account_get_bool(sip->account, "useproxy", FALSE)) {- hostname = g_strdup(sip->servername);- hostname = g_strdup(purple_account_get_string(sip->account, "proxy", sip->servername));- port = purple_account_get_int(sip->account, "port", 0);- GSrvTarget *target = (GSrvTarget *)targets->data;- hostname = g_strdup(g_srv_target_get_hostname(target));- port = g_srv_target_get_port(target);- g_resolver_free_targets(targets);- sip->realhostname = hostname;- /* create service for incoming connections */- sip->service = g_socket_service_new();- sip->listenport = purple_socket_listener_add_any_inet_port(- G_SOCKET_LISTENER(sip->service), G_OBJECT(sip->gc), &error);- if (sip->listenport == 0) {- purple_connection_take_error(sip->gc, error);- g_signal_connect(sip->service, "incoming",- G_CALLBACK(simple_newconn_cb), NULL);- purple_debug_info("simple", "connecting to %s port %d",- sip->realhostname, sip->realport);- client = purple_gio_socket_client_new(sip->account, &error);- purple_connection_take_error(sip->gc, error);- /* open tcp connection to the server */- g_socket_client_connect_to_host_async(client, sip->realhostname,- sip->realport, sip->cancellable,- g_object_unref(client);- GResolver *resolver = g_resolver_get_default();- purple_debug_info("simple", "using udp with server %s and port %d\n", hostname, port);- g_resolver_lookup_by_name_async(resolver,- simple_udp_host_resolved,- g_object_unref(resolver);-static void simple_login(PurpleAccount *account)- struct simple_account_data *sip;- const gchar *hosttoconnect;- const char *username = purple_account_get_username(account);- gc = purple_account_get_connection(account);- purple_connection_set_flags(gc, PURPLE_CONNECTION_FLAG_NO_IMAGES);- if (strpbrk(username, " \t\v\r\n") != NULL) {- purple_connection_error(gc,- PURPLE_CONNECTION_ERROR_INVALID_SETTINGS,- _("SIP usernames may not contain whitespaces or @ symbols"));- sip = g_new0(struct simple_account_data, 1);- purple_connection_set_protocol_data(gc, sip);- sip->account = account;- sip->registerexpire = 900;- sip->udp = purple_account_get_bool(account, "udp", FALSE);- /* TODO: is there a good default grow size? */- sip->txbuf = purple_circular_buffer_new(0);- userserver = g_strsplit(username, "@", 2);- if (userserver[1] == NULL || userserver[1][0] == '\0') {- purple_connection_error(gc,- PURPLE_CONNECTION_ERROR_INVALID_SETTINGS,- _("SIP connect server not specified"));- g_strfreev(userserver);- purple_connection_set_display_name(gc, userserver[0]);- sip->username = g_strdup(userserver[0]);- sip->servername = g_strdup(userserver[1]);- sip->password = g_strdup(purple_connection_get_password(gc));- g_strfreev(userserver);- sip->buddies = g_hash_table_new((GHashFunc)simple_ht_hash_nick, (GEqualFunc)simple_ht_equals_nick);- purple_connection_update_progress(gc, _("Connecting"), 1, 2);- /* TODO: Set the status correctly. */- sip->status = g_strdup("available");- if(!purple_account_get_bool(account, "useproxy", FALSE)) {- hosttoconnect = sip->servername;- hosttoconnect = purple_account_get_string(account, "proxy", sip->servername);- resolver = g_resolver_get_default();- g_resolver_lookup_service_async(resolver,- sip->udp ? "udp" : "tcp",- g_object_unref(resolver);-static void simple_close(PurpleConnection *gc)- struct simple_account_data *sip = purple_connection_get_protocol_data(gc);- if (sip->registerstatus == SIMPLE_REGISTER_COMPLETE)- g_hash_table_foreach(sip->buddies,- (GHFunc)simple_unsubscribe,- if (purple_account_get_bool(sip->account, "dopublish", TRUE))- send_closed_publish(sip);- do_register_exp(sip, 0);- g_slist_free_full(sip->openconns, (GDestroyNotify)connection_destroy);- purple_input_remove(sip->listenpa);- if (sip->resendtimeout)- g_source_remove(sip->resendtimeout);- if (sip->registertimeout)- g_source_remove(sip->registertimeout);- g_cancellable_cancel(sip->cancellable);- g_object_unref(G_OBJECT(sip->cancellable));- g_socket_service_stop(sip->service);- g_clear_object(&sip->service);- if (sip->listen_data != NULL)- purple_network_listen_cancel(sip->listen_data);- g_clear_object(&sip->input);- g_clear_object(&sip->output);- g_free(sip->servername);- g_free(sip->registrar.nonce);- g_free(sip->registrar.opaque);- g_free(sip->registrar.target);- g_free(sip->registrar.realm);- g_free(sip->registrar.digest_session_key);- g_free(sip->proxy.nonce);- g_free(sip->proxy.opaque);- g_free(sip->proxy.target);- g_free(sip->proxy.realm);- g_free(sip->proxy.digest_session_key);- g_hash_table_destroy(sip->buddies);- g_free(sip->regcallid);- g_slist_free_full(sip->transactions, (GDestroyNotify)transactions_destroy);- g_slist_free_full(sip->watcher, (GDestroyNotify)watcher_destroy);- g_free(sip->publish_etag);- g_object_unref(G_OBJECT(sip->txbuf));- g_free(sip->realhostname);- purple_connection_set_protocol_data(gc, NULL);-simple_protocol_init(SIMPLEProtocol *self)- PurpleProtocol *protocol = PURPLE_PROTOCOL(self);- PurpleAccountUserSplit *split;- PurpleAccountOption *option;- protocol->id = "prpl-simple";- protocol->name = "SIMPLE";- split = purple_account_user_split_new(_("Server"), "", '@');- protocol->user_splits = g_list_append(protocol->user_splits, split);- option = purple_account_option_bool_new(_("Publish status (note: everyone may watch you)"), "dopublish", TRUE);- protocol->account_options = g_list_append(protocol->account_options, option);- option = purple_account_option_int_new(_("Connect port"), "port", 0);- protocol->account_options = g_list_append(protocol->account_options, option);- option = purple_account_option_bool_new(_("Use UDP"), "udp", FALSE);- protocol->account_options = g_list_append(protocol->account_options, option);- option = purple_account_option_bool_new(_("Use proxy"), "useproxy", FALSE);- protocol->account_options = g_list_append(protocol->account_options, option);- option = purple_account_option_string_new(_("Proxy"), "proxy", "");- protocol->account_options = g_list_append(protocol->account_options, option);- option = purple_account_option_string_new(_("Auth User"), "authuser", "");- protocol->account_options = g_list_append(protocol->account_options, option);- option = purple_account_option_string_new(_("Auth Domain"), "authdomain", "");- protocol->account_options = g_list_append(protocol->account_options, option);-simple_protocol_class_init(SIMPLEProtocolClass *klass)- PurpleProtocolClass *protocol_class = PURPLE_PROTOCOL_CLASS(klass);- protocol_class->login = simple_login;- protocol_class->close = simple_close;- protocol_class->status_types = simple_status_types;- protocol_class->list_icon = simple_list_icon;-simple_protocol_class_finalize(G_GNUC_UNUSED SIMPLEProtocolClass *klass)-simple_protocol_server_iface_init(PurpleProtocolServerInterface *server_iface)- server_iface->set_status = simple_set_status;- server_iface->add_buddy = simple_add_buddy;- server_iface->remove_buddy = simple_remove_buddy;- server_iface->keepalive = simple_keep_alive;- server_iface->send_raw = simple_send_raw;-simple_protocol_im_iface_init(PurpleProtocolIMInterface *im_iface)- im_iface->send = simple_im_send;- im_iface->send_typing = simple_typing;-G_DEFINE_DYNAMIC_TYPE_EXTENDED(- SIMPLEProtocol, simple_protocol, PURPLE_TYPE_PROTOCOL, 0,- G_IMPLEMENT_INTERFACE_DYNAMIC(PURPLE_TYPE_PROTOCOL_SERVER,- simple_protocol_server_iface_init)- G_IMPLEMENT_INTERFACE_DYNAMIC(PURPLE_TYPE_PROTOCOL_IM,- simple_protocol_im_iface_init));-static PurplePluginInfo *-plugin_query(GError **error)- const gchar * const authors[] = {- "Thomas Butter <butter@uni-mannheim.de>",- return purple_plugin_info_new(- "name", "SIMPLE Protocol",- "version", DISPLAY_VERSION,- "category", N_("Protocol"),- "summary", N_("SIP/SIMPLE Protocol Plugin"),- "description", N_("The SIP/SIMPLE Protocol Plugin"),- "website", PURPLE_WEBSITE,- "abi-version", PURPLE_ABI_VERSION,- "flags", PURPLE_PLUGIN_INFO_FLAGS_INTERNAL |- PURPLE_PLUGIN_INFO_FLAGS_AUTO_LOAD,-plugin_load(PurplePlugin *plugin, GError **error)- simple_protocol_register_type(G_TYPE_MODULE(plugin));- my_protocol = purple_protocols_add(SIMPLE_TYPE_PROTOCOL, error);- purple_signal_connect(purple_get_core(), "uri-handler", plugin,- PURPLE_CALLBACK(simple_uri_handler), NULL);-plugin_unload(PurplePlugin *plugin, GError **error)- purple_signal_disconnect(purple_get_core(), "uri-handler", plugin,- PURPLE_CALLBACK(simple_uri_handler));- if (!purple_protocols_remove(my_protocol, error))-PURPLE_PLUGIN_INIT(simple, plugin_query, plugin_load, plugin_unload);--- a/libpurple/protocols/simple/simple.h Mon Oct 26 20:18:35 2020 -0500
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,154 +0,0 @@
- * Copyright (C) 2005, Thomas Butter <butter@uni-mannheim.de>- * 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-#ifndef PURPLE_SIMPLE_SIMPLE_H-#define PURPLE_SIMPLE_SIMPLE_H-#define SIMPLE_BUF_INC 1024-#define SIMPLE_REGISTER_RETRY_MAX 2-#define SIMPLE_REGISTER_SENT 1-#define SIMPLE_REGISTER_RETRY 2-#define SIMPLE_REGISTER_COMPLETE 3-#define PUBLISH_EXPIRATION 600-#define SUBSCRIBE_EXPIRATION 1200-#define SIMPLE_TYPE_PROTOCOL (simple_protocol_get_type())-#define SIMPLE_PROTOCOL(obj) (G_TYPE_CHECK_INSTANCE_CAST((obj), SIMPLE_TYPE_PROTOCOL, SIMPLEProtocol))-#define SIMPLE_PROTOCOL_CLASS(klass) (G_TYPE_CHECK_CLASS_CAST((klass), SIMPLE_TYPE_PROTOCOL, SIMPLEProtocolClass))-#define SIMPLE_IS_PROTOCOL(obj) (G_TYPE_CHECK_INSTANCE_TYPE((obj), SIMPLE_TYPE_PROTOCOL))-#define SIMPLE_IS_PROTOCOL_CLASS(klass) (G_TYPE_CHECK_CLASS_TYPE((klass), SIMPLE_TYPE_PROTOCOL))-#define SIMPLE_PROTOCOL_GET_CLASS(obj) (G_TYPE_INSTANCE_GET_CLASS((obj), SIMPLE_TYPE_PROTOCOL, SIMPLEProtocolClass))- PurpleProtocolClass parent_class;- struct sip_dialog dialog;- struct sip_dialog *dialog;- int type; /* 1 = Digest / 2 = NTLM */- gchar *digest_session_key;-struct simple_account_data {- GCancellable *cancellable;- PurpleQueuedOutputStream *output;- GSocketService *service;- PurpleNetworkListenData *listen_data;- int registerstatus; /* 0 nothing, 1 first registration send, 2 auth received, 3 registered */- struct sip_auth registrar;- PurpleAccount *account;- PurpleCircularBuffer *txbuf;- struct sockaddr_in serveraddr;- int realport; /* port and hostname from SRV record */- GSocketConnection *sockconn;-typedef gboolean (*TransCallback) (struct simple_account_data *, struct sipmsg *, struct transaction *);- int transport; /* 0 = tcp, 1 = udp */- TransCallback callback;-G_MODULE_EXPORT GType simple_protocol_get_type(void);-#endif /* PURPLE_SIMPLE_SIMPLE_H */--- a/libpurple/protocols/simple/sipmsg.c Mon Oct 26 20:18:35 2020 -0500
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,224 +0,0 @@
- * Copyright (C) 2005 Thomas Butter <butter@uni-mannheim.de>- * 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-#define MAX_CONTENT_LENGTH 30000000-struct sipmsg *sipmsg_parse_msg(const gchar *msg) {- const char *tmp = strstr(msg, "\r\n\r\n");- line = g_strndup(msg, tmp - msg);- smsg = sipmsg_parse_header(line);- smsg->body = g_strdup(tmp + 4);- purple_debug_error("SIMPLE", "No header parsed from line: %s\n", line);-struct sipmsg *sipmsg_parse_header(const gchar *header) {- gchar **parts, **lines;- gchar *dummy, *dummy2, *tmp;- lines = g_strsplit(header,"\r\n",0);- parts = g_strsplit(lines[0], " ", 3);- if(!parts[0] || !parts[1] || !parts[2]) {- msg = g_new0(struct sipmsg,1);- if(strstr(parts[0],"SIP")) { /* numeric response */- msg->method = g_strdup(parts[2]);- msg->response = strtol(parts[1],NULL,10);- msg->method = g_strdup(parts[0]);- msg->target = g_strdup(parts[1]);- for(i=1; lines[i] && strlen(lines[i])>2; i++) {- parts = g_strsplit(lines[i], ":", 2);- if(!parts[0] || !parts[1]) {- while(*dummy==' ' || *dummy=='\t') dummy++;- dummy2 = g_strdup(dummy);- while(lines[i+1] && (lines[i+1][0]==' ' || lines[i+1][0]=='\t')) {- while(*dummy==' ' || *dummy=='\t') dummy++;- tmp = g_strdup_printf("%s %s",dummy2, dummy);- sipmsg_add_header(msg, parts[0], dummy2);- tmp2 = sipmsg_find_header(msg, "Content-Length");- msg->bodylen = strtol(tmp2, NULL, 10);- if (msg->bodylen < 0) {- purple_debug_warning("simple", "Invalid body length: %d",- } else if (msg->bodylen > MAX_CONTENT_LENGTH) {- purple_debug_warning("simple", "Got Content-Length of %d bytes on "- "incoming message (max is %u bytes). Ignoring message body.\n",- msg->bodylen, MAX_CONTENT_LENGTH);- tmp2 = sipmsg_find_header(msg, "CSeq");- /* SHOULD NOT HAPPEN */- parts = g_strsplit(tmp2, " ", 2);- msg->method = g_strdup(parts[1]);-void sipmsg_print(const struct sipmsg *msg) {- PurpleKeyValuePair *elem;- purple_debug_misc("simple", "SIP MSG");- purple_debug_misc("simple", "response: %d\nmethod: %s\nbodylen: %d",- msg->response, msg->method, msg->bodylen);- purple_debug_misc("simple", "target: %s", msg->target);- purple_debug_misc("simple", "name: %s value: %s", elem->key,- cur = g_slist_next(cur);-sipmsg_to_string(const struct sipmsg *msg, const gchar *status_text)- GString *outstr = g_string_new("");- PurpleKeyValuePair *elem;- g_string_append_printf(outstr, "SIP/2.0 %d %s\r\n", msg->response,- status_text ? status_text : "Unknown");- g_string_append_printf(outstr, "%s %s SIP/2.0\r\n",- msg->method, msg->target);- g_string_append_printf(outstr, "%s: %s\r\n", elem->key,- cur = g_slist_next(cur);- g_string_append_printf(outstr, "\r\n%s", msg->bodylen ? msg->body : "");- return g_string_free(outstr, FALSE);-sipmsg_add_header(struct sipmsg *msg, const gchar *name, const gchar *value)- PurpleKeyValuePair *element =- purple_key_value_pair_new_full(name, g_strdup(value), g_free);- msg->headers = g_slist_append(msg->headers, element);-void sipmsg_free(struct sipmsg *msg) {- g_slist_free_full(msg->headers, (GDestroyNotify)purple_key_value_pair_free);-compare_header_names(gconstpointer a, gconstpointer b)- const PurpleKeyValuePair *kvpa = a;- return g_ascii_strcasecmp(kvpa->key, name);-sipmsg_remove_header(struct sipmsg *msg, const gchar *name)- GSList *tmp = g_slist_find_custom(msg->headers, name, compare_header_names);- PurpleKeyValuePair *elem = tmp->data;- msg->headers = g_slist_delete_link(msg->headers, tmp);- purple_key_value_pair_free(elem);-sipmsg_find_header(struct sipmsg *msg, const gchar *name)- GSList *tmp = g_slist_find_custom(msg->headers, name, compare_header_names);- PurpleKeyValuePair *elem = tmp->data;--- a/libpurple/protocols/simple/sipmsg.h Mon Oct 26 20:18:35 2020 -0500
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,44 +0,0 @@
- * Copyright (C) 2005, Thomas Butter <butter@uni-mannheim.de>- * 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-#ifndef PURPLE_SIMPLE_SIPMSG_H-#define PURPLE_SIMPLE_SIPMSG_H- int response; /* 0 means request, otherwise response code */-struct sipmsg *sipmsg_parse_msg(const gchar *msg);-struct sipmsg *sipmsg_parse_header(const gchar *header);-void sipmsg_add_header(struct sipmsg *msg, const gchar *name, const gchar *value);-void sipmsg_free(struct sipmsg *msg);-const gchar *sipmsg_find_header(struct sipmsg *msg, const gchar *name);-void sipmsg_remove_header(struct sipmsg *msg, const gchar *name);-void sipmsg_print(const struct sipmsg *msg);-gchar *sipmsg_to_string(const struct sipmsg *msg, const gchar *status_text);-#endif /* PURPLE_SIMPLE_SIPMSG_H */--- a/meson.build Mon Oct 26 20:18:35 2020 -0500
+++ b/meson.build Thu Oct 29 21:44:26 2020 -0500
@@ -454,7 +454,7 @@
DEFAULT_PRPLS = ['bonjour', 'facebook', 'gg', 'irc', 'jabber', 'novell',
- 'null', 'sametime', 'silc', 'simple', 'zephyr']+ 'null', 'sametime', 'silc', 'zephyr'] ALL_PRPLS = DEFAULT_PRPLS + ['null']
dynamic_list = get_option('dynamic-prpls').split(',')
@@ -489,7 +489,6 @@
DYNAMIC_NULL = DYNAMIC_PRPLS.contains('null')
DYNAMIC_SAMETIME = DYNAMIC_PRPLS.contains('sametime')
DYNAMIC_SILC = DYNAMIC_PRPLS.contains('silc')
-DYNAMIC_SIMPLE = DYNAMIC_PRPLS.contains('simple') DYNAMIC_ZEPHYR = DYNAMIC_PRPLS.contains('zephyr')
conf.set('HAVE_SYS_UTSNAME_H',
--- a/po/POTFILES.in Mon Oct 26 20:18:35 2020 -0500
+++ b/po/POTFILES.in Thu Oct 29 21:44:26 2020 -0500
@@ -215,9 +215,6 @@
libpurple/protocols/silc/silc.c
libpurple/protocols/silc/util.c
libpurple/protocols/silc/wb.c
-libpurple/protocols/simple/ntlm.c-libpurple/protocols/simple/simple.c-libpurple/protocols/simple/sipmsg.c libpurple/protocols/zephyr/ZAsyncLocate.c
libpurple/protocols/zephyr/ZCkAuth.c
libpurple/protocols/zephyr/ZCkIfNot.c
