fix(migration): migrate all versions

Signed-off-by: Rajesh Rajendran <rjshrjndrn@gmail.com>

scripts/helmcharts/openreplay/files/clickhouse.sh

@@ -1,13 +1,13 @@
 #!/bin/bash
 
-set -e
+set -ex
 
 clickhousedir=/opt/openreplay/openreplay/scripts/helm/db/init_dbs/clickhouse
 
 function migrate() {
     echo "Starting clickhouse migration"
-    migration_versions=$1
-    for version in $migration_versions; do
+    IFS=',' read -r -a migration_versions <<< "$1"
+    for version in ${migration_versions[*]}; do
         echo "Migrating clickhouse version $version"
         # For now, we can ignore the clickhouse db inject errors.
         # TODO: Better error handling in script

scripts/helmcharts/openreplay/files/dbops.sh

@@ -27,22 +27,24 @@ function migration() {
     # Checking migration versions
     cd /opt/openreplay/openreplay/scripts/helm
     migration_versions=(`ls -l db/init_dbs/$db | grep -E ^d | awk -v number=${PREVIOUS_APP_VERSION} '$NF > number {print $NF}' | grep -v create`)
-    echo "Migration version: $migration_versions"
+    echo "Migration version: ${migration_versions[*]}"
+    # Can't pass the space seperated array to ansible for migration. So joining them with ,
+    joined_migration_versions=$(IFS=, ; echo "${migration_versions[*]}")
     
     cd -
 
     case "$1" in
         postgresql)
-            /bin/bash postgresql.sh migrate $migration_versions
+            /bin/bash postgresql.sh migrate $joined_migration_versions
             ;;
         minio)
-            /bin/bash minio.sh migrate $migration_versions
+            /bin/bash minio.sh migrate $joined_migration_versions
             ;;
         clickhouse)
-            /bin/bash clickhouse.sh migrate $migration_versions
+            /bin/bash clickhouse.sh migrate $joined_migration_versions
             ;;
         kafka)
-            /bin/bash kafka.sh migrate $migration_versions
+            /bin/bash kafka.sh migrate $joined_migration_versions
             ;;
         *)
             echo "Unknown operation for db migration; exiting."

scripts/helmcharts/openreplay/files/postgresql.sh

@@ -1,6 +1,6 @@
 #!/bin/bash
 
-set -e
+set -ex
 
 pgdir=/opt/openreplay/openreplay/scripts/helm/db/init_dbs/postgresql
 
@@ -14,8 +14,8 @@ pgdir=/opt/openreplay/openreplay/scripts/helm/db/init_dbs/postgresql
 
 function migrate() {
     echo "Starting postgresql migration"
-    migration_versions=$1
-    for version in $migration_versions; do
+    IFS=',' read -r -a migration_versions <<< "$1"
+    for version in ${migration_versions[*]}; do
         echo "Migrating postgresql version $version"
         psql -f ${pgdir}/${version}/${version}.sql
     done