Content Comparison

./castor-change-log-level.sh -d <node_ip> -p <admin:password> [-i <newnew_log_level | -L new_node_log_level>level] [-t <duration_in_seconds>] [-D --detach] [-v]

[root@scs dist]# ./castor-change-log-level.sh -p admin:datacore -i 10 -t 300
Swarm IP: 192.168.1.84
Credentials: [hidden for security]
Cluster Name: gatewayadmindomainmsuen-scs1.suen.work

New log level: 10debug
Current log level is 30.
Updating log level to 10...default.
2025-03-02T05:15:49.901Z Log level changed successfully from 30 → 10.
Keeping log level at 10debug for 300 second (s00:05:00) ...
Countdown: 00:00:01 remaining...

Time's up! Reverting log level back to 30...
Approximate 6988.4MB9MB new logs were generated at log level 10. Current castor.log size is 371.3MB after 300 seconds (00:05:00).
2025-03-02T05:20:50.483Z Log level reverted successfully back to 30.

[root@scs dist]#

#!/bin/bash
# -----------------------------------------------------------------------------------------------------------------------------
# Script: castor-change-log-level.sh
# -----------------------------------------------------------------------------------------------------------------------------
# Description:
# This script changes the log level for the Castor cluster or node(s) using the Swarm API.
# The script supports changing the log level for the entire cluster or individual node(s).
# The script can run in a detachable session using 'screen' or 'tmux'.
# -----------------------------------------------------------------------------------------------------------------------------
# Written by Milton Suen (milton.suen@datacore.com) Oct 31, 2024
# Revision History:
# v1.0.0 - Update to support running the script in a detachable session using screen or tmux.
# v1.1.0 - 2025-02-20 Add support node(s) level log level change.
# v1.2.0 - 2025-02-26 SUPSCR-208:
Auto# detect CSN or SCS to adjust castor.log file- path.Enforced # v1.2.1 - 2025-02-26 Address the issue of the script not display correct when the castor.log file is rotated.
proper credential formatting: credentials must be in the username:password format.
#        - Fixed help message shows script name without hard code it.
# v1.2.21 - 2025-02-26 SUPSCR-209: EnforcedAuto properdetect credentialCSN formatting:or credentialsSCS mustto beadjust incastor.log the username:password formatfile path.
# v1.2.2 - 2025-02-27 Address the issue of the script not display correct when the castor.log file is rotated.
# v1.2.3 - 2025-02-27 Address the issue of log level not display correct within detach session.
# v1.2.4 - 2025-02-27 Bug fix: The default node-level log level is 0 (unset), which differs from the cluster-level default of 30.
# v1.2.5 - 2025-02-28 SUPSCR-208:
#        - Credentials validation and password prompt enhancements.
#        -------------------------------------------------------------------------------------------------------------
# Current Version: 1.2.2
# ------------------------- screen or tmux required with detachable mode, script will stopped with '-D' option if neither is installed.
#        - Fixed an issue where users were prompted to enter password multiple times issue.
#        - Passwords are now hidden in debug output messages.
# v1.2.6 - 2025-02-28 SUPSCR-208:
#        - Disabled credential display on the screen.
#        - Bug fix: Resolved the "debug: command not found" error when removing the -d [IP address] option.
# v1.3.0 - 2025-02-28 Minor bug fix and enhancement.
# v1.3.1 - 2025-03-01 SUPSCR-208:
#        - Fixed an issue where credentials enclosed in single quotes (') were not processed correctly.
# v1.3.2 - 2025-03-02 Minor bug fix and enhancement.
# v1.3.3 - 2025-03-02 Fixed tmux command to long issue.
# ----------------------------------------------------------------------------------------------------
# KB: https://perifery.atlassian.net/wiki/spaces/public/pages/3872161835/Setting+and+Managing+Swarm+Log+Levels+with+script-------------------------
# Current Version: 1.3.3
# -----------------------------------------------------------------------------------------------------------------------------
# # Define colors
RED='\033[0;31m'
BOLD_RED='\033[1;31m'
GREEN='\033[0;32m'
BOLD_GREEN='\033[1;32m'
UNDERLINE_BOLD_GREEN='\033[4;32m'
YELLOW='\033[0;33m'
BOLD_YELLOW='\033[1;33m'
BLUE='\033[0;34m'
BOLD_BLUE='\033[1;34m'
MAGENTA='\033[0;35m'
BOLD_MAGENTA='\033[1;35m'
CYAN='\033[0;36m'
BOLD_CYAN='\033[1;36m'
RESET='\033[0m' # Reset color to default

