available_services.hpp

Go to the documentation of this file.

#ifndef RAPP_CLOUD_AVAILABLE_SERVICES
#define RAPP_CLOUD_AVAILABLE_SERVICES
#include "includes.ihh"
namespace rapp {
namespace cloud {
class available_services : public asio_service_http
{
public:
    available_services(
                        const std::string token,
                        std::function<void(std::vector<std::string>)> callback
                      )
    : asio_service_http(token), delegate_(callback)
    {
        header_ = "GET /hop/available_services HTTP/1.1\r\n";
        callback_ = std::bind(&available_services::handle_reply, this, std::placeholders::_1);
    }
private:
    void handle_reply(std::string json)
    {
        std::stringstream ss(json);
        std::vector<std::string> services;
        try {
            boost::property_tree::ptree tree;
            boost::property_tree::read_json(ss, tree);
            for (auto child : tree.get_child("services")) {
                services.push_back(child.second.get_value<std::string>());
            }
            for (auto child : tree.get_child("error")) {
                const std::string value = child.second.get_value<std::string>();
                if (!value.empty()) {
                    std::cerr << "available_services JSON error: " << value << std::endl;
                }
            }
        }
        catch (boost::property_tree::json_parser::json_parser_error & je) {
            std::cerr << "available_services::handle_reply Error parsing: " << je.filename() 
                      << " on line: " << je.line() << std::endl;
            std::cerr << je.message() << std::endl;
        }
        delegate_(std::move(services));
    }
    std::function<void(std::vector<std::string> services)> delegate_;
};
}
}
#endif