From a7b4bc59be2fbdb9aa6b615eed98fca1c92df4fe Mon Sep 17 00:00:00 2001 From: asonix Date: Mon, 23 Mar 2020 22:43:45 -0500 Subject: [PATCH] Remove re-seed, it's been run in prod already --- src/data/actor.rs | 30 +----------------------------- src/main.rs | 4 ---- 2 files changed, 1 insertion(+), 33 deletions(-) diff --git a/src/data/actor.rs b/src/data/actor.rs index b0c7aa3..d69f773 100644 --- a/src/data/actor.rs +++ b/src/data/actor.rs @@ -1,6 +1,6 @@ use crate::{apub::AcceptedActors, db::Db, error::MyError, requests::Requests}; use activitystreams::primitives::XsdAnyUri; -use log::{error, info, warn}; +use log::error; use std::{collections::HashSet, sync::Arc, time::Duration}; use tokio::sync::RwLock; use ttl_cache::TtlCache; @@ -28,34 +28,6 @@ impl ActorCache { cache } - pub async fn re_seed( - &self, - listeners: &[XsdAnyUri], - requests: &Requests, - ) -> Result<(), MyError> { - info!("Seeding actors with {:?}", listeners); - for listener in listeners { - let mut listener = listener.clone(); - listener.as_url_mut().set_path("/actor"); - - let actor = match self.get(&listener, requests).await { - Ok(actor) => actor, - Err(e) => { - warn!("Couldn't seed {} due to {}, continuing", e, listener); - continue; - } - }; - - match self.save(actor).await { - Ok(_) => (), - Err(e) => { - warn!("Coudn't seed {} due to {}, continuing", listener, e); - } - } - } - Ok(()) - } - pub async fn is_following(&self, id: &XsdAnyUri) -> bool { self.following.read().await.contains(id) } diff --git a/src/main.rs b/src/main.rs index 2d5107d..9883404 100644 --- a/src/main.rs +++ b/src/main.rs @@ -66,10 +66,6 @@ async fn main() -> Result<(), anyhow::Error> { let actors = ActorCache::new(db.clone()); let job_server = create_server(db.clone()); - actors - .re_seed(&state.listeners().await, &state.requests()) - .await?; - notify::spawn(state.clone(), actors.clone(), job_server.clone(), &config)?; if args.jobs_only() {