# Function to display usage information
usage() {
    echo "Usage: ./castor-change-log-level10.sh -d swarm_ip -p admin:password [-i new_log_level | -L new_node_log_level] [-t duration_in_seconds] [-D]"
    echo "  -d, --swarm_ip           IP address of the Swarm API endpoint. Supports single or multiple IPs separated by \",\", \";\" or \" \"."
    echo "               KB: https://perifery.atlassian.net/wiki/spaces/public/pages/3872161835/Setting+and+Managing+Swarm+Log+Levels+with+script
# -----------------------------------------------------------------------------------------------------------------------------

# Define colors
RED='\033[0;31m'
BOLD_RED='\033[1;31m'
GREEN='\033[0;32m'
BOLD_GREEN='\033[1;32m'
UNDERLINE_BOLD_GREEN='\033[4;32m'
YELLOW='\033[0;33m'
BOLD_YELLOW='\033[1;33m'
BLUE='\033[0;34m'
BOLD_BLUE='\033[1;34m'
MAGENTA='\033[0;35m'
BOLD_MAGENTA='\033[1;35m'
CYAN='\033[0;36m'
BOLD_CYAN='\033[1;36m'
RESET='\033[0m' # Reset color to default

SCRIPT_NAME=$(basename "$0")

# Function to display usage information
usage() {
    echo -e ""
    echo -e "${BOLD_GREEN}Usage:${RESET} ./$SCRIPT_NAME -d swarm_ip -p admin:password [-i new_log_level | -L new_node_log_level] [-t duration_in_seconds] [-D | --detach]"
    echo -e "  -d, --swarm_ip           IP address of the Swarm API endpoint. Supports single or multiple IPs separated by \",\", \";\" or \" \"."
    echo -e "                           If multiple IPs are provided, the script will update the log level for all nodes."
    echo -e "                           (Alternatively, set the SCSP_HOST environment variable to the Swarm IP.)"
    echo -e "  -p, --credentials        Credentials in the format admin:password"
    echo -e "  -i, --log.level          Set cluster log level to set (5, 10, 15, 20, 30, 40, 50)"
    echo -e "                           Aliases: chatter, debug, announce, info, error, critical, default."
    echo -e "  -L, --node.log.level     Set node log level to set (0, 5, 10, 15, 20, 30, 40, 50)"
    echo -e "                           Aliases: chatter, debug, announce, info, error, critical, default."
    echo -e "                           **Either -i or -L must be specified, but not both.**"
    echo -e "  -t, --time               (Optional) Duration in seconds to keep the new log level (must be greater than 0)"
    echo -e "  -D, --detach             (Optional) Detach the script from the current terminal and run in a detachable session using screen or tmux"
    echo -e ""
    exit 1
}

# Default options
detachable=false
debug=false
output_log="castor-change-log-level_output.log"		# Log file for capturing detachable session output
# log_level_type="cluster"							# Default log level type
# default_log_level=30								# Default log level
log_file="/var/log/datacore/castor.log"		        # Default log file location
SCRIPTDIR=$( cd "$( dirname "${BASH_SOURCE[0]}" )" && pwd )
JQLOCATION=$SCRIPTDIR/jq
MAX_RETRIES=3                                       # Maximum number of password retries attempts
username="admin"                                    # Default username
password=""                                         # Default password

# Global associative array for log levels
declare -A log_levels=(
    [5]="chatter"
    [10]="debug"
    [15]="audit"
    [20]="info"
    [30]="warning"
    [40]="error"
    [45]="defect"
    [50]="critical"
    [60]="announce"
)

# Global associative array for log level names
declare -A log_level_names=(
    ["chatter"]=5
    ["debug"]=10
    ["audit"]=15
    ["info"]=20
    ["warning"]=30
    ["error"]=40
    ["defect"]=45
    ["critical"]=50
    ["announce"]=60
)

# Separate default values for cluster and node levels
declare -A default_log_levels=(
    ["cluster"]=30
    ["node"]=0
)

# Separate default values for cluster and node level names
declare -A default_log_level_names=(
    ["cluster"]="default"
    ["node"]="default"
)

# Function to get the current timestamp
timestamp() {
    date -u +"%Y-%m-%dT%H:%M:%S.%3NZ"
}

# Function to display debug messages if debug mode is enabled
debug_msg() {
    if $debug; then
        local caller_func=${FUNCNAME[1]:-main}                  # Fallback to "unknown" if empty
        local caller_line=${BASH_LINENO[0]:-unknown}            # Fallback to "unknown" if empty
        echo -e "$(timestamp) [DEBUG] ($caller_func:$caller_line) $*"
    fi
}

# Function to check if either 'screen' or 'tmux' is installed
check_screen_or_tmux() {
    if ! command -v screen &>/dev/null && ! command -v tmux &>/dev/null; then
        echo -e ""
        echo -e "---------------------------------------------------------------------------------------"
        echo -e "  ${YELLOW}Warning${RESET}: Neither '${BOLD_GREEN}screen${RESET}' nor '${BOLD_GREEN}tmux${RESET}' is installed. Cannot run in detachable mode."
        echo -e "  Please install either '${BOLD_GREEN}screen${RESET}' or '${BOLD_GREEN}tmux${RESET}' to run the script in a detachable session."
        echo -e "---------------------------------------------------------------------------------------"
        detachable=false  # Disable detachable session
        usage
    fi
}

# Function to format file size
format_size() {
    local size=$1
    if (( size >= 1073741824 )); then
        echo "$(awk "BEGIN {printf \"%.1fGB\", $size/1073741824}")"
    elif (( size >= 1048576 )); then
        echo "$(awk "BEGIN {printf \"%.1fMB\", $size/1048576}")"
    elif (( size >= 1024 )); then
        echo "$(awk "BEGIN {printf \"%.1fKB\", $size/1024}")"
    else
        echo "${size}B"
    fi
}

# Function to format duration
format_duration() {
    local duration=$1
    local hours=$((duration / 3600))
    local minutes=$(( (duration % 3600) / 60 ))
    local seconds=$((duration % 60))
    printf "%02d:%02d:%02d" $hours $minutes $seconds
}

# Function to check if jq is available and set up JSON parsing method
check_jq() {
    for jq_path in "/usr/local/bin/jq" "$(pwd)/jq"; do
        [[ -x "$jq_path" ]] && echo "$jq_path" && return
    done
    command -v jq &>/dev/null && echo "jq" || echo "grep"
}

if [[ -f "$JQLOCATION" ]]; then
    jq_or_grep=$JQLOCATION
else
    jq_or_grep=$(check_jq)
fi
debug_msg "jq_or_grep: $jq_or_grep"
#jq_or_grep=$(check_jq)

# Function to determine the log file path
determine_log_file() {
    for log in "/var/log/datacore/castor.log" "/var/log/caringo/castor.log"; do
        if [[ -f "$log" ]]; then
            echo "$log"
            return
        fi
    done
    echo -e "${RED}Error: Log file not found.${RESET}"
    exit 1
}

log_file=$(determine_log_file)

# Function to check if credentials are valid
check_credentials() {
    local CREDENTIALS="$1"
    local SWARM_IP="$2"
    debug_msg "Credentials: [hidden for security]"
    debug_msg "Swarm IP: $SWARM_IP"

    # API endpoint for validating user credentials
    local VALIDATE_URL="http://${SWARM_IP}:91/api/validateUser"
    debug_msg "Validate URL: $VALIDATE_URL"

    # Make the API request
    debug_msg "Validating user credentials..."
    debug_msg "curl -s -u \"********\" -X GET \"$VALIDATE_URL\" -H 'Content-Type: application/json'"
    RESPONSE=$(curl -s -u "$CREDENTIALS" -X GET "$VALIDATE_URL" -H 'Content-Type: application/json')
    debug_msg "Validate User Response: $RESPONSE"

    # Check if the response contains "isValid": true
    if echo "$RESPONSE" | "$jq_or_grep" -e '.isValid == true' > /dev/null 2>&1; then
        debug_msg "Authentication successful for user '${CREDENTIALS%%:*}'"
        return 0  # Success
    elif echo "$RESPONSE" | "$jq_or_grep" -e '.isValid == false' > /dev/null 2>&1; then
        debug_msg "Authentication failed for user '${CREDENTIALS%%:*}'"
        return 1  # Failure
    else
        debug_msg "Error: Unable to validate credentials. Please check your inputs."
        return 1  # Failure
    fi
}

# Function to print credentials - hide password
print_credentials() {
    local CREDENTIALS="$1"
    local USERNAME="${CREDENTIALS%%:*}"
    echo -e "${GREEN}$USERNAME${RESET}":"${GREEN}********${RESET}"
}

# Parse input arguments
while [[ "$#" -gt 0 ]]; do
    case $1 in
        -d|--swarm_ip) swarm_ip="$2"; debug_msg "Set swarm_ip to $swarm_ip"; shift 2 ;;
        -p|--credentials)
            credentials="$2"
            shift 2 ;;
        -i|--log.level)
            if [[ -n "$new_log_level" ]]; then
                echo "Error: Options -i (cluster log leve) and -L (node log level) cannot be used together."
                usage
            fi
            log_level_type="cluster"
            if [[ ${log_level_names[$2]} ]]; then
                new_log_level=${log_level_names[$2]}
            elif [[ "$2" == "default" ]]; then
                new_log_level=${default_log_levels[$log_level_type]}
                new_log_level_name="default"
            elif [[ ${log_levels[$2]} ]]; then
                new_log_level=$2
            else
                echo "Invalid log level: $2"
                exit 1
            fi
            new_log_level_name=${log_levels[$new_log_level]}
            default_log_level=30
            debug_msg "Set new_log_level to $new_log_level ($new_log_level_name)"
            shift 2
            ;;
        -L|--node.log.level)
            if [[ -n "$new_log_level" ]]; then
                echo "Error: Options -i (cluster log leve) and -L (node log level) cannot be used together."
                usage
            fi
            log_level_type="node"
            if [[ ${log_level_names[$2]} ]]; then
                new_log_level=${log_level_names[$2]}
            elif [[ "$2" == "default" ]]; then
                new_log_level=${default_log_levels[$log_level_type]}
                new_log_level_name="default"
            elif [[ ${log_levels[$2]} || $2 -eq 0 ]]; then
                new_log_level=$2
                new_log_level_name="default"
            else
                echo "Invalid log level: $2"
                exit 1
            fi
            new_log_level_name=${log_levels[$new_log_level]}
            default_log_level=0
            debug_msg "Set new_log_level to $new_log_level ($new_log_level_name)"
            shift 2
            ;;
        -t|--time)
            if [[ -n "$2" && "$2" != -* && "$2" -gt 0 ]]; then
                duration="$2"
                debug_msg "Set duration to $duration"
                shift 2
            else
                echo -e ""
                echo -e "---------------------------------------------------------------------------------------"
                echo -e "    ${RED}Error${RESET}: Duration must be a number greater than ${BOLD_GREEN}0${RESET}."
                echo -e "    Please specify the duration using the ${BOLD_GREEN}-t${RESET} ${GREEN}<seconds>${RESET} or ${BOLD_GREEN}--time${RESET} ${GREEN}<seconds>${RESET} option."
                echo -e "---------------------------------------------------------------------------------------"
                usage
            fi
            ;;
        -D|--detach) detachable=true; debug_msg "Set detachable to true"; shift ;;
        --debug) debug=true; debug_msg "Set debug to true with ${YELLOW}--debug${RESET}"; shift ;;
        *) usage ;;
    esac
