svn.miranda.im is moving to a new home!

git-svn-id: http://miranda-plugins.googlecode.com/svn/trunk@7 e753b5eb-9565-29b2-b5c5-2cc6f99dfbcb

1 files changed, 613 insertions, 0 deletions

diff --git a/miranda-wine/protocols/Yahoo/file_transfer.c b/miranda-wine/protocols/Yahoo/file_transfer.c
new file mode 100644
index 0000000..f546a43
--- /dev/null
+++ b/miranda-wine/protocols/Yahoo/file_transfer.c
@@ -0,0 +1,613 @@
+/*

+ * $Id: file_transfer.c 3659 2006-08-30 19:43:41Z gena01 $
+ *

+ * myYahoo Miranda Plugin 

+ *

+ * Authors: Gennady Feldman (aka Gena01) 

+ *          Laurent Marechal (aka Peorth)

+ *

+ * This code is under GPL and is based on AIM, MSN and Miranda source code.

+ * I want to thank Robert Rainwater and George Hazan for their code and support

+ * and for answering some of my questions during development of this plugin.

+ */

+#include <time.h>

+#include <sys/stat.h>

+

+#include "yahoo.h"

+#include <m_protosvc.h>

+#include "file_transfer.h"

+

+extern yahoo_local_account * ylad;

+

+void get_fd(int id, int fd, int error, void *data) 

+{

+    y_filetransfer *sf = (y_filetransfer*) data;

+    char buf[1024];

+    long size = 0;

+	DWORD dw = 0;

+	int   rw = 0;

+	struct _stat statbuf;

+	

+	if (fd < 0) {

+		LOG(("[get_fd] Connect Failed!"));

+		error = 1;

+	}

+

+	if (_stat( sf->filename, &statbuf ) != 0 )

+		error = 1;

+	

+    if(!error) {

+		 HANDLE myhFile    = CreateFile(sf->filename,

+                                   GENERIC_READ,

+                                   FILE_SHARE_READ|FILE_SHARE_WRITE,

+			           NULL,

+			           OPEN_EXISTING,

+			           FILE_ATTRIBUTE_NORMAL | FILE_FLAG_SEQUENTIAL_SCAN,

+			           0);

+

+

+		if(myhFile !=INVALID_HANDLE_VALUE) {

+			PROTOFILETRANSFERSTATUS pfts;

+			

+			DWORD lNotify = GetTickCount();

+			LOG(("proto: %s, hContact: %p", yahooProtocolName, sf->hContact));

+			

+			LOG(("Sending file: %s", sf->filename));

+			//ProtoBroadcastAck(yahooProtocolName, sf->hContact, ACKTYPE_FILE, ACKRESULT_CONNECTING, sf, 0);

+			ProtoBroadcastAck(yahooProtocolName, sf->hContact, ACKTYPE_FILE, ACKRESULT_NEXTFILE, sf, 0);

+			ProtoBroadcastAck(yahooProtocolName, sf->hContact, ACKTYPE_FILE, ACKRESULT_CONNECTED, sf, 0);

+			//ProtoBroadcastAck(yahooProtocolName, sf->hContact, ACKTYPE_FILE, ACKRESULT_SENTREQUEST, sf, 0);

+			//ProtoBroadcastAck(yahooProtocolName, sf->hContact, ACKTYPE_FILE, ACKRESULT_INITIALISING, sf, 0);

+						

+			ZeroMemory(&pfts, sizeof(PROTOFILETRANSFERSTATUS));

+			pfts.cbSize = sizeof(PROTOFILETRANSFERSTATUS);

+			pfts.hContact = sf->hContact;

+			pfts.sending = 1;

+			pfts.files = &sf->filename;

+			pfts.totalFiles = 1;

+			pfts.currentFileNumber = 0;

+			pfts.totalBytes = statbuf.st_size;

+			pfts.workingDir = NULL;

+			pfts.currentFile = sf->filename;

+			pfts.currentFileSize = statbuf.st_size; 

+			pfts.currentFileTime = 0;

+			

+			do {

+				ReadFile(myhFile, buf, sizeof(buf), &dw, NULL);

+			

+				if (dw) {

+					rw = Netlib_Send((HANDLE)fd, buf, dw, MSG_NODUMP);

+					

+					if (rw < 1) {

+						LOG(("Upload Failed. Send error? Got: %d", rw));

+						error = 1;

+						break;

+					} else 

+						size += rw;

+					

+					if(GetTickCount() >= lNotify + 500 || rw < 1024 || size == statbuf.st_size) {

+						LOG(("DOING UI Notify. Got %lu/%lu", size, statbuf.st_size));

+						pfts.totalProgress = size;

+						pfts.currentFileProgress = size;

+						

+						ProtoBroadcastAck(yahooProtocolName, sf->hContact, ACKTYPE_FILE, ACKRESULT_DATA, sf, (LPARAM) & pfts);

+						lNotify = GetTickCount();

+					}

+					

+				}

+				

+				if (sf->cancel) {

+					LOG(("Upload Cancelled! "));

+					error = 1;

+					break;

+				}

+			} while ( rw > 0 && dw > 0 && !error);

+			

+			CloseHandle(myhFile);

+

+			pfts.totalProgress = size;

+			pfts.currentFileProgress = size;

+			

+			ProtoBroadcastAck(yahooProtocolName, sf->hContact, ACKTYPE_FILE, ACKRESULT_DATA, sf, (LPARAM) & pfts);

+

+		}

+    }	

+

+	if (fd > 0) {

+		int tr = 0;

+		

+		do {

+			rw = Netlib_Recv((HANDLE)fd, buf, sizeof(buf), 0);

+			LOG(("Got: %d bytes", rw));

+			

+			if (tr == 0) {

+				//"HTTP/1.1 999" 12

+				// 012345678901

+				if (rw > 12) {

+					if (buf[9] != '2' || buf[10] != '0' || buf[11] != '0') {

+						LOG(("File Transfer Failed: %c%c%c", buf[9], buf[10], buf[11]));

+						error=1;

+					}

+				}

+			}

+			tr +=rw;

+		} while (rw > 0);

+	

+		Netlib_CloseHandle((HANDLE)fd);

+	}

+	

+	LOG(("File send complete!"));

+

+	ProtoBroadcastAck(yahooProtocolName, sf->hContact, ACKTYPE_FILE, !error ? ACKRESULT_SUCCESS:ACKRESULT_FAILED, sf, 0);

+}

