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 *receiveRtp = nullptr;
    GstElement *receiveRtcp = nullptr;
    GstElement *sendRtp = nullptr;
    GstElement *sendRtcp = 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