writerperfect/source/common/WPXSvInputStream.cxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
   2 /*
   3  * This file is part of the LibreOffice project.
   4  *
   5  * This Source Code Form is subject to the terms of the Mozilla Public
   6  * License, v. 2.0. If a copy of the MPL was not distributed with this
   7  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
   8  */
   9
  10 #include <WPXSvInputStream.hxx>
  11
  12 #include <com/sun/star/packages/zip/XZipFileAccess2.hpp>
  13 #include <com/sun/star/uno/XComponentContext.hpp>
  14
  15 #include <comphelper/processfactory.hxx>
  16 #include <comphelper/seekableinput.hxx>
  17 #include <o3tl/safeint.hxx>
  18 #include <rtl/string.hxx>
  19 #include <sal/log.hxx>
  20
  21 #include <sot/storage.hxx>
  22
  23 #include <tools/stream.hxx>
  24 #include <unotools/streamwrap.hxx>
  25 #include <unotools/ucbstreamhelper.hxx>
  26
  27 #include <climits>
  28 #include <limits>
  29 #include <memory>
  30 #include <unordered_map>
  31 #include <vector>
  32
  33 namespace writerperfect
  34 {
  35 using namespace ::com::sun::star::uno;
  36 using namespace ::com::sun::star::io;
  37
  38 namespace container = com::sun::star::container;
  39 namespace packages = com::sun::star::packages;
  40
  41 namespace
  42 {
  43 class PositionHolder
  44 {
  45 public:
  46     explicit PositionHolder(const Reference<XSeekable>& rxSeekable);
  47     ~PositionHolder();
  48     PositionHolder(const PositionHolder&) = delete;
  49     PositionHolder& operator=(const PositionHolder&) = delete;
  50
  51 private:
  52     const Reference<XSeekable> mxSeekable;
  53     const sal_uInt64 mnPosition;
  54 };
  55
  56 PositionHolder::PositionHolder(const Reference<XSeekable>& rxSeekable)
  57     : mxSeekable(rxSeekable)
  58     , mnPosition(rxSeekable->getPosition())
  59 {
  60 }
  61
  62 PositionHolder::~PositionHolder()
  63 {
  64     try
  65     {
  66         mxSeekable->seek(mnPosition);
  67     }
  68     catch (...)
  69     {
  70     }
  71 }
  72
  73 } // anonymous namespace
  74
  75 namespace
  76 {
  77 OUString lcl_normalizeSubStreamPath(const OUString& rPath)
  78 {
  79     // accept paths which begin by '/'
  80     // TODO: maybe this should do a full normalization
  81     if (rPath.startsWith("/") && rPath.getLength() >= 2)
  82         return rPath.copy(1);
  83     return rPath;
  84 }
  85 }
  86
  87 namespace
  88 {
  89 OUString concatPath(const OUString& lhs, const OUString& rhs)
  90 {
  91     if (lhs.isEmpty())
  92         return rhs;
  93     return lhs + "/" + rhs;
  94 }
  95
  96 struct OLEStreamData
  97 {
  98     OLEStreamData(const OString& rName, const OString& rvngName);
  99
 100     tools::SvRef<SotStorageStream> stream;
 101
 102     /** Name of the stream.
 103       *
 104       * This is not @c OUString, because we need to be able to
 105       * produce const char* from it.
 106       */
 107     OString name;
 108     /** librevenge name of the stream.
 109       *
 110       * This is not @c OUString, because we need to be able to
 111       * produce const char* from it.
 112       */
 113     OString RVNGname;
 114 };
 115
 116 typedef std::unordered_map<OUString, std::size_t> NameMap_t;
 117 typedef std::unordered_map<OUString, tools::SvRef<SotStorage>> OLEStorageMap_t;
 118
 119 /** Representation of an OLE2 storage.
 120   *
 121   * This class tries to bring a bit of sanity to use of SotStorage with
 122   * respect to the needs of @c librevenge::RVNGInputStream API. It
 123   * holds all nested storages for the whole lifetime (more precisely,
 124   * since initialization, which is performed by calling @c
 125   * initialize()), thus ensuring that no created stream is destroyed
 126   * just because its parent storage went out of scope. It also holds a
 127   * bidirectional map of stream names to their indexes (index of a
 128   * stream is determined by deep-first traversal), which is also
 129   * populated during initialization (member variables @c maStreams and
 130   * @c maNameMap).
 131   *
 132   * Streams are created on demand (and saved, for the same reason as
 133   * storages).
 134   */
 135 struct OLEStorageImpl
 136 {
 137     OLEStorageImpl();
 138
 139     void initialize(std::unique_ptr<SvStream> pStream);
 140
 141     tools::SvRef<SotStorageStream> getStream(const OUString& rPath);
 142     tools::SvRef<SotStorageStream> const& getStream(std::size_t nId);
 143
 144 private:
 145     void traverse(const tools::SvRef<SotStorage>& rStorage, const OUString& rPath);
 146
 147     tools::SvRef<SotStorageStream> createStream(const OUString& rPath);
 148
 149 public:
 150     tools::SvRef<SotStorage> mxRootStorage; //< root storage of the OLE2
 151     OLEStorageMap_t maStorageMap; //< map of all sub storages by name
 152     ::std::vector<OLEStreamData> maStreams; //< list of streams and their names
 153     NameMap_t maNameMap; //< map of stream names to indexes (into @c maStreams)
 154     bool mbInitialized;
 155 };
 156
 157 OLEStreamData::OLEStreamData(const OString& rName, const OString& rvngName)
 158     : stream()
 159     , name(rName)
 160     , RVNGname(rvngName)
 161 {
 162 }
 163
 164 OLEStorageImpl::OLEStorageImpl()
 165     : mxRootStorage()
 166     , maStorageMap()
 167     , maStreams()
 168     , maNameMap()
 169     , mbInitialized(false)
 170 {
 171 }
 172
 173 void OLEStorageImpl::initialize(std::unique_ptr<SvStream> pStream)
 174 {
 175     if (!pStream)
 176         return;
 177
 178     mxRootStorage = new SotStorage(pStream.release(), true);
 179
 180     traverse(mxRootStorage, "");
 181
 182     mbInitialized = true;
 183 }
 184
 185 tools::SvRef<SotStorageStream> OLEStorageImpl::getStream(const OUString& rPath)
 186 {
 187     const OUString aPath(lcl_normalizeSubStreamPath(rPath));
 188     NameMap_t::iterator aIt = maNameMap.find(aPath);
 189
 190     // For the while don't return stream in this situation.
 191     // Later, given how libcdr's zip stream implementation behaves,
 192     // return the first stream in the storage if there is one.
 193     if (maNameMap.end() == aIt)
 194         return tools::SvRef<SotStorageStream>();
 195
 196     if (!maStreams[aIt->second].stream.is())
 197         maStreams[aIt->second].stream
 198             = createStream(OStringToOUString(maStreams[aIt->second].name, RTL_TEXTENCODING_UTF8));
 199
 200     return maStreams[aIt->second].stream;
 201 }
 202
 203 tools::SvRef<SotStorageStream> const& OLEStorageImpl::getStream(const std::size_t nId)
 204 {
 205     if (!maStreams[nId].stream.is())
 206         maStreams[nId].stream
 207             = createStream(OStringToOUString(maStreams[nId].name, RTL_TEXTENCODING_UTF8));
 208
 209     return maStreams[nId].stream;
 210 }
 211
 212 void OLEStorageImpl::traverse(const tools::SvRef<SotStorage>& rStorage, const OUString& rPath)
 213 {
 214     SvStorageInfoList infos;
 215
 216     rStorage->FillInfoList(&infos);
 217
 218     for (const auto& info : infos)
 219     {
 220         if (info.IsStream())
 221         {
 222             OUString baseName = info.GetName(), rvngName = baseName;
 223             // librevenge::RVNGOLEStream ignores the first character when is a control code, so ...
 224             if (!rvngName.isEmpty() && rvngName.toChar() < 32)
 225                 rvngName = rvngName.copy(1);
 226             maStreams.emplace_back(
 227                 OUStringToOString(concatPath(rPath, baseName), RTL_TEXTENCODING_UTF8),
 228                 OUStringToOString(concatPath(rPath, rvngName), RTL_TEXTENCODING_UTF8));
 229             maNameMap[concatPath(rPath, rvngName)] = maStreams.size() - 1;
 230         }
 231         else if (info.IsStorage())
 232         {
 233             const OUString aPath = concatPath(rPath, info.GetName());
 234             tools::SvRef<SotStorage> aStorage
 235                 = rStorage->OpenSotStorage(info.GetName(), StreamMode::STD_READ);
 236             maStorageMap[aPath] = aStorage;
 237
 238             // deep-first traversal
 239             traverse(aStorage, aPath);
 240         }
 241         else
 242         {
 243             SAL_WARN("writerperfect",
 244                      "OLEStorageImpl::traverse: invalid storage entry, neither stream nor file");
 245         }
 246     }
 247 }
 248
 249 tools::SvRef<SotStorageStream> OLEStorageImpl::createStream(const OUString& rPath)
 250 {
 251     const sal_Int32 nDelim = rPath.lastIndexOf(u'/');
 252
 253     if (-1 == nDelim)
 254         return mxRootStorage->OpenSotStream(rPath, StreamMode::STD_READ);
 255
 256     const OUString aDir = rPath.copy(0, nDelim);
 257     const OUString aName = rPath.copy(nDelim + 1);
 258
 259     const OLEStorageMap_t::const_iterator aIt = maStorageMap.find(aDir);
 260
 261     if (maStorageMap.end() == aIt)
 262         return nullptr;
 263
 264     return aIt->second->OpenSotStream(aName, StreamMode::STD_READ);
 265 }
 266 }
 267
 268 namespace
 269 {
 270 struct ZipStreamData
 271 {
 272     explicit ZipStreamData(const OString& rName);
 273
 274     Reference<XInputStream> xStream;
 275
 276     /** Name of the stream.
 277       *
 278       * This is not @c OUString, because we need to be able to
 279       * produce const char* from it.
 280       */
 281     OString aName;
 282 };
 283
 284 /** Representation of a Zip storage.
 285   *
 286   * This is quite similar to OLEStorageImpl, except that we do not need
 287   * to keep all storages (folders) open.
 288   */
 289 struct ZipStorageImpl
 290 {
 291     explicit ZipStorageImpl(const Reference<container::XNameAccess>& rxContainer);
 292
 293     /** Initialize for access.
 294       *
 295       * This creates a bidirectional map of stream names to their
 296       * indexes (index of a stream is determined by deep-first
 297       * traversal).
 298       */
 299     void initialize();
 300
 301     Reference<XInputStream> getStream(const OUString& rPath);
 302     Reference<XInputStream> const& getStream(std::size_t nId);
 303
 304 private:
 305     void traverse(const Reference<container::XNameAccess>& rxEnum);
 306
 307     Reference<XInputStream> createStream(const OUString& rPath);
 308
 309 public:
 310     Reference<container::XNameAccess> mxContainer; //< root of the Zip
 311     ::std::vector<ZipStreamData> maStreams; //< list of streams and their names
 312     NameMap_t maNameMap; //< map of stream names to indexes (into @c maStreams)
 313     bool mbInitialized;
 314 };
 315
 316 ZipStreamData::ZipStreamData(const OString& rName)
 317     : xStream()
 318     , aName(rName)
 319 {
 320 }
 321
 322 ZipStorageImpl::ZipStorageImpl(const Reference<container::XNameAccess>& rxContainer)
 323     : mxContainer(rxContainer)
 324     , maStreams()
 325     , maNameMap()
 326     , mbInitialized(false)
 327 {
 328     assert(mxContainer.is());
 329 }
 330
 331 void ZipStorageImpl::initialize()
 332 {
 333     traverse(mxContainer);
 334
 335     mbInitialized = true;
 336 }
 337
 338 Reference<XInputStream> ZipStorageImpl::getStream(const OUString& rPath)
 339 {
 340     const OUString aPath(lcl_normalizeSubStreamPath(rPath));
 341     NameMap_t::iterator aIt = maNameMap.find(aPath);
 342
 343     // For the while don't return stream in this situation.
 344     // Later, given how libcdr's zip stream implementation behaves,
 345     // return the first stream in the storage if there is one.
 346     if (maNameMap.end() == aIt)
 347         return Reference<XInputStream>();
 348
 349     if (!maStreams[aIt->second].xStream.is())
 350         maStreams[aIt->second].xStream = createStream(aPath);
 351
 352     return maStreams[aIt->second].xStream;
 353 }
 354
 355 Reference<XInputStream> const& ZipStorageImpl::getStream(const std::size_t nId)
 356 {
 357     if (!maStreams[nId].xStream.is())
 358         maStreams[nId].xStream
 359             = createStream(OStringToOUString(maStreams[nId].aName, RTL_TEXTENCODING_UTF8));
 360
 361     return maStreams[nId].xStream;
 362 }
 363
 364 void ZipStorageImpl::traverse(const Reference<container::XNameAccess>& rxContainer)
 365 {
 366     const Sequence<OUString> lNames = rxContainer->getElementNames();
 367
 368     maStreams.reserve(lNames.getLength());
 369
 370     for (const auto& rName : lNames)
 371     {
 372         if (!rName.endsWith("/")) // skip dirs
 373         {
 374             maStreams.emplace_back(OUStringToOString(rName, RTL_TEXTENCODING_UTF8));
 375             maNameMap[rName] = maStreams.size() - 1;
 376         }
 377     }
 378 }
 379
 380 Reference<XInputStream> ZipStorageImpl::createStream(const OUString& rPath)
 381 {
 382     Reference<XInputStream> xStream;
 383
 384     try
 385     {
 386         const Reference<XInputStream> xInputStream(mxContainer->getByName(rPath), UNO_QUERY_THROW);
 387         const Reference<XSeekable> xSeekable(xInputStream, UNO_QUERY);
 388
 389         if (xSeekable.is())
 390             xStream = xInputStream;
 391         else
 392             xStream.set(new comphelper::OSeekableInputWrapper(
 393                 xInputStream, comphelper::getProcessComponentContext()));
 394     }
 395     catch (const Exception&)
 396     {
 397         // nothing needed
 398     }
 399
 400     return xStream;
 401 }
 402 }
 403
 404 class WPXSvInputStreamImpl
 405 {
 406 public:
 407     explicit WPXSvInputStreamImpl(css::uno::Reference<css::io::XInputStream> const& xStream);
 408
 409     bool isStructured();
 410     unsigned subStreamCount();
 411     const char* subStreamName(unsigned id);
 412     bool existsSubStream(const char* name);
 413     librevenge::RVNGInputStream* getSubStreamByName(const char* name);
 414     librevenge::RVNGInputStream* getSubStreamById(unsigned id);
 415
 416     const unsigned char* read(unsigned long numBytes, unsigned long& numBytesRead);
 417     int seek(tools::Long offset);
 418     tools::Long tell();
 419     bool isEnd();
 420
 421     void invalidateReadBuffer();
 422
 423 private:
 424     bool isOLE();
 425     void ensureOLEIsInitialized();
 426
 427     bool isZip();
 428     void ensureZipIsInitialized();
 429
 430     static librevenge::RVNGInputStream*
 431     createWPXStream(const tools::SvRef<SotStorageStream>& rxStorage);
 432     static librevenge::RVNGInputStream* createWPXStream(const Reference<XInputStream>& rxStream);
 433
 434 private:
 435     css::uno::Reference<css::io::XInputStream> mxStream;
 436     css::uno::Reference<css::io::XSeekable> mxSeekable;
 437     css::uno::Sequence<sal_Int8> maData;
 438     std::unique_ptr<OLEStorageImpl> mpOLEStorage;
 439     std::unique_ptr<ZipStorageImpl> mpZipStorage;
 440     bool mbCheckedOLE;
 441     bool mbCheckedZip;
 442
 443 public:
 444     sal_Int64 mnLength;
 445     const unsigned char* mpReadBuffer;
 446     unsigned long mnReadBufferLength;
 447     unsigned long mnReadBufferPos;
 448 };
 449
 450 WPXSvInputStreamImpl::WPXSvInputStreamImpl(Reference<XInputStream> const& xStream)
 451     : mxStream(xStream)
 452     , mxSeekable(xStream, UNO_QUERY)
 453     , maData(0)
 454     , mbCheckedOLE(false)
 455     , mbCheckedZip(false)
 456     , mnLength(0)
 457     , mpReadBuffer(nullptr)
 458     , mnReadBufferLength(0)
 459     , mnReadBufferPos(0)
 460 {
 461     if (!xStream.is() || !mxStream.is())
 462         mnLength = 0;
 463     else
 464     {
 465         if (!mxSeekable.is())
 466             mnLength = 0;
 467         else
 468         {
 469             try
 470             {
 471                 mnLength = mxSeekable->getLength();
 472                 if (0 < mxSeekable->getPosition())
 473                     mxSeekable->seek(0);
 474             }
 475             catch (...)
 476             {
 477                 SAL_WARN("writerperfect", "mnLength = mxSeekable->getLength() threw exception");
 478                 mnLength = 0;
 479             }
 480         }
 481     }
 482 }
 483
 484 const unsigned char* WPXSvInputStreamImpl::read(unsigned long numBytes, unsigned long& numBytesRead)
 485 {
 486     numBytesRead = 0;
 487
 488     if (numBytes == 0 || isEnd())
 489         return nullptr;
 490
 491     numBytesRead = mxStream->readSomeBytes(maData, numBytes);
 492     if (numBytesRead == 0)
 493         return nullptr;
 494
 495     return reinterpret_cast<const unsigned char*>(maData.getConstArray());
 496 }
 497
 498 tools::Long WPXSvInputStreamImpl::tell()
 499 {
 500     if ((mnLength == 0) || !mxStream.is() || !mxSeekable.is())
 501         return -1;
 502     else
 503     {
 504         const sal_Int64 tmpPosition = mxSeekable->getPosition();
 505         if ((tmpPosition < 0) || (tmpPosition > LONG_MAX))
 506             return -1;
 507         return static_cast<tools::Long>(tmpPosition);
 508     }
 509 }
 510
 511 int WPXSvInputStreamImpl::seek(tools::Long offset)
 512 {
 513     if ((mnLength == 0) || !mxStream.is() || !mxSeekable.is())
 514         return -1;
 515
 516     const sal_Int64 tmpPosition = mxSeekable->getPosition();
 517     if ((tmpPosition < 0) || (tmpPosition > LONG_MAX))
 518         return -1;
 519
 520     try
 521     {
 522         mxSeekable->seek(offset);
 523         return 0;
 524     }
 525     catch (...)
 526     {
 527         SAL_WARN("writerperfect", "mxSeekable->seek(offset) threw exception");
 528         return -1;
 529     }
 530 }
 531
 532 bool WPXSvInputStreamImpl::isEnd()
 533 {
 534     if ((mnLength == 0) || !mxStream.is() || !mxSeekable.is())
 535         return true;
 536     return (mxSeekable->getPosition() >= mnLength);
 537 }
 538
 539 bool WPXSvInputStreamImpl::isStructured()
 540 {
 541     if ((mnLength == 0) || !mxStream.is() || !mxSeekable.is())
 542         return false;
 543
 544     PositionHolder pos(mxSeekable);
 545     mxSeekable->seek(0);
 546
 547     if (isOLE())
 548         return true;
 549
 550     mxSeekable->seek(0);
 551
 552     return isZip();
 553 }
 554
 555 unsigned WPXSvInputStreamImpl::subStreamCount()
 556 {
 557     if ((mnLength == 0) || !mxStream.is() || !mxSeekable.is())
 558         return 0;
 559
 560     PositionHolder pos(mxSeekable);
 561     mxSeekable->seek(0);
 562
 563     if (isOLE())
 564     {
 565         ensureOLEIsInitialized();
 566
 567         return mpOLEStorage->maStreams.size();
 568     }
 569
 570     mxSeekable->seek(0);
 571
 572     if (isZip())
 573     {
 574         ensureZipIsInitialized();
 575
 576         return mpZipStorage->maStreams.size();
 577     }
 578
 579     return 0;
 580 }
 581
 582 const char* WPXSvInputStreamImpl::subStreamName(const unsigned id)
 583 {
 584     if ((mnLength == 0) || !mxStream.is() || !mxSeekable.is())
 585         return nullptr;
 586
 587     PositionHolder pos(mxSeekable);
 588     mxSeekable->seek(0);
 589
 590     if (isOLE())
 591     {
 592         ensureOLEIsInitialized();
 593
 594         if (mpOLEStorage->maStreams.size() <= id)
 595             return nullptr;
 596
 597         return mpOLEStorage->maStreams[id].RVNGname.getStr();
 598     }
 599
 600     mxSeekable->seek(0);
 601
 602     if (isZip())
 603     {
 604         ensureZipIsInitialized();
 605
 606         if (mpZipStorage->maStreams.size() <= id)
 607             return nullptr;
 608
 609         return mpZipStorage->maStreams[id].aName.getStr();
 610     }
 611
 612     return nullptr;
 613 }
 614
 615 bool WPXSvInputStreamImpl::existsSubStream(const char* const name)
 616 {
 617     if (!name)
 618         return false;
 619
 620     if ((mnLength == 0) || !mxStream.is() || !mxSeekable.is())
 621         return false;
 622
 623     PositionHolder pos(mxSeekable);
 624     mxSeekable->seek(0);
 625
 626     const OUString aName(OStringToOUString(OString(name), RTL_TEXTENCODING_UTF8));
 627
 628     if (isOLE())
 629     {
 630         ensureOLEIsInitialized();
 631         return mpOLEStorage->maNameMap.end() != mpOLEStorage->maNameMap.find(aName);
 632     }
 633
 634     mxSeekable->seek(0);
 635
 636     if (isZip())
 637     {
 638         ensureZipIsInitialized();
 639         return mpZipStorage->maNameMap.end() != mpZipStorage->maNameMap.find(aName);
 640     }
 641
 642     return false;
 643 }
 644
 645 librevenge::RVNGInputStream* WPXSvInputStreamImpl::getSubStreamByName(const char* const name)
 646 {
 647     if (!name)
 648         return nullptr;
 649
 650     if ((mnLength == 0) || !mxStream.is() || !mxSeekable.is())
 651         return nullptr;
 652
 653     PositionHolder pos(mxSeekable);
 654     mxSeekable->seek(0);
 655
 656     const OUString aName(OStringToOUString(OString(name), RTL_TEXTENCODING_UTF8));
 657
 658     if (isOLE())
 659     {
 660         ensureOLEIsInitialized();
 661         return createWPXStream(mpOLEStorage->getStream(aName));
 662     }
 663
 664     mxSeekable->seek(0);
 665
 666     if (isZip())
 667     {
 668         ensureZipIsInitialized();
 669
 670         try
 671         {
 672             return createWPXStream(mpZipStorage->getStream(aName));
 673         }
 674         catch (const Exception&)
 675         {
 676             // nothing needed
 677         }
 678     }
 679
 680     return nullptr;
 681 }
 682
 683 librevenge::RVNGInputStream* WPXSvInputStreamImpl::getSubStreamById(const unsigned id)
 684 {
 685     if ((mnLength == 0) || !mxStream.is() || !mxSeekable.is())
 686         return nullptr;
 687
 688     PositionHolder pos(mxSeekable);
 689     mxSeekable->seek(0);
 690
 691     if (isOLE())
 692     {
 693         ensureOLEIsInitialized();
 694
 695         if (mpOLEStorage->maStreams.size() <= id)
 696             return nullptr;
 697
 698         return createWPXStream(mpOLEStorage->getStream(id));
 699     }
 700
 701     mxSeekable->seek(0);
 702
 703     if (isZip())
 704     {
 705         ensureZipIsInitialized();
 706
 707         if (mpZipStorage->maStreams.size() <= id)
 708             return nullptr;
 709
 710         try
 711         {
 712             return createWPXStream(mpZipStorage->getStream(id));
 713         }
 714         catch (const Exception&)
 715         {
 716             // nothing needed
 717         }
 718     }
 719     return nullptr;
 720 }
 721
 722 void WPXSvInputStreamImpl::invalidateReadBuffer()
 723 {
 724     if (mpReadBuffer)
 725     {
 726         seek(tell() + static_cast<tools::Long>(mnReadBufferPos)
 727              - static_cast<tools::Long>(mnReadBufferLength));
 728         mpReadBuffer = nullptr;
 729         mnReadBufferPos = 0;
 730         mnReadBufferLength = 0;
 731     }
 732 }
 733
 734 librevenge::RVNGInputStream*
 735 WPXSvInputStreamImpl::createWPXStream(const tools::SvRef<SotStorageStream>& rxStorage)
 736 {
 737     if (rxStorage.is())
 738     {
 739         Reference<XInputStream> xContents(new utl::OSeekableInputStreamWrapper(rxStorage.get()));
 740         return new WPXSvInputStream(xContents);
 741     }
 742     return nullptr;
 743 }
 744
 745 librevenge::RVNGInputStream*
 746 WPXSvInputStreamImpl::createWPXStream(const Reference<XInputStream>& rxStream)
 747 {
 748     if (rxStream.is())
 749         return new WPXSvInputStream(rxStream);
 750     else
 751         return nullptr;
 752 }
 753
 754 bool WPXSvInputStreamImpl::isOLE()
 755 {
 756     if (!mbCheckedOLE)
 757     {
 758         assert(0 == mxSeekable->getPosition());
 759
 760         std::unique_ptr<SvStream> pStream(utl::UcbStreamHelper::CreateStream(mxStream));
 761         if (pStream && SotStorage::IsOLEStorage(pStream.get()))
 762             mpOLEStorage.reset(new OLEStorageImpl());
 763
 764         mbCheckedOLE = true;
 765     }
 766
 767     return bool(mpOLEStorage);
 768 }
 769
 770 bool WPXSvInputStreamImpl::isZip()
 771 {
 772     if (!mbCheckedZip)
 773     {
 774         assert(0 == mxSeekable->getPosition());
 775
 776         try
 777         {
 778             Sequence<Any> aArgs(1);
 779             aArgs[0] <<= mxStream;
 780
 781             const Reference<XComponentContext> xContext(comphelper::getProcessComponentContext(),
 782                                                         UNO_SET_THROW);
 783             const Reference<packages::zip::XZipFileAccess2> xZip(
 784                 xContext->getServiceManager()->createInstanceWithArgumentsAndContext(
 785                     "com.sun.star.packages.zip.ZipFileAccess", aArgs, xContext),
 786                 UNO_QUERY_THROW);
 787             mpZipStorage.reset(new ZipStorageImpl(xZip));
 788         }
 789         catch (const Exception&)
 790         {
 791             // ignore
 792         }
 793
 794         mbCheckedZip = true;
 795     }
 796
 797     return bool(mpZipStorage);
 798 }
 799
 800 void WPXSvInputStreamImpl::ensureOLEIsInitialized()
 801 {
 802     assert(mpOLEStorage);
 803
 804     if (!mpOLEStorage->mbInitialized)
 805         mpOLEStorage->initialize(utl::UcbStreamHelper::CreateStream(mxStream));
 806 }
 807
 808 void WPXSvInputStreamImpl::ensureZipIsInitialized()
 809 {
 810     assert(mpZipStorage);
 811
 812     if (!mpZipStorage->mbInitialized)
 813         mpZipStorage->initialize();
 814 }
 815
 816 WPXSvInputStream::WPXSvInputStream(Reference<XInputStream> const& xStream)
 817     : mpImpl(new WPXSvInputStreamImpl(xStream))
 818 {
 819 }
 820
 821 WPXSvInputStream::~WPXSvInputStream() {}
 822
 823 #define BUFFER_MAX 65536
 824
 825 const unsigned char* WPXSvInputStream::read(unsigned long numBytes, unsigned long& numBytesRead)
 826 {
 827     numBytesRead = 0;
 828
 829     if (numBytes == 0 || numBytes > std::numeric_limits<unsigned long>::max() / 2)
 830         return nullptr;
 831
 832     if (mpImpl->mpReadBuffer)
 833     {
 834         if ((mpImpl->mnReadBufferPos + numBytes > mpImpl->mnReadBufferPos)
 835             && (mpImpl->mnReadBufferPos + numBytes <= mpImpl->mnReadBufferLength))
 836         {
 837             const unsigned char* pTmp = mpImpl->mpReadBuffer + mpImpl->mnReadBufferPos;
 838             mpImpl->mnReadBufferPos += numBytes;
 839             numBytesRead = numBytes;
 840             return pTmp;
 841         }
 842
 843         mpImpl->invalidateReadBuffer();
 844     }
 845
 846     unsigned long curpos = static_cast<unsigned long>(mpImpl->tell());
 847     if (curpos == static_cast<unsigned long>(-1)) // returned ERROR
 848         return nullptr;
 849
 850     if ((curpos + numBytes < curpos) /*overflow*/
 851         || (curpos + numBytes
 852             >= o3tl::make_unsigned(mpImpl->mnLength))) /*reading more than available*/
 853     {
 854         numBytes = mpImpl->mnLength - curpos;
 855     }
 856
 857     if (numBytes < BUFFER_MAX)
 858     {
 859         if (BUFFER_MAX < mpImpl->mnLength - curpos)
 860             mpImpl->mnReadBufferLength = BUFFER_MAX;
 861         else /* BUFFER_MAX >= mpImpl->mnLength - curpos */
 862             mpImpl->mnReadBufferLength = mpImpl->mnLength - curpos;
 863     }
 864     else
 865         mpImpl->mnReadBufferLength = numBytes;
 866
 867     unsigned long tmpNumBytes(0);
 868     mpImpl->mpReadBuffer = mpImpl->read(mpImpl->mnReadBufferLength, tmpNumBytes);
 869     if (tmpNumBytes != mpImpl->mnReadBufferLength)
 870         mpImpl->mnReadBufferLength = tmpNumBytes;
 871
 872     mpImpl->mnReadBufferPos = 0;
 873     if (!mpImpl->mnReadBufferLength)
 874         return nullptr;
 875
 876     if (numBytes <= mpImpl->mnReadBufferLength)
 877         numBytesRead = numBytes;
 878     else
 879         numBytesRead = mpImpl->mnReadBufferLength;
 880
 881     mpImpl->mnReadBufferPos += numBytesRead;
 882     return mpImpl->mpReadBuffer;
 883 }
 884
 885 long WPXSvInputStream::tell()
 886 {
 887     tools::Long retVal = mpImpl->tell();
 888     return retVal - static_cast<tools::Long>(mpImpl->mnReadBufferLength)
 889            + static_cast<tools::Long>(mpImpl->mnReadBufferPos);
 890 }
 891
 892 int WPXSvInputStream::seek(long offset, librevenge::RVNG_SEEK_TYPE seekType)
 893 {
 894     sal_Int64 tmpOffset = offset;
 895     if (seekType == librevenge::RVNG_SEEK_CUR)
 896         tmpOffset += tell();
 897     if (seekType == librevenge::RVNG_SEEK_END)
 898         tmpOffset += mpImpl->mnLength;
 899
 900     int retVal = 0;
 901     if (tmpOffset < 0)
 902     {
 903         tmpOffset = 0;
 904         retVal = -1;
 905     }
 906     if (tmpOffset > mpImpl->mnLength)
 907     {
 908         tmpOffset = mpImpl->mnLength;
 909         retVal = -1;
 910     }
 911
 912     if (tmpOffset < mpImpl->tell()
 913         && o3tl::make_unsigned(tmpOffset)
 914                >= static_cast<unsigned long>(mpImpl->tell()) - mpImpl->mnReadBufferLength)
 915     {
 916         mpImpl->mnReadBufferPos = static_cast<unsigned long>(
 917             tmpOffset + static_cast<tools::Long>(mpImpl->mnReadBufferLength) - mpImpl->tell());
 918         return retVal;
 919     }
 920
 921     mpImpl->invalidateReadBuffer();
 922
 923     if (mpImpl->seek(tmpOffset))
 924         return -1;
 925     return retVal;
 926 }
 927
 928 bool WPXSvInputStream::isEnd()
 929 {
 930     return mpImpl->isEnd() && mpImpl->mnReadBufferPos == mpImpl->mnReadBufferLength;
 931 }
 932
 933 bool WPXSvInputStream::isStructured()
 934 {
 935     mpImpl->invalidateReadBuffer();
 936     return mpImpl->isStructured();
 937 }
 938
 939 unsigned WPXSvInputStream::subStreamCount()
 940 {
 941     mpImpl->invalidateReadBuffer();
 942     return mpImpl->subStreamCount();
 943 }
 944
 945 const char* WPXSvInputStream::subStreamName(const unsigned id)
 946 {
 947     mpImpl->invalidateReadBuffer();
 948     return mpImpl->subStreamName(id);
 949 }
 950
 951 bool WPXSvInputStream::existsSubStream(const char* const name)
 952 {
 953     mpImpl->invalidateReadBuffer();
 954     return mpImpl->existsSubStream(name);
 955 }
 956
 957 librevenge::RVNGInputStream* WPXSvInputStream::getSubStreamByName(const char* name)
 958 {
 959     mpImpl->invalidateReadBuffer();
 960     return mpImpl->getSubStreamByName(name);
 961 }
 962
 963 librevenge::RVNGInputStream* WPXSvInputStream::getSubStreamById(const unsigned id)
 964 {
 965     mpImpl->invalidateReadBuffer();
 966     return mpImpl->getSubStreamById(id);
 967 }
 968 }
 969
 970 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */