openmw/stream/clients/ogre_datastream.hpp

#ifndef MANGLE_STREAM_OGRECLIENT_H
#define MANGLE_STREAM_OGRECLIENT_H

#include <OgreDataStream.h>
#include <assert.h>
#include "../stream.hpp"

namespace Mangle {
namespace Stream {

/** An OGRE DataStream that wraps a Mangle::Stream input.

    This has been built and tested against OGRE 1.6.2. You might have
    to make your own modifications if you're working with newer (or
    older) versions.
 */
class Mangle2OgreStream : public Ogre::DataStream
{
  StreamPtr inp;

  void init()
    {
      // Get the size, if possible
      if(inp->hasSize)
        mSize = inp->size();

      // Allow writing if inp supports it
      if(inp->isWritable)
        mAccess |= Ogre::DataStream::WRITE;
    }

 public:
  /// Constructor without name
  Mangle2OgreStream(StreamPtr _inp)
    : inp(_inp) { init(); }

  /// Constructor for a named data stream
  Mangle2OgreStream(const Ogre::String &name, StreamPtr _inp)
    : Ogre::DataStream(name), inp(_inp) { init(); }

  // Only implement the DataStream functions we have to implement

  size_t read(void *buf, size_t count)
  { return inp->read(buf,count); }

  size_t write(const void *buf, size_t count)
  { assert(inp->isWritable); return inp->write(buf,count); }

  void skip(long count)
    {
      assert(inp->isSeekable && inp->hasPosition);
      inp->seek(inp->tell() + count);
    }

  void seek(size_t pos)
    { assert(inp->isSeekable); inp->seek(pos); }

  size_t tell() const
    { assert(inp->hasPosition); return inp->tell(); }

  bool eof() const { return inp->eof(); }

  /// Does nothing
  void close() {}
};

}} // namespaces
#endif