Add consumer side of WIT+Auth contract tests.

.make/test.mk

@@ -180,6 +180,38 @@ test-integration-benchmark: prebuild-check migrate-database $(SOURCES)
 	$(eval TEST_PACKAGES:=$(shell go list ./... | grep -v $(ALL_PKGS_EXCLUDE_PATTERN)))
 	F8_DEVELOPER_MODE_ENABLED=1 F8_RESOURCE_DATABASE=1 F8_RESOURCE_UNIT_TEST=0 F8_LOG_LEVEL=$(F8_LOG_LEVEL) go test -run=^$$ -bench=. -cpu 1,2,4 -test.benchmem $(GO_TEST_VERBOSITY_FLAG) $(TEST_PACKAGES) | grep -E "Bench|allocs"
 
+.PHONY: test-contracts-consumer-no-coverage
+## Runs the consumer side of contract tests WITHOUT producing coverage files for each package.
+test-contracts-consumer-no-coverage:
+	$(call log-info,"Running test: $@")
+	$(eval TEST_PACKAGES:=$(shell go list ./... | grep -e 'contracts/consumer'))
+	$(eval PACT_DIR=$(PWD)/test/contracts/pacts)
+	$(eval PACT_VERSION="latest")
+	go test $(GO_TEST_VERBOSITY_FLAG) -count=1 $(TEST_PACKAGES)
+
+.PHONY: publish-contract-testing-pacts-to-broker
+## Publishes generated Pact file (the contracts) to the Pact broker.
+## The following env variables needs to be set in environment:
+## - Pact broker for storing pact files
+##   PACT_BROKER_URL
+##   PACT_BROKER_USERNAME
+##   PACT_BROKER_PASSWORD
+publish-contract-testing-pacts-to-broker:
+	$(call log-info,"Publishing pact files to Broker")
+	$(eval PACT_DIR=$(PWD)/test/contracts/pacts)
+	$(eval PACT_FILES:=$(shell find $(PACT_DIR) -name '*.json'))
+	$(eval PACT_VERSION?=1.0.0)
+	$(eval PACT_TAGS?=latest)
+	go run ./test/contracts/publisher/main.go "$(PACT_FILES)" "$(PACT_VERSION)" "$(PACT_TAGS)"
+
+.PHONY: clean-contract-tests
+## Cleans generated pacts and logs from contract tests
+clean-contract-tests:
+	$(call log-info,"Cleaning generated pacts and logs from contract tests")
+	$(eval PACT_DIR=$(PWD)/test/contracts/pacts)
+	$(eval LOGS_TO_BE_CLEANED:=$(shell find test/contracts -name '*logs'))
+	rm -rvf $(PACT_DIR) $(LOGS_TO_BE_CLEANED)
+
 .PHONY: test-remote
 ## Runs the remote tests and produces coverage files for each package.
 test-remote: prebuild-check clean-coverage-remote $(COV_PATH_REMOTE)

cico_run_contract_tests_consumer.sh

@@ -0,0 +1,13 @@
+#!/bin/bash
+
+. cico_setup.sh
+
+cico_setup;
+
+set -e
+
+# Run the contract tests
+make test-contracts-consumer-no-coverage
+
+# Publish the generated Pact files to Pact broker.
+make publish-contract-testing-pacts-to-broker

test/contracts/.gitignore

@@ -0,0 +1,4 @@
+pacts
+output
+**/*/log
+**/*/logs

test/contracts/consumer/fabric8auth/api_status.go

@@ -0,0 +1,37 @@
+package fabric8auth_test
+
+import (
+	"log"
+	"testing"
+
+	"github.com/fabric8-services/fabric8-auth/test/contracts/model"
+	"github.com/fabric8-services/fabric8-wit/test/contracts"
+	"github.com/fabric8-services/fabric8-wit/test/contracts/consumer"
+	"github.com/pact-foundation/pact-go/dsl"
+)
+
+// AuthAPIStatus defines contract of /api/status endpoint
+func AuthAPIStatus(t *testing.T, pact *dsl.Pact) {
+
+	log.Printf("Invoking AuthAPIStatus now\n")
+
+	// Set up our expected interactions.
+	pact.
+		AddInteraction().
+		Given("Auth service is up and running.").
+		UponReceiving("A request to get status").
+		WithRequest(dsl.Request{
+			Method:  "GET",
+			Path:    dsl.String("/api/status"),
+			Headers: dsl.MapMatcher{"Content-Type": dsl.String("application/json")},
+		}).
+		WillRespondWith(dsl.Response{
+			Status:  200,
+			Headers: dsl.MapMatcher{"Content-Type": dsl.String("application/vnd.status+json")},
+			Body:    dsl.Match(model.APIStatusMessage{}),
+		})
+
+	// Verify
+	err := pact.Verify(consumer_test.SimpleGetInteraction(pact, "/api/status"))
+	contracts_test.CheckErrorAndCleanPact(t, pact, err) //workaround for https://github.com/pact-foundation/pact-go/issues/108
+}

