snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2025-09-06 12:46:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

Format

Browse Source
This commit is contained in:
Mubelotix
2025-08-04 14:51:23 +02:00
parent 7acbb1e140
commit c5caac95dd
1 changed files with 17 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
crates/meilisearch/src/routes/webhooks.rs
View File

@ -20,6 +20,7 @@ use crate::analytics::{Aggregate, Analytics};
use crate::extractors::authentication::policies::ActionPolicy; use crate::extractors::authentication::policies::ActionPolicy;
use crate::extractors::authentication::GuardedData; use crate::extractors::authentication::GuardedData;
use crate::extractors::sequential_extractor::SeqHandler; use crate::extractors::sequential_extractor::SeqHandler;
use WebhooksError::*;
#[derive(OpenApi)] #[derive(OpenApi)]
#[openapi( #[openapi(
@ -191,13 +192,11 @@ enum WebhooksError {
impl ErrorCode for WebhooksError { impl ErrorCode for WebhooksError {
fn error_code(&self) -> meilisearch_types::error::Code { fn error_code(&self) -> meilisearch_types::error::Code {
match self { match self {
WebhooksError::MissingUrl(_) => meilisearch_types::error::Code::InvalidWebhooksUrl, MissingUrl(_) => meilisearch_types::error::Code::InvalidWebhooksUrl,
WebhooksError::TooManyWebhooks => meilisearch_types::error::Code::InvalidWebhooks, TooManyWebhooks => meilisearch_types::error::Code::InvalidWebhooks,
WebhooksError::TooManyHeaders(_) => { TooManyHeaders(_) => meilisearch_types::error::Code::InvalidWebhooksHeaders,
meilisearch_types::error::Code::InvalidWebhooksHeaders ReservedWebhook(_) => meilisearch_types::error::Code::ReservedWebhook,
} WebhookNotFound(_) => meilisearch_types::error::Code::WebhookNotFound,
WebhooksError::ReservedWebhook(_) => meilisearch_types::error::Code::ReservedWebhook,
WebhooksError::WebhookNotFound(_) => meilisearch_types::error::Code::WebhookNotFound,
} }
} }
} }
@ -212,8 +211,8 @@ fn patch_webhook_inner(
let url = match new_webhook.url { let url = match new_webhook.url {
Setting::Set(url) => url, Setting::Set(url) => url,
Setting::NotSet => old_url.ok_or_else(|| WebhooksError::MissingUrl(uuid.to_owned()))?, Setting::NotSet => old_url.ok_or_else(|| MissingUrl(uuid.to_owned()))?,
Setting::Reset => return Err(WebhooksError::MissingUrl(uuid.to_owned())), Setting::Reset => return Err(MissingUrl(uuid.to_owned())),
}; };
let headers = match new_webhook.headers { let headers = match new_webhook.headers {
@ -237,7 +236,7 @@ fn patch_webhook_inner(
}; };
if headers.len() > 200 { if headers.len() > 200 {
return Err(WebhooksError::TooManyHeaders(uuid.to_owned())); return Err(TooManyHeaders(uuid.to_owned()));
} }
Ok(Webhook { url, headers }) Ok(Webhook { url, headers })
@ -271,7 +270,7 @@ async fn get_webhook(
let uuid = uuid.into_inner(); let uuid = uuid.into_inner();
let mut webhooks = index_scheduler.webhooks(); let mut webhooks = index_scheduler.webhooks();
let webhook = webhooks.webhooks.remove(&uuid).ok_or(WebhooksError::WebhookNotFound(uuid))?; let webhook = webhooks.webhooks.remove(&uuid).ok_or(WebhookNotFound(uuid))?;
Ok(HttpResponse::Ok().json(WebhookWithMetadata { Ok(HttpResponse::Ok().json(WebhookWithMetadata {
uuid, uuid,
@ -310,16 +309,16 @@ async fn post_webhook(
let uuid = Uuid::new_v4(); let uuid = Uuid::new_v4();
if webhook_settings.headers.as_ref().set().is_some_and(|h| h.len() > 200) { if webhook_settings.headers.as_ref().set().is_some_and(|h| h.len() > 200) {
return Err(WebhooksError::TooManyHeaders(uuid).into()); return Err(TooManyHeaders(uuid).into());
} }
let mut webhooks = index_scheduler.webhooks(); let mut webhooks = index_scheduler.webhooks();
if dbg!(webhooks.webhooks.len() >= 20) { if dbg!(webhooks.webhooks.len() >= 20) {
return Err(WebhooksError::TooManyWebhooks.into()); return Err(TooManyWebhooks.into());
} }
let webhook = Webhook { let webhook = Webhook {
url: webhook_settings.url.set().ok_or(WebhooksError::MissingUrl(uuid))?, url: webhook_settings.url.set().ok_or(MissingUrl(uuid))?,
headers: webhook_settings headers: webhook_settings
.headers .headers
.set() .set()
@ -370,7 +369,7 @@ async fn patch_webhook(
debug!(parameters = ?(uuid, &webhook_settings), "Patch webhook"); debug!(parameters = ?(uuid, &webhook_settings), "Patch webhook");
if uuid.is_nil() { if uuid.is_nil() {
return Err(WebhooksError::ReservedWebhook(uuid).into()); return Err(ReservedWebhook(uuid).into());
} }
let mut webhooks = index_scheduler.webhooks(); let mut webhooks = index_scheduler.webhooks();
@ -378,7 +377,7 @@ async fn patch_webhook(
let webhook = patch_webhook_inner(&uuid, old_webhook, webhook_settings)?; let webhook = patch_webhook_inner(&uuid, old_webhook, webhook_settings)?;
if webhook.headers.len() > 200 { if webhook.headers.len() > 200 {
return Err(WebhooksError::TooManyHeaders(uuid).into()); return Err(TooManyHeaders(uuid).into());
} }
webhooks.webhooks.insert(uuid, webhook.clone()); webhooks.webhooks.insert(uuid, webhook.clone());
@ -415,11 +414,11 @@ async fn delete_webhook(
debug!(parameters = ?uuid, "Delete webhook"); debug!(parameters = ?uuid, "Delete webhook");
if uuid.is_nil() { if uuid.is_nil() {
return Err(WebhooksError::ReservedWebhook(uuid).into()); return Err(ReservedWebhook(uuid).into());
} }
let mut webhooks = index_scheduler.webhooks(); let mut webhooks = index_scheduler.webhooks();
webhooks.webhooks.remove(&uuid).ok_or(WebhooksError::WebhookNotFound(uuid))?; webhooks.webhooks.remove(&uuid).ok_or(WebhookNotFound(uuid))?;
index_scheduler.put_webhooks(webhooks)?; index_scheduler.put_webhooks(webhooks)?;
analytics.publish(PatchWebhooksAnalytics::delete_webhook(), &req); analytics.publish(PatchWebhooksAnalytics::delete_webhook(), &req);