#Upgrade

cat << 'EOF' | bash
#!/usr/bin/env bash

set -o errexit
set -o nounset
set -o pipefail

# Check if kubectl is installed
if ! command -v kubectl &>/dev/null; then
    echo "Error: kubectl is not installed. Please install kubectl and try again." >&2
    exit 1
fi

# Check if we are connected to a cluster
if ! kubectl cluster-info &>/dev/null; then
    echo "Error: Unable to connect to Kubernetes cluster. Please check your kubeconfig." >&2
    exit 1
fi

# Define operator name patterns
patterns=("rds-operator" "rds-operator-stable-platform-cpaas-system" "postgres-operator" "strimzi-kafka-operator" "mysql-mgr-operator" "rabbitmq-cluster-operator" "redis-operator" "clickhouse-operator" "data-services-clickhouse-operator")

# Loop through each pattern
for pattern in "${patterns[@]}"; do
    echo "Processing pattern: $pattern"

    # Get subscriptions that match the pattern (name starts with pattern)
    subscriptions=$(kubectl get subscriptions --all-namespaces -o=jsonpath='{range .items[*]}{.metadata.namespace}{" "}{.metadata.name}{"\n"}{end}' | awk -v pat="$pattern" '$2 ~ "^" pat {print $0}')

    if [ -z "$subscriptions" ]; then
        echo "No subscriptions found for pattern: $pattern"
        continue
    fi

    # Process each subscription
    while IFS= read -r line; do
        namespace=$(echo "$line" | awk '{print $1}')
        name=$(echo "$line" | awk '{print $2}')
        echo "Patching subscription $name in namespace $namespace"

        # Patch the subscription
        if kubectl patch subscription -n "$namespace" "$name" -p '{"spec":{"installPlanApproval":"Manual"}}' --type=merge; then
            echo "Successfully patched subscription $name in namespace $namespace"
        else
            echo "Error: Failed to patch subscription $name in namespace $namespace" >&2
        fi
    done <<<"$subscriptions"
done

echo "Manual upgrade patch completed for all specified operators."
EOF