X-Git-Url: http://these/git/?a=blobdiff_plain;f=src%2Flib.rs;h=1bc00f70cf55b7cf24bef161c57a2c92041a805c;hb=45818fb4c50dc06f6909312bd034f68af92c3146;hp=b76dd106c18a6fa7b09c3a982c3e41ae3c816041;hpb=b214d3dc00c269d7987ace7f5522e2ff406eec03;p=lemmy.git diff --git a/src/lib.rs b/src/lib.rs index b76dd106..1bc00f70 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -121,23 +121,28 @@ pub async fn start_lemmy_server() -> Result<(), LemmyError> { .with(TracingMiddleware::default()) .build(); + let context = LemmyContext::create( + pool.clone(), + client.clone(), + secret.clone(), + rate_limit_cell.clone(), + ); + if scheduled_tasks_enabled { // Schedules various cleanup tasks for the DB - thread::spawn(move || { - scheduled_tasks::setup(db_url, user_agent).expect("Couldn't set up scheduled_tasks"); + thread::spawn({ + let context = context.clone(); + move || { + scheduled_tasks::setup(db_url, user_agent, context) + .expect("Couldn't set up scheduled_tasks"); + } }); } // Create Http server with websocket support let settings_bind = settings.clone(); HttpServer::new(move || { - let context = LemmyContext::create( - pool.clone(), - client.clone(), - secret.clone(), - rate_limit_cell.clone(), - ); - + let context = context.clone(); let federation_config = FederationConfig::builder() .domain(settings.hostname.clone()) .app_data(context.clone())