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/kdeutils@1054174 283d02a7-25f6-0310-bc7c-ecb5cbfe19da

1 files changed, 241 insertions, 0 deletions

diff --git a/kdelirc/irkick/klircclient.cpp b/kdelirc/irkick/klircclient.cpp
new file mode 100644
index 0000000..2876079
--- /dev/null
+++ b/kdelirc/irkick/klircclient.cpp
@@ -0,0 +1,241 @@
+//
+//
+// C++ Implementation: $MODULE$
+//
+// Description:
+//
+//
+// Author: (C) 2002 by Malte Starostik
+// Adaption : Gav Wood <[email protected]>, (C) 2003
+//
+// Copyright: See COPYING file that comes with this distribution
+//
+//
+
+#include <unistd.h>
+#include <fcntl.h>
+#include <cstring>
+#include <sys/un.h>
+#include <sys/socket.h>
+#include <errno.h>
+
+#include <qwidget.h>
+#include <qdialog.h>
+#include <qtooltip.h>
+#include <qsocket.h>
+#include <qsocketnotifier.h>
+#include <qfile.h>
+
+#include <kapplication.h>
+#include <ksystemtray.h>
+#include <kiconloader.h>
+#include <kpassivepopup.h>
+#include <kmessagebox.h>
+#include <kpopupmenu.h>
+#include <kdebug.h>
+#include <klocale.h>
+#include <kaboutdialog.h>
+#include <kaboutkde.h>
+
+#include <dcopclient.h>
+#include <dcopref.h>
+
+#include "klircclient.h"
+
+
+KLircClient::KLircClient(QWidget *parent, const char *name) : QObject(parent, name), theSocket(0), listIsUpToDate(false)
+{
+	connectToLirc();
+}
+
+bool KLircClient::connectToLirc()
+{
+	int sock = ::socket(PF_UNIX, SOCK_STREAM, 0);
+	if(sock == -1) return false;
+
+	sockaddr_un addr;
+	addr.sun_family = AF_UNIX;
+	strcpy(addr.sun_path, "/dev/lircd");
+	if(::connect(sock, (struct sockaddr *)(&addr), sizeof(addr)) == -1)
+	{	::close(sock);
+		// in case of mandrake...
+		strcpy(addr.sun_path, "/tmp/.lircd");
+		if(::connect(sock, (struct sockaddr *)(&addr), sizeof(addr)) == -1)
+		{	::close(sock);
+			return false;
+		}
+	}
+
+	theSocket = new QSocket;
+	theSocket->setSocket(sock);
+	connect(theSocket, SIGNAL(readyRead()), SLOT(slotRead()));
+	connect(theSocket, SIGNAL(connectionClosed()), SLOT(slotClosed()));
+	updateRemotes();
+	return true;
+}
+
+KLircClient::~KLircClient()
+{
+//	if(theSocket)
+		delete theSocket;
+}
+
+void KLircClient::slotClosed()
+{
+	delete theSocket;
+	theSocket = 0;
+	emit connectionClosed();
+}
+
+const QStringList KLircClient::remotes() const
+{
+	QStringList remotes;
+	for(QMap<QString, QStringList>::ConstIterator i = theRemotes.begin(); i != theRemotes.end(); ++i)
+		remotes.append(i.key());
+	remotes.sort();
+	return remotes;
+}
+
+const QStringList KLircClient::buttons(const QString &theRemote) const
+{
+	return theRemotes[theRemote];
+}
+
+void KLircClient::slotRead()
+{
+	while (theSocket->bytesAvailable())
+	{
+		QString line = readLine();
+		if (line == "BEGIN")
+		{
+			// BEGIN
+			// <command>
+			// [SUCCESS|ERROR]
+			// [DATA
+			// n
+			// n lines of data]
+			// END
+			line = readLine();
+			if (line == "SIGHUP")
+			{
+				// Configuration changed
+				do line = readLine();
+				while (!line.isEmpty() && line != "END");
+				updateRemotes();
+				return;
+			}
+			else if (line == "LIST")
+			{
+				// remote control list
+				if (readLine() != "SUCCESS" || readLine() != "DATA")
+				{
+					do line = readLine();
+					while (!line.isEmpty() && line != "END");
+					return;
+				}
+				QStringList remotes;
+				int count = readLine().toInt();
+				for (int i = 0; i < count; ++i)
+					remotes.append(readLine());
+				do line = readLine();
+				while (!line.isEmpty() && line != "END");
+				if (line.isEmpty())
+					return; // abort on corrupt data
+				for (QStringList::ConstIterator it = remotes.begin(); it != remotes.end(); ++it)
+					sendCommand("LIST " + *it);
+				return;
+			}
+			else if (line.left(4) == "LIST")
+			{
+				// button list
+				if (readLine() != "SUCCESS" || readLine() != "DATA")
+				{
+					do line = readLine();
+					while (!line.isEmpty() && line != "END");
+					return;
+				}
+				QString remote = line.mid(5);
+				QStringList buttons;
+				int count = readLine().toInt();
+				for (int i = 0; i < count; ++i)
+				{
+					// <code> <name>
+					QString btn = readLine().mid(17);
+					if(btn.isNull()) break;
+					if(btn.startsWith("'") && btn.endsWith("'"))
+						btn = btn.mid(1, btn.length() - 2);
+					buttons.append(btn);
+				}
+				theRemotes.insert(remote, buttons);
+			}
+			do line = readLine();
+			while (!line.isEmpty() && line != "END");
+			listIsUpToDate = true;
+			emit remotesRead();
+		}
+		else
+		{
+			// <code> <repeat> <button name> <remote control name>
+			line.remove(0, 17); // strip code
+			int pos = line.find(' ');
+			if (pos < 0) return;
+			bool ok;
+			int repeat = line.left(pos).toInt(&ok, 16);
+			if (!ok) return;
+			line.remove(0, pos + 1);
+
+			pos = line.find(' ');
+			if (pos < 0) return;
+			QString btn = line.left(pos);
+			if(btn.startsWith("'") && btn.endsWith("'"))
+				btn = btn.mid(1, btn.length() - 2);
+			line.remove(0, pos + 1);
+
+			emit commandReceived(line, btn, repeat);
+		}
+	}
+}
+
+void KLircClient::updateRemotes()
+{
+	listIsUpToDate = false;
+	theRemotes.clear();
+	sendCommand("LIST");
+}
+
+bool KLircClient::isConnected() const
+{
+	if(!theSocket) return false;
+	return theSocket->state() == QSocket::Connected;
+}
+
+bool KLircClient::haveFullList() const
+{
+	return listIsUpToDate;
+}
+
+const QString KLircClient::readLine()
+{
+	if (!theSocket->canReadLine())
+	{	bool timeout;
+		// FIXME: possible race condition -
+		// more might have arrived between canReadLine and waitForMore
+		theSocket->waitForMore(500, &timeout);
+		if (timeout)
+		{	// something's wrong. there ain't no line comin!
+			return QString::null;
+		}
+	}
+	QString line = theSocket->readLine();
+	line.truncate(line.length() - 1);
+	return line;
+}
+
+void KLircClient::sendCommand(const QString &command)
+{
+	QString cmd = command + "\n";
+	theSocket->writeBlock(QFile::encodeName( cmd ), cmd.length());
+}
+
+
+#include "klircclient.moc"