server.h

Go to the documentation of this file.

#pragma once
 
#include "fl/stl/json.h"
#include "fl/stl/function.h"
#include "fl/stl/optional.h"
#include "fl/stl/vector.h"
#include "fl/stl/noexcept.h"
#include "fl/remote/rpc/response_stream.h"
#include "fl/system/sketch_macros.h"
 
namespace fl {

class Server {
public:
    using RequestSource = fl::function<fl::optional<fl::json>()>;
    using ResponseSink = fl::function<void(const fl::json&)>;
    using RequestHandler = fl::function<fl::json(const fl::json&)>;

    Server() FL_NO_EXCEPT;

    Server(RequestSource source, ResponseSink sink) FL_NO_EXCEPT;
 
    virtual ~Server() FL_NO_EXCEPT = default;
 
    // Non-copyable but movable
    Server(const Server&) FL_NO_EXCEPT = delete;
    Server& operator=(const Server&) FL_NO_EXCEPT = delete;
    Server(Server&&) FL_NO_EXCEPT = default;
    Server& operator=(Server&&) FL_NO_EXCEPT = default;

    void setRequestHandler(RequestHandler handler) FL_NO_EXCEPT;

    void setRequestSource(RequestSource source) FL_NO_EXCEPT;

    void setResponseSink(ResponseSink sink) FL_NO_EXCEPT;

    void setResponseStreamSink(ResponseStreamSink sink) FL_NO_EXCEPT;

    size_t update() FL_NO_EXCEPT;

    size_t pull() FL_NO_EXCEPT;

    size_t push() FL_NO_EXCEPT;
 
protected:
    RequestSource mRequestSource;
    ResponseSink mResponseSink;
    RequestHandler mRequestHandler;
#if FL_PLATFORM_HAS_LARGE_MEMORY
    ResponseStreamSink mResponseStreamSink;
#endif
    fl::vector<fl::json> mOutgoingQueue;
};
 
} // namespace fl