comparison libgaim/upnp.c @ 14354:01daacf7b771

[gaim-migrate @ 17060] Make gaim_url_fetch() cancelable and change Yahoo! to take advantage of the changes. Other stuff can be changed later, the important thing is that the API is there. committer: Tailor Script <[e-mail]>

14353:33dc9f22b528

static void gaim_upnp_discover_send_broadcast(UPnPDiscoveryData *dd);
static void lookup_public_ip(void);
static void lookup_internal_ip(void);


static void
fire_discovery_callbacks(gboolean success)
{
	while(discovery_callbacks) {
		gpointer data;

		discovery_callbacks = g_slist_remove(discovery_callbacks, data);
		cb(success, data);
	}
}


static gboolean
gaim_upnp_compare_device(const xmlnode* device, const gchar* deviceType)
{
	xmlnode* deviceTypeNode = xmlnode_get_child(device, "deviceType");
	char *tmp;

	g_free(tmp);

	return ret;
}


static gboolean
gaim_upnp_compare_service(const xmlnode* service, const gchar* serviceType)
{
	xmlnode* serviceTypeNode;
	char *tmp;

	ret = !g_ascii_strcasecmp(tmp, serviceType);
	g_free(tmp);

	return ret;
}


static gchar*
gaim_upnp_parse_description_response(const gchar* httpResponse, gsize len,
	const gchar* httpURL, const gchar* serviceType)
{

	return controlURL;
}

static void
upnp_parse_description_cb(void *data, const char *httpResponse, gsize len)
{
	UPnPDiscoveryData *dd = data;
	gchar *control_url = NULL;

	if (len > 0)
		control_url = gaim_upnp_parse_description_response(
			httpResponse, len, dd->full_url, dd->service_type);

	/* Remove the timeout because everything it is waiting for has
	 * successfully completed */
	gaim_timeout_remove(dd->tima);
	dd->tima = 0;

	gaim_url_fetch_request(descriptionURL, TRUE, NULL, TRUE, httpRequest,
			TRUE, upnp_parse_description_cb, dd);

	g_free(httpRequest);

}

	gaim_upnp_parse_discover_response(buf, len, dd);

	/* We'll either time out or continue successfully */
}

void
gaim_upnp_discover_send_broadcast(UPnPDiscoveryData *dd)
{
	gchar *sendMessage = NULL;
	gsize totalSize;
	gboolean sentSuccess;

	/* We have already done all our retries. Make sure that the callback
	 * doesn't get called before the original function returns */
	gaim_timeout_add(10, gaim_upnp_discover_timeout, dd);
}


void
gaim_upnp_discover(GaimUPnPCallback cb, gpointer cb_data)
{
	/* Socket Setup Variables */
	int sock;

	gaim_upnp_discover_send_broadcast(dd);
}

static void
gaim_upnp_generate_action_message_and_send(const gchar* actionName,
		const gchar* actionParams, GaimURLFetchCallback cb,
		gpointer cb_data)
{

	gchar* soapMessage;
	gchar* totalSendMessage;

			&port, &pathOfControl, NULL, NULL)) {
		gaim_debug_error("upnp",
			"generate_action_message_and_send(): Failed In Parse URL\n\n");
		/* XXX: This should probably be async */
		if(cb)
			cb(cb_data, NULL, 0);
	}
	if(port == 0 || port == -1) {
		port = DEFAULT_HTTP_PORT;
	}

		control_info.service_type, actionName,
		strlen(soapMessage), soapMessage);
	g_free(pathOfControl);
	g_free(soapMessage);

	gaim_url_fetch_request(control_info.control_url, FALSE, NULL, TRUE,
			totalSendMessage, TRUE, cb, cb_data);

	g_free(totalSendMessage);
	g_free(addressOfControl);
}


const gchar *
gaim_upnp_get_public_ip()
{
	if (control_info.status == GAIM_UPNP_STATUS_DISCOVERED

	return NULL;
}

static void
looked_up_public_ip_cb(gpointer data, const char *httpResponse, gsize len)
{
	gchar* temp, *temp2;

	if(!httpResponse)
		return;

	/* extract the ip, or see if there is an error */
	if((temp = g_strstr_len(httpResponse, len,
			"<NewExternalIPAddress")) == NULL) {

			sizeof(control_info.publicip));

	gaim_debug_info("upnp", "NAT Returned IP: %s\n", control_info.publicip);
}

void
lookup_public_ip()
{
	gaim_upnp_generate_action_message_and_send("GetExternalIPAddress", "",
			looked_up_public_ip_cb, NULL);
}

	} else
		gaim_debug_info("upnp", "Unable to look up local IP\n");

}

void
lookup_internal_ip()
{
	gchar* addressOfControl;
	int port = 0;

	g_free(addressOfControl);
}

