Response.h

Go to the documentation of this file.

//
// Copyright (c) 2002-2026 WEINZIERL ENGINEERING GmbH
// All rights reserved.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE, TITLE AND NON-INFRINGEMENT. IN NO EVENT
// SHALL THE COPYRIGHT HOLDERS BE LIABLE FOR ANY DAMAGES OR OTHER LIABILITY,
// WHETHER IN CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
// WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE
//
 
#ifndef __BAOSLIB_BAOSRESPONSE_H__
#define __BAOSLIB_BAOSRESPONSE_H__
 
#include "baos/Exception.h"
#include "baos/protocol/Defines.h"
 
#include <future>
#include <memory>
#include <sstream>
 
namespace wz::baos::protocol
{
 
struct BaseResponse
{
    using SPtr = std::shared_ptr<BaseResponse>;  
    BaseResponse()          = default;
    virtual ~BaseResponse() = default;
};
 
 
struct BaosBaseResponse : public BaseResponse
{
    using SPtr =
        std::shared_ptr<BaosBaseResponse>;  
 
    BaosBaseResponse() = default;
 
    BaosBaseResponse(protocol::BaosResponseCode code_) : code{code_} {};
    virtual ~BaosBaseResponse() = default;
 
    protocol::BaosResponseCode code{protocol::BaosResponseCode::Success};  
};
 
 
template<class T>
struct BaosResponse : public BaosBaseResponse
{
    BaosResponse() = default;
    BaosResponse(protocol::BaosResponseCode code_, T&& items) : BaosBaseResponse(code_), payload_{std::move(items)} {};
 
    virtual ~BaosResponse() = default;
    using SPtr = std::shared_ptr<BaosResponse>;  
 
    T getPayload()
    {
        return payload_;
    }  // getter
 
    void setPayload(T&& value)
    {
        payload_ = std::move(value);
    }  // setter
private:
    T payload_;
};
 
 
using ResponsePromise = std::promise<BaseResponse::SPtr>;  
using ResponseFuture = std::future<BaseResponse::SPtr>;  
 
 
template<class T>
T waitAndHandleBaosResponse(ResponseFuture&& fut)
{
    auto ownedFuture = std::move(fut);
    const auto response = ownedFuture.get();  // Wait for the response to become ready
    auto responseBaos   = std::dynamic_pointer_cast<BaosBaseResponse>(
        response);  // get the value from the future and cast it to the base type
    if (responseBaos->code == protocol::BaosResponseCode::NoItemFound)
    {
        return T();  // Return empty result
    }
    else if (responseBaos->code != protocol::BaosResponseCode::Success)
    {
        std::ostringstream oss;
        oss << "Error response from BAOS " << protocol::baosResponseCodeToString(responseBaos->code);
        throw wz::baos::WzResponseException(WZ_SL, oss.str().c_str(), static_cast<std::uint32_t>(responseBaos->code));
    }
    else
    {
        auto responseDerived = std::dynamic_pointer_cast<BaosResponse<T>>(
            response);  // get the value from the future and cast it to the actual type
        return responseDerived->getPayload();
    }
}
 
BAOSLIB_EXPORT void waitAndHandleEmptyBaosResponse(ResponseFuture&& fut);
 
}  // namespace wz::baos::protocol
 
#endif