Copy the KDE 3.5 branch to branches/trinity for new KDE 3.5 features.

BUG:215923


git-svn-id: svn://anonsvn.kde.org/home/kde/branches/trinity/kdenetwork@1054174 283d02a7-25f6-0310-bc7c-ecb5cbfe19da

1 files changed, 285 insertions, 0 deletions

diff --git a/librss/loader.cpp b/librss/loader.cpp
new file mode 100644
index 00000000..c38400f4
--- /dev/null
+++ b/librss/loader.cpp
@@ -0,0 +1,285 @@
+/*
+ * loader.cpp
+ *
+ * Copyright (c) 2001, 2002, 2003, 2004 Frerich Raabe <raabe@kde.org>
+ *
+ * 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. For licensing and distribution details, check the
+ * accompanying file 'COPYING'.
+ */
+#include "loader.h"
+#include "document.h"
+
+#include <kio/job.h>
+#include <kprocess.h>
+#include <kurl.h>
+
+#include <qdom.h>
+#include <qbuffer.h>
+#include <qregexp.h>
+
+using namespace RSS;
+
+DataRetriever::DataRetriever()
+{
+}
+
+DataRetriever::~DataRetriever()
+{
+}
+
+struct FileRetriever::Private
+{
+	Private()
+		: buffer(NULL),
+		  lastError(0)
+	{
+	}
+
+	~Private()
+	{
+		delete buffer;
+	}
+
+	QBuffer *buffer;
+	int lastError;
+};
+
+FileRetriever::FileRetriever()
+	: d(new Private)
+{
+}
+
+FileRetriever::~FileRetriever()
+{
+	delete d;
+}
+
+void FileRetriever::retrieveData(const KURL &url)
+{
+	if (d->buffer)
+		return;
+	
+	d->buffer = new QBuffer;
+	d->buffer->open(IO_WriteOnly);
+
+	KIO::Job *job = KIO::get(url, false, false);
+	connect(job, SIGNAL(data(KIO::Job *, const QByteArray &)),
+	             SLOT(slotData(KIO::Job *, const QByteArray &)));
+	connect(job, SIGNAL(result(KIO::Job *)), SLOT(slotResult(KIO::Job *)));
+	connect(job, SIGNAL(permanentRedirection(KIO::Job *, const KURL &, const KURL &)),
+	             SLOT(slotPermanentRedirection(KIO::Job *, const KURL &, const KURL &)));
+}
+
+int FileRetriever::errorCode() const
+{
+	return d->lastError;
+}
+
+void FileRetriever::slotData(KIO::Job *, const QByteArray &data)
+{
+	d->buffer->writeBlock(data.data(), data.size());
+}
+
+void FileRetriever::slotResult(KIO::Job *job)
+{
+	QByteArray data = d->buffer->buffer();
+	data.detach();
+
+	delete d->buffer;
+	d->buffer = NULL;
+	
+	d->lastError = job->error();
+	emit dataRetrieved(data, d->lastError == 0);
+}
+
+void FileRetriever::slotPermanentRedirection(KIO::Job *, const KURL &, const KURL &newUrl)
+{
+	emit permanentRedirection(newUrl);
+}
+
+struct OutputRetriever::Private
+{
+	Private() : process(NULL),
+		buffer(NULL),
+		lastError(0)
+	{
+	}
+
+	~Private()
+	{
+		delete process;
+		delete buffer;
+	}
+	
+	KShellProcess *process;
+	QBuffer *buffer;
+	int lastError;
+};
+
+OutputRetriever::OutputRetriever() :
+	d(new Private)
+{
+}
+
+OutputRetriever::~OutputRetriever()
+{
+	delete d;
+}
+
+void OutputRetriever::retrieveData(const KURL &url)
+{
+	// Ignore subsequent calls if we didn't finish the previous job yet.
+	if (d->buffer || d->process)
+		return;
+	
+	d->buffer = new QBuffer;
+	d->buffer->open(IO_WriteOnly);
+	
+	d->process = new KShellProcess();
+	connect(d->process, SIGNAL(processExited(KProcess *)),
+	                    SLOT(slotExited(KProcess *)));
+	connect(d->process, SIGNAL(receivedStdout(KProcess *, char *, int)),
+	                    SLOT(slotOutput(KProcess *, char *, int)));
+	*d->process << url.path();
+	d->process->start(KProcess::NotifyOnExit, KProcess::Stdout);
+}
+
+int OutputRetriever::errorCode() const
+{
+	return d->lastError;
+}
+
+void OutputRetriever::slotOutput(KProcess *, char *data, int length)
+{
+	d->buffer->writeBlock(data, length);
+}
+
+void OutputRetriever::slotExited(KProcess *p)
+{
+	if (!p->normalExit())
+		d->lastError = p->exitStatus();
+
+	QByteArray data = d->buffer->buffer();
+	data.detach();
+	
+	delete d->buffer;
+	d->buffer = NULL;
+	
+	delete d->process;
+	d->process = NULL;
+	
+	emit dataRetrieved(data, p->normalExit() && p->exitStatus() == 0);
+}
+
+struct Loader::Private
+{
+	Private() : retriever(NULL),
+		lastError(0)
+	{
+	}
+
+	~Private()
+	{
+		delete retriever;
+	}
+
+	DataRetriever *retriever;
+	int lastError;
+};
+
+Loader *Loader::create()
+{
+	return new Loader;
+}
+
+Loader *Loader::create(QObject *object, const char *slot)
+{
+	Loader *loader = create();
+	connect(loader, SIGNAL(loadingComplete(Loader *, Document, Status)),
+	        object, slot);
+	return loader;
+}
+
+Loader::Loader() : d(new Private)
+{
+}
+
+Loader::~Loader()
+{
+	delete d;
+}
+
+void Loader::loadFrom(const KURL &url, DataRetriever *retriever)
+{
+	if (d->retriever != NULL)
+		return;
+
+	d->retriever = retriever;
+	
+	connect(d->retriever, SIGNAL(dataRetrieved(const QByteArray &, bool)),
+	        this, SLOT(slotRetrieverDone(const QByteArray &, bool)));
+
+	d->retriever->retrieveData(url);
+}
+
+int Loader::errorCode() const
+{
+	return d->lastError;
+}
+
+void Loader::slotRetrieverDone(const QByteArray &data, bool success)
+{
+	d->lastError = d->retriever->errorCode();
+	
+	delete d->retriever;
+	d->retriever = NULL;
+	
+	Document rssDoc;
+	Status status = Success;
+	
+	if (success) {
+		QDomDocument doc;
+
+		/* Some servers insert whitespace before the <?xml...?> declaration.
+		 * QDom doesn't tolerate that (and it's right, that's invalid XML),
+		 * so we strip that.
+		 */
+
+		const char *charData = data.data();
+		int len = data.count();
+
+		while (len && QChar(*charData).isSpace()) {
+			--len;
+			++charData;
+		}
+
+		/* It seems that some Microsoft-developed code generates UTF-8 files
+		 * with the three leading unicode characters 0357, 0273, 0277. For
+		 * an example, check http://msdn.microsoft.com/rss.xml
+		 */
+		if (len > 3 && QChar(*charData) == QChar(0357)) {
+			len -= 3;
+			charData += 3;
+		}
+
+		QByteArray tmpData;
+		tmpData.setRawData(charData, len);
+		
+		if (doc.setContent(tmpData))
+			rssDoc = Document(doc);
+		else
+			status = ParseError;
+		
+		tmpData.resetRawData(charData, len);
+	} else
+		status = RetrieveError;
+
+	emit loadingComplete(this, rssDoc, status);
+
+	delete this;
+}
+
+#include "loader.moc"
+// vim:noet:ts=4