test/contracts/consumer/fabric8auth/api_token.go

@@ -0,0 +1,36 @@
+package fabric8auth_test
+
+import (
+	"log"
+	"testing"
+
+	"github.com/fabric8-services/fabric8-auth/test/contracts/model"
+	"github.com/fabric8-services/fabric8-wit/test/contracts"
+	"github.com/fabric8-services/fabric8-wit/test/contracts/consumer"
+	"github.com/pact-foundation/pact-go/dsl"
+)
+
+// AuthAPITokenKeys defines contract of /api/status endpoint
+func AuthAPITokenKeys(t *testing.T, pact *dsl.Pact) {
+
+	log.Printf("Invoking AuthAPITokenKeys now\n")
+
+	// Set up our expected interactions.
+	pact.
+		AddInteraction().
+		Given("Auth service is up and running.").
+		UponReceiving("A request to get public keys").
+		WithRequest(dsl.Request{
+			Method: "GET",
+			Path:   dsl.String("/api/token/keys"),
+		}).
+		WillRespondWith(dsl.Response{
+			Status:  200,
+			Headers: dsl.MapMatcher{"Content-Type": dsl.String("application/vnd.publickeys+json")},
+			Body:    dsl.Match(model.TokenKeys{}),
+		})
+
+	// Verify
+	err := pact.Verify(consumer_test.SimpleGetInteraction(pact, "/api/token/keys"))
+	contracts_test.CheckErrorAndCleanPact(t, pact, err) //workaround for https://github.com/pact-foundation/pact-go/issues/108
+}

test/contracts/consumer/fabric8auth/api_user.go

