File indexing completed on 2025-03-09 05:01:39

 /*
     SPDX-FileCopyrightText: 2018 Ivan Čukić <ivan.cukic(at)kde.org>
 
     SPDX-License-Identifier: LGPL-2.1-only OR LGPL-3.0-only OR LicenseRef-KDE-Accepted-LGPL
 */
 
 #include <iostream>
 
 #include <voy/operations/merge.h>
 #include <voy/operations/slice.h>
 #include <voy/operations/transform.h>
 #include <voy/operations/filter.h>
 #include <voy/operations/identity.h>
 
 #include <voy/basic/delayed.h>
 #include <voy/basic/values.h>
 #include <voy/basic/sink.h>
 
 #include <voy/wrappers/process.h>
 #include <voy/wrappers/tcp_service.h>
 #include <voy/wrappers/zmq_service.h>
 
 #include <voy/engine/event_loop.h>
 
 #include <voy/dsl.h>
 
 
 int main(int argc, char *argv[])
 {
     auto cout = [] (auto&& value) {
         std::cout << "Out: " << voy_fwd(value) << std::endl;
     };
 
     using voy::dsl::operator|;
     using namespace std::literals::string_literals;
     using namespace std::literals::chrono_literals;
 
 // #define VALUES_TEST
 #ifdef VALUES_TEST
     auto pipeline_values =
         voy::values{42, 6} | voy::sink{cout};
 #endif
 
 // #define PROCESS_TEST
 #ifdef PROCESS_TEST
     auto pipeline_process =
         voy::system_cmd("task"s) | voy::sink{cout};
 #endif
 
 // #define DELAYED_TEST
 #ifdef DELAYED_TEST
     auto pipeline_delayed =
         voy::delayed(5s, "I'm finally here"s) | voy::sink{cout};
 #endif
 
 // #define FILTER_TEST
 #ifdef FILTER_TEST
     auto pipeline_filter =
         voy::system_cmd("task"s)
         | voy::transform([] (std::string in) {
                 std::transform(std::begin(in), std::end(in),
                                std::begin(in), toupper);
                 return in;
             })
         | voy::sink{cout};
 #endif
 
 // #define DELAYED_VALS_TEST
 #ifdef DELAYED_VALS_TEST
     auto pipeline_delayed_values =
         voy::delayed_values(2s, {"I'm running late"s, "sorry..."s})
         | voy::filter([] (const auto& s) {
                 return isupper(s[0]);
             })
         | voy::sink{cout};
 #endif
 
 // #define SLICE_TEST
 #ifdef SLICE_TEST
     auto pipeline_slice =
         voy::system_cmd("ping"s, "1.1.1.1"s)
         | voy::slice(1,3)
         | voy::sink{cout};
 #endif
 
 // #define MERGE_TEST
 #ifdef MERGE_TEST
     auto pipeline_merge =
         voy::merge(
             voy::system_cmd("task"s)
             | voy::transform([] (std::string in) {
                     std::transform(std::begin(in), std::end(in),
                                    std::begin(in), toupper);
                     return in;
                 })
             ,
 
             voy::delayed_values(2s, {"I'm running late"s, "sorry..."s})
             | voy::filter([] (const auto& s) {
                     return isupper(s[0]);
                 })
             ,
 
             voy::system_cmd("ping"s, "1.1.1.1"s)
             | voy::slice(1,3)
         )
         | voy::transform([] (auto&& s) {
             return ">> " + voy_fwd(s);
           })
         | voy::identity<>()
         | voy::sink{cout};
 #endif
 
 // #define TCP_TEST
 #ifdef TCP_TEST
     auto pipeline_tcp =
         voy::tcp::service<>(42042)
         | voy::filter(
             [] (const auto& value)
             {
                 auto copy = *value;
                 boost::algorithm::trim(copy);
                 return !copy.empty();
             })
         | voy::transform(
             [] (auto&& value)
             {
                 // value.reply((*value) + " (echoed)\n");
                 value.reply("Got a message: "s + *value + "\n"s);
                 return "TCP message: ["s + *value + "]"s;
             })
         | voy::sink{cout};
 #endif
 
 // #define ZMQ_SUB_TEST
 #ifdef ZMQ_SUB_TEST
     auto pipeline_zmq_sub =
         voy::zmq::subscriber<>("ipc:///tmp/ivan-zmq-voy-socket-in"s)
         | voy::sink{cout};
 #endif
 
 // #define ZMQ_PUB_TEST
 #ifdef ZMQ_PUB_TEST
     auto pipeline_zmq_pub =
         voy::system_cmd("ping"s, "1.1.1.1"s)
         | voy::zmq::publisher<>("ipc:///tmp/ivan-zmq-voy-socket-out"s);
 #endif
 
 // #define ZMQ_PUBSUB_TEST
 #ifdef ZMQ_PUBSUB_TEST
     auto pipeline_zmq_pub =
         voy::zmq::subscriber<>("ipc:///tmp/ivan-zmq-voy-socket-in"s)
         | voy::zmq::publisher<>("ipc:///tmp/ivan-zmq-voy-socket-out"s);
 #endif
 
 // #define ASSOCIATIVITY_TEST
 #ifdef ASSOCIATIVITY_TEST
     auto pipeline_associativity =
         voy::delayed_values(2s, {"I'm running late"s, "sorry..."s})
         | ( voy::filter([] (const auto& s) {
                 return isupper(s[0]);
             })
           | voy::filter([] (const auto& s) {
                 return isupper(s[0]);
             })
           )
         | ( voy::transform([] (auto s) {
                 std::transform(s.begin(), s.end(), s.begin(), toupper);
                 return s;
             })
         | voy::filter([] (const auto& s) {
                 return isupper(s[0]);
             })
           )
         | voy::sink{cout};
 
 
 #endif
 
     voy::event_loop::run();
 
     return 0;
 }