diff --git a/extensions/grpc/codegen/src/main/java/io/quarkus/grpc/deployment/GrpcPostProcessing.java b/extensions/grpc/codegen/src/main/java/io/quarkus/grpc/deployment/GrpcPostProcessing.java index f6f9dcd2a24915..4e7604fcb34ea7 100644 --- a/extensions/grpc/codegen/src/main/java/io/quarkus/grpc/deployment/GrpcPostProcessing.java +++ b/extensions/grpc/codegen/src/main/java/io/quarkus/grpc/deployment/GrpcPostProcessing.java @@ -1,13 +1,6 @@ package io.quarkus.grpc.deployment; -import java.io.IOException; -import java.nio.file.Files; import java.nio.file.Path; -import java.nio.file.StandardCopyOption; -import java.util.HashMap; -import java.util.Map; -import java.util.Map.Entry; -import java.util.function.Consumer; import org.eclipse.microprofile.config.Config; import org.jboss.logging.Logger; @@ -50,7 +43,6 @@ private boolean isEnabled(String name, boolean def) { public void postprocess() { SourceRoot sr = new SourceRoot(root); - Map changedFiles = new HashMap(); try { sr.parse("", new SourceRoot.Callback() { @Override @@ -62,19 +54,9 @@ public com.github.javaparser.utils.SourceRoot.Callback.Result process(Path local if (unit.getPrimaryType().isPresent()) { TypeDeclaration type = unit.getPrimaryType().get(); postprocess(unit, type, context.config()); - - // save to a tempory file first, then move all temporary unit files at the same time - try { - unit.setStorage(Files.createTempFile(null, null), - sr.getParserConfiguration().getCharacterEncoding()) - .getStorage().get().save(sr.getPrinter()); - } catch (IOException ex) { - throw new RuntimeException(ex); - } - - changedFiles.put(unit.getStorage().get().getPath(), absolutePath); - return Result.DONT_SAVE; + return Result.SAVE; } + } else { // Compilation issue - report and skip log.errorf( @@ -86,32 +68,9 @@ public com.github.javaparser.utils.SourceRoot.Callback.Result process(Path local return Result.DONT_SAVE; } }); - - changedFiles.entrySet().stream().forEach(new Consumer>() { - @Override - public void accept(Entry entry) { - try { - Files.move(entry.getKey(), entry.getValue(), StandardCopyOption.REPLACE_EXISTING); - } catch (IOException ex) { - throw new RuntimeException(ex); - } - } - }); - changedFiles.clear(); - } catch (Exception e) { // read issue, report and exit log.error("Unable to parse the classes generated using protoc - skipping gRPC post processing", e); - } finally { - changedFiles.entrySet().stream().forEach(new Consumer>() { - @Override - public void accept(Entry e) { - try { - Files.deleteIfExists(e.getKey()); - } catch (IOException discard) { - } - } - }); } }