Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Omree tmp branch #103

Draft
wants to merge 7 commits into
base: main
Choose a base branch
from
Draft

Omree tmp branch #103

Changes from all commits
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
677df84
Adding line number error handling
May 18, 2023
c16bd1b
Noting functions in trap
omreego May 18, 2023
36a8dca
varying trap logs at beginning of functions
omreego May 18, 2023
be0cc59
Adding trap exceptions
omreego May 18, 2023
b153f39
Adding trap exceptions
omreego May 18, 2023
5ff1da1
Adding exception handling
omreego May 19, 2023
492b776
Merge branch 'main' into omree_tmp_branch
omreego May 19, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
56 changes: 45 additions & 11 deletions faros_event.sh
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -32,6 +32,7 @@ FAROS_RETRY_MAX_TIME_DEFAULT="40"
HASURA_URL_DEFAULT="http://localhost:8080"
HASURA_ADMIN_SECRET_DEFAULT="admin"


declare -a ENVS=("Prod" "Staging" "QA" "Dev" "Sandbox" "Canary" "Custom")
envs=$(printf '%s\n' "$(IFS=,; printf '%s' "${ENVS[*]}")")
declare -a BUILD_STATUSES=("Success" "Failed" "Canceled" "Queued" "Running" "Unknown" "Custom")
Expand Down Expand Up @@ -349,6 +350,7 @@ function processArgs() {
# Resolve input and populate event depending on present event types
# Only one event should be considered per execution
function processEventTypes() {
trap 'handle_error "$BASH_COMMAND" "${FUNCNAME[0]}" $LINENO' ERR
if ((ci_event)); then
event_type="CI"
makeEvent
Expand Down Expand Up @@ -415,7 +417,8 @@ function make_artifact_key() {
}

function doPullRequestCommitMutation() {
if [ -n "$has_commit" ] && [ -n "$pull_request_number" ]; then
trap 'handle_error "$BASH_COMMAND" "${FUNCNAME[0]}" $LINENO' ERR
if ! [ -n "$has_commit" ] && ! [ -n "$pull_request_number" ]; then
pull_request=$(jq -n \
--arg pull_request_number "$pull_request_number" \
'{
Expand All @@ -430,6 +433,7 @@ function doPullRequestCommitMutation() {

function doCDMutations() {
flat=$(flatten "$request_body")
trap 'handle_error "$BASH_COMMAND" "${FUNCNAME[0]}" $LINENO $flat' ERR

app_platform="${deploy_app_platform:-}"
if [ -z "${app_platform}" ]; then
Expand Down Expand Up @@ -515,6 +519,7 @@ function doCDMutations() {
}

function make_mutations_from_run {
trap 'handle_error "$BASH_COMMAND" "${FUNCNAME[0]}" $LINENO' ERR
buildKey=$(jq \
'{data_run_id,data_run_pipeline,data_run_organization,data_run_source}' <<< "$flat"
)
Expand Down Expand Up @@ -562,6 +567,7 @@ function make_mutations_from_run {
}

function doCIMutations() {
trap 'handle_error "$BASH_COMMAND" "${FUNCNAME[0]}" $LINENO' ERR
flat=$(flatten "$request_body")

artifact_key=$(make_artifact_key)
Expand Down Expand Up @@ -593,6 +599,7 @@ function doCIMutations() {
}

function make_mutation() {
trap 'handle_error "$BASH_COMMAND" "${FUNCNAME[0]}" $LINENO $1 $2' ERR
entity_origin=$(jq -n \
--arg data_origin "$origin" \
'{"data_origin": $data_origin}'
Expand Down Expand Up @@ -638,6 +645,7 @@ function concat() {
}

function flatten() {
trap 'handle_error "$BASH_COMMAND" "${FUNCNAME[0]}" $LINENO $1' ERR
jq '[paths(scalars) as $path | { ($path | map(tostring) | join("_")): getpath($path) } ] | add' <<< "$1"
}

Expand Down Expand Up @@ -689,19 +697,22 @@ function resolveInput() {
}

function resolveCDInput() {
trap 'handle_error "$BASH_COMMAND" "${FUNCNAME[0]}" $LINENO' ERR
resolveDeployInput
resolveArtifactInput
resolveCommitInput
resolveRunInput
}

function resolveCIInput() {
trap 'handle_error "$BASH_COMMAND" "${FUNCNAME[0]}" $LINENO' ERR
resolveArtifactInput
resolveCommitInput
resolveRunInput
}

function resolveTestExecutionInput() {
trap 'handle_error "$BASH_COMMAND" "${FUNCNAME[0]}" $LINENO' ERR
resolveTestInput
resolveCommitInput
}
Expand Down Expand Up @@ -886,6 +897,8 @@ function parseArtifactUri() {
}

function makeEvent() {
# Error handling
trap 'handle_error "$BASH_COMMAND" "${FUNCNAME[0]}" $LINENO $origin $event_type' ERR
request_body=$(jq -n \
--arg origin "$origin" \
--arg event_type "$event_type" \
Expand Down Expand Up @@ -926,6 +939,7 @@ function addDeployToData() {
}

function addCommitToData() {
trap 'handle_error "$BASH_COMMAND" "${FUNCNAME[0]}" $LINENO $commit_uri $commit_sha $commit_repo $commit_org $commit_source $branch' ERR
tryAddToEvent '["data","commit","uri"]' "$commit_uri"
tryAddToEvent '["data","commit","sha"]' "$commit_sha"
tryAddToEvent '["data","commit","repository"]' "$commit_repo"
Expand All @@ -944,6 +958,7 @@ function addCommitToData() {
}

function addArtifactToData() {
trap 'handle_error "$BASH_COMMAND" "${FUNCNAME[0]}" $LINENO $artifact_uri $artifact_id $artifact_repo $artifact_org $artifact_source' ERR
tryAddToEvent '["data","artifact","uri"]' "$artifact_uri"
tryAddToEvent '["data","artifact","id"]' "$artifact_id"
tryAddToEvent '["data","artifact","repository"]' "$artifact_repo"
Expand All @@ -952,6 +967,7 @@ function addArtifactToData() {
}

function addRunToData() {
trap 'handle_error "$BASH_COMMAND" "${FUNCNAME[0]}" $LINENO $run_uri' ERR
tryAddToEvent '["data","run","uri"]' "$run_uri"
tryAddToEvent '["data","run","id"]' "$run_id"
tryAddToEvent '["data","run","pipeline"]' "$run_pipeline"
Expand All @@ -965,6 +981,7 @@ function addRunToData() {
}

function addRunStepToData() {
trap 'handle_error "$BASH_COMMAND" "${FUNCNAME[0]}" $LINENO $run_step_id' ERR
tryAddToEvent '["data","run","step","id"]' "$run_step_id"
tryAddToEvent '["data","run","step","name"]' "$run_step_name"
tryAddToEvent '["data","run","step","type"]' "$run_step_type"
Expand All @@ -978,6 +995,7 @@ function addRunStepToData() {
}

function addTestToData() {
trap 'handle_error "$BASH_COMMAND" "${FUNCNAME[0]}" $LINENO $test_id' ERR
tryAddToEvent '["data","test","id"]' "$test_id"
tryAddToEvent '["data","test","source"]' "$test_source"
tryAddToEvent '["data","test","type"]' "$test_type"
Expand Down Expand Up @@ -1012,8 +1030,8 @@ function addTestToData() {
}

function sendEventToFaros() {
trap 'handle_error "$BASH_COMMAND" "${FUNCNAME[0]}" $LINENO $graph $request_body' ERR
log "Sending event to Faros..."

http_response=$(curl -s -S \
--max-time "$max_time" \
--retry "$retry" \
Expand Down Expand Up @@ -1093,23 +1111,39 @@ function fail() {
exit 1
}

function handle_error {
local error_message=$1
local function_name=$2
local line_number=$3
local args=("${@:4}") # Slice the array to start from the 4th argument
local IFS="|" # Set IFS to '|' - meaning debug args will be separated by |
local args_string="${args[*]}"
echo "Error occurred in function: $function_name, line: $line_number, remaining args: [ $args_string ]"
exit 1
}

main() {

trap 'handle_error "$BASH_COMMAND" "${FUNCNAME[0]}" $LINENO main_1' ERR
parseControls "$@"
set -- "${FLAGS[@]:-}" # Restore positional args
parseFlags "$@"
set -- "${POSITIONAL[@]:-}" # Restore positional args
processArgs "$@" # Determine which event types are present
resolveInput # Resolve general fields
processEventTypes # Resolve input and populate event

debug "Faros url: $url"
debug "Faros graph: $graph"
debug "Faros origin: $origin"
debug "Validate Only: $validate_only"
debug "Dry run: $dry_run"
debug "Community edition: $community_edition"

if ! ((community_edition)); then
trap 'handle_error "$BASH_COMMAND" "${FUNCNAME[0]}" $LINENO main_2' ERR
if ((debug)); then
echo "Faros url: $url"
echo "Faros graph: $graph"
echo "Dry run: $dry_run"
echo "Silent: $silent"
echo "Skip Saving Run: $skip_saving_run"
echo "Debug: $debug"
echo "Community edition: $community_edition"
fi

if ! (($community_edition)); then
log "Request Body:"
log "$request_body"

Expand Down