/* * WININET - Ftp implementation * * Copyright 1999 Corel Corporation * Copyright 2004 Mike McCormack for CodeWeavers * Copyright 2004 Kevin Koltzau * * Ulrich Czekalla * Noureddine Jemmali * * Copyright 2000 Andreas Mohr * Copyright 2002 Jaco Greeff * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public * License as published by the Free Software Foundation; either * version 2.1 of the License, or (at your option) any later version. * * This library 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 * Lesser General Public License for more details. * * You should have received a copy of the GNU Lesser General Public * License along with this library; if not, write to the Free Software * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA */ #include "config.h" #include "wine/port.h" #include #include #include #include #include #include #ifdef HAVE_SYS_SOCKET_H # include #endif #ifdef HAVE_UNISTD_H # include #endif #include #include #include "windef.h" #include "winbase.h" #include "wingdi.h" #include "winuser.h" #include "wininet.h" #include "winnls.h" #include "winerror.h" #include "winreg.h" #include "winternl.h" #include "shlwapi.h" #include "wine/debug.h" #include "internet.h" WINE_DEFAULT_DEBUG_CHANNEL(wininet); #define DATA_PACKET_SIZE 0x2000 #define szCRLF "\r\n" #define MAX_BACKLOG 5 /* Testing shows that Windows only accepts dwFlags where the last * 3 (yes 3) bits define FTP_TRANSFER_TYPE_UNKNOWN, FTP_TRANSFER_TYPE_ASCII or FTP_TRANSFER_TYPE_BINARY. */ #define FTP_CONDITION_MASK 0x0007 typedef enum { /* FTP commands with arguments. */ FTP_CMD_ACCT, FTP_CMD_CWD, FTP_CMD_DELE, FTP_CMD_MKD, FTP_CMD_PASS, FTP_CMD_PORT, FTP_CMD_RETR, FTP_CMD_RMD, FTP_CMD_RNFR, FTP_CMD_RNTO, FTP_CMD_STOR, FTP_CMD_TYPE, FTP_CMD_USER, FTP_CMD_SIZE, /* FTP commands without arguments. */ FTP_CMD_ABOR, FTP_CMD_LIST, FTP_CMD_NLST, FTP_CMD_PASV, FTP_CMD_PWD, FTP_CMD_QUIT, } FTP_COMMAND; static const CHAR *const szFtpCommands[] = { "ACCT", "CWD", "DELE", "MKD", "PASS", "PORT", "RETR", "RMD", "RNFR", "RNTO", "STOR", "TYPE", "USER", "SIZE", "ABOR", "LIST", "NLST", "PASV", "PWD", "QUIT", }; static const CHAR szMonths[] = "JANFEBMARAPRMAYJUNJULAUGSEPOCTNOVDEC"; static const WCHAR szNoAccount[] = {'n','o','a','c','c','o','u','n','t','\0'}; static void FTP_CloseFileTransferHandle(LPWININETHANDLEHEADER hdr); static void FTP_CloseSessionHandle(LPWININETHANDLEHEADER hdr); static void FTP_CloseConnection(LPWININETHANDLEHEADER hdr); static void FTP_CloseFindNextHandle(LPWININETHANDLEHEADER hdr); static BOOL FTP_SendCommand(INT nSocket, FTP_COMMAND ftpCmd, LPCWSTR lpszParam, INTERNET_STATUS_CALLBACK lpfnStatusCB, LPWININETHANDLEHEADER hdr, DWORD_PTR dwContext); static BOOL FTP_SendStore(LPWININETFTPSESSIONW lpwfs, LPCWSTR lpszRemoteFile, DWORD dwType); static BOOL FTP_GetDataSocket(LPWININETFTPSESSIONW lpwfs, LPINT nDataSocket); static BOOL FTP_SendData(LPWININETFTPSESSIONW lpwfs, INT nDataSocket, HANDLE hFile); static INT FTP_ReceiveResponse(LPWININETFTPSESSIONW lpwfs, DWORD_PTR dwContext); static BOOL FTP_SendRetrieve(LPWININETFTPSESSIONW lpwfs, LPCWSTR lpszRemoteFile, DWORD dwType); static BOOL FTP_RetrieveFileData(LPWININETFTPSESSIONW lpwfs, INT nDataSocket, HANDLE hFile); static BOOL FTP_InitListenSocket(LPWININETFTPSESSIONW lpwfs); static BOOL FTP_ConnectToHost(LPWININETFTPSESSIONW lpwfs); static BOOL FTP_SendPassword(LPWININETFTPSESSIONW lpwfs); static BOOL FTP_SendAccount(LPWININETFTPSESSIONW lpwfs); static BOOL FTP_SendType(LPWININETFTPSESSIONW lpwfs, DWORD dwType); static BOOL FTP_SendPort(LPWININETFTPSESSIONW lpwfs); static BOOL FTP_DoPassive(LPWININETFTPSESSIONW lpwfs); static BOOL FTP_SendPortOrPasv(LPWININETFTPSESSIONW lpwfs); static BOOL FTP_ParsePermission(LPCSTR lpszPermission, LPFILEPROPERTIESW lpfp); static BOOL FTP_ParseNextFile(INT nSocket, LPCWSTR lpszSearchFile, LPFILEPROPERTIESW fileprop); static BOOL FTP_ParseDirectory(LPWININETFTPSESSIONW lpwfs, INT nSocket, LPCWSTR lpszSearchFile, LPFILEPROPERTIESW *lpafp, LPDWORD dwfp); static HINTERNET FTP_ReceiveFileList(LPWININETFTPSESSIONW lpwfs, INT nSocket, LPCWSTR lpszSearchFile, LPWIN32_FIND_DATAW lpFindFileData, DWORD_PTR dwContext); static DWORD FTP_SetResponseError(DWORD dwResponse); /*********************************************************************** * FtpPutFileA (WININET.@) * * Uploads a file to the FTP server * * RETURNS * TRUE on success * FALSE on failure * */ BOOL WINAPI FtpPutFileA(HINTERNET hConnect, LPCSTR lpszLocalFile, LPCSTR lpszNewRemoteFile, DWORD dwFlags, DWORD_PTR dwContext) { LPWSTR lpwzLocalFile; LPWSTR lpwzNewRemoteFile; BOOL ret; lpwzLocalFile = lpszLocalFile?WININET_strdup_AtoW(lpszLocalFile):NULL; lpwzNewRemoteFile = lpszNewRemoteFile?WININET_strdup_AtoW(lpszNewRemoteFile):NULL; ret = FtpPutFileW(hConnect, lpwzLocalFile, lpwzNewRemoteFile, dwFlags, dwContext); HeapFree(GetProcessHeap(), 0, lpwzLocalFile); HeapFree(GetProcessHeap(), 0, lpwzNewRemoteFile); return ret; } static void AsyncFtpPutFileProc(WORKREQUEST *workRequest) { struct WORKREQ_FTPPUTFILEW const *req = &workRequest->u.FtpPutFileW; LPWININETFTPSESSIONW lpwfs = (LPWININETFTPSESSIONW) workRequest->hdr; TRACE("%p\n", lpwfs); FTP_FtpPutFileW(lpwfs, req->lpszLocalFile, req->lpszNewRemoteFile, req->dwFlags, req->dwContext); HeapFree(GetProcessHeap(), 0, req->lpszLocalFile); HeapFree(GetProcessHeap(), 0, req->lpszNewRemoteFile); } /*********************************************************************** * FtpPutFileW (WININET.@) * * Uploads a file to the FTP server * * RETURNS * TRUE on success * FALSE on failure * */ BOOL WINAPI FtpPutFileW(HINTERNET hConnect, LPCWSTR lpszLocalFile, LPCWSTR lpszNewRemoteFile, DWORD dwFlags, DWORD_PTR dwContext) { LPWININETFTPSESSIONW lpwfs; LPWININETAPPINFOW hIC = NULL; BOOL r = FALSE; if (!lpszLocalFile || !lpszNewRemoteFile) { INTERNET_SetLastError(ERROR_INVALID_PARAMETER); return FALSE; } lpwfs = (LPWININETFTPSESSIONW) WININET_GetObject( hConnect ); if (!lpwfs) { INTERNET_SetLastError(ERROR_INVALID_HANDLE); return FALSE; } if (WH_HFTPSESSION != lpwfs->hdr.htype) { INTERNET_SetLastError(ERROR_INTERNET_INCORRECT_HANDLE_TYPE); goto lend; } if (lpwfs->download_in_progress != NULL) { INTERNET_SetLastError(ERROR_FTP_TRANSFER_IN_PROGRESS); goto lend; } if ((dwFlags & FTP_CONDITION_MASK) > FTP_TRANSFER_TYPE_BINARY) { INTERNET_SetLastError(ERROR_INVALID_PARAMETER); goto lend; } hIC = lpwfs->lpAppInfo; if (hIC->hdr.dwFlags & INTERNET_FLAG_ASYNC) { WORKREQUEST workRequest; struct WORKREQ_FTPPUTFILEW *req = &workRequest.u.FtpPutFileW; workRequest.asyncproc = AsyncFtpPutFileProc; workRequest.hdr = WININET_AddRef( &lpwfs->hdr ); req->lpszLocalFile = WININET_strdupW(lpszLocalFile); req->lpszNewRemoteFile = WININET_strdupW(lpszNewRemoteFile); req->dwFlags = dwFlags; req->dwContext = dwContext; r = INTERNET_AsyncCall(&workRequest); } else { r = FTP_FtpPutFileW(lpwfs, lpszLocalFile, lpszNewRemoteFile, dwFlags, dwContext); } lend: WININET_Release( &lpwfs->hdr ); return r; } /*********************************************************************** * FTP_FtpPutFileW (Internal) * * Uploads a file to the FTP server * * RETURNS * TRUE on success * FALSE on failure * */ BOOL WINAPI FTP_FtpPutFileW(LPWININETFTPSESSIONW lpwfs, LPCWSTR lpszLocalFile, LPCWSTR lpszNewRemoteFile, DWORD dwFlags, DWORD_PTR dwContext) { HANDLE hFile; BOOL bSuccess = FALSE; LPWININETAPPINFOW hIC = NULL; INT nResCode; TRACE(" lpszLocalFile(%s) lpszNewRemoteFile(%s)\n", debugstr_w(lpszLocalFile), debugstr_w(lpszNewRemoteFile)); /* Clear any error information */ INTERNET_SetLastError(0); /* Open file to be uploaded */ if (INVALID_HANDLE_VALUE == (hFile = CreateFileW(lpszLocalFile, GENERIC_READ, 0, 0, OPEN_EXISTING, 0, 0))) /* Let CreateFile set the appropriate error */ return FALSE; hIC = lpwfs->lpAppInfo; SendAsyncCallback(&lpwfs->hdr, lpwfs->hdr.dwContext, INTERNET_STATUS_SENDING_REQUEST, NULL, 0); if (FTP_SendStore(lpwfs, lpszNewRemoteFile, dwFlags)) { INT nDataSocket; /* Get data socket to server */ if (FTP_GetDataSocket(lpwfs, &nDataSocket)) { FTP_SendData(lpwfs, nDataSocket, hFile); closesocket(nDataSocket); nResCode = FTP_ReceiveResponse(lpwfs, dwContext); if (nResCode) { if (nResCode == 226) bSuccess = TRUE; else FTP_SetResponseError(nResCode); } } } if (lpwfs->lstnSocket != -1) closesocket(lpwfs->lstnSocket); if (hIC->hdr.dwFlags & INTERNET_FLAG_ASYNC) { INTERNET_ASYNC_RESULT iar; iar.dwResult = (DWORD)bSuccess; iar.dwError = bSuccess ? ERROR_SUCCESS : INTERNET_GetLastError(); SendAsyncCallback(&lpwfs->hdr, lpwfs->hdr.dwContext, INTERNET_STATUS_REQUEST_COMPLETE, &iar, sizeof(INTERNET_ASYNC_RESULT)); } CloseHandle(hFile); return bSuccess; } /*********************************************************************** * FtpSetCurrentDirectoryA (WININET.@) * * Change the working directory on the FTP server * * RETURNS * TRUE on success * FALSE on failure * */ BOOL WINAPI FtpSetCurrentDirectoryA(HINTERNET hConnect, LPCSTR lpszDirectory) { LPWSTR lpwzDirectory; BOOL ret; lpwzDirectory = lpszDirectory?WININET_strdup_AtoW(lpszDirectory):NULL; ret = FtpSetCurrentDirectoryW(hConnect, lpwzDirectory); HeapFree(GetProcessHeap(), 0, lpwzDirectory); return ret; } static void AsyncFtpSetCurrentDirectoryProc(WORKREQUEST *workRequest) { struct WORKREQ_FTPSETCURRENTDIRECTORYW const *req = &workRequest->u.FtpSetCurrentDirectoryW; LPWININETFTPSESSIONW lpwfs = (LPWININETFTPSESSIONW) workRequest->hdr; TRACE("%p\n", lpwfs); FTP_FtpSetCurrentDirectoryW(lpwfs, req->lpszDirectory); HeapFree(GetProcessHeap(), 0, req->lpszDirectory); } /*********************************************************************** * FtpSetCurrentDirectoryW (WININET.@) * * Change the working directory on the FTP server * * RETURNS * TRUE on success * FALSE on failure * */ BOOL WINAPI FtpSetCurrentDirectoryW(HINTERNET hConnect, LPCWSTR lpszDirectory) { LPWININETFTPSESSIONW lpwfs = NULL; LPWININETAPPINFOW hIC = NULL; BOOL r = FALSE; if (!lpszDirectory) { INTERNET_SetLastError(ERROR_INVALID_PARAMETER); goto lend; } lpwfs = (LPWININETFTPSESSIONW) WININET_GetObject( hConnect ); if (NULL == lpwfs || WH_HFTPSESSION != lpwfs->hdr.htype) { INTERNET_SetLastError(ERROR_INTERNET_INCORRECT_HANDLE_TYPE); goto lend; } if (lpwfs->download_in_progress != NULL) { INTERNET_SetLastError(ERROR_FTP_TRANSFER_IN_PROGRESS); goto lend; } TRACE("lpszDirectory(%s)\n", debugstr_w(lpszDirectory)); hIC = lpwfs->lpAppInfo; if (hIC->hdr.dwFlags & INTERNET_FLAG_ASYNC) { WORKREQUEST workRequest; struct WORKREQ_FTPSETCURRENTDIRECTORYW *req; workRequest.asyncproc = AsyncFtpSetCurrentDirectoryProc; workRequest.hdr = WININET_AddRef( &lpwfs->hdr ); req = &workRequest.u.FtpSetCurrentDirectoryW; req->lpszDirectory = WININET_strdupW(lpszDirectory); r = INTERNET_AsyncCall(&workRequest); } else { r = FTP_FtpSetCurrentDirectoryW(lpwfs, lpszDirectory); } lend: if( lpwfs ) WININET_Release( &lpwfs->hdr ); return r; } /*********************************************************************** * FTP_FtpSetCurrentDirectoryW (Internal) * * Change the working directory on the FTP server * * RETURNS * TRUE on success * FALSE on failure * */ BOOL WINAPI FTP_FtpSetCurrentDirectoryW(LPWININETFTPSESSIONW lpwfs, LPCWSTR lpszDirectory) { INT nResCode; LPWININETAPPINFOW hIC = NULL; DWORD bSuccess = FALSE; TRACE("lpszDirectory(%s)\n", debugstr_w(lpszDirectory)); /* Clear any error information */ INTERNET_SetLastError(0); hIC = lpwfs->lpAppInfo; if (!FTP_SendCommand(lpwfs->sndSocket, FTP_CMD_CWD, lpszDirectory, lpwfs->hdr.lpfnStatusCB, &lpwfs->hdr, lpwfs->hdr.dwContext)) goto lend; nResCode = FTP_ReceiveResponse(lpwfs, lpwfs->hdr.dwContext); if (nResCode) { if (nResCode == 250) bSuccess = TRUE; else FTP_SetResponseError(nResCode); } lend: if (hIC->hdr.dwFlags & INTERNET_FLAG_ASYNC) { INTERNET_ASYNC_RESULT iar; iar.dwResult = (DWORD)bSuccess; iar.dwError = bSuccess ? ERROR_SUCCESS : ERROR_INTERNET_EXTENDED_ERROR; SendAsyncCallback(&lpwfs->hdr, lpwfs->hdr.dwContext, INTERNET_STATUS_REQUEST_COMPLETE, &iar, sizeof(INTERNET_ASYNC_RESULT)); } return bSuccess; } /*********************************************************************** * FtpCreateDirectoryA (WININET.@) * * Create new directory on the FTP server * * RETURNS * TRUE on success * FALSE on failure * */ BOOL WINAPI FtpCreateDirectoryA(HINTERNET hConnect, LPCSTR lpszDirectory) { LPWSTR lpwzDirectory; BOOL ret; lpwzDirectory = lpszDirectory?WININET_strdup_AtoW(lpszDirectory):NULL; ret = FtpCreateDirectoryW(hConnect, lpwzDirectory); HeapFree(GetProcessHeap(), 0, lpwzDirectory); return ret; } static void AsyncFtpCreateDirectoryProc(WORKREQUEST *workRequest) { struct WORKREQ_FTPCREATEDIRECTORYW const *req = &workRequest->u.FtpCreateDirectoryW; LPWININETFTPSESSIONW lpwfs = (LPWININETFTPSESSIONW) workRequest->hdr; TRACE(" %p\n", lpwfs); FTP_FtpCreateDirectoryW(lpwfs, req->lpszDirectory); HeapFree(GetProcessHeap(), 0, req->lpszDirectory); } /*********************************************************************** * FtpCreateDirectoryW (WININET.@) * * Create new directory on the FTP server * * RETURNS * TRUE on success * FALSE on failure * */ BOOL WINAPI FtpCreateDirectoryW(HINTERNET hConnect, LPCWSTR lpszDirectory) { LPWININETFTPSESSIONW lpwfs; LPWININETAPPINFOW hIC = NULL; BOOL r = FALSE; lpwfs = (LPWININETFTPSESSIONW) WININET_GetObject( hConnect ); if (!lpwfs) { INTERNET_SetLastError(ERROR_INVALID_HANDLE); return FALSE; } if (WH_HFTPSESSION != lpwfs->hdr.htype) { INTERNET_SetLastError(ERROR_INTERNET_INCORRECT_HANDLE_TYPE); goto lend; } if (lpwfs->download_in_progress != NULL) { INTERNET_SetLastError(ERROR_FTP_TRANSFER_IN_PROGRESS); goto lend; } if (!lpszDirectory) { INTERNET_SetLastError(ERROR_INVALID_PARAMETER); goto lend; } hIC = lpwfs->lpAppInfo; if (hIC->hdr.dwFlags & INTERNET_FLAG_ASYNC) { WORKREQUEST workRequest; struct WORKREQ_FTPCREATEDIRECTORYW *req; workRequest.asyncproc = AsyncFtpCreateDirectoryProc; workRequest.hdr = WININET_AddRef( &lpwfs->hdr ); req = &workRequest.u.FtpCreateDirectoryW; req->lpszDirectory = WININET_strdupW(lpszDirectory); r = INTERNET_AsyncCall(&workRequest); } else { r = FTP_FtpCreateDirectoryW(lpwfs, lpszDirectory); } lend: WININET_Release( &lpwfs->hdr ); return r; } /*********************************************************************** * FTP_FtpCreateDirectoryW (Internal) * * Create new directory on the FTP server * * RETURNS * TRUE on success * FALSE on failure * */ BOOL WINAPI FTP_FtpCreateDirectoryW(LPWININETFTPSESSIONW lpwfs, LPCWSTR lpszDirectory) { INT nResCode; BOOL bSuccess = FALSE; LPWININETAPPINFOW hIC = NULL; TRACE("lpszDirectory(%s)\n", debugstr_w(lpszDirectory)); /* Clear any error information */ INTERNET_SetLastError(0); if (!FTP_SendCommand(lpwfs->sndSocket, FTP_CMD_MKD, lpszDirectory, 0, 0, 0)) goto lend; nResCode = FTP_ReceiveResponse(lpwfs, lpwfs->hdr.dwContext); if (nResCode) { if (nResCode == 257) bSuccess = TRUE; else FTP_SetResponseError(nResCode); } lend: hIC = lpwfs->lpAppInfo; if (hIC->hdr.dwFlags & INTERNET_FLAG_ASYNC) { INTERNET_ASYNC_RESULT iar; iar.dwResult = (DWORD)bSuccess; iar.dwError = bSuccess ? ERROR_SUCCESS : INTERNET_GetLastError(); SendAsyncCallback(&lpwfs->hdr, lpwfs->hdr.dwContext, INTERNET_STATUS_REQUEST_COMPLETE, &iar, sizeof(INTERNET_ASYNC_RESULT)); } return bSuccess; } /*********************************************************************** * FtpFindFirstFileA (WININET.@) * * Search the specified directory * * RETURNS * HINTERNET on success * NULL on failure * */ HINTERNET WINAPI FtpFindFirstFileA(HINTERNET hConnect, LPCSTR lpszSearchFile, LPWIN32_FIND_DATAA lpFindFileData, DWORD dwFlags, DWORD_PTR dwContext) { LPWSTR lpwzSearchFile; WIN32_FIND_DATAW wfd; LPWIN32_FIND_DATAW lpFindFileDataW; HINTERNET ret; lpwzSearchFile = lpszSearchFile?WININET_strdup_AtoW(lpszSearchFile):NULL; lpFindFileDataW = lpFindFileData?&wfd:NULL; ret = FtpFindFirstFileW(hConnect, lpwzSearchFile, lpFindFileDataW, dwFlags, dwContext); HeapFree(GetProcessHeap(), 0, lpwzSearchFile); if(lpFindFileData) { WININET_find_data_WtoA(lpFindFileDataW, lpFindFileData); } return ret; } static void AsyncFtpFindFirstFileProc(WORKREQUEST *workRequest) { struct WORKREQ_FTPFINDFIRSTFILEW const *req = &workRequest->u.FtpFindFirstFileW; LPWININETFTPSESSIONW lpwfs = (LPWININETFTPSESSIONW) workRequest->hdr; TRACE("%p\n", lpwfs); FTP_FtpFindFirstFileW(lpwfs, req->lpszSearchFile, req->lpFindFileData, req->dwFlags, req->dwContext); HeapFree(GetProcessHeap(), 0, req->lpszSearchFile); } /*********************************************************************** * FtpFindFirstFileW (WININET.@) * * Search the specified directory * * RETURNS * HINTERNET on success * NULL on failure * */ HINTERNET WINAPI FtpFindFirstFileW(HINTERNET hConnect, LPCWSTR lpszSearchFile, LPWIN32_FIND_DATAW lpFindFileData, DWORD dwFlags, DWORD_PTR dwContext) { LPWININETFTPSESSIONW lpwfs; LPWININETAPPINFOW hIC = NULL; HINTERNET r = NULL; lpwfs = (LPWININETFTPSESSIONW) WININET_GetObject( hConnect ); if (NULL == lpwfs || WH_HFTPSESSION != lpwfs->hdr.htype) { INTERNET_SetLastError(ERROR_INTERNET_INCORRECT_HANDLE_TYPE); goto lend; } if (lpwfs->download_in_progress != NULL) { INTERNET_SetLastError(ERROR_FTP_TRANSFER_IN_PROGRESS); goto lend; } hIC = lpwfs->lpAppInfo; if (hIC->hdr.dwFlags & INTERNET_FLAG_ASYNC) { WORKREQUEST workRequest; struct WORKREQ_FTPFINDFIRSTFILEW *req; workRequest.asyncproc = AsyncFtpFindFirstFileProc; workRequest.hdr = WININET_AddRef( &lpwfs->hdr ); req = &workRequest.u.FtpFindFirstFileW; req->lpszSearchFile = (lpszSearchFile == NULL) ? NULL : WININET_strdupW(lpszSearchFile); req->lpFindFileData = lpFindFileData; req->dwFlags = dwFlags; req->dwContext= dwContext; INTERNET_AsyncCall(&workRequest); r = NULL; } else { r = FTP_FtpFindFirstFileW(lpwfs, lpszSearchFile, lpFindFileData, dwFlags, dwContext); } lend: if( lpwfs ) WININET_Release( &lpwfs->hdr ); return r; } /*********************************************************************** * FTP_FtpFindFirstFileW (Internal) * * Search the specified directory * * RETURNS * HINTERNET on success * NULL on failure * */ HINTERNET WINAPI FTP_FtpFindFirstFileW(LPWININETFTPSESSIONW lpwfs, LPCWSTR lpszSearchFile, LPWIN32_FIND_DATAW lpFindFileData, DWORD dwFlags, DWORD_PTR dwContext) { INT nResCode; LPWININETAPPINFOW hIC = NULL; HINTERNET hFindNext = NULL; TRACE("\n"); /* Clear any error information */ INTERNET_SetLastError(0); if (!FTP_InitListenSocket(lpwfs)) goto lend; if (!FTP_SendType(lpwfs, INTERNET_FLAG_TRANSFER_ASCII)) goto lend; if (!FTP_SendPortOrPasv(lpwfs)) goto lend; if (!FTP_SendCommand(lpwfs->sndSocket, FTP_CMD_LIST, NULL, lpwfs->hdr.lpfnStatusCB, &lpwfs->hdr, lpwfs->hdr.dwContext)) goto lend; nResCode = FTP_ReceiveResponse(lpwfs, lpwfs->hdr.dwContext); if (nResCode) { if (nResCode == 125 || nResCode == 150) { INT nDataSocket; /* Get data socket to server */ if (FTP_GetDataSocket(lpwfs, &nDataSocket)) { hFindNext = FTP_ReceiveFileList(lpwfs, nDataSocket, lpszSearchFile, lpFindFileData, dwContext); closesocket(nDataSocket); nResCode = FTP_ReceiveResponse(lpwfs, lpwfs->hdr.dwContext); if (nResCode != 226 && nResCode != 250) INTERNET_SetLastError(ERROR_NO_MORE_FILES); } } else FTP_SetResponseError(nResCode); } lend: if (lpwfs->lstnSocket != -1) closesocket(lpwfs->lstnSocket); hIC = lpwfs->lpAppInfo; if (hIC->hdr.dwFlags & INTERNET_FLAG_ASYNC) { INTERNET_ASYNC_RESULT iar; if (hFindNext) { iar.dwResult = (DWORD)hFindNext; iar.dwError = ERROR_SUCCESS; SendAsyncCallback(&lpwfs->hdr, lpwfs->hdr.dwContext, INTERNET_STATUS_HANDLE_CREATED, &iar, sizeof(INTERNET_ASYNC_RESULT)); } iar.dwResult = (DWORD)hFindNext; iar.dwError = hFindNext ? ERROR_SUCCESS : INTERNET_GetLastError(); SendAsyncCallback(&lpwfs->hdr, lpwfs->hdr.dwContext, INTERNET_STATUS_REQUEST_COMPLETE, &iar, sizeof(INTERNET_ASYNC_RESULT)); } return hFindNext; } /*********************************************************************** * FtpGetCurrentDirectoryA (WININET.@) * * Retrieves the current directory * * RETURNS * TRUE on success * FALSE on failure * */ BOOL WINAPI FtpGetCurrentDirectoryA(HINTERNET hFtpSession, LPSTR lpszCurrentDirectory, LPDWORD lpdwCurrentDirectory) { WCHAR *dir = NULL; DWORD len; BOOL ret; if(lpdwCurrentDirectory) { len = *lpdwCurrentDirectory; if(lpszCurrentDirectory) { dir = HeapAlloc(GetProcessHeap(), 0, len * sizeof(WCHAR)); if (NULL == dir) { INTERNET_SetLastError(ERROR_OUTOFMEMORY); return FALSE; } } } ret = FtpGetCurrentDirectoryW(hFtpSession, lpszCurrentDirectory?dir:NULL, lpdwCurrentDirectory?&len:NULL); if(lpdwCurrentDirectory) { *lpdwCurrentDirectory = len; if(lpszCurrentDirectory) { WideCharToMultiByte(CP_ACP, 0, dir, len, lpszCurrentDirectory, *lpdwCurrentDirectory, NULL, NULL); HeapFree(GetProcessHeap(), 0, dir); } } return ret; } static void AsyncFtpGetCurrentDirectoryProc(WORKREQUEST *workRequest) { struct WORKREQ_FTPGETCURRENTDIRECTORYW const *req = &workRequest->u.FtpGetCurrentDirectoryW; LPWININETFTPSESSIONW lpwfs = (LPWININETFTPSESSIONW) workRequest->hdr; TRACE("%p\n", lpwfs); FTP_FtpGetCurrentDirectoryW(lpwfs, req->lpszDirectory, req->lpdwDirectory); } /*********************************************************************** * FtpGetCurrentDirectoryW (WININET.@) * * Retrieves the current directory * * RETURNS * TRUE on success * FALSE on failure * */ BOOL WINAPI FtpGetCurrentDirectoryW(HINTERNET hFtpSession, LPWSTR lpszCurrentDirectory, LPDWORD lpdwCurrentDirectory) { LPWININETFTPSESSIONW lpwfs; LPWININETAPPINFOW hIC = NULL; BOOL r = FALSE; TRACE("len(%d)\n", *lpdwCurrentDirectory); lpwfs = (LPWININETFTPSESSIONW) WININET_GetObject( hFtpSession ); if (NULL == lpwfs || WH_HFTPSESSION != lpwfs->hdr.htype) { INTERNET_SetLastError(ERROR_INTERNET_INCORRECT_HANDLE_TYPE); goto lend; } if (lpwfs->download_in_progress != NULL) { INTERNET_SetLastError(ERROR_FTP_TRANSFER_IN_PROGRESS); goto lend; } hIC = lpwfs->lpAppInfo; if (hIC->hdr.dwFlags & INTERNET_FLAG_ASYNC) { WORKREQUEST workRequest; struct WORKREQ_FTPGETCURRENTDIRECTORYW *req; workRequest.asyncproc = AsyncFtpGetCurrentDirectoryProc; workRequest.hdr = WININET_AddRef( &lpwfs->hdr ); req = &workRequest.u.FtpGetCurrentDirectoryW; req->lpszDirectory = lpszCurrentDirectory; req->lpdwDirectory = lpdwCurrentDirectory; r = INTERNET_AsyncCall(&workRequest); } else { r = FTP_FtpGetCurrentDirectoryW(lpwfs, lpszCurrentDirectory, lpdwCurrentDirectory); } lend: if( lpwfs ) WININET_Release( &lpwfs->hdr ); return r; } /*********************************************************************** * FTP_FtpGetCurrentDirectoryW (Internal) * * Retrieves the current directory * * RETURNS * TRUE on success * FALSE on failure * */ BOOL WINAPI FTP_FtpGetCurrentDirectoryW(LPWININETFTPSESSIONW lpwfs, LPWSTR lpszCurrentDirectory, LPDWORD lpdwCurrentDirectory) { INT nResCode; LPWININETAPPINFOW hIC = NULL; DWORD bSuccess = FALSE; TRACE("len(%d)\n", *lpdwCurrentDirectory); /* Clear any error information */ INTERNET_SetLastError(0); ZeroMemory(lpszCurrentDirectory, *lpdwCurrentDirectory); hIC = lpwfs->lpAppInfo; if (!FTP_SendCommand(lpwfs->sndSocket, FTP_CMD_PWD, NULL, lpwfs->hdr.lpfnStatusCB, &lpwfs->hdr, lpwfs->hdr.dwContext)) goto lend; nResCode = FTP_ReceiveResponse(lpwfs, lpwfs->hdr.dwContext); if (nResCode) { if (nResCode == 257) /* Extract directory name */ { DWORD firstpos, lastpos, len; LPWSTR lpszResponseBuffer = WININET_strdup_AtoW(INTERNET_GetResponseBuffer()); for (firstpos = 0, lastpos = 0; lpszResponseBuffer[lastpos]; lastpos++) { if ('"' == lpszResponseBuffer[lastpos]) { if (!firstpos) firstpos = lastpos; else break; } } len = lastpos - firstpos - 1; lstrcpynW(lpszCurrentDirectory, &lpszResponseBuffer[firstpos+1], *lpdwCurrentDirectory); HeapFree(GetProcessHeap(), 0, lpszResponseBuffer); *lpdwCurrentDirectory = len; bSuccess = TRUE; } else FTP_SetResponseError(nResCode); } lend: if (hIC->hdr.dwFlags & INTERNET_FLAG_ASYNC) { INTERNET_ASYNC_RESULT iar; iar.dwResult = (DWORD)bSuccess; iar.dwError = bSuccess ? ERROR_SUCCESS : ERROR_INTERNET_EXTENDED_ERROR; SendAsyncCallback(&lpwfs->hdr, lpwfs->hdr.dwContext, INTERNET_STATUS_REQUEST_COMPLETE, &iar, sizeof(INTERNET_ASYNC_RESULT)); } return (DWORD) bSuccess; } /*********************************************************************** * FtpOpenFileA (WININET.@) * * Open a remote file for writing or reading * * RETURNS * HINTERNET handle on success * NULL on failure * */ HINTERNET WINAPI FtpOpenFileA(HINTERNET hFtpSession, LPCSTR lpszFileName, DWORD fdwAccess, DWORD dwFlags, DWORD_PTR dwContext) { LPWSTR lpwzFileName; HINTERNET ret; lpwzFileName = lpszFileName?WININET_strdup_AtoW(lpszFileName):NULL; ret = FtpOpenFileW(hFtpSession, lpwzFileName, fdwAccess, dwFlags, dwContext); HeapFree(GetProcessHeap(), 0, lpwzFileName); return ret; } static void AsyncFtpOpenFileProc(WORKREQUEST *workRequest) { struct WORKREQ_FTPOPENFILEW const *req = &workRequest->u.FtpOpenFileW; LPWININETFTPSESSIONW lpwfs = (LPWININETFTPSESSIONW) workRequest->hdr; TRACE("%p\n", lpwfs); FTP_FtpOpenFileW(lpwfs, req->lpszFilename, req->dwAccess, req->dwFlags, req->dwContext); HeapFree(GetProcessHeap(), 0, req->lpszFilename); } /*********************************************************************** * FtpOpenFileW (WININET.@) * * Open a remote file for writing or reading * * RETURNS * HINTERNET handle on success * NULL on failure * */ HINTERNET WINAPI FtpOpenFileW(HINTERNET hFtpSession, LPCWSTR lpszFileName, DWORD fdwAccess, DWORD dwFlags, DWORD_PTR dwContext) { LPWININETFTPSESSIONW lpwfs; LPWININETAPPINFOW hIC = NULL; HINTERNET r = NULL; TRACE("(%p,%s,0x%08x,0x%08x,0x%08lx)\n", hFtpSession, debugstr_w(lpszFileName), fdwAccess, dwFlags, dwContext); lpwfs = (LPWININETFTPSESSIONW) WININET_GetObject( hFtpSession ); if (!lpwfs) { INTERNET_SetLastError(ERROR_INVALID_HANDLE); return FALSE; } if (WH_HFTPSESSION != lpwfs->hdr.htype) { INTERNET_SetLastError(ERROR_INTERNET_INCORRECT_HANDLE_TYPE); goto lend; } if ((!lpszFileName) || ((fdwAccess != GENERIC_READ) && (fdwAccess != GENERIC_WRITE)) || ((dwFlags & FTP_CONDITION_MASK) > FTP_TRANSFER_TYPE_BINARY)) { INTERNET_SetLastError(ERROR_INVALID_PARAMETER); goto lend; } if (lpwfs->download_in_progress != NULL) { INTERNET_SetLastError(ERROR_FTP_TRANSFER_IN_PROGRESS); goto lend; } hIC = lpwfs->lpAppInfo; if (hIC->hdr.dwFlags & INTERNET_FLAG_ASYNC) { WORKREQUEST workRequest; struct WORKREQ_FTPOPENFILEW *req; workRequest.asyncproc = AsyncFtpOpenFileProc; workRequest.hdr = WININET_AddRef( &lpwfs->hdr ); req = &workRequest.u.FtpOpenFileW; req->lpszFilename = WININET_strdupW(lpszFileName); req->dwAccess = fdwAccess; req->dwFlags = dwFlags; req->dwContext = dwContext; INTERNET_AsyncCall(&workRequest); r = NULL; } else { r = FTP_FtpOpenFileW(lpwfs, lpszFileName, fdwAccess, dwFlags, dwContext); } lend: WININET_Release( &lpwfs->hdr ); return r; } /*********************************************************************** * FTP_FtpOpenFileW (Internal) * * Open a remote file for writing or reading * * RETURNS * HINTERNET handle on success * NULL on failure * */ HINTERNET FTP_FtpOpenFileW(LPWININETFTPSESSIONW lpwfs, LPCWSTR lpszFileName, DWORD fdwAccess, DWORD dwFlags, DWORD_PTR dwContext) { INT nDataSocket; BOOL bSuccess = FALSE; LPWININETFTPFILE lpwh = NULL; LPWININETAPPINFOW hIC = NULL; HINTERNET handle = NULL; TRACE("\n"); /* Clear any error information */ INTERNET_SetLastError(0); if (GENERIC_READ == fdwAccess) { /* Set up socket to retrieve data */ bSuccess = FTP_SendRetrieve(lpwfs, lpszFileName, dwFlags); } else if (GENERIC_WRITE == fdwAccess) { /* Set up socket to send data */ bSuccess = FTP_SendStore(lpwfs, lpszFileName, dwFlags); } /* Get data socket to server */ if (bSuccess && FTP_GetDataSocket(lpwfs, &nDataSocket)) { lpwh = HeapAlloc(GetProcessHeap(), 0, sizeof(WININETFTPFILE)); lpwh->hdr.htype = WH_HFILE; lpwh->hdr.dwFlags = dwFlags; lpwh->hdr.dwContext = dwContext; lpwh->hdr.dwRefCount = 1; lpwh->hdr.close_connection = NULL; lpwh->hdr.destroy = FTP_CloseFileTransferHandle; lpwh->hdr.lpfnStatusCB = lpwfs->hdr.lpfnStatusCB; lpwh->nDataSocket = nDataSocket; lpwh->session_deleted = FALSE; WININET_AddRef( &lpwfs->hdr ); lpwh->lpFtpSession = lpwfs; list_add_head( &lpwfs->hdr.children, &lpwh->hdr.entry ); handle = WININET_AllocHandle( &lpwh->hdr ); if( !handle ) goto lend; /* Indicate that a download is currently in progress */ lpwfs->download_in_progress = lpwh; } if (lpwfs->lstnSocket != -1) closesocket(lpwfs->lstnSocket); hIC = lpwfs->lpAppInfo; if (hIC->hdr.dwFlags & INTERNET_FLAG_ASYNC) { INTERNET_ASYNC_RESULT iar; if (lpwh) { iar.dwResult = (DWORD)handle; iar.dwError = ERROR_SUCCESS; SendAsyncCallback(&lpwfs->hdr, lpwfs->hdr.dwContext, INTERNET_STATUS_HANDLE_CREATED, &iar, sizeof(INTERNET_ASYNC_RESULT)); } iar.dwResult = (DWORD)bSuccess; iar.dwError = bSuccess ? ERROR_SUCCESS : INTERNET_GetLastError(); SendAsyncCallback(&lpwfs->hdr, lpwfs->hdr.dwContext, INTERNET_STATUS_REQUEST_COMPLETE, &iar, sizeof(INTERNET_ASYNC_RESULT)); } lend: if( lpwh ) WININET_Release( &lpwh->hdr ); return handle; } /*********************************************************************** * FtpGetFileA (WININET.@) * * Retrieve file from the FTP server * * RETURNS * TRUE on success * FALSE on failure * */ BOOL WINAPI FtpGetFileA(HINTERNET hInternet, LPCSTR lpszRemoteFile, LPCSTR lpszNewFile, BOOL fFailIfExists, DWORD dwLocalFlagsAttribute, DWORD dwInternetFlags, DWORD_PTR dwContext) { LPWSTR lpwzRemoteFile; LPWSTR lpwzNewFile; BOOL ret; lpwzRemoteFile = lpszRemoteFile?WININET_strdup_AtoW(lpszRemoteFile):NULL; lpwzNewFile = lpszNewFile?WININET_strdup_AtoW(lpszNewFile):NULL; ret = FtpGetFileW(hInternet, lpwzRemoteFile, lpwzNewFile, fFailIfExists, dwLocalFlagsAttribute, dwInternetFlags, dwContext); HeapFree(GetProcessHeap(), 0, lpwzRemoteFile); HeapFree(GetProcessHeap(), 0, lpwzNewFile); return ret; } static void AsyncFtpGetFileProc(WORKREQUEST *workRequest) { struct WORKREQ_FTPGETFILEW const *req = &workRequest->u.FtpGetFileW; LPWININETFTPSESSIONW lpwfs = (LPWININETFTPSESSIONW) workRequest->hdr; TRACE("%p\n", lpwfs); FTP_FtpGetFileW(lpwfs, req->lpszRemoteFile, req->lpszNewFile, req->fFailIfExists, req->dwLocalFlagsAttribute, req->dwFlags, req->dwContext); HeapFree(GetProcessHeap(), 0, req->lpszRemoteFile); HeapFree(GetProcessHeap(), 0, req->lpszNewFile); } /*********************************************************************** * FtpGetFileW (WININET.@) * * Retrieve file from the FTP server * * RETURNS * TRUE on success * FALSE on failure * */ BOOL WINAPI FtpGetFileW(HINTERNET hInternet, LPCWSTR lpszRemoteFile, LPCWSTR lpszNewFile, BOOL fFailIfExists, DWORD dwLocalFlagsAttribute, DWORD dwInternetFlags, DWORD_PTR dwContext) { LPWININETFTPSESSIONW lpwfs; LPWININETAPPINFOW hIC = NULL; BOOL r = FALSE; if (!lpszRemoteFile || !lpszNewFile) { INTERNET_SetLastError(ERROR_INVALID_PARAMETER); return FALSE; } lpwfs = (LPWININETFTPSESSIONW) WININET_GetObject( hInternet ); if (!lpwfs) { INTERNET_SetLastError(ERROR_INVALID_HANDLE); return FALSE; } if (WH_HFTPSESSION != lpwfs->hdr.htype) { INTERNET_SetLastError(ERROR_INTERNET_INCORRECT_HANDLE_TYPE); goto lend; } if ((dwInternetFlags & FTP_CONDITION_MASK) > FTP_TRANSFER_TYPE_BINARY) { INTERNET_SetLastError(ERROR_INVALID_PARAMETER); goto lend; } if (lpwfs->download_in_progress != NULL) { INTERNET_SetLastError(ERROR_FTP_TRANSFER_IN_PROGRESS); goto lend; } hIC = lpwfs->lpAppInfo; if (hIC->hdr.dwFlags & INTERNET_FLAG_ASYNC) { WORKREQUEST workRequest; struct WORKREQ_FTPGETFILEW *req; workRequest.asyncproc = AsyncFtpGetFileProc; workRequest.hdr = WININET_AddRef( &lpwfs->hdr ); req = &workRequest.u.FtpGetFileW; req->lpszRemoteFile = WININET_strdupW(lpszRemoteFile); req->lpszNewFile = WININET_strdupW(lpszNewFile); req->dwLocalFlagsAttribute = dwLocalFlagsAttribute; req->fFailIfExists = fFailIfExists; req->dwFlags = dwInternetFlags; req->dwContext = dwContext; r = INTERNET_AsyncCall(&workRequest); } else { r = FTP_FtpGetFileW(lpwfs, lpszRemoteFile, lpszNewFile, fFailIfExists, dwLocalFlagsAttribute, dwInternetFlags, dwContext); } lend: WININET_Release( &lpwfs->hdr ); return r; } /*********************************************************************** * FTP_FtpGetFileW (Internal) * * Retrieve file from the FTP server * * RETURNS * TRUE on success * FALSE on failure * */ BOOL WINAPI FTP_FtpGetFileW(LPWININETFTPSESSIONW lpwfs, LPCWSTR lpszRemoteFile, LPCWSTR lpszNewFile, BOOL fFailIfExists, DWORD dwLocalFlagsAttribute, DWORD dwInternetFlags, DWORD_PTR dwContext) { BOOL bSuccess = FALSE; HANDLE hFile; LPWININETAPPINFOW hIC = NULL; TRACE("lpszRemoteFile(%s) lpszNewFile(%s)\n", debugstr_w(lpszRemoteFile), debugstr_w(lpszNewFile)); /* Clear any error information */ INTERNET_SetLastError(0); /* Ensure we can write to lpszNewfile by opening it */ hFile = CreateFileW(lpszNewFile, GENERIC_WRITE, 0, 0, fFailIfExists ? CREATE_NEW : CREATE_ALWAYS, dwLocalFlagsAttribute, 0); if (INVALID_HANDLE_VALUE == hFile) return FALSE; /* Set up socket to retrieve data */ if (FTP_SendRetrieve(lpwfs, lpszRemoteFile, dwInternetFlags)) { INT nDataSocket; /* Get data socket to server */ if (FTP_GetDataSocket(lpwfs, &nDataSocket)) { INT nResCode; /* Receive data */ FTP_RetrieveFileData(lpwfs, nDataSocket, hFile); closesocket(nDataSocket); nResCode = FTP_ReceiveResponse(lpwfs, dwContext); if (nResCode) { if (nResCode == 226) bSuccess = TRUE; else FTP_SetResponseError(nResCode); } } } if (lpwfs->lstnSocket != -1) closesocket(lpwfs->lstnSocket); CloseHandle(hFile); hIC = lpwfs->lpAppInfo; if (hIC->hdr.dwFlags & INTERNET_FLAG_ASYNC) { INTERNET_ASYNC_RESULT iar; iar.dwResult = (DWORD)bSuccess; iar.dwError = bSuccess ? ERROR_SUCCESS : INTERNET_GetLastError(); SendAsyncCallback(&lpwfs->hdr, lpwfs->hdr.dwContext, INTERNET_STATUS_REQUEST_COMPLETE, &iar, sizeof(INTERNET_ASYNC_RESULT)); } return bSuccess; } /*********************************************************************** * FtpGetFileSize (WININET.@) */ DWORD WINAPI FtpGetFileSize( HINTERNET hFile, LPDWORD lpdwFileSizeHigh ) { FIXME("(%p, %p)\n", hFile, lpdwFileSizeHigh); if (lpdwFileSizeHigh) *lpdwFileSizeHigh = 0; return 0; } /*********************************************************************** * FtpDeleteFileA (WININET.@) * * Delete a file on the ftp server * * RETURNS * TRUE on success * FALSE on failure * */ BOOL WINAPI FtpDeleteFileA(HINTERNET hFtpSession, LPCSTR lpszFileName) { LPWSTR lpwzFileName; BOOL ret; lpwzFileName = lpszFileName?WININET_strdup_AtoW(lpszFileName):NULL; ret = FtpDeleteFileW(hFtpSession, lpwzFileName); HeapFree(GetProcessHeap(), 0, lpwzFileName); return ret; } static void AsyncFtpDeleteFileProc(WORKREQUEST *workRequest) { struct WORKREQ_FTPDELETEFILEW const *req = &workRequest->u.FtpDeleteFileW; LPWININETFTPSESSIONW lpwfs = (LPWININETFTPSESSIONW) workRequest->hdr; TRACE("%p\n", lpwfs); FTP_FtpDeleteFileW(lpwfs, req->lpszFilename); HeapFree(GetProcessHeap(), 0, req->lpszFilename); } /*********************************************************************** * FtpDeleteFileW (WININET.@) * * Delete a file on the ftp server * * RETURNS * TRUE on success * FALSE on failure * */ BOOL WINAPI FtpDeleteFileW(HINTERNET hFtpSession, LPCWSTR lpszFileName) { LPWININETFTPSESSIONW lpwfs; LPWININETAPPINFOW hIC = NULL; BOOL r = FALSE; lpwfs = (LPWININETFTPSESSIONW) WININET_GetObject( hFtpSession ); if (!lpwfs) { INTERNET_SetLastError(ERROR_INVALID_HANDLE); return FALSE; } if (WH_HFTPSESSION != lpwfs->hdr.htype) { INTERNET_SetLastError(ERROR_INTERNET_INCORRECT_HANDLE_TYPE); goto lend; } if (lpwfs->download_in_progress != NULL) { INTERNET_SetLastError(ERROR_FTP_TRANSFER_IN_PROGRESS); goto lend; } if (!lpszFileName) { INTERNET_SetLastError(ERROR_INVALID_PARAMETER); goto lend; } hIC = lpwfs->lpAppInfo; if (hIC->hdr.dwFlags & INTERNET_FLAG_ASYNC) { WORKREQUEST workRequest; struct WORKREQ_FTPDELETEFILEW *req; workRequest.asyncproc = AsyncFtpDeleteFileProc; workRequest.hdr = WININET_AddRef( &lpwfs->hdr ); req = &workRequest.u.FtpDeleteFileW; req->lpszFilename = WININET_strdupW(lpszFileName); r = INTERNET_AsyncCall(&workRequest); } else { r = FTP_FtpDeleteFileW(lpwfs, lpszFileName); } lend: WININET_Release( &lpwfs->hdr ); return r; } /*********************************************************************** * FTP_FtpDeleteFileW (Internal) * * Delete a file on the ftp server * * RETURNS * TRUE on success * FALSE on failure * */ BOOL FTP_FtpDeleteFileW(LPWININETFTPSESSIONW lpwfs, LPCWSTR lpszFileName) { INT nResCode; BOOL bSuccess = FALSE; LPWININETAPPINFOW hIC = NULL; TRACE("%p\n", lpwfs); /* Clear any error information */ INTERNET_SetLastError(0); if (!FTP_SendCommand(lpwfs->sndSocket, FTP_CMD_DELE, lpszFileName, 0, 0, 0)) goto lend; nResCode = FTP_ReceiveResponse(lpwfs, lpwfs->hdr.dwContext); if (nResCode) { if (nResCode == 250) bSuccess = TRUE; else FTP_SetResponseError(nResCode); } lend: hIC = lpwfs->lpAppInfo; if (hIC->hdr.dwFlags & INTERNET_FLAG_ASYNC) { INTERNET_ASYNC_RESULT iar; iar.dwResult = (DWORD)bSuccess; iar.dwError = bSuccess ? ERROR_SUCCESS : INTERNET_GetLastError(); SendAsyncCallback(&lpwfs->hdr, lpwfs->hdr.dwContext, INTERNET_STATUS_REQUEST_COMPLETE, &iar, sizeof(INTERNET_ASYNC_RESULT)); } return bSuccess; } /*********************************************************************** * FtpRemoveDirectoryA (WININET.@) * * Remove a directory on the ftp server * * RETURNS * TRUE on success * FALSE on failure * */ BOOL WINAPI FtpRemoveDirectoryA(HINTERNET hFtpSession, LPCSTR lpszDirectory) { LPWSTR lpwzDirectory; BOOL ret; lpwzDirectory = lpszDirectory?WININET_strdup_AtoW(lpszDirectory):NULL; ret = FtpRemoveDirectoryW(hFtpSession, lpwzDirectory); HeapFree(GetProcessHeap(), 0, lpwzDirectory); return ret; } static void AsyncFtpRemoveDirectoryProc(WORKREQUEST *workRequest) { struct WORKREQ_FTPREMOVEDIRECTORYW const *req = &workRequest->u.FtpRemoveDirectoryW; LPWININETFTPSESSIONW lpwfs = (LPWININETFTPSESSIONW) workRequest->hdr; TRACE("%p\n", lpwfs); FTP_FtpRemoveDirectoryW(lpwfs, req->lpszDirectory); HeapFree(GetProcessHeap(), 0, req->lpszDirectory); } /*********************************************************************** * FtpRemoveDirectoryW (WININET.@) * * Remove a directory on the ftp server * * RETURNS * TRUE on success * FALSE on failure * */ BOOL WINAPI FtpRemoveDirectoryW(HINTERNET hFtpSession, LPCWSTR lpszDirectory) { LPWININETFTPSESSIONW lpwfs; LPWININETAPPINFOW hIC = NULL; BOOL r = FALSE; lpwfs = (LPWININETFTPSESSIONW) WININET_GetObject( hFtpSession ); if (!lpwfs) { INTERNET_SetLastError(ERROR_INVALID_HANDLE); return FALSE; } if (WH_HFTPSESSION != lpwfs->hdr.htype) { INTERNET_SetLastError(ERROR_INTERNET_INCORRECT_HANDLE_TYPE); goto lend; } if (lpwfs->download_in_progress != NULL) { INTERNET_SetLastError(ERROR_FTP_TRANSFER_IN_PROGRESS); goto lend; } if (!lpszDirectory) { INTERNET_SetLastError(ERROR_INVALID_PARAMETER); goto lend; } hIC = lpwfs->lpAppInfo; if (hIC->hdr.dwFlags & INTERNET_FLAG_ASYNC) { WORKREQUEST workRequest; struct WORKREQ_FTPREMOVEDIRECTORYW *req; workRequest.asyncproc = AsyncFtpRemoveDirectoryProc; workRequest.hdr = WININET_AddRef( &lpwfs->hdr ); req = &workRequest.u.FtpRemoveDirectoryW; req->lpszDirectory = WININET_strdupW(lpszDirectory); r = INTERNET_AsyncCall(&workRequest); } else { r = FTP_FtpRemoveDirectoryW(lpwfs, lpszDirectory); } lend: WININET_Release( &lpwfs->hdr ); return r; } /*********************************************************************** * FTP_FtpRemoveDirectoryW (Internal) * * Remove a directory on the ftp server * * RETURNS * TRUE on success * FALSE on failure * */ BOOL FTP_FtpRemoveDirectoryW(LPWININETFTPSESSIONW lpwfs, LPCWSTR lpszDirectory) { INT nResCode; BOOL bSuccess = FALSE; LPWININETAPPINFOW hIC = NULL; TRACE("\n"); /* Clear any error information */ INTERNET_SetLastError(0); if (!FTP_SendCommand(lpwfs->sndSocket, FTP_CMD_RMD, lpszDirectory, 0, 0, 0)) goto lend; nResCode = FTP_ReceiveResponse(lpwfs, lpwfs->hdr.dwContext); if (nResCode) { if (nResCode == 250) bSuccess = TRUE; else FTP_SetResponseError(nResCode); } lend: hIC = lpwfs->lpAppInfo; if (hIC->hdr.dwFlags & INTERNET_FLAG_ASYNC) { INTERNET_ASYNC_RESULT iar; iar.dwResult = (DWORD)bSuccess; iar.dwError = bSuccess ? ERROR_SUCCESS : INTERNET_GetLastError(); SendAsyncCallback(&lpwfs->hdr, lpwfs->hdr.dwContext, INTERNET_STATUS_REQUEST_COMPLETE, &iar, sizeof(INTERNET_ASYNC_RESULT)); } return bSuccess; } /*********************************************************************** * FtpRenameFileA (WININET.@) * * Rename a file on the ftp server * * RETURNS * TRUE on success * FALSE on failure * */ BOOL WINAPI FtpRenameFileA(HINTERNET hFtpSession, LPCSTR lpszSrc, LPCSTR lpszDest) { LPWSTR lpwzSrc; LPWSTR lpwzDest; BOOL ret; lpwzSrc = lpszSrc?WININET_strdup_AtoW(lpszSrc):NULL; lpwzDest = lpszDest?WININET_strdup_AtoW(lpszDest):NULL; ret = FtpRenameFileW(hFtpSession, lpwzSrc, lpwzDest); HeapFree(GetProcessHeap(), 0, lpwzSrc); HeapFree(GetProcessHeap(), 0, lpwzDest); return ret; } static void AsyncFtpRenameFileProc(WORKREQUEST *workRequest) { struct WORKREQ_FTPRENAMEFILEW const *req = &workRequest->u.FtpRenameFileW; LPWININETFTPSESSIONW lpwfs = (LPWININETFTPSESSIONW) workRequest->hdr; TRACE("%p\n", lpwfs); FTP_FtpRenameFileW(lpwfs, req->lpszSrcFile, req->lpszDestFile); HeapFree(GetProcessHeap(), 0, req->lpszSrcFile); HeapFree(GetProcessHeap(), 0, req->lpszDestFile); } /*********************************************************************** * FtpRenameFileW (WININET.@) * * Rename a file on the ftp server * * RETURNS * TRUE on success * FALSE on failure * */ BOOL WINAPI FtpRenameFileW(HINTERNET hFtpSession, LPCWSTR lpszSrc, LPCWSTR lpszDest) { LPWININETFTPSESSIONW lpwfs; LPWININETAPPINFOW hIC = NULL; BOOL r = FALSE; lpwfs = (LPWININETFTPSESSIONW) WININET_GetObject( hFtpSession ); if (!lpwfs) { INTERNET_SetLastError(ERROR_INVALID_HANDLE); return FALSE; } if (WH_HFTPSESSION != lpwfs->hdr.htype) { INTERNET_SetLastError(ERROR_INTERNET_INCORRECT_HANDLE_TYPE); goto lend; } if (lpwfs->download_in_progress != NULL) { INTERNET_SetLastError(ERROR_FTP_TRANSFER_IN_PROGRESS); goto lend; } if (!lpszSrc || !lpszDest) { INTERNET_SetLastError(ERROR_INVALID_PARAMETER); goto lend; } hIC = lpwfs->lpAppInfo; if (hIC->hdr.dwFlags & INTERNET_FLAG_ASYNC) { WORKREQUEST workRequest; struct WORKREQ_FTPRENAMEFILEW *req; workRequest.asyncproc = AsyncFtpRenameFileProc; workRequest.hdr = WININET_AddRef( &lpwfs->hdr ); req = &workRequest.u.FtpRenameFileW; req->lpszSrcFile = WININET_strdupW(lpszSrc); req->lpszDestFile = WININET_strdupW(lpszDest); r = INTERNET_AsyncCall(&workRequest); } else { r = FTP_FtpRenameFileW(lpwfs, lpszSrc, lpszDest); } lend: WININET_Release( &lpwfs->hdr ); return r; } /*********************************************************************** * FTP_FtpRenameFileW (Internal) * * Rename a file on the ftp server * * RETURNS * TRUE on success * FALSE on failure * */ BOOL FTP_FtpRenameFileW( LPWININETFTPSESSIONW lpwfs, LPCWSTR lpszSrc, LPCWSTR lpszDest) { INT nResCode; BOOL bSuccess = FALSE; LPWININETAPPINFOW hIC = NULL; TRACE("\n"); /* Clear any error information */ INTERNET_SetLastError(0); if (!FTP_SendCommand(lpwfs->sndSocket, FTP_CMD_RNFR, lpszSrc, 0, 0, 0)) goto lend; nResCode = FTP_ReceiveResponse(lpwfs, lpwfs->hdr.dwContext); if (nResCode == 350) { if (!FTP_SendCommand(lpwfs->sndSocket, FTP_CMD_RNTO, lpszDest, 0, 0, 0)) goto lend; nResCode = FTP_ReceiveResponse(lpwfs, lpwfs->hdr.dwContext); } if (nResCode == 250) bSuccess = TRUE; else FTP_SetResponseError(nResCode); lend: hIC = lpwfs->lpAppInfo; if (hIC->hdr.dwFlags & INTERNET_FLAG_ASYNC) { INTERNET_ASYNC_RESULT iar; iar.dwResult = (DWORD)bSuccess; iar.dwError = bSuccess ? ERROR_SUCCESS : INTERNET_GetLastError(); SendAsyncCallback(&lpwfs->hdr, lpwfs->hdr.dwContext, INTERNET_STATUS_REQUEST_COMPLETE, &iar, sizeof(INTERNET_ASYNC_RESULT)); } return bSuccess; } /*********************************************************************** * FtpCommandA (WININET.@) */ BOOL WINAPI FtpCommandA( HINTERNET hConnect, BOOL fExpectResponse, DWORD dwFlags, LPCSTR lpszCommand, DWORD_PTR dwContext, HINTERNET* phFtpCommand ) { FIXME("%p %d 0x%08x %s 0x%08lx %p\n", hConnect, fExpectResponse, dwFlags, debugstr_a(lpszCommand), dwContext, phFtpCommand); return TRUE; } /*********************************************************************** * FtpCommandW (WININET.@) */ BOOL WINAPI FtpCommandW( HINTERNET hConnect, BOOL fExpectResponse, DWORD dwFlags, LPCWSTR lpszCommand, DWORD_PTR dwContext, HINTERNET* phFtpCommand ) { FIXME("%p %d 0x%08x %s 0x%08lx %p\n", hConnect, fExpectResponse, dwFlags, debugstr_w(lpszCommand), dwContext, phFtpCommand); return TRUE; } /*********************************************************************** * FTP_Connect (internal) * * Connect to a ftp server * * RETURNS * HINTERNET a session handle on success * NULL on failure * * NOTES: * * Windows uses 'anonymous' as the username, when given a NULL username * and a NULL password. The password is first looked up in: * * HKCU\Software\Microsoft\Windows\CurrentVersion\Internet Settings\EmailName * * If this entry is not present it uses the current username as the password. * */ HINTERNET FTP_Connect(LPWININETAPPINFOW hIC, LPCWSTR lpszServerName, INTERNET_PORT nServerPort, LPCWSTR lpszUserName, LPCWSTR lpszPassword, DWORD dwFlags, DWORD_PTR dwContext, DWORD dwInternalFlags) { static const WCHAR szKey[] = {'S','o','f','t','w','a','r','e','\\', 'M','i','c','r','o','s','o','f','t','\\', 'W','i','n','d','o','w','s','\\', 'C','u','r','r','e','n','t','V','e','r','s','i','o','n','\\', 'I','n','t','e','r','n','e','t',' ','S','e','t','t','i','n','g','s',0}; static const WCHAR szValue[] = {'E','m','a','i','l','N','a','m','e',0}; static const WCHAR szDefaultUsername[] = {'a','n','o','n','y','m','o','u','s','\0'}; static const WCHAR szEmpty[] = {'\0'}; struct sockaddr_in socketAddr; INT nsocket = -1; UINT sock_namelen; BOOL bSuccess = FALSE; LPWININETFTPSESSIONW lpwfs = NULL; HINTERNET handle = NULL; TRACE("%p Server(%s) Port(%d) User(%s) Paswd(%s)\n", hIC, debugstr_w(lpszServerName), nServerPort, debugstr_w(lpszUserName), debugstr_w(lpszPassword)); assert( hIC->hdr.htype == WH_HINIT ); if (NULL == lpszUserName && NULL != lpszPassword) { INTERNET_SetLastError(ERROR_INVALID_PARAMETER); goto lerror; } lpwfs = HeapAlloc(GetProcessHeap(), 0, sizeof(WININETFTPSESSIONW)); if (NULL == lpwfs) { INTERNET_SetLastError(ERROR_OUTOFMEMORY); goto lerror; } if (nServerPort == INTERNET_INVALID_PORT_NUMBER) nServerPort = INTERNET_DEFAULT_FTP_PORT; lpwfs->hdr.htype = WH_HFTPSESSION; lpwfs->hdr.dwFlags = dwFlags; lpwfs->hdr.dwContext = dwContext; lpwfs->hdr.dwInternalFlags = dwInternalFlags; lpwfs->hdr.dwRefCount = 1; lpwfs->hdr.close_connection = FTP_CloseConnection; lpwfs->hdr.destroy = FTP_CloseSessionHandle; lpwfs->hdr.lpfnStatusCB = hIC->hdr.lpfnStatusCB; lpwfs->download_in_progress = NULL; WININET_AddRef( &hIC->hdr ); lpwfs->lpAppInfo = hIC; list_add_head( &hIC->hdr.children, &lpwfs->hdr.entry ); handle = WININET_AllocHandle( &lpwfs->hdr ); if( !handle ) { ERR("Failed to alloc handle\n"); INTERNET_SetLastError(ERROR_OUTOFMEMORY); goto lerror; } if(hIC->lpszProxy && hIC->dwAccessType == INTERNET_OPEN_TYPE_PROXY) { if(strchrW(hIC->lpszProxy, ' ')) FIXME("Several proxies not implemented.\n"); if(hIC->lpszProxyBypass) FIXME("Proxy bypass is ignored.\n"); } if ( !lpszUserName) { HKEY key; WCHAR szPassword[MAX_PATH]; DWORD len = sizeof(szPassword); lpwfs->lpszUserName = WININET_strdupW(szDefaultUsername); RegOpenKeyW(HKEY_CURRENT_USER, szKey, &key); if (RegQueryValueExW(key, szValue, NULL, NULL, (LPBYTE)szPassword, &len)) { /* Nothing in the registry, get the username and use that as the password */ if (!GetUserNameW(szPassword, &len)) { /* Should never get here, but use an empty password as failsafe */ strcpyW(szPassword, szEmpty); } } RegCloseKey(key); TRACE("Password used for anonymous ftp : (%s)\n", debugstr_w(szPassword)); lpwfs->lpszPassword = WININET_strdupW(szPassword); } else { lpwfs->lpszUserName = WININET_strdupW(lpszUserName); if (lpszPassword) lpwfs->lpszPassword = WININET_strdupW(lpszPassword); else lpwfs->lpszPassword = WININET_strdupW(szEmpty); } /* Don't send a handle created callback if this handle was created with InternetOpenUrl */ if (!(lpwfs->hdr.dwInternalFlags & INET_OPENURL)) { INTERNET_ASYNC_RESULT iar; iar.dwResult = (DWORD)handle; iar.dwError = ERROR_SUCCESS; SendAsyncCallback(&hIC->hdr, dwContext, INTERNET_STATUS_HANDLE_CREATED, &iar, sizeof(INTERNET_ASYNC_RESULT)); } SendAsyncCallback(&hIC->hdr, dwContext, INTERNET_STATUS_RESOLVING_NAME, (LPWSTR) lpszServerName, strlenW(lpszServerName)); if (!GetAddress(lpszServerName, nServerPort, &socketAddr)) { INTERNET_SetLastError(ERROR_INTERNET_NAME_NOT_RESOLVED); goto lerror; } SendAsyncCallback(&hIC->hdr, dwContext, INTERNET_STATUS_NAME_RESOLVED, (LPWSTR) lpszServerName, strlenW(lpszServerName)); nsocket = socket(AF_INET,SOCK_STREAM,0); if (nsocket == -1) { INTERNET_SetLastError(ERROR_INTERNET_CANNOT_CONNECT); goto lerror; } SendAsyncCallback(&hIC->hdr, dwContext, INTERNET_STATUS_CONNECTING_TO_SERVER, &socketAddr, sizeof(struct sockaddr_in)); if (connect(nsocket, (struct sockaddr *)&socketAddr, sizeof(socketAddr)) < 0) { ERR("Unable to connect (%s)\n", strerror(errno)); INTERNET_SetLastError(ERROR_INTERNET_CANNOT_CONNECT); } else { TRACE("Connected to server\n"); lpwfs->sndSocket = nsocket; SendAsyncCallback(&hIC->hdr, dwContext, INTERNET_STATUS_CONNECTED_TO_SERVER, &socketAddr, sizeof(struct sockaddr_in)); sock_namelen = sizeof(lpwfs->socketAddress); getsockname(nsocket, (struct sockaddr *) &lpwfs->socketAddress, &sock_namelen); if (FTP_ConnectToHost(lpwfs)) { TRACE("Successfully logged into server\n"); bSuccess = TRUE; } } lerror: if (lpwfs) WININET_Release( &lpwfs->hdr ); if (!bSuccess && handle) { WININET_FreeHandle( handle ); handle = NULL; } if (hIC->hdr.dwFlags & INTERNET_FLAG_ASYNC) { INTERNET_ASYNC_RESULT iar; iar.dwResult = bSuccess ? (DWORD_PTR)lpwfs : 0; iar.dwError = bSuccess ? ERROR_SUCCESS : INTERNET_GetLastError(); SendAsyncCallback(&hIC->hdr, dwContext, INTERNET_STATUS_REQUEST_COMPLETE, &iar, sizeof(INTERNET_ASYNC_RESULT)); } return handle; } /*********************************************************************** * FTP_ConnectToHost (internal) * * Connect to a ftp server * * RETURNS * TRUE on success * NULL on failure * */ static BOOL FTP_ConnectToHost(LPWININETFTPSESSIONW lpwfs) { INT nResCode; BOOL bSuccess = FALSE; TRACE("\n"); FTP_ReceiveResponse(lpwfs, lpwfs->hdr.dwContext); if (!FTP_SendCommand(lpwfs->sndSocket, FTP_CMD_USER, lpwfs->lpszUserName, 0, 0, 0)) goto lend; nResCode = FTP_ReceiveResponse(lpwfs, lpwfs->hdr.dwContext); if (nResCode) { /* Login successful... */ if (nResCode == 230) bSuccess = TRUE; /* User name okay, need password... */ else if (nResCode == 331) bSuccess = FTP_SendPassword(lpwfs); /* Need account for login... */ else if (nResCode == 332) bSuccess = FTP_SendAccount(lpwfs); else FTP_SetResponseError(nResCode); } TRACE("Returning %d\n", bSuccess); lend: return bSuccess; } /*********************************************************************** * FTP_SendCommandA (internal) * * Send command to server * * RETURNS * TRUE on success * NULL on failure * */ static BOOL FTP_SendCommandA(INT nSocket, FTP_COMMAND ftpCmd, LPCSTR lpszParam, INTERNET_STATUS_CALLBACK lpfnStatusCB, LPWININETHANDLEHEADER hdr, DWORD_PTR dwContext) { DWORD len; CHAR *buf; DWORD nBytesSent = 0; int nRC = 0; DWORD dwParamLen; TRACE("%d: (%s) %d\n", ftpCmd, lpszParam, nSocket); if (lpfnStatusCB) { lpfnStatusCB(hdr->hInternet, dwContext, INTERNET_STATUS_SENDING_REQUEST, NULL, 0); } dwParamLen = lpszParam?strlen(lpszParam)+1:0; len = dwParamLen + strlen(szFtpCommands[ftpCmd]) + strlen(szCRLF); if (NULL == (buf = HeapAlloc(GetProcessHeap(), 0, len+1))) { INTERNET_SetLastError(ERROR_OUTOFMEMORY); return FALSE; } sprintf(buf, "%s%s%s%s", szFtpCommands[ftpCmd], dwParamLen ? " " : "", dwParamLen ? lpszParam : "", szCRLF); TRACE("Sending (%s) len(%d)\n", buf, len); while((nBytesSent < len) && (nRC != -1)) { nRC = send(nSocket, buf+nBytesSent, len - nBytesSent, 0); nBytesSent += nRC; } HeapFree(GetProcessHeap(), 0, (LPVOID)buf); if (lpfnStatusCB) { lpfnStatusCB(hdr->hInternet, dwContext, INTERNET_STATUS_REQUEST_SENT, &nBytesSent, sizeof(DWORD)); } TRACE("Sent %d bytes\n", nBytesSent); return (nRC != -1); } /*********************************************************************** * FTP_SendCommand (internal) * * Send command to server * * RETURNS * TRUE on success * NULL on failure * */ static BOOL FTP_SendCommand(INT nSocket, FTP_COMMAND ftpCmd, LPCWSTR lpszParam, INTERNET_STATUS_CALLBACK lpfnStatusCB, LPWININETHANDLEHEADER hdr, DWORD_PTR dwContext) { BOOL ret; LPSTR lpszParamA = lpszParam?WININET_strdup_WtoA(lpszParam):NULL; ret = FTP_SendCommandA(nSocket, ftpCmd, lpszParamA, lpfnStatusCB, hdr, dwContext); HeapFree(GetProcessHeap(), 0, lpszParamA); return ret; } /*********************************************************************** * FTP_ReceiveResponse (internal) * * Receive response from server * * RETURNS * Reply code on success * 0 on failure * */ INT FTP_ReceiveResponse(LPWININETFTPSESSIONW lpwfs, DWORD_PTR dwContext) { LPSTR lpszResponse = INTERNET_GetResponseBuffer(); DWORD nRecv; INT rc = 0; char firstprefix[5]; BOOL multiline = FALSE; LPWININETAPPINFOW hIC = NULL; TRACE("socket(%d)\n", lpwfs->sndSocket); hIC = lpwfs->lpAppInfo; SendAsyncCallback(&lpwfs->hdr, dwContext, INTERNET_STATUS_RECEIVING_RESPONSE, NULL, 0); while(1) { if (!INTERNET_GetNextLine(lpwfs->sndSocket, &nRecv)) goto lerror; if (nRecv >= 3) { if(!multiline) { if(lpszResponse[3] != '-') break; else { /* Start of multiline repsonse. Loop until we get "nnn " */ multiline = TRUE; memcpy(firstprefix, lpszResponse, 3); firstprefix[3] = ' '; firstprefix[4] = '\0'; } } else { if(!memcmp(firstprefix, lpszResponse, 4)) break; } } } if (nRecv >= 3) { rc = atoi(lpszResponse); SendAsyncCallback(&lpwfs->hdr, dwContext, INTERNET_STATUS_RESPONSE_RECEIVED, &nRecv, sizeof(DWORD)); } lerror: TRACE("return %d\n", rc); return rc; } /*********************************************************************** * FTP_SendPassword (internal) * * Send password to ftp server * * RETURNS * TRUE on success * NULL on failure * */ static BOOL FTP_SendPassword(LPWININETFTPSESSIONW lpwfs) { INT nResCode; BOOL bSuccess = FALSE; TRACE("\n"); if (!FTP_SendCommand(lpwfs->sndSocket, FTP_CMD_PASS, lpwfs->lpszPassword, 0, 0, 0)) goto lend; nResCode = FTP_ReceiveResponse(lpwfs, lpwfs->hdr.dwContext); if (nResCode) { TRACE("Received reply code %d\n", nResCode); /* Login successful... */ if (nResCode == 230) bSuccess = TRUE; /* Command not implemented, superfluous at the server site... */ /* Need account for login... */ else if (nResCode == 332) bSuccess = FTP_SendAccount(lpwfs); else FTP_SetResponseError(nResCode); } lend: TRACE("Returning %d\n", bSuccess); return bSuccess; } /*********************************************************************** * FTP_SendAccount (internal) * * * * RETURNS * TRUE on success * FALSE on failure * */ static BOOL FTP_SendAccount(LPWININETFTPSESSIONW lpwfs) { INT nResCode; BOOL bSuccess = FALSE; TRACE("\n"); if (!FTP_SendCommand(lpwfs->sndSocket, FTP_CMD_ACCT, szNoAccount, 0, 0, 0)) goto lend; nResCode = FTP_ReceiveResponse(lpwfs, lpwfs->hdr.dwContext); if (nResCode) bSuccess = TRUE; else FTP_SetResponseError(nResCode); lend: return bSuccess; } /*********************************************************************** * FTP_SendStore (internal) * * Send request to upload file to ftp server * * RETURNS * TRUE on success * FALSE on failure * */ static BOOL FTP_SendStore(LPWININETFTPSESSIONW lpwfs, LPCWSTR lpszRemoteFile, DWORD dwType) { INT nResCode; BOOL bSuccess = FALSE; TRACE("\n"); if (!FTP_InitListenSocket(lpwfs)) goto lend; if (!FTP_SendType(lpwfs, dwType)) goto lend; if (!FTP_SendPortOrPasv(lpwfs)) goto lend; if (!FTP_SendCommand(lpwfs->sndSocket, FTP_CMD_STOR, lpszRemoteFile, 0, 0, 0)) goto lend; nResCode = FTP_ReceiveResponse(lpwfs, lpwfs->hdr.dwContext); if (nResCode) { if (nResCode == 150 || nResCode == 125) bSuccess = TRUE; else FTP_SetResponseError(nResCode); } lend: if (!bSuccess && lpwfs->lstnSocket != -1) { closesocket(lpwfs->lstnSocket); lpwfs->lstnSocket = -1; } return bSuccess; } /*********************************************************************** * FTP_InitListenSocket (internal) * * Create a socket to listen for server response * * RETURNS * TRUE on success * FALSE on failure * */ static BOOL FTP_InitListenSocket(LPWININETFTPSESSIONW lpwfs) { BOOL bSuccess = FALSE; socklen_t namelen = sizeof(struct sockaddr_in); TRACE("\n"); lpwfs->lstnSocket = socket(PF_INET, SOCK_STREAM, 0); if (lpwfs->lstnSocket == -1) { TRACE("Unable to create listening socket\n"); goto lend; } /* We obtain our ip addr from the name of the command channel socket */ lpwfs->lstnSocketAddress = lpwfs->socketAddress; /* and get the system to assign us a port */ lpwfs->lstnSocketAddress.sin_port = htons((u_short) 0); if (bind(lpwfs->lstnSocket,(struct sockaddr *) &lpwfs->lstnSocketAddress, sizeof(struct sockaddr_in)) == -1) { TRACE("Unable to bind socket\n"); goto lend; } if (listen(lpwfs->lstnSocket, MAX_BACKLOG) == -1) { TRACE("listen failed\n"); goto lend; } if (getsockname(lpwfs->lstnSocket, (struct sockaddr *) &lpwfs->lstnSocketAddress, &namelen) != -1) bSuccess = TRUE; lend: if (!bSuccess && lpwfs->lstnSocket != -1) { closesocket(lpwfs->lstnSocket); lpwfs->lstnSocket = -1; } return bSuccess; } /*********************************************************************** * FTP_SendType (internal) * * Tell server type of data being transferred * * RETURNS * TRUE on success * FALSE on failure * * W98SE doesn't cache the type that's currently set * (i.e. it sends it always), * so we probably don't want to do that either. */ static BOOL FTP_SendType(LPWININETFTPSESSIONW lpwfs, DWORD dwType) { INT nResCode; WCHAR type[] = { 'I','\0' }; BOOL bSuccess = FALSE; TRACE("\n"); if (dwType & INTERNET_FLAG_TRANSFER_ASCII) type[0] = 'A'; if (!FTP_SendCommand(lpwfs->sndSocket, FTP_CMD_TYPE, type, 0, 0, 0)) goto lend; nResCode = FTP_ReceiveResponse(lpwfs, lpwfs->hdr.dwContext)/100; if (nResCode) { if (nResCode == 2) bSuccess = TRUE; else FTP_SetResponseError(nResCode); } lend: return bSuccess; } #if 0 /* FIXME: should probably be used for FtpGetFileSize */ /*********************************************************************** * FTP_GetFileSize (internal) * * Retrieves from the server the size of the given file * * RETURNS * TRUE on success * FALSE on failure * */ static BOOL FTP_GetFileSize(LPWININETFTPSESSIONW lpwfs, LPCWSTR lpszRemoteFile, DWORD *dwSize) { INT nResCode; BOOL bSuccess = FALSE; TRACE("\n"); if (!FTP_SendCommand(lpwfs->sndSocket, FTP_CMD_SIZE, lpszRemoteFile, 0, 0, 0)) goto lend; nResCode = FTP_ReceiveResponse(lpwfs, lpwfs->hdr.dwContext); if (nResCode) { if (nResCode == 213) { /* Now parses the output to get the actual file size */ int i; LPSTR lpszResponseBuffer = INTERNET_GetResponseBuffer(); for (i = 0; (lpszResponseBuffer[i] != ' ') && (lpszResponseBuffer[i] != '\0'); i++) ; if (lpszResponseBuffer[i] == '\0') return FALSE; *dwSize = atol(&(lpszResponseBuffer[i + 1])); bSuccess = TRUE; } else { FTP_SetResponseError(nResCode); } } lend: return bSuccess; } #endif /*********************************************************************** * FTP_SendPort (internal) * * Tell server which port to use * * RETURNS * TRUE on success * FALSE on failure * */ static BOOL FTP_SendPort(LPWININETFTPSESSIONW lpwfs) { static const WCHAR szIPFormat[] = {'%','d',',','%','d',',','%','d',',','%','d',',','%','d',',','%','d','\0'}; INT nResCode; WCHAR szIPAddress[64]; BOOL bSuccess = FALSE; TRACE("\n"); sprintfW(szIPAddress, szIPFormat, lpwfs->lstnSocketAddress.sin_addr.s_addr&0x000000FF, (lpwfs->lstnSocketAddress.sin_addr.s_addr&0x0000FF00)>>8, (lpwfs->lstnSocketAddress.sin_addr.s_addr&0x00FF0000)>>16, (lpwfs->lstnSocketAddress.sin_addr.s_addr&0xFF000000)>>24, lpwfs->lstnSocketAddress.sin_port & 0xFF, (lpwfs->lstnSocketAddress.sin_port & 0xFF00)>>8); if (!FTP_SendCommand(lpwfs->sndSocket, FTP_CMD_PORT, szIPAddress, 0, 0, 0)) goto lend; nResCode = FTP_ReceiveResponse(lpwfs, lpwfs->hdr.dwContext); if (nResCode) { if (nResCode == 200) bSuccess = TRUE; else FTP_SetResponseError(nResCode); } lend: return bSuccess; } /*********************************************************************** * FTP_DoPassive (internal) * * Tell server that we want to do passive transfers * and connect data socket * * RETURNS * TRUE on success * FALSE on failure * */ static BOOL FTP_DoPassive(LPWININETFTPSESSIONW lpwfs) { INT nResCode; BOOL bSuccess = FALSE; TRACE("\n"); if (!FTP_SendCommand(lpwfs->sndSocket, FTP_CMD_PASV, NULL, 0, 0, 0)) goto lend; nResCode = FTP_ReceiveResponse(lpwfs, lpwfs->hdr.dwContext); if (nResCode) { if (nResCode == 227) { LPSTR lpszResponseBuffer = INTERNET_GetResponseBuffer(); LPSTR p; int f[6]; int i; char *pAddr, *pPort; INT nsocket = -1; struct sockaddr_in dataSocketAddress; p = lpszResponseBuffer+4; /* skip status code */ while (*p != '\0' && (*p < '0' || *p > '9')) p++; if (*p == '\0') { ERR("no address found in response, aborting\n"); goto lend; } if (sscanf(p, "%d,%d,%d,%d,%d,%d", &f[0], &f[1], &f[2], &f[3], &f[4], &f[5]) != 6) { ERR("unknown response address format '%s', aborting\n", p); goto lend; } for (i=0; i < 6; i++) f[i] = f[i] & 0xff; dataSocketAddress = lpwfs->socketAddress; pAddr = (char *)&(dataSocketAddress.sin_addr.s_addr); pPort = (char *)&(dataSocketAddress.sin_port); pAddr[0] = f[0]; pAddr[1] = f[1]; pAddr[2] = f[2]; pAddr[3] = f[3]; pPort[0] = f[4]; pPort[1] = f[5]; nsocket = socket(AF_INET,SOCK_STREAM,0); if (nsocket == -1) goto lend; if (connect(nsocket, (struct sockaddr *)&dataSocketAddress, sizeof(dataSocketAddress))) { ERR("can't connect passive FTP data port.\n"); closesocket(nsocket); goto lend; } lpwfs->pasvSocket = nsocket; bSuccess = TRUE; } else FTP_SetResponseError(nResCode); } lend: return bSuccess; } static BOOL FTP_SendPortOrPasv(LPWININETFTPSESSIONW lpwfs) { if (lpwfs->hdr.dwFlags & INTERNET_FLAG_PASSIVE) { if (!FTP_DoPassive(lpwfs)) return FALSE; } else { if (!FTP_SendPort(lpwfs)) return FALSE; } return TRUE; } /*********************************************************************** * FTP_GetDataSocket (internal) * * Either accepts an incoming data socket connection from the server * or just returns the already opened socket after a PASV command * in case of passive FTP. * * * RETURNS * TRUE on success * FALSE on failure * */ static BOOL FTP_GetDataSocket(LPWININETFTPSESSIONW lpwfs, LPINT nDataSocket) { struct sockaddr_in saddr; socklen_t addrlen = sizeof(struct sockaddr); TRACE("\n"); if (lpwfs->hdr.dwFlags & INTERNET_FLAG_PASSIVE) { *nDataSocket = lpwfs->pasvSocket; } else { *nDataSocket = accept(lpwfs->lstnSocket, (struct sockaddr *) &saddr, &addrlen); closesocket(lpwfs->lstnSocket); lpwfs->lstnSocket = -1; } return *nDataSocket != -1; } /*********************************************************************** * FTP_SendData (internal) * * Send data to the server * * RETURNS * TRUE on success * FALSE on failure * */ static BOOL FTP_SendData(LPWININETFTPSESSIONW lpwfs, INT nDataSocket, HANDLE hFile) { BY_HANDLE_FILE_INFORMATION fi; DWORD nBytesRead = 0; DWORD nBytesSent = 0; DWORD nTotalSent = 0; DWORD nBytesToSend, nLen; int nRC = 1; time_t s_long_time, e_long_time; LONG nSeconds; CHAR *lpszBuffer; TRACE("\n"); lpszBuffer = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, sizeof(CHAR)*DATA_PACKET_SIZE); /* Get the size of the file. */ GetFileInformationByHandle(hFile, &fi); time(&s_long_time); do { nBytesToSend = nBytesRead - nBytesSent; if (nBytesToSend <= 0) { /* Read data from file. */ nBytesSent = 0; if (!ReadFile(hFile, lpszBuffer, DATA_PACKET_SIZE, &nBytesRead, 0)) ERR("Failed reading from file\n"); if (nBytesRead > 0) nBytesToSend = nBytesRead; else break; } nLen = DATA_PACKET_SIZE < nBytesToSend ? DATA_PACKET_SIZE : nBytesToSend; nRC = send(nDataSocket, lpszBuffer, nLen, 0); if (nRC != -1) { nBytesSent += nRC; nTotalSent += nRC; } /* Do some computation to display the status. */ time(&e_long_time); nSeconds = e_long_time - s_long_time; if( nSeconds / 60 > 0 ) { TRACE( "%d bytes of %d bytes (%d%%) in %d min %d sec estimated remaining time %d sec\n", nTotalSent, fi.nFileSizeLow, nTotalSent*100/fi.nFileSizeLow, nSeconds / 60, nSeconds % 60, (fi.nFileSizeLow - nTotalSent) * nSeconds / nTotalSent ); } else { TRACE( "%d bytes of %d bytes (%d%%) in %d sec estimated remaining time %d sec\n", nTotalSent, fi.nFileSizeLow, nTotalSent*100/fi.nFileSizeLow, nSeconds, (fi.nFileSizeLow - nTotalSent) * nSeconds / nTotalSent); } } while (nRC != -1); TRACE("file transfer complete!\n"); HeapFree(GetProcessHeap(), 0, lpszBuffer); return nTotalSent; } /*********************************************************************** * FTP_SendRetrieve (internal) * * Send request to retrieve a file * * RETURNS * Number of bytes to be received on success * 0 on failure * */ static BOOL FTP_SendRetrieve(LPWININETFTPSESSIONW lpwfs, LPCWSTR lpszRemoteFile, DWORD dwType) { INT nResCode; BOOL ret; TRACE("\n"); if (!(ret = FTP_InitListenSocket(lpwfs))) goto lend; if (!(ret = FTP_SendType(lpwfs, dwType))) goto lend; if (!(ret = FTP_SendPortOrPasv(lpwfs))) goto lend; if (!(ret = FTP_SendCommand(lpwfs->sndSocket, FTP_CMD_RETR, lpszRemoteFile, 0, 0, 0))) goto lend; nResCode = FTP_ReceiveResponse(lpwfs, lpwfs->hdr.dwContext); if ((nResCode != 125) && (nResCode != 150)) { /* That means that we got an error getting the file. */ FTP_SetResponseError(nResCode); ret = FALSE; } lend: if (!ret && lpwfs->lstnSocket != -1) { closesocket(lpwfs->lstnSocket); lpwfs->lstnSocket = -1; } return ret; } /*********************************************************************** * FTP_RetrieveData (internal) * * Retrieve data from server * * RETURNS * TRUE on success * FALSE on failure * */ static BOOL FTP_RetrieveFileData(LPWININETFTPSESSIONW lpwfs, INT nDataSocket, HANDLE hFile) { DWORD nBytesWritten; DWORD nBytesReceived = 0; INT nRC = 0; CHAR *lpszBuffer; TRACE("\n"); lpszBuffer = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, sizeof(CHAR)*DATA_PACKET_SIZE); if (NULL == lpszBuffer) { INTERNET_SetLastError(ERROR_OUTOFMEMORY); return FALSE; } while (nRC != -1) { nRC = recv(nDataSocket, lpszBuffer, DATA_PACKET_SIZE, 0); if (nRC != -1) { /* other side closed socket. */ if (nRC == 0) goto recv_end; WriteFile(hFile, lpszBuffer, nRC, &nBytesWritten, NULL); nBytesReceived += nRC; } } TRACE("Data transfer complete\n"); recv_end: HeapFree(GetProcessHeap(), 0, lpszBuffer); return (nRC != -1); } /*********************************************************************** * FTP_CloseConnection (internal) * * Close connections */ static void FTP_CloseConnection(LPWININETHANDLEHEADER hdr) { LPWININETFTPSESSIONW lpwfs = (LPWININETFTPSESSIONW) hdr; TRACE("\n"); SendAsyncCallback(&lpwfs->hdr, lpwfs->hdr.dwContext, INTERNET_STATUS_CLOSING_CONNECTION, 0, 0); if (lpwfs->download_in_progress != NULL) lpwfs->download_in_progress->session_deleted = TRUE; if (lpwfs->sndSocket != -1) closesocket(lpwfs->sndSocket); if (lpwfs->lstnSocket != -1) closesocket(lpwfs->lstnSocket); if (lpwfs->pasvSocket != -1) closesocket(lpwfs->pasvSocket); SendAsyncCallback(&lpwfs->hdr, lpwfs->hdr.dwContext, INTERNET_STATUS_CONNECTION_CLOSED, 0, 0); } /*********************************************************************** * FTP_CloseSessionHandle (internal) * * Deallocate session handle */ static void FTP_CloseSessionHandle(LPWININETHANDLEHEADER hdr) { LPWININETFTPSESSIONW lpwfs = (LPWININETFTPSESSIONW) hdr; TRACE("\n"); WININET_Release(&lpwfs->lpAppInfo->hdr); HeapFree(GetProcessHeap(), 0, lpwfs->lpszPassword); HeapFree(GetProcessHeap(), 0, lpwfs->lpszUserName); HeapFree(GetProcessHeap(), 0, lpwfs); } /*********************************************************************** * FTP_FindNextFileW (Internal) * * Continues a file search from a previous call to FindFirstFile * * RETURNS * TRUE on success * FALSE on failure * */ BOOL WINAPI FTP_FindNextFileW(LPWININETFTPFINDNEXTW lpwh, LPVOID lpvFindData) { BOOL bSuccess = TRUE; LPWIN32_FIND_DATAW lpFindFileData; TRACE("index(%d) size(%d)\n", lpwh->index, lpwh->size); assert (lpwh->hdr.htype == WH_HFTPFINDNEXT); /* Clear any error information */ INTERNET_SetLastError(0); lpFindFileData = (LPWIN32_FIND_DATAW) lpvFindData; ZeroMemory(lpFindFileData, sizeof(WIN32_FIND_DATAA)); if (lpwh->index >= lpwh->size) { INTERNET_SetLastError(ERROR_NO_MORE_FILES); bSuccess = FALSE; goto lend; } FTP_ConvertFileProp(&lpwh->lpafp[lpwh->index], lpFindFileData); lpwh->index++; TRACE("\nName: %s\nSize: %d\n", debugstr_w(lpFindFileData->cFileName), lpFindFileData->nFileSizeLow); lend: if (lpwh->hdr.dwFlags & INTERNET_FLAG_ASYNC) { INTERNET_ASYNC_RESULT iar; iar.dwResult = (DWORD)bSuccess; iar.dwError = iar.dwError = bSuccess ? ERROR_SUCCESS : INTERNET_GetLastError(); INTERNET_SendCallback(&lpwh->hdr, lpwh->hdr.dwContext, INTERNET_STATUS_REQUEST_COMPLETE, &iar, sizeof(INTERNET_ASYNC_RESULT)); } return bSuccess; } /*********************************************************************** * FTP_CloseFindNextHandle (internal) * * Deallocate session handle * * RETURNS * TRUE on success * FALSE on failure * */ static void FTP_CloseFindNextHandle(LPWININETHANDLEHEADER hdr) { LPWININETFTPFINDNEXTW lpwfn = (LPWININETFTPFINDNEXTW) hdr; DWORD i; TRACE("\n"); WININET_Release(&lpwfn->lpFtpSession->hdr); for (i = 0; i < lpwfn->size; i++) { HeapFree(GetProcessHeap(), 0, lpwfn->lpafp[i].lpszName); } HeapFree(GetProcessHeap(), 0, lpwfn->lpafp); HeapFree(GetProcessHeap(), 0, lpwfn); } /*********************************************************************** * FTP_CloseFileTransferHandle (internal) * * Closes the file transfer handle. This also 'cleans' the data queue of * the 'transfer complete' message (this is a bit of a hack though :-/ ) * */ static void FTP_CloseFileTransferHandle(LPWININETHANDLEHEADER hdr) { LPWININETFTPFILE lpwh = (LPWININETFTPFILE) hdr; LPWININETFTPSESSIONW lpwfs = lpwh->lpFtpSession; INT nResCode; TRACE("\n"); WININET_Release(&lpwh->lpFtpSession->hdr); if (!lpwh->session_deleted) lpwfs->download_in_progress = NULL; if (lpwh->nDataSocket != -1) closesocket(lpwh->nDataSocket); nResCode = FTP_ReceiveResponse(lpwfs, lpwfs->hdr.dwContext); if (nResCode > 0 && nResCode != 226) WARN("server reports failed transfer\n"); HeapFree(GetProcessHeap(), 0, lpwh); } /*********************************************************************** * FTP_ReceiveFileList (internal) * * Read file list from server * * RETURNS * Handle to file list on success * NULL on failure * */ static HINTERNET FTP_ReceiveFileList(LPWININETFTPSESSIONW lpwfs, INT nSocket, LPCWSTR lpszSearchFile, LPWIN32_FIND_DATAW lpFindFileData, DWORD_PTR dwContext) { DWORD dwSize = 0; LPFILEPROPERTIESW lpafp = NULL; LPWININETFTPFINDNEXTW lpwfn = NULL; HINTERNET handle = 0; TRACE("(%p,%d,%s,%p,%08lx)\n", lpwfs, nSocket, debugstr_w(lpszSearchFile), lpFindFileData, dwContext); if (FTP_ParseDirectory(lpwfs, nSocket, lpszSearchFile, &lpafp, &dwSize)) { if(lpFindFileData) FTP_ConvertFileProp(lpafp, lpFindFileData); lpwfn = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, sizeof(WININETFTPFINDNEXTW)); if (lpwfn) { lpwfn->hdr.htype = WH_HFTPFINDNEXT; lpwfn->hdr.dwContext = dwContext; lpwfn->hdr.dwRefCount = 1; lpwfn->hdr.close_connection = NULL; lpwfn->hdr.destroy = FTP_CloseFindNextHandle; lpwfn->hdr.lpfnStatusCB = lpwfs->hdr.lpfnStatusCB; lpwfn->index = 1; /* Next index is 1 since we return index 0 */ lpwfn->size = dwSize; lpwfn->lpafp = lpafp; WININET_AddRef( &lpwfs->hdr ); lpwfn->lpFtpSession = lpwfs; list_add_head( &lpwfs->hdr.children, &lpwfn->hdr.entry ); handle = WININET_AllocHandle( &lpwfn->hdr ); } } if( lpwfn ) WININET_Release( &lpwfn->hdr ); TRACE("Matched %d files\n", dwSize); return handle; } /*********************************************************************** * FTP_ConvertFileProp (internal) * * Converts FILEPROPERTIESW struct to WIN32_FIND_DATAA * * RETURNS * TRUE on success * FALSE on failure * */ BOOL FTP_ConvertFileProp(LPFILEPROPERTIESW lpafp, LPWIN32_FIND_DATAW lpFindFileData) { BOOL bSuccess = FALSE; ZeroMemory(lpFindFileData, sizeof(WIN32_FIND_DATAW)); if (lpafp) { /* Convert 'Unix' time to Windows time */ RtlSecondsSince1970ToTime(mktime(&lpafp->tmLastModified), (LARGE_INTEGER *) &(lpFindFileData->ftLastAccessTime)); lpFindFileData->ftLastWriteTime = lpFindFileData->ftLastAccessTime; lpFindFileData->ftCreationTime = lpFindFileData->ftLastAccessTime; /* Not all fields are filled in */ lpFindFileData->nFileSizeHigh = 0; /* We do not handle files bigger than 0xFFFFFFFF bytes yet :-) */ lpFindFileData->nFileSizeLow = lpafp->nSize; if (lpafp->bIsDirectory) lpFindFileData->dwFileAttributes |= FILE_ATTRIBUTE_DIRECTORY; if (lpafp->lpszName) lstrcpynW(lpFindFileData->cFileName, lpafp->lpszName, MAX_PATH); bSuccess = TRUE; } return bSuccess; } /*********************************************************************** * FTP_ParseNextFile (internal) * * Parse the next line in file listing * * RETURNS * TRUE on success * FALSE on failure */ static BOOL FTP_ParseNextFile(INT nSocket, LPCWSTR lpszSearchFile, LPFILEPROPERTIESW lpfp) { static const char szSpace[] = " \t"; DWORD nBufLen; char *pszLine; char *pszToken; char *pszTmp; BOOL found = FALSE; int i; lpfp->lpszName = NULL; do { if(!(pszLine = INTERNET_GetNextLine(nSocket, &nBufLen))) return FALSE; pszToken = strtok(pszLine, szSpace); /* ls format *