musket 0.22.0

Musket is a command line interface to send a URL to several destinations.
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
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68

use super::{Destination, DestinationError};
use megalodon::{entities::StatusVisibility, generator, megalodon::PostStatusInputOptions};
use serde::{Deserialize, Serialize};
use tracing::debug;

#[derive(Clone, Default, Serialize, Deserialize)]
pub struct MastodonConfiguration {
    pub server: String,
    pub token: String,
    pub commentary: String,
    pub language: String,
    pub enabled: bool,
}
pub struct Mastodon {
    pub configuration: MastodonConfiguration,
    pub url: String,
    pub tags: Vec<String>,
    pub commentary: String,
    pub language: String,
}

impl From<megalodon::error::Error> for DestinationError {
    fn from(e: megalodon::error::Error) -> Self {
        DestinationError::Mastodon {
            message: format!("The url cannot be sent to Mastodon due to {e}."),
        }
    }
}

impl Destination for Mastodon {
    async fn fire(&self) -> Result<(), DestinationError> {
        debug!("Inside fire function. Mastodon destination");

        match generator(
            megalodon::SNS::Mastodon,
            self.configuration.server.clone(),
            Some(self.configuration.token.clone()),
            Some(String::from("Musket")),
        ) {
            Err(e) => {
                return Err(DestinationError::Mastodon {
                    message: format!("The url cannot be sent to Mastodon due to {e}."),
                });
            }
            Ok(mastodon_client) => {
                let mut status_content = format!("{}\n{}", self.commentary, self.url);

                if !self.tags.is_empty() {
                    let tags_joined = self.tags.join(", #");
                    status_content = format!("{}\n#{}", status_content, &tags_joined);
                }

                mastodon_client
                    .post_status(
                        status_content,
                        Some(&PostStatusInputOptions {
                            visibility: Some(StatusVisibility::Public),
                            language: Some(self.language.clone()),
                            ..Default::default()
                        }),
                    )
                    .await?;
            }
        }

        Ok(())
    }
}