fix(message): prevent panic on malformed UUID in log fields (#1562)

### **SUMMARY**

Fixes a daemon crash caused by `.unwrap()` when parsing UUIDs from log
fields. Invalid UUIDs from node logs would panic the system.

Changes are in `libraries/message/src/common.rs` inside
`LogMessage::from(...)`.

---

### FIX


#### **Before**

```rust id="9et2c1"
.map(|id| BuildId(Uuid::parse_str(&id).unwrap()))
```

#### **After**

```rust id="x68dih"
.and_then(|id| Uuid::parse_str(&id).ok().map(BuildId))
```

---

### **VERIFICATION**

To verify, emit a log from a node process with an invalid UUID such as
`{"fields": {"build_id": "not-a-uuid"}}`. Before this change, the daemon
would panic while converting the log message. After the fix, the daemon
continues running normally and simply treats the invalid UUID field as
`None`.

Author: phil-opp

libraries/message/src/common.rs

@@ -50,27 +50,27 @@ impl From<LogMessageHelper> for LogMessage {
         LogMessage {
             build_id: helper.build_id.or(fields
                 .and_then(|f| f.get("build_id").cloned())
-                .map(|id| BuildId(Uuid::parse_str(&id).unwrap()))),
+                .and_then(|id| Uuid::parse_str(&id).ok().map(BuildId))),
             dataflow_id: helper.dataflow_id.or(fields
                 .and_then(|f| f.get("dataflow_id").cloned())
-                .map(|id| DataflowId::from(Uuid::parse_str(&id).unwrap()))),
+                .and_then(|id| Uuid::parse_str(&id).ok().map(DataflowId::from))),
             node_id: helper.node_id.or(fields
                 .and_then(|f| f.get("node_id").cloned())
                 .map(|id| NodeId(id))),
-            daemon_id: helper
-                .daemon_id
-                .or(fields.and_then(|f| f.get("daemon_id").cloned()).map(|id| {
+            daemon_id: helper.daemon_id.or(fields
+                .and_then(|f| f.get("daemon_id").cloned())
+                .and_then(|id| {
                     let parts: Vec<&str> = id.splitn(2, '-').collect();
                     if parts.len() == 2 {
-                        DaemonId {
+                        Uuid::parse_str(parts[1]).ok().map(|uuid| DaemonId {
                             machine_id: Some(parts[0].to_string()),
-                            uuid: Uuid::parse_str(parts[1]).unwrap(),
-                        }
+                            uuid,
+                        })
                     } else {
-                        DaemonId {
+                        Uuid::parse_str(&parts[0]).ok().map(|uuid| DaemonId {
                             machine_id: None,
-                            uuid: Uuid::parse_str(&parts[0]).unwrap(),
-                        }
+                            uuid,
+                        })
                     }
                 })),
             level: helper.level,