From f4d9880d3c9555b48affad727589ef5c093b1841 Mon Sep 17 00:00:00 2001 From: Felix Morgner Date: Fri, 16 Sep 2022 23:28:09 +0200 Subject: source: clean up structure --- source/app/CMakeLists.txt | 43 ++++++++++++++ source/app/src/wandac.cpp | 94 +++++++++++++++++++++++++++++ source/app/src/wandad.cpp | 146 ++++++++++++++++++++++++++++++++++++++++++++++ 3 files changed, 283 insertions(+) create mode 100644 source/app/CMakeLists.txt create mode 100644 source/app/src/wandac.cpp create mode 100644 source/app/src/wandad.cpp (limited to 'source/app') diff --git a/source/app/CMakeLists.txt b/source/app/CMakeLists.txt new file mode 100644 index 0000000..a224b57 --- /dev/null +++ b/source/app/CMakeLists.txt @@ -0,0 +1,43 @@ +include("CheckIPOSupported") + +check_ipo_supported(RESULT "WANDA_IPO_SUPPORTED") + +find_package("lyra") + +#[=====[ Server ]=====] + +add_executable("wandad" + "src/wandad.cpp" +) + +target_link_libraries("wandad" PRIVATE + "bfg::lyra" + "wanda::wanda" +) + +set_target_properties("wandad" PROPERTIES + CXX_STANDARD_REQUIRED YES + CXX_EXTENSIONS OFF + INTERPROCEDURAL_OPTIMIZATION ${WANDA_IPO_SUPPORTED} +) + +install(TARGETS "wandad") + +#[=====[ Client ]=====] + +add_executable("wandac" + "src/wandac.cpp" +) + +target_link_libraries("${PROJECT_NAME}c" PRIVATE + "bfg::lyra" + "wanda::wanda" +) + +set_target_properties("wandac" PROPERTIES + CXX_STANDARD_REQUIRED YES + CXX_EXTENSIONS OFF + INTERPROCEDURAL_OPTIMIZATION ${WANDA_IPO_SUPPORTED} +) + +install(TARGETS "wandac") \ No newline at end of file diff --git a/source/app/src/wandac.cpp b/source/app/src/wandac.cpp new file mode 100644 index 0000000..1873ef4 --- /dev/null +++ b/source/app/src/wandac.cpp @@ -0,0 +1,94 @@ +#include +#include +#include +#include +#include + +#include +#include +#include +#include + +#include +#include +#include +#include + +struct cli +{ + std::string command{}; + bool help{}; + + lyra::cli_parser parser{}; + + auto parse(int argc, char const * const * argv, std::ostream & error) + { + parser |= lyra::arg{command, "command"}("The command to send to the deamon").required() | + lyra::help(help); + + auto result = parser.parse({argc, argv}); + + if (!result) + { + error << "Error while processing command line arguments: " + << result.message() + << '\n' + << parser + << '\n'; + return false; + } + + return true; + } +}; + +struct listener : wanda::commander::listener +{ + listener(::cli & cli, asio::io_service & service) + : m_cli{cli} + , m_service{service} + { + } + + void on_connected(wanda::commander & commander) override + { + if (m_cli.command == "change") + { + commander.send(wanda::make_change_command()); + m_service.post([&]{ + commander.stop(); + }); + } + } + +private: + ::cli & m_cli; + asio::io_service & m_service; +}; + +int main(int argc, char const * const * argv) +{ + auto cli = ::cli{}; + if (!cli.parse(argc, argv, std::cerr)) + { + return EXIT_FAILURE; + } + else if (cli.help) + { + std::cout << cli.parser << '\n'; + return EXIT_SUCCESS; + } + + wanda::initialize_logger(std::make_shared()); + + auto interface = wanda::xdg_path_for(wanda::xdg_directory::runtime_dir, wanda::environment{}) / ".wanda_interface"; + auto service = asio::io_service{}; + auto listener = ::listener{cli, service}; + + auto commander = wanda::commander{service, interface, listener}; + + wanda::get_logger()->info("trying to connect to wanda control interface on '{}'", interface.native()); + commander.start(); + + service.run(); +} diff --git a/source/app/src/wandad.cpp b/source/app/src/wandad.cpp new file mode 100644 index 0000000..8579a83 --- /dev/null +++ b/source/app/src/wandad.cpp @@ -0,0 +1,146 @@ +#include +#include +#include +#include +#include +#include +#include +#include +#include + +#include +#include +#include + +#include +#include +#include +#include +#include + +namespace +{ + constexpr auto image_filter = [](auto const & path) { + static auto const extensions = std::set{ + std::filesystem::path{".jpg"}, + std::filesystem::path{".png"}, + }; + + if (!std::filesystem::is_regular_file(path)) + { + return false; + } + + return extensions.find(path.extension()) != extensions.cend(); + }; + + struct cli + { + std::string wallpaper_directory{}; + bool help{}; + + lyra::cli_parser parser{}; + + auto parse(int argc, char const * const * argv, std::ostream & error) + { + parser |= lyra::arg{wallpaper_directory, "directory"}("The wallpaper source directory").required() | + lyra::help(help); + + auto result = parser.parse({argc, argv}); + + if (!result) + { + error << "Error while processing command line arguments: " + << result.message() + << '\n' + << parser + << '\n'; + return false; + } + + return true; + } + }; + + struct listener : wanda::control_interface::listener + { + listener(std::vector const & wallpapers) + : m_wallpapers{wallpapers} + { + } + + void on_received(wanda::control_interface & interface, wanda::command command) override + { + switch (command.id) + { + case wanda::command_id::change: { + auto wallpaper = wanda::random_pick(m_wallpapers); + wanda::get_logger()->info("changing wallpaper to '{}'", wallpaper.native()); + wanda::set_wallpaper(wallpaper); + break; + } + default: + wanda::get_logger()->error("received unknown command '{}'", static_cast(command.id)); + } + } + + private: + std::vector const & m_wallpapers; + }; + +} // namespace + +int main(int argc, char const * const * argv) +{ + using namespace wanda::std_ext; + + auto cli = ::cli{}; + if (!cli.parse(argc, argv, std::cerr)) + { + return EXIT_FAILURE; + } + else if (cli.help) + { + std::cout << cli.parser << '\n'; + return EXIT_SUCCESS; + } + + wanda::initialize_logger(std::make_shared()); + wanda::get_logger()->info("wanda is starting up"); + + with(wanda::scan({cli.wallpaper_directory}, image_filter), [&](auto const & list) { + auto service = asio::io_service{}; + auto socket_path = wanda::xdg_path_for(wanda::xdg_directory::runtime_dir, wanda::environment{}) / ".wanda_interface"; + + wanda::get_logger()->info("starting control interface on '{}'", socket_path.native()); + auto listener = ::listener{list}; + auto interface = wanda::make_interface(service, socket_path, listener); + + if (!interface) + { + wanda::get_logger()->error("failed to start control interface"); + return; + } + + if (interface->start()) + { + return; + } + + auto signals = asio::signal_set{service, SIGINT, SIGTERM}; + signals.async_wait([&](auto const & error, auto const signal) { + if (!error) + { + wanda::get_logger()->info("Received signal {}. terminating...", signal); + interface->shutdown(); + service.stop(); + } + }); + + auto wallpaper = wanda::random_pick(list); + wanda::set_wallpaper(wallpaper); + + service.run(); + }) || + [&] { wanda::get_logger()->error("wallpaper directory does not exist"); }; +} -- cgit v1.2.3