feat(install): commands check version currency before running

Now that we have departed from packaging the CLI tools as part
of pact-go, we needed a mechanism to ensure the tools matched
the library.

The only sensible time for this is at runtime, prior to executing
the tests.

Author: mefellows

client/service_manager.go

@@ -21,6 +21,7 @@ type ServiceManager struct {
 // Setup the Management services.
 func (s *ServiceManager) Setup() {
 	log.Println("[DEBUG] setting up a service manager")
+
 	s.commandCreatedChan = make(chan *exec.Cmd)
 	s.commandCompleteChan = make(chan *exec.Cmd)
 	s.processes = make(map[int]*exec.Cmd)

command/install.go

@@ -1,23 +1,29 @@
 package command
 
 import (
-	"fmt"
+	"log"
+	"os"
+
+	"github.com/pact-foundation/pact-go/install"
 
 	"github.com/spf13/cobra"
 )
 
 var path string
 var installCmd = &cobra.Command{
 	Use:   "install",
-	Short: "Install required tools",
-	Long:  "Installs underlying Pact standalone tools for use by the library",
+	Short: "Check required tools",
+	Long:  "Checks versions of required Pact CLI tools for used by the library",
 	Run: func(cmd *cobra.Command, args []string) {
 		setLogLevel(verbose, logLevel)
 
 		// Run the installer
-		fmt.Println("[INFO] Installing required tools...", path)
-		fmt.Println("[INFO] Checking installation succeeded...")
-		fmt.Println("[INFO] Tooling installed and up to date!")
+		i := install.NewInstaller()
+		var err error
+		if err = i.CheckInstallation(); err != nil {
+			log.Println("[ERROR] Your Pact CLI installation is out of date, please update to the latest version. Error:", err)
+			os.Exit(1)
+		}
 	},
 }
 

dsl/mock_service.go

@@ -61,7 +61,6 @@ func (m *MockService) call(method string, url string, content interface{}) error
 
 	responseBody, err := ioutil.ReadAll(res.Body)
 	res.Body.Close()
-	log.Printf("[DEBUG] mock service response Body: %s\n", responseBody)
 	if res.StatusCode < 200 || res.StatusCode >= 300 {
 		return errors.New(string(responseBody))
 	}

dsl/pact.go

@@ -13,6 +13,7 @@ import (
 
 	"github.com/hashicorp/logutils"
 	"github.com/pact-foundation/pact-go/client"
+	"github.com/pact-foundation/pact-go/install"
 	"github.com/pact-foundation/pact-go/types"
 	"github.com/pact-foundation/pact-go/utils"
 )
@@ -73,6 +74,14 @@ type Pact struct {
 	// Ports MockServer can be deployed to, can be CSV or Range with a dash
 	// Example "1234", "12324,5667", "1234-5667"
 	AllowedMockServerPorts string
+
+	// DisableToolValidityCheck prevents CLI version checking - use this carefully!
+	// The ideal situation is to check the tool installation with  before running
+	// the tests, which should speed up large test suites significantly
+	DisableToolValidityCheck bool
+
+	// Check if CLI tools are up to date
+	toolValidityCheck bool
 }
 
 // AddInteraction creates a new Pact interaction, initialising all
@@ -97,6 +106,11 @@ func (p *Pact) Setup(startMockServer bool) *Pact {
 		p.Network = "tcp"
 	}
 
+	if !p.toolValidityCheck && !p.DisableToolValidityCheck {
+		checkCliCompatibility()
+		p.toolValidityCheck = true
+	}
+
 	if p.Host == "" {
 		p.Host = "localhost"
 	}
@@ -163,7 +177,7 @@ func (p *Pact) setupLogging() {
 			p.LogLevel = "INFO"
 		}
 		p.logFilter = &logutils.LevelFilter{
-			Levels:   []logutils.LogLevel{"DEBUG", "WARN", "ERROR"},
+			Levels:   []logutils.LogLevel{"DEBUG", "INFO", "WARN", "ERROR"},
 			MinLevel: logutils.LogLevel(p.LogLevel),
 			Writer:   os.Stderr,
 		}
@@ -279,3 +293,15 @@ func (p *Pact) VerifyProvider(t *testing.T, request types.VerifyRequest) (types.
 
 	return res, err
 }
+
+var installer = install.NewInstaller()
+
+var checkCliCompatibility = func() {
+	log.Println("[DEBUG] checking CLI compatability")
+	err := installer.CheckInstallation()
+
+	if err != nil {
+		log.Println("[DEBUG] asoetusaoteuasoet")
+		log.Fatal("[ERROR] CLI tools are out of date, please upgrade before continuing.")
+	}
+}

dsl/pact_test.go

@@ -10,6 +10,11 @@ import (
 	"github.com/pact-foundation/pact-go/types"
 )
 
+func init() {
+	// mock out this function
+	checkCliCompatibility = func() {}
+}
+
 func TestPact_setupLogging(t *testing.T) {
 	res := captureOutput(func() {
 		(&Pact{LogLevel: "DEBUG"}).setupLogging()

examples/consumer/goconsumer/user_service_test.go

@@ -97,10 +97,12 @@ func setup() {
 // Create Pact connecting to local Daemon
 func createPact() dsl.Pact {
 	return dsl.Pact{
-		Consumer: "billy",
-		Provider: "bobby",
-		LogDir:   logDir,
-		PactDir:  pactDir,
+		Consumer:                 "billy",
+		Provider:                 "bobby",
+		LogDir:                   logDir,
+		PactDir:                  pactDir,
+		LogLevel:                 "DEBUG",
+		DisableToolValidityCheck: true,
 	}
 }
 

install/install_darwin.go

@@ -13,11 +13,12 @@ import (
 
 // Installer manages the underlying Ruby installation
 type Installer struct {
+	commander commander
 }
 
 const (
 	mockServiceRange = ">= 2.6.4, < 3.0.0"
-	verifierRange    = ">= 1.11.0, < 2.0.0"
+	verifierRange    = ">= 1.12.0, < 3.0.0"
 	brokerRange      = ">= 1.14.0, < 2.0.0"
 )
 
@@ -27,6 +28,11 @@ var versionMap = map[string]string{
 	"pact-broker":            brokerRange,
 }
 
+// NewInstaller creates a new initialised Installer
+func NewInstaller() *Installer {
+	return &Installer{commander: realCommander{}}
+}
+
 // CheckInstallation checks installation of all of the tools
 func (i *Installer) CheckInstallation() error {
 
@@ -68,7 +74,7 @@ func (i *Installer) CheckVersion(binary, version string) error {
 		return nil
 	}
 
-	return fmt.Errorf("version %s does not match constraint %s", version, versionRange)
+	return fmt.Errorf("version %s of %s does not match constraint %s", version, binary, versionRange)
 }
 
 // InstallTools installs the CLI tools onto the host system
@@ -82,9 +88,20 @@ func (i *Installer) InstallTools() error {
 func (i *Installer) GetVersionForBinary(binary string) (version string, err error) {
 	log.Println("[DEBUG] running binary", binary)
 
-	cmd := exec.Command(binary, "version")
-	content, err := cmd.Output()
+	content, err := i.commander.Output(binary, "version")
 	version = string(content)
 
 	return strings.TrimSpace(version), err
 }
+
+// commander wraps the exec package, allowing us
+// properly test the file system
+type commander interface {
+	Output(command string, args ...string) ([]byte, error)
+}
+
+type realCommander struct{}
+
+func (c realCommander) Output(command string, args ...string) ([]byte, error) {
+	return exec.Command(command, args...).CombinedOutput()
+}