Contract Testing: Chia sẻ file contract dễ dàng với Pact Broker

version: '3'

services:

  postgres:
    image: postgres
    healthcheck:
      test: psql postgres --command "select 1" -U postgres
    ports:
      - "5432"
    environment:
      POSTGRES_USER: postgres
      POSTGRES_PASSWORD: password
      POSTGRES_DB: postgres

  broker_app:
    image: pactfoundation/pact-broker
    ports:
      - "9292:9292"
    links:
      - postgres
    environment:
      PACT_BROKER_DATABASE_USERNAME: postgres
      PACT_BROKER_DATABASE_PASSWORD: password
      PACT_BROKER_DATABASE_HOST: postgres
      PACT_BROKER_DATABASE_NAME: postgres
      PACT_BROKER_LOG_LEVEL: DEBUG

// pkg/consumer/consumer_test.go
package consumer

import (
   "errors"
   "fmt"
   "github.com/pact-foundation/pact-go/dsl"
   "github.com/pact-foundation/pact-go/types"
   "testing"
)

func TestConsumer(t *testing.T) {
   // init Pack DSL
   pact := dsl.Pact{
      Consumer: "example-consumer",
      Provider: "example-provider",
   }

   // setup Pack mock server
   pact.Setup(true)

   t.Run("get user by id", func(t *testing.T) {
      id := "1"

      pact.
         AddInteraction().
         Given("User John exists").                 // specify Provider state
         UponReceiving("User 'John' is requested"). // specify test case name
         WithRequest(dsl.Request{                   // specify expected request
            Method: "GET",
            Path:   dsl.Term("/users/1", "/users/[0-9]+"), // specify matching for endpoint
         }).
         WillRespondWith(dsl.Response{ // specify expected response
            Status: 200,
            Body: dsl.Like(User{ // specify matching for response body
               ID:    id,
               Name:  "John",
               Email: "john@gmail.com",
            }),
         })

      // verify contract
      err := pact.Verify(func() error {
         // use pact mock server
         host := fmt.Sprintf("%s:%d", pact.Host, pact.Server.Port)

         // send request
         user, err := GetUserByID(host, id)
         if err != nil {
            return errors.New("error is not expected")
         }

         // check if actual response match expected
         if user == nil || user.ID != id {
            return fmt.Errorf("expected user with ID %s but got %v", id, user)
         }

         return err
      })

      if err != nil {
         t.Fatal(err)
      }
   })

   // Write Contract file
   if err := pact.WritePact(); err != nil {
      t.Fatal(err)
   }

   // specify PACT publisher
   publisher := dsl.Publisher{}
   err := publisher.Publish(types.PublishRequest{
      PactURLs:        []string{"./pacts/"},    // specify folder contains pact contract
      PactBroker:      "http://localhost:9292", // specify PACT broker URL
      ConsumerVersion: "1.0.0",
      Tags:            []string{"1.0.0", "latest"},
   })
   if err != nil {
      t.Fatal(err)
   }

   pact.Teardown()
}

// pkg/provider/provider_test.go
package provider

import (
   "github.com/pact-foundation/pact-go/dsl"
   "github.com/pact-foundation/pact-go/types"
   "testing"
)

func TestProvider(t *testing.T) {
   // init Pact DSl
   pact := dsl.Pact{
      Provider: "example-provider",
   }

   _, err := pact.VerifyProvider(t, types.VerifyRequest{
      BrokerURL:       "http://localhost:9292",
      ProviderBaseURL: "http://127.0.0.1:8080",
      ProviderVersion: "1.1.0",
      ConsumerVersionSelectors: []types.ConsumerVersionSelector{
         {
            Consumer: "example-consumer",
            Tag:      "1.0.0",
         },
      },
      PublishVerificationResults: true, // publish results of verification to PACT broker
   })

   if err != nil {
      t.Log(err)
   }
}

// pkg/provider/provider_test.go
...
_, err := pact.VerifyProvider(t, types.VerifyRequest{
   BrokerURL:       "http://localhost:9292",
   ProviderBaseURL: "http://127.0.0.1:8080",
   ProviderVersion: "1.1.0", // update version to 1.1.0
   ConsumerVersionSelectors: []types.ConsumerVersionSelector{
      {
         Consumer: "example-consumer",
         Tag:      "1.0.0",
      },
   },
   PublishVerificationResults: true, // publish results of verification to PACT broker
})

...