RequestInterceptor.hpp

/*
 * (c) Copyright, Real-Time Innovations, 2017.
 * All rights reserved.
 *
 * No duplications, whole or partial, manual or electronic, may be made
 * without express written permission.  Any such copies, or
 * revisions thereof, must display this notice unaltered.
 * This code contains trade secrets of Real-Time Innovations, Inc.
 */

#ifndef RTI_SERVICE_REQUEST_INTERCEPTOR_HPP_
#define RTI_SERVICE_REQUEST_INTERCEPTOR_HPP_

#include "routingservice/routingservice_remote_config.h"

#include "rti/service/ServiceException.hpp"
#include "rti/service/log/LogConfig.hpp"

namespace rti { namespace service { namespace admin {

/*
 * @brief string representation of EntityStateKind
 */
inline
const char* to_native_string(const RTI_Service_Admin_CommandActionKind command_kind)
{
    switch (command_kind) {
    case RTI_SERVICE_COMMAND_ACTION_UPDATE:
        return "UPDATE";
    case RTI_SERVICE_COMMAND_ACTION_GET:
        return "GET";
    case RTI_SERVICE_COMMAND_ACTION_CREATE:
        return "CREATE";
    case RTI_SERVICE_COMMAND_ACTION_DELETE:
        return "DELETE";
    default:
        return "";
    }
}

/*
 * @brief string representation of EntityStateKind
 */
inline
const std::string to_string(const RTI_Service_Admin_CommandActionKind command_kind)
{
    switch (command_kind) {
    case RTI_SERVICE_COMMAND_ACTION_UPDATE:
        return "UPDATE";
    case RTI_SERVICE_COMMAND_ACTION_GET:
        return "GET";
    case RTI_SERVICE_COMMAND_ACTION_CREATE:
        return "CREATE";
    case RTI_SERVICE_COMMAND_ACTION_DELETE:
        return "DELETE";
    default:
        std::ostringstream string_stream;
        string_stream << (int) command_kind;
        return string_stream.str();
    }
}

class RequestInterceptor {
public:         

    virtual void on_command(
            const RTI_Service_Admin_CommandRequest& incoming_request,
            const DDS_SampleInfo& request_info,
            RTI_RoutingServiceAdminReplier& replier) = 0;    
    
    virtual ~RequestInterceptor() {}
    
};

class RequestInterceptorForwarder  {
public:
    
    typedef RTI_RoutingServiceConfigInterceptor native;
    
    static native create(RequestInterceptor *interceptor)
    {
        native native_interceptor;
        native_interceptor.on_command_request = on_request_forwarder;
        native_interceptor.interceptor_data = static_cast<void*>(interceptor);
        
        return native_interceptor;        
    }
    
private:    
    static void on_request_forwarder(
            void *interceptor_data,
            const RTI_Service_Admin_CommandRequest *incoming_request,
            const DDS_SampleInfo *request_info,
            RTI_RoutingServiceAdminReplier *replier)
    {
        RequestInterceptor *interceptor = 
                static_cast<RequestInterceptor *>(interceptor_data);
        try {
            interceptor->on_command(*incoming_request, *request_info, *replier); 
        } catch (ServiceException& ex) {
            SERVICELog_fromException(ex);
        } catch (...) {
            SERVICELog_exception(&RTI_LOG_UNEXPECTED_EXCEPTION);
        }
    }        
    
};

}}}


#endif // RTI_SERVICE_REQUEST_INTERCEPTOR_HPP_