Change the API so that we have a builder pattern for LocalTransportCh…

…annel

chorus_book/src/guide-projector.md

@@ -11,7 +11,7 @@ To create a `Projector`, you need to provide the target location and the transpo
 # use chorus_lib::transport::local::{LocalTransport, LocalTransportChannel};
 # use chorus_lib::core::{ChoreographyLocation, Projector};
 # use chorus_lib::{LocationSet};
-# let transport_channel = LocalTransportChannel::<LocationSet!(Alice, Bob)>::new();
+# let transport_channel = LocalTransportChannel::new().with(Alice).with(Bob);
 # let alice_transport = LocalTransport::new(Alice, transport_channel.clone());
 # #[derive(ChoreographyLocation)]
 # struct Alice;
@@ -31,7 +31,7 @@ To execute a choreography, you need to call the `epp_and_run` method on the `Pro
 # use chorus_lib::transport::local::{LocalTransport, LocalTransportChannel};
 # use chorus_lib::core::{ChoreographyLocation, Projector, Choreography, ChoreoOp};
 # use chorus_lib::{LocationSet};
-# let transport_channel = LocalTransportChannel::<LocationSet!(Alice, Bob)>::new();
+# let transport_channel = LocalTransportChannel::new().with(Alice).with(Bob);
 # let alice_transport = LocalTransport::new(Alice, transport_channel.clone());
 # #[derive(ChoreographyLocation)]
 # struct Alice;

chorus_book/src/guide-transport.md

@@ -8,7 +8,7 @@ ChoRus provides two built-in transports: `local` and `http`.
 
 ### The Local Transport
 
-The `local` transport is used to execute choreographies on the same machine on different threads. This is useful for testing and prototyping. Each `local` transport is defined over `LocalTransportChannel`, which contains the set of `ChoreographyLocation` that the `local` transport operates on. You can build a `LocalTransportChannel` by importing the `LocalTransportChannel` stsruct from the `chorus_lib` crate.
+The `local` transport is used to execute choreographies on the same machine on different threads. This is useful for testing and prototyping. Each `local` transport is defined over `LocalTransportChannel`, which contains the set of `ChoreographyLocation` that the `local` transport operates on. You can build a `LocalTransportChannel` by importing the `LocalTransportChannel` struct from the `chorus_lib` crate.
 
 ```rust
 # extern crate chorus_lib;
@@ -20,7 +20,7 @@ The `local` transport is used to execute choreographies on the same machine on d
 # struct Bob;
 use chorus_lib::transport::local::LocalTransportChannel;
 
-let transport_channel = LocalTransportChannel::<LocationSet!(Alice, Bob)>::new();
+let transport_channel = LocalTransportChannel::new().with(Alice).with(Bob);
 ```
 
 To use the `local` transport, first import the `LocalTransport` struct from the `chorus_lib` crate.
@@ -34,7 +34,7 @@ Then build the transport by using the `LocalTransport::new` associated function,
 # #[derive(ChoreographyLocation)]
 # struct Alice;
 # use chorus_lib::transport::local::LocalTransportChannel;
-# let transport_channel = LocalTransportChannel::<LocationSet!(Alice)>::new();
+# let transport_channel = LocalTransportChannel::new().with(Alice);
 use chorus_lib::transport::local::{LocalTransport};
 
 let alice_transport = LocalTransport::new(Alice, transport_channel.clone());
@@ -58,7 +58,7 @@ Because of the nature of the `Local` transport, you must use the same `LocalTran
 #     fn run(self, op: &impl ChoreoOp<Self::L>) {
 #     }
 # }
