response_send.h

Go to the documentation of this file.

#pragma once
 
#include "fl/stl/json.h"
#include "fl/stl/function.h"
#include "fl/stl/noexcept.h"
 
namespace fl {

class ResponseSend {
public:
    ResponseSend(const fl::json& requestId, fl::function<void(const fl::json&)> sink)
        : mRequestId(requestId), mResponseSink(fl::move(sink)), mIsFinal(false) {}
 
    // Non-copyable but movable
    ResponseSend(const ResponseSend&) FL_NOEXCEPT = delete;
    ResponseSend& operator=(const ResponseSend&) FL_NOEXCEPT = delete;
    ResponseSend(ResponseSend&&) FL_NOEXCEPT = default;
    ResponseSend& operator=(ResponseSend&&) FL_NOEXCEPT = default;

    void send(const fl::json& result) {
        if (!mResponseSink || mIsFinal) {
            return;
        }
 
        fl::json response = fl::json::object();
        response.set("jsonrpc", "2.0");
        response.set("result", result);
        response.set("id", mRequestId);
 
        mResponseSink(response);
    }

    void sendUpdate(const fl::json& update) {
        if (!mResponseSink || mIsFinal) {
            return;
        }
 
        fl::json response = fl::json::object();
        response.set("jsonrpc", "2.0");
 
        fl::json result = fl::json::object();
        result.set("update", update);
 
        response.set("result", result);
        response.set("id", mRequestId);
 
        mResponseSink(response);
    }

    void sendFinal(const fl::json& result) {
        if (!mResponseSink || mIsFinal) {
            return;
        }
 
        mIsFinal = true;
 
        fl::json response = fl::json::object();
        response.set("jsonrpc", "2.0");
 
        fl::json finalResult = fl::json::object();
        finalResult.set("value", result);
        finalResult.set("stop", true);
 
        response.set("result", finalResult);
        response.set("id", mRequestId);
 
        mResponseSink(response);
    }

    bool isFinal() const {
        return mIsFinal;
    }

    const fl::json& requestId() const {
        return mRequestId;
    }
 
private:
    fl::json mRequestId;                          // Request ID from JSON-RPC request
    fl::function<void(const fl::json&)> mResponseSink;  // Function to send responses
    bool mIsFinal;                                // True if sendFinal() was called
};
 
} // namespace fl