add intial support for Jingle RTP Sessions

1 files changed, 211 insertions, 0 deletions

diff --git a/source/QXmppCallManager.h b/source/QXmppCallManager.h
new file mode 100644
index 00000000..a16e3717
--- /dev/null
+++ b/source/QXmppCallManager.h
@@ -0,0 +1,211 @@
+/*
+ * Copyright (C) 2010 Bolloré telecom
+ *
+ * Author:
+ *	Jeremy Lainé
+ *
+ * Source:
+ *	http://code.google.com/p/qxmpp
+ *
+ * This file is a part of QXmpp library.
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 2.1 of the License, or (at your option) any later version.
+ *
+ * This library 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
+ * Lesser General Public License for more details.
+ *
+ */
+
+#ifndef QXMPPCALLMANAGER_H
+#define QXMPPCALLMANAGER_H
+
+#include <QObject>
+#include <QIODevice>
+
+#include "QXmppJingleIq.h"
+#include "QXmppLogger.h"
+
+class QXmppCodec;
+class QXmppJingleCandidate;
+class QXmppJingleIq;
+class QXmppJinglePayloadType;
+class QXmppStream;
+class QXmppStunSocket;
+
+/// The QXmppCall class represents a Voice-Over-IP call to a remote party.
+///
+/// It acts as a QIODevice so that you can read / write audio samples, for
+/// instance using a QAudioInput and/or QAudioOutput.
+///
+/// \note: THIS API IS NOT FINALIZED YET
+
+class QXmppCall : public QIODevice
+{
+    Q_OBJECT
+
+public:
+    enum Direction
+    {
+        IncomingDirection, ///< The call is incoming.
+        OutgoingDirection, ///< The call is outgoing.
+    };
+
+    enum State
+    {
+        OfferState = 0,
+        ConnectingState = 1,
+        ActiveState = 2,
+        DisconnectingState = 3,
+        FinishedState = 4,
+    };
+
+    QXmppCall::Direction direction() const;
+    QString jid() const;
+    QString sid() const;
+    QXmppCall::State state() const;
+
+    QXmppJinglePayloadType payloadType() const;
+    qint64 bytesAvailable() const;
+    bool isSequential() const;
+
+signals:
+    /// This signal is emitted when a call is finished.
+    ///
+    /// Note: Do not delete the call in the slot connected to this signal,
+    /// instead use deleteLater().
+    void finished();
+
+    /// This signal is emitted when the remote party is ringing.
+    void ringing();
+
+    /// This signal is emitted to send logging messages.
+    void logMessage(QXmppLogger::MessageType type, const QString &msg);
+
+    /// This signal is emitted when the call state.
+    void stateChanged(QXmppCall::State state);
+
+    /// This signal is emitted when the read/write mode changes.
+    ///
+    /// You can connect to this signal to know when you can bind a
+    /// QAudioInput and/or QAudioOutput to the call.
+    void openModeChanged(QIODevice::OpenMode);
+
+public slots:
+    void accept();
+    void hangup();
+
+private slots:
+    void datagramReceived(const QByteArray &datagram);
+    void emitSignals();
+    void updateOpenMode();
+    void terminate();
+    void terminated();
+
+protected:
+    qint64 readData(char * data, qint64 maxSize);
+    qint64 writeData(const char * data, qint64 maxSize);
+
+private:
+    QXmppCall(const QString &jid, QXmppCall::Direction direction, QObject *parent);
+    void connectToHost();
+    QList<QXmppJingleCandidate> localCandidates() const;
+    void setPayloadType(const QXmppJinglePayloadType &type);
+    void addRemoteCandidates(const QList<QXmppJingleCandidate> &candidates);
+    void setRemoteUser(const QString &user);
+    void setRemotePassword(const QString &password);
+    void setState(QXmppCall::State state);
+
+    Direction m_direction;
+    QString m_jid;
+    QString m_sid;
+    State m_state;
+    QString m_contentName;
+    QXmppJinglePayloadType m_payloadType;
+
+    QList<QXmppJingleIq> m_requests;
+    QList<QXmppJinglePayloadType> m_commonPayloadTypes;
+
+    // ICE-UDP
+    QXmppStunSocket *m_socket;
+    QXmppStunSocket *m_rtcpSocket;
+
+    // signals
+    bool m_signalsEmitted;
+    qint64 m_writtenSinceLastEmit;
+
+    // RTP
+    bool m_buffered;
+    QXmppCodec *m_codec;
+
+    QByteArray m_incomingBuffer;
+    bool m_incomingBuffering;
+    int m_incomingMinimum;
+    quint16 m_incomingSequence;
+    quint32 m_incomingStamp;
+
+    quint16 m_outgoingChunk;
+    QByteArray m_outgoingBuffer;
+    bool m_outgoingMarker;
+    quint16 m_outgoingSequence;
+    quint32 m_outgoingStamp;
+
+    friend class QXmppCallManager;
+};
+
+/// \brief The QXmppCallManager class provides support for making and
+/// receiving voice calls.
+///
+/// Session initiation is performed as described by XEP-0166: Jingle,
+/// XEP-0167: Jingle RTP Sessions and XEP-0176: Jingle ICE-UDP Transport
+/// Method.
+///
+/// The data stream is connected using Interactive Connectivity Establishment
+/// (RFC 5245) and data is transfered using Real Time Protocol (RFC 3550)
+/// packets.
+///
+/// \note: THIS API IS NOT FINALIZED YET
+
+class QXmppCallManager : public QObject
+{
+    Q_OBJECT
+
+public:
+    QXmppCallManager(QXmppStream *stream, QObject *parent = 0);
+    QXmppCall *call(const QString &jid);
+
+signals:
+    /// This signal is emitted when a new incoming call is received.
+    ///
+    /// To accept the call, invoke the call's QXmppCall::accept() method.
+    /// To refuse the call, invoke the call's QXmppCall::abort() method.
+    void callReceived(QXmppCall *call);
+
+    /// This signal is emitted to send logging messages.
+    void logMessage(QXmppLogger::MessageType type, const QString &msg);
+
+private slots:
+    void callDestroyed(QObject *object);
+    void callStateChanged(QXmppCall::State state);
+    void iqReceived(const QXmppIq &iq);
+    void jingleIqReceived(const QXmppJingleIq &iq);
+
+private:
+    bool checkPayloadTypes(QXmppCall *call, const QList<QXmppJinglePayloadType> &remotePayloadTypes);
+    QXmppCall *findCall(const QString &sid) const;
+    QXmppCall *findCall(const QString &sid, QXmppCall::Direction direction) const;
+    QList<QXmppJinglePayloadType> localPayloadTypes() const;
+    bool sendAck(const QXmppJingleIq &iq);
+    bool sendRequest(QXmppCall *call, const QXmppJingleIq &iq);
+
+    QList<QXmppCall*> m_calls;
+
+    // reference to xmpp stream (no ownership)
+    QXmppStream* m_stream;
+};
+
+#endif