feat: mention user on failed master branch build

.github/actions/match-github-to-slack-user/action.yml

@@ -0,0 +1,24 @@
+# This action will try to match git commit author (GITHUB_ACTOR) with Slack user
+# and add it to GITHUB_OUTPUT
+# Following env variables should be provided.
+# Provided by Github:
+#   GITHUB_ACTOR: commit author
+#   GITHUB_REPOSITORY: name of the repo we check the commit author, e.g. "airbytehq/airbyte-cloud"
+# Required:
+#   AIRBYTE_TEAM_BOT_SLACK_TOKEN: ${{ secrets.AIRBYTE_TEAM_BOT_SLACK_TOKEN }}
+#   GITHUB_API_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+
+name: "Match Github user to Slack user"
+description: "Match Github user to Slack by email or full name in Github profile."
+outputs:
+  slack_user_ids:
+    description: "Comma separated slack user IDs that match to GITHUB_ACTOR (Github username)"
+    value: ${{ steps.match-github-to-slack-user.outputs.slack_user_ids }}
+runs:
+  using: "composite"
+  steps:
+    - name: Match github user to slack user
+      id: match-github-to-slack-user
+      run: |
+        ./tools/bin/match_github_user_to_slack
+      shell: bash

.github/workflows/test-gradle.yml

