|
5 | 5 |
|
6 | 6 | import io.kafbat.ui.api.ApplicationConfigApi; |
7 | 7 | import io.kafbat.ui.config.ClustersProperties; |
| 8 | +import io.kafbat.ui.model.ActionDTO; |
8 | 9 | import io.kafbat.ui.model.ApplicationConfigDTO; |
9 | 10 | import io.kafbat.ui.model.ApplicationConfigPropertiesDTO; |
10 | 11 | import io.kafbat.ui.model.ApplicationConfigValidationDTO; |
|
18 | 19 | import io.kafbat.ui.util.ApplicationRestarter; |
19 | 20 | import io.kafbat.ui.util.DynamicConfigOperations; |
20 | 21 | import java.util.Map; |
| 22 | +import java.util.Optional; |
21 | 23 | import javax.annotation.Nullable; |
22 | 24 | import lombok.RequiredArgsConstructor; |
23 | 25 | import lombok.extern.slf4j.Slf4j; |
@@ -46,6 +48,12 @@ interface PropertiesMapper { |
46 | 48 | DynamicConfigOperations.PropertiesStructure fromDto(ApplicationConfigPropertiesDTO dto); |
47 | 49 |
|
48 | 50 | ApplicationConfigPropertiesDTO toDto(DynamicConfigOperations.PropertiesStructure propertiesStructure); |
| 51 | + |
| 52 | + default ActionDTO stringToActionDto(String str) { |
| 53 | + return Optional.ofNullable(str) |
| 54 | + .map(s -> Enum.valueOf(ActionDTO.class, s.toUpperCase())) |
| 55 | + .orElseThrow(); |
| 56 | + } |
49 | 57 | } |
50 | 58 |
|
51 | 59 | private final DynamicConfigOperations dynamicConfigOperations; |
@@ -75,7 +83,7 @@ public Mono<ResponseEntity<ApplicationConfigDTO>> getCurrentConfig(ServerWebExch |
75 | 83 | @Override |
76 | 84 | public Mono<ResponseEntity<Void>> restartWithConfig(Mono<RestartRequestDTO> restartRequestDto, |
77 | 85 | ServerWebExchange exchange) { |
78 | | - var context = AccessContext.builder() |
| 86 | + var context = AccessContext.builder() |
79 | 87 | .applicationConfigActions(EDIT) |
80 | 88 | .operationName("restartWithConfig") |
81 | 89 | .build(); |
|
0 commit comments