static void
done_port_mapping_cb(gpointer data, const gchar *httpResponse, gsize len)
{
	UPnPMappingAddRemove *ar = data;

	gboolean success = TRUE;

	/* determine if port mapping was a success */
	if(!httpResponse || g_strstr_len(httpResponse, len, HTTP_OK) == NULL) {
		gaim_debug_error("upnp",
			"gaim_upnp_set_port_mapping(): Failed HTTP_OK\n\n%s\n\n",
			httpResponse ? httpResponse : "(null)");
		success =  FALSE;
	} else

14354:01daacf7b771

static void gaim_upnp_discover_send_broadcast(UPnPDiscoveryData *dd);
static void lookup_public_ip(void);
static void lookup_internal_ip(void);

static void
fire_discovery_callbacks(gboolean success)
{
	while(discovery_callbacks) {
		gpointer data;

		discovery_callbacks = g_slist_remove(discovery_callbacks, data);
		cb(success, data);
	}
}

static gboolean
gaim_upnp_compare_device(const xmlnode* device, const gchar* deviceType)
{
	xmlnode* deviceTypeNode = xmlnode_get_child(device, "deviceType");
	char *tmp;

	g_free(tmp);

	return ret;
}

static gboolean
gaim_upnp_compare_service(const xmlnode* service, const gchar* serviceType)
{
	xmlnode* serviceTypeNode;
	char *tmp;

	ret = !g_ascii_strcasecmp(tmp, serviceType);
	g_free(tmp);

	return ret;
}

static gchar*
gaim_upnp_parse_description_response(const gchar* httpResponse, gsize len,
	const gchar* httpURL, const gchar* serviceType)
{

	return controlURL;
}

static void
upnp_parse_description_cb(GaimUtilFetchUrlData *url_data, gpointer user_data,
		const gchar *httpResponse, gsize len, const gchar *error_message)
{
	UPnPDiscoveryData *dd = user_data;
	gchar *control_url = NULL;

	if (len > 0)
		control_url = gaim_upnp_parse_description_response(
			httpResponse, len, dd->full_url, dd->service_type);

	/* Remove the timeout because everything it is waiting for has
	 * successfully completed */
	gaim_timeout_remove(dd->tima);
	dd->tima = 0;

	gaim_util_fetch_url_request(descriptionURL, TRUE, NULL, TRUE, httpRequest,
			TRUE, upnp_parse_description_cb, dd);

	g_free(httpRequest);

}

	gaim_upnp_parse_discover_response(buf, len, dd);

	/* We'll either time out or continue successfully */
}

static void
gaim_upnp_discover_send_broadcast(UPnPDiscoveryData *dd)
{
	gchar *sendMessage = NULL;
	gsize totalSize;
	gboolean sentSuccess;

	/* We have already done all our retries. Make sure that the callback
	 * doesn't get called before the original function returns */
	gaim_timeout_add(10, gaim_upnp_discover_timeout, dd);
}

void
gaim_upnp_discover(GaimUPnPCallback cb, gpointer cb_data)
{
	/* Socket Setup Variables */
	int sock;

	gaim_upnp_discover_send_broadcast(dd);
}

static void
gaim_upnp_generate_action_message_and_send(const gchar* actionName,
		const gchar* actionParams, GaimUtilFetchUrlCallback cb,
		gpointer cb_data)
{

	gchar* soapMessage;
	gchar* totalSendMessage;

			&port, &pathOfControl, NULL, NULL)) {
		gaim_debug_error("upnp",
			"generate_action_message_and_send(): Failed In Parse URL\n\n");
		/* XXX: This should probably be async */
		if(cb)
			cb(NULL, cb_data, NULL, 0, NULL);
	}
	if(port == 0 || port == -1) {
		port = DEFAULT_HTTP_PORT;
	}

		control_info.service_type, actionName,
		strlen(soapMessage), soapMessage);
	g_free(pathOfControl);
	g_free(soapMessage);

	gaim_util_fetch_url_request(control_info.control_url, FALSE, NULL, TRUE,
			totalSendMessage, TRUE, cb, cb_data);

	g_free(totalSendMessage);
	g_free(addressOfControl);
}

const gchar *
gaim_upnp_get_public_ip()
{
	if (control_info.status == GAIM_UPNP_STATUS_DISCOVERED

	return NULL;
}

static void
looked_up_public_ip_cb(GaimUtilFetchUrlData *url_data, gpointer user_data,
		const gchar *httpResponse, gsize len, const gchar *error_message)
{
	gchar* temp, *temp2;

	if ((error_message != NULL) || (httpResponse == NULL))
		return;

	/* extract the ip, or see if there is an error */
	if((temp = g_strstr_len(httpResponse, len,
			"<NewExternalIPAddress")) == NULL) {

			sizeof(control_info.publicip));

	gaim_debug_info("upnp", "NAT Returned IP: %s\n", control_info.publicip);
}

static void
lookup_public_ip()
{
	gaim_upnp_generate_action_message_and_send("GetExternalIPAddress", "",
			looked_up_public_ip_cb, NULL);
}

	} else
		gaim_debug_info("upnp", "Unable to look up local IP\n");

}

static void
lookup_internal_ip()
{
	gchar* addressOfControl;
	int port = 0;

	g_free(addressOfControl);
}

static void
done_port_mapping_cb(GaimUtilFetchUrlData *url_data, gpointer user_data,
		const gchar *httpResponse, gsize len, const gchar *error_message)
{
	UPnPMappingAddRemove *ar = user_data;

	gboolean success = TRUE;

	/* determine if port mapping was a success */
	if ((error_message != NULL) || (httpResponse == NULL) ||
		(g_strstr_len(httpResponse, len, HTTP_OK) == NULL))
	{
		gaim_debug_error("upnp",
			"gaim_upnp_set_port_mapping(): Failed HTTP_OK\n\n%s\n\n",
			httpResponse ? httpResponse : "(null)");
		success =  FALSE;
	} else