feat(data-plane): support for multiple servers (#173)

# Description

Support listening on multiple server endpoints for message processor.

Signed-off-by: Mauro Sardara <[email protected]>

Author: msardara

data-plane/config/base/server-config.yaml

@@ -13,9 +13,8 @@ runtime:
 
 services:
   gateway/0:
-    server:
-      endpoint: "0.0.0.0:46357"
-      tls:
-        insecure: true
-
+    servers:
+      - endpoint: "0.0.0.0:46357"
+        tls:
+          insecure: true
     clients: []

data-plane/config/basic-auth/server-config.yaml

@@ -13,14 +13,14 @@ runtime:
 
 services:
   gateway/0:
-    server:
-      endpoint: "0.0.0.0:46357"
-      tls:
-        cert_file: "./config/crypto/server-cert.pem"
-        key_file: "./config/crypto/server-key.pem"
-      auth:
-        basic:
-          username: username
-          password: ${env:PASSWORD}
+    servers:
+      - endpoint: "0.0.0.0:46357"
+        tls:
+          cert_file: "./config/crypto/server-cert.pem"
+          key_file: "./config/crypto/server-key.pem"
+        auth:
+          basic:
+            username: username
+            password: ${env:PASSWORD}
 
     clients: []

data-plane/config/mtls/server-config.yaml

@@ -13,12 +13,12 @@ runtime:
 
 services:
   gateway/0:
-    server:
-      endpoint: "0.0.0.0:46357"
-      tls:
-        cert_file: "./config/crypto/server-cert.pem"
-        key_file: "./config/crypto/server-key.pem"
+    servers:
+      - endpoint: "0.0.0.0:46357"
+        tls:
+          cert_file: "./config/crypto/server-cert.pem"
+          key_file: "./config/crypto/server-key.pem"
 
-        client_ca_file: "./config/crypto/client-ca-cert.pem"
+          client_ca_file: "./config/crypto/client-ca-cert.pem"
 
     clients: []

data-plane/config/tls/server-config.yaml

@@ -13,10 +13,10 @@ runtime:
 
 services:
   gateway/0:
-    server:
-      endpoint: "0.0.0.0:46357"
-      tls:
-        cert_file: "./config/crypto/server-cert.pem"
-        key_file: "./config/crypto/server-key.pem"
+    servers:
+      - endpoint: "0.0.0.0:46357"
+        tls:
+          cert_file: "./config/crypto/server-cert.pem"
+          key_file: "./config/crypto/server-key.pem"
 
     clients: []

data-plane/examples/src/sdk-mock/main.rs

@@ -39,7 +39,7 @@ async fn main() {
 
     // get service
     let id = agp_config::component::id::ID::new_with_str("gateway/0").unwrap();
-    let svc = config.services.remove(&id).unwrap();
+    let mut svc = config.services.remove(&id).unwrap();
 
     // create local agent
     let agent_id = 0;
@@ -49,9 +49,13 @@ async fn main() {
         .await
         .expect("failed to create agent");
 
-    // connect to the remote gateway
-    let conn_id = svc.connect(None).await.unwrap();
-    info!("remote connection id = {}", conn_id);
+    // run the service - this will create all the connections provided via the config file.
+    svc.run().await.unwrap();
+
+    // get the connection id
+    let conn_id = svc
+        .get_connection_id(&svc.config().clients()[0].endpoint)
+        .unwrap();
 
     let local_agent_type = AgentType::from_strings("cisco", "default", local_agent);
     svc.subscribe(

data-plane/gateway/config/src/component.rs

@@ -23,7 +23,7 @@ pub trait Component {
 
     // start the component
     #[allow(async_fn_in_trait)]
-    async fn start(&self) -> Result<(), ComponentError>;
+    async fn start(&mut self) -> Result<(), ComponentError>;
 }
 
 pub trait ComponentBuilder {

data-plane/gateway/gateway/src/bin/main.rs

@@ -24,7 +24,7 @@ fn main() {
     let config_file = args.config().expect("config file is required");
 
     // create configured components
-    let config = config::load_config(config_file).expect("failed to load configuration");
+    let mut config = config::load_config(config_file).expect("failed to load configuration");
 
     // print build info
     info!("{}", build_info::BUILD_INFO);
@@ -49,7 +49,7 @@ fn main() {
         );
 
         // start services
-        for service in config.services.iter() {
+        for service in config.services.iter_mut() {
             info!("Starting service: {}", service.0);
             service.1.start().await.expect("failed to start service")
         }

data-plane/gateway/nop_component/src/lib.rs

@@ -65,7 +65,7 @@ impl Component for NopComponent {
     }
 
     // Start the component
-    async fn start(&self) -> Result<(), ComponentError> {
+    async fn start(&mut self) -> Result<(), ComponentError> {
         // Start the component
         Ok(())
     }

data-plane/gateway/service/src/errors.rs

@@ -33,6 +33,8 @@ pub enum ServiceError {
     SessionNotFound(String),
     #[error("error in session: {0}")]
     SessionError(String),
+    #[error("client already connected: {0}")]
+    ClientAlreadyConnected(String),
     #[error("unknown error")]
     Unknown,
 }