Yehowshua/ZIm
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Render the DAG

Browse source
This commit is contained in:
Mikayla 2023-09-08 18:47:59 -07:00
parent 3a62d2988a
commit 8222102d01
No known key found for this signature in database
4 changed files with 227 additions and 123 deletions
Download patch file Download diff file Expand all files Collapse all files

14
crates/channel/src/channel_store.rs
View file

@ -11,6 +11,7 @@ use std::{mem, sync::Arc, time::Duration};
use util::ResultExt;
use self::channel_index::ChannelIndex;
pub use self::channel_index::ChannelPath;
pub const RECONNECT_TIMEOUT: Duration = Duration::from_secs(30);
@ -145,11 +146,13 @@ impl ChannelStore {
})
}
pub fn channel_at_index(&self, ix: usize) -> Option<(usize, &Arc<Channel>)> {
pub fn channel_at_index(&self, ix: usize) -> Option<(usize, &Arc<Channel>, &Arc<[ChannelId]>)> {
let path = self.channel_index.get(ix)?;
let id = path.last().unwrap();
let channel = self.channel_for_id(*id).unwrap();
Some((path.len() - 1, channel))
Some((path.len() - 1, channel, path))
}
pub fn channel_invitations(&self) -> &[Arc<Channel>] {
@ -734,12 +737,15 @@ impl ChannelStore {
}
}
self.channel_index.insert_channels(payload.channels);
let mut channel_index = self.channel_index.start_upsert();
for channel in payload.channels {
channel_index.upsert(channel)
}
}
for edge in payload.delete_channel_edge {
self.channel_index
.remove_edge(edge.parent_id, edge.channel_id);
.delete_edge(edge.parent_id, edge.channel_id);
}
for permission in payload.channel_permissions {