diff options
Diffstat (limited to 'extensions/source/xmlextract/xmxtrct.cxx')
| -rw-r--r-- | extensions/source/xmlextract/xmxtrct.cxx | 197 |
1 files changed, 197 insertions, 0 deletions
diff --git a/extensions/source/xmlextract/xmxtrct.cxx b/extensions/source/xmlextract/xmxtrct.cxx new file mode 100644 index 000000000000..a50c1816bd02 --- /dev/null +++ b/extensions/source/xmlextract/xmxtrct.cxx @@ -0,0 +1,197 @@ +/************************************************************************* + * + * 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_extensions.hxx" + +#include "xmxtrct.hxx" + +#include <rtl/memory.h> +#include <tools/zcodec.hxx> +#include <unotools/streamhelper.hxx> +#include <sot/storage.hxx> + +// ---------------- +// - XMXLockBytes - +// ---------------- + +class XMXLockBytes : public SvLockBytes +{ + REF( NMSP_IO::XInputStream ) mxIStm; + SEQ( sal_Int8 ) maSeq; + + XMXLockBytes(); + +public: + + XMXLockBytes( const REF( NMSP_IO::XInputStream )& rxIStm ); + virtual ~XMXLockBytes(); + + virtual ErrCode ReadAt( sal_Size nPos, void* pBuffer, sal_Size nCount, sal_Size* pRead ) const; + virtual ErrCode WriteAt( sal_Size nPos, const void* pBuffer, sal_Size nCount, sal_Size* pWritten ); + virtual ErrCode Flush() const; + virtual ErrCode SetSize( sal_Size nSize ); + virtual ErrCode Stat( SvLockBytesStat*, SvLockBytesStatFlag ) const; +}; + +// ------------------------------------------------------------------------ + +XMXLockBytes::XMXLockBytes( const REF( NMSP_IO::XInputStream )& rxIStm ) : + mxIStm( rxIStm ) +{ + if( mxIStm.is() ) + { + const sal_uInt32 nBytesToRead = 65535; + sal_uInt32 nRead; + + do + { + SEQ( sal_Int8 ) aReadSeq; + + nRead = mxIStm->readSomeBytes( aReadSeq, nBytesToRead ); + + if( nRead ) + { + const sal_uInt32 nOldLength = maSeq.getLength(); + maSeq.realloc( nOldLength + nRead ); + rtl_copyMemory( maSeq.getArray() + nOldLength, aReadSeq.getConstArray(), aReadSeq.getLength() ); + } + } + while( nBytesToRead == nRead ); + } +} + +// ------------------------------------------------------------------------ + +XMXLockBytes::~XMXLockBytes() +{ +} + +// ------------------------------------------------------------------------ + +ErrCode XMXLockBytes::ReadAt( sal_Size nPos, void* pBuffer, sal_Size nCount, sal_Size* pRead ) const +{ + const sal_Size nSeqLen = maSeq.getLength(); + ErrCode nErr = ERRCODE_NONE; + + if( nPos < nSeqLen ) + { + if( ( nPos + nCount ) > nSeqLen ) + nCount = nSeqLen - nPos; + + rtl_copyMemory( pBuffer, maSeq.getConstArray() + nPos, nCount ); + *pRead = nCount; + } + else + *pRead = 0UL; + + return nErr; +} + +// ------------------------------------------------------------------------ + +ErrCode XMXLockBytes::WriteAt( sal_Size /*nPos*/, const void* /*pBuffer*/, sal_Size /*nCount*/, sal_Size* /*pWritten*/ ) +{ + return ERRCODE_IO_CANTWRITE; +} + +// ------------------------------------------------------------------------ + +ErrCode XMXLockBytes::Flush() const +{ + return ERRCODE_NONE; +} + +// ------------------------------------------------------------------------ + +ErrCode XMXLockBytes::SetSize( sal_Size /*nSize*/ ) +{ + return ERRCODE_IO_CANTWRITE; +} + +// ------------------------------------------------------------------------ + +ErrCode XMXLockBytes::Stat( SvLockBytesStat* pStat, SvLockBytesStatFlag /*eFlag*/ ) const +{ + pStat->nSize = maSeq.getLength(); + return ERRCODE_NONE; +} + +// ---------------- +// - XMLExtractor - +// ---------------- + +XMLExtractor::XMLExtractor( const REF( NMSP_LANG::XMultiServiceFactory )& rxMgr ) : + mxFact( rxMgr ) +{ +} + +// ----------------------------------------------------------------------------- + +XMLExtractor::~XMLExtractor() +{ +} + +// ----------------------------------------------------------------------------- + +REF( NMSP_IO::XInputStream ) SAL_CALL XMLExtractor::extract( const REF( NMSP_IO::XInputStream )& rxIStm ) throw( NMSP_UNO::RuntimeException ) +{ + REF( NMSP_IO::XInputStream ) xRet; + + if( rxIStm.is() ) + { + SvStream aIStm( new XMXLockBytes( rxIStm ) ); + SvStorageRef aStorage( new SvStorage( aIStm ) ); + String aStmName; + const String aFormat1( String::CreateFromAscii( "XMLFormat" ) ); + const String aFormat2( String::CreateFromAscii( "XMLFormat2" ) ); + + if( aStorage->IsContained( aFormat2 ) ) + aStmName = aFormat2; + else if( aStorage->IsContained( aFormat1 ) ) + aStmName = aFormat1; + + if( !aStorage->GetError() && aStmName.Len() && aStorage->IsStream( aStmName ) ) + { + SvStorageStreamRef xStream( aStorage->OpenSotStream( aStmName ) ); + + if( xStream.Is() ) + { + SvMemoryStream* pMemStm = new SvMemoryStream( 65535, 65535 ); + ZCodec aCodec; + + aCodec.BeginCompression( ZCODEC_BEST_COMPRESSION ); + aCodec.Decompress( *xStream, *pMemStm ); + aCodec.EndCompression(); + + xRet = new ::utl::OInputStreamHelper( new SvLockBytes( pMemStm, TRUE ), 65535 ); + } + } + } + + return xRet; +} |