feat: add rpc example (philips-software#141)

examples/CMakeLists.txt

@@ -2,6 +2,7 @@ if (EMIL_HOST_BUILD)
     add_subdirectory(http)
     add_subdirectory(https)
     add_subdirectory(mdns)
+    add_subdirectory(rpc)
     add_subdirectory(serial_net)
     add_subdirectory(serial_output)
     add_subdirectory(sntp)

examples/rpc/CMakeLists.txt

@@ -0,0 +1,4 @@
+add_executable(examples.rpc_server)
+target_sources(examples.rpc_server PRIVATE Server.cpp)
+target_link_libraries(examples.rpc_server PRIVATE services.network_instantiations hal.generic)
+protocol_buffer_echo_cpp(examples.rpc_server Console.proto)

examples/rpc/Console.proto

@@ -0,0 +1,19 @@
+syntax = "proto3";
+
+import "EchoAttributes.proto";
+
+package examples;
+option java_package = "com.philips.emil.protobufEcho";
+option java_outer_classname = "ConsoleProto";
+
+message Message
+{
+    string message = 2 [(string_size) = 128];
+}
+
+service Console
+{
+    option (service_id) = 1;
+
+    rpc Write(Message) returns (Nothing) { option (method_id) = 1; }
+}

examples/rpc/Server.cpp

@@ -0,0 +1,65 @@
+#include "generated/echo/Console.pb.hpp"
+#include "hal/generic/TimerServiceGeneric.hpp"
+#include "protobuf/echo/Echo.hpp"
+#include "services/network_instantiations/NetworkAdapter.hpp"
+#include <iostream>
+
+class Console
+    : public examples::Console
+{
+public:
+    Console(services::Echo& echo)
+        : examples::Console(echo)
+    {}
+
+    void Write(infra::BoundedConstString message) override
+    {
+        std::cout << infra::AsStdString(message) << std::endl;
+        MethodDone();
+    }
+};
+
+class EchoConnection
+    : public services::EchoOnConnection
+{
+public:
+    EchoConnection()
+        : console(*this)
+    {}
+
+private:
+    Console console;
+};
+
+class RpcServer
+    : public services::ServerConnectionObserverFactory
+{
+public:
+    RpcServer(services::ConnectionFactory& factory)
+        : listener(factory.Listen(1234, *this))
+    {}
+
+    void ConnectionAccepted(infra::AutoResetFunction<void(infra::SharedPtr<services::ConnectionObserver> connectionObserver)>&& createdObserver, services::IPAddress address) override
+    {
+        if (connection)
+            connection->::services::EchoOnConnection::Subject().AbortAndDestroy();
+
+        if (connection.Allocatable())
+            createdObserver(connection.Emplace());
+    }
+
+private:
+    infra::SharedPtr<void> listener;
+    infra::SharedOptional<EchoConnection> connection;
+};
+
+int main(int argc, const char* argv[], const char* env[])
+{
+    static hal::TimerServiceGeneric timerService;
+    static main_::NetworkAdapter network;
+    static RpcServer rpc(network.ConnectionFactory());
+
+    network.Run();
+
+    return 0;
+}