+

+void YAHOO_SendFile(y_filetransfer *sf)

+{

+	long tFileSize = 0;

+	{	struct _stat statbuf;

+		if ( _stat( sf->filename, &statbuf ) == 0 )

+			tFileSize += statbuf.st_size;

+	}

+

+	yahoo_send_file(ylad->id, sf->who, sf->msg, sf->filename, tFileSize, &get_fd, sf);

+}

+

+void YAHOO_FT_cancel(const char *buddy, const char *filename, const char *ft_token, int command)

+{

+	yahoo_ftdc_cancel(ylad->id, buddy, filename, ft_token, command);	

+}

+

+void get_url(int id, int fd, int error,	const char *filename, unsigned long size, void *data) 

+{

+    y_filetransfer *sf = (y_filetransfer*) data;

+    char buf[1024];

+    long rsize = 0;

+	DWORD dw, c;

+

+	if (fd < 0) {

+		LOG(("[get_url] Connect Failed!"));

+		

+		if (sf->ftoken != NULL) {

+			LOG(("[get_url] DC Detected: asking sender to upload to Yahoo FileServers!"));

+			YAHOO_FT_cancel(sf->who, sf->filename, sf->ftoken, 3);	

+		}

+		

+		error = 1;

+	}

+	

+    if(!error) {

+		HANDLE myhFile;

+		PROTOFILETRANSFERSTATUS pfts;

+

+		ZeroMemory(&pfts, sizeof(PROTOFILETRANSFERSTATUS));

+		pfts.cbSize = sizeof(PROTOFILETRANSFERSTATUS);

+		pfts.hContact = sf->hContact;

+		pfts.sending = 0;

+		pfts.files = (char**)&filename;

+		pfts.totalFiles = 1;//ntohs(1);

+		pfts.currentFileNumber = 0;

+		pfts.totalBytes = size;

+		

+		pfts.workingDir = sf->savepath;//ft->savepath;

+		pfts.currentFileSize = size; //ntohl(ft->hdr.size);

+			

+		LOG(("dir: %s, file: %s", sf->savepath, sf->filename ));

+		wsprintf(buf, "%s\\%s", sf->savepath, sf->filename);

+		

+		pfts.currentFile = _strdup(buf);		

+		LOG(("Saving: %s",  pfts.currentFile));

+		

+		if ( sf->hWaitEvent != INVALID_HANDLE_VALUE )

+			CloseHandle( sf->hWaitEvent );

+		

+	    sf->hWaitEvent = CreateEvent( NULL, FALSE, FALSE, NULL );

+

+		if ( YAHOO_SendBroadcast( sf->hContact, ACKTYPE_FILE, ACKRESULT_FILERESUME, (void *)sf, ( LPARAM )&pfts )) {

+			WaitForSingleObject( sf->hWaitEvent, INFINITE );

+			

+			switch(sf->action){

+				case FILERESUME_RENAME:

+				case FILERESUME_OVERWRITE:	

+				case FILERESUME_RESUME:	

+					// no action needed at this point, just break out of the switch statement

+					break;

+

+				case FILERESUME_CANCEL	:

+					sf->cancel = 1;

+					break;

+

+				case FILERESUME_SKIP	:

+				default:

+					//delete this; // per usual dcc objects destroy themselves when they fail or when connection is closed

+					//return FALSE; 

+					sf->cancel = 2;

+					break;

+				}

+		}

+

+		free(pfts.currentFile);

+		

+		if (! sf->cancel) {

+			

+			if (sf->action != FILERESUME_RENAME ) {

+				LOG(("dir: %s, file: %s", sf->savepath, sf->filename ));

+			

+				wsprintf(buf, "%s\\%s", sf->savepath, sf->filename);

+			} else {

+				LOG(("file: %s", sf->filename ));

+			//wsprintf(buf, "%s\%s", sf->filename);

+				lstrcpy(buf, sf->filename);

+			}

+			

+			//pfts.files = &buf;

+			pfts.currentFile = _strdup(buf);		

+	

+			LOG(("Getting file: %s", buf));

+			myhFile    = CreateFile(buf,

+									GENERIC_WRITE,

+									FILE_SHARE_WRITE,

+									NULL, OPEN_ALWAYS,  FILE_ATTRIBUTE_NORMAL,  0);

+	

+			if(myhFile !=INVALID_HANDLE_VALUE) {

+				DWORD lNotify = GetTickCount();

+				

+				SetEndOfFile(myhFile);

+				

+				LOG(("proto: %s, hContact: %p", yahooProtocolName, sf->hContact));

+				

+				ProtoBroadcastAck(yahooProtocolName, sf->hContact, ACKTYPE_FILE, ACKRESULT_CONNECTED, sf, 0);

+				

+				do {

+					dw = Netlib_Recv((HANDLE)fd, buf, 1024, MSG_NODUMP);

+				

+					if (dw > 0) {

+						WriteFile(myhFile, buf, dw, &c, NULL);

+						rsize += dw;

+						

+						/*LOG(("Got %d/%d", rsize, size));*/

+						if(GetTickCount() >= lNotify + 500 || dw <= 0 || rsize == size) {

+							

+						LOG(("DOING UI Notify. Got %lu/%lu", rsize, size));

+						

+						pfts.totalProgress = rsize;

+						pfts.currentFileTime = time(NULL);//ntohl(ft->hdr.modtime);

+						pfts.currentFileProgress = rsize;

+						

+						ProtoBroadcastAck(yahooProtocolName, sf->hContact, ACKTYPE_FILE, ACKRESULT_DATA, sf, (LPARAM) & pfts);

+						lNotify = GetTickCount();

+						}

+					} else {

+						LOG(("Recv Failed! Socket Error?"));

+						error = 1;

+						break;

+					}

+					

+					if (sf->cancel) {

+						LOG(("Recv Cancelled! "));

+						error = 1;

+						break;

+					}

+				} while ( dw > 0 && rsize < size);

+				

+				LOG(("[Finished DL] Got %lu/%lu", rsize, size));

+				CloseHandle(myhFile);

+				

+			} else {

+				LOG(("Can not open file for writing: %s", buf));

+				error = 1;

+			}

+			

+			free(pfts.currentFile);

+		}

+		

+    }

+	

+	if (fd > 0) {

+		LOG(("Closing connection: %d", fd));

+		Netlib_CloseHandle((HANDLE)fd);

+	}

+	

+    LOG(("File download complete!"));

+

+    ProtoBroadcastAck(yahooProtocolName, sf->hContact, ACKTYPE_FILE, !error ? ACKRESULT_SUCCESS:ACKRESULT_FAILED, sf, 0);

+}

