Method execute

graphlite/src/catalog/providers/graph_metadata.rs:717–928

(&mut self, op: CatalogOperation)

    }

    fn execute(&mut self, op: CatalogOperation) -> CatalogResult<CatalogResponse> {
        match op {
            CatalogOperation::Create {
                entity_type,
                name,
                params,
            } => match entity_type {
                EntityType::Graph => {
                    let graph = Graph::from_params(name.clone(), &params);
                    self.add_graph(graph)?;
                    Ok(CatalogResponse::Success {
                        data: Some(json!({ "message": format!("Graph '{}' created", name) })),
                    })
                }
                EntityType::GraphType => {
                    let graph_type = GraphType::from_params(name.clone(), &params);
                    self.add_graph_type(graph_type)?;
                    Ok(CatalogResponse::Success {
                        data: Some(json!({ "message": format!("Graph type '{}' created", name) })),
                    })
                }
                EntityType::VertexType => {
                    let graph_type_name = params
                        .get("graph_type")
                        .and_then(|v| v.as_str())
                        .ok_or_else(|| {
                            CatalogError::InvalidParameters(
                                "Missing 'graph_type' parameter".to_string(),
                            )
                        })?;

                    let vertex_type = serde_json::from_value::<VertexType>(params.clone())
                        .map_err(|e| CatalogError::InvalidParameters(e.to_string()))?;

                    self.add_vertex_type_to_graph_type(graph_type_name, vertex_type)?;
                    Ok(CatalogResponse::Success {
                        data: Some(
                            json!({ "message": format!("Vertex type '{}' added to graph type '{}'", name, graph_type_name) }),
                        ),
                    })
                }
                EntityType::EdgeType => {
                    let graph_type_name = params
                        .get("graph_type")
                        .and_then(|v| v.as_str())
                        .ok_or_else(|| {
                            CatalogError::InvalidParameters(
                                "Missing 'graph_type' parameter".to_string(),
                            )
                        })?;

                    let edge_type = serde_json::from_value::<EdgeType>(params.clone())
                        .map_err(|e| CatalogError::InvalidParameters(e.to_string()))?;

                    self.add_edge_type_to_graph_type(graph_type_name, edge_type)?;
                    Ok(CatalogResponse::Success {
                        data: Some(
                            json!({ "message": format!("Edge type '{}' added to graph type '{}'", name, graph_type_name) }),