add switchcounter client

backend/.gitignore

@@ -0,0 +1 @@
+Rocket.toml

backend/Cargo.toml

@@ -40,5 +40,4 @@ features = ["sqlite", "r2d2", "uuidv07", "chrono"]
 [dependencies.rocket_contrib]
 version = "0.4"
 default-features = false
-features = ["json", "diesel_sqlite_pool", "uuid", "helmet"]
+features = ["json", "diesel_sqlite_pool", "uuid", "helmet"]
-

backend/src/main.rs

@@ -19,6 +19,7 @@ const APPLICATION_NAME: &str = concat!(env!("CARGO_PKG_NAME"), "/", env!("CARGO_
 pub mod api;
 pub mod models;
 pub mod schema;
+pub mod web;
 
 #[database("main_data")]
 pub struct MainDatabase(SqliteConnection);
@@ -35,6 +36,7 @@ fn main() -> Result<()> {
         .attach(prometheus.clone())
         .attach(MainDatabase::fairing())
         .attach(SpaceHelmet::default())
+        .attach(web::switchcounter::Client::fairing())
         .mount("/metrics", prometheus)
         .mount(
             "/",

backend/src/web/mod.rs

@@ -0,0 +1 @@
+pub mod switchcounter;

backend/src/web/switchcounter.rs

@@ -0,0 +1,72 @@
+use color_eyre::eyre::{eyre, Result};
+use rocket::fairing::AdHoc;
+use serde::{Deserialize, Serialize};
+
+#[derive(Serialize, Debug)]
+pub struct FrontAsk {
+    pub command: String,
+}
+
+impl Default for FrontAsk {
+    fn default() -> Self {
+        FrontAsk {
+            command: "switch".to_string(),
+        }
+    }
+}
+
+#[derive(Serialize, Debug)]
+pub struct SwitchCommand {
+    pub command: String,
+    pub member_name: String,
+}
+
+#[derive(Deserialize, Debug)]
+pub struct Status {
+    pub member_name: String,
+    pub started_at: chrono::NaiveDateTime,
+}
+
+pub struct Client {
+    webhook_url: String,
+}
+
+impl Client {
+    pub fn new(webhook_url: String) -> Self {
+        Client {
+            webhook_url: webhook_url,
+        }
+    }
+
+    pub fn fairing() -> AdHoc {
+        AdHoc::on_attach("Switch Counter API", |rocket| {
+            let webhook_url = rocket.config().get_string("switchcounter_webhook").unwrap();
+            Ok(rocket.manage(Client::new(webhook_url)))
+        })
+    }
+
+    #[instrument(err, skip(self))]
+    pub fn status(&self) -> Result<Status> {
+        let resp =
+            ureq::post(&self.webhook_url).send_json(serde_json::to_value(FrontAsk::default())?);
+        if resp.ok() {
+            Ok(resp.into_json_deserialize()?)
+        } else {
+            Err(eyre!("{}", resp.status_line()))
+        }
+    }
+
+    #[instrument(err, skip(self))]
+    pub fn switch(&self, member_name: String) -> Result<Status> {
+        let resp = ureq::post(&self.webhook_url).send_json(serde_json::to_value(SwitchCommand {
+            command: "switch".to_string(),
+            member_name: member_name,
+        })?);
+
+        if resp.ok() {
+            Ok(resp.into_json_deserialize()?)
+        } else {
+            Err(eyre!("{}", resp.status_line()))
+        }
+    }
+}