Add Config.Connect

lib/zenohex/config.ex

@@ -5,8 +5,9 @@ defmodule Zenohex.Config do
   Used by `Zenohex.open/1`, `Zenohex.open!/1`.
   """
 
+  alias Zenohex.Config.Connect
   alias Zenohex.Config.Scouting
 
-  @type t :: %__MODULE__{scouting: Scouting.t()}
-  defstruct scouting: %Scouting{}
+  @type t :: %__MODULE__{connect: Connect.t(), scouting: Scouting.t()}
+  defstruct connect: %Connect{}, scouting: %Scouting{}
 end

lib/zenohex/config/connect.ex

@@ -0,0 +1,14 @@
+defmodule Zenohex.Config.Connect do
+  @moduledoc """
+  Documentation for `#{__MODULE__}`.
+  """
+
+  @type t :: %__MODULE__{endpoints: endpoints()}
+
+  @typedoc """
+  ex. ["tcp/192.168.1.1:7447", "tcp/192.168.1.2:7447"]
+  """
+  @type endpoints() :: [String.t()]
+
+  defstruct endpoints: []
+end

mix.exs

@@ -71,6 +71,7 @@ defmodule Zenohex.MixProject do
       groups_for_modules: [
         Configs: [
           Zenohex.Config,
+          Zenohex.Config.Connect,
           Zenohex.Config.Scouting
         ],
         Options: [

native/zenohex_nif/src/config.rs

@@ -3,17 +3,41 @@ use rustler::ErlOption;
 #[derive(rustler::NifStruct)]
 #[module = "Zenohex.Config"]
 pub(crate) struct ExConfig {
+    connect: ExConfigConnect,
     scouting: ExConfigScouting,
 }
 
 impl From<ExConfig> for zenoh::prelude::config::Config {
     fn from(value: ExConfig) -> Self {
         let mut config = zenoh::prelude::config::peer();
+        config.connect = value.connect.into();
         config.scouting = value.scouting.into();
         config
     }
 }
 
+#[derive(rustler::NifStruct)]
+#[module = "Zenohex.Config.Connect"]
+pub(crate) struct ExConfigConnect {
+    endpoints: Vec<String>,
+}
+
+impl From<ExConfigConnect> for zenoh::prelude::config::ConnectConfig {
+    fn from(value: ExConfigConnect) -> Self {
+        let endpoints = value
+            .endpoints
+            .iter()
+            .map(|endpoint| {
+                zenoh::prelude::config::EndPoint::try_from(endpoint.clone())
+                    .unwrap_or_else(|error| panic!("{}", error.to_string()))
+            })
+            .collect();
+        let mut config = zenoh::prelude::config::ConnectConfig::default();
+        let _ = config.set_endpoints(endpoints);
+        config
+    }
+}
+
 #[derive(rustler::NifStruct)]
 #[module = "Zenohex.Config.Scouting"]
 pub(crate) struct ExConfigScouting {

test/zenohex/config_test.exs

@@ -0,0 +1,16 @@
+defmodule Zenohex.ConfigTest do
+  use ExUnit.Case, async: true
+
+  alias Zenohex.Config
+  alias Zenohex.Config.Connect
+  alias Zenohex.Config.Scouting
+
+  test "" do
+    config = %Config{
+      connect: %Connect{endpoints: ["tcp/localhost:7447"]},
+      scouting: %Scouting{delay: 200}
+    }
+
+    assert {:ok, session} = Zenohex.open(config)
+  end
+end