mirror of
https://github.com/chatmail/core.git
synced 2026-05-09 01:46:30 +03:00
fix(job): avoid double insertion
This commit is contained in:
15
src/job.rs
15
src/job.rs
@@ -1018,23 +1018,8 @@ pub async fn add(
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
let param_str = param.to_string();
|
|
||||||
let job = Job::new(action, foreign_id as u32, param, delay_seconds);
|
let job = Job::new(action, foreign_id as u32, param, delay_seconds);
|
||||||
job.save(context).await;
|
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 {
|
if delay_seconds == 0 {
|
||||||
match action {
|
match action {
|
||||||
|
|||||||
Reference in New Issue
Block a user