module libraw.datastream;

import libraw.const_;
import libraw.types;

import core.stdc.errno;
import core.stdc.stdio;
import core.stdc..string;
//#include <sys/types.h>
import core.stdc.stdlib;

version (Windows) {
	import core.sys.windows.winsock2;
}


//#include <fstream>
//#include <memory>

version (USE_DNGSDK) {
	/+#if defined WIN32 || defined(__MINGW32__)
	#define qWinOS 1
	#define qMacOS 0
	#elif defined(__APPLE__)
	#define qWinOS 0
	#define qMacOS 1
	#else
	/* define OS types for DNG here */
	#endif
	#define qDNGXMPDocOps 0
	#define qDNGUseLibJPEG 1
	#define qDNGXMPFiles 0
	#define qDNGExperimental 1
	#define qDNGThreadSafe 1
	#include "dng_stream.h"
	#endif /* DNGSDK */ +/
}

/*#define IOERROR()                                                                                                      \
	do                                                                                                                   \
	{                                                                                                                    \
		throw LIBRAW_EXCEPTION_IO_EOF;                                                                                     \
	} while (0)*/

/+extern (C++) {
	class LibRaw_bit_buffer;

	class LibRaw_abstract_datastream
	{
		// NOTE: the virtual destructor produces a multiple definition error if a
		//       body is defined and an unresolved external if no body is defined.
		//       We define a dummy symbol to take the space of the unresolved symbol
		//       and define the destructor without a body to solve this.
		void* dummy(uint) { return null; }

		//~this();

		abstract int valid();
		abstract int read(void *, size_t, size_t);
		abstract int seek(long, int);
		abstract long tell();
		abstract long size();
		abstract int get_char();
		abstract char *gets(char *, int);
		abstract int scanf_one(const(char)*, void*);
		abstract int eof();
		abstract void *make_jas_stream();
		int jpeg_src(void*);
		void buffering_off() {}
		int lock();
		void unlock();
		const(char)* fname();
		version (Windows) {
			const(wchar_t)* wfname() { return null; }
			int subfile_open(const(wchar_t)*) { return -1; }
		}
		int subfile_open(const(char)*);
		void subfile_close();

		int tempbuffer_open(void*, size_t);
		void tempbuffer_close();

	protected:
		LibRaw_abstract_datastream *substream;
	}
}+/

/+#ifdef WIN32
template class std::auto_ptr<std::streambuf>;
#endif

class LibRaw_file_datastream : public LibRaw_abstract_datastream
{
protected:
	std::auto_ptr<std::streambuf> f;       /* will close() automatically through dtor */
	std::auto_ptr<std::streambuf> saved_f; /* when *f is a subfile, *saved_f is the master file */
	std::string filename;
	INT64 _fsize;
#ifdef WIN32
	std::wstring wfilename;
#endif
	FILE *jas_file;

public:
	virtual ~LibRaw_file_datastream();
	LibRaw_file_datastream(const char *fname);
#if defined(_WIN32) && !defined(__MINGW32__) && defined(_MSC_VER) && (_MSC_VER > 1310)
	LibRaw_file_datastream(const wchar_t *fname);
#endif
	virtual void *make_jas_stream();
	virtual int valid();
	virtual int read(void *ptr, size_t size, size_t nmemb);
	virtual int eof();
	virtual int seek(INT64 o, int whence);
	virtual INT64 tell();
	virtual INT64 size() { return _fsize; }
	virtual int get_char()
	{
		if (substream)
			return substream->get_char();
		return f->sbumpc();
	}
	virtual char *gets(char *str, int sz);
	virtual int scanf_one(const char *fmt, void *val);
	virtual const char *fname();
#if defined(_WIN32) && !defined(__MINGW32__) && defined(_MSC_VER) && (_MSC_VER > 1310)
	virtual const wchar_t *wfname();
	virtual int subfile_open(const wchar_t *fn);
#endif
	virtual int subfile_open(const char *fn);
	virtual void subfile_close();
};

