(self, request: ProtoZtDomainConfig)
| 473 | } |
| 474 | |
| 475 | async fn add_zt_domain(self, request: ProtoZtDomainConfig) -> Result<ZtDomainInfo> { |
| 476 | let kv_store = self.state.kv_store(); |
| 477 | let cert_resolver = &self.state.cert_resolver; |
| 478 | |
| 479 | // Check if domain already exists |
| 480 | if kv_store.get_zt_domain_config(&request.domain).is_some() { |
| 481 | bail!("ZT-Domain config already exists: {}", request.domain); |
| 482 | } |
| 483 | |
| 484 | let config = proto_to_zt_domain_config(&request, kv_store)?; |
| 485 | |
| 486 | kv_store.save_zt_domain_config(&config)?; |
| 487 | info!("Added ZT-Domain config: {}", config.domain); |
| 488 | |
| 489 | Ok(zt_domain_to_proto(config, kv_store, cert_resolver)) |
| 490 | } |
| 491 | |
| 492 | async fn update_zt_domain(self, request: ProtoZtDomainConfig) -> Result<ZtDomainInfo> { |
| 493 | let kv_store = self.state.kv_store(); |
nothing calls this directly
no test coverage detected