extensions/source/xmlextract/xmxtrct.cxx

   1 /*************************************************************************
   2  *
   3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   4  *
   5  * Copyright 2008 by Sun Microsystems, Inc.
   6  *
   7  * OpenOffice.org - a multi-platform office productivity suite
   8  *
   9  * $RCSfile: xmxtrct.cxx,v $
  10  * $Revision: 1.8 $
  11  *
  12  * This file is part of OpenOffice.org.
  13  *
  14  * OpenOffice.org is free software: you can redistribute it and/or modify
  15  * it under the terms of the GNU Lesser General Public License version 3
  16  * only, as published by the Free Software Foundation.
  17  *
  18  * OpenOffice.org is distributed in the hope that it will be useful,
  19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21  * GNU Lesser General Public License version 3 for more details
  22  * (a copy is included in the LICENSE file that accompanied this code).
  23  *
  24  * You should have received a copy of the GNU Lesser General Public License
  25  * version 3 along with OpenOffice.org.  If not, see
  26  * <http://www.openoffice.org/license.html>
  27  * for a copy of the LGPLv3 License.
  28  *
  29  ************************************************************************/
  30
  31 // MARKER(update_precomp.py): autogen include statement, do not remove
  32 #include "precompiled_extensions.hxx"
  33
  34 #include "xmxtrct.hxx"
  35
  36 #include <rtl/memory.h>
  37 #include <tools/zcodec.hxx>
  38 #include <unotools/streamhelper.hxx>
  39 #include <sot/storage.hxx>
  40
  41 // ----------------
  42 // - XMXLockBytes -
  43 // ----------------
  44
  45 class XMXLockBytes : public SvLockBytes
  46 {
  47     REF( NMSP_IO::XInputStream )        mxIStm;
  48     SEQ( sal_Int8 )                                     maSeq;
  49
  50                                     XMXLockBytes();
  51
  52 public:
  53
  54                                     XMXLockBytes( const REF( NMSP_IO::XInputStream )& rxIStm );
  55     virtual                                                     ~XMXLockBytes();
  56
  57     virtual ErrCode                                     ReadAt( sal_Size nPos, void* pBuffer, sal_Size nCount, sal_Size* pRead ) const;
  58     virtual ErrCode                                     WriteAt( sal_Size nPos, const void* pBuffer, sal_Size nCount, sal_Size* pWritten );
  59     virtual ErrCode                                     Flush() const;
  60     virtual ErrCode                                     SetSize( sal_Size nSize );
  61     virtual ErrCode                                     Stat( SvLockBytesStat*, SvLockBytesStatFlag ) const;
  62 };
  63
  64 // ------------------------------------------------------------------------
  65
  66 XMXLockBytes::XMXLockBytes( const REF( NMSP_IO::XInputStream )& rxIStm ) :
  67     mxIStm( rxIStm )
  68 {
  69     if( mxIStm.is() )
  70     {
  71         const sal_uInt32        nBytesToRead = 65535;
  72         sal_uInt32                      nRead;
  73
  74         do
  75         {
  76             SEQ( sal_Int8 ) aReadSeq;
  77
  78             nRead = mxIStm->readSomeBytes( aReadSeq, nBytesToRead );
  79
  80             if( nRead )
  81             {
  82                 const sal_uInt32 nOldLength = maSeq.getLength();
  83                 maSeq.realloc( nOldLength + nRead );
  84                 rtl_copyMemory( maSeq.getArray() + nOldLength, aReadSeq.getConstArray(), aReadSeq.getLength() );
  85             }
  86         }
  87         while( nBytesToRead == nRead );
  88     }
  89 }
  90
  91 // ------------------------------------------------------------------------
  92
  93 XMXLockBytes::~XMXLockBytes()
  94 {
  95 }
  96
  97 // ------------------------------------------------------------------------
  98
  99 ErrCode XMXLockBytes::ReadAt( sal_Size nPos, void* pBuffer, sal_Size nCount, sal_Size* pRead ) const
 100 {
 101     const sal_Size              nSeqLen = maSeq.getLength();
 102     ErrCode                             nErr = ERRCODE_NONE;
 103
 104     if( nPos < nSeqLen )
 105     {
 106         if( ( nPos + nCount ) > nSeqLen )
 107             nCount = nSeqLen - nPos;
 108
 109         rtl_copyMemory( pBuffer, maSeq.getConstArray() + nPos, nCount );
 110         *pRead = nCount;
 111     }
 112     else
 113         *pRead = 0UL;
 114
 115     return nErr;
 116 }
 117
 118 // ------------------------------------------------------------------------
 119
 120 ErrCode XMXLockBytes::WriteAt( sal_Size /*nPos*/, const void* /*pBuffer*/, sal_Size /*nCount*/, sal_Size* /*pWritten*/ )
 121 {
 122     return ERRCODE_IO_CANTWRITE;
 123 }
 124
 125 // ------------------------------------------------------------------------
 126
 127 ErrCode XMXLockBytes::Flush() const
 128 {
 129     return ERRCODE_NONE;
 130 }
 131
 132 // ------------------------------------------------------------------------
 133
 134 ErrCode XMXLockBytes::SetSize( sal_Size /*nSize*/ )
 135 {
 136     return ERRCODE_IO_CANTWRITE;
 137 }
 138
 139 // ------------------------------------------------------------------------
 140
 141 ErrCode XMXLockBytes::Stat( SvLockBytesStat* pStat, SvLockBytesStatFlag /*eFlag*/ ) const
 142 {
 143     pStat->nSize = maSeq.getLength();
 144     return ERRCODE_NONE;
 145 }
 146
 147 // ----------------
 148 // - XMLExtractor -
 149 // ----------------
 150
 151 XMLExtractor::XMLExtractor( const REF( NMSP_LANG::XMultiServiceFactory )& rxMgr ) :
 152     mxFact( rxMgr )
 153 {
 154 }
 155
 156 // -----------------------------------------------------------------------------
 157
 158 XMLExtractor::~XMLExtractor()
 159 {
 160 }
 161
 162 // -----------------------------------------------------------------------------
 163
 164 REF( NMSP_IO::XInputStream ) SAL_CALL XMLExtractor::extract( const REF( NMSP_IO::XInputStream )& rxIStm ) throw( NMSP_UNO::RuntimeException )
 165 {
 166     REF( NMSP_IO::XInputStream ) xRet;
 167
 168     if( rxIStm.is() )
 169     {
 170         SvStream                aIStm( new XMXLockBytes( rxIStm ) );
 171         SvStorageRef    aStorage( new SvStorage( aIStm ) );
 172         String                  aStmName;
 173         const String    aFormat1( String::CreateFromAscii( "XMLFormat" ) );
 174         const String    aFormat2( String::CreateFromAscii( "XMLFormat2" ) );
 175
 176         if( aStorage->IsContained( aFormat2 ) )
 177             aStmName = aFormat2;
 178         else if( aStorage->IsContained( aFormat1 ) )
 179             aStmName = aFormat1;
 180
 181         if( !aStorage->GetError() && aStmName.Len() && aStorage->IsStream( aStmName ) )
 182         {
 183             SvStorageStreamRef xStream( aStorage->OpenSotStream( aStmName ) );
 184
 185             if( xStream.Is() )
 186             {
 187                 SvMemoryStream* pMemStm = new SvMemoryStream( 65535, 65535 );
 188                 ZCodec                  aCodec;
 189
 190                 aCodec.BeginCompression( ZCODEC_BEST_COMPRESSION );
 191                 aCodec.Decompress( *xStream, *pMemStm );
 192                 aCodec.EndCompression();
 193
 194                 xRet = new ::utl::OInputStreamHelper( new SvLockBytes( pMemStm, TRUE ), 65535 );
 195             }
 196         }
 197     }
 198
 199     return xRet;
 200 }