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

use actix::prelude::*;

use tracing::{debug, info};

use crate::server::actors::webhook::message::WebhookMessage;

pub async fn start(address: actix::prelude::Recipient<super::message::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::query::raw())
        // .and(warp::header::headers_cloned())
        .and(warp::body::bytes())
        .and_then(
            |recipient: Recipient<WebhookMessage>,
             path,
             // query: String,
             // headers: warp::http::HeaderMap,
             body: bytes::Bytes| async move {
                let bytes = body.to_vec();
                let request_data = String::from_utf8_lossy(&bytes).to_string();
                let id = ulid::Ulid::new().to_string();
                debug!(id, path, "Received webhook");
                let message =
                    WebhookMessage::new(id, path, /* query, headers, */ request_data);
                recipient
                    .try_send(message)
                    .map(|_| warp::reply::with_status("OK", warp::http::StatusCode::OK))
                    .map_err(|_| warp::reject::reject())
            },
        );

    // Start the server
    info!("Starting webhook server: http://0.0.0.0:8080/");
    warp::serve(route).run(([0, 0, 0, 0], 8080)).await;
}