feat(dvc)!: expose dynamic channel accessors

Add mutable dynamic channel lookup APIs for drdynvc client / server.

BREAKING CHANGE: DynamicVirtualChannel::channel_processor_downcast_ref
now requires `DvcClientProcessor` instead of `DvcProcessor`.

Signed-off-by: uchouT <i@uchout.moe>

Author: uchouT

crates/ironrdp-dvc/src/client.rs

@@ -161,6 +161,10 @@ impl DrdynvcClient {
         self.dynamic_channels.get_by_channel_id(channel_id)
     }
 
+    pub fn get_dvc_by_channel_id_mut(&mut self, channel_id: u32) -> Option<&mut DynamicVirtualChannel> {
+        self.dynamic_channels.get_by_channel_id_mut(channel_id)
+    }
+
     fn create_capabilities_response(&mut self, server_version: CapsVersion) -> SvcMessage {
         let caps_response = DrdynvcClientPdu::Capabilities(CapabilitiesResponsePdu::new(server_version));
         debug!("Send DVC Capabilities Response PDU: {caps_response:?}");

crates/ironrdp-dvc/src/lib.rs

@@ -138,10 +138,14 @@ impl DynamicVirtualChannel {
         self.channel_id
     }
 
-    pub fn channel_processor_downcast_ref<T: DvcProcessor>(&self) -> Option<&T> {
+    pub fn channel_processor_downcast_ref<T: DvcClientProcessor>(&self) -> Option<&T> {
         self.channel_processor.as_any().downcast_ref()
     }
 
+    pub fn channel_processor_downcast_mut<T: DvcClientProcessor>(&mut self) -> Option<&mut T> {
+        self.channel_processor.as_any_mut().downcast_mut()
+    }
+
     fn start(&mut self, channel_id: DynamicChannelId) -> PduResult<Vec<DvcMessage>> {
         let messages = self.channel_processor.start(channel_id)?;
         self.channel_id = Some(channel_id);

crates/ironrdp-dvc/src/server.rs

@@ -186,6 +186,18 @@ impl DrdynvcServer {
             .ok_or_else(|| invalid_field_err!("DRDYNVC", "", "invalid channel id"))
     }
 
+    pub fn dvc_by_id<T: DvcServerProcessor>(&self, id: u32) -> Option<&T> {
+        self.dynamic_channels
+            .get(id)
+            .and_then(|w| w.processor.as_any().downcast_ref())
+    }
+
+    pub fn dvc_by_id_mut<T: DvcServerProcessor>(&mut self, id: u32) -> Option<&mut T> {
+        self.dynamic_channels
+            .get_mut(id)
+            .and_then(|c| c.processor.as_any_mut().downcast_mut())
+    }
+
     /// Creates a new DVC, returns CreateRequest PDU to send to client.
     ///
     /// # Panics