summaryrefslogtreecommitdiff
path: root/src/server.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/server.rs')
-rw-r--r--src/server.rs4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/server.rs b/src/server.rs
index 994d059..79c3226 100644
--- a/src/server.rs
+++ b/src/server.rs
@@ -141,7 +141,7 @@ fn import_strava(
tx: State<Mutex<Sender<importer::Command>>>,
user: LoggedInUser) -> Result<(), Error> {
let user = db::get_user(&*conn, &user.username)?;
- tx.lock().expect("FIX").send(importer::Command::ImportStravaUser(user));
+ tx.lock().expect("FIX").send(importer::Command::ImportStravaUser(user)).expect("FIX");
Ok(())
}
@@ -181,7 +181,7 @@ pub fn start(conn: diesel::PgConnection, db_url: &str, base_url: &str) {
.unwrap();
let importer_pool = ThreadPool::with_name("import".to_string(), importer::WORKERS);
- let tx = importer::run(importer_pool.clone());
+ let tx = importer::run(importer_pool.clone(), conn);
rocket::custom(config)
.manage(params)