done

debug_msg "Set log_level_type to ${YELLOW}$log_level_type${RESET}"

# Check if 'screen' or 'tmux' is installed
if [[ "$detachable" == true ]]; then
    if [[ -z "$duration" ]]; then
        echo -e ""
        echo -e "---------------------------------------------------------------------------------------"
        echo -e "    ${RED}Error${RESET}: Duration must be specified when running in detachable mode."
        echo -e "    Please specify the duration using the ${BOLD_GREEN}-t${RESET} or ${BOLD_GREEN}--time${RESET} option."
        echo -e "---------------------------------------------------------------------------------------"
        usage
    fi
    check_screen_or_tmux
fi

# If swarm_ip is not provided, try using SCSP_HOST environment variable
if [[ -z "$swarm_ip" ]]; then
    if [[ -n "$SCSP_HOST" ]]; then
        swarm_ip="$SCSP_HOST"
        debug_msg "Using Swarm IP from SCSP_HOST: $swarm_ip"
    else
        echo "Error: swarm_ip not provided and SCSP_HOST is not set."
        usage
    fi
fi

# Check if required arguments are provided
if [[ -z "$credentials" || -z "$new_log_level" ]]; then
    usage
fi

# Split the swarm_ip into an array of IP addresses if it contains delimiters
IFS=';, ' read -r -a ip_array <<< "$swarm_ip"

# Validate credentials before proceeding
debug_msg "Validating credentials..."
#if [[ "$credentials" =~ ^[^:]+$ ]]; then
if [[ -n "$credentials" ]]; then
    CREDENTIALS="$credentials"
    ATTEMPT=$MAX_RETRIES
    USERNAME=""
    PASSWORD=""
    debug_msg "CREDENTIALS: $(print_credentials "$CREDENTIALS")"
    debug_msg "ATTEMPT: $ATTEMPT"

    # Check if credentials contain a colon (username:password format)
    debug_msg "Checking for colon in credentials..."
    if [[ "$CREDENTIALS" == *":"* ]]; then
        debug_msg "Credentials contain colon"
        USERNAME="${CREDENTIALS%%:*}"
        PASSWORD="${CREDENTIALS#*:}"

        # Validate Ifcredentials
multiple IPs are provided, the script will update the log level for all nodes."check_credentials "$CREDENTIALS" "${ip_array[0]}"
       echo "if [[ $? -ne 0 ]]; then
            debug_msg "Invalid credentials. Please check your username  (Alternatively, set the SCSP_HOST environment variable to the Swarm IP.)"and password."
            echo -e ""
 -p, --credentials        Credentials in theecho format admin:password"
    echo "  -i, --log.level-e "${RED}Error${RESET}: Invalid credentials. Please check your username and password."
            echo New-e cluster""
log level to set (5, 10, 15, 20, 30, 40, 50, chatter, debug,exit announce,1
info, error, critical, default)"     echofi
"  -L, --node.log.level     New node log level to set (0, 5, 10, 15, 20, 30, 40, 50, chatter, debug, announce, info, error, critical, default)"debug_msg "Validate credentials"
        credentials=$CREDENTIALS
    else
        echodebug_msg "Credentials do not contain password"
        debug_msg "Username: $(print_credentials "$CREDENTIALS")"
        USERNAME="$CREDENTIALS"
 **Either  -i or -L must be specified,# butPrompt not both.**"for password
    echo "  -t, --time       while [[ $ATTEMPTS -lt $MAX_RETRIES ]]; do
        (Optional) Duration in seconds toecho keep""
the new log level (must be greater than 0)"    read echo-sp "Enter password for -D, --detach  user $USERNAME: " PASSWORD
          (Optional) Detach theecho script""
from the current terminal and run in a detachable session using screen orecho tmux""
      exit 1 }  # Default options
detachable=false
debug=false
output_log="script_output.log"						# Log file for capturing detachable session output
log_level_type="cluster"									# Default log level type
default_log_level=30											# Default log level
log_file="/var/log/datacore/castor.log"		# Default log file location

# Global associative array for log levels
declare -A log_levels=(
    [5]="chatter"
    [10]="debug"
    [15]="audit"
    [20]="info"
    [30]="warning"
    [40]="error"
    [45]="defect"
    [50]="critical"
    [60]="announce"
    [30]="default"
)

# Global associative array for log level names
declare -A log_level_names=(
    ["chatter"]=5
    ["debug"]=10
    ["audit"]=15
    ["info"]=20
    ["warning"]=30
    ["error"]=40
    ["defect"]=45
    ["critical"]=50
    ["announce"]=60
    ["default"]=30
)

# Function to display debug messages if debug mode is enabled
debug_msg() {
    if $debug; thenif [[ -z "$PASSWORD" ]]; then
                echo -e "${RED}Error${RESET}: Password cannot be empty."
                ((ATTEMPTS++))
                continue
            fi
            CREDENTIALS="$USERNAME:$PASSWORD"
            debug_msg "CREDENTIALS: $(print_credentials "$CREDENTIALS"))"
            check_credentials "$CREDENTIALS" "${ip_array[0]}"
            if [[ $? -eq 0 ]]; then
                debug_msg "CREDENTIALS: $(print_credentials "$CREDENTIALS"))"
                echo -e "[DEBUG] $1" >> "$output_log"debug_msg "Valid credentials"
       fi }  # Function to check if either 'screen' or 'tmux' is installed
check_screen_or_tmux() { credentials=$CREDENTIALS
          if ! command -v screen &>/dev/null && ! command -v tmux &>/dev/null; then break
            else
 echo "Error: Neither 'screen' nor 'tmux' is installed. Cannot run in detachable mode."   echo -e ""
   detachable=false  # Disable detachable session        echo debug_msg-e "detachable=${YELLOWRED}false$Error${RESET}"
    fi
}

