agent-beast-coro.cpp

#include "examples_util.hpp"

#include <banana/api.hpp>
#include <banana/agent/beast.hpp>

#include <boost/asio/co_spawn.hpp>

#ifndef BOOST_ASIO_HAS_CO_AWAIT
#error Coroutine support disabled
#endif

#include <iostream>

static_assert(std::is_same_v<banana::api_result<banana::api::message_t, banana::agent::beast_coro_monadic>, boost::asio::awaitable<banana::expected<banana::api::message_t>>>);
static_assert(std::is_same_v<banana::api_result<banana::api::message_t, banana::agent::beast_coro>, boost::asio::awaitable<banana::api::message_t>>);

int main(int argc, const char** argv) {
    const auto [token, target, name, message_text] = parse_input_or_fail(argc, argv);

    boost::asio::io_context io_context;
    boost::asio::ssl::context ctx(boost::asio::ssl::context::tlsv12_client);

    int result = 0;

    boost::asio::co_spawn(io_context, [&]() -> boost::asio::awaitable<void> {
        banana::agent::beast_coro agent{ token, io_context, ctx };

        std::cout << "bot name: " << (co_await banana::api::get_me(agent)).username.value() << "\n";

        // TODO: workaround for double free bug in gcc-10.2
        banana::api::send_message_args_t args{ .chat_id = target, .text = message_text + " (throwing)" };
        std::cout << "message sent: " << (co_await banana::api::send_message(agent, std::move(args))).message_id << "\n";
        co_return;
    }, [&](std::exception_ptr e) {
        try {
            if (e) {
                std::rethrow_exception(e);
            }
        }
        catch (std::exception& e) {
            std::cout << "exception while running throwing " << name << ": " << e.what() << "\n";
            result = 1;
        }
    });

    boost::asio::co_spawn(io_context, [&]() -> boost::asio::awaitable<void> {
        banana::agent::beast_coro_monadic agent{ token, io_context, ctx };

        std::cout << "bot name: " << (co_await banana::api::get_me(agent)).value().username.value() << "\n";

        // TODO: workaround for double free bug in gcc-10.2
        banana::api::send_message_args_t args{ .chat_id = target, .text = message_text + " (monadic)" };
        std::cout << "message sent: " << (co_await banana::api::send_message(agent, std::move(args))).value().message_id << "\n";
        co_return;
    }, [&](std::exception_ptr e) {
        try {
            if (e) {
                std::rethrow_exception(e);
            }
        }
        catch (std::exception& e) {
            std::cout << "exception while running monadic " << name << ": " << e.what() << "\n";
            result = 1;
        }
    });

    io_context.run();

    return result;
}