func_result.h

Go to the documentation of this file.

#pragma once
#include "webcface/common/val_adaptor_vec.h"
#include "webcface/exception.h"
#include <chrono>
#ifdef WEBCFACE_MESON
#include "webcface-config.h"
#else
#include "webcface/common/webcface-config.h"
#endif
#include <optional>
#include <memory>
#include <functional>
#include "field.h"
#include "webcface/common/val_adaptor.h"
#include "webcface/c_wcf/def_types.h"
 
WEBCFACE_NS_BEGIN
namespace internal {
struct PromiseData;
struct FuncInfo;
struct ClientData;
} // namespace internal
 
class WEBCFACE_DLL Promise : Field {
    std::shared_ptr<internal::PromiseData> data;
 
    static SanityError WEBCFACE_CALL invalidPromise();
 
  public:
    Promise(const Field &base,
            const std::shared_ptr<internal::PromiseData> &data);
 
    using Field::member;
    using Field::name;
    using Field::nameW;
 
  private:
    void waitReachImpl(std::optional<std::chrono::microseconds> timeout) const;
    void waitFinishImpl(std::optional<std::chrono::microseconds> timeout) const;
 
  public:
    bool reached() const;
    bool found() const;
    Promise &waitReach() {
        waitReachImpl(std::nullopt);
        return *this;
    }
    Promise &waitReachFor(std::chrono::microseconds timeout) {
        waitReachImpl(timeout);
        return *this;
    }
    template <typename Clock, typename Duration>
    Promise &waitReachUntil(std::chrono::time_point<Clock, Duration> timeout) {
        waitReachImpl(std::chrono::duration_cast<std::chrono::microseconds>(
            timeout - Clock::now()));
        return *this;
    }
 
    bool finished() const;
    bool isError() const;
    ValAdaptorVector response() const;
    StringView rejection() const;
    WStringView rejectionW() const;
 
    Promise &waitFinish() {
        waitFinishImpl(std::nullopt);
        return *this;
    }
    Promise &waitFinishFor(std::chrono::microseconds timeout) {
        waitFinishImpl(timeout);
        return *this;
    }
    template <typename Clock, typename Duration>
    Promise &waitFinishUntil(std::chrono::time_point<Clock, Duration> timeout) {
        waitFinishImpl(std::chrono::duration_cast<std::chrono::microseconds>(
            timeout - Clock::now()));
        return *this;
    }
 
    Promise &onReach(std::function<void WEBCFACE_CALL_FP(Promise)> callback);
    template <typename F, typename std::enable_if_t<std::is_invocable_v<F>,
                                                    std::nullptr_t> = nullptr>
    Promise &onReach(F callback) {
        return onReach(
            [callback = std::move(callback)](const Promise &) { callback(); });
    }
    Promise &onFinish(std::function<void WEBCFACE_CALL_FP(Promise)> callback);
    template <typename F, typename std::enable_if_t<std::is_invocable_v<F>,
                                                    std::nullptr_t> = nullptr>
    Promise &onFinish(F callback) {
        return onFinish(
            [callback = std::move(callback)](const Promise &) { callback(); });
    }
};
 
using AsyncFuncResult = Promise;
 
class WEBCFACE_DLL CallHandle : Field {
    std::shared_ptr<internal::PromiseData> data;
 
    static SanityError WEBCFACE_CALL invalidHandle();
 
  public:
    CallHandle() = default;
    CallHandle(const Field &base,
               const std::shared_ptr<internal::PromiseData> &data);
 
    friend class Func;
    friend class FuncListener;
    friend struct internal::FuncInfo;
    friend struct internal::ClientData;
 
    using Field::name;
    using Field::nameW;
 
    const std::vector<ValAdaptorVector> &args() const;
    const wcfMultiVal *cArgs() const;
    const wcfMultiValW *cWArgs() const;
 
    void respond(const ValAdaptorVector &value) const;
    void reject(const ValAdaptor &message) const;
    void reach(bool found) const;
 
    bool assertArgsNum(std::size_t expected) const;
 
    template <typename T>
    void respond(const T &value) const {
        respond(ValAdaptorVector(value));
    }
    void respond(StringInitializer value) const {
        respond(ValAdaptorVector(std::move(value)));
    }
    void respond() const { respond(ValAdaptorVector()); }
 
    void reject(StringInitializer message) const {
        reject(ValAdaptor(std::move(message)));
    }
 
    bool respondable() const;
};
using FuncCallHandle = CallHandle;
 
WEBCFACE_NS_END