# Function to format file size
format_size() {
    local size=$1: Invalid credentials. Please check your username and password."
            fi
       if (( size >= 1073741824 ((ATTEMPTS++)); then
        echodone
"$(awk "BEGIN {printf \"%.1fGB\", $size/1073741824}")"    if elif[[ (( size >= 1048576 ))$ATTEMPTS -ge $MAX_RETRIES ]]; then
        echo "$(awk "BEGIN {printf \"%.1fMB\", $size/1048576}")"    echo -e ""
      elif (( size >= 1024 )); thenecho -e "${RED}Error${RESET}: Maximum number of password attempts reached. echoExiting "$(awk "BEGIN {printf \"%.1fKB\", $size/1024}")"script."
            elseexit 1
       echo "${size}B" fi
    fi
}else
 # Function to formatif duration! format_duration() {
    local duration=$1check_credentials "$credentials" "${ip_array[0]}"; then
       local hours=$((duration / 3600)) echo -e ""
    local minutes=$(( (duration % 3600)echo / 60 ))
-e "${YELLOW}Warning${RESET}: ${RED}Invalid credentials${RESET}."
   local seconds=$((duration % 60))  echo -e  printf "%02d:%02d:%02d"
$hours $minutes $seconds }  # Function to checkexit if1
jq is available and setfi
upfi
JSON
parsing# method
check_jq() {
    if [[ -x "/usr/local/bin/jq" ]]; then
        echo "/usr/local/bin/jq"
    elif [[ -x "$(pwd)/jqRetrieve cluster name and handle JSON parsing using the first IP address
debug_msg "Retrieving the cluster name from Swarm API using IP: ${ip_array[0]}"
if [[ "$jq_or_grep" == "grep" ]]; then
    clusterName=$(curl --user "$credentials" -sS echo "$(pwd)/jq"
    elif command -v jq &>/dev/null; then
 http://${ip_array[0]}:91/api/storage/clusters" | grep -oP '"name":\s*"\K[^"]+')
else
      echoclusterName=$(curl --user "jq$credentials" -sS "http://${ip_array[0]}:91/api/storage/clusters" |  else
        echo "grep"
    fi
}

jq_or_grep=$(check_jq)

# Function to determine the log file path
determine_log_file() {"$jq_or_grep" -r '._embedded.clusters[0].name')
fi

if [[ -z "$clusterName" ]]; then
    echo "Failed to retrieve the cluster name. Please check your inputs."
    ifexit [[1
-f "/var/log/datacore/castor.log" ]]; then
        echo "/var/log/datacore/castor.log"
    elif [[ -f "/var/log/caringo/castor.log" ]]; then
   fi
debug_msg "Cluster Name: $clusterName"

# Main logic function to run the script tasks
main_script() {
    local swarm_ip="$1"
    local credentials="$2"
    echo "/var/log/caringo/castor.loglocal new_log_level="$3"
    elselocal new_log_level_name="$4"
    local duration="$5"
  echo "Error: Log file not found in /var/log/datacore/castor.log or local log_level_type="$6"
    #local log_file="/var/log/caringodatacore/castor.log"
    if [[ -z "$log_file" ]]; exitthen
1     fi }  log_file=$(determine_log_file)
 # Parse input argumentsfi
while [[ "$#" -gt 0 ]]; do
    case $1 in
        -d|--swarm_ip) swarm_ip="$2"; debug_msg "Set swarm_ip to $swarm_ip"; shift 2 ;;
local initial_size=$(stat -c%s "$log_file" 2>/dev/null || echo 0)
    local current_log_level
 -p|--credentials)      local clusterName="$7"
      credentialslocal jq_or_grep="$2$8"
       local detachable="$9"
    if ! [[ "$credentials$detachable" =~ ^[^:]+:[^:]+$ ]]; then
        local debug="${10}"
        eval "$(echo -e ""${11}" | sed 's/declare -A/declare -A/')"
        eval   "$(echo -e "Error: Credentials must be in the format ${BOLD_GREEN}username:password${RESET}"${12}" | sed 's/declare -A/declare -A/')"
    fi
      local default_log_levels="$13"
    exit 1local default_log_levels_name="$14"
    debug_msg "**********************************************************"
    debug_msg "local fivariables"
    debug_msg "Log Level Type: ${GREEN}$log_level_type${RESET}"
   if [[debug_msg "$credentials"Default =~ [^a-zA-Z0-9:] ]]; thenLog Level: ${GREEN}$default_log_level${RESET}"
    debug_msg "Swarm IP: $swarm_ip"
    debug_msg "Credentials:    echo -e "$(print_credentials "$credentials")"
    debug_msg "New Log Level: $new_log_level"
    debug_msg "New log echoLevel -e "Warning: Password contains special characters. Please enclose the credentials with single quotes (${BOLD_YELLOW}'${BOLD_GREEN}username:password${RESET}${BOLD_YELLOW}'${RESET}).Name: $new_log_level_name"
    debug_msg "Duration: $duration"
    debug_msg "Log File: $log_file"
                exit 1
     debug_msg "Initial Log File Size: $initial_size"
    debug_msg "Current Log Level: $current_log_level"
    debug_msg "Cluster fiName: $clusterName"
    debug_msg "jq_or_grep: $jq_or_grep"
    debug_msg "SetDetach: credentials$detachable";
shift 2 ;;  debug_msg "Debug: $debug"
    -i|--log.level)
   debug_msg "**********************************************************"

    # Split  if [[ -n "$new_log_level" ]]; then
   the swarm_ip into an array of IP addresses
    IFS=';,        echo "Error: Options -i (cluster log leve) and -L (node log level) cannot be used together.' read -r -a ip_array <<< "$swarm_ip"
    debug_msg "IP Array: ${ip_array[*]}"

    # Display  usage
      initial information
     fi
            if [[ ${log_level_names[$2]}"$log_level_type" == "cluster" ]]; then
        echo -e "Swarm      new_log_level=${log_level_names[$2]}IP: ${GREEN}${ip_array[0]}${RESET}"
    else
        elif [[echo -e "Swarm IPs: ${log_levels[$2]} ]]; thenGREEN}${ip_array[*]}${RESET}"
    fi
    # echo -e "Swarm IP: ${GREEN}$swarm_ip${RESET}"
   new_log_level=$2
    debug_msg "Credentials: ${GREEN}[hidden for security]${RESET}"
    echo -e "Cluster  else
Name: ${GREEN}$clusterName${RESET}"

    debug_msg "Starting main_script function..."
      echodebug_msg "InvalidLog loglevel leveltype: $2$log_level_type"

    # Store the original log levels
    declare exit 1-A original_log_levels
    declare -A original_log_level_names

    fidefault_log_level=${default_log_levels[$log_level_type]}
            newdefault_log_level_name=${default_log_levelslevel_names[$new$log_loglevel_leveltype]}
    debug_msg "Default log level: $default_log_level"
    log_level_type="cluster"
    debug_msg "Default log level name: $default_log_level_name"

    if [[ default$log_loglevel_leveltype ==30 "cluster" ]]; then
         debug_msg "SetSetting cluster new_log_ level to $new_log_level ($new_log_level_name)"
        # Retrieve current  shift 2
            ;;
        -L|--node.log.level)
log level
           if [[ -n "$new$jq_log_levelor_grep" == "grep" ]]; then
                echo "Error: Options -i (cluster log leve) and -L (node log level) cannot be
used together."           current_log_level=$(curl --user "$credentials" -sS "http://${ip_array[0]}:91/api/storage/clusters/$clusterName/settings/log.level" | usagegrep -oP '"value":\s*\K[0-9]+')
        else
 fi           current_log_level=$(curl  if [[ ${log_level_names[$2]} ]]; then--user "$credentials" -sS "http://${ip_array[0]}:91/api/storage/clusters/$clusterName/settings/log.level" | "$jq_or_grep" -r '.value')
        fi
        newcurrent_log_level_name=${log_levels[$current_log_level_names[$2]}
          if  elif [[ ${$current_log_levels[$2]} || $2 -eq 0 level == 30 ]]; then
                newcurrent_log_level=$2
                new_log_level_name="default"
        fi
   else     if [[ $new_log_level == 30 ]]; then
     echo "Invalid log level: $2"   new_log_level_name="default"
        fi
    exit 1   debug_msg "Current cluster log level: ${BOLD_GREEN}$current_log_level${RESET}"
    fi    debug_msg "Current log level      name: ${BOLD_GREEN}$current_log_level_type="node"name${RESET}"
        echo -e ""
 default_log_level=0       echo -e "New cluster log level: debug_msg "Set new${BOLD_GREEN}$new_log_level to $new_log_level (_name${RESET} (${BOLD_GREEN}$new_log_level_namelevel${RESET})"
        echo -e "Current cluster shiftlog 2level is      ${BOLD_GREEN}$current_log_level_name${RESET} (${BOLD_GREEN}$current_log_level${RESET})."

    ;;    # Skip update if  -t|--time)
   new level matches the current level
        if [[ -n "$2" && "$2" != -* && "$2" -gt 0 "$current_log_level" -eq "$new_log_level" ]]; then
            echo    duration="$2"
                debug_msgecho -e "SetCluster durationlog tolevel $duration"is already set to ${BOLD_GREEN}$new_log_level_name${RESET} (${BOLD_GREEN}$new_log_level${RESET}). No changes made."
        shift 2   return
        fi
else
        # Update       echo "Error: Duration must be a number greater than 0."the cluster log level using PUT
        debug_msg "Updating cluster log level to $new_log_level_name"
    exit 1   debug_msg "Cluster Name: $clusterName"
      fi  debug_msg "Credentials: $(print_credentials "$credentials")"
       ;; debug_msg "curl --user \"$(print_credentials "$credentials")\" -sS -X PUT -D|--detach) detachable=true; debug_msg "Set detachable to true"; shift ;;H \"Content-Type: application/json\" \"http://${ip_array[0]}:91/api/storage/clusters/$clusterName/settings/log.level\" -d \"{\\\"value\\\": $new_log_level}\""
        response=$(curl  --debug) debug=true; debug_msg "Set debug to true"; shift ;;
        *) usage ;;
    esac
done

debug_msg "Set log_level_type to ${YELLOW}$log_level_type${RESET}"

# Set default values if not provided
if [[ -z "$new_log_level" ]]; thenuser "$credentials" -sS -X PUT -H "Content-Type: application/json" \
          if [[ "$log_level_type" == "cluster" ]]; thenhttp://${ip_array[0]}:91/api/storage/clusters/$clusterName/settings/log.level" \
            -d  new"{\"value\": $new_log_level=$default_log_level}")
    else    debug_msg "Response: $response"

 new_log_level=0     fi  if [[  new"$jq_log_level_name="default"
    new_log_level_name=${log_levels[$new_log_level]}or_grep" == "grep" ]]; then
       debug_msg "Set default new_log_level to $newupdated_log_level ($new_log_level_name)"
fi

# Check if 'screen' or 'tmux' is installed
check_screen_or_tmux

# If swarm_ip is not provided, try using SCSP_HOST environment variable
if [[ -z "$swarm_ip" ]]; then
    if [[ -n "$SCSP_HOST" ]]; then=$(echo "$response" | grep -oP '"value":\s*\K[0-9]+')
        else
            updated_log_level=$(echo "$response" | "$jq_or_grep" -r '.value')
        swarm_ip="$SCSP_HOST"fi
        debug_msg "UsingUpdated Swarmcluster IPlog fromlevel: SCSP_HOST: $swarm_ip$updated_log_level"

   else     if [[   echo "Error: swarm_ip not provided and SCSP_HOST is not set."
 "$updated_log_level" -eq "$new_log_level" ]]; then
      usage     fi fiecho 
# Check if required arguments are provided
if [[ -z "$credentials" || -z "$new_log_level" ]]; then-e "${GREEN}$(timestamp)${RESET} Log level changed successfully from ${BOLD_GREEN}$current_log_level_name${RESET} (${BOLD_GREEN}$current_log_level${RESET}) -> ${BOLD_GREEN}$new_log_level_name${RESET} (${BOLD_GREEN}$new_log_level${RESET})."
      usage fi else
# Split the swarm_ip into an array of IP addresses if it contains delimiters
IFS=';, ' read -r -a ip_array <<< "$swarm_ip"

# Retrieve cluster name and handle JSON parsing using the first IP address
debug_msg "Retrieving the cluster name from Swarm API using IP: ${ip_array[0]}"
if [[ "$jq_or_grep" == "grep" ]]; then
    clusterName=$(curl --user "$credentials" -sS "http://${ip_array[0]}:91/api/storage/clusters" | grep -oP '"name":\s*"\K[^"]+')
else
    clusterName=$(curl --user "$credentials" -sS "http://${ip_array[0]}:91/api/storage/clusters" | "$jq_or_grep" -r '._embedded.clusters[0].name')
fi

if [[ -z "$clusterName" ]]; then
    echo "Failed to retrieve the cluster name. Please check your inputs."
    exit 1
fi
debug_msg "Cluster Name: $clusterName"

# Main logic function to run the script tasks
main_script() {
    local swarm_ip="$1"
    local credentials="$2"
    local new_log_level="$3"
    local new_log_level_name="$4"
    local duration="$5"
    local log_level_type="$6"
    # local log_file="/var/log/datacore/castor.log"
    local initial_size=$(stat -c%s "$log_file" 2>/dev/null || echo 0)
    local current_log_level
    local clusterName="$7"
    local jq_or_grep="$8"
    local debug="$9"
    debug_msg "**********************************************************"
    debug_msg "local variables"
    debug_msg "Swarm IP: $swarm_ip"
    debug_msg "Credentials: $credentials"
    debug_msg "New Log Level: $new_log_level ($new_log_level_name)"
    debug_msg "Duration: $duration"
    debug_msg "Log Level Type: $log_level_type"
    debug_msg "Log File: $log_file"
    debug_msg "Initial Log File Size: $initial_size"
    debug_msg "Current Log Level: $current_log_level"
    debug_msg "Cluster Name: $clusterName"
    debug_msg "jq_or_grep: $jq_or_grep"
    debug_msg "Debug: $debug"
    debug_msg "**********************************************************"

    # Split the swarm_ip into an array of IP addresses
    IFS=';, ' read -r -a ip_array <<< "$swarm_ip"
    debug_msg "IP Array: ${ip_array[*]}"

    # Display initial informationecho -e "${GREEN}$(timestamp)${RESET} Failed to update log level. Response: ${RED}$response${RESET}"
            exit 1
        fi

        # Countdown and revert log level
        if [[ -n "$duration" && "$duration" -gt 0 ]]; then
            echo -e "Keeping log level at ${YELLOW}$new_log_level_name${RESET} (${YELLOW}$new_log_level${RESET}) for ${YELLOW}$duration${RESET} seconds (${YELLOW}$(format_duration $duration)${RESET}) ..."
            echo -e ""
            for ((i=duration; i>0; i--)); do
                printf -v countdown "%02d:%02d:%02d" $((i/3600)) $(( (i%3600) / 60 )) $((i%60))
                echo -ne "Countdown: ${YELLOW}$countdown${RESET} remaining...\r"
                sleep 1
            done
            echo -e "\n\nTime's up! Reverting log level back to ${GREEN}$current_log_level_name${RESET} (${BOLD_GREEN}$current_log_level${RESET}) ..."

            # Revert the log level back to the original value
            # echo -e "Level log revert on $(timestamp)"
            response=$(curl --user "$credentials" -sS -X PUT -H "Content-Type: application/json" \
                "http://${ip_array[0]}:91/api/storage/clusters/$clusterName/settings/log.level" \
                -d "{\"value\": $current_log_level}")
            debug_msg "Response: $response"

            if [[ "$log$jq_levelor_typegrep" == "clustergrep" ]]; then
                reverted_log_level=$(echo -e "Swarm IP: ${GREEN}${ip_array[0]}${RESET}""$response" | grep -oP '"value":\s*\K[0-9]+')
    else        else
echo  -e "Swarm IPs: ${GREEN}${ip_array[*]}${RESET}"     fi     # echo -e "Swarm IP: ${GREEN}$swarm_ip${RESET}"
    echo -e "Credentials: ${GREEN}[hidden for security]${RESET}" reverted_log_level=$(echo "$response" | "$jq_or_grep" -r '.value')
        echo -e "Cluster Name: ${GREEN}$clusterName${RESET}" fi
     debug_msg "Starting main_script function..."     debug_msg "LogReverted cluster log level type: $log$reverted_log_level_type"

    # Store the original log levels   final_size=$(stat  declare -A original_log_levels
 -c%s "$log_file" 2>/dev/null || echo 0)
  declare -A original_log_level_names      if [[ $log_level_type == "cluster" ]]; thendebug_msg "Initial log file size: $initial_size"
            debug_msg "SettingFinal cluster log levelfile tosize: $new_log_level ($new_log_level_name)"$final_size"
            # Retrieve current log levelsize_diff=$(( final_size - initial_size ))
          if [[ "$jqsize_ordiff_grep" == "grep" ]]; thenformatted=$(format_size "$size_diff")
             current_log_levelduration_formatted=$(curl --user "$credentials" -sS "http://${ip_array[0]}:91/api/storage/clusters/$clusterName/settings/log.level" | grep -oP '"value":\s*\K[0-9]+')
        else
 format_duration "$duration")
	    if (( size_diff < 0 )); then
		echo -e "castor.log file was rotated."
	    else
          current_log_level=$(curl --user "$credentials" echo -sSe "http://${ip_array[0]}:91/api/storage/clusters/$clusterName/settings/log.level" | "$jq_or_grep" -r
'.value')         fi   echo -e     current_log_level_name="Approximate ${log_levels[$current_log_level]}
        debug_msg "Current cluster log level: BOLD_GREEN}$size_diff_formatted${RESET} new logs were generated at log level ${BOLD_GREEN}$new_log_level_name${RESET} (${BOLD_GREEN}$current$new_log_level${RESET}"). Current castor.log size is     debug_msg "Current log level: ${BOLD_GREEN}$current_log_level_name${RESET}"${BOLD_GREEN}$(format_size "$final_size")${RESET} after ${YELLOW}$duration${RESET} seconds (${YELLOW}$duration_formatted${RESET})."
            echo -e ""
	    fi
     echo  -e "Newif cluster[[ "$reverted_log level: ${BOLD_GREEN}$new__level" -eq "$current_log_level_name${RESET}"" ]]; then
            echo -e "Current cluster log level is${GREEN}$(timestamp)${RESET} Log level reverted successfully back to ${BOLD_GREEN}$current_log_level_name.${RESET}name${RESET} (${BOLD_GREEN}$current_log_level${RESET})."
         # Skip update ifecho new-e level""