@@ -0,0 +1,167 @@
+package fabric8auth_test
+
+import (
+	"fmt"
+	"log"
+	"testing"
+
+	"github.com/fabric8-services/fabric8-auth/test/contracts/model"
+	"github.com/fabric8-services/fabric8-wit/test/contracts"
+	consumer "github.com/fabric8-services/fabric8-wit/test/contracts/consumer"
+	"github.com/pact-foundation/pact-go/dsl"
+)
+
+// AuthAPIUserByName defines contract of /api/users?filter[username]=<user_name> endpoint
+func AuthAPIUserByName(t *testing.T, pact *dsl.Pact, userName string) {
+
+	log.Println("Invoking AuthAPIUserByName test interaction now")
+
+	// Set up our expected interactions.
+	pact.
+		AddInteraction().
+		Given("User with a given username exists.").
+		UponReceiving("A request to get user's information by username").
+		WithRequest(dsl.Request{
+			Method: "GET",
+			Path:   dsl.String("/api/users"),
+			Query: dsl.MapMatcher{
+				"filter[username]": dsl.Term(
+					userName,
+					model.UserNameRegex,
+				),
+			},
+			Headers: dsl.MapMatcher{"Content-Type": dsl.String("application/json")},
+		}).
+		WillRespondWith(dsl.Response{
+			Status:  200,
+			Headers: dsl.MapMatcher{"Content-Type": dsl.String("application/vnd.api+json")},
+			Body:    dsl.Match(model.Users{}),
+		})
+
+	// Verify
+	err := pact.Verify(consumer.SimpleGetInteraction(pact, fmt.Sprintf("/api/users?filter[username]=%s", userName)))
+	contracts_test.CheckErrorAndCleanPact(t, pact, err)
+}
+
+// AuthAPIUserByID defines contract of /api/users/<user_id> endpoint
+func AuthAPIUserByID(t *testing.T, pact *dsl.Pact, userID string) {
+
+	log.Printf("Invoking AuthAPIUserByID test interaction now\n")
+
+	// Set up our expected interactions.
+	pact.
+		AddInteraction().
+		Given("User with a given ID exists.").
+		UponReceiving("A request to get user's information by ID").
+		WithRequest(dsl.Request{
+			Method: "GET",
+			Path: dsl.Term(
+				fmt.Sprintf("/api/users/%s", userID),
+				fmt.Sprintf("/api/users/%s", model.UserIDRegex),
+			),
+			Headers: dsl.MapMatcher{"Content-Type": dsl.String("application/json")},
+		}).
+		WillRespondWith(dsl.Response{
+			Status:  200,
+			Headers: dsl.MapMatcher{"Content-Type": dsl.String("application/vnd.api+json")},
+			Body:    dsl.Match(model.User{}),
+		})
+
+	// Verify
+	err := pact.Verify(consumer.SimpleGetInteraction(pact, fmt.Sprintf("/api/users/%s", userID)))
+	contracts_test.CheckErrorAndCleanPact(t, pact, err) //workaround for https://github.com/pact-foundation/pact-go/issues/108
+}
+
+// AuthAPIUserByToken defines contract of /api/user endpoint with valid auth token
+// passed as 'Authorization: Bearer ...' header
+func AuthAPIUserByToken(t *testing.T, pact *dsl.Pact, userToken string) {
+
+	log.Printf("Invoking AuthAPIUserByToken test interaction now\n")
+
+	// Pass in test case
+	// Set up our expected interactions.
+	pact.
+		AddInteraction().
+		Given("A user exists with the given valid token.").
+		UponReceiving("A request to get user's information with valid auth token ").
+		WithRequest(dsl.Request{
+			Method: "GET",
+			Path:   dsl.String("/api/user"),
+			Headers: dsl.MapMatcher{
+				"Content-Type": dsl.String("application/json"),
+				"Authorization": dsl.Term(
+					fmt.Sprintf("Bearer %s", userToken),
+					fmt.Sprintf("^Bearer %s$", model.JWSRegex),
+				),
+			},
+		}).
+		WillRespondWith(dsl.Response{
+			Status:  200,
+			Headers: dsl.MapMatcher{"Content-Type": dsl.String("application/vnd.api+json")},
+			Body:    dsl.Match(model.User{}),
+		})
+
+	// Verify
+	err := pact.Verify(consumer.SimpleGetInteractionWithToken(pact, "/api/user", userToken))
+	contracts_test.CheckErrorAndCleanPact(t, pact, err) //workaround for https://github.com/pact-foundation/pact-go/issues/108
+}
+
+// AuthAPIUserInvalidToken defines contract of /api/user endpoint with invalid auth token
+func AuthAPIUserInvalidToken(t *testing.T, pact *dsl.Pact, invalidToken string) {
+
+	log.Printf("Invoking AuthAPIUserInvalidToken test interaction now\n")
+
+	// Set up our expected interactions.
+	pact.
+		AddInteraction().
+		Given("No user exists with the given token valid.").
+		UponReceiving("A request to get user's information with invalid auth token ").
+		WithRequest(dsl.Request{
+			Method: "GET",
+			Path:   dsl.String("/api/user"),
+			Headers: dsl.MapMatcher{
+				"Content-Type": dsl.String("application/json"),
+				"Authorization": dsl.Term(
+					fmt.Sprintf("Bearer %s", invalidToken),
+					fmt.Sprintf("^Bearer %s$", model.JWSRegex),
+				),
+			},
+		}).
+		WillRespondWith(dsl.Response{
+			Status:  401,
+			Headers: dsl.MapMatcher{"Content-Type": dsl.String("application/vnd.api+json")},
+			Body:    dsl.Match(model.InvalidTokenMessage{}),
+		})
+
+	// Verify
+	err := pact.Verify(consumer.SimpleGetInteractionWithToken(pact, "/api/user", invalidToken))
+	contracts_test.CheckErrorAndCleanPact(t, pact, err) //workaround for https://github.com/pact-foundation/pact-go/issues/108
+}
+
+// AuthAPIUserNoToken defines contract of /api/user endpoint with missing auth token
+func AuthAPIUserNoToken(t *testing.T, pact *dsl.Pact) {
+
+	log.Printf("Invoking AuthAPIUserNoToken test interaction now\n")
+
+	// Set up our expected interactions.
+	pact.
+		AddInteraction().
+		Given("Any user exists but no auth token was provided.").
+		UponReceiving("A request to get user's information with no auth token ").
+		WithRequest(dsl.Request{
+			Method: "GET",
+			Path:   dsl.String("/api/user"),
+			Headers: dsl.MapMatcher{
+				"Content-Type": dsl.String("application/json"),
+			},
+		}).
+		WillRespondWith(dsl.Response{
+			Status:  401,
+			Headers: dsl.MapMatcher{"Content-Type": dsl.String("application/vnd.api+json")},
+			Body:    dsl.Match(model.MissingTokenMessage{}),
+		})
+
+	// Verify
+	err := pact.Verify(consumer.SimpleGetInteraction(pact, "/api/user"))
+	contracts_test.CheckErrorAndCleanPact(t, pact, err) //workaround for https://github.com/pact-foundation/pact-go/issues/108
+}