do not index sessions twice when fetching

This commit is contained in:
Nikita Galaiko 2023-05-17 14:27:22 +02:00
parent e083922114
commit fc32525d85
2 changed files with 1 additions and 17 deletions

View File

@ -2,17 +2,13 @@ use std::time;
use anyhow::{Context, Result};
use crate::{
app::{gb_repository, search},
projects,
};
use crate::{app::gb_repository, projects};
use super::events;
pub struct Handler<'handler> {
project_id: String,
project_storage: projects::Storage,
deltas_searcher: search::Deltas,
gb_repository: &'handler gb_repository::Repository,
}
@ -20,13 +16,11 @@ impl<'handler> Handler<'handler> {
pub fn new(
project_id: String,
project_storage: projects::Storage,
deltas_searcher: search::Deltas,
gb_repository: &'handler gb_repository::Repository,
) -> Self {
Self {
project_id,
project_storage,
deltas_searcher,
gb_repository,
}
}
@ -67,15 +61,6 @@ impl<'handler> Handler<'handler> {
.filter(|s| !sessions_before_fetch.contains(s))
.collect::<Vec<_>>();
for session in &new_sessions {
if let Err(e) = self
.deltas_searcher
.index_session(&self.gb_repository, &session)
{
log::error!("{}: failed to index session: {:#}", self.project_id, e);
}
}
let events = new_sessions
.into_iter()
.cloned()

View File

@ -70,7 +70,6 @@ impl<'handler> Handler<'handler> {
fetch_project_handler: fetch_project::Handler::new(
project_id.clone(),
project_store.clone(),
searcher.clone(),
gb_repository,
),
chech_fetch_project_handler: check_fetch_project::Handler::new(