- name: execute alternative tasks when source env is OSPdO
  ansible.builtin.include_role:
    name: mariadb_copy
    tasks_from: env_vars_src_ospdo.yaml
  when: ospdo_src| bool

- name: start an adoption mariadb helper pod
  vars:
    internalapi_default_nad: >-
      {% if not (bgp | bool) -%}
      '[{"name":"internalapi","namespace":"openstack"}]'
      {% else -%}
      '[{"name":"internalapi","namespace":"openstack","default-route":["{{ internalapi_prefix | default('172.17.0') }}.1"]}]'
      {% endif -%}
  ansible.builtin.shell: |-
    {{ oc_header }}
    {{ mariadb_copy_shell_vars_src }}

    oc apply -f - <<EOF
    ---
    apiVersion: v1
    kind: PersistentVolumeClaim
    metadata:
      name: mariadb-data
    spec:
      storageClassName: $STORAGE_CLASS
      accessModes:
        - ReadWriteOnce
      resources:
        requests:
          storage: 10Gi
    ---
    apiVersion: v1
    kind: Pod
    metadata:
      name: mariadb-copy-data
      annotations:
        openshift.io/scc: anyuid
        k8s.v1.cni.cncf.io/networks: {{ copy_pods_custom_networks | default(internalapi_default_nad) }}
      labels:
        app: adoption
    spec:
      {{ copy_pods_custom_spec|default('') }}
      containers:
      - image: $MARIADB_IMAGE
        command: [ "sh", "-c", "sleep infinity"]
        name: adoption
        volumeMounts:
        - mountPath: /backup
          name: mariadb-data
      securityContext:
        allowPrivilegeEscalation: false
        capabilities:
          drop: ALL
        runAsNonRoot: true
        seccompProfile:
          type: RuntimeDefault
      volumes:
      - name: mariadb-data
        persistentVolumeClaim:
          claimName: mariadb-data
    EOF
  changed_when: true
  notify: delete adoption mariadb helper pod and pvc

- name: wait for the pod to come up
  ansible.builtin.shell: |
    {{ shell_header }}
    {{ oc_header }}
    oc wait --for condition=Ready pod/mariadb-copy-data --timeout=10s
  register: mariadb_data_pod_result
  until: mariadb_data_pod_result is success
  retries: 25
  delay: "{{ mariadb_retry_delay }}"

- name: wait until podified MariaDB is reachable
  no_log: "{{ use_no_log }}"
  ansible.builtin.shell: |
    {{ oc_header }}
    {{ mariadb_copy_shell_vars_dst }}
    oc rsh mariadb-copy-data mysql -rsh "${PODIFIED_MARIADB_IP['super']}" \
      -uroot -p"${PODIFIED_DB_ROOT_PASSWORD['super']}" -e 'select 1;'
  register: _podified_db_check
  retries: 60
  delay: 3
  until: _podified_db_check.rc == 0
  changed_when: false

- name: check that the Galera database cluster(s) members are online and synced, for all cells
  no_log: "{{ use_no_log }}"
  ansible.builtin.shell: |
    {{ oc_header }}
    {{ mariadb_members_env }}
    {{ mariadb_copy_shell_vars_src }}
    for CELL in $(echo $CELLS); do
      MEMBERS=SOURCE_GALERA_MEMBERS_$(echo ${CELL}|tr '[:lower:]' '[:upper:]')[@]
      for i in "${!MEMBERS}"; do
        echo "Checking for the database node $i WSREP status Synced"
        oc rsh mariadb-copy-data mysql \
          -h "$i" -uroot -p"${SOURCE_DB_ROOT_PASSWORD[$CELL]}" \
          -e "show global status like 'wsrep_local_state_comment'" | \
          grep -qE "\bSynced\b"
      done
    done

- name: Get the count of not-OK source databases
  no_log: "{{ use_no_log }}"
  ansible.builtin.shell: |
    for CELL in $(echo $CELLS); do
    set +u
      . ~/.source_cloud_exported_variables_$CELL
    set -u
    done
    test -z "$PULL_OPENSTACK_CONFIGURATION_MYSQLCHECK_NOK"  || [ "x$PULL_OPENSTACK_CONFIGURATION_MYSQLCHECK_NOK" = "x " ] && echo "OK" || echo "CHECK FAILED"
  register: result
  failed_when: result.rc != 0 or 'CHECK FAILED' in result.stdout

- name: test connection to podified DBs (show databases)
  no_log: "{{ use_no_log }}"
  ansible.builtin.shell:
    cmd: "{{ lookup('ansible.builtin.template', 'pre_checks.bash') }}"

- name: dump databases
  no_log: "{{ use_no_log }}"
  ansible.builtin.shell:
    cmd: "{{ lookup('ansible.builtin.template', 'dump_dbs.bash') }}"

- name: restore databases
  no_log: "{{ use_no_log }}"
  ansible.builtin.shell:
    cmd: "{{ lookup('ansible.builtin.template', 'restore_dbs.bash') }}"

- name: Verify MariaDB data imported
  ansible.builtin.include_tasks:
    file: mariadb_verify.yaml