helpers

#!/bin/bash

argo_version="v3.5.5"
image_k3s="rancher/k3s:v1.27.5-k3s1"

check_ready() {
    ready="0"
    status="0"
    while true; do
    kube_resource=$(kubectl --kubeconfig .kubeconfig get -n $1 $2 | $3 | awk '{print $1}') && \
    status=$(kubectl --kubeconfig .kubeconfig get $2 -n $1 $kube_resource -o $5="$6")
    echo "$kube_resource : status == $status"
    echo "$status" | grep -qi "$4" && echo "$7" && ready="1"
    if [ "$ready" == "1" ]; then
        break
    fi
    sleep 2
    done
}

create_cluster() {
    k3d cluster create \
        --k3s-arg "--disable=traefik@server:0" \
        --volume $(pwd)/install.yaml:/var/lib/rancher/k3s/server/manifests/install.yaml \
        --image $image_k3s \
        mycluster && \
    k3d kubeconfig get mycluster > .kubeconfig && \
    check_ready "kube-system"\
                "pod" \
                "grep coredns" \
                "true" \
                "jsonpath" \
                "{.status.containerStatuses.*.ready}" \
                "COREDNS READY" && \
    check_ready "argo" \
                "pod" \
                "grep argo-server" \
                "true" \
                "jsonpath" \
                "{.status.containerStatuses.*.ready}" \
                "ARGO WORKFLOWS READY"
}

check_workflow () {
    check_ready "default" \
                "workflow" \
                "tail -n 1" \
                "Succeeded" \
                "go-template" \
                '{{ index .metadata.labels "workflows.argoproj.io/phase" }}' \
                "DONE"
}

drop_cluster() {
    k3d cluster delete mycluster
}

setup_forward() {
    kube_pod=$(kubectl --kubeconfig .kubeconfig get -n argo pods | grep argo-server | awk '{print $1}')
    kubectl --kubeconfig .kubeconfig -n argo port-forward pods/$kube_pod 9000:2746
}

update() {
    curl -Lo ./base/install.yaml \
    https://github.com/argoproj/argo-workflows/releases/download/$argo_version/install.yaml && \
    kustomize build overlays/rbac/ > install.yaml
}