diff --git a/backend/windmill-api/src/users.rs b/backend/windmill-api/src/users.rs index 73ccb3a96b..ae27df194d 100644 --- a/backend/windmill-api/src/users.rs +++ b/backend/windmill-api/src/users.rs @@ -1311,7 +1311,9 @@ async fn create_user( if let Some(new_user_webhook) = NEW_USER_WEBHOOK.clone() { let _ = HTTP_CLIENT .post(&new_user_webhook) - .json(&serde_json::json!({"email" : &nu.email, "name": &nu.name, "event": "new_user"})) + .json( + &serde_json::json!({"email" : &nu.email, "name": &nu.name, "event": "global_add"}), + ) .send() .await .map_err(|e| tracing::error!("Error sending new user webhook: {}", e.to_string())); diff --git a/backend/windmill-api/src/workspaces.rs b/backend/windmill-api/src/workspaces.rs index d3027fe329..dd2ee22f34 100644 --- a/backend/windmill-api/src/workspaces.rs +++ b/backend/windmill-api/src/workspaces.rs @@ -965,7 +965,7 @@ async fn invite_user( if let Some(new_user_webhook) = NEW_USER_WEBHOOK.clone() { let _ = &HTTP_CLIENT .post(&new_user_webhook) - .json(&serde_json::json!({"email" : &nu.email, "event": "new_invite"})) + .json(&serde_json::json!({"email" : &nu.email, "event": "workspace_invite"})) .send() .await .map_err(|e| tracing::error!("Error sending new user webhook: {}", e.to_string())); @@ -1002,6 +1002,15 @@ async fn add_user( tx.commit().await?; + if let Some(new_user_webhook) = NEW_USER_WEBHOOK.clone() { + let _ = HTTP_CLIENT + .post(&new_user_webhook) + .json(&serde_json::json!({"email" : &nu.email, "event": "workspace_add"})) + .send() + .await + .map_err(|e| tracing::error!("Error sending new user webhook: {}", e.to_string())); + } + Ok(( StatusCode::CREATED, format!("user with email {} added", nu.email),