matches the current level     else
   if [[ "$current_log_level" -eq "$new_log_level" ]]; then   echo -e "${GREEN}$(timestamp)${RESET} Failed to revert log level.   echo ""Response: ${RED}$response${RESET}"
            echo -e "Cluster log level is already set to ${BOLD_GREEN}$new_log_level_name${RESET}. No changes made." ""
            exit 1
        fi
     return   else
     fi       echo -e  # Update the cluster log level using PUT"${GREEN}$(timestamp)${RESET} Log level change is permanent until manually modified."
        debug_msg "Updating cluster log level to $new_logfi
    elif [[ "$log_level_nametype" == "node" ]];   then
  debug_msg "Cluster Name: $clusterName"   # First loop: Change the node response=$(curl --user "$credentials" -sS -X PUT -H "Content-Type: application/json" \
log level
        local same_log_level=false
        for ip in "http://${ip_array[0@]}:91/api/storage/clusters/$clusterName/settings/log.level" \"; do
            # Retrieve -d "{\"value\": $new_log_level}")current node log level
            debug_msg "ResponseRetrieving current node log level for IP: $response$ip"
          if [[ "$jq_or_grep" == "grep" ]]; then  debug_msg "curl -s -u \"$(print_credentials "$credentials")\" \"http://$ip:91/api/storage/nodes/_self/settings/log.nodeLogLevel\""
              updatedcurrent_log_level=$(echo "$responsecurl -s -u "$credentials" "http://$ip:91/api/storage/nodes/_self/settings/log.nodeLogLevel" | $jq_or_grep -oPr '"value":\s*\K[0-9]+.value')
        else    debug_msg "Current log level for IP $ip:   updated$current_log_level=$(echo "$response" | "$jq_or_grep" -r '.value')"
            original_log_levels["$ip"]=$current_log_level
   fi         debug_msg "Updated cluster log level: $updated_log_level"Original log level for IP $ip: ${original_log_levels["$ip"]}"
            if [[ "$updated$current_log_level" -eq== "$new_log_level0" ]]; then
            echo -e "Log level changed successfully from ${GREEN}$current current_log_level${RESET} → ${BOLD_GREEN}$new_log_level${RESET}.level_name="default"
        else    else
        echo -e "Failed to update log level. Response: ${RED}$response${RESET}" current_log_level_name=${log_levels[$current_log_level]}
            fi
            original_log_level_names["$ip"]=$current_log_level_name
 exit 1         fi debug_msg "Original log level name: ${original_log_level_names["$ip"]}"
   # Countdown and revert log level
        if [[ -n "$duration" && "$duration" -gt 0 "$new_log_level" == "0" ]]; then
            echo -e "Keeping log level at ${YELLOW}$new new_log_level${RESET} for ${YELLOW}$duration${RESET} second(s)..."level_name="default"
            else
echo -e ""             for ((i=duration; i>0; i--)); do new_log_level_name=${log_levels[$new_log_level]}
            fi
      printf -v countdown "%02d:%02d:%02d" $((i/3600)) $(( (i%3600) / 60 )) $((i%60))
    debug_msg "Current log level for IP $ip: $current_log_level ($current_log_level_name)"
            echo -ne "Countdown: ${YELLOW}$countdown${RESET} remaining...\r"
            echo -e "New node sleeplog 1
            donelevel: ${BOLD_GREEN}$new_log_level_name${RESET} (${BOLD_GREEN}$new_log_level${RESET})"
            echo -e "\n\nTime's up! Reverting Current node log level back to ${for IP ${BOLD_GREEN}$ip${RESET} is ${BOLD_GREEN}$current_log_level_name${RESET} (${BOLD_GREEN}$current_log_level${RESET}..)."

            # RevertSkip update theif lognew level backmatches the tocurrent thelevel
original value           if  response=$(curl --user "$credentials" -sS -X PUT -H "Content-Type: application/json" \[[ "$current_log_level" -eq "$new_log_level" ]]; then
                same_log_level=true
                echo "http://${ip_array[0]}:91/api/storage/clusters/$clusterName/settings/log.level"
\                echo -de "{\"value\": $current_log_level}")
            debug_msg "Response: $responseNode log level for IP ${BOLD_GREEN}$ip${RESET} is already set to ${BOLD_GREEN}$new_log_level_name${RESET} (${BOLD_GREEN}$new_log_level${RESET}). No changes made."
             if [[ "$jq_or_grep" == "grep" ]]; then    continue
            reverted_log_level=$(echo "$response" | grep -oP '"value":\s*\K[0-9]+')else
                same_log_level=false
else            fi

   reverted_log_level=$(echo "$response" | "$jq_or_grep" -r '.value')    if [[ "$same_log_level" == false ]]; then
  fi             debug_msg "Reverted# clusterUpdate logthe level:node $reverted_log_ level" using PUT
           final_size=$(stat -c%s "$log_file" 2>/dev/null || echo 0)
        debug_msg "Updating node log level to $new_log_level_name for IP $ip..."
   size_diff=$(( final_size - initial_size ))         debug_msg "curl   size_diff_formatted=--user \"$(formatprint_sizecredentials "$size_diff$credentials")\" -sS -X PUT -H \"Content-Type: application/json\" \"http://$ip:91/api/storage/nodes/_self/settings/log.nodeLogLevel?value=$new_log_level\""
     duration_formatted=$(format_duration "$duration") 	    if (( size_diff < 0 )); then
		echo -e "castor.log file was rotated."
	    else response=$(curl --user "$credentials" -sS -X PUT -H "Content-Type: application/json" \
                   echo -e "Approximate ${BOLD_GREEN}$size_diff_formatted${RESET} new logs were generated at log level ${BOLD_GREEN}$new_log_level${RESET}. Current castor.log size is ${BOLD_GREEN}$(format_size "$final_size")${RESET} after $duration_formatted."
	    fi"http://$ip:91/api/storage/nodes/_self/settings/log.nodeLogLevel?value=$new_log_level")
                debug_msg "Response: $response"

                if [[ "$reverted$jq_logor_levelgrep" -eq== "$current_log_levelgrep" ]]; then
                echo -e "Log level reverted successfully back to ${BOLD_GREEN}$current updated_log_level${RESET}.level=$(echo "$response" | grep -oP '"value":\s*\K[0-9]+')
        else        else
        echo -e "Failed to revert log level. Response: ${RED}$response${RESET}"    updated_log_level=$(echo "$response" | "$jq_or_grep"   -r '.value')
      exit 1             fi
        else        debug_msg "Updated log level for echoIP "Log level change is permanent until manually modified."$ip: $updated_log_level"

            fi     elifif [[ "$log$updated_log_level_type" ==-eq "node$new_log_level" ]]; then
          # First loop: Change the node          echo -e "${GREEN}$(timestamp)${RESET} Node log level for IP ${BOLD_GREEN}$ip${RESET} changed successfully from ${BOLD_GREEN}$current_log_level_name${RESET}  for ip in "${ip_array[@]}"; do(${GREEN}$current_log_level${RESET}) -> ${BOLD_GREEN}$new_log_level_name${RESET} (${BOLD_GREEN}$new_log_level${RESET})."
             # Retrieve current nodeelse
log level             debug_msg "Retrieving current node log level forecho IP:-e $ip"
            debug_msg "curl -s -u \"$credentials\" \"http://$ip:91/api/storage/nodes/_self/settings/log.nodeLogLevel\""
            current_log_level=$(curl -s -u "$credentials" "http://$ip:91/api/storage/nodes/_self/settings/log.nodeLogLevel" | $jq_or_grep -r '.value')"${GREEN}$(timestamp)${RESET} Failed to update node log level for IP ${BOLD_GREEN}$ip${RESET}. Response: ${RED}$response${RESET}"
                    exit 1
  original_log_levels["$ip"]=$current_log_level             if [[ "$current_log_level" == "0" ]]; thenfi
            fi
        current_log_level_name="default"done

        # Second loop: elseCountdown if duration is provided
        if    current[[ "$same_log_level_name=${log_levels[$current_log_level]}" == false ]]; then\
            fiif [[ -n "$duration" && "$duration" -gt 0 ]]; then
   original_log_level_names["$ip"]=$current_log_level_name             ifecho [[-e "$new_log_level"
  ==  "0" ]]; then          echo -e "Keeping node(s) log level at new${YELLOW}$new_log_level_name="default"_name${RESET} (${YELLOW}$new_log_level${RESET}) for ${YELLOW}$duration${RESET} seconds (${YELLOW}$(format_duration $duration)${RESET}) ..."
              else  echo -e ""
            new_log_level_name=${log_levels[$new_log_level]}    for ((i=duration; i>0; i--)); do
    fi             debug_msg "Current log levelprintf for-v IP $ip: $current_log_level ($current_log_level_name)"
     countdown "%02d:%02d:%02d" $((i/3600)) $(( (i%3600) / 60 )) $((i%60))
      echo ""             echo -ene "New node log levelCountdown: ${BOLD_GREEN}$new_log_level_name${RESET}YELLOW}$countdown${RESET} remaining...\r"
            echo  -e "Current node log level for IPsleep $ip1
is ${GREEN}$current_log_level_name.${RESET}"              # Skipdone
update if new level matches the current level         echo -e "\n\nTime's up! ifReverting [[node "$current_log_level" -eq "$new_log_level" ]];back thento original levels..."

             echo ""  # Third loop: Revert the node log   level
     echo -e "Node log level for IP $ip is already set to ${BOLD_GREEN}$new_log_level_name${RESET}. No changes made."
for ip in "${ip_array[@]}"; do
               continue     current_log_level=${original_log_levels["$ip"]}
       fi              # Update the node log level using PUTcurrent_log_level_name=${original_log_level_names["$ip"]}
                    debug_msg "UpdatingReverting node log level back to $new$current_log_level_name for IP $ip..."
                    debug_msg "curl --user \"$(print_credentials "$credentials")\" -sS -X PUT -H \"Content-Type: application/json\" \"http://$ip:91/api/storage/nodes/_self/settings/log.nodeLogLevel?value=$new_log_level\""value=$current_log_level\""
                    # echo -e "Node level log revert on $(timestamp) for IP $ip"
                    response=$(curl --user "$credentials" -sS -X PUT -H "Content-Type: application/json" \
                        "http://$ip:91/api/storage/nodes/_self/settings/log.nodeLogLevel?value=$new$current_log_level")
                    debug_msg "Response: $response"

                    if [[ "$jq_or_grep" == "grep" ]]; then
                 updated       reverted_log_level=$(echo "$response" | grep -oP '"value":\s*\K[0-9]+')
                    else
                        reverted_log_level=$(echo "$response" | "$jq_or_grep" -r '.value')
                    fi

else                    updatedfinal_log_levelsize=$(echostat -c%s "$response$log_file" 2>/dev/null | "$jq_or_grep" -r '.value')
    | echo 0)
                    size_diff=$(( final_size - initial_size ))
       fi             debug_msg "UpdatedInitial log level for IP $ipfile size: $updated$initial_log_levelsize"
             if [[ "$updated_log_level" -eq "$new_log_level" ]]; then debug_msg "Final log file size: $final_size"
          echo -e "Node log level for IP $ip changed successfully from ${GREEN}$current_log_level_name${RESET} → ${BOLD_GREEN}$new_log_level_name${RESET}."size_diff_formatted=$(format_size "$size_diff")
            else        duration_formatted=$(format_duration "$duration")

      echo -e "Failed to update node log level for IP $ip. Response: ${RED}$response${RESET}"  if [[ "$reverted_log_level" -eq "$current_log_level" ]]; then
        exit 1             fi  echo       done

        # Second loop: Countdown if duration is provided-e "${GREEN}$(timestamp)${RESET} Node log level for IP ${BOLD_GREEN}$ip${RESET} reverted successfully back to ${BOLD_GREEN}${current_log_level_name}${RESET} (${BOLD_GREEN}$current_log_level${RESET})."
            if [[ -n "$duration" && "$duration" -gt 0 ]];else
