discord-webhook-proxy 1.0.0

DiscordWebhookProxy is a powerful Discord proxy service designed for Roblox, built to prevent abuse and provide secure relaying. It offers complete server management, allowing users to set hardware usage caps and ban abusive users via an intuitive dashboard. Easily deployed with one-click options for Docker, Nix, or Vercel.
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
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80

use rocket::post;
use super::webhook_queue::{QueueSender, Webhook};
use super::{ApiResult, ApiError};
use rocket::serde::json::serde_json;
use rocket::{http::Status, serde::json::Json, State};

#[post("/<webhook_id>/<webhook_token>", data = "<body>")]
pub async fn webhook_proxy(
    webhook_id: u64,
    webhook_token: &str,
    body: Json<serde_json::Value>,
    queue_sender: &State<QueueSender>,
) -> ApiResult<(Status, Json<serde_json::Value>)> {
    let (response_status, response_body, _) =
        forward_webhook_request(webhook_id, webhook_token, &body.to_string())?;

    match response_status.code {
        429 => {
            queue_sender
                .send(Webhook {
                    id: webhook_id,
                    token: webhook_token.to_string(),
                    body: body.to_string(),
                })
                .await
                .map_err(|_| {
                    ApiError::message(Status::InternalServerError, "Failed to queue request")
                })?;

            Ok((Status::Accepted, Json(serde_json::json!({"queued": true}))))
        },
        _ => {
            let response_body: serde_json::Value =
                serde_json::from_str::<serde_json::Value>(&response_body)
                    .map_or(serde_json::json!({}), |body| body);

            Ok((response_status, Json(response_body)))
        },
    }
}

pub fn forward_webhook_request(
    webhook_id: u64,
    webhook_token: &str,
    body: &str,
) -> Result<(Status, String, minreq::Response), ApiError> {
    let url = format!("https://discord.com/api/webhooks/{webhook_id}/{webhook_token}");

    let response = minreq::post(&url)
        .with_header("Content-Type", "application/json")
        .with_body(body)
        .send()
        .map_err(|_| ApiError::message(Status::InternalServerError, "Failed to forward request"))?;

    let response_status_code = status_from_code(response.status_code)?;
    let response_body = response
        .as_str()
        .map_err(|_| ApiError::message(Status::InternalServerError, "Failed to encode the body"))?
        .to_string();

    Ok((response_status_code, response_body, response))
}

fn status_from_code(code: i32) -> ApiResult<Status> {
    let code: u16 = code.try_into().map_err(|_| {
        ApiError::message(
            Status::InternalServerError,
            "Failed to convert the status code",
        )
    })?;

    let status = Status::from_code(code).ok_or_else(|| {
        ApiError::message(
            Status::InternalServerError,
            "Failed to convert the status code",
        )
    })?;

    Ok(status)
}