WIP: SP for replication testing

Author: dofinn

rust-tui/src/bin/integration_test.rs

@@ -45,7 +45,7 @@ async fn main() -> Result<()> {
 
     ditto.update_transport_config(|config| {
         config.enable_all_peer_to_peer();
-        config.connect.websocket_urls.insert(websocket_url);
+        config.connect.websocket_urls.insert(websocket_url.clone());
     });
 
     // Disable sync with v3 peers and DQL strict mode
@@ -60,7 +60,8 @@ async fn main() -> Result<()> {
     println!("✅ Created Ditto instance and started sync");
 
     // Create todolist instance (loads the app)
-    let todolist = Todolist::new(ditto)?;
+    let client_name = env::var("DITTO_CLIENT_NAME").ok();
+    let todolist = Todolist::new(ditto, websocket_url, client_name)?;
     println!("📝 App loaded - Created todolist instance");
 
     // Wait for sync and check for the seeded task

rust-tui/src/bin/main.rs

@@ -24,6 +24,10 @@ pub struct Cli {
     #[clap(long, env = "DITTO_WEBSOCKET_URL")]
     websocket_url: String,
 
+    /// Optional client name to display in the TUI
+    #[clap(long, env = "DITTO_CLIENT_NAME")]
+    client_name: Option<String>,
+
     /// Path to write logs on disk
     #[clap(long, default_value = "/tmp/ditto-quickstart.log")]
     log: PathBuf,
@@ -56,11 +60,17 @@ async fn main() -> Result<()> {
         cli.app_id,
         cli.token,
         cli.custom_auth_url,
-        cli.websocket_url,
+        cli.websocket_url.clone(),
     )
     .await?;
-    let _tui_task = TuiTask::try_spawn(shutdown.clone(), terminal, ditto)
-        .context("failed to start tui task")?;
+    let _tui_task = TuiTask::try_spawn(
+        shutdown.clone(),
+        terminal,
+        ditto,
+        cli.websocket_url,
+        cli.client_name,
+    )
+    .context("failed to start tui task")?;
     tracing::info!(success = true, "Initialized!");
 
     // Wait for shutdown trigger
@@ -117,8 +127,11 @@ async fn try_init_ditto(
         .build()?;
 
     ditto.update_transport_config(|config| {
-        config.enable_all_peer_to_peer();
-        //set websocket url
+        // Explicitly disable all peer-to-peer transports - only use Big Peer
+        config.peer_to_peer.bluetooth_le.enabled = false;
+        config.peer_to_peer.lan.enabled = false;
+
+        // Keep only the WebSocket connection to Big Peer
         config.connect.websocket_urls.insert(websocket_url);
     });
 

rust-tui/src/tui/mod.rs

@@ -26,8 +26,10 @@ impl TuiTask {
         shutdown: Shutdown,
         terminal: Terminal<CrosstermBackend<Stdout>>,
         ditto: Ditto,
+        websocket_url: String,
+        client_name: Option<String>,
     ) -> Result<TuiTask> {
-        let todolist_state = Todolist::new(ditto)?;
+        let todolist_state = Todolist::new(ditto, websocket_url, client_name)?;
         let task_context = TuiContext {
             terminal,
             shutdown,

rust-tui/src/tui/todolist.rs

@@ -37,6 +37,13 @@ pub struct Todolist {
     /// Subscriptions cause Ditto to sync selected data from other peers
     pub tasks_subscription: Arc<SyncSubscription>,
 
+    // Connection info for display
+    /// The WebSocket URL this client is connected to
+    pub websocket_url: String,
+
+    /// Optional client name for display purposes
+    pub client_name: Option<String>,
+
     // TUI state below
     pub mode: TodoMode,
 
@@ -82,7 +89,7 @@ impl TodoItem {
 }
 
 impl Todolist {
-    pub fn new(ditto: Ditto) -> Result<Self> {
+    pub fn new(ditto: Ditto, websocket_url: String, client_name: Option<String>) -> Result<Self> {
         let (tasks_tx, tasks_rx) = watch::channel(Vec::new());
 
         // Register a subscription, which determines what data syncs to this peer
@@ -110,6 +117,8 @@ impl Todolist {
             tasks_rx,
             tasks_observer,
             tasks_subscription,
+            websocket_url,
+            client_name,
             mode: TodoMode::Normal,
             create_task_title: None,
             edit_task: None,
@@ -155,6 +164,14 @@ impl Todolist {
             .into_iter()
             .collect::<Line>();
 
+        // Format connection info: "client_name@websocket_url" or just "websocket_url"
+        let connection_info = if let Some(ref client_name) = self.client_name {
+            format!(" {}@{} ", client_name, self.websocket_url)
+        } else {
+            format!(" {} ", self.websocket_url)
+        };
+        let connection_line = Line::raw(connection_info).cyan();
+
         let table = Table::new(rows, Constraint::from_percentages([30, 70]))
             .header(header)
             .highlight_symbol("❯❯ ")
@@ -164,7 +181,8 @@ impl Todolist {
                     .border_type(BorderType::Rounded)
                     .title_top(Line::raw(" Tasks (j↓, k↑, ⏎ toggle done) ").left_aligned())
                     .title_top(sync_line.right_aligned())
-                    .title_bottom(" (c: create) (d: delete) (e: edit) (q: quit) "),
+                    .title_bottom(Line::raw(" (c: create) (d: delete) (e: edit) (q: quit) ").left_aligned())
+                    .title_bottom(connection_line.right_aligned()),
             );
         StatefulWidget::render(table, area, buf, &mut self.table_state);
     }