bie-kafka-end2end-test.yml

name: 'CI: BIE Kafka End-2-End Test'

on:
  # Allow manual triggering
  workflow_dispatch:

  # Allow being called by another GitHub Action
  workflow_call:

env:
  COMPOSE_PROFILES: 'kafka'
  VRO_DEV_SECRETS_FOLDER: "${{ github.workspace }}/.cache/abd-vro-dev-secrets"
jobs:
  integration-test:
    runs-on: ubuntu-latest
    steps:
      - name: 'Checkout source code'
        uses: actions/checkout@v3

      - name: "Checkout abd-vro-dev-secrets repo"
        uses: actions/checkout@v3
        with:
          # Checkout using a PAT so that we can access the internal repo
          token: ${{ secrets.ACCESS_TOKEN_CHECKOUT_INTERNAL_REPO }}
          repository: 'department-of-veterans-affairs/abd-vro-dev-secrets'
          path: "${{ env.VRO_DEV_SECRETS_FOLDER }}"

      - name: 'Set RABBITMQ_BASIC_AUTH'
        run: |
          source scripts/setenv.sh

          # create basic auth token for RabbitMQ and export to github environment
          BASIC_AUTH=$(echo "${RABBITMQ_PLACEHOLDERS_USERNAME}:${RABBITMQ_PLACEHOLDERS_USERPASSWORD}" | base64)
          echo "RABBITMQ_BASIC_AUTH=${BASIC_AUTH}" >> "$GITHUB_ENV"

          export -p | sed 's/declare -x //'

      - name: 'Build the images'
        uses: ./.github/actions/build-images

      - name: 'Start the containers'
        run: |
          source scripts/setenv.sh
          export -p | sed 's/declare -x //'

          ./gradlew :dockerComposeUp

          ./gradlew -p mocks :mock-bie-kafka:docker
          ./gradlew -p mocks :dockerComposeUp

          ./gradlew :domain-xample:dockerComposeUp
          ./gradlew :app:dockerComposeUp

      - name: 'Wait for RabbitMQ to be ready'
        uses: indiesdev/curl@v1.1
        with:
          url: 'http://localhost:15672/api/vhosts'
          method: 'GET'
          basic-auth-token: '${{env.RABBITMQ_BASIC_AUTH}}'
          accept: 200
          # Retry every 2 seconds
          timeout: 2000
          # Quit after 60 seconds
          retries: 30

      - name: 'Install kafkacat and postgresql'
        run: |
          sudo apt-get update
          sudo apt-get install kafkacat
          which kafkacat

          sudo apt-get install postgresql
          which psql

      - name: 'Wait for Kafka to be ready'
        run: |
          # Verify broker is up with 30 second timeout
          BROKER_QUERY=$(kafkacat -m 30 -b localhost:9092 -L)
          if echo "$BROKER_QUERY" | grep -q '1 brokers'
          then
            echo "Found Broker: $BROKER_QUERY"
          else
            echo "Count not find Kafka broker"
            exit 5
          fi

      - name: 'Wait for xample-workflow to be ready'
        uses: nev7n/wait_for_response@v1
        with:
          url: 'http://localhost:10021/actuator/health'
          responseCode: 200
          # Retry every 2 seconds
          interval: 2000
          # Quit after 60 seconds
          timeout: 60000

      - name: 'Wait for svc-bie-kafka to be ready'
        uses: nev7n/wait_for_response@v1
        with:
          url: 'http://localhost:10301/actuator/health'
          responseCode: 200
          # Retry every 2 seconds
          interval: 2000
          # Quit after 60 seconds
          timeout: 60000

      - name: 'Create Kafka topic and send message'
        run: |
          source scripts/setenv.sh

          pushd svc-bie-kafka && { source ./docker-entryprep.sh; popd; }
          if ! ./gradlew :svc-bie-kafka:integrationTest; then
            echo "First run could fail due to some mock Kafka initialization"
            # Subsequent runs should pass
            ./gradlew :svc-bie-kafka:integrationTest
          fi

      - name: 'Check for saved DB entry in Postgres'
        run: |
          source scripts/setenv.sh

          # Retry to 5 times to allow time for message to travel from kafka to database
          for i in {1..5}; do
            sleep 10
            echo "Attempt $i"
            # For debugging
            echo "::group::Table bie_contention_event contents"
            psql "postgres://$POSTGRES_USER:$POSTGRES_PASSWORD@localhost:5432/vro" -c \
              "SELECT * FROM claims.bie_contention_event"
            echo "::endgroup::"

            RESULT=$(psql postgres://$POSTGRES_USER:$POSTGRES_PASSWORD@localhost:5432/vro -x -c \
            "SELECT COUNT(*) FROM claims.bie_contention_event
              -- This is the contention id used in BieKafkaApplicationTest
              WHERE contention_id=1234567890
            ")
            echo "$RESULT"
            if echo "$RESULT" | grep -q 'count | 1'; then
              break
            fi
          done

          # This will cause a failure if expected result is not found
          echo "$RESULT" | grep -q 'count | 1'

      - name: "Collect docker logs"
        if: always()
        uses: jwalton/gh-docker-logs@v2
        with:
          dest: './bie-kafka-end2end-test-with-mock-container-logs'

      - name: "Upload artifact"
        if: always()
        uses: actions/upload-artifact@v3
        with:
          name: bie-kafka-end2end-test-with-mock-container-logs
          path: ./bie-kafka-end2end-test-with-mock-container-logs/**
          retention-days: 14


      - name: 'Clean shutdown of all containers'
        if: always()
        shell: bash
        run: |
          docker ps
          COMPOSE_PROFILES="all" ./gradlew dockerComposeDown
          ./gradlew -p mocks :dockerComposeDown