f_portrait.c

#include "internal.h"

#include "accountopt.h"
#include "blist.h"
#include "conversation.h"
#include "dnsquery.h"
#include "debug.h"
#include "notify.h"
#include "privacy.h"
#include "prpl.h"
#include "plugin.h"
#include "util.h"
#include "version.h"
#include "network.h"
#include "xmlnode.h"
#include "request.h"
#include "imgstore.h"
#include "sslconn.h"

#include "sipmsg.h"
#include "dnssrv.h"
#include "ntlm.h"

#include "sipmsg.h"
#include "f_portrait.h"


void CheckPortrait(struct fetion_account_data *sip,const gchar *who,const gchar *crc)
{
	PurpleBuddy *buddy=NULL;
	struct fetion_buddy * f_buddy;
	const gchar *old_crc = NULL;
	buddy = purple_find_buddy(sip->account,who);
	g_return_if_fail(buddy!=NULL);

	old_crc = purple_buddy_icons_get_checksum_for_user(buddy);
	if(old_crc!=NULL && (strcmp(old_crc,crc)==0))
		return ;

	f_buddy = g_hash_table_lookup(sip->buddies,who);
	g_return_if_fail(f_buddy!=NULL);
	f_buddy->icon_crc = g_strdup(crc);
	GetPortrait(sip,f_buddy,NULL);	

}
void DownLoadPortrait(gpointer data, gint source, const gchar *error_message)
{
	gchar buf[10240];
	gchar *content_len,*cur,*pos;
	gchar *temp=NULL;
	gint len,rcv_len;
	struct fetion_account_data *sip;
	struct fetion_buddy *who=data;
	sip=who->sip;

	g_return_if_fail(who!=NULL);

	rcv_len=read(source,buf,10240);

	if(rcv_len>0)
	{
		cur = strstr(buf,"\r\n\r\n");
		if(cur!=NULL)
		{

			if (strncmp(buf, "HTTP/1.1 200 OK\r\n", 17) != 0) 
			{
				if (strncmp(buf, "HTTP/1.1 302 Found\r\n", 20) != 0) 
				{
					who->icon_buf=NULL;
					return;
				}
				temp =  get_token(buf, "Location: HTTP://", "/hds/getportrait.aspx");

				if(temp!=NULL && strlen(temp)>7)
					GetPortrait(sip,who,temp);
				else
				{
					who->icon_buf=NULL;
					return;
				}
				purple_debug_info("fetion:","DownLoadPortrait ip[%s][%s]\n",temp,who->name);
				purple_input_remove(who->inpa);
				return;
			}
			temp = 	get_token(buf, "Content-Length: ", "\r\n");
			if(temp==NULL)
				return;
			content_len = g_strdup(temp);
			purple_debug_info("fetion:","DownLoadPortrait Content-Length%s\n",content_len);
			if(content_len!=NULL)
				who->icon_size=atoi(content_len);
			purple_debug_info("fetion:","DownLoadPortrait Content-Length%d\n",who->icon_size);
			who->icon_rcv_len=0;
			who->icon_buf=g_malloc0(who->icon_size);
			cur+=4;
			len=rcv_len-(cur-buf);
			memcpy(who->icon_buf,cur,len);
			who->icon_rcv_len=len;
			purple_debug_info("fetion:","DownLoadPortrait begin[%s]\n",buf);
		}
		else if(who->icon_buf!=NULL)
		{

			pos=(who->icon_buf)+(who->icon_rcv_len);
			memcpy(pos,buf,rcv_len);
			who->icon_rcv_len+=rcv_len;
		}

		purple_debug_info("fetion:","DownLoadPortrait%d\n",rcv_len);
	}
	else 
	{
		purple_input_remove(who->inpa);

		if(who->icon_rcv_len == who->icon_size)
			purple_buddy_icons_set_for_user(sip->account,who->name,who->icon_buf,who->icon_size,who->icon_crc);
		g_free(who->host);

	}


}
void GetPortrait_cb(gpointer data, gint source, const gchar *error_message)
{
	struct fetion_buddy *who=data;
	struct fetion_account_data *sip=who->sip;
	gchar *head,*server_ip;
	const gchar *ssic;
	gint writed_len;
	if(who->host==NULL)
		server_ip = g_strdup(sip->PortraitServer);
	else
		server_ip = g_strdup(who->host);

	ssic=purple_url_encode(sip->ssic);

	head = g_strdup_printf("GET /hds/getportrait.aspx?%sUri=%s"
			"&Size=%s&c=%s HTTP/1.1\r\n"
			"User-Agent: IIC2.0/PC 3.1.0480\r\n"
			"Accept: image/pjpeg;image/jpeg;image/bmp;image/x-windows-bmp;image/png;image/gif\r\n"
			"Host: %s\r\n\r\n",
			(who->host?"transfer=1&":""),who->name,"96",ssic,server_ip
			);
	purple_debug_info("fetion:","GetPortrait_cb:%s\n",head);
	who->inpa = purple_input_add(source,PURPLE_INPUT_READ,(PurpleInputFunction ) DownLoadPortrait,who);
	writed_len = write(source,head,strlen(head));
	//g_free(head);
	//g_free(ssic);
	g_free(server_ip);
}
void GetPortrait(struct fetion_account_data *sip,struct fetion_buddy *buddy,const gchar *host)
{
	PurpleProxyConnectData *conn;
	gchar * server_ip;
	g_return_if_fail(buddy!=NULL);
	buddy->sip=sip;
	if(host!=NULL)
	{
		server_ip = g_strdup(host);
		buddy->host = g_strdup(host);
	}
	else
		server_ip = g_strdup(sip->PortraitServer);

	purple_debug_info("fetion:","GetPortrait:buddy[%s]\n",buddy->name);
	if ( (conn = purple_proxy_connect(sip->gc, sip->account, server_ip,
				80, GetPortrait_cb, buddy) )== NULL)
	{
		purple_connection_error_reason(sip->gc,
				PURPLE_CONNECTION_ERROR_NETWORK_ERROR,
				_("Couldn't create socket"));
	}

	g_free(server_ip);

}
void UploadPortrait_cb(gpointer data,gint source,const gchar *error_message)
{
	struct fetion_account_data *sip = data;
	gsize max_write;
	gssize written;

	max_write = purple_circ_buffer_get_max_read(sip->icon_buf);
	if(max_write == 0)
	{
		purple_input_remove(sip->icon_handler);
		sip->icon_handler = 0;
		return;
	}
	written = write(source, sip->icon_buf->outptr, max_write);
	purple_debug_info("fetion:","UploadPortrait[%d][%d]",max_write,written);
	if(written < 0 && errno == EAGAIN)
		written = 0;
	else if(written <= 0)
	{
		/*TODO: do we really want to disconnect on a failure to write?*/
		purple_connection_error_reason(sip->gc,
				PURPLE_CONNECTION_ERROR_NETWORK_ERROR,
				_("Could not write"));
		return;
	}

	purple_circ_buffer_mark_read(sip->icon_buf, written);



}
void UploadPortrait(gpointer data, gint source, const gchar *error_message)
{
	struct fetion_account_data *sip=data;
	PurpleStoredImage *img = sip->icon;
	gchar *head;
	gchar *buf;
	gint head_len;
	gint ret,lenth,writed;
	gconstpointer img_data = purple_imgstore_get_data(img);
	size_t size = purple_imgstore_get_size(img);


	head = g_strdup_printf("POST /hds/setportrait.aspx HTTP/1.1\r\n"
			"User-Agent: IIC2.0/PC 3.1.0480\r\n"
			"Content-Type: image/jpeg\r\n"
			"Host: %s\r\n"
			"Cookie: ssic=%s\r\n"
			"Content-Length: %d\r\n\r\n",
			sip->UploadServer,sip->ssic,size
			);
	purple_debug_info("fetion:","UploadPortrait:head[%s][%d]\n",head,size);
	head_len = strlen(head);
	buf = g_malloc(head_len+size);
	memcpy(buf,head,head_len);
	memcpy(buf+head_len,img_data,size);
	lenth = size+strlen(head);	
	writed = 0;
	ret = write(source,buf,lenth);
	if (ret < 0 && errno == EAGAIN)
		ret = 0;
	g_return_if_fail(ret>=0);
	if(ret<lenth)
	{
		purple_circ_buffer_append(sip->icon_buf, buf + ret,lenth-ret);
		sip->icon_handler = purple_input_add(source,PURPLE_INPUT_WRITE,(PurpleInputFunction) UploadPortrait_cb,sip);

	}
	g_free(head);
	sip->icon = NULL;
	purple_imgstore_unref(img);
}
void fetion_set_buddy_icon(PurpleConnection *gc, PurpleStoredImage *img)
{
	size_t size = purple_imgstore_get_size(img);
	PurpleProxyConnectData *conn;
	struct fetion_account_data *sip= gc->proto_data;

	g_return_if_fail(img!=NULL);

	if (size > 0x32000)
		return;
	sip->icon = img;

	purple_debug_info("fetion:","set_buddy_icon:len[%d]\n",size);
	if ( (conn = purple_proxy_connect(sip->gc, sip->account, sip->UploadServer,
				80, UploadPortrait, sip) )== NULL)
	{
		purple_connection_error_reason(sip->gc,
				PURPLE_CONNECTION_ERROR_NETWORK_ERROR,
				_("Couldn't create socket"));
	}


	purple_imgstore_ref(img);

}