class LibRaw_buffer_datastream : public LibRaw_abstract_datastream
{
public:
	LibRaw_buffer_datastream(void *buffer, size_t bsize);
	virtual ~LibRaw_buffer_datastream();
	virtual int valid();
	virtual void *make_jas_stream();
	virtual int jpeg_src(void *jpegdata);
	virtual int read(void *ptr, size_t sz, size_t nmemb);
	virtual int eof();
	virtual int seek(INT64 o, int whence);
	virtual INT64 tell();
	virtual INT64 size() { return streamsize; }
	virtual char *gets(char *s, int sz);
	virtual int scanf_one(const char *fmt, void *val);
	virtual int get_char()
	{
		if (substream)
			return substream->get_char();
		if (streampos >= streamsize)
			return -1;
		return buf[streampos++];
	}

private:
	unsigned char *buf;
	size_t streampos, streamsize;
};

class LibRaw_bigfile_datastream : public LibRaw_abstract_datastream
{
public:
	LibRaw_bigfile_datastream(const char *fname);
#if defined(_WIN32) && !defined(__MINGW32__) && defined(_MSC_VER) && (_MSC_VER > 1310)
	LibRaw_bigfile_datastream(const wchar_t *fname);
#endif
	virtual ~LibRaw_bigfile_datastream();
	virtual int valid();
	virtual void *make_jas_stream();

	virtual int read(void *ptr, size_t size, size_t nmemb);
	virtual int eof();
	virtual int seek(INT64 o, int whence);
	virtual INT64 tell();
	virtual INT64 size() { return _fsize; }
	virtual char *gets(char *str, int sz);
	virtual int scanf_one(const char *fmt, void *val);
	virtual const char *fname();
#if defined(_WIN32) && !defined(__MINGW32__) && defined(_MSC_VER) && (_MSC_VER > 1310)
	virtual const wchar_t *wfname();
	virtual int subfile_open(const wchar_t *fn);
#endif
	virtual int subfile_open(const char *fn);
	virtual void subfile_close();
	virtual int get_char()
	{
#if !defined(_WIN32) && !defined(__MINGW32__)
		return substream ? substream->get_char() : getc_unlocked(f);
#else
		return substream ? substream->get_char() : fgetc(f);
#endif
	}

protected:
	FILE *f, *sav;
	std::string filename;
	INT64 _fsize;
#ifdef WIN32
	std::wstring wfilename;
#endif
};

#ifdef WIN32
class LibRaw_windows_datastream : public LibRaw_buffer_datastream
{
public:
	/* ctor: high level constructor opens a file by name */
	LibRaw_windows_datastream(const TCHAR *sFile);
	/* ctor: construct with a file handle - caller is responsible for closing the file handle */
	LibRaw_windows_datastream(HANDLE hFile);
	/* dtor: unmap and close the mapping handle */
	virtual ~LibRaw_windows_datastream();
	virtual INT64 size() { return cbView_; }

protected:
	void Open(HANDLE hFile);
	inline void reconstruct_base()
	{
		/* this subterfuge is to overcome the private-ness of LibRaw_buffer_datastream */
		(LibRaw_buffer_datastream &)*this = LibRaw_buffer_datastream(pView_, (size_t)cbView_);
	}

	HANDLE hMap_;    /* handle of the file mapping */
	void *pView_;    /* pointer to the mapped memory */
	__int64 cbView_; /* size of the mapping in bytes */
};

#endif

#ifdef USE_DNGSDK

class libraw_dng_stream : public dng_stream
{
public:
	libraw_dng_stream(LibRaw_abstract_datastream *p)
			: dng_stream((dng_abort_sniffer *)NULL, kBigBufferSize, 0), parent_stream(p)
	{
		if (parent_stream)
		{
			parent_stream->buffering_off();
			off = parent_stream->tell();
			parent_stream->seek(0UL, SEEK_SET); /* seek to start */
		}
	}
	~libraw_dng_stream()
	{
		if (parent_stream)
			parent_stream->seek(off, SEEK_SET);
	}
	virtual uint64 DoGetLength()
	{
		if (parent_stream)
			return parent_stream->size();
		return 0;
	}
	virtual void DoRead(void *data, uint32 count, uint64 offset)
	{
		if (parent_stream)
		{
			parent_stream->seek(offset, SEEK_SET);
			parent_stream->read(data, 1, count);
		}
	}

private:
	libraw_dng_stream(const libraw_dng_stream &stream);
	libraw_dng_stream &operator=(const libraw_dng_stream &stream);
	LibRaw_abstract_datastream *parent_stream;
	INT64 off;
};

#endif

#endif /* cplusplus */ +/