examples/futuretimeservice/main.cpp

/*------------------------------------------------------------------------------
    Copyright Butterfly Energy Systems 2022.
    Distributed under the Boost Software License, Version 1.0.
    http://www.boost.org/LICENSE_1_0.txt
------------------------------------------------------------------------------*/
 
//******************************************************************************
// Example WAMP service provider app using std::future.
//******************************************************************************
 
#include <chrono>
#include <ctime>
#include <iostream>
#include <future>
#include <boost/asio/steady_timer.hpp>
#include <boost/asio/use_future.hpp>
#include <cppwamp/json.hpp>
#include <cppwamp/session.hpp>
#include <cppwamp/tcp.hpp>
#include <cppwamp/unpacker.hpp>
#include <cppwamp/variant.hpp>
 
const std::string realm = "cppwamp.demo.time";
const std::string address = "localhost";
const short port = 54321u;
 
//------------------------------------------------------------------------------
namespace wamp
{
    // Convert a std::tm to/from an object variant.
    template <typename TConverter>
    void convert(TConverter& conv, std::tm& t)
    {
        conv ("sec",   t.tm_sec)
             ("min",   t.tm_min)
             ("hour",  t.tm_hour)
             ("mday",  t.tm_mday)
             ("mon",   t.tm_mon)
             ("year",  t.tm_year)
             ("wday",  t.tm_wday)
             ("yday",  t.tm_yday)
             ("isdst", t.tm_isdst);
    }
}
 
//------------------------------------------------------------------------------
std::tm getTime()
{
    auto t = std::time(nullptr);
    return *std::localtime(&t);
}
 
//------------------------------------------------------------------------------
int main()
{
    using namespace wamp;
    using boost::asio::use_future;
 
    // Run the io_context off in its own thread so that it operates
    // completely asynchronously with respect to the rest of the program.
    boost::asio::io_context ioctx;
    auto work = boost::asio::make_work_guard(ioctx);
    std::thread thread([&ioctx](){ ioctx.run(); });
 
    auto tcp = connector<Json>(ioctx, TcpHost(address, port));
    auto session = Session::create(ioctx, tcp);
    boost::asio::steady_timer timer(ioctx);
 
    // get() blocks the main thread until completion.
    // value() throws if there was an error.
    auto index = session->connect(use_future).get().value();
    std::cout << "Connected via " << index << std::endl;
 
    auto info = session->join(Realm(realm), use_future).get().value();
    std::cout << "Joined, SessionId=" << info.id() << std::endl;
 
    auto reg = session->enroll(Procedure("get_time"),
                               simpleRpc<std::tm>(&getTime),
                               use_future).get().value();
    std::cout << "Registered 'get_time', RegistrationId=" << reg.id()
              << std::endl;
 
    auto deadline = std::chrono::steady_clock::now();
    while (true)
    {
        deadline += std::chrono::seconds(1);
        timer.expires_at(deadline);
        timer.async_wait(use_future).get();
 
        auto t = std::time(nullptr);
        const std::tm* local = std::localtime(&t);
        session->publish(Pub("time_tick").withArgs(*local),
                         use_future).get().value();
        std::cout << "Tick: " << std::asctime(local) << "\n";
    }
 
    return 0;
}