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

more logging

Browse source
This commit is contained in:
Robin Appelman 2021-08-17 20:39:34 +02:00
commit 482911ebca
3 changed files with 6 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

1
Cargo.lock generated
View file

@ -760,6 +760,7 @@ version = "0.1.0"
dependencies = [ dependencies = [
"color-eyre", "color-eyre",
"env_logger", "env_logger",
"log",
"reqwest", "reqwest",
"rss", "rss",
"serde", "serde",

3
Cargo.toml
View file

@ -12,4 +12,5 @@ serde = { version = "1.0", features = ["derive"] }
serde_json = "1" serde_json = "1"
toml = "0.5" toml = "0.5"
color-eyre = "0.5" color-eyre = "0.5"
env_logger = "0.9" env_logger = "0.9"
log = "0.4"

3
src/main.rs
View file

@ -13,6 +13,7 @@ use std::hash::{Hash, Hasher};
use tokio::time::sleep; use tokio::time::sleep;
use tokio::signal::ctrl_c; use tokio::signal::ctrl_c;
use tokio::select; use tokio::select;
use log::debug;
#[tokio::main] #[tokio::main]
async fn main() -> Result<()> { async fn main() -> Result<()> {
@ -54,9 +55,11 @@ async fn main_loop(config: Config) {
let mut req = fetcher.client.post(&feed.hook); let mut req = fetcher.client.post(&feed.hook);
for (key, value) in &feed.headers { for (key, value) in &feed.headers {
req = req.header(key, value); req = req.header(key, value);
debug!("setting header '{}' = '{}'", key, value);
} }
if !feed.body.is_null() { if !feed.body.is_null() {
req = req.json(&feed.body); req = req.json(&feed.body);
debug!("setting body '{:?}'", feed.body);
} }
if let Err(e) = req.send().await.and_then(|res| res.error_for_status()) { if let Err(e) = req.send().await.and_then(|res| res.error_for_status()) {
eprintln!("{:#}", e); eprintln!("{:#}", e);