From 6bb42bc259f6418bb41fefc83a28bdb5df9ecde3 Mon Sep 17 00:00:00 2001 From: Max Audron Date: Tue, 19 Dec 2023 15:34:35 +0100 Subject: implement bufferviewmanager/config init --- .../signalproxy/objects/bufferviewmanager.rs | 26 +++++++++++++++++++--- 1 file changed, 23 insertions(+), 3 deletions(-) (limited to 'src/message/signalproxy/objects/bufferviewmanager.rs') diff --git a/src/message/signalproxy/objects/bufferviewmanager.rs b/src/message/signalproxy/objects/bufferviewmanager.rs index 0ea30f7..50265dc 100644 --- a/src/message/signalproxy/objects/bufferviewmanager.rs +++ b/src/message/signalproxy/objects/bufferviewmanager.rs @@ -15,7 +15,7 @@ use super::BufferViewConfig; #[derive(Debug, Clone, PartialEq, Default)] pub struct BufferViewManager { - pub buffer_view_configs: HashMap, + pub buffer_view_configs: HashMap>, } // TODO initialize the BufferViewConfigs from somewhere @@ -67,6 +67,14 @@ impl BufferViewManager { #[cfg(feature = "server")] sync!("deleteBufferViewConfig", [id]) } + + pub fn init_buffer_view_config(&mut self, config: BufferViewConfig) { + if let Some(stored) = self.buffer_view_configs.get_mut(&config.buffer_view_id) { + *stored = Some(config); + } else { + self.buffer_view_configs.insert(config.buffer_view_id, Some(config)); + } + } } #[cfg(feature = "client")] @@ -137,10 +145,22 @@ impl super::NetworkList for BufferViewManager { return res; } - fn from_network_list(_input: &mut VariantList) -> Self { + fn from_network_list(input: &mut VariantList) -> Self { + let mut i = input.iter(); + i.position(|x| *x == Variant::ByteArray(String::from("BufferViewIds"))) + .expect(format!("failed to get field BufferViewIds").as_str()); + + let ids = match i.next().expect("failed to get next field") { + libquassel::primitive::Variant::VariantList(var) => var.clone(), + _ => panic!("network::list::from: wrong variant type"), + }; + // TODO Somehow do the initrequests for all the IDs we get here Self { - buffer_view_configs: HashMap::new(), + buffer_view_configs: ids + .into_iter() + .map(|id| (i32::try_from(id).unwrap(), Option::None)) + .collect(), } } } -- cgit v1.2.3