|
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