Added status streaming to Init grpc call

This will be useful in the next commits

Author: cmaglie

cli/cli.go

@@ -86,7 +86,7 @@ func packageManagerInitReq() *rpc.InitReq {
 func InitInstance() *rpc.InitResp {
 	logrus.Info("Initializing package manager")
 	req := packageManagerInitReq()
-	resp, err := commands.Init(context.Background(), req)
+	resp, err := commands.Init(context.Background(), req, OutputProgressBar(), OutputTaskProgress())
 	if err != nil {
 		formatter.PrintError(err, "Error initializing package manager")
 		os.Exit(ErrGeneric)

commands/instances.go

@@ -72,7 +72,7 @@ func GetLibraryManager(req InstanceContainer) *librariesmanager.LibrariesManager
 	return i.lm
 }
 
-func Init(ctx context.Context, req *rpc.InitReq) (*rpc.InitResp, error) {
+func Init(ctx context.Context, req *rpc.InitReq, downloadCB DownloadProgressCB, taskCB TaskProgressCB) (*rpc.InitResp, error) {
 	inConfig := req.GetConfiguration()
 	if inConfig == nil {
 		return nil, fmt.Errorf("invalid request")

daemon/client/client.go

@@ -46,7 +46,7 @@ func main() {
 
 	// INIT
 	fmt.Println("=== calling Init")
-	initResp, err := client.Init(context.Background(), &rpc.InitReq{
+	initRespStream, err := client.Init(context.Background(), &rpc.InitReq{
 		Configuration: &rpc.Configuration{
 			DataDir: datadir,
 		},
@@ -55,9 +55,28 @@ func main() {
 		fmt.Printf("Error creating server instance: %s\n", err)
 		os.Exit(1)
 	}
-	instance := initResp.GetInstance()
-	fmt.Printf("---> %+v\n", initResp)
-	fmt.Println()
+	var instance *rpc.Instance
+	for {
+		initResp, err := initRespStream.Recv()
+		if err == io.EOF {
+			fmt.Println()
+			break
+		}
+		if err != nil {
+			fmt.Printf("Init error: %s\n", err)
+			os.Exit(1)
+		}
+		if initResp.GetInstance() != nil {
+			instance = initResp.GetInstance()
+			fmt.Printf("---> %+v\n", initResp)
+		}
+		if initResp.GetDownloadProgress() != nil {
+			fmt.Printf(">> DOWNLOAD: %s\n", initResp.GetDownloadProgress())
+		}
+		if initResp.GetTaskProgress() != nil {
+			fmt.Printf(">> TASK: %s\n", initResp.GetTaskProgress())
+		}
+	}
 
 	// UPDATE-INDEX
 	fmt.Println("=== calling UpdateIndex")

daemon/daemon.go

@@ -103,8 +103,16 @@ func (s *ArduinoCoreServerImpl) UpdateLibrariesIndex(req *rpc.UpdateLibrariesInd
 	return stream.Send(&rpc.UpdateLibrariesIndexResp{})
 }
 
-func (s *ArduinoCoreServerImpl) Init(ctx context.Context, req *rpc.InitReq) (*rpc.InitResp, error) {
-	return commands.Init(ctx, req)
+func (s *ArduinoCoreServerImpl) Init(req *rpc.InitReq, stream rpc.ArduinoCore_InitServer) error {
+	resp, err := commands.Init(stream.Context(), req,
+		func(p *rpc.DownloadProgress) { stream.Send(&rpc.InitResp{DownloadProgress: p}) },
+		func(p *rpc.TaskProgress) { stream.Send(&rpc.InitResp{TaskProgress: p}) },
+	)
+	if err != nil {
+		return err
+	}
+	fmt.Println(resp)
+	return stream.Send(resp)
 }
 
 func (s *ArduinoCoreServerImpl) Compile(req *rpc.CompileReq, stream rpc.ArduinoCore_CompileServer) error {