+

+void YAHOO_RecvFile(y_filetransfer *ft)

+{

+	yahoo_get_url_handle(ylad->id, ft->url, &get_url, ft);

+}

+

+void ext_yahoo_got_file(int id, const char *me, const char *who, const char *url, long expires, const char *msg, const char *fname, unsigned long fesize, const char *ft_token, int y7)

+{

+    CCSDATA ccs;

+    PROTORECVEVENT pre;

+	HANDLE hContact;

+	char *szBlob;

+	y_filetransfer *ft;

+	

+    LOG(("[ext_yahoo_got_file] id: %i, ident:%s, who: %s, url: %s, expires: %lu, msg: %s, fname: %s, fsize: %lu ftoken: %s y7: %d", id, me, who, url, expires, msg, fname, fesize, ft_token == NULL ? "NULL" : ft_token, y7));

+	

+	hContact = getbuddyH(who);

+	if (hContact == NULL) 

+		hContact = add_buddy(who, who, PALF_TEMPORARY);

+	

+	ft= (y_filetransfer*) malloc(sizeof(y_filetransfer));

+	ft->id  = id;

+	ft->who = strdup(who);

+	ft->hWaitEvent = INVALID_HANDLE_VALUE;

+	if (msg != NULL)

+		ft->msg = strdup(msg);

+	else

+		ft->msg = strdup("[no description given]");

+	

+	ft->hContact = hContact;

+	if (fname != NULL)

+		ft->filename = strdup(fname);

+	else {

+		char *start, *end;

+		

+		/* based on how gaim does this */

+		start = strrchr(url, '/');

+		if (start)

+			start++;

+		

+		end = strrchr(url, '?');

+		

+		if (start && *start && end) {

+			/* argh WINDOWS SUCKS!!! */

+			//ft->filename = strndup(start, end-start);

+			ft->filename = (char *)malloc(end - start + 1);

+			strncpy(ft->filename, start, end-start);

+			ft->filename[end-start] = '\0';

+		} else 

+			ft->filename = strdup("filename.ext");

+	}

+	

+	ft->url = strdup(url);

+	ft->fsize = fesize;

+	ft->cancel = 0;

+	ft->y7 = y7;

+	ft->ftoken = (ft_token == NULL) ? NULL : strdup(ft_token);

+	

+    // blob is DWORD(*ft), ASCIIZ(filenames), ASCIIZ(description)

+    szBlob = (char *) malloc(sizeof(DWORD) + lstrlen(ft->filename) + lstrlen(ft->msg) + 2);

+    *((PDWORD) szBlob) = (DWORD) ft;

+    strcpy(szBlob + sizeof(DWORD), ft->filename);

+    strcpy(szBlob + sizeof(DWORD) + lstrlen(ft->filename) + 1, ft->msg);

+

+	pre.flags = 0;

+	pre.timestamp = time(NULL);

+    pre.szMessage = szBlob;

+    pre.lParam = 0;

+    ccs.szProtoService = PSR_FILE;

+    ccs.hContact = ft->hContact;

+    ccs.wParam = 0;

+    ccs.lParam = (LPARAM) & pre;

+    CallService(MS_PROTO_CHAINRECV, 0, (LPARAM) & ccs);

+	free(szBlob);

+}

