fix naming changes in coordinator

Author: adwinwhite

ui/Cargo.lock

@@ -440,6 +440,7 @@ enum PlaygroundMessage {
     Response(WSResponse),
     StdoutPacket(String),
     StderrPacket(String),
+    StreamFailure,
 }
 
 #[derive(Debug, serde::Serialize, serde::Deserialize)]
@@ -460,14 +461,14 @@ impl From<(JobReport, serde_json::Value, ResponseKind)> for WSResponse {
             ResponseKind::Compile => {
                 let mut success = false;
                 let mut code = String::new();
-                if let Some(Response::ReadFile(ReadFileResponse(Ok(data)))) = responses.last() {
+                if let Some(ResponseResult(Ok(Response::ReadFile(ReadFileResponse(data))))) = responses.last() {
                     success = true;
                     code = std::str::from_utf8(data).unwrap().to_owned();
                 }
                 let mut stdout = String::new();
                 let mut stderr = String::new();
                 if responses.len() >= 3 {
-                    if let Some(Response::ExecuteCommand(ExecuteCommandResponse(Ok(output)))) =
+                    if let Some(ResponseResult(Ok(Response::ExecuteCommand(ExecuteCommandResponse(output))))) =
                         responses.get(2)
                     {
                         stdout = from_utf8(&output.stdout).unwrap().to_owned();
@@ -485,14 +486,14 @@ impl From<(JobReport, serde_json::Value, ResponseKind)> for WSResponse {
             ResponseKind::Format => {
                 let mut success = false;
                 let mut code = String::new();
-                if let Some(Response::ReadFile(ReadFileResponse(Ok(data)))) = responses.last() {
+                if let Some(ResponseResult(Ok(Response::ReadFile(ReadFileResponse(data))))) = responses.last() {
                     success = true;
                     code = std::str::from_utf8(data).unwrap().to_owned();
                 }
                 let mut stdout = String::new();
                 let mut stderr = String::new();
                 if responses.len() >= 3 {
-                    if let Some(Response::ExecuteCommand(ExecuteCommandResponse(Ok(output)))) =
+                    if let Some(ResponseResult(Ok(Response::ExecuteCommand(ExecuteCommandResponse(output))))) =
                         responses.get(2)
                     {
                         stdout = from_utf8(&output.stdout).unwrap().to_owned();
@@ -508,8 +509,8 @@ impl From<(JobReport, serde_json::Value, ResponseKind)> for WSResponse {
                 })
             }
             ResponseKind::Execute => {
-                let success = if let Some(Response::StreamCommand(resp)) = responses.last() {
-                    resp.0.is_ok()
+                let success = if let Some(ResponseResult(resp)) = responses.last() {
+                    resp.is_ok()
                 } else {
                     false
                 };
@@ -648,6 +649,9 @@ async fn pair_websocket_worker(
                             WorkerMessage::StderrPacket(packet) => {
                                 ws_sender.send(serde_json::to_string(&PlaygroundMessage::StderrPacket(packet)).expect("Failed to serilaze standard output")).await.expect("Websocket failed to send standard output to client");
                             }
+                            WorkerMessage::StreamFailure => {
+                                ws_sender.send(serde_json::to_string(&PlaygroundMessage::StreamFailure).expect("Failed to serilize streaming failure notification")).await.expect("Websocket failed to send streaming failure notification");
+                            }
                         }
                     }
                 }