QXmppCallStream_p.h

// SPDX-FileCopyrightText: 2019 Niels Ole Salscheider <ole@salscheider.org>
// SPDX-FileCopyrightText: 2025 Linus Jahn <lnj@kaidan.im>
//
// SPDX-License-Identifier: LGPL-2.1-or-later
 
#ifndef QXMPPCALLSTREAM_P_H
#define QXMPPCALLSTREAM_P_H
 
#include "QXmppCall_p.h"
#include "QXmppJingleIq.h"
 
#include <gst/gst.h>
 
#include <QList>
#include <QObject>
#include <QString>
 
class QXmppIceConnection;
 
//
//  W A R N I N G
//  -------------
//
// This file is not part of the QXmpp API.
// This header file may change from version to version without notice,
// or even be removed.
//
// We mean it.
//
 
static const int RTP_COMPONENT = 1;
static const int RTCP_COMPONENT = 2;
 
constexpr QStringView AUDIO_MEDIA = u"audio";
constexpr QStringView VIDEO_MEDIA = u"video";
 
namespace QXmpp::Private {
 
enum DtlsClientSetup {
    Actpass,
    Active,
    Passive,
};
}
 
class QXmppCallStreamPrivate : public QObject
{
    Q_OBJECT
 
public:
    QXmppCallStreamPrivate(QXmppCallStream *parent, GstElement *pipeline_, GstElement *rtpBin_,
                           QString media_, QString creator_, QString name_, int id_, bool useDtls_);
    ~QXmppCallStreamPrivate();
 
    GstFlowReturn sendDatagram(GstElement *appsink, int component);
    void datagramReceived(const QByteArray &datagram, GstElement *appsrc);
 
    void addEncoder(QXmppCallPrivate::GstCodec &codec);
    void addDecoder(GstPad *pad, QXmppCallPrivate::GstCodec &codec);
    bool isDtlsClient() const;
    void enableDtlsClientMode();
    void onDtlsConnectionStateChanged(QXmpp::Private::GstDtlsConnectionState);
    void onPeerCertificateReceived(QXmpp::Private::GCharPtr pem);
 
    Q_SIGNAL void peerCertificateReceived(bool fingerprintMatches);
 
    bool sendPadCbReady() const { return sendPadCB && sendPad && (dtlsHandshakeComplete || !useDtls); }
    bool receivePadCbReady() const { return receivePadCB && receivePad && (dtlsHandshakeComplete || !useDtls); }
 
    QXmppCallStream *q;
 
    quint32 localSsrc;
 
    GstElement *pipeline = nullptr;
    GstElement *rtpBin = nullptr;
    GstPad *sendPad = nullptr;
    GstPad *receivePad = nullptr;
    GstElement *encoderBin = nullptr;
    GstElement *decoderBin = nullptr;
    GstElement *iceReceiveBin = nullptr;
    GstElement *iceSendBin = nullptr;
    GstElement *appRtpSrc = nullptr;
    GstElement *appRtcpSrc = nullptr;
    GstElement *appRtpSink = nullptr;
    GstElement *appRtcpSink = nullptr;
    // DTLS-SRTP
    GstElement *dtlsSrtpEncoder = nullptr;
    GstElement *dtlsSrtcpEncoder = nullptr;
    GstElement *dtlsSrtpDecoder = nullptr;
    GstElement *dtlsSrtcpDecoder = nullptr;
 
    std::function<void(GstPad *)> sendPadCB;
    std::function<void(GstPad *)> receivePadCB;
 
    QXmppIceConnection *connection;
    QString media;
    QString creator;
    QString name;
    int id;
 
    bool useDtls;
    // DTLS setup mode received from the other peer
    std::optional<QXmpp::Private::DtlsClientSetup> dtlsPeerSetup;
    QByteArray ownCertificateDigest;
    QByteArray peerCertificateDigest;
    QByteArray expectedPeerCertificateDigest;
    bool dtlsHandshakeComplete = false;
 
    QList<QXmppJinglePayloadType> payloadTypes;
};
 
#endif