+3 -3

flake.lock

reviewed

··· 322 322 "nixpkgs": "nixpkgs_3" 323 323 }, 324 324 "locked": { 325 325 - "lastModified": 1776647130, 326 326 - "narHash": "sha256-XCMjiqN2bvJ016q7JEW6tKOfk3pPrzPsACmbtSJPY50=", 325 325 + "lastModified": 1776647805, 326 326 + "narHash": "sha256-l+uoaWI8VKkvX+3Vxe4zGSt9iMB/mzSKs+OI2aOpOSI=", 327 327 "owner": "90-008", 328 328 "repo": "verbiage", 329 329 - "rev": "cf8cfa6e7cb4d9ab1fc4b5088c01235b09928850", 329 329 + "rev": "27021863f1c01358ee92c03a8b9c5ece42ba59d1", 330 330 "type": "github" 331 331 }, 332 332 "original": {

+1

flake.nix

reviewed

··· 13 13 { 14 14 pkgs, 15 15 config, 16 16 + inputs', 16 17 ... 17 18 }: 18 19 {

+6 -1

src/control/mod.rs

reviewed

··· 403 403 .expect("firehose shared already set"); 404 404 let fire_shared = firehose.shared.get().unwrap(); 405 405 406 406 + // add hosts from config 406 407 let relay_hosts = config.relays.clone(); 407 408 if !relay_hosts.is_empty() { 408 409 info!( ··· 425 426 } 426 427 } 427 428 429 429 + // add persisted hosts 428 430 let persisted_sources = tokio::task::spawn_blocking({ 429 431 let state = state.clone(); 430 432 move || load_persisted_firehose_sources(&state.db) 431 433 }) 432 434 .await 433 435 .into_diagnostic()??; 434 434 - 435 436 for source in &persisted_sources { 436 437 let _ = firehose 437 438 .known_sources ··· 444 445 .spawn_firehose_ingestor(source, fire_shared, true) 445 446 .await?; 446 447 } 448 448 + // we use spawn_firehose_ingestor directly here since we dont want 449 449 + // to go through the whole add_source machinery and checks 450 450 + // its ok since we block here before running stuff like seed_hosts 451 451 + // and whatnot 447 452 448 453 // 10c. seed firehose PDS sources from listHosts on configured seed URLs 449 454 if !config.seed_hosts.is_empty() {