From 10c093a617929db5c6b201dbf03d6070b12b36b4 Mon Sep 17 00:00:00 2001
From: Manjeet Dahiya <manjeetdahiya@gmail.com>
Date: Tue, 27 Oct 2009 12:04:03 +0000
Subject: Issue 15: Implement XEP-0047

---
 source/QXmppIbbTransferManager.cpp | 95 ++++++++++++++++++++++++++++++++++++++
 1 file changed, 95 insertions(+)
 create mode 100644 source/QXmppIbbTransferManager.cpp

(limited to 'source/QXmppIbbTransferManager.cpp')

diff --git a/source/QXmppIbbTransferManager.cpp b/source/QXmppIbbTransferManager.cpp
new file mode 100644
index 00000000..e9437b5b
--- /dev/null
+++ b/source/QXmppIbbTransferManager.cpp
@@ -0,0 +1,95 @@
+#include "QXmppIbbTransferManager.h"
+#include "QXmppClient.h"
+
+QXmppIbbTransferManager::QXmppIbbTransferManager(QXmppClient* client):
+        m_client(client)
+{
+}
+
+void QXmppIbbTransferManager::teardownIbbTransferManager( const QString &sid )
+{
+    QString id = getIbbTransferJobBySid(sid)->getId();
+    delete m_activeTransfers[id];
+    m_activeTransfers.remove(id);
+}
+
+void QXmppIbbTransferManager::addIbbTransferManager( QXmppIbbTransferJob *mgr )
+{
+    m_activeTransfers[mgr->getId()] = mgr;
+    connect( mgr, SIGNAL(transferCanceled(QString,QString)),
+             this, SIGNAL(byteStreamCanceled(QString,QString)));
+    connect( mgr, SIGNAL(transferFinished(QString,QString)),
+             this, SIGNAL(byteStreamClosed(QString,QString)));
+    connect( mgr, SIGNAL(transferRequested(QString,QString)),
+             this, SIGNAL(byteStreamRequestReceived(QString,QString)));
+    connect( mgr, SIGNAL(transferStarted(QString)),
+             this, SIGNAL(byteStreamOpened(QString)));
+    connect( mgr, SIGNAL(readyForTeardown(QString)),
+             this, SLOT(teardownIbbTransferManager(QString)));
+}
+
+QXmppIbbTransferJob *QXmppIbbTransferManager::getIbbTransferJob( const QString &id )
+{
+    QXmppIbbTransferJob *mgr = m_activeTransfers[id];
+    if( mgr == 0 )
+    {
+        mgr = new QXmppIbbTransferJob(m_client);
+        mgr->setId(id);
+        addIbbTransferManager(mgr);
+    }
+    return mgr;
+}
+
+bool QXmppIbbTransferManager::isIbbTransferJobId( const QString &id )
+{
+    return m_activeTransfers.keys().contains(id);
+}
+
+QXmppIbbTransferJob *QXmppIbbTransferManager::getIbbTransferJobBySid( const QString &sid )
+{
+    foreach( QXmppIbbTransferJob *mgr, m_activeTransfers )
+    {
+        if ( mgr->getSid() == sid )
+            return mgr;
+    }
+
+    return 0;
+}
+
+void QXmppIbbTransferManager::sendByteStreamRequest( const QString &sid, const QString &bareRemoteJid,  QIODevice *io)
+{
+
+    QXmppIbbTransferJob *mgr = new QXmppIbbTransferJob(m_client);
+    mgr->setSid( sid );
+    mgr->setRemoteJid( bareRemoteJid );  //FIXME: make like send message
+    mgr->setIoDevice( io );
+    mgr->requestTransfer();
+    addIbbTransferManager( mgr );
+
+}
+
+void QXmppIbbTransferManager::acceptByteStreamRequest( const QString &sid, QIODevice *io )
+{
+    QXmppIbbTransferJob *mgr = getIbbTransferJobBySid(sid);
+    if( mgr == 0 )
+        return;
+
+    mgr->setIoDevice(io);
+    mgr->acceptTransfer();
+}
+
+void QXmppIbbTransferManager::rejectByteStreamRequest( const QString &sid )
+{
+    QXmppIbbTransferJob *mgr = getIbbTransferJobBySid(sid);
+    if( mgr == 0 )
+        return;
+    mgr->cancelTransfer();
+}
+
+void QXmppIbbTransferManager::cancelByteStreamRequest( const QString &sid )
+{
+    QXmppIbbTransferJob *mgr = getIbbTransferJobBySid(sid);
+    if( mgr == 0 )
+        return;
+    mgr->cancelTransfer();
+}
-- 
cgit v1.2.3