kellnr-webhooks 6.2.0

Kellnr is a self-hosted registry for Rust crates with support for rustdocs and crates.io caching.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

use chrono::{DateTime, Utc};
use kellnr_common::normalized_name::NormalizedName;
use kellnr_common::version::Version;
use kellnr_common::webhook::WebhookEvent;
use kellnr_db::DbProvider;
use serde_json::json;

pub mod endpoints;
mod service;
#[cfg(test)]
mod tests;
pub mod types;

pub use endpoints::{
    delete_webhook, get_all_webhooks, get_webhook, register_webhook, test_webhook,
};
pub use service::run_webhook_service;

pub async fn notify_crate(
    event: WebhookEvent,
    timestamp: &DateTime<Utc>,
    normalized_name: &NormalizedName,
    version: &Version,
    db: &std::sync::Arc<dyn DbProvider>,
) {
    let payload = json!({
        "type": event,
        "timestamp": timestamp,
        "data": {
            "crate_name": format!("{}", normalized_name),
            "crate_version": version
        }
    });

    if let Err(err) = db.add_webhook_queue(event, payload).await {
        tracing::error!("Db: {err:?}");
    }
}