testsuite: added first daemon test for gRPC board watch

.github/workflows/test-go-task.yml

@@ -89,6 +89,9 @@ jobs:
           repo-token: ${{ secrets.GITHUB_TOKEN }}
           version: 3.x
 
+      - name: Build arduino-cli
+        run: task go:build
+
       - name: Run tests
         run: task go:test
 

internal/integrationtest/arduino-cli_daemon_test.go

@@ -0,0 +1,87 @@
+// This file is part of arduino-cli.
+//
+// Copyright 2022 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 license@arduino.cc.
+
+package integrationtest
+
+import (
+	"context"
+	"fmt"
+	"io"
+	"testing"
+	"time"
+
+	"github.com/arduino/arduino-cli/rpc/cc/arduino/cli/commands/v1"
+	"github.com/arduino/go-paths-helper"
+	"github.com/stretchr/testify/require"
+)
+
+func TestArduinoCliDaemon(t *testing.T) {
+	env := NewEnvironment(t)
+	defer env.CleanUp()
+
+	cli := NewArduinoCliWithinEnvironment(t, paths.New("..", "..", "arduino-cli"), env)
+	defer cli.CleanUp()
+
+	_, _, err := cli.Run("core", "update-index")
+	require.NoError(t, err)
+
+	_ = cli.StartDeamon(false)
+
+	inst := cli.Create()
+	require.NoError(t, inst.Init("", "", func(ir *commands.InitResponse) {
+		fmt.Printf("INIT> %v\n", ir.GetMessage())
+	}))
+
+	// Run a one-shot board list
+	boardListResp, err := inst.BoardList(time.Second)
+	require.NoError(t, err)
+	fmt.Printf("Got boardlist response with %d ports\n", len(boardListResp.GetPorts()))
+
+	// Run a one-shot board list again (should not fail)
+	boardListResp, err = inst.BoardList(time.Second)
+	require.NoError(t, err)
+	fmt.Printf("Got boardlist response with %d ports\n", len(boardListResp.GetPorts()))
+
+	testWatcher := func() {
+		// Run watcher
+		watcher, err := inst.BoardListWatch()
+		require.NoError(t, err)
+		ctx, cancel := context.WithCancel(context.Background())
+		go func() {
+			defer cancel()
+			for {
+				msg, err := watcher.Recv()
+				if err == io.EOF {
+					fmt.Println("Watcher EOF")
+					return
+				}
+				require.Empty(t, msg.Error, "Board list watcher returned an error")
+				require.NoError(t, err, "BoardListWatch grpc call returned an error")
+				fmt.Printf("WATCH> %v\n", msg)
+			}
+		}()
+		time.Sleep(time.Second)
+		require.NoError(t, watcher.CloseSend())
+		select {
+		case <-ctx.Done():
+			// all right!
+		case <-time.After(time.Second):
+			require.Fail(t, "BoardListWatch didn't close")
+		}
+	}
+
+	testWatcher()
+	testWatcher()
+}