@@ -130,14 +130,9 @@ impl Indexer {
130130 let pricing_catalog = self . cached_pricing_catalog ( ) ;
131131 let now_millis = epoch_millis ( SystemTime :: now ( ) ) ?;
132132
133- let excluded = crate :: trash_state:: shared_deleted_ids ( ) ;
134133 let provider_refs = self . selected_providers ( filter) ;
135- let works = self . collect_provider_work (
136- & provider_refs,
137- pricing_catalog. as_ref ( ) ,
138- & excluded,
139- force_parse,
140- ) ?;
134+ let works =
135+ self . collect_provider_work ( & provider_refs, pricing_catalog. as_ref ( ) , force_parse) ?;
141136
142137 // Phase 2 (sequential, DB writer): commit each provider's snapshot.
143138 // SQLite has a single writer mutex; serializing here avoids contention
@@ -206,7 +201,6 @@ impl Indexer {
206201 & self ,
207202 providers : & [ & dyn SessionProvider ] ,
208203 pricing_catalog : Option < & PricingCatalog > ,
209- excluded : & HashSet < String > ,
210204 force_parse : bool ,
211205 ) -> ServiceResult < Vec < ProviderWork > > {
212206 // Phase 1 (parallel, CPU/IO): scan each provider's files and compute
@@ -215,17 +209,14 @@ impl Indexer {
215209 // scan), so providers don't share state and can run in parallel.
216210 providers
217211 . par_iter ( )
218- . map ( |provider| {
219- self . scan_provider_work ( * provider, pricing_catalog, excluded, force_parse)
220- } )
212+ . map ( |provider| self . scan_provider_work ( * provider, pricing_catalog, force_parse) )
221213 . collect ( )
222214 }
223215
224216 fn scan_provider_work (
225217 & self ,
226218 provider : & dyn SessionProvider ,
227219 pricing_catalog : Option < & PricingCatalog > ,
228- excluded : & HashSet < String > ,
229220 force_parse : bool ,
230221 ) -> ServiceResult < ProviderWork > {
231222 let provider_kind = provider. provider ( ) ;
@@ -250,13 +241,8 @@ impl Indexer {
250241 let outcome = provider. scan_incremental ( & known) . map_err ( |e| {
251242 ServiceError :: ScanProvider ( provider_kind. key ( ) . to_string ( ) , e. to_string ( ) )
252243 } ) ?;
253- let mut sessions = outcome. parsed ;
244+ let sessions = outcome. parsed ;
254245 let unchanged_source_paths = outcome. unchanged_source_paths ;
255-
256- if !excluded. is_empty ( ) {
257- sessions. retain ( |session| !excluded. contains ( & session. meta . id ) ) ;
258- }
259-
260246 let stats_batch = build_token_stats_batch ( provider, & sessions, pricing_catalog) ;
261247
262248 Ok ( ProviderWork {
@@ -319,7 +305,7 @@ impl Indexer {
319305 }
320306 self . db
321307 . set_meta ( "usage_last_refreshed_at" , & chrono:: Utc :: now ( ) . to_rfc3339 ( ) )
322- . map_err ( |e | ServiceError :: StoreUsageLastRefreshed ( e . to_string ( ) ) ) ?;
308+ . map_err ( |error | ServiceError :: StoreUsageLastRefreshed ( error . to_string ( ) ) ) ?;
323309 Ok ( ( ) )
324310 }
325311
0 commit comments