titan-iac/services/comms/mas-db-ensure-job.yaml

# services/comms/mas-db-ensure-job.yaml
apiVersion: batch/v1
kind: Job
metadata:
  name: mas-db-ensure-11
  namespace: comms
spec:
  backoffLimit: 1
  ttlSecondsAfterFinished: 600
  template:
    spec:
      serviceAccountName: mas-db-ensure
      restartPolicy: Never
      containers:
        - name: ensure
          image: bitnami/kubectl:latest
          command: ["/bin/sh", "-c"]
          args:
            - |
              set -eu
              trap 'echo "mas-db-ensure failed"; sleep 300' ERR
              umask 077
              EXISTING_B64="$(kubectl -n comms get secret mas-db -o jsonpath='{.data.password}' 2>/dev/null || true)"
              if [ -n "${EXISTING_B64}" ]; then
                MAS_PASS="$(printf '%s' "${EXISTING_B64}" | base64 -d)"
              else
                MAS_PASS="$(head -c 32 /dev/urandom | base64 | tr -d '\n')"
                MAS_B64="$(printf '%s' "${MAS_PASS}" | base64 | tr -d '\n')"
                payload="$(printf '{"data":{"password":"%s"}}' "${MAS_B64}")"
                kubectl -n comms patch secret mas-db --type=merge -p "${payload}" >/dev/null
              fi

              POD_NAME="$(kubectl -n postgres get pods -l app=postgres -o jsonpath='{.items[0].metadata.name}')"
              if [ -z "${POD_NAME}" ]; then
                echo "postgres pod not found" >&2
                exit 1
              fi

              kubectl -n postgres exec -i "${POD_NAME}" -- psql -U postgres -d postgres -v ON_ERROR_STOP=1 -v mas_pass="${MAS_PASS}" \
                -c "DO \\$\\$ BEGIN IF NOT EXISTS (SELECT 1 FROM pg_catalog.pg_roles WHERE rolname = 'mas') THEN EXECUTE format('CREATE ROLE mas LOGIN PASSWORD %L', :'mas_pass'); ELSE EXECUTE format('ALTER ROLE mas WITH PASSWORD %L', :'mas_pass'); END IF; END \\$\\$;" \
                -c "DO \\$\\$ BEGIN IF NOT EXISTS (SELECT 1 FROM pg_database WHERE datname = 'mas') THEN CREATE DATABASE mas OWNER mas; END IF; END \\$\\$;"