From dcde6edba425b2b0328144bbd8eb06e5250a54dd Mon Sep 17 00:00:00 2001 From: Brandon Thomas Date: Fri, 18 Feb 2022 17:17:46 -0500 Subject: [PATCH] delete twitch event rule --- .../src/api_tokens/delete_api_token.rs | 2 -- ...nt_rule.rs => create_twitch_event_rule.rs} | 0 .../delete_twitch_event_rule.rs | 33 +++++++++++++++++++ .../src/twitch_event_rules/mod.rs | 3 +- 4 files changed, 35 insertions(+), 3 deletions(-) rename crates/lib/database_queries/src/twitch_event_rules/{create_event_rule.rs => create_twitch_event_rule.rs} (100%) create mode 100644 crates/lib/database_queries/src/twitch_event_rules/delete_twitch_event_rule.rs diff --git a/crates/lib/database_queries/src/api_tokens/delete_api_token.rs b/crates/lib/database_queries/src/api_tokens/delete_api_token.rs index 3c224b35b6..dc1e2d00de 100644 --- a/crates/lib/database_queries/src/api_tokens/delete_api_token.rs +++ b/crates/lib/database_queries/src/api_tokens/delete_api_token.rs @@ -1,8 +1,6 @@ use anyhow::anyhow; use container_common::anyhow_result::AnyhowResult; -use log::warn; use sqlx::MySqlPool; -use std::collections::{HashSet, HashMap}; pub async fn delete_api_token( user_token: &str, diff --git a/crates/lib/database_queries/src/twitch_event_rules/create_event_rule.rs b/crates/lib/database_queries/src/twitch_event_rules/create_twitch_event_rule.rs similarity index 100% rename from crates/lib/database_queries/src/twitch_event_rules/create_event_rule.rs rename to crates/lib/database_queries/src/twitch_event_rules/create_twitch_event_rule.rs diff --git a/crates/lib/database_queries/src/twitch_event_rules/delete_twitch_event_rule.rs b/crates/lib/database_queries/src/twitch_event_rules/delete_twitch_event_rule.rs new file mode 100644 index 0000000000..18e890424c --- /dev/null +++ b/crates/lib/database_queries/src/twitch_event_rules/delete_twitch_event_rule.rs @@ -0,0 +1,33 @@ +use anyhow::anyhow; +use container_common::anyhow_result::AnyhowResult; +use sqlx::MySqlPool; + +pub async fn delete_twitch_event_rule( + event_rule_token: &str, + ip_address_delete: &str, + mysql_pool: &MySqlPool +) -> AnyhowResult { + + let query = sqlx::query!( + r#" +UPDATE twitch_event_rules +SET + deleted_at = CURRENT_TIMESTAMP, + ip_address_last_update = ? +WHERE + token = ? +LIMIT 1 + "#, + ip_address_delete, + event_rule_token, + ); + + let result = query.execute(mysql_pool).await; + + match result { + Err(err) => { + Err(anyhow!("error with query: {:?}", err)) + }, + Ok(results) => Ok(true), + } +} diff --git a/crates/lib/database_queries/src/twitch_event_rules/mod.rs b/crates/lib/database_queries/src/twitch_event_rules/mod.rs index 690e3110f8..e73b7171ad 100644 --- a/crates/lib/database_queries/src/twitch_event_rules/mod.rs +++ b/crates/lib/database_queries/src/twitch_event_rules/mod.rs @@ -1 +1,2 @@ -pub mod create_event_rule; \ No newline at end of file +pub mod create_twitch_event_rule; +pub mod delete_twitch_event_rule; \ No newline at end of file