diff options
Diffstat (limited to 'tools/_deprecated/Yahoo/src/file_transfer.cpp')
| -rw-r--r-- | tools/_deprecated/Yahoo/src/file_transfer.cpp | 821 |
1 files changed, 821 insertions, 0 deletions
diff --git a/tools/_deprecated/Yahoo/src/file_transfer.cpp b/tools/_deprecated/Yahoo/src/file_transfer.cpp new file mode 100644 index 0000000000..099c78235c --- /dev/null +++ b/tools/_deprecated/Yahoo/src/file_transfer.cpp @@ -0,0 +1,821 @@ +/*
+* $Id: file_transfer.cpp 13893 2011-10-23 19:29:28Z borkra $
+*
+* 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 "stdafx.h"
+#include <m_protosvc.h>
+#include "file_transfer.h"
+
+YList *file_transfers = NULL;
+
+static y_filetransfer* new_ft(CYahooProto* ppro, int id, MCONTACT hContact, const char *who, const char *msg,
+ const char *url, const char *ft_token, int y7, YList *fs, int sending)
+{
+ LOG(("[new_ft] id: %d, who: %s, msg: %s, ft_token: %s, y7: %d, sending: %d", id, who, msg, ft_token, y7, sending));
+
+ y_filetransfer* ft = (y_filetransfer*)calloc(1, sizeof(y_filetransfer));
+ ft->ppro = ppro;
+ ft->id = id;
+ ft->who = strdup(who);
+ ft->hWaitEvent = INVALID_HANDLE_VALUE;
+
+ ft->hContact = hContact;
+ ft->files = fs;
+
+ ft->url = (url == NULL) ? NULL : strdup(url);
+ ft->ftoken = (ft_token == NULL) ? NULL : strdup(ft_token);
+ ft->msg = (msg != NULL) ? strdup(msg) : strdup("[no description given]");
+
+ ft->cancel = 0;
+ ft->y7 = y7;
+
+ ft->hWaitEvent = CreateEvent(NULL, FALSE, FALSE, NULL);
+
+ ft->pfts.cbSize = sizeof(PROTOFILETRANSFERSTATUS);
+ ft->pfts.hContact = hContact;
+ ft->pfts.flags = PFTS_UNICODE;
+ ft->pfts.flags |= (sending != 0) ? PFTS_SENDING : PFTS_RECEIVING;
+
+ ft->pfts.tszWorkingDir = NULL;
+ ft->pfts.currentFileTime = 0;
+
+ ft->pfts.totalFiles = y_list_length(fs);
+
+ ft->pfts.ptszFiles = (wchar_t**)mir_calloc(ft->pfts.totalFiles * sizeof(wchar_t *));
+ ft->pfts.totalBytes = 0;
+
+ int i = 0;
+ for (YList *l = fs; l; l = l->next) {
+ yahoo_file_info *fi = (yahoo_file_info*)l->data;
+
+ ft->pfts.ptszFiles[i++] = mir_utf8decodeW(fi->filename);
+ ft->pfts.totalBytes += fi->filesize;
+ }
+
+ ft->pfts.currentFileNumber = 0;
+
+ yahoo_file_info *fi = (yahoo_file_info*)fs->data;
+ ft->pfts.tszCurrentFile = wcsdup(ft->pfts.ptszFiles[ft->pfts.currentFileNumber]);
+ ft->pfts.currentFileSize = fi->filesize;
+
+ file_transfers = y_list_prepend(file_transfers, ft);
+
+ LOG(("[/new_ft]"));
+
+ return ft;
+}
+
+y_filetransfer* find_ft(const char *ft_token, const char *who)
+{
+ LOG(("[find_ft] Searching for: %s", ft_token));
+
+ for (YList *l = file_transfers; l; l = y_list_next(l)) {
+ y_filetransfer *f = (y_filetransfer*)l->data;
+ if (mir_strcmp(f->ftoken, ft_token) == 0 && mir_strcmp(f->who, who) == 0) {
+ LOG(("[find_ft] Got it!"));
+ return f;
+ }
+ }
+
+ LOG(("[find_ft] FT not found?"));
+ return NULL;
+}
+
+static void free_ft(y_filetransfer *ft)
+{
+ LOG(("[free_ft] token: %s", ft->ftoken));
+
+ for (YList *l = file_transfers; l; l = y_list_next(l)) {
+ if (l->data == ft) {
+ LOG(("[free_ft] Ft found and removed from the list"));
+ file_transfers = y_list_remove_link(file_transfers, l);
+ y_list_free_1(l);
+ break;
+ }
+ }
+
+ if (ft->hWaitEvent != INVALID_HANDLE_VALUE)
+ CloseHandle(ft->hWaitEvent);
+
+ FREE(ft->who);
+ FREE(ft->msg);
+ FREE(ft->url);
+ FREE(ft->ftoken);
+ FREE(ft->relay);
+
+ LOG(("[free_ft] About to free the File List."));
+
+ while (ft->files) {
+ YList *tmp = ft->files;
+ yahoo_file_info *c = (yahoo_file_info*)ft->files->data;
+ FREE(c->filename);
+ FREE(c);
+ ft->files = y_list_remove_link(ft->files, ft->files);
+ y_list_free_1(tmp);
+ }
+
+ LOG(("[free_ft] About to free PFTS."));
+
+ for (int i = 0; i < ft->pfts.totalFiles; i++)
+ mir_free(ft->pfts.ptszFiles[i]);
+
+ mir_free(ft->pfts.ptszFiles);
+ FREE(ft->pfts.tszCurrentFile);
+ FREE(ft->pfts.tszWorkingDir);
+ FREE(ft);
+
+ LOG(("[/free_ft]"));
+}
+
+static void upload_file(int, INT_PTR fd, int error, void *data)
+{
+ y_filetransfer *sf = (y_filetransfer*)data;
+ yahoo_file_info *fi = (yahoo_file_info *)sf->files->data;
+ char buf[1024];
+ unsigned long size = 0;
+ DWORD dw = 0;
+ int rw = 0;
+
+ if (fd < 0) {
+ LOG(("[get_fd] Connect Failed!"));
+ error = 1;
+ }
+
+ if (!error) {
+ HANDLE myhFile = CreateFile(sf->pfts.tszCurrentFile,
+ GENERIC_READ,
+ FILE_SHARE_READ | FILE_SHARE_WRITE,
+ NULL,
+ OPEN_EXISTING,
+ FILE_ATTRIBUTE_NORMAL | FILE_FLAG_SEQUENTIAL_SCAN,
+ 0);
+
+ if (myhFile != INVALID_HANDLE_VALUE) {
+ DWORD lNotify = GetTickCount();
+
+ LOG(("proto: %s, hContact: %p", sf->ppro->m_szModuleName, sf->hContact));
+
+ LOG(("Sending file: %s", fi->filename));
+ ProtoBroadcastAck(sf->ppro->m_szModuleName, sf->hContact, ACKTYPE_FILE, ACKRESULT_CONNECTED, sf, 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 == fi->filesize) {
+ LOG(("DOING UI Notify. Got %lu/%lu", size, fi->filesize));
+ sf->pfts.totalProgress = size;
+ sf->pfts.currentFileProgress = size;
+
+ ProtoBroadcastAck(sf->ppro->m_szModuleName, sf->hContact, ACKTYPE_FILE, ACKRESULT_DATA, sf, (LPARAM)& sf->pfts);
+ lNotify = GetTickCount();
+ }
+
+ }
+
+ if (sf->cancel) {
+ LOG(("Upload Cancelled! "));
+ error = 1;
+ break;
+ }
+ } while (rw > 0 && dw > 0 && !error);
+
+ CloseHandle(myhFile);
+
+ sf->pfts.totalProgress = size;
+ sf->pfts.currentFileProgress = size;
+
+ ProtoBroadcastAck(sf->ppro->m_szModuleName, sf->hContact, ACKTYPE_FILE, ACKRESULT_DATA, sf, (LPARAM)& sf->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!"));
+
+ if (!error) {
+ sf->pfts.currentFileNumber++;
+
+ if (sf->pfts.currentFileNumber >= sf->pfts.totalFiles) {
+ ProtoBroadcastAck(sf->ppro->m_szModuleName, sf->hContact, ACKTYPE_FILE, ACKRESULT_SUCCESS, sf, 0);
+ }
+ else {
+ // Do Next file
+ FREE(sf->pfts.tszCurrentFile);
+
+ YList *l = sf->files;
+
+ fi = (yahoo_file_info*)l->data;
+ FREE(fi->filename);
+ FREE(fi);
+
+ sf->files = y_list_remove_link(sf->files, l);
+ y_list_free_1(l);
+
+ // need to move to the next file on the list and fill the file information
+ fi = (yahoo_file_info*)sf->files->data;
+ sf->pfts.tszCurrentFile = wcsdup(sf->pfts.ptszFiles[sf->pfts.currentFileNumber]);
+ sf->pfts.currentFileSize = fi->filesize;
+ sf->pfts.currentFileProgress = 0;
+
+ ProtoBroadcastAck(sf->ppro->m_szModuleName, sf->hContact, ACKTYPE_FILE, ACKRESULT_NEXTFILE, sf, 0);
+ LOG(("Waiting for next file request packet..."));
+ }
+ }
+ else ProtoBroadcastAck(sf->ppro->m_szModuleName, sf->hContact, ACKTYPE_FILE, ACKRESULT_FAILED, sf, 0);
+}
+
+static void dl_file(int id, INT_PTR fd, int error, const char*, unsigned long size, void *data)
+{
+ y_filetransfer *sf = (y_filetransfer*)data;
+ yahoo_file_info *fi = (yahoo_file_info *)sf->files->data;
+ char buf[1024];
+ unsigned 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_ftdc_deny(id, sf->who, fi->filename, sf->ftoken, 3);
+ }
+
+ error = 1;
+ }
+
+ if (!error) {
+ HANDLE myhFile;
+ wchar_t filefull[MAX_PATH];
+
+ /*
+ * We need FULL Path for File Resume to work properly!!!
+ *
+ * Don't rely on workingDir to be right, since it's not used to check if file exists.
+ */
+ mir_snwprintf(filefull, L"%s\\%s", sf->pfts.tszWorkingDir, sf->pfts.tszCurrentFile);
+ FREE(sf->pfts.tszCurrentFile);
+ sf->pfts.tszCurrentFile = wcsdup(filefull);
+
+ ResetEvent(sf->hWaitEvent);
+
+ if (sf->ppro->ProtoBroadcastAck(sf->hContact, ACKTYPE_FILE, ACKRESULT_FILERESUME, sf, (LPARAM)&sf->pfts)) {
+ WaitForSingleObject(sf->hWaitEvent, INFINITE);
+
+ LOG(("[dl_file] Got action: %ld", sf->action));
+
+ 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:
+ sf->cancel = 2;
+ break;
+ }
+ }
+
+
+
+ if (!sf->cancel) {
+
+ myhFile = CreateFile(sf->pfts.tszCurrentFile,
+ 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", sf->ppro->m_szModuleName, sf->hContact));
+
+ ProtoBroadcastAck(sf->ppro->m_szModuleName, 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;
+ sf->pfts.totalProgress += dw;
+ sf->pfts.currentFileProgress += dw;
+
+ if (GetTickCount() >= lNotify + 500 || dw <= 0 || rsize == size) {
+
+ LOG(("DOING UI Notify. Got %lu/%lu", rsize, size));
+
+ ProtoBroadcastAck(sf->ppro->m_szModuleName, sf->hContact, ACKTYPE_FILE, ACKRESULT_DATA, sf, (LPARAM)& sf->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);
+
+ while (dw > 0 && !sf->cancel && !error) {
+ dw = Netlib_Recv((HANDLE)fd, buf, 1024, MSG_NODUMP);
+ LOG(("Ack."));
+ }
+
+ ProtoBroadcastAck(sf->ppro->m_szModuleName, sf->hContact, ACKTYPE_FILE, ACKRESULT_DATA, sf, (LPARAM)& sf->pfts);
+
+ LOG(("[Finished DL] Got %lu/%lu", rsize, size));
+ CloseHandle(myhFile);
+
+ }
+ else {
+ LOG(("Can not open file for writing: %s", buf));
+ error = 1;
+ }
+
+ }
+ }
+
+ if (fd > 0) {
+ LOG(("Closing connection: %d", fd));
+ Netlib_CloseHandle((HANDLE)fd);
+
+ if (sf->cancel || error) {
+ /* abort FT transfer */
+ yahoo_ft7dc_abort(id, sf->who, sf->ftoken);
+ }
+ }
+
+ if (!error) {
+ sf->pfts.currentFileNumber++;
+
+ LOG(("File %d/%d download complete!", sf->pfts.currentFileNumber, sf->pfts.totalFiles));
+
+ if (sf->pfts.currentFileNumber >= sf->pfts.totalFiles) {
+ ProtoBroadcastAck(sf->ppro->m_szModuleName, sf->hContact, ACKTYPE_FILE, ACKRESULT_SUCCESS, sf, 0);
+ }
+ else {
+ // Do Next file
+ yahoo_ft7dc_nextfile(id, sf->who, sf->ftoken);
+ FREE(sf->pfts.tszCurrentFile);
+
+ YList *l = sf->files;
+
+ fi = (yahoo_file_info*)l->data;
+ FREE(fi->filename);
+ FREE(fi);
+
+ sf->files = y_list_remove_link(sf->files, l);
+ y_list_free_1(l);
+
+ // need to move to the next file on the list and fill the file information
+ fi = (yahoo_file_info*)sf->files->data;
+ sf->pfts.tszCurrentFile = wcsdup(sf->pfts.ptszFiles[sf->pfts.currentFileNumber]);
+ sf->pfts.currentFileSize = fi->filesize;
+ sf->pfts.currentFileProgress = 0;
+
+ ProtoBroadcastAck(sf->ppro->m_szModuleName, sf->hContact, ACKTYPE_FILE, ACKRESULT_NEXTFILE, sf, 0);
+ }
+ }
+ else {
+ LOG(("File download failed!"));
+
+ ProtoBroadcastAck(sf->ppro->m_szModuleName, sf->hContact, ACKTYPE_FILE, ACKRESULT_FAILED, sf, 0);
+ }
+}
+
+//=======================================================
+//File Transfer
+//=======================================================
+void __cdecl CYahooProto::recv_filethread(void *psf)
+{
+ y_filetransfer *sf = (y_filetransfer*)psf;
+ yahoo_file_info *fi = (yahoo_file_info *)sf->files->data;
+
+ ProtoBroadcastAck(sf->hContact, ACKTYPE_FILE, ACKRESULT_CONNECTING, sf, 0);
+
+ debugLogA("[yahoo_recv_filethread] who: %s, msg: %s, filename: %s ", sf->who, sf->msg, fi->filename);
+
+
+ yahoo_get_url_handle(m_id, sf->url, &dl_file, sf);
+
+ if (sf->pfts.currentFileNumber >= sf->pfts.totalFiles)
+ free_ft(sf);
+ else
+ debugLogA("[yahoo_recv_filethread] More files coming?");
+}
+
+void CYahooProto::ext_got_file(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)
+{
+ LOG(("[ext_yahoo_got_file] ident:%s, who: %s, url: %s, expires: %lu, msg: %s, fname: %s, fsize: %lu ftoken: %s y7: %d", me, who, url, expires, msg, fname, fesize, ft_token == NULL ? "NULL" : ft_token, y7));
+
+ MCONTACT hContact = getbuddyH(who);
+ if (hContact == NULL)
+ hContact = add_buddy(who, who, 0 /* NO FT for other IMs */, PALF_TEMPORARY);
+
+ char fn[1024];
+ memset(fn, 0, sizeof(fn));
+
+ if (fname != NULL)
+ mir_strncpy(fn, fname, 1024);
+ else {
+ /* based on how gaim does this */
+ char *start = (char*)strrchr(url, '/');
+ if (start)
+ start++;
+
+ char *end = (char*)strrchr(url, '?');
+ if (start && *start && end)
+ mir_strncpy(fn, start, end - start + 1);
+ else
+ mir_strcpy(fn, "filename.ext");
+ }
+
+ yahoo_file_info *fi = y_new(yahoo_file_info, 1);
+ fi->filename = strdup(fn);
+ fi->filesize = fesize;
+
+ YList *files = y_list_append(NULL, fi);
+
+ y_filetransfer *ft = new_ft(this, m_id, hContact, who, msg, url, ft_token, y7, files, 0 /* downloading */);
+ if (ft == NULL) {
+ y_list_free(files);
+ debugLogA("SF IS NULL!!!");
+ return;
+ }
+
+ char *szFileName = fn;
+
+ PROTORECVFILET pre = { 0 };
+ pre.dwFlags = PRFF_UNICODE;
+ pre.fileCount = 1;
+ pre.timestamp = time(NULL);
+ pre.descr.a = (char*)msg;
+ pre.files.a = &szFileName;
+ pre.lParam = (LPARAM)ft;
+ ProtoChainRecvFile(hContact, &pre);
+}
+
+void CYahooProto::ext_got_files(const char *me, const char *who, const char *ft_token, int y7, YList* files)
+{
+ LOG(("[ext_yahoo_got_files] ident:%s, who: %s, ftoken: %s ", me, who, ft_token == NULL ? "NULL" : ft_token));
+
+ MCONTACT hContact = getbuddyH(who);
+ if (hContact == NULL)
+ hContact = add_buddy(who, who, 0 /* NO FT for other IMs */, PALF_TEMPORARY);
+
+ y_filetransfer *ft = new_ft(this, m_id, hContact, who, NULL, NULL, ft_token, y7, files, 0 /* downloading */);
+ if (ft == NULL) {
+ debugLogA("SF IS NULL!!!");
+ return;
+ }
+
+ int fc = 0;
+ LIST<char> arNames(1);
+
+ for (YList *f = files; f; f = y_list_next(f)) {
+ yahoo_file_info *fi = (yahoo_file_info *)f->data;
+ arNames.insert(fi->filename);
+ fc++;
+ }
+
+ PROTORECVFILET pre = { 0 };
+ pre.fileCount = fc;
+ pre.timestamp = time(NULL);
+ pre.descr.a = "";
+ pre.files.a = arNames.getArray();
+ pre.lParam = (LPARAM)ft;
+ ProtoChainRecvFile(ft->hContact, &pre);
+}
+
+void CYahooProto::ext_got_file7info(const char *me, const char *who, const char *url, const char *fname, const char *ft_token)
+{
+ LOG(("[ext_yahoo_got_file7info] ident:%s, who: %s, url: %s, fname: %s, ft_token: %s", me, who, url, fname, ft_token));
+
+ y_filetransfer *ft = find_ft(ft_token, who);
+
+ if (ft == NULL) {
+ LOG(("ERROR: Can't find the token: %s in my file transfers list...", ft_token));
+ return;
+ }
+
+ ProtoBroadcastAck(ft->hContact, ACKTYPE_GETINFO, ACKRESULT_SUCCESS, (HANDLE)1, 0);
+
+ FREE(ft->url);
+
+ ft->url = strdup(url);
+
+ ForkThread(&CYahooProto::recv_filethread, ft);
+}
+
+void ext_yahoo_send_file7info(int id, const char *me, const char *who, const char *ft_token)
+{
+ LOG(("[ext_yahoo_send_file7info] id: %i, ident:%s, who: %s, ft_token: %s", id, me, who, ft_token));
+
+ y_filetransfer *ft = find_ft(ft_token, who);
+
+ if (ft == NULL) {
+ LOG(("ERROR: Can't find the token: %s in my file transfers list...", ft_token));
+ return;
+ }
+
+ yahoo_file_info *fi = (yahoo_file_info *)ft->files->data;
+
+ char *c = strrchr(fi->filename, '\\');
+ if (c != NULL) {
+ c++;
+ }
+ else {
+ c = fi->filename;
+ }
+
+ LOG(("Resolving relay.msg.yahoo.com..."));
+ PHOSTENT he = gethostbyname("relay.msg.yahoo.com");
+
+ if (he) {
+ ft->relay = strdup(inet_ntoa(*(PIN_ADDR)he->h_addr_list[0]));
+ LOG(("Got Relay IP: %s", ft->relay));
+ }
+ else {
+ ft->relay = strdup("98.136.112.33");
+ LOG(("DNS Lookup failed. Using Relay IP: %s", ft->relay));
+ }
+
+ yahoo_send_file7info(id, me, who, ft_token, c, ft->relay);
+}
+
+struct _sfs
+{
+ char *me;
+ char *token;
+ y_filetransfer *sf;
+};
+
+void CYahooProto::ext_ft7_send_file(const char *me, const char *who, const char*, const char *token, const char *ft_token)
+{
+ LOG(("[ext_yahoo_send_file7info] ident:%s, who: %s, ft_token: %s", me, who, ft_token));
+
+ y_filetransfer *sf = find_ft(ft_token, who);
+
+ if (sf == NULL) {
+ LOG(("ERROR: Can't find the token: %s in my file transfers list...", ft_token));
+ return;
+ }
+
+ _sfs *s = (_sfs *)malloc(sizeof(_sfs));
+
+ s->me = strdup(me);
+ s->token = strdup(token);
+ s->sf = sf;
+
+ ForkThread(&CYahooProto::send_filethread, s);
+}
+
+/**************** Send File ********************/
+
+void __cdecl CYahooProto::send_filethread(void *psf)
+{
+ _sfs *s = (_sfs *)psf;
+ y_filetransfer *sf = s->sf;
+ yahoo_file_info *fi = (yahoo_file_info *)sf->files->data;
+
+ ProtoBroadcastAck(sf->hContact, ACKTYPE_FILE, ACKRESULT_CONNECTING, sf, 0);
+
+ LOG(("who %s, msg: %s, filename: %s filesize: %ld", sf->who, sf->msg, fi->filename, fi->filesize));
+
+ yahoo_send_file_y7(sf->id, s->me, sf->who, sf->relay, fi->filesize, s->token, &upload_file, sf);
+
+ FREE(s->me);
+ FREE(s->token);
+ FREE(s);
+
+ if (sf->pfts.currentFileNumber >= sf->pfts.totalFiles) {
+ free_ft(sf);
+ }
+ else {
+ debugLogA("[yahoo_send_filethread] More files coming?");
+ }
+}
+
+
+////////////////////////////////////////////////////////////////////////////////////////
+// SendFile - sends a file
+
+HANDLE __cdecl CYahooProto::SendFile(MCONTACT hContact, const wchar_t *szDescription, wchar_t **ppszFiles)
+{
+ LOG(("[YahooSendFile]"));
+
+ if (!m_bLoggedIn)
+ return 0;
+
+ DBVARIANT dbv;
+ if (!getString(hContact, YAHOO_LOGINID, &dbv)) {
+ long tFileSize = 0;
+ struct _stat statbuf;
+ YList *fs = NULL;
+
+ int i = 0;
+ for (; ppszFiles[i] != NULL; i++) {
+ if (_wstat(ppszFiles[i], &statbuf) == 0)
+ tFileSize = statbuf.st_size;
+
+ yahoo_file_info *fi = y_new(yahoo_file_info, 1);
+
+ fi->filename = strdup(T2Utf(ppszFiles[i]));
+ fi->filesize = tFileSize;
+
+ fs = y_list_append(fs, fi);
+ }
+
+ y_filetransfer *sf = new_ft(this, m_id, hContact, dbv.pszVal, (char*)szDescription,
+ NULL, NULL, 0, fs, 1 /* sending */);
+
+ db_free(&dbv);
+
+ if (sf == NULL) {
+ debugLogA("SF IS NULL!!!");
+ return 0;
+ }
+
+ LOG(("who: %s, msg: %s, # files: %d", sf->who, sf->msg, i));
+
+ sf->ftoken = yahoo_ft7dc_send(m_id, sf->who, fs);
+
+ LOG(("Exiting SendRequest..."));
+
+ return sf;
+ }
+
+ LOG(("[/YahooSendFile]"));
+
+ return 0;
+}
+
+////////////////////////////////////////////////////////////////////////////////////////
+// FileAllow - starts a file transfer
+
+HANDLE __cdecl CYahooProto::FileAllow(MCONTACT, HANDLE hTransfer, const wchar_t* szPath)
+{
+ y_filetransfer *ft = (y_filetransfer *)hTransfer;
+
+ debugLogA("[YahooFileAllow]");
+
+ //LOG(LOG_INFO, "[%s] Requesting file from %s", ft->cookie, ft->user);
+ ft->pfts.tszWorkingDir = wcsdup(szPath);
+
+ size_t len = mir_wstrlen(ft->pfts.tszWorkingDir) - 1;
+ if (ft->pfts.tszWorkingDir[len] == '\\')
+ ft->pfts.tszWorkingDir[len] = 0;
+
+ if (ft->y7) {
+ debugLogA("[YahooFileAllow] Trying to relay Y7 transfer.");
+ //void yahoo_ft7dc_accept(int id, const char *buddy, const char *ft_token);
+ yahoo_ft7dc_accept(ft->id, ft->who, ft->ftoken);
+
+ return hTransfer;
+ }
+
+ ForkThread(&CYahooProto::recv_filethread, ft);
+ return hTransfer;
+}
+
+////////////////////////////////////////////////////////////////////////////////////////
+// FileCancel - cancels a file transfer
+
+int __cdecl CYahooProto::FileCancel(MCONTACT, HANDLE hTransfer)
+{
+ debugLogA("[YahooFileCancel]");
+
+ y_filetransfer* ft = (y_filetransfer*)hTransfer;
+
+ if (!(ft->pfts.flags & PFTS_SENDING) && !ft->cancel) {
+ /* abort FT transfer */
+ yahoo_ft7dc_abort(ft->id, ft->who, ft->ftoken);
+ }
+
+ if (ft->hWaitEvent != INVALID_HANDLE_VALUE)
+ SetEvent(ft->hWaitEvent);
+
+ ft->action = FILERESUME_CANCEL;
+ ft->cancel = 1;
+
+ return 0;
+}
+
+////////////////////////////////////////////////////////////////////////////////////////
+// FileDeny - denies a file transfer
+
+int __cdecl CYahooProto::FileDeny(MCONTACT, HANDLE hTransfer, const wchar_t*)
+{
+ /* deny file receive request.. just ignore it! */
+ y_filetransfer *ft = (y_filetransfer *)hTransfer;
+
+ debugLogA("[YahooFileDeny]");
+
+ if (!m_bLoggedIn || ft == NULL) {
+ debugLogA("[YahooFileDeny] Not logged-in or some other error!");
+ return 1;
+ }
+
+ if (ft->y7) {
+ debugLogA("[YahooFileDeny] Y7 Transfer detected.");
+ //void yahoo_ft7dc_accept(int id, const char *buddy, const char *ft_token);
+ yahoo_ft7dc_deny(ft->id, ft->who, ft->ftoken);
+ return 0;
+ }
+
+ if (ft->ftoken != NULL) {
+ yahoo_file_info *fi = (yahoo_file_info *)ft->files->data;
+
+ debugLogA("[YahooFileDeny] DC Detected: Denying File Transfer!");
+ yahoo_ftdc_deny(m_id, ft->who, fi->filename, ft->ftoken, 2);
+ }
+ return 0;
+}
+
+////////////////////////////////////////////////////////////////////////////////////////
+// FileResume - processes file renaming etc
+
+int __cdecl CYahooProto::FileResume(HANDLE hTransfer, int* action, const wchar_t** szFilename)
+{
+ y_filetransfer *ft = (y_filetransfer *)hTransfer;
+
+ debugLogA("[YahooFileResume] Action: %d", *action);
+
+ if (!m_bLoggedIn || ft == NULL) {
+ debugLogA("[YahooFileResume] Not loggedin or some other error!");
+ return 1;
+ }
+
+ ft->action = *action;
+
+ debugLogA("[YahooFileResume] Action: %d", *action);
+
+ if (*action == FILERESUME_RENAME) {
+ debugLogA("[YahooFileResume] Renamed file!");
+
+ FREE(ft->pfts.tszCurrentFile);
+ ft->pfts.tszCurrentFile = wcsdup(*szFilename);
+ }
+
+ SetEvent(ft->hWaitEvent);
+ return 0;
+}
|