rename startSession to newSession

Signed-off-by: kerthcet <kerthcet@gmail.com>

Author: kerthcet

docs/PROTOCOL.md

@@ -177,13 +177,13 @@ All messages are JSON with a `type` field indicating the message type:
 
 ### Interactive Session (PTY)
 
-#### StartSession
+#### NewSession
 **Direction**: Agent → Daemon
 **Purpose**: Start an interactive session
 
 ```json
 {
-  "type": "start_session",
+  "type": "new_session",
   "session_id": "550e8400-e29b-41d4-a716-446655440001",
   "rows": 24,
   "cols": 80,
@@ -390,7 +390,7 @@ All messages are JSON with a `type` field indicating the message type:
 
 1. Agent generates unique `session_id`
 2. Agent registers mpsc channel for this session
-3. Agent sends `StartSession` message
+3. Agent sends `NewSession` message
 4. Daemon starts PTY and begins streaming output
 5. Agent sends `SessionInput` as user types
 6. Daemon sends `SessionOutput` continuously

sandd/src/main.rs

@@ -209,7 +209,14 @@ async fn connect_and_serve(
         };
 
         // Handle message inline
-        if let Err(e) = handle_message(message, ws_tx_clone.clone(), executor.clone(), session_manager.clone()).await {
+        if let Err(e) = handle_message(
+            message,
+            ws_tx_clone.clone(),
+            executor.clone(),
+            session_manager.clone(),
+        )
+        .await
+        {
             error!("Error handling message: {}", e);
         }
     }
@@ -293,7 +300,7 @@ where
             }
         }
 
-        Message::StartSession {
+        Message::NewSession {
             session_id,
             rows,
             cols,
@@ -303,7 +310,7 @@ where
 
             let mut manager = session_manager.lock().await;
             let result = manager
-                .start_session(session_id.clone(), rows, cols, &term, ws_tx.clone())
+                .new_session(session_id.clone(), rows, cols, &term, ws_tx.clone())
                 .await;
 
             let response = match result {
@@ -326,11 +333,12 @@ where
                 .map_err(|e| anyhow::anyhow!("{}", e))?;
         }
 
-        Message::SessionInput {
-            session_id,
-            data,
-        } => {
-            debug!("Session input: {} bytes for session {}", data.len(), session_id);
+        Message::SessionInput { session_id, data } => {
+            debug!(
+                "Session input: {} bytes for session {}",
+                data.len(),
+                session_id
+            );
             let manager = session_manager.lock().await;
             if let Err(e) = manager.send_input(&session_id, &data).await {
                 error!("Failed to send input to session {}: {}", session_id, e);

sandd/src/protocol.rs

@@ -37,7 +37,7 @@ pub enum Message {
         request_id: String,
         error: String,
     },
-    StartSession {
+    NewSession {
         session_id: String,
         rows: u16,
         cols: u16,

sandd/src/session.rs

@@ -29,7 +29,7 @@ impl SessionManager {
         }
     }
 
-    pub async fn start_session<T>(
+    pub async fn new_session<T>(
         &mut self,
         session_id: String,
         rows: u16,

server/src/lib.rs

@@ -133,7 +133,7 @@ impl Server {
         let session_id = Uuid::new_v4().to_string();
         let (tx, rx) = tokio::sync::mpsc::unbounded_channel();
 
-        let msg = Message::StartSession {
+        let msg = Message::NewSession {
             session_id: session_id.clone(),
             rows,
             cols,

server/src/protocol.rs

@@ -40,7 +40,7 @@ pub enum Message {
     },
 
     // Interactive session (PTY mode)
-    StartSession {
+    NewSession {
         session_id: String,
         rows: u16,
         cols: u16,
@@ -259,7 +259,7 @@ mod tests {
 
     #[test]
     fn test_session_messages() {
-        let start = Message::StartSession {
+        let start = Message::NewSession {
             session_id: "session-1".to_string(),
             rows: 24,
             cols: 80,
@@ -270,7 +270,7 @@ mod tests {
         let parsed: Message = serde_json::from_str(&json).unwrap();
 
         match parsed {
-            Message::StartSession {
+            Message::NewSession {
                 session_id,
                 rows,
                 cols,