QSocket --> BSD sockets
[irwi] / src / irctrl.cpp
index 54b067f..94c6329 100644 (file)
@@ -1,62 +1,80 @@
+#include <cstdlib>
+
+#include <sys/socket.h>
+#include <unistd.h>
+#include <sys/types.h>
+#include <netinet/in.h>
+#include <netinet/ip.h>
+#include <netinet/tcp.h>
+
 #include <QSettings>
+#include <QByteArray>
+#include <QString>
+#include <QDebug>
+
 #include "irctrl.h"
-#include "irctrl_p.h"
 
 IrCtrl::IrCtrl(QObject *parent)
     : QObject(parent)
-    , d_ptr(new IrCtrlPrivate())
-{
-    Q_D(IrCtrl);
-    d->q_ptr = this;
-}
-
-IrCtrl::IrCtrl(IrCtrlPrivate &dd, QObject *parent)
-    : QObject(parent)
-    , d_ptr(&dd)
 {
-    Q_D(IrCtrl);
-    d->q_ptr = this;
+    QSettings settings;
+    m_killLircTimer.setInterval(
+            settings.value("idleTimeout", "300").toInt() * 1000);
+    m_killLircTimer.setSingleShot(true);
+    connect(&m_killLircTimer, SIGNAL(timeout()),
+            this, SLOT(stopLirc()));
+    startLirc();
+    m_killLircTimer.start();
 }
-
+    
 IrCtrl::~IrCtrl()
 {
-    delete d_ptr;
 }
 
-void IrCtrl::sendCmd0()
+void IrCtrl::sendCmd(const QString &cmd)
 {
-    Q_D(IrCtrl);
-    d->genericSendCmd(d->settings->value("cmd0", "VOL+").toString());
-}
+    if (!m_killLircTimer.isActive()) {
+        startLirc();
+    } else {
+        m_killLircTimer.stop();
+    }
 
-void IrCtrl::sendCmd1()
-{
-    Q_D(IrCtrl);
-    d->genericSendCmd(d->settings->value("cmd1", "VOL-").toString());
-}
+    QSettings settings;
+    QString remoteName = settings.value("remoteName", "").toString();
+    QString cmdStr = "SEND_ONCE " + remoteName + " " + cmd + "\n";
+    QByteArray buf = cmdStr.toAscii();
 
-void IrCtrl::sendCmd2()
-{
-    Q_D(IrCtrl);
-    d->genericSendCmd(d->settings->value("cmd2", "P+").toString());
-}
+    sockaddr_in addr;
+    memset(&addr, 0, sizeof(addr));
+    addr.sin_family      = AF_INET;
+    addr.sin_addr.s_addr = INADDR_LOOPBACK;
+    addr.sin_port        = LIRC_PORT;
+    int sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
+    if (sock == -1) {
+        qDebug() << "Socket open fail";
+    } else {
+        int c = ::connect(sock, (sockaddr*)&addr, sizeof(sockaddr_in));
+        if (c == 0) {
+            write(sock, buf.constData(), buf.count());
+        } else {
+            qDebug() << "Connect fail";
+        }
+        shutdown(sock, SHUT_RDWR);
+        close(sock);
+    }
 
-void IrCtrl::sendCmd3()
-{
-    Q_D(IrCtrl);
-    d->genericSendCmd(d->settings->value("cmd3", "P-").toString());
+    m_killLircTimer.start();
 }
 
-void IrCtrl::sendCmd4()
+
+void IrCtrl::stopLirc()
 {
-    Q_D(IrCtrl);
-    d->genericSendCmd(d->settings->value("cmd4", "ON/OFF").toString());
+    std::system("sudo /etc/init.d/lirc stop");
 }
 
-void IrCtrl::sendCmd5()
+void IrCtrl::startLirc()
 {
-    Q_D(IrCtrl);
-    d->genericSendCmd(d->settings->value("cmd5", "MUTE").toString());
+    std::system("sudo /etc/init.d/lirc start");
 }