@@ -0,0 +1,68 @@
+name: Airbyte CI
+
+env:
+  S3_BUILD_CACHE_ACCESS_KEY_ID: ${{ secrets.SELF_RUNNER_AWS_ACCESS_KEY_ID }}
+  S3_BUILD_CACHE_SECRET_KEY: ${{ secrets.SELF_RUNNER_AWS_SECRET_ACCESS_KEY }}
+
+on:
+  #ability to start task manually in Web UI
+  workflow_dispatch:
+    inputs:
+      debug_mode:
+        description: "Enable or disable tmate session for debug during helm ac tests"
+        type: choice
+        default: "false"
+        options:
+          - "true"
+          - "false"
+        required: false
+  schedule:
+    - cron: "0 */1 * * *"
+  push:
+    branches-ignore:
+      - "gitbook/v1"
+
+permissions: write-all
+
+jobs:
+  # COMMON TASKS
+  ensure-images-exist:
+    name: "Ensure all required Docker images exist on Dockerhub"
+    timeout-minutes: 10
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout Airbyte
+        uses: actions/checkout@v3
+
+      - name: Check images exist
+        shell: bash
+        run: exit 1
+
+  notify-failure-slack-channel:
+    name: "Notify Slack Channel on Build Failures"
+    runs-on: ubuntu-latest
+    needs:
+      - ensure-images-exist
+    if: ${{ failure() && github.ref == 'refs/heads/3583-mention-user-on-failed-master-build' }}
+    steps:
+      - name: Checkout Airbyte
+        uses: actions/checkout@v3
+      - name: Match GitHub User to Slack User
+        id: match-github-to-slack-user
+        uses: ./.github/actions/match-github-to-slack-user
+        env:
+          AIRBYTE_TEAM_BOT_SLACK_TOKEN: ${{ secrets.SLACK_AIRBYTE_TEAM_READ_USERS }}
+          GITHUB_API_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+      - name: Publish to OSS Build Failure Slack Channel
+        uses: abinoda/slack-action@master
+        env:
+          SLACK_BOT_TOKEN: ${{ secrets.SLACK_BOT_TOKEN_AIRBYTE_TEAM }}
+        with:
+          args: >-
+            {\"channel\":\"C03BEADRPNY\", \"blocks\":[
+            {\"type\":\"divider\"},
+            {\"type\":\"section\",\"text\":{\"type\":\"mrkdwn\",\"text\":\" TEST MESSAGE!!!11 :bangbang: \n\n\"}},
+            {\"type\":\"section\",\"text\":{\"type\":\"mrkdwn\",\"text\":\"_merged by_: *${{ github.actor }}* \n\"}},
+            {\"type\":\"section\",\"text\":{\"type\":\"mrkdwn\",\"text\":\"<@${{ steps.match-github-to-slack-user.outputs.slack_user_ids }}> \n\"}},
+            {\"type\":\"section\",\"text\":{\"type\":\"mrkdwn\",\"text\":\" :octavia-shocked: <https://github.com/${{github.repository}}/actions/runs/${{github.run_id}}|View Action Run> :octavia-shocked: \n\"}},
+            {\"type\":\"divider\"}]}

tools/bin/match_github_user_to_slack

@@ -0,0 +1,139 @@
+#!/usr/bin/env bash
+
+set -e
+
+function usage() {
+    echo "Usage: $0 -r GITHUB_REPOSITORY [-l GITHUB_ACTOR]"
+    echo "Either of the parameters below have to be provided:"
+    echo "     -l GITHUB_ACTOR - github user login"
+}
+
+function error_exit() {
+    usage
+    echo $1 >>/dev/stderr;
+    exit 1
+}
+
+function lc() {
+    tr '[:upper:]' '[:lower:]'
+}
+
+function uc() {
+    tr '[:lower:]' '[:upper:]'
+}
+
+function jq_filter() {
+    local name=$(echo -n "$1" | lc)
+    filter=''
+    filter+="( .profile.email | tostring | ascii_downcase | startswith(\"$name \") )"
+    filter+=" or ( .profile.email | tostring | ascii_downcase == (\"$name\") )"
+    filter+=" or ( .profile.display_name | tostring | ascii_downcase | startswith(\"$name \") )"
+    filter+=" or ( .profile.display_name | tostring | ascii_downcase | endswith(\" $name\") )"
+    filter+=" or ( .profile.display_name | tostring | ascii_downcase == (\"$name\") )"
+    filter+=" or ( .name | tostring | ascii_downcase | startswith(\"$name \") )"
+    filter+=" or ( .name | tostring | ascii_downcase | endswith(\" $name\") )"
+    filter+=" or ( (.name | tostring | ascii_downcase) == \"$name\" )"
+    filter+=" or ( .real_name | tostring | ascii_downcase | startswith(\"$name \") )"
+    filter+=" or ( .real_name | tostring | ascii_downcase | endswith(\" $name\") )"
+    filter+=" or ( .real_name | tostring | ascii_downcase == (\"$name\") )"
+
+
+    echo "${filter}"
+}
+
+function fetch_slack_users() {
+    local slack_api_key=$1
+    echo  "Fetching slack users ..." >>/dev/stderr
+    slack_users="$(curl -s -H "Authorization: Bearer ${slack_api_key}" -H "Content-type: application/json" https://slack.com/api/users.list?limit=2000)"
+    echo "$slack_users" > ./slack_users.json
+    slack_page_id="$(echo ${slack_users} | jq -r '.response_metadata.next_cursor')"
+    x=0
+    echo ${slack_page_id} >>/dev/stderr
+    if [ -n "${slack_page_id}" ]; then
+        while [ -n "${slack_page_id}" ]; do
+            echo "Extracting page info ${slack_page_id} for part ${x}" >>/dev/stderr
+            slack_users_paginator="$(curl -s -H "Authorization: Bearer ${slack_api_key}" -G -H "Content-type: application/json" --data-urlencode "cursor=${slack_page_id}" https://slack.com/api/users.list)"
+            slack_page_id="$(echo ${slack_users_paginator} | jq -r '.response_metadata.next_cursor')"
+            echo "$slack_users_paginator" > ./slack_users_${x}.json
+            x=$(( $x + 1 ))
+        done
+        all_slack_users="$(jq -n '[ inputs.members ] | add ' slack_users*.json)"
+    else
+        all_slack_users="$(jq -n '[ inputs.members ] | add ' slack_users*.json)"
+    fi
+    echo ${all_slack_users}
+}
+
+[ -z "${AIRBYTE_TEAM_BOT_SLACK_TOKEN}" ] && error_exit "ERROR: AIRBYTE_TEAM_BOT_SLACK_TOKEN  is not set."
+
+while getopts ":r:c:u:l:" opt; do
+  case ${opt} in
+    r )
+      GITHUB_REPOSITORY=$OPTARG
+      ;;
+    l )
+      GITHUB_ACTOR=$OPTARG
+      ;;
+    \? ) usage
+      ;;
+  esac
+done
+
+
+[ -z "$GITHUB_ACTOR" ] && error_exit "ERROR: GITHUB_ACTOR (-l GITHUB_ACTOR) have to be provided."
+
+if [ -n "$GITHUB_ACTOR" ]; then
+    [ -z "${GITHUB_API_TOKEN}" ] && error_exit "ERROR: GITHUB_API_TOKEN is not set."
+fi
+
+
+if [ -n "$GITHUB_ACTOR" ]; then
+    echo  "Fetching github user ..." >>/dev/stderr
+    github_user="$(curl -s -H "Authorization: token ${GITHUB_API_TOKEN}" https://api.github.com/users/${GITHUB_ACTOR})"
+    echo $github_user
+    email="$(echo "$github_user"  | jq -r '.email | select(type == "string")')"
+    name="$(echo "$github_user"  | jq -r '.name | select(type == "string")')"
+    if [ -z "$email" -a -z "$name" ]; then
+        echo "WARNING: Github user ($GITHUB_ACTOR) does not have either name nor email in the profile." >>/dev/stderr
+        echo "Fetching commits made by this user to detect user by commit author name and/or email." >>/dev/stderr
+        [ -z "$GITHUB_REPOSITORY" ] && error_exit "ERROR: Git reposuitory  (-r GITHUB_REPOSITORY) is missing."
+        commit="$(curl -s -H "Authorization: token ${GITHUB_API_TOKEN}" https://api.github.com/repos/${GITHUB_REPOSITORY}/commits?author=$GITHUB_ACTOR | jq '.[0] | .commit | select(type == "object")' )"
+        github_user="$(echo "$commit" | jq  '.author | select(type == "object")')"
+    fi
+    [ -z "$github_user" ] && error_exit "ERROR: Gitub user is not found for commit ${GITHUB_ACTOR}"
+else
+    github_user="$GITHUB_USER"
+fi
+
+airbyte_team_slack_users=$(fetch_slack_users ${AIRBYTE_TEAM_BOT_SLACK_TOKEN})
+
+all_users_list=$(jq -s '.[0] + .[1]' <<EOF
+$airbyte_team_slack_users
+EOF
+)
+
+echo $all_users_list > all_slack_users.json
+
+OLDIFS=$IFS;
+IFS=$'\n'
+for git_user in $(echo "$github_user"  | jq -r '.email, .name | select(type == "string")'; echo "$github_user" | jq -r '.name | select(type == "string")' | tr ' ' "\n"); do
+    if [ -z "$git_user" ]; then
+        echo "Skipping empty string ..." >>/dev/stderr
+        continue
+    fi
+    echo "Checking $git_user string ..." >>/dev/stderr
+    slack_user_id=$(echo "$all_users_list" | lc | jq -r ".[] | select( $(jq_filter "${git_user}") ) | .id | select(type == \"string\")" | uc)
+    [ -n "$slack_user_id" ] && break
+done
+IFS=$OLDIFS
+
+if [ -z "$slack_user_id" ]; then
+        echo "WARN: Slack user is not found for ${GITHUB_ACTOR}"
+        slack_user_id="GitHub user do not match any user in Slack"
+        echo slack_user_ids=$(echo $slack_user_id) >> $GITHUB_OUTPUT
+else
+        echo "Slack User ID is found $slack_user_id" >> /dev/stderr
+        slack_user_ids=$(echo $slack_user_id | tr -s '[:blank:]' ',')
+        echo $slack_user_ids 
+        echo slack_user_ids=$slack_user_ids >> $GITHUB_OUTPUT
+fi