-let transport_channel = LocalTransportChannel::<LocationSet!(Alice, Bob)>::new();
+let transport_channel = LocalTransportChannel::new().with(Alice).with(Bob);
 let mut handles: Vec<thread::JoinHandle<()>> = Vec::new();
 {
     // create a transport for Alice
@@ -89,23 +89,32 @@ To use the `http` transport, import the `HttpTransport` struct and the `HttpTran
 use chorus_lib::transport::http::{HttpTransport, HttpTransportConfig};
 ```
 
-The primary constructor requires an argument of type `HttpTransportConfig`. To create an instance of this configuration, utilize the builder pattern. Start with `HttpTransportConfig::for_target(target_location, target_information)` and then chain additional locations using the `.with(other_location, other_location_information)` method. Conclude with `.build()`. In this context, `target_location` refers to the target `ChoreographyLocation`, and `target_information` is specifically a tuple of `(host_name: String, port: u16)`. Subsequent calls to `.with()` allow you to add more locations and their respective information. For the `HttpTransport`, think of `HttpTransportConfig` as a mapping from locations to their hostnames and ports. However, for other generic transports, the corresponding information might vary, potentially diverging from the `(host_name, port)` format presented here.  In some cases, the `target_information` could even have a different type than the following `other_location_information` types. But all the `other_location_information`s should have the same type.
+The primary constructor requires an argument of type `HttpTransportConfig`. To create an instance of this configuration, start with `HttpTransportConfig::for_target(target_location, target_information)` and then chain additional locations using the `.with(other_location, other_location_information)` method. In this context, `target_location` refers to the target `ChoreographyLocation`, and `target_information` is specifically a tuple of `(host_name: String, port: u16)`. Subsequent calls to `.with()` allow you to add more locations and their respective information. You can think of `HttpTransportConfig` as a mapping from locations to their hostnames and ports.
 
 ```rust
 {{#include ./header.txt}}
 # use chorus_lib::transport::http::{HttpTransport, HttpTransportConfig};
 let config = HttpTransportConfig::for_target(Alice, ("localhost".to_string(), 8080))
-                .with(Bob, ("localhost".to_string(), 8081))
-                .build();
+                .with(Bob, ("localhost".to_string(), 8081));
 
-let transport = HttpTransport::new(&config);
+let transport = HttpTransport::new(config);
 ```
 
 In the above example, the transport will start the HTTP server on port 8080 on localhost. If Alice needs to send a message to Bob, it will use `http://localhost:8081` as the destination.
 
 ## Creating a Custom Transport
 
-You can also create your own transport by implementing the `Transport` trait. See the API documentation for more details.
+You can also create your own transport by implementing the `Transport` trait. It might be helpful first build a `TransportConfig` to have the the information that you need for each `ChoreographyLocation`, and then have a constructor that takes the `TransportConfig` and builds the `Transport` based on it. While the syntax is similar to `HttpTransportConfig`, the type of information for each `ChoreographyLocation` might diverge from the `(host_name, port)` format presented here. In some cases, the `target_information` could even have a different type than the following `other_location_information` types. But all the `other_location_information`s should have the same type.
+
+```rust
+{{#include ./header.txt}}
+# use chorus_lib::transport::TransportConfig;
+let config = TransportConfig::for_target(Alice, ())
+                .with(Bob, ("localhost".to_string(), 8081))
+                .with(Carol, ("localhost".to_string(), 8082));
+```
+
+See the API documentation for more details.
 
 
 ### Note on the location set of the Choreography

chorus_book/src/header.txt

@@ -8,7 +8,7 @@
 # struct Bob;
 # #[derive(ChoreographyLocation)]
 # struct Carol;
-# let transport_channel = LocalTransportChannel::<LocationSet!(Alice, Bob, Carol)>::new();
+# let transport_channel = LocalTransportChannel::new().with(Alice).with(Bob).with(Carol);
 # let alice_transport = LocalTransport::new(Alice, transport_channel.clone());
 # let bob_transport = LocalTransport::new(Bob, transport_channel.clone());
 # let carol_transport = LocalTransport::new(Carol, transport_channel.clone());

chorus_lib/examples/bookseller.rs

@@ -73,7 +73,7 @@ impl Choreography for BooksellerChoreography {
 }
 
 fn main() {
-    let transport_channel = LocalTransportChannel::<LocationSet!(Seller, Buyer)>::new();
+    let transport_channel = LocalTransportChannel::new().with(Seller).with(Buyer);
     let transport_seller = LocalTransport::new(Seller, transport_channel.clone());
     let transport_buyer = LocalTransport::new(Buyer, transport_channel.clone());
 

chorus_lib/examples/bookseller2.rs

@@ -143,7 +143,11 @@ fn main() {
         i
     };
 
-    let transport_channel = LocalTransportChannel::<LocationSet!(Seller, Buyer1, Buyer2)>::new();
+    let transport_channel = LocalTransportChannel::new()
+        .with(Seller)
+        .with(Buyer1)
+        .with(Buyer2);
+
     let seller_projector = Arc::new(Projector::new(
         Seller,
         LocalTransport::new(Seller, transport_channel.clone()),

chorus_lib/examples/hello.rs

@@ -40,19 +40,20 @@ impl Choreography for HelloWorldChoreography {
 fn main() {
     let mut handles: Vec<thread::JoinHandle<()>> = Vec::new();
     // Create a transport channel
-    let transport_channel = LocalTransportChannel::<LocationSet!(Bob, Alice)>::new();
+    // let transport_channel = LocalTransportChannel::<LocationSet!(Bob, Alice)>::new();
+    let transport_channel = LocalTransportChannel::new().with(Alice).with(Bob);
     // Run the choreography in two threads
     {
-        let transport_channel = transport_channel.clone();
-        let transport = LocalTransport::new(Alice, transport_channel);
+        // let transport_channel = transport_channel.clone();
+        let transport = LocalTransport::new(Alice, transport_channel.clone());
         handles.push(thread::spawn(move || {
             let p = Projector::new(Alice, transport);
             p.epp_and_run(HelloWorldChoreography);
         }));
     }
     {
-        let transport_channel = transport_channel.clone();
-        let transport = LocalTransport::new(Bob, transport_channel);
+        // let transport_channel = transport_channel.clone();
+        let transport = LocalTransport::new(Bob, transport_channel.clone());
         handles.push(thread::spawn(move || {
             let p = Projector::new(Bob, transport);
             p.epp_and_run(HelloWorldChoreography);

chorus_lib/examples/loc-poly.rs

@@ -57,7 +57,11 @@ impl Choreography<Located<i32, Alice>> for MainChoreography {
 }
 
 fn main() {
-    let transport_channel = LocalTransportChannel::<LocationSet!(Alice, Bob, Carol)>::new();
+    let transport_channel = LocalTransportChannel::new()
+        .with(Alice)
+        .with(Bob)
+        .with(Carol);
+
     let mut handles = vec![];
     {
         let transport = LocalTransport::new(Alice, transport_channel.clone());

chorus_lib/examples/tic-tac-toe.rs

@@ -305,9 +305,9 @@ fn main() {
                     args.opponent_hostname.as_str().to_string(),
                     args.opponent_port,
                 ),
-            )
-            .build();
-            let transport = HttpTransport::new(&config);
+            );
+
+            let transport = HttpTransport::new(config);
             let projector = Projector::new(PlayerX, transport);
             projector.epp_and_run(TicTacToeChoreography {
                 brain_for_x: projector.local(brain),
@@ -325,9 +325,9 @@ fn main() {
                     args.opponent_hostname.as_str().to_string(),
                     args.opponent_port,
                 ),
-            )
-            .build();
-            let transport = HttpTransport::new(&config);
+            );
+
+            let transport = HttpTransport::new(config);
             let projector = Projector::new(PlayerO, transport);
             projector.epp_and_run(TicTacToeChoreography {
                 brain_for_x: projector.remote(PlayerX),

chorus_lib/src/core.rs

@@ -96,12 +96,11 @@ pub trait HList {
     /// returns
     fn to_string_list() -> Vec<&'static str>;
 }
+
 /// end of HList
-#[derive(Clone)]
 pub struct HNil;
-/// An element of HList
 
-#[derive(Clone)]
+/// An element of HList
 pub struct HCons<Head, Tail>(Head, Tail);
 
 impl HList for HNil {
@@ -171,22 +170,6 @@ where
 {
 }
 
-/// Equal trait
-pub trait Equal<L: HList, Index> {}
-
-// Base case: HNil is equal to HNil
-impl Equal<HNil, Here> for HNil {}
-
-// Recursive case: Head::Tail is equal to L if
-// 1. Head is a member of L
-// 2. Tail is equal to the remainder of L
-impl<L: HList, Head, Tail, Index1, Index2> Equal<L, HCons<Index1, Index2>> for HCons<Head, Tail>
-where
-    Head: Member<L, Index1>,
-    Tail: Equal<Head::Remainder, Index2>,
-{
-}
-
 /// Provides a method to work with located values at the current location
 pub struct Unwrapper<L1: ChoreographyLocation> {
     phantom: PhantomData<L1>,
@@ -280,7 +263,11 @@ pub trait Choreography<R = ()> {
 /// Provides methods to send and receive messages.
 ///
 /// The trait provides methods to send and receive messages between locations. Implement this trait to define a custom transport.
-pub trait Transport<L, TargetLocation> {
+///
+/// The type parameter `L` is the location set that the transport is operating on.
+///
+/// The type paramter `TargetLocation` is the target `ChoreographyLocation`.
+pub trait Transport<L: HList, TargetLocation: ChoreographyLocation> {
     /// Returns a list of locations.
     fn locations(&self) -> Vec<String>;
     /// Sends a message from `from` to `to`.

chorus_lib/src/transport.rs

@@ -38,30 +38,17 @@ impl<L: HList, InfoType, TargetLocation: ChoreographyLocation, TargetInfoType>
 {
     /// Adds information about a new `ChoreographyLocation`.
     pub fn with<NewLocation: ChoreographyLocation>(
-        self,
+        mut self,
         _location: NewLocation,
         info: InfoType,
     ) -> TransportConfig<HCons<NewLocation, L>, InfoType, TargetLocation, TargetInfoType>
 where {
-        let mut new_info = HashMap::new();
-        for (k, v) in self.info.into_iter() {
-            new_info.insert(k, v);
-        }
-        new_info.insert(NewLocation::name().to_string(), info);
+        self.info.insert(NewLocation::name().to_string(), info);
 
-        TransportConfig {
-            info: new_info,
-            target_info: self.target_info,
-            location_set: PhantomData,
-        }
-    }
-
-    /// Finalize the `TransportConfig`.
-    pub fn build(self) -> TransportConfig<L, InfoType, TargetLocation, TargetInfoType> {
         TransportConfig {
             info: self.info,
-            location_set: PhantomData,
             target_info: self.target_info,
+            location_set: PhantomData,
         }
     }
 }

chorus_lib/src/transport/http.rs

@@ -48,7 +48,7 @@ pub struct HttpTransport<L: HList, TLocation> {
 
 impl<L: HList, TLocation: ChoreographyLocation> HttpTransport<L, TLocation> {
     /// Creates a new `HttpTransport` instance from the configuration.
-    pub fn new<Index>(http_config: &HttpTransportConfig<L, TLocation>) -> Self
+    pub fn new<Index>(http_config: HttpTransportConfig<L, TLocation>) -> Self
     where
         TLocation: Member<L, Index>,
     {
@@ -60,7 +60,7 @@ impl<L: HList, TLocation: ChoreographyLocation> HttpTransport<L, TLocation> {
             Arc::new(m.into())
         };
 
-        let info = &http_config.info;
+        let info = http_config.info;
 
         let (_, (hostname, port)) = &http_config.target_info;
         let server = Arc::new(Server::http(format!("{}:{}", hostname, port)).unwrap());
@@ -116,7 +116,9 @@ impl<L: HList, TLocation> Drop for HttpTransport<L, TLocation> {
     }
 }
 
-impl<L: HList, TLocation> Transport<L, TLocation> for HttpTransport<L, TLocation> {
+impl<L: HList, TLocation: ChoreographyLocation> Transport<L, TLocation>
+    for HttpTransport<L, TLocation>
+{
     fn locations(&self) -> Vec<String> {
         Vec::from_iter(self.config.keys().map(|s| s.clone()))
     }
@@ -165,22 +167,20 @@ mod tests {
         let mut handles = Vec::new();
         {
             let config = HttpTransportConfig::for_target(Alice, ("0.0.0.0".to_string(), 9010))
-                .with(Bob, ("localhost".to_string(), 9011))
-                .build();
+                .with(Bob, ("localhost".to_string(), 9011));
 
             handles.push(thread::spawn(move || {
                 wait.recv().unwrap(); // wait for Bob to start
-                let transport = HttpTransport::new(&config);
+                let transport = HttpTransport::new(config);
                 transport.send::<i32>(Alice::name(), Bob::name(), &v);
             }));
         }
         {
             let config = HttpTransportConfig::for_target(Bob, ("0.0.0.0".to_string(), 9011))
-                .with(Alice, ("localhost".to_string(), 9010))
-                .build();
+                .with(Alice, ("localhost".to_string(), 9010));
 
             handles.push(thread::spawn(move || {
-                let transport = HttpTransport::new(&config);
+                let transport = HttpTransport::new(config);
                 signal.send(()).unwrap();
                 let v2 = transport.receive::<i32>(Alice::name(), Bob::name());
                 assert_eq!(v, v2);
@@ -199,25 +199,23 @@ mod tests {
         let mut handles = Vec::new();
         {
             let config = HttpTransportConfig::for_target(Alice, ("0.0.0.0".to_string(), 9020))
-                .with(Bob, ("localhost".to_string(), 9021))
-                .build();
+                .with(Bob, ("localhost".to_string(), 9021));
 
             handles.push(thread::spawn(move || {
                 signal.send(()).unwrap();
-                let transport = HttpTransport::new(&config);
+                let transport = HttpTransport::new(config);
                 transport.send::<i32>(Alice::name(), Bob::name(), &v);
             }));
         }
         {
             let config = HttpTransportConfig::for_target(Bob, ("0.0.0.0".to_string(), 9021))
-                .with(Alice, ("localhost".to_string(), 9020))
-                .build();
+                .with(Alice, ("localhost".to_string(), 9020));
 
             handles.push(thread::spawn(move || {
                 // wait for Alice to start, which forces Alice to retry
                 wait.recv().unwrap();
                 sleep(Duration::from_millis(100));
-                let transport = HttpTransport::new(&config);
+                let transport = HttpTransport::new(config);
                 let v2 = transport.receive::<i32>(Alice::name(), Bob::name());
                 assert_eq!(v, v2);
             }));