Report which unknown message was received

Author: shepmaster

compiler/base/orchestrator/Cargo.lock

@@ -15,6 +15,7 @@ once_cell = { version = "1.18.0", default-features = false, features = ["std"] }
 serde = { version = "1.0", default-features = false, features = ["derive"] }
 serde_json = { version = "1.0.108", default-features = false, features = ["std"] }
 snafu = { version = "0.8.0", default-features = false, features = ["futures", "std"] }
+strum_macros = { version = "0.25.3", default-features = false }
 tokio = { version = "1.28", default-features = false, features = ["fs", "io-std", "io-util", "macros", "process", "rt", "time", "sync"] }
 tokio-stream = { version = "0.1.14", default-features = false }
 tokio-util = { version = "0.7.8", default-features = false, features = ["io", "io-util"] }

compiler/base/orchestrator/Cargo.toml

@@ -1773,7 +1773,10 @@ impl Container {
                                 WorkerMessage::Error2(e) =>
                                     return Err(e).context(WorkerSnafu),
 
-                                _ => return UnexpectedMessageSnafu.fail(),
+                                _ => {
+                                    let message = container_msg.as_ref();
+                                    return UnexpectedMessageSnafu { message }.fail()
+                                },
                             }
                         },
 
@@ -2097,8 +2100,8 @@ pub enum SpawnCargoError {
     #[snafu(display("The worker operation failed"))]
     Worker { source: SerializedError2 },
 
-    #[snafu(display("Received an unexpected message"))]
-    UnexpectedMessage,
+    #[snafu(display("Received the unexpected message `{message}`"))]
+    UnexpectedMessage { message: String },
 
     #[snafu(display("There are no more messages"))]
     UnexpectedEndOfMessages,

compiler/base/orchestrator/src/coordinator.rs

@@ -41,7 +41,7 @@ impl_narrow_to_broad!(
     ExecuteCommand => ExecuteCommandRequest,
 );
 
-#[derive(Debug, Serialize, Deserialize)]
+#[derive(Debug, Serialize, Deserialize, strum_macros::AsRefStr)]
 pub enum WorkerMessage {
     WriteFile(WriteFileResponse),
     DeleteFile(DeleteFileResponse),