+

+//=======================================================

+//File Transfer

+//=======================================================

+static void __cdecl yahoo_recv_filethread(void *psf) 

+{

+	y_filetransfer *sf = psf;

+	

+//    ProtoBroadcastAck(yahooProtocolName, hContact, ACKTYPE_GETINFO, ACKRESULT_SUCCESS, (HANDLE) 1, 0);

+	if (sf == NULL) {

+		YAHOO_DebugLog("SF IS NULL!!!");

+		return;

+	}

+	YAHOO_DebugLog("who %s, msg: %s, filename: %s ", sf->who, sf->msg, sf->filename);

+	

+	YAHOO_RecvFile(sf);

+	if ( sf->hWaitEvent != INVALID_HANDLE_VALUE )

+		CloseHandle( sf->hWaitEvent );

+	

+	free(sf->who);

+	free(sf->msg);

+	free(sf->filename);

+	free(sf->url);

+	free(sf->savepath);

+	free(sf);

+	

+}

+

+/**************** Receive File ********************/

+int YahooFileAllow(WPARAM wParam,LPARAM lParam) 

+{

+    CCSDATA *ccs = (CCSDATA *) lParam;

+    y_filetransfer *ft = (y_filetransfer *) ccs->wParam;

+	int len;

+	

+	YAHOO_DebugLog("[YahooFileAllow]");

+	

+	if (ft->y7) {

+		YAHOO_DebugLog("[YahooFileAllow] We don't handle y7 stuff yet.");

+		//void yahoo_ft7dc_accept(int id, const char *buddy, const char *ft_token);

+		yahoo_ft7dc_accept(ft->id, ft->who, ft->ftoken);

+

+		return ccs->wParam;

+	}

+    //LOG(LOG_INFO, "[%s] Requesting file from %s", ft->cookie, ft->user);

+    ft->savepath = _strdup((char *) ccs->lParam);

+	

+	len = lstrlen(ft->savepath) - 1;

+	if (ft->savepath[len] == '\\')

+		ft->savepath[len] = '\0';

+	

+    pthread_create(yahoo_recv_filethread, (void *) ft);

+	

+    return ccs->wParam;

+}

