Added GRPC feedback on TaskProgress

Author: cmaglie

daemon/client/client.go

@@ -55,7 +55,12 @@ func main() {
 				fmt.Printf("Install error: %s\n", err)
 				return
 			}
-			fmt.Printf("%s\n", installResp.GetProgress())
+			if installResp.GetProgress() != nil {
+				fmt.Printf(">> DOWNLOAD: %s\n", installResp.GetProgress())
+			}
+			if installResp.GetTaskProgress() != nil {
+				fmt.Printf(">> TASK: %s\n", installResp.GetTaskProgress())
+			}
 		}
 		fmt.Println("Installation completed!")
 	}
@@ -81,7 +86,12 @@ func main() {
 			fmt.Printf("Upgrade error: %s\n", err)
 			os.Exit(1)
 		}
-		fmt.Printf("%s\n", upgradeResp.GetProgress())
+		if upgradeResp.GetProgress() != nil {
+			fmt.Printf(">> DOWNLOAD: %s\n", upgradeResp.GetProgress())
+		}
+		if upgradeResp.GetTaskProgress() != nil {
+			fmt.Printf(">> TASK: %s\n", upgradeResp.GetTaskProgress())
+		}
 	}
 	fmt.Println("Upgrade completed!")
 
@@ -114,25 +124,13 @@ func main() {
 			fmt.Printf("Compile error: %s\n", err)
 			os.Exit(1)
 		}
-		fmt.Printf("%s", compResp.GetOutput())
-	}
-	/*
-		compile, err := client.Compile(context.Background(), &pb.CompileReq{})
-		if err != nil {
-			log.Fatal(err)
+		if compResp.GetOutput() != nil {
+			fmt.Printf("%s", compResp.GetOutput())
 		}
-		for {
-			resp, err := compile.Recv()
-			if err == io.EOF {
-				break
-			}
-			if err != nil {
-				fmt.Printf("%+v\n", err)
-				log.Fatal(err)
-			}
-			fmt.Println(resp)
+		if compResp.GetTaskProgress() != nil {
+			fmt.Printf(">> TASK: %s\n", compResp.GetTaskProgress())
 		}
-	*/
+	}
 
 	_, err = client.PlatformUninstall(context.Background(), &rpc.PlatformUninstallReq{
 		Instance:        instance,

daemon/daemon.go

@@ -68,7 +68,7 @@ func (s *ArduinoCoreServerImpl) Compile(req *rpc.CompileReq, stream rpc.ArduinoC
 		}
 	}()
 	resp, err := compile.Compile(stream.Context(), req, w, func(taskProgress *rpc.TaskProgress) {
-		// TODO
+		stream.Send(&rpc.CompileResp{TaskProgress: taskProgress})
 	})
 	stream.Send(resp)
 	return err
@@ -78,7 +78,7 @@ func (s *ArduinoCoreServerImpl) PlatformInstall(req *rpc.PlatformInstallReq, str
 	resp, err := core.PlatformInstall(stream.Context(), req, func(progress *rpc.DownloadProgress) {
 		stream.Send(&rpc.PlatformInstallResp{Progress: progress})
 	}, func(taskProgress *rpc.TaskProgress) {
-		// TODO
+		stream.Send(&rpc.PlatformInstallResp{TaskProgress: taskProgress})
 	})
 	if err != nil {
 		return err
@@ -104,7 +104,7 @@ func (s *ArduinoCoreServerImpl) PlatformUpgrade(req *rpc.PlatformUpgradeReq, str
 	resp, err := core.PlatformUpgrade(stream.Context(), req, func(progress *rpc.DownloadProgress) {
 		stream.Send(&rpc.PlatformUpgradeResp{Progress: progress})
 	}, func(taskProgress *rpc.TaskProgress) {
-		// TODO
+		stream.Send(&rpc.PlatformUpgradeResp{TaskProgress: taskProgress})
 	})
 	if err != nil {
 		return err

rpc/compile.pb.go

@@ -24,4 +24,5 @@ message CompileReq {
 
 message CompileResp {
   bytes output = 1;
+  TaskProgress task_progress = 2;
 }