Protei/PromucFlow_constructor
2
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

chore: add code split for refactoring inputs (#32928)

Browse Source
This commit is contained in:
subratadeypappu 2024-04-29 11:26:04 +06:00 committed by GitHub
parent 9ba7036621
commit cc306b0c84
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 29 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
app/server/appsmith-server/src/main/java/com/appsmith/server/refactors/applications/RefactoringServiceCEImpl.java
View File

@ -39,6 +39,7 @@ import java.util.Set;
import java.util.regex.Pattern;
import java.util.stream.Collectors;
import static com.appsmith.server.helpers.ContextTypeUtils.getDefaultContextIfNull;
import static com.appsmith.server.services.ce.ApplicationPageServiceCEImpl.EVALUATION_VERSION;
@Slf4j
@ -193,27 +194,38 @@ public class RefactoringServiceCEImpl implements RefactoringServiceCE {
RefactorEntityNameDTO refactorEntityNameDTO,
Mono<String> contextIdMono,
Map<String, String> analyticsProperties) {
return contextIdMono
.flatMap(branchedPageId -> {
refactorEntityNameDTO.setPageId(branchedPageId);
return this.isNameAllowed(
branchedPageId,
CreatorContextType.PAGE,
refactorEntityNameDTO.getLayoutId(),
refactorEntityNameDTO.getNewFullyQualifiedName())
.zipWith(newPageService.getById(branchedPageId));
})
.flatMap(tuple -> {
analyticsProperties.put(
FieldName.APPLICATION_ID, tuple.getT2().getApplicationId());
analyticsProperties.put(FieldName.PAGE_ID, refactorEntityNameDTO.getPageId());
if (!tuple.getT1()) {
return contextIdMono.flatMap(branchedContextId -> validateEntityName(refactorEntityNameDTO, branchedContextId)
.then(prepareAnalyticsProperties(refactorEntityNameDTO, contextIdMono, analyticsProperties)));
}
protected Mono<Map<String, String>> prepareAnalyticsProperties(
RefactorEntityNameDTO refactorEntityNameDTO,
Mono<String> contextIdMono,
Map<String, String> analyticsProperties) {
return contextIdMono.flatMap(branchedPageId -> {
refactorEntityNameDTO.setPageId(branchedPageId);
return newPageService.getById(branchedPageId).map(page -> {
analyticsProperties.put(FieldName.APPLICATION_ID, page.getApplicationId());
analyticsProperties.put(FieldName.PAGE_ID, refactorEntityNameDTO.getPageId());
return analyticsProperties;
});
});
}
protected Mono<Void> validateEntityName(RefactorEntityNameDTO refactorEntityNameDTO, String contextId) {
return isNameAllowed(
contextId,
getDefaultContextIfNull(refactorEntityNameDTO.getContextType()),
refactorEntityNameDTO.getLayoutId(),
refactorEntityNameDTO.getNewFullyQualifiedName())
.flatMap(valid -> {
if (!valid) {
return Mono.error(new AppsmithException(
AppsmithError.NAME_CLASH_NOT_ALLOWED_IN_REFACTOR,
refactorEntityNameDTO.getOldFullyQualifiedName(),
refactorEntityNameDTO.getNewFullyQualifiedName()));
}
return Mono.just(analyticsProperties);
return Mono.empty();
});
}
@ -223,7 +235,7 @@ public class RefactoringServiceCEImpl implements RefactoringServiceCE {
EntityRefactoringService<?> service,
Map<String, String> analyticsProperties) {
return service.updateRefactoredEntity(refactorEntityNameDTO, branchName)
.then(this.refactorName(refactorEntityNameDTO))
.then(Mono.defer(() -> this.refactorName(refactorEntityNameDTO)))
.flatMap(tuple2 -> {
AnalyticsEvents event = service.getRefactorAnalyticsEvent(refactorEntityNameDTO.getEntityType());
return this.sendRefactorAnalytics(event, analyticsProperties, tuple2.getT2())