--- a/libpurple/protocols/bonjour/dns_sd.c Wed Jun 06 00:17:06 2007 +0000
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,387 +0,0 @@
-/*
- * 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 Library 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., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
- */
-
-#include <string.h>
-
-#include "dns_sd.h"
-#include "bonjour.h"
-#include "buddy.h"
-#include "debug.h"
-
-/* Private functions */
-
-static sw_result HOWL_API
-_publish_reply(sw_discovery discovery, sw_discovery_oid oid,
- sw_discovery_publish_status status, sw_opaque extra)
-{
- purple_debug_warning("bonjour", "_publish_reply --> Start\n");
-
- /* Check the answer from the mDNS daemon */
- switch (status)
- {
- case SW_DISCOVERY_PUBLISH_STARTED :
- purple_debug_info("bonjour", "_publish_reply --> Service started\n");
- break;
- case SW_DISCOVERY_PUBLISH_STOPPED :
- purple_debug_info("bonjour", "_publish_reply --> Service stopped\n");
- break;
- case SW_DISCOVERY_PUBLISH_NAME_COLLISION :
- purple_debug_info("bonjour", "_publish_reply --> Name collision\n");
- break;
- case SW_DISCOVERY_PUBLISH_INVALID :
- purple_debug_info("bonjour", "_publish_reply --> Service invalid\n");
- break;
- }
-
- return SW_OKAY;
-}
-
-static sw_result HOWL_API
-_resolve_reply(sw_discovery discovery, sw_discovery_oid oid,
- sw_uint32 interface_index, sw_const_string name,
- sw_const_string type, sw_const_string domain,
- sw_ipv4_address address, sw_port port,
- sw_octets text_record, sw_ulong text_record_len,
- sw_opaque extra)
-{
- BonjourBuddy *buddy;
- PurpleAccount *account = (PurpleAccount*)extra;
- gchar *txtvers = NULL;
- gchar *version = NULL;
- gchar *first = NULL;
- gchar *phsh = NULL;
- gchar *status = NULL;
- gchar *email = NULL;
- gchar *last = NULL;
- gchar *jid = NULL;
- gchar *AIM = NULL;
- gchar *vc = NULL;
- gchar *msg = NULL;
- gint address_length = 16;
- gchar *ip = NULL;
- sw_text_record_iterator iterator;
- char key[SW_TEXT_RECORD_MAX_LEN];
- char value[SW_TEXT_RECORD_MAX_LEN];
- sw_uint32 value_length;
-
- sw_discovery_cancel(discovery, oid);
-
- /* Get the ip as a string */
- ip = malloc(address_length);
- sw_ipv4_address_name(address, ip, address_length);
-
- /* Obtain the parameters from the text_record */
- if ((text_record_len > 0) && (text_record) && (*text_record != '\0'))
- {
- sw_text_record_iterator_init(&iterator, text_record, text_record_len);
- while (sw_text_record_iterator_next(iterator, key, (sw_octet *)value, &value_length) == SW_OKAY)
- {
- /* Compare the keys with the possible ones and save them on */
- /* the appropiate place of the buddy_list */
- if (strcmp(key, "txtvers") == 0) {
- txtvers = g_strdup(value);
- } else if (strcmp(key, "version") == 0) {
- version = g_strdup(value);
- } else if (strcmp(key, "1st") == 0) {
- first = g_strdup(value);
- } else if (strcmp(key, "status") == 0) {
- status = g_strdup(value);
- } else if (strcmp(key, "email") == 0) {
- email = g_strdup(value);
- } else if (strcmp(key, "last") == 0) {
- last = g_strdup(value);
- } else if (strcmp(key, "jid") == 0) {
- jid = g_strdup(value);
- } else if (strcmp(key, "AIM") == 0) {
- AIM = g_strdup(value);
- } else if (strcmp(key, "vc") == 0) {
- vc = g_strdup(value);
- } else if (strcmp(key, "phsh") == 0) {
- phsh = g_strdup(value);
- } else if (strcmp(key, "msg") == 0) {
- msg = g_strdup(value);
- }
- }
- }
-
- /* Put the parameters of the text_record in a buddy and add the buddy to */
- /* the buddy list */
- buddy = bonjour_buddy_new(name, first, port, phsh,
- status, email, last, jid, AIM, vc, ip, msg);
-
- if (bonjour_buddy_check(buddy) == FALSE)
- {
- bonjour_buddy_delete(buddy);
- return SW_DISCOVERY_E_UNKNOWN;
- }
-
- /* Add or update the buddy in our buddy list */
- bonjour_buddy_add_to_purple(account, buddy);
-
- /* Free all the temporal strings */
- g_free(txtvers);
- g_free(version);
- g_free(first);
- g_free(last);
- g_free(status);
- g_free(email);
- g_free(jid);
- g_free(AIM);
- g_free(vc);
- g_free(phsh);
- g_free(msg);
-
- return SW_OKAY;
-}
-
-static sw_result HOWL_API
-_browser_reply(sw_discovery discovery, sw_discovery_oid oid,
- sw_discovery_browse_status status,
- sw_uint32 interface_index, sw_const_string name,
- sw_const_string type, sw_const_string domain,
- sw_opaque_t extra)
-{
- sw_discovery_resolve_id rid;
- PurpleAccount *account = (PurpleAccount*)extra;
- PurpleBuddy *gb = NULL;
-
- switch (status)
- {
- case SW_DISCOVERY_BROWSE_INVALID:
- purple_debug_warning("bonjour", "_browser_reply --> Invalid\n");
- break;
- case SW_DISCOVERY_BROWSE_RELEASE:
- purple_debug_warning("bonjour", "_browser_reply --> Release\n");
- break;
- case SW_DISCOVERY_BROWSE_ADD_DOMAIN:
- purple_debug_warning("bonjour", "_browser_reply --> Add domain\n");
- break;
- case SW_DISCOVERY_BROWSE_ADD_DEFAULT_DOMAIN:
- purple_debug_warning("bonjour", "_browser_reply --> Add default domain\n");
- break;
- case SW_DISCOVERY_BROWSE_REMOVE_DOMAIN:
- purple_debug_warning("bonjour", "_browser_reply --> Remove domain\n");
- break;
- case SW_DISCOVERY_BROWSE_ADD_SERVICE:
- /* A new peer has joined the network and uses iChat bonjour */
- purple_debug_info("bonjour", "_browser_reply --> Add service\n");
- if (g_ascii_strcasecmp(name, account->username) != 0)
- {
- if (sw_discovery_resolve(discovery, interface_index, name, type,
- domain, _resolve_reply, extra, &rid) != SW_OKAY)
- {
- purple_debug_warning("bonjour", "_browser_reply --> Cannot send resolve\n");
- }
- }
- break;
- case SW_DISCOVERY_BROWSE_REMOVE_SERVICE:
- purple_debug_info("bonjour", "_browser_reply --> Remove service\n");
- gb = purple_find_buddy((PurpleAccount*)extra, name);
- if (gb != NULL)
- {
- bonjour_buddy_delete(gb->proto_data);
- purple_blist_remove_buddy(gb);
- }
- break;
- case SW_DISCOVERY_BROWSE_RESOLVED:
- purple_debug_info("bonjour", "_browse_reply --> Resolved\n");
- break;
- default:
- break;
- }
-
- return SW_OKAY;
-}
-
-static int
-_dns_sd_publish(BonjourDnsSd *data, PublishType type)
-{
- sw_text_record dns_data;
- sw_result publish_result = SW_OKAY;
- char portstring[6];
-
- /* Fill the data for the service */
- if (sw_text_record_init(&dns_data) != SW_OKAY)
- {
- purple_debug_error("bonjour", "Unable to initialize the data for the mDNS.\n");
- return -1;
- }
-
- /* Convert the port to a string */
- snprintf(portstring, sizeof(portstring), "%d", data->port_p2pj);
-
- /* Publish standard records */
- sw_text_record_add_key_and_string_value(dns_data, "txtvers", data->txtvers);
- sw_text_record_add_key_and_string_value(dns_data, "version", data->version);
- sw_text_record_add_key_and_string_value(dns_data, "1st", data->first);
- sw_text_record_add_key_and_string_value(dns_data, "last", data->last);
- sw_text_record_add_key_and_string_value(dns_data, "port.p2pj", portstring);
- sw_text_record_add_key_and_string_value(dns_data, "phsh", data->phsh);
- sw_text_record_add_key_and_string_value(dns_data, "status", data->status);
- sw_text_record_add_key_and_string_value(dns_data, "vc", data->vc);
-
- /* Publish extra records */
- if ((data->email != NULL) && (*data->email != '\0'))
- sw_text_record_add_key_and_string_value(dns_data, "email", data->email);
-
- if ((data->jid != NULL) && (*data->jid != '\0'))
- sw_text_record_add_key_and_string_value(dns_data, "jid", data->jid);
-
- if ((data->AIM != NULL) && (*data->AIM != '\0'))
- sw_text_record_add_key_and_string_value(dns_data, "AIM", data->AIM);
-
- if ((data->msg != NULL) && (*data->msg != '\0'))
- sw_text_record_add_key_and_string_value(dns_data, "msg", data->msg);
-
- /* Publish the service */
- switch (type)
- {
- case PUBLISH_START:
- publish_result = sw_discovery_publish(data->session, 0, data->name, ICHAT_SERVICE, NULL,
- NULL, data->port_p2pj, sw_text_record_bytes(dns_data), sw_text_record_len(dns_data),
- _publish_reply, NULL, &data->session_id);
- break;
- case PUBLISH_UPDATE:
- publish_result = sw_discovery_publish_update(data->session, data->session_id,
- sw_text_record_bytes(dns_data), sw_text_record_len(dns_data));
- break;
- }
- if (publish_result != SW_OKAY)
- {
- purple_debug_error("bonjour", "Unable to publish or change the status of the _presence._tcp service.\n");
- return -1;
- }
-
- /* Free the memory used by temp data */
- sw_text_record_fina(dns_data);
-
- return 0;
-}
-
-static void
-_dns_sd_handle_packets(gpointer data, gint source, PurpleInputCondition condition)
-{
- sw_discovery_read_socket((sw_discovery)data);
-}
-
-/* End private functions */
-
-/**
- * Allocate space for the dns-sd data.
- */
-BonjourDnsSd *
-bonjour_dns_sd_new()
-{
- BonjourDnsSd *data = g_new0(BonjourDnsSd, 1);
-
- return data;
-}
-
-/**
- * Deallocate the space of the dns-sd data.
- */
-void
-bonjour_dns_sd_free(BonjourDnsSd *data)
-{
- g_free(data->first);
- g_free(data->last);
- g_free(data->email);
- g_free(data);
-}
-
-/**
- * Send a new dns-sd packet updating our status.
- */
-void
-bonjour_dns_sd_send_status(BonjourDnsSd *data, const char *status, const char *status_message)
-{
- g_free(data->status);
- g_free(data->msg);
-
- data->status = g_strdup(status);
- data->msg = g_strdup(status_message);
-
- /* Update our text record with the new status */
- _dns_sd_publish(data, PUBLISH_UPDATE); /* <--We must control the errors */
-}
-
-/**
- * Advertise our presence within the dns-sd daemon and start browsing
- * for other bonjour peers.
- */
-gboolean
-bonjour_dns_sd_start(BonjourDnsSd *data)
-{
- PurpleAccount *account;
- PurpleConnection *gc;
- gint dns_sd_socket;
- sw_discovery_oid session_id;
-
- account = data->account;
- gc = purple_account_get_connection(account);
-
- /* Initialize the dns-sd data and session */
- if (sw_discovery_init(&data->session) != SW_OKAY)
- {
- purple_debug_error("bonjour", "Unable to initialize an mDNS session.\n");
-
- /* In Avahi, sw_discovery_init frees data->session but doesn't clear it */
- data->session = NULL;
-
- return FALSE;
- }
-
- /* Publish our bonjour IM client at the mDNS daemon */
- _dns_sd_publish(data, PUBLISH_START); /* <--We must control the errors */
-
- /* Advise the daemon that we are waiting for connections */
- if (sw_discovery_browse(data->session, 0, ICHAT_SERVICE, NULL, _browser_reply,
- data->account, &session_id) != SW_OKAY)
- {
- purple_debug_error("bonjour", "Unable to get service.");
- return FALSE;
- }
-
- /* Get the socket that communicates with the mDNS daemon and bind it to a */
- /* callback that will handle the dns_sd packets */
- dns_sd_socket = sw_discovery_socket(data->session);
- gc->inpa = purple_input_add(dns_sd_socket, PURPLE_INPUT_READ,
- _dns_sd_handle_packets, data->session);
-
- return TRUE;
-}
-
-/**
- * Unregister the "_presence._tcp" service at the mDNS daemon.
- */
-void
-bonjour_dns_sd_stop(BonjourDnsSd *data)
-{
- PurpleAccount *account;
- PurpleConnection *gc;
-
- if (data->session == NULL)
- return;
-
- sw_discovery_cancel(data->session, data->session_id);
-
- account = data->account;
- gc = purple_account_get_connection(account);
- purple_input_remove(gc->inpa);
-
- g_free(data->session);
- data->session = NULL;
-}