Use build tags to separate func and integ tests

Using the build tags "integration" and "functional" we separate the two
class of tests.

Author: Fabio Falzoi

Makefile

@@ -27,7 +27,7 @@ integ-test:
 		$(GOBUILD) -ldflags "-X main.version=1.0.0-dev" github.com/arduino/arduino-connector
 		cd ./test && ./upload_dev_artifacts_on_s3.sh
 		cd ./test && vagrant provision
-		source ./test/setup_host_test_env.sh && $(GOTEST) ./... -timeout $(GOTEST_TIMEOUT)
+		source ./test/setup_host_test_env.sh && $(GOTEST) --tags=integration ./... -timeout $(GOTEST_TIMEOUT)
 
 teardown-test:
 		cd ./test && ./teardown_iot_device.sh

README.md

@@ -69,8 +69,8 @@ See [API](./API.md)
 This type of tests are executed all locally and you need to configure a dedicated docker container:
 - `docker pull guerra1994/go-mqtt-docker-env`
 - follow the steps [here](https://hub.docker.com/r/guerra1994/go-mqtt-docker-env) to run it
-- run mosquitto broker in background mode using `mosquitto &`
-- then run your test, for example `go test -v --run="TestDockerPsApi"`
+- run mosquitto broker in background mode using `mosquitto > /dev/null 2>&1 &`
+- then run your test, for example `go test -v --tags=functional --run="TestDockerPsApi"`
 
 
 ## Integration tests disclaimer

handlers_containers_functional_test.go

@@ -0,0 +1,75 @@
+// +build functional
+
+package main
+
+import (
+	"encoding/json"
+	"os"
+	"os/exec"
+	"strings"
+	"testing"
+	"time"
+
+	"github.com/docker/docker/api/types"
+	docker "github.com/docker/docker/client"
+	mqtt "github.com/eclipse/paho.mqtt.golang"
+	"github.com/stretchr/testify/assert"
+)
+
+type testStatus struct {
+	appStatus *Status
+	ui        *MqttTestClient
+}
+
+var ts testStatus
+
+func TestMain(m *testing.M) {
+	os.Exit(setupAndRun(m))
+}
+
+func setupAndRun(m *testing.M) int {
+	ts.ui = NewMqttTestClientLocal()
+	defer ts.ui.Close()
+
+	ts.appStatus = NewStatus(program{}.Config, nil, nil, "")
+	ts.appStatus.dockerClient, _ = docker.NewClientWithOpts(docker.WithVersion("1.38"))
+	ts.appStatus.mqttClient = mqtt.NewClient(mqtt.NewClientOptions().AddBroker("tcp://localhost:1883").SetClientID("arduino-connector"))
+
+	defer ts.appStatus.mqttClient.Disconnect(100)
+
+	return m.Run()
+}
+
+func TestDockerPsApi(t *testing.T) {
+	if token := ts.appStatus.mqttClient.Connect(); token.Wait() && token.Error() != nil {
+		t.Fatal(token.Error())
+	}
+
+	subscribeTopic(ts.appStatus.mqttClient, "0", "/containers/ps/post", ts.appStatus, ts.appStatus.ContainersPsEvent, false)
+	resp := ts.ui.MqttSendAndReceiveTimeout(t, "/containers/ps", "{}", 50*time.Millisecond)
+
+	// ask Docker about containers effectively running
+	cmd := exec.Command("bash", "-c", "docker ps -a")
+	out, err := cmd.CombinedOutput()
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	lines := strings.Split(string(out), "\n")
+	// Remove the first line (command output header) and the last line (empty line)
+	lines = lines[1 : len(lines)-1]
+
+	// Take json without INFO tag
+	resp = strings.TrimPrefix(resp, "INFO: ")
+	resp = strings.TrimSuffix(resp, "\n\n")
+	var result []types.Container
+	if err := json.Unmarshal([]byte(resp), &result); err != nil {
+		t.Fatal(err)
+	}
+
+	assert.Equal(t, len(result), len(lines))
+	for i, line := range lines {
+		containerId := strings.Fields(line)[0]
+		assert.True(t, strings.HasPrefix(result[i].ID, containerId))
+	}
+}