fix grpc: use grpc-client-common (#44)

Co-authored-by: Antony Polukhin <[email protected]>

Author: Anton3

configs/static_config.yaml

@@ -1,7 +1,7 @@
 components_manager:
     task_processors:                  # Task processor is an executor for coroutine tasks
 
-        main-task-processor:          # Make a task processor for CPU-bound couroutine tasks.
+        main-task-processor:          # Make a task processor for CPU-bound coroutine tasks.
             worker_threads: $worker-threads         # Process tasks in 4 threads.
 
         fs-task-processor:            # Make a separate task processor for filesystem bound tasks.
@@ -14,13 +14,21 @@ components_manager:
     default_task_processor: main-task-processor
 
     components:                       # Configuring components that were registered via component_list
-        grpc-client-factory:
+        # Settings common to all gRPC client factories
+        grpc-client-common:
             # The TaskProcessor for blocking connection initiation
-            task-processor: grpc-blocking-task-processor
+            blocking-task-processor: grpc-blocking-task-processor
 
+        grpc-client-factory:
             # Optional channel parameters for gRPC Core
             # https://grpc.github.io/grpc/core/group__grpc__arg__keys.html
             channel-args: {}
+            middlewares:
+              - grpc-client-logging
+              - grpc-client-deadline-propagation
+
+        grpc-client-logging:
+        grpc-client-deadline-propagation:
 
         handler-hello:
 
@@ -30,9 +38,17 @@ components_manager:
         grpc-server:
             port: 8081
             service-defaults:
-                middlewares: []
+                middlewares:
+                  - grpc-server-logging
+                  - grpc-server-deadline-propagation
+                  - grpc-server-congestion-control
                 task-processor: main-task-processor
 
+        congestion-control:
+        grpc-server-logging:
+        grpc-server-deadline-propagation:
+        grpc-server-congestion-control:
+
         server:
             listener:                 # configuring the main listening socket...
                 port: $server-port            # ...to listen on this port and...

src/main.cpp

@@ -1,9 +1,16 @@
 #include <userver/clients/http/component.hpp>
 #include <userver/components/minimal_server_component_list.hpp>
+#include <userver/congestion_control/component.hpp>
 #include <userver/server/handlers/ping.hpp>
 #include <userver/server/handlers/tests_control.hpp>
 #include <userver/testsuite/testsuite_support.hpp>
 #include <userver/ugrpc/client/client_factory_component.hpp>
+#include <userver/ugrpc/client/common_component.hpp>
+#include <userver/ugrpc/client/middlewares/deadline_propagation/component.hpp>
+#include <userver/ugrpc/client/middlewares/log/component.hpp>
+#include <userver/ugrpc/server/middlewares/congestion_control/component.hpp>
+#include <userver/ugrpc/server/middlewares/deadline_propagation/component.hpp>
+#include <userver/ugrpc/server/middlewares/log/component.hpp>
 #include <userver/ugrpc/server/server_component.hpp>
 #include <userver/utils/daemon_run.hpp>
 
@@ -13,8 +20,15 @@
 int main(int argc, char* argv[]) {
   auto component_list =
       userver::components::MinimalServerComponentList()
+          .Append<userver::congestion_control::Component>()
           .Append<userver::ugrpc::server::ServerComponent>()
+          .Append<userver::ugrpc::server::middlewares::congestion_control::Component>()
+          .Append<userver::ugrpc::server::middlewares::deadline_propagation::Component>()
+          .Append<userver::ugrpc::server::middlewares::log::Component>()
+          .Append<userver::ugrpc::client::CommonComponent>()
           .Append<userver::ugrpc::client::ClientFactoryComponent>()
+          .Append<userver::ugrpc::client::middlewares::deadline_propagation::Component>()
+          .Append<userver::ugrpc::client::middlewares::log::Component>()
           .Append<userver::server::handlers::Ping>()
           .Append<userver::components::TestsuiteSupport>()
           .Append<userver::components::HttpClient>()