ServiceBase.hpp

Go to the documentation of this file.

#ifndef _IDENTT_QUERY_SERVICEBASE_HPP_
#define _IDENTT_QUERY_SERVICEBASE_HPP_

#include <fstream>
#include <iomanip>
#include <utils/BaseUtils.hpp>

#define IDENTT_HTTP_CHAR_PERCENT '%'
#define IDENTT_HTTP_CHAR_SPACE ' '
#define IDENTT_HTTP_CHAR_PLUS '+'
#define IDENTT_HTTP_STR_EQUALTO "="
#define IDENTT_HTTP_STR_AMPERSAND "&"

namespace identt {
namespace query {

struct InvalidDataError {
    bool error=false;
    std::string message;
};

template <class HttpServerT>
class ServiceBase {
public:

protected:
    const unsigned int myscope;

    ServiceBase(const unsigned int myscope_) : myscope(myscope_) {}

    void HttpErrorAction(typename HttpServerT::RespPtr response, typename HttpServerT::ReqPtr request,
                         int ec, const char* em)
    {
        std::string output="";
        std::stringstream content_stream;
        content_stream << output;
        content_stream << ec << " " << em << request->method << " " << request->path << " HTTP/" << request->http_version << "";
        content_stream.seekp(0, std::ios::end);
        output = content_stream.str();
        *response <<  "HTTP/" << request->http_version << " " << ec << " " << em;
        *response << "\r\nContent-Length: " << output.length() << "\r\n\r\n" << output.c_str();
        LOG(INFO) << "NOK: " << output;
    }

    void HttpErrorAction(typename HttpServerT::RespPtr response, typename HttpServerT::ReqPtr request,
                         int ec, const char* em, std::string payload)
    {
        *response <<  "HTTP/" << request->http_version << " " << ec << " " << em;
        *response << "\r\nContent-Length: " << payload.length() << "\r\n\r\n" << payload.c_str();
    }

    void HttpOKAction(typename HttpServerT::RespPtr response, typename HttpServerT::ReqPtr request,
                      int ec, const char* em, const char* content_type , std::string& payload, bool add_cors)
    {
        *response << "HTTP/" << request->http_version << " " << ec <<  " " << em << "\r\n";
        if (add_cors) {
            *response << "Access-Control-Allow-Headers: Origin, X-Requested-With, Content-Type, Accept\r\n";
            *response << "Access-Control-Allow-Methods: GET, POST, PUT, DELETE, OPTIONS\r\n";
            *response << "Access-Control-Allow-Origin: *\r\n";
        }
        *response << "Content-Type: " << content_type << "\r\n";
        *response << "Content-Length: " << payload.length() << "\r\n";
        *response << "\r\n" << payload.c_str();
        DLOG(INFO) << "OK: " << payload;
    }

    bool JsonRequest(typename HttpServerT::ReqPtr request)
    {
        auto it=request->header.find("Content-Type");
        if(it==request->header.end()) it=request->header.find("Accept");
        if(it==request->header.end()) return false;
        return ( it->second.compare(0,16,"application/json",16)==0);
    }

};
} // namespace query
} // namespace identt

#endif /* _IDENTT_QUERY_SERVICEBASE_HPP_ */