1 files changed, 134 insertions, 0 deletions
diff --git a/src/svnqt/svnfilestream.cpp b/src/svnqt/svnfilestream.cpp
new file mode 100644
index 0000000..2803ef4
--- /dev/null
+++ b/src/svnqt/svnfilestream.cpp
@@ -0,0 +1,134 @@
+/***************************************************************************
+ *   Copyright (C) 2006-2007 by Rajko Albrecht                             *
+ *   ral@alwins-world.de                                                   *
+ *                                                                         *
+ *   This program is free software; you can redistribute it and/or modify  *
+ *   it under the terms of the GNU General Public License as published by  *
+ *   the Free Software Foundation; either version 2 of the License, or     *
+ *   (at your option) any later version.                                   *
+ *                                                                         *
+ *   This program 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 General Public License for more details.                          *
+ *                                                                         *
+ *   You should have received a copy of the GNU General Public License     *
+ *   along with this program; if not, write to the                         *
+ *   Free Software Foundation, Inc.,                                       *
+ *   51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.         *
+ ***************************************************************************/
+#include "svnfilestream.hpp"
+
+#include <qfile.h>
+
+namespace svn {
+
+namespace stream {
+
+#if QT_VERSION < 0x040000
+typedef int openmode;
+#define READONLY IO_ReadOnly
+#define WRITEONLY IO_WriteOnly
+#else
+typedef QIODevice::OpenMode openmode;
+#define READONLY QIODevice::ReadOnly
+#define WRITEONLY QIODevice::WriteOnly
+#endif
+
+class SVNQT_NOEXPORT SvnFileStream_private
+{
+public:
+    SvnFileStream_private(const QString&fn,openmode mode);
+    virtual ~SvnFileStream_private();
+
+    QString m_FileName;
+    QFile m_File;
+};
+
+SvnFileStream_private::SvnFileStream_private(const QString&fn,openmode mode)
+    : m_FileName(fn),m_File(fn)
+{
+    m_File.open(mode);
+}
+
+SvnFileStream_private::~SvnFileStream_private()
+{
+}
+
+SvnFileOStream::SvnFileOStream(const QString&fn,svn_client_ctx_t*ctx)
+    :SvnStream(false,true,ctx)
+{
+    m_FileData = new SvnFileStream_private(fn,WRITEONLY);
+    if (!m_FileData->m_File.isOpen()) {
+        setError(m_FileData->m_File.errorString());
+    }
+}
+
+
+SvnFileOStream::~SvnFileOStream()
+{
+    delete m_FileData;
+}
+
+
+bool SvnFileOStream::isOk() const
+{
+    return m_FileData->m_File.isOpen();
+}
+
+long SvnFileOStream::write(const char* data, const unsigned long max)
+{
+    if (!m_FileData->m_File.isOpen()) {
+        return -1;
+    }
+#if QT_VERSION < 0x040000
+    long res = m_FileData->m_File.writeBlock(data,max);
+#else
+    long res = m_FileData->m_File.write(data,max);
+#endif
+    if (res<0) {
+        setError(m_FileData->m_File.errorString());
+    }
+    return res;
+}
+
+SvnFileIStream::SvnFileIStream(const QString&fn,svn_client_ctx_t*ctx)
+    :SvnStream(true,false,ctx)
+{
+    m_FileData = new SvnFileStream_private(fn,READONLY);
+    if (!m_FileData->m_File.isOpen()) {
+        setError(m_FileData->m_File.errorString());
+    }
+}
+
+
+SvnFileIStream::~SvnFileIStream()
+{
+    delete m_FileData;
+}
+
+
+bool SvnFileIStream::isOk() const
+{
+    return m_FileData->m_File.isOpen();
+}
+
+long SvnFileIStream::read(char* data, const unsigned long max)
+{
+    if (!m_FileData->m_File.isOpen()) {
+        return -1;
+    }
+#if QT_VERSION < 0x040000
+    long res = m_FileData->m_File.readBlock(data,max);
+#else
+    long res = m_FileData->m_File.read(data,max);
+#endif
+    if (res<0) {
+        setError(m_FileData->m_File.errorString());
+    }
+    return res;
+}
+
+}
+
+}