forked from kemitix/git-next
46 lines
1 KiB
Rust
46 lines
1 KiB
Rust
|
//
|
||
|
|
use actix::prelude::*;
|
||
|
|
|
||
|
|
use crate as config;
|
||
|
|
|
||
|
|
use std::collections::HashMap;
|
||
|
|
|
||
|
|
#[derive(Message, Debug, Clone, derive_more::Constructor)]
|
||
|
|
#[rtype(result = "()")]
|
||
|
|
pub struct WebhookMessage {
|
||
|
|
forge_alias: config::ForgeAlias,
|
||
|
|
repo_alias: config::RepoAlias,
|
||
|
|
headers: HashMap<String, String>,
|
||
|
|
body: Body,
|
||
|
|
}
|
||
|
|
impl WebhookMessage {
|
||
|
|
pub const fn forge_alias(&self) -> &config::ForgeAlias {
|
||
|
|
&self.forge_alias
|
||
|
|
}
|
||
|
|
pub const fn repo_alias(&self) -> &config::RepoAlias {
|
||
|
|
&self.repo_alias
|
||
|
|
}
|
||
|
|
pub const fn body(&self) -> &Body {
|
||
|
|
&self.body
|
||
|
|
}
|
||
|
|
#[deprecated]
|
||
|
|
pub const fn authorisation(&self) -> &config::WebhookAuth {
|
||
|
|
todo!()
|
||
|
|
}
|
||
|
|
pub fn header(&self, header: &str) -> Option<String> {
|
||
|
|
self.headers.get(header).map(|value| value.to_string())
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
#[derive(Clone, Debug, derive_more::Constructor)]
|
||
|
|
pub struct Body(String);
|
||
|
|
impl Body {
|
||
|
|
pub fn as_str(&self) -> &str {
|
||
|
|
self.0.as_str()
|
||
|
|
}
|
||
|
|
|
||
|
|
pub fn as_bytes(&self) -> &[u8] {
|
||
|
|
self.0.as_bytes()
|
||
|
|
}
|
||
|
|
}
|