add webmention support (#274)

* add webmention support

Signed-off-by: Christine Dodrill <me@christine.website>

* add webmention integration post

Signed-off-by: Christine Dodrill <me@christine.website>

1 files changed, 63 insertions, 0 deletions

diff --git a/lib/mi/src/lib.rs b/lib/mi/src/lib.rs
new file mode 100644
index 0000000..ec9d459
--- /dev/null
+++ b/lib/mi/src/lib.rs
@@ -0,0 +1,63 @@
+use color_eyre::eyre::Result;
+use reqwest::header;
+use serde::Deserialize;
+use tracing::instrument;
+
+const USER_AGENT_BASE: &str = concat!(
+    "library/",
+    env!("CARGO_PKG_NAME"),
+    "/",
+    env!("CARGO_PKG_VERSION")
+);
+
+pub struct Client {
+    cli: reqwest::Client,
+    base_url: String,
+}
+
+impl Client {
+    pub fn new(token: String, user_agent: String) -> Result<Self> {
+        let mut headers = header::HeaderMap::new();
+        headers.insert(
+            header::AUTHORIZATION,
+            header::HeaderValue::from_str(&token.clone())?,
+        );
+
+        let cli = reqwest::Client::builder()
+            .user_agent(&format!("{} {}", user_agent, USER_AGENT_BASE))
+            .default_headers(headers)
+            .build()?;
+
+        Ok(Self {
+            cli: cli,
+            base_url: "https://mi.within.website".to_string(),
+        })
+    }
+
+    #[instrument(skip(self))]
+    pub async fn mentioners(&self, url: String) -> Result<Vec<WebMention>> {
+        Ok(self
+            .cli
+            .get(&format!("{}/api/webmention/for", self.base_url))
+            .query(&[("target", &url)])
+            .send()
+            .await?
+            .error_for_status()?
+            .json()
+            .await?)
+    }
+}
+
+#[derive(Debug, Deserialize, Eq, PartialEq, Clone)]
+pub struct WebMention {
+    pub source: String,
+    pub title: Option<String>,
+}
+
+#[cfg(test)]
+mod tests {
+    #[test]
+    fn it_works() {
+        assert_eq!(2 + 2, 4);
+    }
+}