robin/rss-webhook-trigger
1
0
Fork 0
mirror of https://codeberg.org/icewind/rss-webhook-trigger.git synced 2026-06-03 09:54:18 +02:00
Code Issues Projects Releases Wiki Activity

it requires user-agent....

Browse source
This commit is contained in:
Robin Appelman 2021-08-17 23:49:02 +02:00
commit 6f551c9f30
1 changed files with 17 additions and 15 deletions
Download patch file Download diff file Expand all files Collapse all files

32
src/main.rs
View file

@ -1,6 +1,6 @@
mod config;
use crate::config::Config;
use crate::config::{Config, FeedConfig};
use color_eyre::{
eyre::{eyre, WrapErr},
Result,
@ -51,20 +51,7 @@ async fn main_loop(config: Config) {
for feed in config.feed.iter() {
match fetcher.is_feed_updated(&feed.feed).await {
Ok(true) => {
println!("Triggering hook for {}", feed.feed);
let mut req = fetcher.client.post(&feed.hook);
for (key, value) in &feed.headers {
req = req.header(key, value);
debug!("setting header '{}' = '{}'", key, value);
}
if !feed.body.is_null() {
req = req.json(&feed.body);
debug!("setting body '{:?}'", feed.body);
}
debug!("request '{:?}'", req);
if let Err(e) = req.send().await.and_then(|res| res.error_for_status()) {
eprintln!("{:#}", e);
}
trigger(&fetcher.client, feed).await;
}
Err(e) => eprintln!("{:#}", e),
Ok(false) => {}
@ -75,6 +62,21 @@ async fn main_loop(config: Config) {
}
}
async fn trigger(client: &Client, feed: &FeedConfig) {
println!("Triggering hook for {}", feed.feed);
let mut req = client.post(&feed.hook).header("user-agent", "rss-webhook-trigger");
for (key, value) in &feed.headers {
req = req.header(key, value);
}
if !feed.body.is_null() {
req = req.json(&feed.body);
}
debug!("request {:?}", req);
if let Err(e) = req.send().await.and_then(|res| res.error_for_status()) {
eprintln!("{:#}", e);
}
}
#[derive(Default)]
pub struct FeedFetcher {
client: Client,