qtpromise/tests/auto/qtpromise/qpromise/tst_construct.cpp

/*
 * Copyright (c) Simon Brunel, https://github.com/simonbrunel
 *
 * This source code is licensed under the MIT license found in
 * the LICENSE file in the root directory of this source tree.
 */

#include "../shared/utils.h"

#include <QtPromise>
#include <QtTest>

#include <memory>

class tst_qpromise_construct : public QObject
{
    Q_OBJECT

private Q_SLOTS:
    void resolveSyncOneArg();
    void resolveSyncOneArg_void();
    void resolveSyncTwoArgs();
    void resolveSyncTwoArgs_void();
    void resolveAsyncOneArg();
    void resolveAsyncOneArg_void();
    void resolveAsyncTwoArgs();
    void resolveAsyncTwoArgs_void();
    void rejectThrowOneArg();
    void rejectThrowOneArg_void();
    void rejectThrowTwoArgs();
    void rejectThrowTwoArgs_void();
    void rejectSync();
    void rejectSync_void();
    void rejectAsync();
    void rejectAsync_void();
    void rejectUndefined();
    void rejectUndefined_void();
    void connectAndResolve();
    void connectAndReject();
};

QTEST_MAIN(tst_qpromise_construct)
#include "tst_construct.moc"

void tst_qpromise_construct::resolveSyncOneArg()
{
    QtPromise::QPromise<int> p{[](const QtPromise::QPromiseResolve<int>& resolve) {
        resolve(42);
    }};

    QCOMPARE(p.isFulfilled(), true);
    QCOMPARE(waitForError(p, QString{}), QString{});
    QCOMPARE(waitForValue(p, -1), 42);
}

void tst_qpromise_construct::resolveSyncOneArg_void()
{
    QtPromise::QPromise<void> p{[](const QtPromise::QPromiseResolve<void>& resolve) {
        resolve();
    }};

    QCOMPARE(p.isFulfilled(), true);
    QCOMPARE(waitForError(p, QString{}), QString{});
    QCOMPARE(waitForValue(p, -1, 42), 42);
}

void tst_qpromise_construct::resolveSyncTwoArgs()
{
    QtPromise::QPromise<int> p{
        [](const QtPromise::QPromiseResolve<int>& resolve, const QtPromise::QPromiseReject<int>&) {
            resolve(42);
        }};

    QCOMPARE(p.isFulfilled(), true);
    QCOMPARE(waitForError(p, QString{}), QString{});
    QCOMPARE(waitForValue(p, -1), 42);
}

void tst_qpromise_construct::resolveSyncTwoArgs_void()
{
    QtPromise::QPromise<void> p{[](const QtPromise::QPromiseResolve<void>& resolve,
                                   const QtPromise::QPromiseReject<void>&) {
        resolve();
    }};

    QCOMPARE(p.isFulfilled(), true);
    QCOMPARE(waitForError(p, QString{}), QString{});
    QCOMPARE(waitForValue(p, -1, 42), 42);
}

void tst_qpromise_construct::resolveAsyncOneArg()
{
    QtPromise::QPromise<int> p{[](const QtPromise::QPromiseResolve<int>& resolve) {
        QtPromisePrivate::qtpromise_defer([=]() {
            resolve(42);
        });
    }};

    QCOMPARE(p.isPending(), true);
    QCOMPARE(waitForError(p, QString{}), QString{});
    QCOMPARE(waitForValue(p, -1), 42);
    QCOMPARE(p.isFulfilled(), true);
}

void tst_qpromise_construct::resolveAsyncOneArg_void()
{
    QtPromise::QPromise<void> p{[](const QtPromise::QPromiseResolve<void>& resolve) {
        QtPromisePrivate::qtpromise_defer([=]() {
            resolve();
        });
    }};

    QCOMPARE(p.isPending(), true);
    QCOMPARE(waitForError(p, QString{}), QString{});
    QCOMPARE(waitForValue(p, -1, 42), 42);
    QCOMPARE(p.isFulfilled(), true);
}

