#!/bin/bash
: '
 @vendor    Chorke Academia, Inc.
 @web       https://cdn.chorke.org/docs/academia
 @version   1.0.00
 @since     1.0.00
'

:<<EOC
export TARGET_USER='spark'
if [[ -x "$(command -v curl)" ]]&&
[[ "$(grep -c "^${TARGET_USER}:" /etc/passwd)" -gt 0 ]];then 
sudo -i -u ${TARGET_USER} bash <<EOF
export SPARK_HOME_DIR='/var/spark/spark-3.3.0-bin-hadoop3'
bash <(curl -s 'https://cdn.chorke.org/exec/cli/bash/install/profile/chorke/robotics/apache-spark.sh.txt')
EOF
else printf 'curl/spark \033[0;31mnot found! \033[0m:(\n';fi
EOC


function conf_init(){
    MEMBER_ENV_PROFILE="${HOME}/.chorke/robotics/env"
    EXPORT_ENV_PATTERN=$(cat <<'EOF'

# spark home added
export SPARK_HOME='%s'
if [[ ! "${PATH}" =~ "${SPARK_HOME}/bin:" ]]&&
   [[ -d "${SPARK_HOME}/bin" ]];then
    export PATH="${SPARK_HOME}/bin:${PATH}"
fi

EOF
)
    if  [[ -f "${MEMBER_ENV_PROFILE}" ]]&&[[ -s "${MEMBER_ENV_PROFILE}" ]]&&
        [[ "$(grep -c 'SPARK_HOME' ${MEMBER_ENV_PROFILE})" == 0 ]];then

        # format spark env pattern to avoid variable interpolation
        printf -v EXPORT_ENV_CONTENT "${EXPORT_ENV_PATTERN}" "${SPARK_HOME_DIR}"
        echo   "${EXPORT_ENV_CONTENT}" >> "${MEMBER_ENV_PROFILE}"
    else
        printf 'already configured "\033[0;32mSPARK_HOME\033[0m" :)\n\n'
    fi

    # suppress warning for relogin or exec script
    if  [[ -f "${MEMBER_ENV_PROFILE}" ]]&&[[ -s "${MEMBER_ENV_PROFILE}" ]]&&
        [[ "${SPARK_HOME}/env/set" == '/env/set' ]];then

        printf 'please relogin or exec "\033[0;32msource %s\033[0m"\n\n' "${MEMBER_ENV_PROFILE}"
        source "${MEMBER_ENV_PROFILE}"
    fi
}

function void_init(){
    if [[ "${SPARK_HOME_DIR}/env/set" == '/env/set' ]];then
        export SPARK_HOME_DIR='/var/spark/spark-3.3.4'
    fi
}

function post_init(){
    bash <(curl -s 'https://cdn.chorke.org/exec/cli/bash/install/profile/chorke/robotics.sh.txt')
}

function init(){
    post_init
    void_init
    conf_init
}

init