squawk/qomemo/qxmpp_omemo_manager.cpp

/*
 * Created by victoria on 2021-05-12.
 */

#include "qxmpp_omemo_manager.h"

#include "device.h"
#include "variant/conversations.h"

#include <QDomElement>

#include <QXmppClient.h>
#include <QXmppPubSubIq.h>
#include <iostream>

using namespace QXmpp::Omemo;

Manager::Manager()
        : deviceService(new DeviceService(this)),
          omemoVariant(new Variant::Conversations) {
    connect(this, &Manager::deviceListReceived, deviceService.get(), &DeviceService::onDeviceListReceived);
}

bool QXmpp::Omemo::Manager::handleStanza(const QDomElement &stanza) {
    QString str{};
    QTextStream info(&str);
    stanza.save(info, 4);

    std::cout << str.toStdString();

    if (stanza.tagName() == "iq") {
        if (stanza.attribute("type") == "result") {
            auto pubsub = stanza.firstChildElement("pubsub");
            if (!pubsub.isNull()) {
                auto items = pubsub.firstChildElement("items");
                if (items.attribute("node") ==
                    "eu.siacs.conversations.axolotl.devicelist") {
                    auto item = items.firstChildElement("item");
                    if (!item.isNull()) {
                        auto list = item.firstChildElement("list");
                        if (!list.isNull()) {
                            DeviceList deviceList = omemoVariant->deviceListFromXml(list);
                            emit deviceListReceived(stanza.attribute("from"), deviceList);

                            return true;
                        }
                    }
                }
            }
        }
    }

    return false;
}

void QXmpp::Omemo::Manager::setClient(QXmppClient *client) {
    QXmppClientExtension::setClient(client);

    if (!client)
        return;

    QObject::connect(client, &QXmppClient::connected, this,
                     &Manager::fetchOwnDevices);
}

void QXmpp::Omemo::Manager::fetchOwnDevices() {
    QXmppPubSubIq iq{};
    iq.setFrom(client()->configuration().jid());
    iq.setTo(client()->configuration().jidBare());
    iq.setType(QXmppIq::Get);
    iq.setQueryNode("eu.siacs.conversations.axolotl.devicelist");

    client()->sendPacket(iq);
}