void tst_qpromise_construct::resolveAsyncTwoArgs()
{
    QtPromise::QPromise<int> p{
        [](const QtPromise::QPromiseResolve<int>& resolve, const QtPromise::QPromiseReject<int>&) {
            QtPromisePrivate::qtpromise_defer([=]() {
                resolve(42);
            });
        }};

    QCOMPARE(p.isPending(), true);
    QCOMPARE(waitForError(p, QString{}), QString{});
    QCOMPARE(waitForValue(p, -1), 42);
    QCOMPARE(p.isFulfilled(), true);
}

void tst_qpromise_construct::resolveAsyncTwoArgs_void()
{
    QtPromise::QPromise<void> p{[](const QtPromise::QPromiseResolve<void>& resolve,
                                   const QtPromise::QPromiseReject<void>&) {
        QtPromisePrivate::qtpromise_defer([=]() {
            resolve();
        });
    }};

    QCOMPARE(p.isPending(), true);
    QCOMPARE(waitForError(p, QString{}), QString{});
    QCOMPARE(waitForValue(p, -1, 42), 42);
    QCOMPARE(p.isFulfilled(), true);
}

void tst_qpromise_construct::rejectSync()
{
    QtPromise::QPromise<int> p{
        [](const QtPromise::QPromiseResolve<int>&, const QtPromise::QPromiseReject<int>& reject) {
            reject(QString{"foo"});
        }};

    QCOMPARE(p.isRejected(), true);
    QCOMPARE(waitForValue(p, -1), -1);
    QCOMPARE(waitForError(p, QString{}), QString{"foo"});
}

void tst_qpromise_construct::rejectSync_void()
{
    QtPromise::QPromise<void> p{
        [](const QtPromise::QPromiseResolve<void>&, const QtPromise::QPromiseReject<void>& reject) {
            reject(QString{"foo"});
        }};

    QCOMPARE(p.isRejected(), true);
    QCOMPARE(waitForValue(p, -1, 42), -1);
    QCOMPARE(waitForError(p, QString{}), QString{"foo"});
}

void tst_qpromise_construct::rejectAsync()
{
    QtPromise::QPromise<int> p{
        [](const QtPromise::QPromiseResolve<int>&, const QtPromise::QPromiseReject<int>& reject) {
            QtPromisePrivate::qtpromise_defer([=]() {
                reject(QString{"foo"});
            });
        }};

    QCOMPARE(p.isPending(), true);
    QCOMPARE(waitForValue(p, -1), -1);
    QCOMPARE(waitForError(p, QString{}), QString{"foo"});
    QCOMPARE(p.isRejected(), true);
}

void tst_qpromise_construct::rejectAsync_void()
{
    QtPromise::QPromise<void> p{
        [](const QtPromise::QPromiseResolve<void>&, const QtPromise::QPromiseReject<void>& reject) {
            QtPromisePrivate::qtpromise_defer([=]() {
                reject(QString{"foo"});
            });
        }};

    QCOMPARE(p.isPending(), true);
    QCOMPARE(waitForValue(p, -1, 42), -1);
    QCOMPARE(waitForError(p, QString{}), QString{"foo"});
    QCOMPARE(p.isRejected(), true);
}

void tst_qpromise_construct::rejectThrowOneArg()
{
    QtPromise::QPromise<int> p{[](const QtPromise::QPromiseResolve<int>&) {
        throw QString{"foo"};
    }};

    QCOMPARE(p.isRejected(), true);
    QCOMPARE(waitForValue(p, -1), -1);
    QCOMPARE(waitForError(p, QString{}), QString{"foo"});
}

void tst_qpromise_construct::rejectThrowOneArg_void()
{
    QtPromise::QPromise<void> p{[](const QtPromise::QPromiseResolve<void>&) {
        throw QString{"foo"};
    }};

    QCOMPARE(p.isRejected(), true);
    QCOMPARE(waitForValue(p, -1, 42), -1);
    QCOMPARE(waitForError(p, QString{}), QString{"foo"});
}

