Added integration-test to check handling of multiple discovery instances

Author: cmaglie

internal/integrationtest/arduino-cli.go

@@ -506,6 +506,13 @@ func (cli *ArduinoCLI) Create() *ArduinoCLIInstance {
 	}
 }
 
+// Destroy calls the "Destroy" gRPC method.
+func (inst *ArduinoCLIInstance) Destroy(ctx context.Context) error {
+	logCallf(">>> Destroy(%v)\n", inst.instance.GetId())
+	_, err := inst.cli.daemonClient.Destroy(ctx, &commands.DestroyRequest{Instance: inst.instance})
+	return err
+}
+
 // SetValue calls the "SetValue" gRPC method.
 func (cli *ArduinoCLI) SetValue(key, jsonData string) error {
 	req := &commands.SettingsSetValueRequest{

internal/integrationtest/daemon/discoveries_test.go

@@ -0,0 +1,86 @@
+// This file is part of arduino-cli.
+//
+// Copyright 2025 ARDUINO SA (http://www.arduino.cc/)
+//
+// This software is released under the GNU General Public License version 3,
+// which covers the main part of arduino-cli.
+// The terms of this license can be found at:
+// https://www.gnu.org/licenses/gpl-3.0.en.html
+//
+// You can be released from the requirements of the above licenses by purchasing
+// a commercial license. Buying such a license is mandatory if you want to
+// modify or otherwise use the software for commercial activities involving the
+// Arduino software without disclosing the source code of your own applications.
+// To purchase a commercial license, send an email to [email protected].
+
+package daemon
+
+import (
+	"fmt"
+	"testing"
+	"time"
+
+	"github.com/arduino/arduino-cli/internal/integrationtest"
+	"github.com/arduino/arduino-cli/rpc/cc/arduino/cli/commands/v1"
+	"github.com/stretchr/testify/require"
+)
+
+func TestBoardListMock(t *testing.T) {
+	env, cli := integrationtest.CreateEnvForDaemon(t)
+	defer env.CleanUp()
+
+	_, _, err := cli.Run("core", "update-index")
+	require.NoError(t, err)
+
+	cli.InstallMockedSerialDiscovery(t)
+
+	var tmp1, tmp2 string
+
+	{
+		// Create a new instance of the daemon
+		grpcInst := cli.Create()
+		require.NoError(t, grpcInst.Init("", "", func(ir *commands.InitResponse) {
+			fmt.Printf("INIT> %v\n", ir.GetMessage())
+		}))
+
+		// Run a BoardList
+		resp, err := grpcInst.BoardList(time.Second)
+		require.NoError(t, err)
+		require.NotEmpty(t, resp.Ports)
+		for _, port := range resp.Ports {
+			if port.GetPort().GetProtocol() == "serial" {
+				tmp1 = port.Port.GetProperties()["discovery_tmp"]
+			}
+		}
+		require.NotEmpty(t, tmp1)
+
+		// Close instance
+		require.NoError(t, grpcInst.Destroy(t.Context()))
+	}
+
+	{
+		// Create a second instance of the daemon
+		grpcInst := cli.Create()
+		require.NoError(t, grpcInst.Init("", "", func(ir *commands.InitResponse) {
+			fmt.Printf("INIT> %v\n", ir.GetMessage())
+		}))
+
+		// Run a BoardList
+		resp, err := grpcInst.BoardList(time.Second)
+		require.NoError(t, err)
+		require.NotEmpty(t, resp.Ports)
+		for _, port := range resp.Ports {
+			if port.GetPort().GetProtocol() == "serial" {
+				tmp2 = port.Port.GetProperties()["discovery_tmp"]
+			}
+		}
+		require.NotEmpty(t, tmp2)
+
+		// Close instance
+		require.NoError(t, grpcInst.Destroy(t.Context()))
+	}
+
+	// Check if the discoveries have been successfully close
+	require.NoFileExists(t, tmp1, "discovery has not been closed")
+	require.NoFileExists(t, tmp2, "discovery has not been closed")
+}

internal/mock_serial_discovery/main.go

@@ -19,20 +19,39 @@ package main
 
 import (
 	"errors"
+	"fmt"
 	"os"
 	"time"
 
+	"github.com/arduino/go-paths-helper"
 	"github.com/arduino/go-properties-orderedmap"
 	discovery "github.com/arduino/pluggable-discovery-protocol-handler/v2"
 )
 
 type mockSerialDiscovery struct {
 	startSyncCount int
 	closeChan      chan<- bool
+	tmpFile        string
 }
 
 func main() {
-	dummy := &mockSerialDiscovery{}
+	// Write a file in a $TMP/mock_serial_discovery folder.
+	// This file will be used by the integration tests to detect if the discovery is running.
+	tmpDir := paths.TempDir().Join("mock_serial_discovery")
+	if err := tmpDir.MkdirAll(); err != nil {
+		fmt.Fprintf(os.Stderr, "Error creating temp dir: %v\n", err)
+		os.Exit(1)
+	}
+	tmpFile, err := paths.MkTempFile(tmpDir, "")
+	if err != nil {
+		fmt.Fprintf(os.Stderr, "Error creating temp file: %v\n", err)
+		os.Exit(1)
+	}
+	tmpFile.Close()
+	defer os.Remove(tmpFile.Name())
+
+	// Run mock discovery
+	dummy := &mockSerialDiscovery{tmpFile: tmpFile.Name()}
 	server := discovery.NewServer(dummy)
 	if err := server.Run(os.Stdin, os.Stdout); err != nil {
 		os.Exit(1)
@@ -80,9 +99,10 @@ func (d *mockSerialDiscovery) StartSync(eventCB discovery.EventCallback, errorCB
 			ProtocolLabel: "Serial",
 			HardwareID:    "123456",
 			Properties: properties.NewFromHashmap(map[string]string{
-				"vid":    "0x2341",
-				"pid":    "0x0041",
-				"serial": "123456",
+				"vid":           "0x2341",
+				"pid":           "0x0041",
+				"serial":        "123456",
+				"discovery_tmp": d.tmpFile,
 			}),
 		})