| // Copyright 2021 The Fuchsia Authors. All rights reserved. |
| // Use of this source code is governed by a BSD-style license that can be |
| // found in the LICENSE file. |
| |
| #include <lib/async-loop/cpp/loop.h> |
| #include <lib/async-loop/default.h> |
| #include <lib/fidl/cpp/binding_set.h> |
| #include <lib/fidl/cpp/string.h> |
| #include <lib/sys/cpp/component_context.h> |
| |
| #include <iostream> |
| #include <sstream> |
| #include <string> |
| #include <utility> |
| |
| #include <test/placeholders/cpp/fidl.h> |
| |
| #include "sdk/lib/sys/component/cpp/tests/echo_server_config_lib.h" |
| |
| class EchoServer : public test::placeholders::Echo { |
| public: |
| explicit EchoServer(echo_server_config_lib::Config c) : config(std::move(c)) {} |
| |
| void EchoString(::fidl::StringPtr value, EchoStringCallback callback) override { |
| std::string intercept = value.value_or(""); |
| |
| std::string return_value = |
| intercept + " [" + std::to_string(config.my_flag()) + "][" + |
| std::to_string(config.my_uint8()) + "][" + std::to_string(config.my_uint16()) + "][" + |
| std::to_string(config.my_uint32()) + "][" + std::to_string(config.my_uint64()) + "][" + |
| std::to_string(config.my_int8()) + "][" + std::to_string(config.my_int16()) + "][" + |
| std::to_string(config.my_int32()) + "][" + std::to_string(config.my_int64()) + "][" + |
| config.my_string() + "]["; |
| for (const auto& value : config.my_vector_of_flag()) { |
| return_value += std::to_string(value) + ","; |
| } |
| return_value += "]["; |
| for (const auto& value : config.my_vector_of_uint8()) { |
| return_value += std::to_string(value) + ","; |
| } |
| return_value += "]["; |
| for (const auto& value : config.my_vector_of_uint16()) { |
| return_value += std::to_string(value) + ","; |
| } |
| return_value += "]["; |
| for (const auto& value : config.my_vector_of_uint32()) { |
| return_value += std::to_string(value) + ","; |
| } |
| return_value += "]["; |
| for (const auto& value : config.my_vector_of_uint64()) { |
| return_value += std::to_string(value) + ","; |
| } |
| return_value += "]["; |
| for (const auto& value : config.my_vector_of_int8()) { |
| return_value += std::to_string(value) + ","; |
| } |
| return_value += "]["; |
| for (const auto& value : config.my_vector_of_int16()) { |
| return_value += std::to_string(value) + ","; |
| } |
| return_value += "]["; |
| for (const auto& value : config.my_vector_of_int32()) { |
| return_value += std::to_string(value) + ","; |
| } |
| return_value += "]["; |
| for (const auto& value : config.my_vector_of_int64()) { |
| return_value += std::to_string(value) + ","; |
| } |
| return_value += "]["; |
| for (const auto& value : config.my_vector_of_string()) { |
| return_value += value + ","; |
| } |
| return_value += "]"; |
| |
| ZX_ASSERT(return_value.size() < 4096); |
| |
| callback(std::move(return_value)); |
| if (listener_) { |
| listener_(std::move(intercept)); |
| } |
| } |
| |
| fidl::InterfaceRequestHandler<test::placeholders::Echo> GetHandler() { |
| return bindings_.GetHandler(this); |
| } |
| |
| void SetListener(fit::function<void(std::string)> list) { listener_ = std::move(list); } |
| |
| private: |
| fidl::BindingSet<test::placeholders::Echo> bindings_; |
| fit::function<void(std::string)> listener_; |
| echo_server_config_lib::Config config; |
| }; |
| |
| int main(int argc, const char** argv) { |
| auto c = echo_server_config_lib::Config::from_args(); |
| std::cout << "Starting echo server." << std::endl; |
| async::Loop loop(&kAsyncLoopConfigAttachToCurrentThread); |
| auto startup = sys::ComponentContext::CreateAndServeOutgoingDirectory(); |
| std::unique_ptr<EchoServer> echo_server = std::make_unique<EchoServer>(std::move(c)); |
| startup->outgoing()->AddPublicService(echo_server->GetHandler()); |
| loop.Run(); |
| |
| std::cout << "Stopping echo server." << std::endl; |
| return 0; |
| } |