void tst_qpromise_construct::rejectThrowTwoArgs()
{
    QtPromise::QPromise<int> p{
        [](const QtPromise::QPromiseResolve<int>&, const QtPromise::QPromiseReject<int>&) {
            throw QString{"foo"};
        }};

    QCOMPARE(p.isRejected(), true);
    QCOMPARE(waitForValue(p, -1), -1);
    QCOMPARE(waitForError(p, QString{}), QString{"foo"});
}

void tst_qpromise_construct::rejectThrowTwoArgs_void()
{
    QtPromise::QPromise<void> p{
        [](const QtPromise::QPromiseResolve<void>&, const QtPromise::QPromiseReject<void>&) {
            throw QString{"foo"};
        }};

    QCOMPARE(p.isRejected(), true);
    QCOMPARE(waitForValue(p, -1, 42), -1);
    QCOMPARE(waitForError(p, QString{}), QString{"foo"});
}

void tst_qpromise_construct::rejectUndefined()
{
    QtPromise::QPromise<int> p{
        [](const QtPromise::QPromiseResolve<int>&, const QtPromise::QPromiseReject<int>& reject) {
            QtPromisePrivate::qtpromise_defer([=]() {
                reject();
            });
        }};

    QCOMPARE(p.isPending(), true);
    QCOMPARE(waitForRejected<QtPromise::QPromiseUndefinedException>(p), true);
}

void tst_qpromise_construct::rejectUndefined_void()
{
    QtPromise::QPromise<void> p{
        [](const QtPromise::QPromiseResolve<void>&, const QtPromise::QPromiseReject<void>& reject) {
            QtPromisePrivate::qtpromise_defer([=]() {
                reject();
            });
        }};

    QCOMPARE(p.isPending(), true);
    QCOMPARE(waitForRejected<QtPromise::QPromiseUndefinedException>(p), true);
}

// https://github.com/simonbrunel/qtpromise/issues/6
void tst_qpromise_construct::connectAndResolve()
{
    QScopedPointer<QObject> object(new QObject{});

    std::weak_ptr<int> wptr;

    {
        auto p = QtPromise::QPromise<std::shared_ptr<int>>{
            [&](const QtPromise::QPromiseResolve<std::shared_ptr<int>>& resolve,
                const QtPromise::QPromiseReject<std::shared_ptr<int>>& reject) {
                connect(object.data(),
                        &QObject::objectNameChanged,
                        [=, &wptr](const QString& name) {
                            auto sptr = std::make_shared<int>(42);

                            wptr = sptr;

                            if (name == "foobar") {
                                resolve(sptr);
                            } else {
                                reject(42);
                            }
                        });
            }};

        QCOMPARE(p.isPending(), true);

        object->setObjectName("foobar");

        QCOMPARE(waitForValue(p, std::shared_ptr<int>{}), wptr.lock());
        QCOMPARE(wptr.use_count(), 1l); // "p" still holds a reference
    }

    QCOMPARE(wptr.use_count(), 0l);
}

// https://github.com/simonbrunel/qtpromise/issues/6
void tst_qpromise_construct::connectAndReject()
{
    QScopedPointer<QObject> object(new QObject{});

    std::weak_ptr<int> wptr;

    {
        auto p = QtPromise::QPromise<int>{[&](const QtPromise::QPromiseResolve<int>& resolve,
                                              const QtPromise::QPromiseReject<int>& reject) {
            connect(object.data(), &QObject::objectNameChanged, [=, &wptr](const QString& name) {
                auto sptr = std::make_shared<int>(42);

                wptr = sptr;

                if (name == "foobar") {
                    reject(sptr);
                } else {
                    resolve(42);
                }
            });
        }};

        QCOMPARE(p.isPending(), true);

        object->setObjectName("foobar");

        QCOMPARE(waitForError(p, std::shared_ptr<int>{}), wptr.lock());
        QCOMPARE(wptr.use_count(), 1l); // "p" still holds a reference
    }

    QCOMPARE(wptr.use_count(), 0l);
}