Compiler now read progress through GRPC

Author: cmaglie

arduino-core/src/cc/arduino/Compiler.java

@@ -205,10 +205,10 @@ public String build(List<CompilerProgressListener> progListeners, boolean export
 
     CompileResult result;
     try {
-      MessageConsumerOutputStream out = new MessageConsumerOutputStream(new ProgressAwareMessageConsumer(new I18NAwareMessageConsumer(System.out, System.err), progListeners), "\n");
+      MessageConsumerOutputStream out = new MessageConsumerOutputStream(new I18NAwareMessageConsumer(System.out, System.err), "\n");
       MessageConsumerOutputStream err = new MessageConsumerOutputStream(new I18NAwareMessageConsumer(System.err, this), "\n");
 
-      result = core.compile(req.build(), out, err);
+      result = core.compile(req.build(), out, err, progListeners);
 
       out.flush();
       err.flush();

arduino-core/src/cc/arduino/cli/ArduinoCoreInstance.java

@@ -39,6 +39,7 @@
 
 import com.google.protobuf.ByteString;
 
+import cc.arduino.CompilerProgressListener;
 import cc.arduino.cli.commands.ArduinoCoreGrpc.ArduinoCoreBlockingStub;
 import cc.arduino.cli.commands.Board.BoardDetailsReq;
 import cc.arduino.cli.commands.Board.BoardDetailsResp;
@@ -91,8 +92,8 @@ public void boardDetails(String fqbn) throws StatusException {
     }
   }
 
-  public CompileResult compile(CompileReq req, OutputStream out,
-                               OutputStream err) throws StatusException {
+  public CompileResult compile(CompileReq req, OutputStream out, OutputStream err,
+                               List<CompilerProgressListener> progressListeners) throws StatusException {
     req = CompileReq.newBuilder(req) //
         .setInstance(instance) //
         .build();
@@ -108,6 +109,13 @@ public CompileResult compile(CompileReq req, OutputStream out,
           ByteString errdata = resp.getErrStream();
           if (errdata != null)
             err.write(errdata.toByteArray());
+          TaskProgress taskProgress = resp.getTaskProgress();
+          if (taskProgress != null) {
+            float progress = taskProgress.getPercentCompleted();
+            if (progress > 0) {
+              progressListeners.forEach(l -> l.progress((int) progress));
+            }
+          }
         } catch (IOException e) {
           e.printStackTrace();
         }