diff options
| -rw-r--r-- | src/graphql/types/alert.rs | 35 |
1 files changed, 35 insertions, 0 deletions
diff --git a/src/graphql/types/alert.rs b/src/graphql/types/alert.rs index cce2bee..9b71188 100644 --- a/src/graphql/types/alert.rs +++ b/src/graphql/types/alert.rs @@ -180,6 +180,41 @@ pub mod mutations { return Err(AppError::BadRequest("Polygon is not valid".to_string()).into()); } + // This is like a cache system to avoid multiple alerts for the same area within 10 + // minutes of interval + if let Some(previous_alert) = client.query( + &format!( + "SELECT + id, user_id, extract(epoch from created_at)::double precision as created_at, + ST_AsText(area) as area, + ST_AsText(ST_Buffer(area::geography, 1000)) as area_level2, + ST_AsText(ST_Buffer(area::geography, 2000)) as area_level3, + text1, text2, text3, + reached_users + FROM alerts WHERE area = {} AND created_at >= NOW() - INTERVAL '10 MINUTE'", + polygon + ), + &[] + ).await? + .iter() + .map(|row| Alert { + id: row.get("id"), + user_id: row.get("user_id"), + created_at: row.get::<_, f64>("created_at") as i64, + area: row.get("area"), + area_level2: row.get("area_level2"), + area_level3: row.get("area_level3"), + text1: row.get("text1"), + text2: row.get("text2"), + text3: row.get("text3"), + reached_users: row.get("reached_users"), + }) + .collect::<Vec<Alert>>() + .first() + .cloned() { + return Ok(previous_alert); + } + let insert_query = format!( "INSERT INTO alerts (user_id, area, text1, text2, text3) VALUES($1, {}, $2, $3, $4) |