git-next/crates/server/src/actors/webhook/server.rs

//
use std::{collections::HashMap, net::SocketAddr};

use actix::prelude::*;

use config::{ForgeAlias, RepoAlias};
use git_next_config as config;

use tracing::{info, warn};

pub async fn start(
    socket_addr: SocketAddr,
    address: actix::prelude::Recipient<config::WebhookMessage>,
) {
    // start webhook server
    use warp::Filter;
    // Define the Warp route to handle incoming HTTP requests
    let route = warp::post()
        .map(move || address.clone())
        .and(warp::path::param())
        .and(warp::path::param())
        .and(warp::header::headers_cloned())
        .and(warp::body::bytes())
        .and_then(
            |recipient: Recipient<config::WebhookMessage>,
             forge_alias: String,
             repo_alias: String,
             // query: String,
             headers: warp::http::HeaderMap,
             body: bytes::Bytes| async move {
                info!("POST received");
                let forge_alias = ForgeAlias::new(forge_alias);
                let repo_alias = RepoAlias::new(repo_alias);
                let bytes = body.to_vec();
                let body = config::webhook::message::Body::new(
                    String::from_utf8_lossy(&bytes).to_string(),
                );
                let headers = headers
                    .into_iter()
                    .filter_map(|(k, v)| {
                        k.map(|k| (k.to_string(), v.to_str().unwrap_or_default().to_string()))
                    })
                    .collect::<HashMap<String, String>>();
                let message = config::WebhookMessage::new(forge_alias, repo_alias, headers, body);
                recipient
                    .try_send(message)
                    .map(|_| {
                        info!("Message sent ok");
                        warp::reply::with_status("OK", warp::http::StatusCode::OK)
                    })
                    .map_err(|e| {
                        warn!("Unknown error: {:?}", e);
                        warp::reject()
                    })
            },
        );

    // Start the server
    info!("Starting webhook server: {}", socket_addr);
    warp::serve(route).run(socket_addr).await;
}