feat(config): rule http

4 files changed, 167 insertions, 0 deletions

diff --git a/crates/configuration/src/server/http_svc/routes/rule/create.rs b/crates/configuration/src/server/http_svc/routes/rule/create.rs
new file mode 100644
index 0000000..809c00b
--- /dev/null
+++ b/crates/configuration/src/server/http_svc/routes/rule/create.rs
@@ -0,0 +1,38 @@
+use axum::{extract::State, response::IntoResponse};
+use warden_core::configuration::rule::{
+    RuleConfiguration, mutate_rule_configuration_server::MutateRuleConfiguration,
+};
+
+use crate::{
+    server::{error::AppError, http_svc::TAG_RULES, version::Version},
+    state::AppHandle,
+};
+
+/// Create rule configuration
+#[utoipa::path(
+    post,
+    path = "/{version}/rule",
+    params(
+        ("version" = Version, Path, description = "API version, e.g., v1, v2, v3"),
+    ),
+    responses((
+        status = CREATED,
+        body = RuleConfiguration,
+    )),
+    operation_id = "create_rule_configuration", // https://github.com/juhaku/utoipa/issues/1170
+    tag = TAG_RULES,
+    )
+]
+#[axum::debug_handler]
+#[tracing::instrument(skip(state))]
+pub async fn create_rule(
+    version: Version,
+    State(state): State<AppHandle>,
+    axum::Json(body): axum::Json<RuleConfiguration>,
+) -> Result<impl IntoResponse, AppError> {
+    let response = state
+        .create_rule_configuration(tonic::Request::new(body))
+        .await?
+        .into_inner();
+    Ok((axum::http::StatusCode::CREATED, axum::Json(response)))
+}
diff --git a/crates/configuration/src/server/http_svc/routes/rule/delete.rs b/crates/configuration/src/server/http_svc/routes/rule/delete.rs
new file mode 100644
index 0000000..2352fba
--- /dev/null
+++ b/crates/configuration/src/server/http_svc/routes/rule/delete.rs
@@ -0,0 +1,42 @@
+use axum::extract::{Query, State};
+use tonic::IntoRequest;
+use warden_core::configuration::rule::{
+    DeleteRuleConfigurationRequest, RuleConfiguration,
+    mutate_rule_configuration_server::MutateRuleConfiguration,
+};
+
+use crate::{
+    server::{error::AppError, http_svc::TAG_RULES, version::Version},
+    state::AppHandle,
+};
+
+/// Delete rule configuration
+#[utoipa::path(
+    delete,
+    path = "/{version}/rule",
+    responses((
+        status = OK,
+        body = RuleConfiguration
+    )),
+    params(
+        ("version" = Version, Path, description = "API version, e.g., v1, v2, v3"),
+        DeleteRuleConfigurationRequest,
+    ),
+    operation_id = "delete_rule_configuration", // https://github.com/juhaku/utoipa/issues/1170
+    tag = TAG_RULES,
+    )
+]
+#[axum::debug_handler]
+#[tracing::instrument(skip(state))]
+pub async fn delete_rule_config(
+    version: Version,
+    State(state): State<AppHandle>,
+    Query(body): Query<DeleteRuleConfigurationRequest>,
+) -> Result<axum::Json<RuleConfiguration>, AppError> {
+    let body = state
+        .delete_rule_configuration(body.into_request())
+        .await?
+        .into_inner();
+
+    Ok(axum::Json(body))
+}
diff --git a/crates/configuration/src/server/http_svc/routes/rule/get.rs b/crates/configuration/src/server/http_svc/routes/rule/get.rs
new file mode 100644
index 0000000..935eefb
--- /dev/null
+++ b/crates/configuration/src/server/http_svc/routes/rule/get.rs
@@ -0,0 +1,42 @@
+use axum::extract::{Query, State};
+use warden_core::configuration::rule::{
+    RuleConfiguration, RuleConfigurationRequest,
+    query_rule_configuration_server::QueryRuleConfiguration,
+};
+
+use crate::{
+    server::{error::AppError, http_svc::TAG_RULES, version::Version},
+    state::AppHandle,
+};
+
+/// Get rule configuration
+#[utoipa::path(
+    get,
+    path = "/{version}/rule",
+    responses((
+        status = OK,
+        body = RuleConfiguration
+    )),
+    params(
+        ("version" = Version, Path, description = "API version, e.g., v1, v2, v3"),
+        RuleConfigurationRequest
+    ),
+    operation_id = "get_rule_configuration", // https://github.com/juhaku/utoipa/issues/1170
+    tag = TAG_RULES,
+    )
+]
+#[axum::debug_handler]
+#[tracing::instrument(skip(state))]
+pub async fn get_rule(
+    version: Version,
+    State(state): State<AppHandle>,
+    Query(body): Query<RuleConfigurationRequest>,
+) -> Result<axum::Json<Option<RuleConfiguration>>, AppError> {
+    let response = state
+        .get_rule_configuration(tonic::Request::new(body))
+        .await?
+        .into_inner()
+        .configuration;
+
+    Ok(axum::Json(response))
+}
diff --git a/crates/configuration/src/server/http_svc/routes/rule/update.rs b/crates/configuration/src/server/http_svc/routes/rule/update.rs
new file mode 100644
index 0000000..7bf3fe0
--- /dev/null
+++ b/crates/configuration/src/server/http_svc/routes/rule/update.rs
@@ -0,0 +1,45 @@
+use axum::extract::State;
+use tonic::IntoRequest;
+use warden_core::configuration::rule::{
+    RuleConfiguration, UpdateRuleRequest, mutate_rule_configuration_server::MutateRuleConfiguration,
+};
+
+use crate::{
+    server::{error::AppError, http_svc::TAG_RULES, version::Version},
+    state::AppHandle,
+};
+
+/// Update the routing configuration
+#[utoipa::path(
+    put,
+    path = "/{version}/rule",
+    params(
+        ("version" = Version, Path, description = "API version, e.g., v1, v2, v3"),
+    ),
+    responses((
+        status = OK,
+        body = RuleConfiguration
+    )),
+    operation_id = "update rule configuration", // https://github.com/juhaku/utoipa/issues/1170
+    tag = TAG_RULES,
+    )
+]
+#[axum::debug_handler]
+#[tracing::instrument(skip(state))]
+pub async fn update_rule_config(
+    version: Version,
+    State(state): State<AppHandle>,
+    axum::Json(body): axum::Json<RuleConfiguration>,
+) -> Result<axum::Json<RuleConfiguration>, AppError> {
+    let config = state
+        .update_rule_configuration(
+            UpdateRuleRequest {
+                configuration: Some(body),
+            }
+            .into_request(),
+        )
+        .await?
+        .into_inner();
+
+    Ok(axum::Json(config))
+}