Revert "Postprocess in temporary files before moving all of them at t…

…he same time" This reverts commit 8d01ea5.
quarkusio · Feb 10, 2023 · 8ee1451 · 8ee1451
1 parent ede6b7b
commit 8ee1451
Showing 1 changed file with 2 additions and 43 deletions.
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
@@ -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<Path, Path> changedFiles = new HashMap<Path, Path>();
         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<Entry<Path, Path>>() {
-                @Override
-                public void accept(Entry<Path, Path> 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<Entry<Path, Path>>() {
-                @Override
-                public void accept(Entry<Path, Path> e) {
-                    try {
-                        Files.deleteIfExists(e.getKey());
-                    } catch (IOException discard) {
-                    }
-                }
-            });
         }
     }