simple_service.cc

Go to the documentation of this file.

/*
 * simple_service.cc
 *
 *  Created on: Aug 23, 2018
 *      Author: N.S. Oblath
 */
 
#define DRIPLINE_EXAMPLES_API_EXPORTS
 
#include "simple_service.hh"
 
#include "dripline_exceptions.hh"
 
#include "logger.hh"
#include "macros.hh"
#include "param.hh"
#include "signal_handler.hh"
 
#include <chrono>
#include <thread>
 
LOGGER( dlog, "simple_service" )
 
namespace dripline
{
 
    simple_service::simple_service( const scarab::param_node& a_config, const scarab::authentication& a_auth ) :
            scarab::cancelable(),
            service( a_config, a_auth ),
            f_return( dl_success().rc_value() )
    {
    }
 
    simple_service::~simple_service()
    {
    }
 
    void simple_service::execute()
    {
        auto t_cwrap = scarab::wrap_cancelable( *this );
        scarab::signal_handler::add_cancelable( t_cwrap );
 
        try
        {
            run();
        }
        catch( std::exception& e )
        {
            LERROR( dlog, "Exception caught: " << e.what() );
            LERROR( dlog, "Exiting service" );
            f_return = dl_service_error().rc_value() / 100;
            scarab::signal_handler::cancel_all( f_return );
        }
 
        if( scarab::signal_handler::get_exited() )
        {
            f_return = scarab::signal_handler::get_return_code();
        }
 
        return;
    }
 
    reply_ptr_t simple_service::do_cmd_request( const request_ptr_t a_request )
    {
        if( a_request->parsed_specifier().empty() )
        {
            return a_request->reply( dl_service_error_invalid_specifier(), "No specifier provided" );
        }
 
        std::string t_specifier = a_request->parsed_specifier().front();
        a_request->parsed_specifier().pop_front();
 
        if( t_specifier == "echo" )
        {
            reply_ptr_t t_reply = a_request->reply( dl_success(), "Echoed payload" );
            LDEBUG( dlog, "Echoing payload: \n" << a_request->payload() );
            t_reply->set_payload( a_request->payload().clone() );
            return t_reply;
        }
        else if( t_specifier == "error" )
        {
            throw std::runtime_error( "An error occurred in the endpoint!  (Note: this is a test, this is only a test)" );
        }
        else
        {
            return a_request->reply( dl_service_error_invalid_specifier(), "Unknown specifier: " + t_specifier );
        }
    }
 
 
 
} /* namespace dripline */