test: basic exclude clear to-device traffic for widgets in e2ee room

Author: BillCarsonFr

crates/matrix-sdk/src/widget/matrix.rs

@@ -240,7 +240,6 @@ impl MatrixDriver {
                     return;
                 };
 
-                // Or should I use room.encryption_settings()?
                 let room_encrypted = room.latest_encryption_state().await
                     .map(|s| s.is_encrypted())
                     // Default consider encrypted

crates/matrix-sdk/tests/integration/widget.rs

@@ -487,6 +487,38 @@ async fn test_receive_live_events() {
     assert_matches!(recv_message(&driver_handle).now_or_never(), None);
 }
 
+#[async_test]
+async fn test_block_clear_to_device_in_e2ee_room() {
+    let (client, mock_server, driver_handle) = run_test_driver(false, true).await;
+
+    negotiate_capabilities(
+        &driver_handle,
+        json!(["org.matrix.msc3819.receive.to_device:my.custom.to.device"]),
+    )
+    .await;
+
+    // No messages from the driver yet
+    assert_matches!(recv_message(&driver_handle).now_or_never(), None);
+
+    mock_server
+        .mock_sync()
+        .ok_and_run(&client, |sync_builder| {
+            sync_builder.add_to_device_event(json!({
+                    "sender": "@alice:example.com",
+                    "type": "my.custom.to.device",
+                    "content": {
+                      "a": "test",
+                    }
+                  }
+            ));
+        })
+        .await;
+
+    // The message should be filtered out because it is not encrypted and the room
+    // is encrypted
+    assert_matches!(recv_message(&driver_handle).now_or_never(), None);
+}
+
 #[async_test]
 async fn test_send_room_message() {
     let (_, mock_server, driver_handle) = run_test_driver(false, false).await;