Also 'cargo clippy --fix', as current clippy warns on more things.
This commit is contained in:
3286
Cargo.lock
generated
3286
Cargo.lock
generated
File diff suppressed because it is too large
Load Diff
12
Cargo.toml
12
Cargo.toml
@@ -25,16 +25,16 @@ exclude = [
|
|||||||
[dependencies]
|
[dependencies]
|
||||||
anyhow = "1"
|
anyhow = "1"
|
||||||
chrono = { version = "0.4", features = ["serde"] }
|
chrono = { version = "0.4", features = ["serde"] }
|
||||||
constant_time_eq = "0.3"
|
constant_time_eq = "0.4"
|
||||||
dateparser = "0.2"
|
dateparser = "0.2"
|
||||||
env_logger = "0.10"
|
env_logger = "0.11"
|
||||||
futures = "0.3"
|
futures = "0.3"
|
||||||
http = "0.2"
|
http = "1.3"
|
||||||
log = { version = "0.4", features = ["std"] }
|
log = { version = "0.4", features = ["std"] }
|
||||||
matrix-sdk = { version = "0.6", features = ["anyhow", "markdown", "rustls-tls"], default-features = false }
|
matrix-sdk = { version = "0.13", features = ["anyhow", "markdown", "rustls-tls"], default-features = false }
|
||||||
quick-xml = { version = "0.30", features = ["serialize"] }
|
quick-xml = { version = "0.38", features = ["serialize"] }
|
||||||
regex = "1"
|
regex = "1"
|
||||||
reqwest = { version = "0.11", default-features = false, features = ["tokio-rustls", "rustls-tls-native-roots", "gzip"] }
|
reqwest = { version = "0.12", default-features = false, features = ["charset", "http2", "gzip", "rustls-tls-native-roots", "system-proxy"] }
|
||||||
serde = { version = "1", features = ["derive"] }
|
serde = { version = "1", features = ["derive"] }
|
||||||
serde_json = "1"
|
serde_json = "1"
|
||||||
serde_regex = "1"
|
serde_regex = "1"
|
||||||
|
@@ -105,7 +105,7 @@ fn load_blocking(path: &String) -> anyhow::Result<Config> {
|
|||||||
pub async fn load<S: AsRef<str>>(path: S) -> anyhow::Result<Config> {
|
pub async fn load<S: AsRef<str>>(path: S) -> anyhow::Result<Config> {
|
||||||
let p = String::from(path.as_ref());
|
let p = String::from(path.as_ref());
|
||||||
let config = tokio::task::spawn_blocking(move || {
|
let config = tokio::task::spawn_blocking(move || {
|
||||||
load_blocking(&p).with_context(|| format!("Failed to load config from {}", p))
|
load_blocking(&p).with_context(|| format!("Failed to load config from {p}"))
|
||||||
})
|
})
|
||||||
.await??;
|
.await??;
|
||||||
Ok(config)
|
Ok(config)
|
||||||
|
@@ -14,6 +14,8 @@
|
|||||||
// You should have received a copy of the GNU General Public License
|
// You should have received a copy of the GNU General Public License
|
||||||
// along with this program. If not, see <http://www.gnu.org/licenses/>.
|
// along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||||
|
|
||||||
|
#![allow(unused)]
|
||||||
|
|
||||||
use core::fmt;
|
use core::fmt;
|
||||||
|
|
||||||
use crate::config::PublishEvent;
|
use crate::config::PublishEvent;
|
||||||
@@ -281,7 +283,7 @@ impl GitlabEventExt for GitlabEvent {
|
|||||||
false
|
false
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
GitlabEvent::TagPush { .. } => find_publish_event!(publish_events, PublishEvent::TagPush { .. }).is_some(),
|
GitlabEvent::TagPush { .. } => find_publish_event!(publish_events, PublishEvent::TagPush).is_some(),
|
||||||
GitlabEvent::Issue { object_attributes, .. } => {
|
GitlabEvent::Issue { object_attributes, .. } => {
|
||||||
if let Some(PublishEvent::Issues { actions }) =
|
if let Some(PublishEvent::Issues { actions }) =
|
||||||
find_publish_event!(publish_events, PublishEvent::Issues { .. })
|
find_publish_event!(publish_events, PublishEvent::Issues { .. })
|
||||||
@@ -437,7 +439,7 @@ impl GitlabEventExt for GitlabEvent {
|
|||||||
.or(merge_request.as_ref().map(|mr| mr.title.clone()))
|
.or(merge_request.as_ref().map(|mr| mr.title.clone()))
|
||||||
.iter()
|
.iter()
|
||||||
.fold(format!("Pipeline **{}**", object_attributes.status), |accum, title| {
|
.fold(format!("Pipeline **{}**", object_attributes.status), |accum, title| {
|
||||||
format!("{}: {}", accum, title)
|
format!("{accum}: {title}")
|
||||||
});
|
});
|
||||||
vec![markdown_link(&title, &object_attributes.url)]
|
vec![markdown_link(&title, &object_attributes.url)]
|
||||||
} else {
|
} else {
|
||||||
@@ -451,7 +453,7 @@ impl GitlabEventExt for GitlabEvent {
|
|||||||
|
|
||||||
#[inline]
|
#[inline]
|
||||||
fn markdown_link(title: &String, url: &String) -> String {
|
fn markdown_link(title: &String, url: &String) -> String {
|
||||||
format!("[{}]({})", title, url)
|
format!("[{title}]({url})")
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn parse_ref(r#ref: &str) -> String {
|
pub fn parse_ref(r#ref: &str) -> String {
|
||||||
|
@@ -17,13 +17,12 @@
|
|||||||
use std::sync::Arc;
|
use std::sync::Arc;
|
||||||
|
|
||||||
use constant_time_eq::constant_time_eq;
|
use constant_time_eq::constant_time_eq;
|
||||||
use http::StatusCode;
|
|
||||||
use matrix_sdk::{
|
use matrix_sdk::{
|
||||||
ruma::{events::room::message::RoomMessageEventContent, OwnedRoomOrAliasId},
|
ruma::{events::room::message::RoomMessageEventContent, OwnedRoomOrAliasId},
|
||||||
Client,
|
Client,
|
||||||
};
|
};
|
||||||
use tokio::sync::mpsc;
|
use tokio::sync::mpsc;
|
||||||
use warp::{filters::BoxedFilter, reply::Reply, Filter};
|
use warp::{filters::BoxedFilter, http::StatusCode, reply::Reply, Filter};
|
||||||
|
|
||||||
use crate::{
|
use crate::{
|
||||||
config::GitlabWebhookConfig,
|
config::GitlabWebhookConfig,
|
||||||
@@ -41,7 +40,7 @@ pub fn build_gitlab_messages(event: &GitlabEvent) -> Vec<String> {
|
|||||||
format!(
|
format!(
|
||||||
"\\[{}\\] {}*{}* {}",
|
"\\[{}\\] {}*{}* {}",
|
||||||
project.path_with_namespace,
|
project.path_with_namespace,
|
||||||
refname.as_ref().map(|rn| format!("`{}` ", rn)).unwrap_or_default(),
|
refname.as_ref().map(|rn| format!("`{rn}` ")).unwrap_or_default(),
|
||||||
event.user(),
|
event.user(),
|
||||||
title,
|
title,
|
||||||
)
|
)
|
||||||
@@ -56,9 +55,9 @@ pub async fn handle_gitlab_event(
|
|||||||
) -> anyhow::Result<()> {
|
) -> anyhow::Result<()> {
|
||||||
let room = matrix::ensure_room_joined(matrix_client, room_id).await?;
|
let room = matrix::ensure_room_joined(matrix_client, room_id).await?;
|
||||||
for msg in build_gitlab_messages(&event) {
|
for msg in build_gitlab_messages(&event) {
|
||||||
debug!("Sending message to {}: {}", room_id, msg);
|
debug!("Sending message to {room_id}: {msg}");
|
||||||
let msg_content = RoomMessageEventContent::text_markdown(&msg);
|
let msg_content = RoomMessageEventContent::text_markdown(&msg);
|
||||||
room.send(msg_content, None).await?;
|
room.send(msg_content).await?;
|
||||||
}
|
}
|
||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
@@ -68,7 +67,7 @@ pub fn build_route(config: GitlabWebhookConfig, matrix_client: Client) -> anyhow
|
|||||||
tokio::spawn(async move {
|
tokio::spawn(async move {
|
||||||
while let Some((event, room)) = event_rx.recv().await {
|
while let Some((event, room)) = event_rx.recv().await {
|
||||||
if let Err(err) = handle_gitlab_event(event, &room, &matrix_client).await {
|
if let Err(err) = handle_gitlab_event(event, &room, &matrix_client).await {
|
||||||
warn!("Failed to handle payload: {}", err);
|
warn!("Failed to handle payload: {err}");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
@@ -105,10 +104,10 @@ pub fn build_route(config: GitlabWebhookConfig, matrix_client: Client) -> anyhow
|
|||||||
let config_key = project.web_url.replace("http://", "").replace("https://", "");
|
let config_key = project.web_url.replace("http://", "").replace("https://", "");
|
||||||
if let Some(repo_config) = config.repo_configs.get(&config_key) {
|
if let Some(repo_config) = config.repo_configs.get(&config_key) {
|
||||||
if !constant_time_eq(token.as_bytes(), repo_config.token.as_bytes()) {
|
if !constant_time_eq(token.as_bytes(), repo_config.token.as_bytes()) {
|
||||||
warn!("Invalid token for repo '{}'", config_key);
|
warn!("Invalid token for repo '{config_key}'");
|
||||||
warp::reply::with_status("Invalid token", StatusCode::FORBIDDEN)
|
warp::reply::with_status("Invalid token", StatusCode::FORBIDDEN)
|
||||||
} else {
|
} else {
|
||||||
debug!("payload: {:?}", event);
|
debug!("payload: {event:?}");
|
||||||
if let Some(room) = &repo_config.room.as_ref().or(config.default_room.as_ref()) {
|
if let Some(room) = &repo_config.room.as_ref().or(config.default_room.as_ref()) {
|
||||||
let publish_events = repo_config
|
let publish_events = repo_config
|
||||||
.publish_events
|
.publish_events
|
||||||
@@ -116,12 +115,12 @@ pub fn build_route(config: GitlabWebhookConfig, matrix_client: Client) -> anyhow
|
|||||||
.or(config.default_publish_events.as_ref());
|
.or(config.default_publish_events.as_ref());
|
||||||
if publish_events.map(|ecs| event.should_publish(ecs)).unwrap_or(true) {
|
if publish_events.map(|ecs| event.should_publish(ecs)).unwrap_or(true) {
|
||||||
if let Err(err) = event_tx.send((event, (*room).clone())).await {
|
if let Err(err) = event_tx.send((event, (*room).clone())).await {
|
||||||
warn!("Failed to enqueue payload: {}", err);
|
warn!("Failed to enqueue payload: {err}");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
warp::reply::with_status("OK", StatusCode::OK)
|
warp::reply::with_status("OK", StatusCode::OK)
|
||||||
} else {
|
} else {
|
||||||
info!("Channel not configured for repo '{}'", config_key);
|
info!("Channel not configured for repo '{config_key}'");
|
||||||
warp::reply::with_status(
|
warp::reply::with_status(
|
||||||
"Matrix room not configured for repo",
|
"Matrix room not configured for repo",
|
||||||
StatusCode::NOT_FOUND,
|
StatusCode::NOT_FOUND,
|
||||||
@@ -129,7 +128,7 @@ pub fn build_route(config: GitlabWebhookConfig, matrix_client: Client) -> anyhow
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
info!("Repo '{}' unconfigured", config_key);
|
info!("Repo '{config_key}' unconfigured");
|
||||||
warp::reply::with_status("Repo not configured", StatusCode::NOT_FOUND)
|
warp::reply::with_status("Repo not configured", StatusCode::NOT_FOUND)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@@ -112,14 +112,14 @@ async fn handle_list(
|
|||||||
|
|
||||||
let rooms_f = room_ids.iter().map(|room_id| {
|
let rooms_f = room_ids.iter().map(|room_id| {
|
||||||
matrix::ensure_room_joined(matrix_client, room_id)
|
matrix::ensure_room_joined(matrix_client, room_id)
|
||||||
.map(move |res| res.with_context(|| format!("Failed to join Matrix room '{}'", room_id)))
|
.map(move |res| res.with_context(|| format!("Failed to join Matrix room '{room_id}'")))
|
||||||
});
|
});
|
||||||
let rooms = join_all(rooms_f)
|
let rooms = join_all(rooms_f)
|
||||||
.await
|
.await
|
||||||
.into_iter()
|
.into_iter()
|
||||||
.flat_map(|room_res| match room_res {
|
.flat_map(|room_res| match room_res {
|
||||||
Err(err) => {
|
Err(err) => {
|
||||||
warn!("{:#}", err);
|
warn!("{err:#}");
|
||||||
vec![]
|
vec![]
|
||||||
}
|
}
|
||||||
Ok(room) => vec![room],
|
Ok(room) => vec![room],
|
||||||
@@ -133,7 +133,7 @@ async fn handle_list(
|
|||||||
.get(url)
|
.get(url)
|
||||||
.send()
|
.send()
|
||||||
.await
|
.await
|
||||||
.with_context(|| format!("Failed to fetch mail RSS feed from '{}'", url))
|
.with_context(|| format!("Failed to fetch mail RSS feed from '{url}'"))
|
||||||
.and_then(|response| {
|
.and_then(|response| {
|
||||||
if !response.status().is_success() {
|
if !response.status().is_success() {
|
||||||
Err(anyhow!(
|
Err(anyhow!(
|
||||||
@@ -148,10 +148,10 @@ async fn handle_list(
|
|||||||
let body = response
|
let body = response
|
||||||
.text()
|
.text()
|
||||||
.await
|
.await
|
||||||
.with_context(|| format!("Failed to decode RSS response body for '{}'", url))?;
|
.with_context(|| format!("Failed to decode RSS response body for '{url}'"))?;
|
||||||
let mail_rss = tokio::task::spawn_blocking(move || quick_xml::de::from_str::<MailRss>(&body))
|
let mail_rss = tokio::task::spawn_blocking(move || quick_xml::de::from_str::<MailRss>(&body))
|
||||||
.await?
|
.await?
|
||||||
.with_context(|| format!("Failed to parse RSS feed for '{}'", url))?;
|
.with_context(|| format!("Failed to parse RSS feed for '{url}'"))?;
|
||||||
let items = mail_rss
|
let items = mail_rss
|
||||||
.channel
|
.channel
|
||||||
.items
|
.items
|
||||||
@@ -167,7 +167,7 @@ async fn handle_list(
|
|||||||
"\\[{}\\] [{}]({})",
|
"\\[{}\\] [{}]({})",
|
||||||
list.name, item.title, item.link
|
list.name, item.title, item.link
|
||||||
));
|
));
|
||||||
room.send(msg, None)
|
room.send(msg)
|
||||||
.await
|
.await
|
||||||
.with_context(|| format!("Failed to send message to room '{}'", room.room_id()))?;
|
.with_context(|| format!("Failed to send message to room '{}'", room.room_id()))?;
|
||||||
}
|
}
|
||||||
@@ -223,7 +223,7 @@ pub fn start_polling(config: MailArchiveConfig, matrix_client: Client) -> anyhow
|
|||||||
)
|
)
|
||||||
.await
|
.await
|
||||||
{
|
{
|
||||||
warn!("{:#}", err);
|
warn!("{err:#}");
|
||||||
}
|
}
|
||||||
|
|
||||||
sleep(update_interval).await;
|
sleep(update_interval).await;
|
||||||
@@ -269,7 +269,7 @@ mod test {
|
|||||||
let f = File::open(format!("{}/test-data/maillist.xml", env!("CARGO_MANIFEST_DIR")))?;
|
let f = File::open(format!("{}/test-data/maillist.xml", env!("CARGO_MANIFEST_DIR")))?;
|
||||||
let r = BufReader::new(f);
|
let r = BufReader::new(f);
|
||||||
let mail_rss = quick_xml::de::from_reader::<_, MailRss>(r)?;
|
let mail_rss = quick_xml::de::from_reader::<_, MailRss>(r)?;
|
||||||
println!("{:#?}", mail_rss);
|
println!("{mail_rss:#?}");
|
||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@@ -76,7 +76,7 @@ async fn main() {
|
|||||||
env_logger::init_from_env(lenv);
|
env_logger::init_from_env(lenv);
|
||||||
|
|
||||||
if let Err(err) = run().await {
|
if let Err(err) = run().await {
|
||||||
error!("{:#}", err);
|
error!("{err:#}");
|
||||||
exit(1);
|
exit(1);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@@ -18,7 +18,7 @@ use std::{fmt, process::exit, time::Duration};
|
|||||||
|
|
||||||
use matrix_sdk::{
|
use matrix_sdk::{
|
||||||
config::SyncSettings,
|
config::SyncSettings,
|
||||||
room::Joined,
|
room::Room,
|
||||||
ruma::{OwnedRoomOrAliasId, OwnedUserId, RoomOrAliasId, UserId},
|
ruma::{OwnedRoomOrAliasId, OwnedUserId, RoomOrAliasId, UserId},
|
||||||
BaseRoom, Client,
|
BaseRoom, Client,
|
||||||
};
|
};
|
||||||
@@ -26,12 +26,8 @@ use serde::de;
|
|||||||
|
|
||||||
use crate::config::Config;
|
use crate::config::Config;
|
||||||
|
|
||||||
async fn build_sync_settings(matrix_client: &Client) -> SyncSettings {
|
async fn build_sync_settings() -> SyncSettings {
|
||||||
let mut settings = SyncSettings::default().timeout(Duration::from_secs(30));
|
SyncSettings::default().timeout(Duration::from_secs(30))
|
||||||
if let Some(token) = matrix_client.sync_token().await {
|
|
||||||
settings = settings.token(token);
|
|
||||||
}
|
|
||||||
settings
|
|
||||||
}
|
}
|
||||||
|
|
||||||
pub async fn connect(config: &Config) -> anyhow::Result<Client> {
|
pub async fn connect(config: &Config) -> anyhow::Result<Client> {
|
||||||
@@ -41,21 +37,21 @@ pub async fn connect(config: &Config) -> anyhow::Result<Client> {
|
|||||||
.build()
|
.build()
|
||||||
.await?;
|
.await?;
|
||||||
client
|
client
|
||||||
|
.matrix_auth()
|
||||||
.login_username(&config.user_id, &config.password)
|
.login_username(&config.user_id, &config.password)
|
||||||
.initial_device_display_name("Bebot")
|
.initial_device_display_name("Bebot")
|
||||||
.send()
|
|
||||||
.await?;
|
.await?;
|
||||||
info!("Connected to matrix as {}; waiting for first sync", config.user_id);
|
info!("Connected to matrix as {}; waiting for first sync", config.user_id);
|
||||||
|
|
||||||
let settings = build_sync_settings(&client).await;
|
let settings = build_sync_settings().await;
|
||||||
client.sync_once(settings).await?;
|
client.sync_once(settings).await?;
|
||||||
info!("First matrix sync complete");
|
info!("First matrix sync complete");
|
||||||
|
|
||||||
let sync_client = client.clone();
|
let sync_client = client.clone();
|
||||||
tokio::spawn(async move {
|
tokio::spawn(async move {
|
||||||
let settings = build_sync_settings(&sync_client).await;
|
let settings = build_sync_settings().await;
|
||||||
if let Err(err) = sync_client.sync(settings).await {
|
if let Err(err) = sync_client.sync(settings).await {
|
||||||
error!("Matrix sync failed: {}", err);
|
error!("Matrix sync failed: {err}");
|
||||||
exit(1);
|
exit(1);
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
@@ -63,7 +59,7 @@ pub async fn connect(config: &Config) -> anyhow::Result<Client> {
|
|||||||
Ok(client)
|
Ok(client)
|
||||||
}
|
}
|
||||||
|
|
||||||
pub async fn ensure_room_joined(matrix_client: &Client, room_id: &OwnedRoomOrAliasId) -> anyhow::Result<Joined> {
|
pub async fn ensure_room_joined(matrix_client: &Client, room_id: &OwnedRoomOrAliasId) -> anyhow::Result<Room> {
|
||||||
fn room_matches(a_room: &BaseRoom, our_room: &OwnedRoomOrAliasId) -> bool {
|
fn room_matches(a_room: &BaseRoom, our_room: &OwnedRoomOrAliasId) -> bool {
|
||||||
let our_room_str = our_room.as_str();
|
let our_room_str = our_room.as_str();
|
||||||
a_room.room_id().as_str() == our_room_str
|
a_room.room_id().as_str() == our_room_str
|
||||||
@@ -85,11 +81,11 @@ pub async fn ensure_room_joined(matrix_client: &Client, room_id: &OwnedRoomOrAli
|
|||||||
.iter()
|
.iter()
|
||||||
.find(|a_room| room_matches(a_room, room_id))
|
.find(|a_room| room_matches(a_room, room_id))
|
||||||
{
|
{
|
||||||
invited.accept_invitation().await?;
|
invited.join().await?;
|
||||||
} else {
|
} else {
|
||||||
matrix_client.join_room_by_id_or_alias(room_id, &[]).await?;
|
matrix_client.join_room_by_id_or_alias(room_id, &[]).await?;
|
||||||
}
|
}
|
||||||
let settings = build_sync_settings(matrix_client).await;
|
let settings = build_sync_settings().await;
|
||||||
matrix_client.sync_once(settings).await?;
|
matrix_client.sync_once(settings).await?;
|
||||||
room = matrix_client
|
room = matrix_client
|
||||||
.joined_rooms()
|
.joined_rooms()
|
||||||
|
Reference in New Issue
Block a user