// Copyright (C) 2023-2099 The crate authors.
//
// This program is free software: you can redistribute it and/or modify it
// under the terms of the GNU Affero General Public License as published by the
// Free Software Foundation, either version 3 of the License, or (at your
// option) any later version.
//
// This program is distributed in the hope that it will be useful, but WITHOUT
// ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
// FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License
// for more details.
//
// You should have received a copy of the GNU Affero General Public License
// along with this program. If not, see .
pub use gitlab::webhooks::{IssueAction, MergeRequestAction, WebHook, WikiPageAction};
use log::debug;
pub fn format_webhook(wh: &WebHook) -> Option {
Some(match wh {
WebHook::Push(push) => {
if push.commits.len() != 0 {
let mut text = format!(
"[{}] {} pushed {} commits branch {}",
push.project.name,
push.user_name,
push.commits.len(),
push.ref_,
);
for commit in &push.commits {
match commit.message.lines().nth(0) {
Some(subject) => {
text = format!("{}\n• {} <{}>", text, subject, commit.url);
}
None => {}
}
}
text
} else {
format!(
"[{}] {} deleted branch {}",
push.project.name, push.user_name, push.ref_,
)
}
}
WebHook::Issue(issue) => {
let action = match issue.object_attributes.action {
Some(IssueAction::Update) => "updated",
Some(IssueAction::Open) => "opened",
Some(IssueAction::Close) => "closed",
Some(IssueAction::Reopen) => "reopened",
None => return None,
};
format!(
"[{}] {} {} issue {}: {}{}",
issue.project.name,
issue.user.name,
action,
issue.object_attributes.iid,
issue.object_attributes.title,
issue
.object_attributes
.url
.as_ref()
.map(|url| format!(" <{}>", url))
.unwrap_or("".to_owned())
)
}
WebHook::MergeRequest(merge_req) => {
let action = match merge_req.object_attributes.action {
Some(MergeRequestAction::Update) => "updated",
Some(MergeRequestAction::Open) => "opened",
Some(MergeRequestAction::Close) => "closed",
Some(MergeRequestAction::Reopen) => "reopened",
Some(MergeRequestAction::Merge) => "merged",
None => return None,
_ => todo!(),
};
format!(
"[{}] {} {} merge request {}: {}{}",
merge_req.project.name,
merge_req.user.name,
action,
merge_req.object_attributes.iid,
merge_req.object_attributes.title,
merge_req
.object_attributes
.url
.as_ref()
.map(|url| format!(" <{}>", url))
.unwrap_or("".to_owned())
)
}
WebHook::Note(note) => {
if let Some(_) = note.snippet {
return None;
}
if let Some(commit) = ¬e.commit {
format!(
"[{}] {} commented on commit {:?} <{}>",
note.project.name, note.user.name, commit.id, commit.url,
)
} else if let Some(issue) = ¬e.issue {
format!(
"[{}] {} commented on issue {}: {} <{}>",
note.project.name,
note.user.name,
issue.iid,
issue.title,
note.object_attributes.url,
)
} else if let Some(mr) = ¬e.merge_request {
format!(
"[{}] {} commented on merge request {}: {} <{}>",
note.project.name, note.user.name, mr.iid, mr.title, note.object_attributes.url,
)
} else {
unreachable!()
}
}
WebHook::Build(build) => {
println!("Build: {:?}", build);
return None;
}
WebHook::WikiPage(page) => {
let action = match page.object_attributes.action {
WikiPageAction::Update => "updated",
WikiPageAction::Create => "created",
};
format!(
"[{}] {} {} wiki page {} <{}>",
page.project.name,
page.user.name,
action,
page.object_attributes.title,
page.object_attributes.url,
)
}
_wh => {
debug!("Webhook not supported");
return None;
}
})
}