diff options
Diffstat (limited to 'automation/source/testtool/httprequest.cxx')
| -rw-r--r-- | automation/source/testtool/httprequest.cxx | 239 |
1 files changed, 239 insertions, 0 deletions
diff --git a/automation/source/testtool/httprequest.cxx b/automation/source/testtool/httprequest.cxx new file mode 100644 index 000000000000..1e45fd1fc976 --- /dev/null +++ b/automation/source/testtool/httprequest.cxx @@ -0,0 +1,239 @@ +/************************************************************************* + * + * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. + * + * Copyright 2000, 2010 Oracle and/or its affiliates. + * + * OpenOffice.org - a multi-platform office productivity suite + * + * This file is part of OpenOffice.org. + * + * OpenOffice.org is free software: you can redistribute it and/or modify + * it under the terms of the GNU Lesser General Public License version 3 + * only, as published by the Free Software Foundation. + * + * OpenOffice.org 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 version 3 for more details + * (a copy is included in the LICENSE file that accompanied this code). + * + * You should have received a copy of the GNU Lesser General Public License + * version 3 along with OpenOffice.org. If not, see + * <http://www.openoffice.org/license.html> + * for a copy of the LGPLv3 License. + * + ************************************************************************/ + +// MARKER(update_precomp.py): autogen include statement, do not remove +#include "precompiled_automation.hxx" + +#include <stdio.h> +#include "httprequest.hxx" +#include <vos/socket.hxx> +#include <tools/debug.hxx> + + +void HttpRequest::Init() +{ + nResultId = 0; + aHeader.Erase(); + aContentType.Erase(); + delete pStream; + pStream = NULL; +} + +HttpRequest::HttpRequest() +: nStatus( HTTP_INIT ) +, nResultId( 0 ) +, pStream( NULL ) +{} + +HttpRequest::~HttpRequest() +{ + delete pStream; + pStream = NULL; +} + +void HttpRequest::SetRequest( ByteString aHost, ByteString aPath, USHORT nPort ) +{ + nStatus = HTTP_REQUEST_SET; + Init(); + aRequestHost = aHost; + aRequestPath = aPath; + nRequestPort = nPort; +} + +void HttpRequest::SetProxy( ByteString aHost, USHORT nPort ) +{ + nStatus = HTTP_REQUEST_SET; + Init(); + aProxyHost = aHost; + nProxyPort = nPort; +} + +BOOL HttpRequest::Execute() +{ + nStatus = HTTP_REQUEST_PENDING; + Init(); + + // Open channel to standard redir host + NAMESPACE_VOS(OInetSocketAddr) aConnectAddr; + + if ( aProxyHost.Len() ) + { + aConnectAddr.setAddr( rtl::OUString( UniString( aProxyHost, RTL_TEXTENCODING_UTF8 ) ) ); + aConnectAddr.setPort( nProxyPort ); + } + else + { + aConnectAddr.setAddr( rtl::OUString( UniString( aRequestHost, RTL_TEXTENCODING_UTF8 ) ) ); + aConnectAddr.setPort( nRequestPort ); + } + + TimeValue aTV; + aTV.Seconds = 10; // Warte 10 Sekunden + aTV.Nanosec = 0; + + pOutSocket = new NAMESPACE_VOS(OConnectorSocket)(); + if ( pOutSocket->connect( aConnectAddr, &aTV ) == NAMESPACE_VOS(ISocketTypes::TResult_Ok) ) + { +// pOutSocket->setTcpNoDelay( 1 ); + } + else + { + delete pOutSocket; + nStatus = HTTP_REQUEST_ERROR; + return FALSE; + } + + + SendString( pOutSocket, "GET " ); + if ( aProxyHost.Len() ) + { + //GET http://staroffice-doc.germany.sun.com/cgi-bin/htdig/binarycopy.sh?CopyIt=++CopyIt++ HTTP/1.0 + SendString( pOutSocket, "http://" ); + SendString( pOutSocket, aRequestHost ); + SendString( pOutSocket, ":" ); + SendString( pOutSocket, ByteString::CreateFromInt32( nRequestPort ) ); + SendString( pOutSocket, aRequestPath ); + SendString( pOutSocket, " HTTP/1.0\n" ); + + SendString( pOutSocket, "Proxy-Connection: Keep-Alive\n" ); + } + else + { + //GET /cgi-bin/htdig/binarycopy.sh?CopyIt=++CopyIt++ HTTP/1.0 + SendString( pOutSocket, aRequestPath ); + SendString( pOutSocket, " HTTP/1.0\n" ); + + SendString( pOutSocket, "Connection: Keep-Alive\n" ); + } + + SendString( pOutSocket, "User-Agent: Mozilla/4.7 [de] (Linux; I)" ); + SendString( pOutSocket, "Host: " ); + SendString( pOutSocket, aRequestHost ); + // Terminate with empty line + SendString( pOutSocket, "\n\n" ); + + + +#define BUFFRE_SIZE 0x10000 // 64K Buffer + char* pBuffer = new char[ BUFFRE_SIZE ]; + + BOOL bWasError = ( nStatus != HTTP_REQUEST_PENDING ); + + ULONG nDataRead; + pStream = new SvMemoryStream( 0x10000, 0x10000 ); + while ( !bWasError ) + { + bWasError |= ( BUFFRE_SIZE != ( nDataRead = pOutSocket->read( pBuffer, BUFFRE_SIZE ) ) ); + + pStream->Write( pBuffer, nDataRead ); + } + + delete [] pBuffer; + pOutSocket->shutdown(); + pOutSocket->close(); + + pStream->Seek( 0 ); + + ByteString aLine; + BOOL bInsideHeader = TRUE; + while ( bInsideHeader ) + { + pStream->ReadLine( aLine ); + if ( !aLine.Len() ) + bInsideHeader = FALSE; + else + { + if ( IsItem( "HTTP/", aLine ) ) + nResultId = (USHORT)aLine.GetToken( 1, ' ' ).ToInt32(); + if ( IsItem( "Content-Type:", aLine ) ) + { + aContentType = aLine.Copy( 13 ); + aContentType.EraseLeadingAndTrailingChars(); + } + aHeader += aLine; + aHeader += "\n"; + } + } + + if ( nStatus == HTTP_REQUEST_PENDING ) + { + nStatus = HTTP_REQUEST_DONE; + return TRUE; + } + else + { + nStatus = HTTP_REQUEST_ERROR; + return FALSE; + } +} +/* +HTTP/1.1 200 OK +Date: Tue, 22 Jan 2002 14:16:20 GMT +Server: Apache/1.3.14 (Unix) (SuSE/Linux) mod_throttle/3.0 mod_layout/1.0 mod_f +astcgi/2.2.2 mod_jk +Set-Cookie2: JSESSIONID=ffkpgb7tm1;Version=1;Discard;Path="/bugtracker" +Set-Cookie: JSESSIONID=ffkpgb7tm1;Path=/bugtracker +Servlet-Engine: Tomcat Web Server/3.2.1 (JSP 1.1; Servlet 2.2; Java 1.3.0; Linux + 2.4.0-4GB i386; java.vendor=Sun Microsystems Inc.) +Connection: close +Content-Type: text/xml; charset=ISO-8859-1 + */ +void HttpRequest::SendString( vos::OStreamSocket* pSocket , ByteString aText ) +{ + if ( nStatus == HTTP_REQUEST_PENDING ) + pSocket->write( aText.GetBuffer(), aText.Len() ); +} + +BOOL HttpRequest::IsItem( ByteString aItem, ByteString aLine ) +{ + return aItem.Match( aLine ) == STRING_MATCH; +} + + +void HttpRequest::Abort() +{ + if ( pOutSocket ) + { + nStatus = HTTP_REQUEST_ERROR; + pOutSocket->shutdown(); + pOutSocket->close(); + } +} + + + + +SvMemoryStream* HttpRequest::GetBody() +{ + return pStream; +} + +USHORT HttpRequest::GetStatus() +{ + return nStatus; +} + |