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

Extract logic from route

Browse Source
This commit is contained in:
Mubelotix
2025-07-31 10:01:25 +02:00
parent f67043801b
commit 446fce6c16
1 changed files with 18 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -180,10 +180,17 @@ async fn patch_webhooks(
req: HttpRequest, req: HttpRequest,
analytics: Data<Analytics>, analytics: Data<Analytics>,
) -> Result<HttpResponse, ResponseError> { ) -> Result<HttpResponse, ResponseError> {
let WebhooksSettings { webhooks: new_webhooks } = new_webhooks.0; let webhooks = patch_webhooks_inner(&index_scheduler, new_webhooks.0)?;
let Webhooks { mut webhooks } = index_scheduler.webhooks();
debug!(parameters = ?new_webhooks, "Patch webhooks");
analytics.publish(PatchWebhooksAnalytics, &req);
Ok(HttpResponse::Ok().json(webhooks))
}
fn patch_webhooks_inner(
index_scheduler: &GuardedData<ActionPolicy<{ actions::WEBHOOKS_UPDATE }>, Data<IndexScheduler>>,
new_webhooks: WebhooksSettings,
) -> Result<Webhooks, ResponseError> {
fn merge_webhook( fn merge_webhook(
name: &str, name: &str,
old_webhook: Option<Webhook>, old_webhook: Option<Webhook>,
@ -225,7 +232,11 @@ async fn patch_webhooks(
Ok(Webhook { url, headers }) Ok(Webhook { url, headers })
} }
match new_webhooks { debug!(parameters = ?new_webhooks, "Patch webhooks");
let Webhooks { mut webhooks } = index_scheduler.webhooks();
match new_webhooks.webhooks {
Setting::Set(new_webhooks) => { Setting::Set(new_webhooks) => {
for (name, new_webhook) in new_webhooks { for (name, new_webhook) in new_webhooks {
if name.starts_with('_') { if name.starts_with('_') {
@ -253,10 +264,10 @@ async fn patch_webhooks(
return Err(WebhooksError::TooManyWebhooks.into()); return Err(WebhooksError::TooManyWebhooks.into());
} }
analytics.publish(PatchWebhooksAnalytics, &req);
let webhooks = Webhooks { webhooks }; let webhooks = Webhooks { webhooks };
index_scheduler.put_webhooks(webhooks.clone())?; index_scheduler.put_webhooks(webhooks.clone())?;
debug!(returns = ?webhooks, "Patch webhooks"); debug!(returns = ?webhooks, "Patch webhooks");
Ok(HttpResponse::Ok().json(webhooks))
Ok(webhooks)
} }