added Rescan function

Author: Rocketct

commands/instances.go

@@ -181,3 +181,80 @@ func UpdateLibrariesIndex(ctx context.Context, lm *librariesmanager.LibrariesMan
 		//os.Exit(ErrNetwork)
 	}
 }
+
+func Rescan(ctx context.Context, req *rpc.RescanReq) (*rpc.RescanResp, error) {
+	id := req.Instance.Id
+	coreInstance, ok := instances[id]
+	if !ok {
+		return nil, fmt.Errorf("invalid handle")
+	}
+
+	config := coreInstance.config
+	if config == nil {
+		return nil, fmt.Errorf("invalid request")
+	}
+
+	var pm *packagemanager.PackageManager
+	pm = packagemanager.NewPackageManager(
+		config.IndexesDir(),
+		config.PackagesDir(),
+		config.DownloadsDir(),
+		config.DataDir.Join("tmp"))
+
+	for _, URL := range config.BoardManagerAdditionalUrls {
+		if err := pm.LoadPackageIndex(URL); err != nil {
+			return nil, fmt.Errorf("loading "+URL.String()+" package index: %s", err)
+		}
+	}
+
+	if err := pm.LoadHardware(config); err != nil {
+		return nil, fmt.Errorf("loading hardware packages: %s", err)
+	}
+
+	// Initialize library manager
+	// --------------------------
+	lm := librariesmanager.NewLibraryManager(
+		config.IndexesDir(),
+		config.DownloadsDir())
+
+	// Add IDE builtin libraries dir
+	if bundledLibsDir := config.IDEBundledLibrariesDir(); bundledLibsDir != nil {
+		lm.AddLibrariesDir(bundledLibsDir, libraries.IDEBuiltIn)
+	}
+
+	// Add sketchbook libraries dir
+	lm.AddLibrariesDir(config.LibrariesDir(), libraries.Sketchbook)
+
+	// Add libraries dirs from installed platforms
+	if pm != nil {
+		for _, targetPackage := range pm.GetPackages().Packages {
+			for _, platform := range targetPackage.Platforms {
+				if platformRelease := pm.GetInstalledPlatformRelease(platform); platformRelease != nil {
+					lm.AddPlatformReleaseLibrariesDir(platformRelease, libraries.PlatformBuiltIn)
+				}
+			}
+		}
+	}
+
+	// Load index and auto-update it if needed
+	if err := lm.LoadIndex(); err != nil {
+		UpdateLibrariesIndex(ctx, lm, func(curr *rpc.DownloadProgress) {
+			fmt.Printf(">> %+v\n", curr)
+		})
+		if err := lm.LoadIndex(); err != nil {
+			return nil, fmt.Errorf("loading libraries index: %s", err)
+		}
+	}
+
+	// Scan for libraries
+	if err := lm.RescanLibraries(); err != nil {
+		return nil, fmt.Errorf("libraries rescan: %s", err)
+	}
+
+	coreInstance.pm = pm
+	coreInstance.lm = lm
+	id = req.Instance.Id
+	return &rpc.RescanResp{
+		Instance: &rpc.Instance{Id: id},
+	}, nil
+}

daemon/client/client.go

@@ -34,12 +34,24 @@ func main() {
 	}
 	instance := resp.GetInstance()
 	fmt.Println("Created new server instance:", instance)
-
+	UninstalResp, err := client.PlatformUninstall(context.Background(), &rpc.PlatformUninstallReq{
+		Instance:        instance,
+		PlatformPackage: "arduino",
+		Architecture:    "samd",
+		Version:         "1.6.21",
+	})
+	if err != nil {
+		if UninstalResp != nil {
+		}
+		fmt.Printf("uninstall error: %s\n", err)
+		os.Exit(1)
+	}
 	install := func() {
 		installRespStream, err := client.PlatformInstall(context.Background(), &rpc.PlatformInstallReq{
 			Instance:        instance,
 			PlatformPackage: "arduino",
 			Architecture:    "samd",
+			Version:         "1.6.19",
 		})
 		if err != nil {
 			fmt.Printf("Error installing platform: %s\n", err)
@@ -58,9 +70,39 @@ func main() {
 		}
 		fmt.Println("Installation completed!")
 	}
-
-	install()
 	install()
+	respResc, err := client.Rescan(context.Background(), &rpc.RescanReq{
+		Instance: instance,
+	})
+	if err != nil {
+		fmt.Printf("Error creating server instance: %s\n", err)
+		os.Exit(1)
+	}
+	instance = respResc.GetInstance()
+	upgrade := func() {
+		upgradeRespStream, err := client.PlatformUpgrade(context.Background(), &rpc.PlatformUpgradeReq{
+			Instance:        instance,
+			PlatformPackage: "arduino",
+			Architecture:    "samd",
+		})
+		if err != nil {
+			fmt.Printf("Error Upgrade platform: %s\n", err)
+			os.Exit(1)
+		}
+		for {
+			upgradeResp, err := upgradeRespStream.Recv()
+			if err == io.EOF {
+				break
+			}
+			if err != nil {
+				fmt.Printf("Install error: %s\n", err)
+				os.Exit(1)
+			}
+			fmt.Printf("%s\n", upgradeResp.GetProgress())
+		}
+		fmt.Println("Upgrade completed!")
+	}
+	upgrade()
 
 	details, err := client.BoardDetails(context.Background(), &rpc.BoardDetailsReq{
 		Instance: instance,

daemon/daemon.go

@@ -47,6 +47,10 @@ func (s *ArduinoCoreServerImpl) Destroy(ctx context.Context, req *rpc.DestroyReq
 	return commands.Destroy(ctx, req)
 }
 
+func (s *ArduinoCoreServerImpl) Rescan(ctx context.Context, req *rpc.RescanReq) (*rpc.RescanResp, error) {
+	return commands.Rescan(ctx, req)
+}
+
 func (s *ArduinoCoreServerImpl) Init(ctx context.Context, req *rpc.InitReq) (*rpc.InitResp, error) {
 	return commands.Init(ctx, req)
 }