+

+int YahooFileDeny(WPARAM wParam,LPARAM lParam) 

+{

+	/* deny file receive request.. just ignore it! */

+	CCSDATA *ccs = (CCSDATA *) lParam;

+    y_filetransfer *ft = (y_filetransfer *) ccs->wParam;

+	

+	YAHOO_DebugLog("[YahooFileDeny]");

+	

+	if ( !yahooLoggedIn || ft == NULL ) {

+		YAHOO_DebugLog("[YahooFileResume] Not logged-in or some other error!");

+		return 1;

+	}

+

+	if (ft->y7) {

+		YAHOO_DebugLog("[YahooFileDeny] We don't handle y7 stuff yet.");

+		//void yahoo_ft7dc_accept(int id, const char *buddy, const char *ft_token);

+		yahoo_ft7dc_cancel(ft->id, ft->who, ft->ftoken);

+		return 0;

+	}

+

+	if (ft->ftoken != NULL) {

+		YAHOO_DebugLog("[] DC Detected: Denying File Transfer!");

+		YAHOO_FT_cancel(ft->who, ft->filename, ft->ftoken, 2);	

+	}

+	return 0;

+}

+

+int YahooFileResume( WPARAM wParam, LPARAM lParam )

+{

+    PROTOFILERESUME *pfr;

+	y_filetransfer *ft = (y_filetransfer *) wParam;

+	

+	YAHOO_DebugLog("[YahooFileResume]");

+	

+	if ( !yahooLoggedIn || ft == NULL ) {

+		YAHOO_DebugLog("[YahooFileResume] Not loggedin or some other error!");

+		return 1;

+	}

+

+	pfr = (PROTOFILERESUME*)lParam;

+	

+	ft->action = pfr->action;

+	

+	YAHOO_DebugLog("[YahooFileResume] Action: %d", pfr->action);

+	

+	if ( pfr->action == FILERESUME_RENAME ) {

+		YAHOO_DebugLog("[YahooFileResume] Renamed file!");

+		if ( ft->filename != NULL ) {

+			free( ft->filename );

+			ft->filename = NULL;

+		}

+

+		ft->filename = strdup( pfr->szFilename );

+	}	

+	

+

+	SetEvent( ft->hWaitEvent );

+	return 0;

+}

+

+/**************** Send File ********************/

+static void __cdecl yahoo_send_filethread(void *psf) 