then             echo -e ""
            echo -e "Keeping node(s)${GREEN}$(timestamp)${RESET} Failed to revert node log level for atIP ${YELLOW}$new_log_level_name$BOLD_GREEN}$ip${RESET}. forResponse: ${YELLOWRED}$duration$$response${RESET} second(s)...""
              echo -e ""        exit 1
   for ((i=duration; i>0; i--)); do             fi
   printf -v countdown "%02d:%02d:%02d" $((i/3600)) $(( (i%3600) / 60 )) $((i%60))   done

            echo -ne "Countdown: ${YELLOW}$countdown${RESET} remaining...\r"
            # Combine the log output for multiple IP addresses into a single summary
    sleep 1       if (( size_diff < 0 )); donethen
            echo -e "\n\nTime's up! Reverting node log level back to original levels... "castor.log file was rotated."
             #else
Third loop: Revert the node log level             for ipecho in-e "${ip_array[@]}";
do                 current_log_level=${original_log_levels["$ip"]}   echo -e "Approximate ${BOLD_GREEN}$size_diff_formatted${RESET} new logs were generated at log     currentlevel ${BOLD_GREEN}$new_log_level_name=name${RESET} (${originalBOLD_GREEN}$new_log_level_names["$ip"]}
                debug_msg "Reverting node log level back to $current_log_level_name for IP $ip...level${RESET}) for IP ${ip_array[*]}. Current castor.log size is ${BOLD_GREEN}$(format_size "$final_size")${RESET} after ${YELLOW}$duration${RESET} seconds (${YELLOW}$duration_formatted${RESET})."
                debug_msg "curl --user \"$credentials\" -sS -X PUT -H \"Content-Type: application/json\" \"http://$ip:91/api/storage/nodes/_self/settings/log.nodeLogLevel?value=$current_log_level\ echo -e ""
            fi
   response=$(curl --user "$credentials" -sS -X PUT -H "Content-Type: application/json" \else
                echo -e "${GREEN}$(timestamp)${RESET}  "http://$ip:91/api/storage/nodes/_self/settings/log.nodeLogLevel?value=$current_log_level")
     Log level change is permanent until manually modified."
          debug_msg "Response: $response"  fi
        fi
    fi
}

