diff --git a/examples/avro/avro_consumer_test.go b/examples/avro/avro_consumer_test.go index 07111c749..15613893e 100644 --- a/examples/avro/avro_consumer_test.go +++ b/examples/avro/avro_consumer_test.go @@ -9,6 +9,7 @@ import ( "net/http" "net/url" "os" + "strings" "testing" "github.com/pact-foundation/pact-go/v2/consumer" @@ -21,17 +22,18 @@ import ( var dir, _ = os.Getwd() func TestAvroHTTP(t *testing.T) { - mockProvider, err := consumer.NewV4Pact(consumer.MockHTTPProviderConfig{ - Consumer: "AvroConsumer", - Provider: "AvroProvider", - PactDir: filepath.ToSlash(fmt.Sprintf("%s/../pacts", dir)), - }) - assert.NoError(t, err) + if os.Getenv("SKIP_PLUGIN_AVRO") != "1" { + mockProvider, err := consumer.NewV4Pact(consumer.MockHTTPProviderConfig{ + Consumer: "AvroConsumer", + Provider: "AvroProvider", + PactDir: filepath.ToSlash(fmt.Sprintf("%s/../pacts", dir)), + }) + assert.NoError(t, err) - dir, _ := os.Getwd() - path := fmt.Sprintf("%s/user.avsc", dir) + dir, _ := os.Getwd() + path := fmt.Sprintf("%s/user.avsc", strings.ReplaceAll(dir, "\\", "/")) - avroResponse := `{ + avroResponse := `{ "pact:avro": "` + path + `", "pact:record-name": "User", "pact:content-type": "avro/binary", @@ -39,27 +41,28 @@ func TestAvroHTTP(t *testing.T) { "username": "notEmpty('matt')" }` - // Set up our expected interactions. - err = mockProvider. - AddInteraction(). - UponReceiving("A request to do get some Avro stuff"). - UsingPlugin(consumer.PluginConfig{ - Plugin: "avro", - Version: "0.0.5", - }). - WithRequest("GET", "/avro"). - WillRespondWith(200, func(res *consumer.V4InteractionWithPluginResponseBuilder) { - res.PluginContents("avro/binary", avroResponse) - }). - ExecuteTest(t, func(msc consumer.MockServerConfig) error { - resp, err := callServiceHTTP(msc) - - assert.Equal(t, int64(1), resp.ID) - assert.Equal(t, "matt", resp.Username) // ??????! - - return err - }) - assert.NoError(t, err) + // Set up our expected interactions. + err = mockProvider. + AddInteraction(). + UponReceiving("A request to do get some Avro stuff"). + UsingPlugin(consumer.PluginConfig{ + Plugin: "avro", + Version: "0.0.5", + }). + WithRequest("GET", "/avro"). + WillRespondWith(200, func(res *consumer.V4InteractionWithPluginResponseBuilder) { + res.PluginContents("avro/binary", avroResponse) + }). + ExecuteTest(t, func(msc consumer.MockServerConfig) error { + resp, err := callServiceHTTP(msc) + + assert.Equal(t, int64(1), resp.ID) + assert.Equal(t, "matt", resp.Username) // ??????! + + return err + }) + assert.NoError(t, err) + } } func callServiceHTTP(msc consumer.MockServerConfig) (*User, error) { diff --git a/examples/avro/avro_provider_test.go b/examples/avro/avro_provider_test.go index d8cbaf331..38779439c 100644 --- a/examples/avro/avro_provider_test.go +++ b/examples/avro/avro_provider_test.go @@ -21,23 +21,25 @@ var dir, _ = os.Getwd() var pactDir = fmt.Sprintf("%s/../pacts", dir) func TestAvroHTTPProvider(t *testing.T) { - httpPort, _ := utils.GetFreePort() + if os.Getenv("SKIP_PLUGIN_AVRO") != "1" { + httpPort, _ := utils.GetFreePort() - // Start provider API in the background - go startHTTPProvider(httpPort) + // Start provider API in the background + go startHTTPProvider(httpPort) - verifier := provider.NewVerifier() + verifier := provider.NewVerifier() - // Verify the Provider with local Pact Files - err := verifier.VerifyProvider(t, provider.VerifyRequest{ - ProviderBaseURL: fmt.Sprintf("http://127.0.0.1:%d", httpPort), - Provider: "AvroProvider", - PactFiles: []string{ - filepath.ToSlash(fmt.Sprintf("%s/AvroConsumer-AvroProvider.json", pactDir)), - }, - }) + // Verify the Provider with local Pact Files + err := verifier.VerifyProvider(t, provider.VerifyRequest{ + ProviderBaseURL: fmt.Sprintf("http://127.0.0.1:%d", httpPort), + Provider: "AvroProvider", + PactFiles: []string{ + filepath.ToSlash(fmt.Sprintf("%s/AvroConsumer-AvroProvider.json", pactDir)), + }, + }) - assert.NoError(t, err) + assert.NoError(t, err) + } } func startHTTPProvider(port int) {