Method execute

graphlite/src/catalog/providers/security.rs:593–819

(&mut self, op: CatalogOperation)

    }

    fn execute(&mut self, op: CatalogOperation) -> CatalogResult<CatalogResponse> {
        match op {
            CatalogOperation::Create {
                entity_type,
                name,
                params,
            } => match entity_type {
                EntityType::User => {
                    let user = User::from_params(name.clone(), &params);
                    self.add_user(user)?;
                    Ok(CatalogResponse::Success {
                        data: Some(json!({ "message": format!("User '{}' created", name) })),
                    })
                }
                EntityType::Role => {
                    let role = Role::from_params(name.clone(), &params);
                    self.add_role(role)?;
                    Ok(CatalogResponse::Success {
                        data: Some(json!({ "message": format!("Role '{}' created", name) })),
                    })
                }
                EntityType::Ace => {
                    let ace = Ace::from_params(&params)?;
                    self.add_ace(ace)?;
                    Ok(CatalogResponse::Success {
                        data: Some(json!({ "message": "Access control entry created" })),
                    })
                }
                _ => Ok(CatalogResponse::NotSupported),
            },

            CatalogOperation::Drop {
                entity_type,
                name,
                cascade,
            } => match entity_type {
                EntityType::User => {
                    let removed = self.remove_user(&name)?;
                    Ok(CatalogResponse::Success {
                        data: Some(serde_json::to_value(removed)?),
                    })
                }
                EntityType::Role => {
                    let removed = self.remove_role(&name, cascade)?;
                    Ok(CatalogResponse::Success {
                        data: Some(serde_json::to_value(removed)?),
                    })
                }
                _ => Ok(CatalogResponse::NotSupported),
            },

            CatalogOperation::Query { query_type, params } => {
                match query_type {
                    QueryType::GetUser => {
                        if let Some(name) = params.get("name").and_then(|v| v.as_str()) {
                            if let Some(user) = self.get_user(name) {
                                Ok(CatalogResponse::Query {
                                    results: serde_json::to_value(user)?,