make TimelineCache::timelines private
Signed-off-by: kernelkind <kernelkind@gmail.com>
This commit is contained in:
@@ -242,9 +242,9 @@ mod tests {
|
|||||||
.timeline_id()
|
.timeline_id()
|
||||||
.unwrap();
|
.unwrap();
|
||||||
|
|
||||||
assert_eq!(app.timeline_cache.timelines.len(), 2);
|
assert_eq!(app.timeline_cache.num_timelines(), 2);
|
||||||
assert!(app.timeline_cache.timelines.get(&tl1).is_some());
|
assert!(app.timeline_cache.get(&tl1).is_some());
|
||||||
assert!(app.timeline_cache.timelines.get(&tl2).is_some());
|
assert!(app.timeline_cache.get(&tl2).is_some());
|
||||||
|
|
||||||
rmrf(tmpdir);
|
rmrf(tmpdir);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -281,7 +281,7 @@ impl NewNotes {
|
|||||||
) {
|
) {
|
||||||
let reversed = false;
|
let reversed = false;
|
||||||
|
|
||||||
let timeline = if let Some(profile) = timeline_cache.timelines.get_mut(&self.id) {
|
let timeline = if let Some(profile) = timeline_cache.get_mut(&self.id) {
|
||||||
profile
|
profile
|
||||||
} else {
|
} else {
|
||||||
error!("NewNotes: could not get timeline for key {}", self.id);
|
error!("NewNotes: could not get timeline for key {}", self.id);
|
||||||
|
|||||||
@@ -130,7 +130,7 @@ fn try_process_event(
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
for (_kind, timeline) in damus.timeline_cache.timelines.iter_mut() {
|
for (_kind, timeline) in &mut damus.timeline_cache {
|
||||||
let is_ready = timeline::is_timeline_ready(
|
let is_ready = timeline::is_timeline_ready(
|
||||||
app_ctx.ndb,
|
app_ctx.ndb,
|
||||||
app_ctx.pool,
|
app_ctx.pool,
|
||||||
@@ -252,7 +252,7 @@ fn handle_eose(
|
|||||||
}
|
}
|
||||||
|
|
||||||
SubKind::FetchingContactList(timeline_uid) => {
|
SubKind::FetchingContactList(timeline_uid) => {
|
||||||
let timeline = if let Some(tl) = timeline_cache.timelines.get_mut(timeline_uid) {
|
let timeline = if let Some(tl) = timeline_cache.get_mut(timeline_uid) {
|
||||||
tl
|
tl
|
||||||
} else {
|
} else {
|
||||||
error!(
|
error!(
|
||||||
|
|||||||
@@ -123,11 +123,8 @@ impl Columns {
|
|||||||
.map(|r| match r {
|
.map(|r| match r {
|
||||||
IntermediaryRoute::Timeline(mut timeline) => {
|
IntermediaryRoute::Timeline(mut timeline) => {
|
||||||
let route = Route::timeline(timeline.kind.clone());
|
let route = Route::timeline(timeline.kind.clone());
|
||||||
|
|
||||||
timeline.subscription.increment();
|
timeline.subscription.increment();
|
||||||
timeline_cache
|
timeline_cache.insert(timeline.kind.clone(), timeline);
|
||||||
.timelines
|
|
||||||
.insert(timeline.kind.clone(), timeline);
|
|
||||||
route
|
route
|
||||||
}
|
}
|
||||||
IntermediaryRoute::Route(route) => route,
|
IntermediaryRoute::Route(route) => route,
|
||||||
|
|||||||
@@ -13,7 +13,7 @@ use tracing::{debug, error, info, warn};
|
|||||||
|
|
||||||
#[derive(Default)]
|
#[derive(Default)]
|
||||||
pub struct TimelineCache {
|
pub struct TimelineCache {
|
||||||
pub timelines: HashMap<TimelineKind, Timeline>,
|
timelines: HashMap<TimelineKind, Timeline>,
|
||||||
}
|
}
|
||||||
|
|
||||||
pub enum Vitality<'a, M> {
|
pub enum Vitality<'a, M> {
|
||||||
|
|||||||
@@ -504,7 +504,7 @@ pub fn send_initial_timeline_filters(
|
|||||||
info!("Sending initial filters to {}", relay_id);
|
info!("Sending initial filters to {}", relay_id);
|
||||||
let relay = &mut pool.relays.iter_mut().find(|r| r.url() == relay_id)?;
|
let relay = &mut pool.relays.iter_mut().find(|r| r.url() == relay_id)?;
|
||||||
|
|
||||||
for (_kind, timeline) in timeline_cache.timelines.iter_mut() {
|
for (_kind, timeline) in timeline_cache {
|
||||||
send_initial_timeline_filter(since_optimize, subs, relay, timeline, accounts);
|
send_initial_timeline_filter(since_optimize, subs, relay, timeline, accounts);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -644,7 +644,7 @@ pub fn setup_initial_nostrdb_subs(
|
|||||||
note_cache: &mut NoteCache,
|
note_cache: &mut NoteCache,
|
||||||
timeline_cache: &mut TimelineCache,
|
timeline_cache: &mut TimelineCache,
|
||||||
) -> Result<()> {
|
) -> Result<()> {
|
||||||
for (_kind, timeline) in timeline_cache.timelines.iter_mut() {
|
for (_kind, timeline) in timeline_cache {
|
||||||
let txn = Transaction::new(ndb).expect("txn");
|
let txn = Transaction::new(ndb).expect("txn");
|
||||||
if let Err(err) = setup_timeline_nostrdb_sub(ndb, &txn, note_cache, timeline) {
|
if let Err(err) = setup_timeline_nostrdb_sub(ndb, &txn, note_cache, timeline) {
|
||||||
error!("setup_initial_nostrdb_subs: {err}");
|
error!("setup_initial_nostrdb_subs: {err}");
|
||||||
|
|||||||
@@ -632,9 +632,7 @@ pub fn render_add_column_routes(
|
|||||||
.router_mut()
|
.router_mut()
|
||||||
.route_to_replaced(Route::timeline(timeline.kind.clone()));
|
.route_to_replaced(Route::timeline(timeline.kind.clone()));
|
||||||
|
|
||||||
app.timeline_cache
|
app.timeline_cache.insert(timeline.kind.clone(), timeline);
|
||||||
.timelines
|
|
||||||
.insert(timeline.kind.clone(), timeline);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
AddColumnResponse::Algo(algo_option) => match algo_option {
|
AddColumnResponse::Algo(algo_option) => match algo_option {
|
||||||
@@ -674,9 +672,7 @@ pub fn render_add_column_routes(
|
|||||||
.router_mut()
|
.router_mut()
|
||||||
.route_to_replaced(Route::timeline(timeline.kind.clone()));
|
.route_to_replaced(Route::timeline(timeline.kind.clone()));
|
||||||
|
|
||||||
app.timeline_cache
|
app.timeline_cache.insert(timeline.kind.clone(), timeline);
|
||||||
.timelines
|
|
||||||
.insert(timeline.kind.clone(), timeline);
|
|
||||||
} else {
|
} else {
|
||||||
// we couldn't fetch the timeline yet... let's let
|
// we couldn't fetch the timeline yet... let's let
|
||||||
// the user know ?
|
// the user know ?
|
||||||
|
|||||||
@@ -94,7 +94,7 @@ fn timeline_ui(
|
|||||||
*/
|
*/
|
||||||
|
|
||||||
let scroll_id = {
|
let scroll_id = {
|
||||||
let timeline = if let Some(timeline) = timeline_cache.timelines.get_mut(timeline_id) {
|
let timeline = if let Some(timeline) = timeline_cache.get_mut(timeline_id) {
|
||||||
timeline
|
timeline
|
||||||
} else {
|
} else {
|
||||||
error!("tried to render timeline in column, but timeline was missing");
|
error!("tried to render timeline in column, but timeline was missing");
|
||||||
@@ -154,7 +154,7 @@ fn timeline_ui(
|
|||||||
}
|
}
|
||||||
|
|
||||||
let scroll_output = scroll_area.show(ui, |ui| {
|
let scroll_output = scroll_area.show(ui, |ui| {
|
||||||
let timeline = if let Some(timeline) = timeline_cache.timelines.get(timeline_id) {
|
let timeline = if let Some(timeline) = timeline_cache.get(timeline_id) {
|
||||||
timeline
|
timeline
|
||||||
} else {
|
} else {
|
||||||
error!("tried to render timeline in column, but timeline was missing");
|
error!("tried to render timeline in column, but timeline was missing");
|
||||||
|
|||||||
Reference in New Issue
Block a user