# Run ifin [[detachable "$jq_or_grep" == "grep" ]]directly
if $detachable; then
    # Pass the main_script function to the screen session and store the output in a file
    reverted_log_level=$(echo "$responsedebug_msg "**********************************************************" | greptee -oP '"value":\s*\K[0-9]+')
       a "$output_log"
    debug_msg "Detach mode - Parameters passed to main_script:" | tee -a "$output_log"
    debug_msg "   else  Swarm IP: $swarm_ip" | tee -a "$output_log"
    debug_msg "       reverted_log_level=$(echo "$response" | "$jq_or_grep" -r '.value')
   Credentials: $(print_credentials "$credentials")"  | tee -a "$output_log"
    debug_msg "     New Log Level: $new_log_level" | tee -a "$output_log"
fi    debug_msg "     New log Level Name: $new_log_level_name" |   final_size=$(stat -c%s "$log_file" 2>/dev/null || echo 0)
                size_diff=$(( final_size - initial_size ))
  tee -a "$output_log"
    debug_msg "     Duration: $duration" | tee -a "$output_log"
    debug_msg "     Log Level Type: size$log_diff_formatted=$(format_size "$size_diff")
   level_type" | tee -a "$output_log"
    debug_msg "     Log File: duration_formatted=$(format_duration "$duration")

  $log_file" | tee -a "$output_log"
    debug_msg "     Initial Log File if [[ "$reverted_log_level" -eq "$current_log_level" ]]; then
   Size: $initial_size" | tee -a "$output_log"
    debug_msg "     Current Log           echo -e "Node log level for IP $ip reverted successfully back to ${BOLD_GREEN}${current_log_level_name}${RESET}."
       Level: $current_log_level" | tee -a "$output_log"
    debug_msg "     Cluster Name: $clusterName" | tee -a "$output_log"
    debug_msg "   else  jq_or_grep: $jq_or_grep" | tee -a "$output_log"
    debug_msg "     Detach: $detachable" | echotee -ea "Failed to revert node log level for IP $ip. Response: ${RED}$response${RESET}$output_log"
    debug_msg "     Debug: $debug" | tee    -a "$output_log"
    debug_msg "**********************************************************" | tee exit 1-a "$output_log"

    # Convert associative arrays to strings and pass them to the fiscreen session
    log_levels_string=$(declare -p log_levels)
    done

log_level_names_string=$(declare -p log_level_names)
    debug_msg       # Combine the log output for multiple IP addresses into a single summary
	"log_levels_string: $log_levels_string" | tee -a "$output_log"
    debug_msg "log_level_names_string: $log_level_names_string" | tee -a "$output_log"

    if (( size_diff < 0 ))command -v screen &>/dev/null; then
		echo -e "castor.log file was rotated." 	  echo -e else"Running in ${YELLOW}screen${RESET} detachable mode..."             echo -e "| tee -a "$output_log"
        screen -dmS castor_log_script bash -c "$(declare -f main_script timestamp echo -e "Approximate ${BOLD_GREEN}$size_diff_formatted${RESET} new logs were generated at log level ${BOLD_GREEN}debug_msg format_size format_duration check_jq determine_log_file print_credentials); main_script \"$swarm_ip\" \"$credentials\" \"$new_log_level\" \"$new_log_level_name${RESET} for IP ${ip_array[*]}. Current castor.log size is ${BOLD_GREEN}$(format_size "$final_size")${RESET} after $duration_formatted."
	    fi
        else
            echo "Log level change is permanent until manually modified."
        fi
    fi
}