+{

+	y_filetransfer *sf = psf;

+	

+//    ProtoBroadcastAck(yahooProtocolName, hContact, ACKTYPE_GETINFO, ACKRESULT_SUCCESS, (HANDLE) 1, 0);

+	if (sf == NULL) {

+		YAHOO_DebugLog("SF IS NULL!!!");

+		return;

+	}

+	YAHOO_DebugLog("who %s, msg: %s, filename: %s ", sf->who, sf->msg, sf->filename);

+	

+	YAHOO_SendFile(sf);

+	free(sf->who);

+	free(sf->msg);

+	free(sf->filename);

+	free(sf);

+	

+}

+

+int YahooFileCancel(WPARAM wParam,LPARAM lParam) 

+{

+	CCSDATA* ccs = ( CCSDATA* )lParam;

+	y_filetransfer* ft = (y_filetransfer*)ccs->wParam;

+	

+	YAHOO_DebugLog("[YahooFileCancel]");

+	

+	if ( ft->hWaitEvent != INVALID_HANDLE_VALUE )

+		SetEvent( ft->hWaitEvent );

+	

+	ft->action = FILERESUME_CANCEL;

+	ft->cancel = 1;

+	return 0;

+}

+

+/*

+ *

+ */

+int YahooSendFile(WPARAM wParam,LPARAM lParam) 

+{

+	DBVARIANT dbv;

+	y_filetransfer *sf;

+	CCSDATA *ccs;

+	char** files;

+	

+	YAHOO_DebugLog("YahooSendFile");

+	

+	if ( !yahooLoggedIn )

+		return 0;

+

+	YAHOO_DebugLog("Gathering Data");

+	

+	ccs = ( CCSDATA* )lParam;

+	//if ( YAHOO_GetWord( ccs->hContact, "Status", ID_STATUS_OFFLINE ) == ID_STATUS_OFFLINE )

+	//	return 0;

+

+	YAHOO_DebugLog("Getting Files");

+	

+	files = ( char** )ccs->lParam;

+	if ( files[1] != NULL ){

+		MessageBox(NULL, "YAHOO protocol allows only one file to be sent at a time", "Yahoo", MB_OK | MB_ICONINFORMATION);

+		return 0;

+ 	}

+	

+	YAHOO_DebugLog("Getting Yahoo ID");

+	

+	if (!DBGetContactSetting(ccs->hContact, yahooProtocolName, YAHOO_LOGINID, &dbv)) {

+

+		sf = (y_filetransfer*) malloc(sizeof(y_filetransfer));

+		sf->who = strdup(dbv.pszVal);

+		sf->msg = strdup(( char* )ccs->wParam );

+		sf->filename = strdup(files[0]);

+		sf->hContact = ccs->hContact;

+		sf->cancel = 0;

+		

+		YAHOO_DebugLog("who: %s, msg: %s, filename: %s", sf->who, sf->msg, sf->filename);

+		pthread_create(yahoo_send_filethread, sf);

+		

+		DBFreeVariant(&dbv);

+		YAHOO_DebugLog("Exiting SendRequest...");

+		return (int)(HANDLE)sf;

+	}

+	

+	YAHOO_DebugLog("Exiting SendFile");

+	return 0;

+}

+

+int YahooRecvFile(WPARAM wParam,LPARAM lParam) 

+{

+    DBEVENTINFO dbei;

+    CCSDATA *ccs = (CCSDATA *) lParam;

+    PROTORECVEVENT *pre = (PROTORECVEVENT *) ccs->lParam;

+    char *szDesc, *szFile;

+

+    DBDeleteContactSetting(ccs->hContact, "CList", "Hidden");

+    szFile = pre->szMessage + sizeof(DWORD);

+    szDesc = szFile + lstrlen(szFile) + 1;

+    ZeroMemory(&dbei, sizeof(dbei));

+    dbei.cbSize = sizeof(dbei);

+    dbei.szModule = yahooProtocolName;

+    dbei.timestamp = pre->timestamp;

+    dbei.flags = pre->flags & (PREF_CREATEREAD ? DBEF_READ : 0);

+    dbei.eventType = EVENTTYPE_FILE;

+    dbei.cbBlob = sizeof(DWORD) + lstrlen(szFile) + lstrlen(szDesc) + 2;

+    dbei.pBlob = (PBYTE) pre->szMessage;

+    CallService(MS_DB_EVENT_ADD, (WPARAM) ccs->hContact, (LPARAM) & dbei);

+    return 0;

+}

+