@@ -355,56 +355,8 @@ async def try_backfill(domains: List[str]) -> bool:
355
355
if success :
356
356
return True
357
357
358
- # Huh, well *those* domains didn't work out. Lets try some domains
359
- # from the time.
360
-
361
- tried_domains = set (likely_domains )
362
- tried_domains .add (self .server_name )
363
-
364
- event_ids = list (extremities .keys ())
365
-
366
- logger .debug ("calling resolve_state_groups in _maybe_backfill" )
367
- resolve = preserve_fn (self .state_handler .resolve_state_groups_for_events )
368
- states_list = await make_deferred_yieldable (
369
- defer .gatherResults (
370
- [resolve (room_id , [e ]) for e in event_ids ], consumeErrors = True
371
- )
372
- )
373
-
374
- # A map from event_id to state map of event_ids.
375
- state_ids : Dict [str , StateMap [str ]] = dict (
376
- zip (event_ids , [s .state for s in states_list ])
377
- )
378
-
379
- state_map = await self .store .get_events (
380
- [e_id for ids in state_ids .values () for e_id in ids .values ()],
381
- get_prev_content = False ,
382
- )
383
-
384
- # A map from event_id to state map of events.
385
- state_events : Dict [str , StateMap [EventBase ]] = {
386
- key : {
387
- k : state_map [e_id ]
388
- for k , e_id in state_dict .items ()
389
- if e_id in state_map
390
- }
391
- for key , state_dict in state_ids .items ()
392
- }
393
-
394
- for e_id in event_ids :
395
- likely_extremeties_domains = get_domains_from_state (state_events [e_id ])
396
-
397
- success = await try_backfill (
398
- [
399
- dom
400
- for dom , _ in likely_extremeties_domains
401
- if dom not in tried_domains
402
- ]
403
- )
404
- if success :
405
- return True
406
-
407
- tried_domains .update (dom for dom , _ in likely_extremeties_domains )
358
+ # TODO: we could also try servers which were previously in the room, but
359
+ # are no longer.
408
360
409
361
return False
410
362
0 commit comments