From 16e519430a6b66478c437566577669d4beeeb523 Mon Sep 17 00:00:00 2001 From: dignifiedquire Date: Wed, 20 May 2020 18:38:53 +0200 Subject: [PATCH] fix(job): avoid double insertion --- src/job.rs | 15 --------------- 1 file changed, 15 deletions(-) diff --git a/src/job.rs b/src/job.rs index 43b795c54..7da9b6186 100644 --- a/src/job.rs +++ b/src/job.rs @@ -1018,23 +1018,8 @@ pub async fn add( return; } - let param_str = param.to_string(); let job = Job::new(action, foreign_id as u32, param, delay_seconds); job.save(context).await; - let timestamp = time(); - let thread: Thread = action.into(); - - context.sql.execute( - "INSERT INTO jobs (added_timestamp, thread, action, foreign_id, param, desired_timestamp) VALUES (?,?,?,?,?,?);", - paramsv![ - timestamp, - thread, - action, - foreign_id, - param_str, - (timestamp + delay_seconds as i64) - ] - ).await.ok(); if delay_seconds == 0 { match action {