response_aware_binding.h

Go to the documentation of this file.

#pragma once
 
#include "fl/stl/json.h"
#include "fl/stl/function.h"
#include "fl/stl/tuple.h"
#include "fl/remote/rpc/response_send.h"
#include "fl/remote/rpc/type_conversion_result.h"
#include "fl/remote/rpc/typed_rpc_binding.h"
#include "fl/remote/rpc/rpc_invokers.h"
 
namespace fl {
namespace detail {
 
// =============================================================================
// ResponseAwareInvoker - Invokes response-aware functions (with ResponseSend&)
// =============================================================================

 
// Forward declaration
template<typename Sig>
class ResponseAwareInvoker;
 
// Specialization for non-void return types
template<typename R, typename... Args>
class ResponseAwareInvoker<R(Args...)> : public ErasedInvoker {
public:
    ResponseAwareInvoker(fl::function<R(ResponseSend&, Args...)> fn,
                        const fl::json& requestId,
                        fl::function<void(const fl::json&)> responseSink)
        : mFn(fl::move(fn)), mRequestId(requestId), mResponseSink(fl::move(responseSink)) {}
 
    fl::tuple<TypeConversionResult, json> invoke(const json& args) override {
        // Create ResponseSend instance
        ResponseSend responseSend(mRequestId, mResponseSink);
 
        // Use TypedRpcBinding to convert JSON params to C++ args (without ResponseSend&)
        TypedRpcBinding<R(Args...)> binding([this, &responseSend](Args... cppArgs) -> R {
            // Invoke user function with ResponseSend& + converted args
            return mFn(responseSend, fl::forward<Args>(cppArgs)...);
        });
 
        return binding.invokeWithReturn(args);
    }
 
private:
    fl::function<R(ResponseSend&, Args...)> mFn;
    fl::json mRequestId;
    fl::function<void(const fl::json&)> mResponseSink;
};
 
// Specialization for void return type
template<typename... Args>
class ResponseAwareInvoker<void(Args...)> : public ErasedInvoker {
public:
    ResponseAwareInvoker(fl::function<void(ResponseSend&, Args...)> fn,
                        const fl::json& requestId,
                        fl::function<void(const fl::json&)> responseSink)
        : mFn(fl::move(fn)), mRequestId(requestId), mResponseSink(fl::move(responseSink)) {}
 
    fl::tuple<TypeConversionResult, json> invoke(const json& args) override {
        // Create ResponseSend instance
        ResponseSend responseSend(mRequestId, mResponseSink);
 
        // Use TypedRpcBinding to convert JSON params to C++ args (without ResponseSend&)
        TypedRpcBinding<void(Args...)> binding([this, &responseSend](Args... cppArgs) -> void {
            // Invoke user function with ResponseSend& + converted args
            mFn(responseSend, fl::forward<Args>(cppArgs)...);
        });
 
        TypeConversionResult result = binding.invoke(args);
        return fl::make_tuple(result, json(nullptr));
    }
 
private:
    fl::function<void(ResponseSend&, Args...)> mFn;
    fl::json mRequestId;
    fl::function<void(const fl::json&)> mResponseSink;
};
 
} // namespace detail
} // namespace fl