# Run in detachable or directly
if $detachable; then
    # Pass the main_script function to the screen session and store the output in a file
    if command -v screenname\" \"$duration\" \"$log_level_type\" \"$clusterName\" \"$jq_or_grep\" \"$detachable\" \"$debug\" \"${log_levels_string}\" \"${log_level_names_string}\" \"${default_log_levels}\" \"${default_log_levels_name}\" | tee \"$output_log\""
        screen -r castor_log_script
        # Wait for the screen session to complete and then display the output log
        sleep 1
        while screen -list | grep -q "castor_log_script"; do
            sleep 1
        done
    elif command -v tmux &>/dev/null; then
        #echo screen -dmS indexer_script bash -c "$(declare -f main_script format_size format_duration check_jq debug); main_script \"$swarm_ip\" \"$credentials\" \"$new_log_level\" \"$new_log_level_name\" \"$duration\" \"$log_level_type\" \"$clusterName\" \"$jq_or_grep\" | tee \"$output_log\""-e "Running in ${YELLOW}tmux${RESET} detachable mode..." > "$output_log"  # Truncate log file to remove old entries

        # Create a temp script file
        temp_script="$SCRIPTDIR/castor_log_script.sh"

        # Write the script to a file to avoid printing function definitions
        cat screen<<EOF -dmS> indexer"$temp_script"
#!/bin/bash
-c "$(declare -f main_script timestamp debug_msg format_size format_duration check_jq); determine_log_file print_credentials)
main_script \"$swarm_ip\" \"$credentials\" \"$new_log_level\" \"$new_log_level_name\" \"$duration\" "$log_level_type" "$clusterName" "$jq_or_grep" "$detachable" "$debug" \"$log${log_levellevels_type\string}" \"$clusterName\"${log_level_names_string}" \"$jq${default_orlog_grep\levels}" \"$debug\"${default_log_levels_name}" | tee \-a "$output_log\"""
rm -f "$temp_script"               screen     # Remove the script file
tmux kill-session -rt indexercastor_log_script
EOF

  elif command -v tmux &>/dev/null; then # Ensure the script is executable
  # tmux new-session -d -s indexer_script "$(declare -f main_script format_size format_duration check_jq debug); main_script \"$swarm_ip\" \"$credentials\" \"$new_log_level\" \"$new_log_level_name\" \"$duration\" \"$log_level_type\" \"$clusterName\" \"$jq_or_grep\" | tee \"$output_log\"" chmod +x "$temp_script"

        # Start tmux session and execute the script inside
        tmux new-session -d -s indexercastor_log_script "$(declare -f main_script debug_msg format_size format_duration check_jq); main_script \"$swarm_ip\" \"$credentials\" \"$new_log_level\" \"$new_log_level_name\" \"$duration\" \"$log_level_type\" \"$clusterName\" \"$jq_or_grep\" \"$debug\" | tee \"$output_log\""bash $temp_script"

        # Attach session only if it's still running
        while tmux has-session -t castor_log_script 2>/dev/null; do
            tmux attach-session -t indexercastor_log_script
        done
else         echo "Error: Neither screen nor tmux available. Run without --detachable."
  # if tmux has-session -t castor_log_script 2>/dev/null; then
        #     tmux exit 1
attach-session -t castor_log_script
   fi      # Waitfi
for the screen session toelse
complete and then display the output log  echo "Error: Neither sleepscreen 1nor tmux available. Run  whilewithout screen -list | grep -q "indexer_script"; do-detachable."
        exit sleep 1
    donefi

    echo ""
    cat "$output_log"
else
    # main_script "$swarm_ip" "$credentials" "$new_log_level" "$duration" "$clusterName" "$jq_or_grep" | tee "$output_log"
    debug_msg "**********************************************************"
    debug_msg "Parameters passed to main_script:"
    debug_msg "Swarm IP: $swarm_ip"
    debug_msg "Credentials: $(print_credentials "$credentials")"
    debug_msg "New Log Level: $new_log_level"
    debug_msg "Duration: $duration"
    debug_msg "Cluster Name: $clusterName"
    debug_msg "jq_or_grep: $jq_or_grep"
    debug_msg "**********************************************************"
    debug_msg "Running main_script function..."
    main_script "$swarm_ip" "$credentials" "$new_log_level" "$new_log_level_name" "$duration" "$log_level_type" "$clusterName" "$jq_or_grep" | tee "$output_log"
fi