webmention 0.6.0

Library and a CLI tool for sending and validation webmentions
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

use crate::error::WebmentionError;
use crate::webmention::Webmention;

use crate::wm_url::Url;
use std::sync::{Arc, Mutex};

pub trait WebmentionStorage {
    fn store(&self, webmention: Webmention) -> Result<(), WebmentionError>;
    fn lookup_by_target(&self, target: Url) -> Result<Vec<Webmention>, WebmentionError>;
}

#[derive(Debug)]
pub struct InMemoryWebmentionStorage {
    mentions: Arc<Mutex<Vec<Webmention>>>,
}

impl InMemoryWebmentionStorage {
    pub fn new() -> InMemoryWebmentionStorage {
        InMemoryWebmentionStorage {
            mentions: Arc::new(Mutex::new(Vec::new())),
        }
    }
}

impl WebmentionStorage for InMemoryWebmentionStorage {
    fn store(&self, mention: Webmention) -> Result<(), WebmentionError> {
        {
            let mut lock = self.mentions.lock().unwrap();
            lock.push(mention);
        }
        Ok(())
    }

    fn lookup_by_target(&self, url: Url) -> Result<Vec<Webmention>, WebmentionError> {
        let mut view: Vec<Webmention> = Vec::new();
        let lock = self.mentions.lock().unwrap();
        for mention in lock.iter() {
            if mention.target.eq(&url) {
                view.push(mention.clone());
            }
        }
        Ok(view)
    }
}