### Definitions

unset $ns $cr $nodes $fnode $vectorpath $checkpoints

ns="openshift-logging"
cr="collector"
nodes=$(oc get nodes -o jsonpath={.items[*].metadata.name}) 
fnode=$(oc get nodes -o jsonpath={.items[0].metadata.name})
vectorpath="/var/lib/vector"

### Create directories
echo "### Create directories ###"
for node in $(echo $nodes); do echo "  ### node: $node ###"; oc debug node/$node -- chroot /host /bin/bash -c "mkdir -p $vectorpath/$ns/$cr && chmod -R 755 $vectorpath/$ns" 2>/dev/null; done

### Get the checkpoints
echo "### Get the checkpoints ###"
checkpoints=$(for node in $(echo $fnode); do oc debug node/$node -- chroot /host /bin/bash -c "cd $vectorpath; ls -d raw*" 2>/dev/null ; done)
echo "checkpoints: $checkpoints"

### Copy the Vector checkpoints from 5.8 to 6
echo "### Copy the checkpoints ###"
for checkpoint in $(echo $checkpoints)
  do
    checkpointdef=$(echo $checkpoint |sed "s/raw/input/")
    for node in $(echo $nodes)
      do 
	echo "  ### node: $node ###"
        oc debug node/$node -- chroot /host /bin/bash -c "mkdir -v $vectorpath/$ns/$cr/$checkpointdef && cp -avR  $vectorpath/$checkpoint/* /var/lib/vector/$ns/$cr/$checkpointdef/" 2>/dev/null
      done
  done

## Adapt path names from Logging v5 to Logging v6
echo "### Rename the checkpoints ###"
for node in $(echo $nodes)
  do
    echo "  ### node: $node ###"
    oc debug node/$node -- chroot /host /bin/bash -c "cd $vectorpath/$ns/$cr/; mv input_container_logs input_application_container ; mv input_host_audit_logs  input_audit_host ; mv input_journal_logs input_infrastructure_journal ; mv input_k8s_audit_logs input_audit_kube ; mv input_openshift_audit_logs input_audit_openshift ; mv input_ovn_audit_logs input_audit_ovn" 2>/dev/null
  done